Index: db.scm
==================================================================
--- db.scm
+++ db.scm
@@ -1961,11 +1961,11 @@
 
 ;; Update run_stats for given run_id
 ;; input data is a list (state status count)
 ;;
 (define (db:update-run-stats dbstruct run-id stats)
-  ;;(mutex-lock! *db-stats-mutex*)
+  (mutex-lock! *db-stats-mutex*)
   (db:with-db
    dbstruct
    #f
    #f
 
@@ -1983,11 +1983,11 @@
 		   (sqlite3:execute stmt1 run-id (car dat)(cadr dat))
 		   (apply sqlite3:execute stmt2 run-id dat))
 		 stats)))))
        (sqlite3:finalize! stmt1)
        (sqlite3:finalize! stmt2)
-       ;;(mutex-unlock! *db-stats-mutex*)
+       (mutex-unlock! *db-stats-mutex*)
        res))))
 
 (define (db:get-main-run-stats dbstruct run-id)
   (db:with-db
    dbstruct
@@ -3175,42 +3175,46 @@
 			   (db:test-get-testname testdat)
 			   test-name))
 	 (item-path    (db:test-get-item-path testdat))
          (tl-testdat   (db:get-test-info dbstruct run-id test-name ""))
          (tl-test-id   (db:test-get-id tl-testdat)))
-    (sqlite3:with-transaction
-     db
-     (lambda ()
-       (db:test-set-state-status-by-id dbstruct run-id test-id state status comment)
-       (if (not (equal? item-path "")) ;; only roll up IF incoming test is an item
-	   (let* ((state-status-counts  (db:get-all-state-status-counts-for-test db run-id test-name item-path)) ;; item-path is used to exclude current state/status of THIS test
-		  (running              (length (filter (lambda (x)
-							  (member (dbr:counts-state x) *common:running-states*))
-							state-status-counts)))
-		  (bad-not-started      (length (filter (lambda (x)
-							  (and (equal? (dbr:counts-state x) "NOT_STARTED")
-							       (not (member (dbr:counts-status x)
-									    *common:not-started-ok-statuses*))))
-							state-status-counts)))
-		  (all-curr-states   (common:special-sort  ;; worst -> best (sort of)
-                                      (delete-duplicates
-                                       (cons state (map dbr:counts-state state-status-counts)))
-                                      *common:std-states* >))
-                  (all-curr-statuses (common:special-sort  ;; worst -> best
-                                      (delete-duplicates
-				       (cons status (map dbr:counts-status state-status-counts)))
-				      *common:std-statuses* >))
-		  (newstate          (if (> running 0)
-					 "RUNNING"
-					 (if (> bad-not-started 0)
-					     "COMPLETED"
-					     (car all-curr-states))))
-		  (newstatus         (if (> bad-not-started 0)
-					 "CHECK"
-					 (car all-curr-statuses))))
-	     ;; (print "Setting toplevel to: " newstate "/" newstatus)
-	     (db:test-set-state-status-by-id dbstruct run-id tl-test-id newstate newstatus #f)))))))
+    (mutex-lock! *db-stats-mutex*)
+    (let ((tr-res
+           (sqlite3:with-transaction
+            db
+            (lambda ()
+              (db:test-set-state-status-by-id dbstruct run-id test-id state status comment)
+              (if (not (equal? item-path "")) ;; only roll up IF incoming test is an item
+                  (let* ((state-status-counts  (db:get-all-state-status-counts-for-test db run-id test-name item-path)) ;; item-path is used to exclude current state/status of THIS test
+                         (running              (length (filter (lambda (x)
+                                                                 (member (dbr:counts-state x) *common:running-states*))
+                                                               state-status-counts)))
+                         (bad-not-started      (length (filter (lambda (x)
+                                                                 (and (equal? (dbr:counts-state x) "NOT_STARTED")
+                                                                      (not (member (dbr:counts-status x)
+                                                                                   *common:not-started-ok-statuses*))))
+                                                               state-status-counts)))
+                         (all-curr-states   (common:special-sort  ;; worst -> best (sort of)
+                                             (delete-duplicates
+                                              (cons state (map dbr:counts-state state-status-counts)))
+                                             *common:std-states* >))
+                         (all-curr-statuses (common:special-sort  ;; worst -> best
+                                             (delete-duplicates
+                                              (cons status (map dbr:counts-status state-status-counts)))
+                                             *common:std-statuses* >))
+                         (newstate          (if (> running 0)
+                                                "RUNNING"
+                                                (if (> bad-not-started 0)
+                                                    "COMPLETED"
+                                                    (car all-curr-states))))
+                         (newstatus         (if (> bad-not-started 0)
+                                                "CHECK"
+                                                (car all-curr-statuses))))
+                    ;; (print "Setting toplevel to: " newstate "/" newstatus)
+                    (db:test-set-state-status-by-id dbstruct run-id tl-test-id newstate newstatus #f))))))
+          (mutex-unlock! *db-stats-mutex*))
+      trres)))
 
 (define db:roll-up-pass-fail-counts db:set-state-status-and-roll-up-items)
 
 ;; call with state = #f to roll up with out accounting for state/status of this item
 ;;

Index: rmt.scm
==================================================================
--- rmt.scm
+++ rmt.scm
@@ -180,11 +180,11 @@
 			  (debug:print 0 *default-log-port* "ERROR: transport " (remote-transport *runremote*) " not supported")
 			  (exit))))
 	     (success  (if (vector? dat) (vector-ref dat 0) #f))
 	     (res      (if (vector? dat) (vector-ref dat 1) #f)))
 	(if (vector? conninfo)(http-transport:server-dat-update-last-access conninfo)) ;; refresh access time
-        (debug:print-info 12 *default-log-port* "rmt:send-receive, case  9. conninfo=" conninfo " dat=" dat)
+        (debug:print-info 12 *default-log-port* "rmt:send-receive, case  9. conninfo=" conninfo " dat=" dat " *runremote* = "*runremote*)
 	(if success
 	    (case (remote-transport *runremote*)
 	      ((http) res)
 	      (else
 	       (debug:print 0 *default-log-port* "ERROR: transport " (remote-transport *runremote*) " is unknown")