Index: rmtmod.scm
==================================================================
--- rmtmod.scm
+++ rmtmod.scm
@@ -62,10 +62,11 @@
 	;; http-client
 	;; intarweb
 	matchable
 	md5
 	message-digest
+	nanomsg
 	(prefix base64 base64:)
 	(prefix sqlite3 sqlite3:)
 	regex
 	s11n
 	;; spiffy
@@ -119,10 +120,11 @@
 ;;
 (defstruct servdat
   (host #f)
   (port #f)
   (uuid #f)
+  (rep  #f)
   (dbfile #f)
   (api-url #f)
   (api-uri #f)
   (api-req #f)
   (status 'starting)
@@ -295,24 +297,28 @@
 (define (rmt:send-receive-real remote apath dbname cmd params)
   (let* ((conn (rmt:get-conn remote apath dbname)))
     (assert conn "FATAL: rmt:send-receive-real called without the needed channels opened")
     (pp (rmt:conn->alist conn))
     ;; (rmt:send-receive-setup conn)
-    (let-values (((i o) (tcp-connect (rmt:conn-ipaddr conn)
-				     (rmt:conn-port conn))))
-      (let* ((key     #f)
-	     (payload `((cmd    . ,cmd)
-			(key    . ,(rmt:conn-srvkey conn))
-			(params . ,params)))
-	     (res      (begin
-			 (write payload o) ;; (rmt:conn-outport conn))
-			 (with-input-from-port
-			     i ;; (rmt:conn-inport conn)
-			   read))))
-	(close-input-port i)
-	(close-output-port o)
-	res))))
+;;     (let-values (((i o) (tcp-connect (rmt:conn-ipaddr conn)
+;; 				     (rmt:conn-port conn))))
+    (let* ((key     #f)
+	   (host    (rmt:conn-ipaddr conn))
+	   (port    (rmt:conn-port   conn))
+	   (payload `((cmd    . ,cmd)
+		      (key    . ,(rmt:conn-srvkey conn))
+		      (params . ,params)))
+	   (res      (open-send-receive-nn (conc host":"port)
+					   (sexpr->string payload))))
+      ;; begin
+	;; 		 (write payload o) ;; (rmt:conn-outport conn))
+	;; 		 (with-input-from-port
+	;; 		     i ;; (rmt:conn-inport conn)
+	;; 		   read))))
+	;; (close-input-port i)
+	;; (close-output-port o)
+      (string->sexpr res))))
 ;;  (if (string? res)
 ;; 	  (string->sexpr res)
 ;; 	  res))))
 
 
@@ -1610,16 +1616,17 @@
     (let* ((portnum (servdat-port *server-info*)))
       (portlogger:open-run-close portlogger:set-port portnum "released")
       (debug:print 1 *default-log-port* "INFO: server has been stopped"))))
 
 (define (rmt:try-start-server ipaddrstr portnum)
-  (if *server-info*
+  (if *server-info* ;; update the server info as we might be trying next port
       (begin
 	(servdat-host-set! *server-info* ipaddrstr)
 	(servdat-port-set! *server-info* portnum)
 	(servdat-status-set! *server-info* 'trying-port)
-	(servdat-trynum-set! *server-info* (+ (servdat-trynum *server-info*) 1)))
+	(servdat-trynum-set! *server-info*
+			     (+ (servdat-trynum *server-info*) 1)))
       (set! *server-info* (make-servdat host: ipaddrstr port: portnum)))
   (debug:print-info 0 *default-log-port* "rmt:try-start-server time="
 		    (seconds->time-string (current-seconds))
 		    " ipaddrsstr=" ipaddrstr
 		    " portnum=" portnum)
@@ -1640,14 +1647,18 @@
 	 (begin
 	   (print "ERROR: Tried and tried but could not start the server"))))
    ;; any error in following steps will result in a retry
    (if *server-info*
        (servdat-status-set! *server-info* 'starting)
-       (set! *server-info* (make-servdat host: ipaddrstr port: portnum)))
-   
-   (debug:print 0 *default-log-port* "INFO: Trying to start server on " ipaddrstr ":" portnum)
-   (tcp-listen portnum)))
+       (let ((rep (nn-socket 'rep)))
+	 (set! *server-info* (make-servdat
+			      host: ipaddrstr
+			      port: portnum
+			      rep: rep))))
+   (let* ((rep (servdat-rep *server-info*)))
+     (debug:print 0 *default-log-port* "INFO: Trying to start server on " ipaddrstr ":" portnum)
+     (nn-bind rep (conc "tcp://*:" portnum)))))
 
 ;;======================================================================
 ;; S E R V E R   U T I L I T I E S 
 ;;======================================================================
 
@@ -1796,31 +1807,33 @@
 (define (server-address srv-pkt)
   (conc (alist-ref 'host srv-pkt) ":"
 	(alist-ref 'port srv-pkt)))
 	
 (define (server-ready? host port key) ;; server-address is host:port
-  (let-values (((i o)(handle-exceptions
-		      exn
-		      (values #f #f)
-		      (tcp-connect host port))))
-    (if (and i o)
-	(begin
-	  (write `((cmd . ping)
-		   (key . ,key)
-		   (params . ())) o)
-	  (let ((res (with-input-from-port i
-		       read)))
-	    (close-output-port o)
-	    (close-input-port i)
-	    res))
+;;  (let-values (((i o)(handle-exceptions
+;;		      exn
+;;		      (values #f #f)
+;;		      (tcp-connect host port))))
+;;    (if (and i o)
+  (let* ((data (sexpr->string  `((cmd . ping)
+				 (key . ,key)
+				 (params . ()))))
+	 (res  (open-send-receive-nn (conc host ":" port) data)))
+    (string->sexpr res)))
+
+;; (let ((res (with-input-from-port i
+;; 		       read)))
+;; 	    (close-output-port o)
+;; 	    (close-input-port i)
+;; 	    res))
 ;; 	    (if (string? res)
 ;; 		(string->sexpr res)
 ;; 		res)))
-	(begin ;; connection failed
-	  (debug:print-info 0 *default-log-port* "Server at "host":"port" is not responding.")
-	  #f))))
- 	      
+;;     (begin ;; connection failed
+;; 	  (debug:print-info 0 *default-log-port* "Server at "host":"port" is not responding.")
+;; 	  #f))))
+
 ;; (define (loop-test host port data) ;; server-address is host:port
 ;;   ;; ping the server and ask it
 ;;   ;; if it ready
 ;;   ;; (let* ((sdat (servdat-init #f host port #f)))
 ;;   ;;   (http-transport:send-receive sdat "abc" 'ping '())))
@@ -2192,10 +2205,112 @@
 (define (rmt:get-signature) 
   (if *my-signature* *my-signature*
       (let ((sig (rmt:mk-signature)))
         (set! *my-signature* sig)
         *my-signature*)))
+
+;;======================================================================
+;; Nanomsg transport
+;;======================================================================
+
+(define (is-port-in-use port-num)
+ (let* ((ret #f))
+     (let-values (((inp oup pid)
+                (process "netstat" (list  "-tulpn" ))))
+      (let loop ((inl (read-line inp)))
+        (if (not (eof-object? inl))
+            (begin 
+                (if (string-search (regexp (conc ":" port-num)) inl)
+                 (begin
+                 ;(print "Output: "  inl)
+                  (set! ret  #t))
+                 (loop (read-line inp)))))))
+ret))
+
+;;start a server, returns the connection
+;;
+(define (start-nn-server portnum )
+  (let ((rep (nn-socket 'rep)))
+    (handle-exceptions
+     exn
+     (let ((emsg ((condition-property-accessor 'exn 'message) exn)))
+       (print "ERROR: Failed to start server \"" emsg "\"")
+       (exit 1))
+      
+     (nn-bind rep (conc "tcp://*:" portnum)))
+    rep))
+
+;; open connection to server, send message, close connection
+;;
+(define (open-send-close-nn host-port msg #!key (timeout 3) ) ;; default timeout is 3 seconds
+  (let ((req  (nn-socket 'req))
+        (uri  (conc "tcp://" host-port))
+        (res  #f)
+        ;; (contacts (alist-ref 'contact attrib))
+        ;; (mode (alist-ref 'mode attrib))
+	) 
+    (handle-exceptions
+     exn
+     (let ((emsg ((condition-property-accessor 'exn 'message) exn)))
+       ;; Send notification       
+       (debug:print 0 *default-log-port* "ERROR: Failed to connect / send to " uri " message was \"" emsg "\"" )
+       #f)
+     (nn-connect req uri)
+     ;; (print "Connected to the server " )
+     (nn-send req msg)
+     ;; (print "Request Sent")  
+     (let* ((th1  (make-thread (lambda ()
+                                 (let ((resp (nn-recv req)))
+                                   (nn-close req)
+                                   (set! res (if (equal? resp "ok")
+                                                 #t
+                                                 #f))))
+                               "recv thread"))
+            (th2 (make-thread (lambda ()
+                                (thread-sleep! timeout)
+                                (thread-terminate! th1))
+			      "timer thread")))
+       (thread-start! th1)
+       (thread-start! th2)
+       (thread-join! th1)
+       res))))
+
+(define (open-send-receive-nn host-port msg #!key (timeout 3) ) ;; default timeout is 3 seconds
+  (let ((req  (nn-socket 'req))
+        (uri  (conc "tcp://" host-port))
+        (res  #f)
+	;;        (contacts (alist-ref 'contact attrib))
+        ;; (mode (alist-ref 'mode attrib))
+	) 
+    (handle-exceptions
+     exn
+     (let ((emsg ((condition-property-accessor 'exn 'message) exn)))
+       ;; Send notification      
+       (debug:print 0 *default-log-port* "ERROR: Failed to connect / send to " uri " message was \"" emsg "\"" )
+       #f)
+     (nn-connect req uri)
+     ;; (print "Connected to the server " )
+     (nn-send req msg)
+     ;; (print "Request Sent")  
+     ;; receive code here
+     ;;(print (nn-recv req))
+     (let* ((th1  (make-thread (lambda ()
+                                 (let ((resp (nn-recv req)))
+                                   (nn-close req)
+                                   (print resp)
+                                   (set! res (if (equal? resp "ok")
+                                                 #t
+                                                 #f))))
+                               "recv thread"))
+            (th2 (make-thread (lambda ()
+                                (thread-sleep! timeout)
+                                (thread-terminate! th1))
+                             "timer thread")))
+       (thread-start! th1)
+       (thread-start! th2)
+       (thread-join! th1)
+       res))))
 
 ;;======================================================================
 ;; S E R V E R   U T I L I T I E S 
 ;;======================================================================
 

Index: tests/unittests/server.scm
==================================================================
--- tests/unittests/server.scm
+++ tests/unittests/server.scm
@@ -54,10 +54,11 @@
 (define dbname ".db/2.db")
 (define remote *rmt:remote*)
 (define keyvals  '(("SYSTEM" "a")("RELEASE" "b")))
 
 (test #f #t (rmt:open-main-connection remote apath))
+(test #f #t (rmt:conn? (rmt:get-conn *rmt:remote* *toppath* ".db/main.db")))
 (test #f #t (rmt:conn? (rmt:get-conn *rmt:remote* *toppath* ".db/main.db")))
 (test #f 'server-started (rmt:send-receive-real *rmt:remote* *toppath* ".db/main.db" 'get-server `(,apath ,dbname)))
 
 (thread-sleep! 2)
 (test #f #t (list? (rmt:general-open-connection *rmt:remote* *toppath* ".db/2.db")))