start of AnyEvent conversion
[spider.git] / perl / Msg.pm
index 6805e008a770368b33e801c127fc721fc51187bf..5aebab650caac475f3b05600ff2a2e7e3d46f35b 100644 (file)
@@ -14,7 +14,6 @@ use strict;
 
 use DXUtil;
 
-use IO::Select;
 use DXDebug;
 use Timer;
 
@@ -224,10 +223,10 @@ sub connect {
        
        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
-               my $sock = $io_socket->new();
+               $sock = $io_socket->new();
                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);
-               shutdown($sock, 3);
+               shutdown($sock, 2);
                close($sock);
        }