--- loncom/lond	2000/05/01 20:22:39	1.11
+++ loncom/lond	2000/06/26 02:42:28	1.12
@@ -5,7 +5,7 @@
 # 7/8,7/9,7/10,7/12,7/17,7/19,9/21,
 # 10/7,10/8,10/9,10/11,10/13,10/15,11/4,11/16,
 # 12/7,12/15,01/06,01/11,01/12,01/14,2/8,
-# 03/07 Gerd Kortemeyer
+# 03/07,05/31 Gerd Kortemeyer
 # based on "Perl Cookbook" ISBN 1-56592-243-3
 # preforker - server who forks first
 # runs as a daemon
@@ -184,6 +184,28 @@ sub reply {
   return $answer;
 }
 
+sub sqlreply {
+    my ($cmd)=@_;
+    my $answer=subsqlreply($cmd);
+    if ($answer eq 'con_lost') { $answer=subsqlreply($cmd); }
+    return $answer;
+}
+
+sub subsqlreply {
+    my ($cmd)=@_;
+    my $unixsock="mysqlsock";
+    my $peerfile="$perlvar{'lonSockDir'}/$unixsock";
+    my $sclient=IO::Socket::UNIX->new(Peer    =>"$peerfile",
+                                      Type    => SOCK_STREAM,
+                                      Timeout => 10)
+       or return "con_lost";
+    print $sclient "$cmd\n";
+    my $answer=<$sclient>;
+    chomp($answer);
+    if (!$answer) { $answer="con_lost"; }
+    return $answer;
+}
+
 # -------------------------------------------- Return path to profile directory
 
 sub propath {
@@ -526,6 +548,21 @@ sub make_new_child {
 		       } else {
                         print $client "rejected\n";
 		       }
+# ------------------------------------------------------------------------- log
+                   } elsif ($userinput =~ /^log/) {
+                       my ($cmd,$udom,$uname,$what)=split(/:/,$userinput);
+                       chomp($what);
+                       my $proname=propath($udom,$uname);
+                       my $now=time;
+                       {
+			 my $hfh;
+			 if ($hfh=IO::File->new(">>$proname/activity.log")) { 
+                            print $hfh "$now:$hostid{$clientip}:$what\n";
+                            print $client "ok\n"; 
+			} else {
+                            print $client "error:$!\n";
+		        }
+		       }
 # ------------------------------------------------------------------------- put
                    } elsif ($userinput =~ /^put/) {
                       my ($cmd,$udom,$uname,$namespace,$what)
@@ -795,6 +832,24 @@ sub make_new_child {
                        } else {
                            print $client "error:$!\n";
                        }
+# ------------------------------------------------------------------- querysend
+                   } elsif ($userinput =~ /^querysend/) {
+                       my ($cmd,$query)=split(/:/,$userinput);
+                       # make sure you get one \n and only one
+		       $query=~s/\n*$//g;
+                       print $client sqlreply("$hostid{$clientip}\&$query")."\n";
+# ------------------------------------------------------------------ queryreply
+                   } elsif ($userinput =~ /^queryreply/) {
+                       my ($cmd,$id,$reply)=split(/:/,$userinput); 
+		       my $store;
+                       if ($store=IO::File->new(">/tmp/$id")) {
+			   print $store $reply;
+			   close $store;
+			   print $client "ok\n";
+		       }
+		       else {
+			   print $client "error:$!\n";
+		       }
 # ----------------------------------------------------------------------- idput
                    } elsif ($userinput =~ /^idput/) {
                        my ($cmd,$udom,$what)=split(/:/,$userinput);