projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
start of AnyEvent conversion
[spider.git]
/
perl
/
Msg.pm
diff --git
a/perl/Msg.pm
b/perl/Msg.pm
index 6805e008a770368b33e801c127fc721fc51187bf..5aebab650caac475f3b05600ff2a2e7e3d46f35b 100644
(file)
--- a/
perl/Msg.pm
+++ b/
perl/Msg.pm
@@
-14,7
+14,6
@@
use strict;
use DXUtil;
use DXUtil;
-use IO::Select;
use DXDebug;
use Timer;
use DXDebug;
use Timer;
@@
-224,10
+223,10
@@
sub connect {
my $sock;
if ($blocking_supported) {
my $sock;
if ($blocking_supported) {
- $sock = $io_socket->new(PeerAddr => $to_host, PeerPort => $to_port, Proto => 'tcp', Blocking =>0);
+ $sock = $io_socket->new(PeerAddr => $to_host, PeerPort => $to_port, Proto => 'tcp', Blocking =>0)
or return undef
;
} else {
# Create a new internet socket
} else {
# Create a new internet socket
-
my
$sock = $io_socket->new();
+ $sock = $io_socket->new();
return undef unless $sock;
my $proto = getprotobyname('tcp');
return undef unless $sock;
my $proto = getprotobyname('tcp');
@@
-331,7
+330,7
@@
sub disconnect
if (defined($sock)) {
set_event_handler ($sock, read => undef, write => undef, error => undef);
if (defined($sock)) {
set_event_handler ($sock, read => undef, write => undef, error => undef);
- shutdown($sock,
3
);
+ shutdown($sock,
2
);
close($sock);
}
close($sock);
}