… | |
… | |
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 { |