Index: megatest.scm
==================================================================
--- megatest.scm
+++ megatest.scm
@@ -2662,9 +2662,13 @@
 	       (else (exit 3)))))
      )
 
 )
 
-(import megatest-main)
-(import commonmod)
-(main)
+(import megatest-main commonmod)
+(import srfi-18)
+
+(thread-join!
+ (thread-start!
+  (make-thread main)))
+
 

Index: ulex/ulex.scm
==================================================================
--- ulex/ulex.scm
+++ ulex/ulex.scm
@@ -94,11 +94,11 @@
   (work-proc  #f)                ;; set by user
   (cnum       0)                 ;; cookie number
   (mboxes     (make-hash-table)) ;; for the replies
   (avail-cmboxes '())            ;; list of (<cookie> . <mbox>) for re-use
   ;; threads
-  (numthreads 10)
+  (numthreads 50)
   (cmd-thread #f)
   (work-queue-thread #f)
   ) 
 
 ;; ;; struct for keeping track of others we are talking to
@@ -158,10 +158,12 @@
   (let* ((uconn (make-udat)))
     (udat-work-proc-set! uconn handler-proc)
     (if (setup-listener uconn port-suggestion)
 	(let* ((th1 (make-thread (lambda ()(ulex-cmd-loop uconn)) "Ulex command loop"))
 	       (th2 (make-thread (lambda ()(process-work-queue uconn)) "Ulex work queue processor")))
+	  (tcp-buffer-size 2048)
+	  ;; (max-connections 2048) 
 	  (thread-start! th1)
 	  (thread-start! th2)
 	  (udat-cmd-thread-set! uconn th1)
 	  (udat-work-queue-thread-set! uconn th2)
 	  (print "cmd loop and process workers started")
@@ -314,13 +316,19 @@
 (define (do-work uconn rdat)
   (let* ((proc (udat-work-proc uconn))) ;; get it each time - conceivebly it could change
     ;; put this following into a do-work procedure
     (match rdat
       ((rem-host-port qrykey cmd params)
-       (let* ((result (proc rem-host-port qrykey cmd params)))
+       (let* ((start-time (current-milliseconds))
+	      (result (proc rem-host-port qrykey cmd params))
+	      (end-time (current-milliseconds))
+	      (run-time (- end-time start-time)))
+	 (print "ULEX: work "cmd", "params" done in "run-time" ms")
 	 ;; send 'response as cmd and result as params
-	 (send uconn rem-host-port qrykey 'response result))) ;; could check for ack
+	 (send uconn rem-host-port qrykey 'response result) ;; could check for ack
+	 (print "ULEX: response sent back to "rem-host-port" in "(- (current-milliseconds) end-time))))
+      (MBOX_TIMEOUT #f)
       (else
        (print "ERROR: rdat "rdat", did not match rem-host-port qrykey cmd params")))))
      
 (define (process-work-queue uconn) 
   (let ((wqueue (udat-work-queue uconn))
@@ -327,12 +335,14 @@
 	(proc   (udat-work-proc  uconn))
 	(numthr (udat-numthreads uconn)))
     (let loop ((thnum    1)
 	       (threads '()))
       (let ((thlst (cons (make-thread (lambda ()
-					(let ((rdat (mailbox-receive! wqueue #f 'MBOX_TIMEOUT)))
-					  (do-work uconn rdat)))
+					(let work-loop ()
+					  (let ((rdat (mailbox-receive! wqueue 24000 'MBOX_TIMEOUT)))
+					    (do-work uconn rdat))
+					  (work-loop)))
 				      (conc "work thread " thnum))
 			 threads)))
 	(if (< thnum numthr)
 	    (loop (+ thnum 1)
 		  thlst)