Discussion :

[bn0550]

Bonjour,

Y a-til une classe .NET permettant d'avoir un Stream partagé entre 2 threads
- un qui écrit des données
- un qui lit les données

.. ce qui se fait en Java de cette manière

pin = new PipedInputStream();
pout = new PipedOutputStream((PipedInputStream)pin);



Merci

[François DORIN]

Bonjour,
presque la même chose :

• AnonymousPipeServerStream / AnonymousPipeClientStream
• NamedPipeServerStream / NamedPipeClientStream

Ces streams sont utilisables pour des communications interprocess, donc valable également pour des communications interthreads.

[bn0550]

Bonjour,

J'avais effectivement vu ces classes mais cela me paraissait lourd ?
Je vais essayer

Merci

[Pol63]

tout peut être partagé entre 2 threads, je ne vois pas pourquoi il faudrait quelque chose de spécial
même un event ca conviendrait surement
dans le pire des cas quelque chose avec un lock

[François DORIN]

Des accès concurrents nécessitent des précautions d'usage. Sinon, c'est une source de bogue plus ou moins fréquent extrêmement difficile à diagnostiquer.

Pour un stream, il faut quelque chose de spéciale, car les flux de lecture et d'écriture ne vont pas évoluer de la même manière. Même si on a un stream qui est à la fois accessible en lecture et en écriture (comme MemoryStream), mélanger une opération de lecture avec une d'écriture (sans même parler d'accès concurrents), c'est le meilleur moyen d'avoir un bazar monstre, car la lecture du flux va modifier la position courante, qui ne sera plus bonne pour l'écriture et vice-versa. Et dans le cas d'accès concurrents, un lock seul ne suffira pas, d'où la nécessite d'avoir une structure particulière.

Après, c'est un problème "classique" de producteur / consommateur. Est-ce que le stream est le plus adéquat ici ? Aucune idée, puisqu'on ne sait pas la nature des données qui transitent par le flux. Mais cette question sort du cadre de cette discussion.

[bn0550]

Bonjour,

Voici les tests que je viens de réaliser.
Le second test ne fonctionne pas... avez vous une piste ?

Le but final est de rendre disponible ce qui est lu du serveur SSH comme input pour un autre traitement (CopyTo par exemple)


Ce premier test fonctionne sans les pipes

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
 
using (MemoryStream o = new MemoryStream())
            {                
                using (SftpFileStream pin = client.OpenRead("/toto/fichier.txt"))
                {
                    pin.CopyTo(o);
                }
                byte[] res = o.ToArray();
            }

Ce second exemple ne fonctionne pas, cela bloque au niveau du Join.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
 
using (AnonymousPipeServerStream pipein = new AnonymousPipeServerStream(PipeDirection.In))
            {
                using (AnonymousPipeClientStream pipeout = new AnonymousPipeClientStream(PipeDirection.Out,
                    pipein.GetClientHandleAsString()))
                {
                    byte[] res;
                    Thread t = new Thread(() =>
                    {
                        using (MemoryStream x = new MemoryStream())
                        {
                            pipein.CopyTo(x);
                            res = x.ToArray();
                        }
                    });
                    t.Start();
 
                    using (SftpFileStream pin = client.OpenRead("/toto/fichier.txt"))
                    {
                        pin.CopyTo(pipeout);
                    }
 
                    t.Join();
                }
            }

client vient de la lib SSH.net

Merci

[bn0550]

Voici un exemple plus simple qui ne fonctionne pas
Avez-vous une idée ?

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

 Console.WriteLine("> " + text2);

n'est jamais appelé
Cela bloque au niveau du Join

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
using (AnonymousPipeServerStream pipeout = new AnonymousPipeServerStream(PipeDirection.Out))
            {
                using (AnonymousPipeClientStream pipein = new AnonymousPipeClientStream(PipeDirection.In,
                    pipeout.GetClientHandleAsString()))
                {
 
                    byte[] res;
                    Thread t = new Thread(() =>
                    {
                        using (MemoryStream x = new MemoryStream())
                        {
 
                            pipein.CopyTo(x);
                            res = x.ToArray();
                            string text2 = Encoding.UTF8.GetString(res);
                            Console.WriteLine("> " + text2);
 
 
                        }
                    });
                    t.Start();
 
                    string text = "hello !";
                    using (MemoryStream x = new MemoryStream(Encoding.UTF8.GetBytes(text)))
                    {
                        x.CopyTo(pipeout);
                    }
 
 
                    t.Join();
                }               
            }

[Pol63]

peut tu détailler un peu ce que tu veux faire transiter ? juste des strings ? des instances de classes contenant des données typées ?
c'est un truc sans fin (qui peut écrire plein de choses n'importe quand et chaque chose doit être traitée au fur et à mesure par une autre portion de code ?) ou juste une fois ?
ce sont 2 classes qui sont des threads différents ? des threads qui while true ?
y a 50 moyens de faire ça simplement, on va bien t'en trouver un ^^

[François DORIN]

Le problème vient de l'usage de CopyTo. CopyTo copie des informations tant que le stream est ouvert. Ici, rajouter un pipeout.Close() fermera le flux après y avoir écrit, permettant au reste du programme de tourner correctement.

[bn0550]

C'est effectivement ce que j'avais vu.
Merci