Here's my test code, I used two sockets,
The following codes work under WinXP, which from original thread by BrowserUK: Re: Sockets and threads, oh my!Any suggestion would be graceful! Thanks. Thanks, Yun## codes from BrowserUK #------------------------------------------------ # For server #------------------------------------------------ #!/usr/bin/env perl use strict; use warnings; use threads; use IO::Socket qw(:DEFAULT :crlf); my $port = 1985; my $socket = new IO::Socket::INET ( LocalPort => $port, Proto => 'tcp', Listen => 5, Reuse => 1, ) || die "Not able to create socket, $!\n"; my $client = $socket->accept(); my $arg = 1; ioctl( $client, 0x8004667e, \$arg ); my $listenerThread = threads->create(\&listener, $client) or die "$@\n ++"; while (<STDIN>){ chomp; print $client $_, CRLF; } exit(0); sub listener($) { my $s = shift; my $data; $/ = CRLF; while( 1 ) { ## try to read something. my $read = sysread($s, $data, 2048); ## Quit if sysread gave an error (returned undef) other than 1 +0035 ## 10035 => A non-blocking socket operation could not be comp +eted immediately last unless defined $read or 0+$^E == 10035; ## If there was nothing to read, sleep a while and retry #sleep 1 and redo unless $read; ## Got something, so display it syswrite(STDOUT, $data); } print "\nListener exiting\n"; }; #-------------------------------------------------- # For client #-------------------------------------------------- use strict; use warnings; use threads; use IO::Socket qw(:DEFAULT :crlf); my $host = shift || 'localhost'; my $socket = IO::Socket::INET->new( PeerAddr => $host, PeerPort => 1985, Proto => 'tcp', Type => SOCK_STREAM, Timeout => 5 ) or die "Couldn't connect to remote host: $@\n"; my $arg = 1; ioctl( $socket, 0x8004667e, \$arg ); my $listenerThread = threads->create(\&listener, $socket) or die "$@\n ++"; while (<STDIN>) { chomp; print $socket $_, CRLF; }; exit(0); sub listener($) { my $s = shift; my $data; $/ = CRLF; while( 1 ) { ## try to read something. my $read = sysread($s, $data, 2048); ## Quit if sysread gave an error (returned undef) other than 1 +0035 ## 10035 => A non-blocking socket operation could not be comp +eted immediately last unless defined $read or 0+$^E == 10035; ## If there was nothing to read, sleep a while and retry #sleep 1 and redo unless $read; ## Got something, so display it syswrite(STDOUT, $data); } print "\nListener exiting\n"; };
In reply to Sync messages for chatting peers by kzle
| For: | Use: | ||
| & | & | ||
| < | < | ||
| > | > | ||
| [ | [ | ||
| ] | ] |