Discussion :

[Balbuzard]

Bonjour à tous;

J'ai un processus perl qui reçoit des données d'un pipe et les traite.
Je dois rajouter des données venant du réseau.
J'ai construit un serveur TCP qui fait bien le travail, indépendamment du premier processus, et c'est dommage, car les deux processus travaillent sur des données qui peuvent être identiques.
Donc j'ai pensé à inclure ce serveur dans le premier processus pour qu'il puisse vérifier si les données qu'il reçoit du réseau sont déjà présentes, et dans ce cas, les droper.

Voici mon code:

Code :

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

1
2
3
4
5
my $server = server->new();
my $thread = threads->create(sub {$server->server();});
my $thread2 = threads->create(sub {
while(<STDIN>) {
    ...instructions et traitement des données ...

Donc je lance le processus. Il se lance correctement et fait les tâches de traitement des données venant du pipe.
Je me connecte en telnet. La connexion se fait sans problème. Mais les données que j'envoie au serveur ne sont pas traitées.

Code :

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

1
2
3
4
5
6
7
8
9
sub server {
	my($self) = @_;
	while (my $client = $serveur->accept()) {
		next if my $pid = fork;
		print "\n*** Connected ***\n"; # -> ça s'affiche bien
		print "--- I am PID $$ ---\n"; # ça s'affiche aussi
		my $message = "";
		while( my $rep = <$client> ) {
			print "oui\n"; # -> ça ne s'affiche pas

Je pense que la ligne blocante est celle en gras. Mais je ne vois pas de moyen de m'en sortir du coup: Si la méthode accept est blocante, je ne peux jamais mettre ça dans un thread :-S Il doit bien y avoir une solution? Ce problème me parait basique, mais google ne m'a pas trop aidé :-S
Merci pour vos conseils/remarques/suggestions!

[Philou67430]

Je t'invite alors à utilise IO::Select (si tu n'es pas sur une plateforme Windows/ActiveState). Avec cet objet, tu peux configurer plusieurs handle et utiliser la méthode can_read afin de savoir, apriori, si tu peux lire quelque chose sur un handle.

Je recherche le fil où l'on en a parlé récemment.

[Philou67430]

La limitation d'ActivePerl pour IO::Select concerne STDIN. Voir ici, ainsi que le fil complet dans lequel je donne une exemple fonctionnel de client de tchat qui accepte une connexion socket et clavier.

[Balbuzard]

Hello,Philou67430!
Merci pour ta réponse;

Je me suis demandé si le processus de fork n'était pas plus intéressant; mais j'ai pile le même problème :-S

Donc pour le IO::Select:
Je me demande en quoi ça résout le problème de blocage lors du socket->accept()?

[Philou67430]

Mmmh... bonne question. En fait, je n'avais pas vu que ton blocage se situait à ce niveau.
Mais la réponse est en fait simple : en lisant la doc de IO::Select->accept, il est indiqué qu'une simple utilisation de select avec un timeout de 0 permet de résoudre ce problème :

accept([PKG])
perform the system call "accept" on the socket and return a new
object. The new object will be created in the same class as the
listen socket, unless "PKG" is specified. This object can be used
to communicate with the client that was trying to connect.

In a scalar context the new socket is returned, or undef upon
failure. In a list context a two-element array is returned
containing the new socket and the peer address; the list will be
empty upon failure.

The timeout in the [PKG] can be specified as zero to effect a
"poll", but you shouldn't do that because a new IO::Select object
will be created behind the scenes just to do the single poll. This
is horrendously inefficient. Use rather true select() with a zero
timeout on the handle, or non-blocking IO.

[Philou67430]

Quoique, si l'usage de select te rebute, il me semble que rien ne t'empêche d'utiliser IO::Select pour vérifier à priori si $serveur contient à socket à accepter :

Code :

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

1
2
3
4
5
6
7
my $sel = IO::Select->new($serveur);
 
while () {
  if ($sel->can_read() && my $client = $serveur->accept()) {
  }
  ...
}

Par ailleurs, en te relisant, tu indiquais que la ligne grasse était la ligne bloquante. Je suis confus