Beefy Boxes and Bandwidth Generously Provided by pair Networks
Come for the quick hacks, stay for the epiphanies.
 
PerlMonks  

Re: New to perl: IO Select question :(

by pg (Canon)
on Aug 21, 2005 at 00:32 UTC ( [id://485452]=note: print w/replies, xml ) Need Help??


in reply to New to perl: IO Select question :(

You never had the opportunity to accept any connection from the client side. Add $sock to IO::Select is no good, as it is not an "active channel" yet. Add the accept(), plus fix some minor syntax stuff, your code works.

use strict; use warnings; use IO::Socket; use IO::Select; my $sock = IO::Socket::INET->new( Proto=>"tcp", LocalHost=>"localhost", Listen=>16, Reuse=>1, LocalPort=>3000 ) or die("Could not create socket!\n") +; my $connection = $sock->accept(); my $readSet = new IO::Select(); $readSet->add($connection); while(1) { my @rhSet = IO::Select->select($readSet, undef, undef, 0); foreach my $rh (@{$rhSet[0]}) { my $buf=<$rh>; if($buf) { printf "$buf"; } else { $readSet->remove($rh); close($rh); } } }

Client side test code:

use IO::Socket; my $sock = IO::Socket::INET->new( Proto=>"tcp", PeerHost=>"localhost", PeerPort=>3000 ) or die("Could not create socket!\n") +; print $sock "abcd\n";

Well, I leave it to you to add back the code to accept further connections.

Replies are listed 'Best First'.
Re^2: New to perl: IO Select question :(
by Crackers2 (Parson) on Aug 21, 2005 at 03:17 UTC

    I don't think you're right on this one. His code works fine as long as you just replace

    my @rhSet = IO::Select->select($readSet, undef, undef, 0); foreach my $rh (@{$rhSet[0]}) {

    with (as in your example)
    my @rhSet = IO::Select->select($readSet, undef, undef, 0); foreach my $rh (@{$rhSet[0]}) {

    The

    my $connection = $sock->accept(); $readSet->add($connection);
    you added are not needed, and I'd personally consider doing that more harmful than useful.

    I also don't understand your comment about $sock not being an "active channel". After you create a server socket you can add it to the read set perfectly fine, and the select will return the socket when there's a connection to accept.

      For server side, one cares whether each connection can read or write, not the listening server socket. The listening socket does not read or write.

      Let's do a simple testing. With the following client and server:

      #server use strict; use warnings; use IO::Socket; use IO::Select; my $sock = IO::Socket::INET->new(Proto=>"tcp", LocalHost=>"localhost", + Listen=>16, Reuse=>1, LocalPort=>3000) || die("Could not create socket!\n"); my $conn = $sock->accept(); my $sel = new IO::Select($sock); if ($sel->can_read()) { print "can read\n"; } #client use IO::Socket; my $sock = IO::Socket::INET->new( Proto=>"tcp", PeerHost=>"Localhost", PeerPort=>3000 ) or die("Could not create socket!\n") +; print $sock "abcd\n";

      Run perl -w server.pl in one window, then run perl -w client.pl in another window, nothing gets printed in the server window! run perl -w client.pl again, "abcd" gets printed. This is not what one will want.

      change server code:

      use strict; use warnings; use IO::Socket; use IO::Select; my $sock = IO::Socket::INET->new(Proto=>"tcp", LocalHost=>"localhost", + Listen=>16, Reuse=>1, LocalPort=>3000) || die("Could not create socket!\n"); my $conn = $sock->accept(); my $sel = new IO::Select($conn); if ($sel->can_read()) { print "can read\n"; }

      The first time you run perl -w client.pl, server side knows that it can read, and prints "abcd". That's what one wants.

        For server side, one cares whether each connection can read or write, not the listening server socket. The listening socket does not read or write.

        This is false, and your example is not analogous to the original post. A listening socket becomes readable when a connection is ready to be accept()ed. His code correctly tests the listening socket and all open client connections, reacting to a readable state on the listening socket with an accept(), and on all other sockets with a read. (The read isn't quite right since it blocks waiting for a full line, but the intent is fairly clear.)

        Your version blocks on an extraneous accept() before hitting the select(), and is unable to ever accept any more connections. Your "simple testing" fails because it doesn't select on the listening socket until after it pulls the first connection off of it. So, yes, that select() doesn't fall through until a second connection comes in. His code doesn't have that flaw.

Log In?
Username:
Password:

What's my password?
Create A New User
Domain Nodelet?
Node Status?
node history
Node Type: note [id://485452]
help
Chatterbox?
and the web crawler heard nothing...

How do I use this?Last hourOther CB clients
Other Users?
Others wandering the Monastery: (None)
    As of 2024-04-19 00:22 GMT
    Sections?
    Information?
    Find Nodes?
    Leftovers?
      Voting Booth?

      No recent polls found