Re^3: Problem handling 2 simultaneous socket streams

[zentara]

How would I go about adding in reading STDIN to allow a user to type quit to end this program?

See Re: Ask for STDIN but don't pause for it and the last example. This is untested in your code, but something like this will work. Just add \*STDIN to your Select object and test for it.

# Add listen sockets to select
my $sockets = new IO::Select();
$sockets->add(\*STDIN );
$sockets->add($stream1_lsn);
$sockets->add($client1_lsn);
$sockets->add($client2_lsn);

.....

#Go into infinite loop, handling connections - how do I end this?
while(my @ready = $sockets->can_read) { #got data
  
foreach my $socket (@ready) { # find which socket sent data
     
    if ($socket == \*STDIN) {  
            #read stdin and detect a q;
            exit;  }

[PhillyR]

Adding \*STDIN to the select causes the while loop not to execute...

[zentara]

Use sysread instead of reading <>, I mentioned it in comments in the script. And be sure to add a timeout value to your select loop.

 my $input;
 sysread( \*STDIN, $input, 1024);

Update: I forgot to mention you can set the nonblocking flag on STDIN

use Fcntl;
  
fcntl(\*STDIN, F_SETFL, O_NONBLOCK) || die "$!\n";
# Set the non-block flags

[PhillyR]

I tried several versions of adding \*STDIN to the select and using sysread but I finally got soo close by using a separate thread to run in a while(1) loop doing a sysread. However, now when the stream starts flowing it hangs after a while until I provide some input and then works normally. I tried setting the nonblock flag as you mention above but then I get a new error: Your vendor has not defined Fcntl macro F_SETFL. Any help with this?