| … | |
… | |
| 37 | }, sub { |
37 | }, sub { |
| 38 | warn "error on accept: $!"; |
38 | warn "error on accept: $!"; |
| 39 | $cv->broadcast; |
39 | $cv->broadcast; |
| 40 | }); |
40 | }); |
| 41 | |
41 | |
| 42 | my $clsock = |
|
|
| 43 | IO::Socket::INET->new ( |
|
|
| 44 | PeerHost => $sock->sockhost, |
|
|
| 45 | PeerPort => $sock->sockport, |
|
|
| 46 | Blocking => 0, |
|
|
| 47 | ); |
|
|
| 48 | |
|
|
| 49 | my $clhdl; |
42 | my $clhdl; |
| 50 | my $wc = AnyEvent::Util::connect ($clsock, sub { |
43 | my $wc = AnyEvent::Util::tcp_connect ($sock->sockhost, $sock->sockport, sub { |
| 51 | my ($clsock) = @_; |
44 | my ($clsock) = @_; |
| 52 | $clhdl = AnyEvent::Handle->new (fh => $clsock, on_eof => sub { $cv->broadcast }); |
45 | $clhdl = AnyEvent::Handle->new (fh => $clsock, on_eof => sub { $cv->broadcast }); |
| 53 | |
46 | |
| 54 | $clhdl->push_write ("TEST\015\012"); |
47 | $clhdl->push_write ("TEST\015\012"); |
| 55 | $clhdl->push_read_line (sub { |
48 | $clhdl->push_read_line (sub { |
