--- loncom/Attic/lonc	2001/11/26 22:20:26	1.18
+++ loncom/Attic/lonc	2001/11/29 18:57:46	1.22
@@ -5,6 +5,30 @@
 # provides persistent TCP connections to the other servers in the network
 # through multiplexed domain sockets
 #
+# $Id: lonc,v 1.22 2001/11/29 18:57:46 www Exp $
+#
+# Copyright Michigan State University Board of Trustees
+#
+# This file is part of the LearningOnline Network with CAPA (LON-CAPA).
+#
+# LON-CAPA is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 2 of the License, or
+# (at your option) any later version.
+#
+# LON-CAPA is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with LON-CAPA; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+#
+# /home/httpd/html/adm/gpl.txt
+#
+# http://www.lon-capa.org/
+#
 # PID in subdir logs/lonc.pid
 # kill kills
 # HUP restarts
@@ -16,7 +40,7 @@
 # 12/05 Scott Harrison
 # 12/05 Gerd Kortemeyer
 # 01/10/01 Scott Harrison
-# 03/14/01,03/15,06/12,11/26 Gerd Kortemeyer
+# 03/14/01,03/15,06/12,11/26,11/27,11/28 Gerd Kortemeyer
 # 
 # based on nonforker from Perl Cookbook
 # - server who multiplexes without forking
@@ -182,10 +206,20 @@ sub subreply {
                                       Type    => SOCK_STREAM,
                                       Timeout => 10)
        or return "con_lost";
-    print $sclient "$cmd\n";
-    my $answer=<$sclient>;
-    chomp($answer);
-    if (!$answer) { $answer="con_lost"; }
+
+
+    $SIG{ALRM}=sub { die "timeout" };
+    $SIG{__DIE__}='DEFAULT';
+    eval {
+     alarm(10);
+     print $sclient "$cmd\n";
+     $answer=<$sclient>;
+     chomp($answer);
+     alarm(0);
+    };
+    if ((!$answer) || ($@=~/timeout/)) { $answer="con_lost"; }
+    $SIG{ALRM}='DEFAULT';
+    $SIG{__DIE__}=\&catchexception;
  } else { $answer='self_reply'; }
  return $answer;
 }
@@ -344,15 +378,30 @@ unless (
        sleep($st);
        exit; 
      };
-# --------------------------------------- Send a ping to make other end do USR1
+# ----------------------------------------------------------------- Init dialog
 
 &status("Init dialogue: $conserver");
 
+     $SIG{ALRM}=sub { die "timeout" };
+     $SIG{__DIE__}='DEFAULT';
+     eval {
+         alarm(60);
 print $remotesock "init\n";
 $answer=<$remotesock>;
 print $remotesock "$answer";
 $answer=<$remotesock>;
 chomp($answer);
+          alarm(0);
+     };
+     $SIG{ALRM}='DEFAULT';
+     $SIG{__DIE__}=\&catchexception;
+ 
+     if ($@=~/timeout/) {
+	 &logthis("Timed out during init: $conserver");
+         exit;
+     }
+
+
 &logthis("Init reply for $conserver: >$answer<");
 if ($answer ne 'ok') {
        my $st=120+int(rand(240));
@@ -422,11 +471,19 @@ if ($cipher=new IDEA $cipherkey) {
             }
             $cmd="enc:$cmdlength:$encrequest\n";
         }
-
+    $SIG{ALRM}=sub { die "timeout" };
+    $SIG{__DIE__}='DEFAULT';
+    eval {
+        alarm(60);
         print $remotesock "$cmd\n";
         $answer=<$remotesock>;
 	chomp($answer);
-        if ($answer ne '') {
+        alarm(0);
+    };
+    $SIG{ALRM}='DEFAULT';
+    $SIG{__DIE__}=\&catchexception;
+
+        if (($answer ne '') && ($@!~/timeout/)) {
 	    unlink("$dfname");
             &logthis("Delayed $cmd to $conserver: >$answer<");
             &logperm("S:$conserver:$bcmd");
@@ -576,11 +633,27 @@ sub handle {
             }
             $request="enc:$cmdlength:$encrequest\n";
         }
+# --------------------------------------------------------------- Main exchange
+    $SIG{ALRM}=sub { die "timeout" };
+    $SIG{__DIE__}='DEFAULT';
+    eval {
+        alarm(300);
         &status("Sending $conserver: $request");
         print $remotesock "$request";
         &status("Waiting for reply from $conserver: $request");
         $answer=<$remotesock>;
         &status("Received reply: $request");
+        alarm(0);
+    };
+    if ($@=~/timeout/) { 
+       $answer='';
+       &logthis(
+        "<font color=red>CRITICAL: Timeout $conserver: $request</font>");
+    }  
+    $SIG{ALRM}='DEFAULT';
+    $SIG{__DIE__}=\&catchexception;
+
+
         if ($answer) {
 	   if ($answer =~ /^enc/) {
                my ($cmd,$cmdlength,$encinput)=split(/:/,$answer);