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