blocking($sock, 0);
my $ip = gethostbyname($to_host);
- my $r = $sock->connect($to_port, $ip);
+# my $r = $sock->connect($to_port, $ip);
+ my $r = connect($sock, pack_sockaddr_in($to_port, $ip));
unless ($r) {
return undef unless $! == EINPROGRESS;
}
$call ||= 'unallocated';
dbg('connll', "Connection $call disconnected");
- set_event_handler ($sock, read => undef, write => undef, error => undef);
-
unless ($^O =~ /^MS/i) {
kill 'TERM', $conn->{pid} if exists $conn->{pid};
}
}
return unless defined($sock);
+ set_event_handler ($sock, read => undef, write => undef, error => undef);
shutdown($sock, 3);
close($sock);
}
last unless ($rd_handles->count() || $wt_handles->count());
($rset, $wset) = IO::Select->select($rd_handles, $wt_handles, $er_handles, $timeout);
- $now = time;
foreach $e (@$eset) {
&{$er_callbacks{$e}}($e) if exists $er_callbacks{$e};