--- loncom/lond 2007/03/12 22:24:58 1.362 +++ loncom/lond 2007/03/28 00:05:38 1.363 @@ -2,7 +2,7 @@ # The LearningOnline Network # lond "LON Daemon" Server (port "LOND" 5663) # -# $Id: lond,v 1.362 2007/03/12 22:24:58 albertel Exp $ +# $Id: lond,v 1.363 2007/03/28 00:05:38 albertel Exp $ # # Copyright Michigan State University Board of Trustees # @@ -59,7 +59,7 @@ my $DEBUG = 0; # Non zero to ena my $status=''; my $lastlog=''; -my $VERSION='$Revision: 1.362 $'; #' stupid emacs +my $VERSION='$Revision: 1.363 $'; #' stupid emacs my $remoteVERSION; my $currenthostid="default"; my $currentdomainid; @@ -5309,15 +5309,36 @@ sub reconlonc { } } -# -------------------------------------------------- Non-critical communication +sub create_connection { + my ($server) = @_; + my $client=IO::Socket::UNIX->new(Peer => $perlvar{'lonSockCreate'}, + Type => SOCK_STREAM, + Timeout => 10); + return 0 if (!$client); + print $client ("$server\n"); + my $result = <$client>; + chomp($result); + return 1 if ($result eq 'done'); + return 0; +} +# -------------------------------------------------- Non-critical communication +my $max_connection_retries = 10; sub subreply { my ($cmd,$server)=@_; my $peerfile="$perlvar{'lonSockDir'}/".$hostname{$server}; - my $sclient=IO::Socket::UNIX->new(Peer =>"$peerfile", - Type => SOCK_STREAM, - Timeout => 10) - or return "con_lost"; + my $sclient; + for (my $retries = 0; $retries < $max_connection_retries; $retries++) { + $sclient=IO::Socket::UNIX->new(Peer =>"$peerfile", + Type => SOCK_STREAM, + Timeout => 10); + if($sclient) { + last; # Connected! + } else { + &create_connection($hostname{$server}); + } + sleep(1); # Try again later if failed connection. + } print $sclient "sethost:$server:$cmd\n"; my $answer=<$sclient>; chomp($answer);