Index: http-transport.scm
==================================================================
--- http-transport.scm
+++ http-transport.scm
@@ -118,15 +118,15 @@
      (print-error-message exn)
      (if (< portnum 9000)
 	 (begin 
 	   (print "WARNING: failed to start on portnum: " portnum ", trying next port")
 	   (thread-sleep! 0.1)
-	   (open-run-close tasks:remove-server-records tasks:open-db)
+	   ;; (open-run-close tasks:remove-server-records tasks:open-db)
 	   (http-transport:try-start-server ipaddrstr (+ portnum 1)))
 	 (print "ERROR: Tried and tried but could not start the server")))
    (set! *runremote* (list ipaddrstr portnum))
-   (open-run-close tasks:remove-server-records tasks:open-db)
+   ;; (open-run-close tasks:remove-server-records tasks:open-db)
    (open-run-close tasks:server-register 
 		   tasks:open-db 
 		   (current-process-id)
 		   ipaddrstr portnum 0 'live 'http)
    (print "INFO: Trying to start server on " ipaddrstr ":" portnum)

Index: server.scm
==================================================================
--- server.scm
+++ server.scm
@@ -188,11 +188,11 @@
     ;; else fall back to fs
     (debug:print-info 11 "CLIENT SETUP, hostinfo=" hostinfo)
     (set! *transport-type* (if hostinfo 
 			       (string->symbol (tasks:hostinfo-get-transport hostinfo))
 			       'fs))
-    (debug:print-info 1 "Using transport type of " *transport-type* (if hostinfo (conc " to connect to " hostinfo) ""))
+    (debug:print-info 11 "Using transport type of " *transport-type* (if hostinfo (conc " to connect to " hostinfo) ""))
     (case *transport-type* 
     ((fs)(if (not *megatest-db*)(set! *megatest-db* (open-db))))
     ((http)
      (http-transport:client-connect (tasks:hostinfo-get-interface hostinfo)
 				    (tasks:hostinfo-get-port hostinfo)))

Index: zmq-transport.scm
==================================================================
--- zmq-transport.scm
+++ zmq-transport.scm
@@ -123,20 +123,21 @@
 
     ;; The heavy lifting
     ;;
     ;; make-vector-record cdb packet client-sig qtype immediate query-sig params qtime
     ;;
+    (debug:print-info 11 "Server setup complete, start listening for messages")
     (let loop ((queue-lst '()))
       (let* ((rawmsg (receive-message* pull-socket))
 	     (packet (db:string->obj rawmsg))
-					  (qtype  (cdb:packet-get-qtype packet)))
-				     (debug:print-info 12 "server=> received packet=" packet)
-				     (if (not (member qtype '(sync ping)))
-					 (begin
-					   (mutex-lock! *heartbeat-mutex*)
-					   (set! *last-db-access* (current-seconds))
-					   (mutex-unlock! *heartbeat-mutex*)))
+	     (qtype  (cdb:packet-get-qtype packet)))
+	(debug:print-info 12 "server=> received packet=" packet)
+	(if (not (member qtype '(sync ping)))
+	    (begin
+	      (mutex-lock! *heartbeat-mutex*)
+	      (set! *last-db-access* (current-seconds))
+	      (mutex-unlock! *heartbeat-mutex*)))
 	(if #t ;; (cdb:packet-get-immediate packet) ;; process immediately or put in queue
 	    (begin
 	      (open-run-close db:process-queue #f pub-socket (cons packet queue-lst))
 	      (loop '()))
 	    (loop (cons packet queue-lst)))))))
@@ -153,22 +154,24 @@
 			  (mutex-lock! *heartbeat-mutex*)
 			  (set! sdat *server-info*)
 			  (mutex-unlock! *heartbeat-mutex*)
 			  (if sdat sdat
 			      (begin
+				(debug:print 12 "WARNING: server not started yet, waiting few seconds before trying again")
 				(sleep 4)
 				(loop))))))
 	 (iface       (cadr server-info))
 	 (pullport    (caddr server-info))
 	 (pubport     (cadddr server-info)) ;; id interface pullport pubport)
-	 (zmq-sockets (zmq-transport:client-connect iface pullport pubport))
+	 ;; (zmq-sockets (zmq-transport:client-connect iface pullport pubport))
 	 (last-access 0))
     (debug:print-info 11 "heartbeat started for zmq server on " iface " " pullport " " pubport)
     (let loop ((count 0))
       (thread-sleep! 4) ;; no need to do this very often
       ;; NB// sync currently does NOT return queue-length
-      (let ((queue-len (cdb:client-call zmq-sockets 'sync #t 1)))
+      ;; GET REAL QUEUE LENGTH FROM THE VARIABLE
+      (let ((queue-len 0)) ;; FOR NOW DO NOT DO THIS (cdb:client-call zmq-sockets 'sync #t 1)))
       ;; (print "Server running, count is " count)
 	(if (< count 1) ;; 3x3 = 9 secs aprox
 	    (loop (+ count 1)))
 
 	;; NOTE: Get rid of this mechanism! It really is not needed...
@@ -233,10 +236,11 @@
 					ipaddrstr p1 
 					0 
 					'live
 					'zmq
 					pubport: p2))
+    (debug:print-info 11 "*server-info* set to " *server-info*)
     (mutex-unlock! *heartbeat-mutex*)
     (list s1 s2)))
 
 (define (zmq-transport:mk-signature)
   (message-digest-string (md5-primitive)