--- projects/cms/source/host/ihost-perl/ihost.pl 2001/02/27 19:26:51 1.18 +++ projects/cms/source/host/ihost-perl/ihost.pl 2001/03/01 18:53:42 1.23 @@ -10,7 +10,7 @@ # - pjm2@ukc.ac.uk # # $Author: pjm2 $ -# $Id: ihost.pl,v 1.18 2001/02/27 19:26:51 pjm2 Exp $ +# $Id: ihost.pl,v 1.23 2001/03/01 18:53:42 pjm2 Exp $ #------------------------------------------------------------ $| = 1; @@ -86,7 +86,7 @@ sub tcp_configure() { PeerAddr => $filter_manager_addr, PeerPort => $filter_manager_port, Proto => 'tcp' - ); + ) or die "Cannot connect!"; if (!defined $sock) { print "IHOST ERROR: Could not connect to $filter_manager_addr:$filter_manager_port.\n"; print "Please check that there is an i-scream server at this address.\n"; @@ -209,8 +209,7 @@ sub send_udp_packet() { } $disk_info .= ""; - my($machine_name) = hostname(); - my($ip) = inet_ntoa(scalar(gethostbyname($machine_name)) || 'localhost'); + my($ip) = inet_ntoa(scalar(gethostbyname(hostname())) || 'localhost'); # Build the XML packet this way, as we can clearly # see the structure and contents... I like this ;-) @@ -218,7 +217,7 @@ sub send_udp_packet() { # larger than 8196 bytes] my($xml) = < + $packet{"packet.load.load1"} $packet{"packet.load.load5"} @@ -265,12 +264,12 @@ EOF # Make the packet smaller by stripping out newlines and leading spaces. $xml =~ s/\n\s*//g; - + my($sock) = new IO::Socket::INET ( PeerPort => $udp_port, PeerAddr => $filter_addr, Proto => 'udp' - ) or die "Socket: $!\n"; + ) or die "Could not send UDP: $!\n"; print $sock $xml or die "Could not send UDP packet: $!\n"; close($sock); @@ -294,7 +293,7 @@ sub send_tcp_heartbeat() { PeerAddr => $filter_addr, PeerPort => $tcp_port, Proto => 'tcp' - ); + ) or return; if (!defined $sock) { print "IHOST WARNING: Failed to deliver a heartbeat to the i-scream filter.\n"; return; @@ -305,6 +304,7 @@ sub send_tcp_heartbeat() { print $sock "HEARTBEAT\n"; $response = <$sock>; + return if (!defined $response); chop $response; if (!$response eq "OK") { close($sock); @@ -314,6 +314,7 @@ sub send_tcp_heartbeat() { print $sock "CONFIG\n"; $response = <$sock>; + return if (!defined $response); chop $response; if (!$response eq "OK") { close($sock); @@ -323,6 +324,7 @@ sub send_tcp_heartbeat() { print $sock "$file_list\n"; $response = <$sock>; + return if (!defined $response); chop $response; if (!$response eq "OK") { close($sock); @@ -332,6 +334,7 @@ sub send_tcp_heartbeat() { print $sock "$last_modified\n"; $response = <$sock>; + return if (!defined $response); chop $response; if ($response eq "ERROR") { close($sock); @@ -346,6 +349,7 @@ sub send_tcp_heartbeat() { print $sock "ENDHEARTBEAT\n"; $response = <$sock>; + return if (!defined $response); chop $response; if (!$response eq "OK") { close($sock);