Index: api.scm
==================================================================
--- api.scm
+++ api.scm
@@ -235,11 +235,11 @@
                    ((del-var)                      (apply db:del-var dbstruct params))
 		   ((add-var)                      (apply db:add-var dbstruct params))
 
                    ;; STEPS
                    ((teststep-set-status!)         (apply db:teststep-set-status! dbstruct params))
-                   ((delete-steps-for-test!)        (apply db:delete-steps-for-test! dbstruct params))
+                   ((delete-steps-for-test!)       (apply db:delete-steps-for-test! dbstruct params))
                    
                    ;; TEST DATA
                    ((test-data-rollup)             (apply db:test-data-rollup dbstruct params))
                    ((csv->test-data)               (apply db:csv->test-data dbstruct params))
 

Index: dbfile.scm
==================================================================
--- dbfile.scm
+++ dbfile.scm
@@ -488,14 +488,14 @@
 	(begin
 	  (if (common:low-noise-print 120 busy-file)
 	      (dbfile:print-err "INFO: dbfile:cautious-open-database: journal file "
 				busy-file" exists, trying again in few seconds."))
 	  (thread-sleep! 1)
-	;; (if (eq? tries-left 2)
-	;;     (begin
-	;; 	(dbfile:print-err "INFO: forcing journal rollup "busy-file)
-	;; 	(dbfile:brute-force-salvage-db fname)))
+	  (if (eq? tries-left 2)
+	      (begin
+	  	(dbfile:print-err "INFO: forcing journal rollup "busy-file)
+	  	(dbfile:brute-force-salvage-db fname)))
 	  (dbfile:cautious-open-database fname init-proc (- tries-left 1)))
 
 	(let* ((result (condition-case
 		         (if dir-access
 			   (dbfile:with-simple-file-lock
@@ -1218,11 +1218,42 @@
 				      " is locked. Try copying to another location, remove original and copy back."))
       (exn (permission)(db:generic-error-printout exn "ERROR: database " fname " has some permissions problem."))
       (exn ()
 	   (db:generic-error-printout exn "ERROR: Unknown error with database " fname " message: "
 				      ((condition-property-accessor 'exn 'message) exn))))))
-      
+
+;;======================================================================
+;; another attempt at a transactionized queue
+;;======================================================================
+
+;; ;; ;; (define *transaction-queues* (make-hash-table))
+;; ;; ;; 
+;; ;; ;; (define (db:get-queue run-id)
+;; ;; ;;   (let* ((res (hash-table-ref/default *transaction-queues* run-id #f)))
+;; ;; ;;     (if res
+;; ;; ;; 	res
+;; ;; ;; 	(let* ((newq (make-queue)))
+;; ;; ;; 	  (hash-table-set! *transaction-queues* run-id newq)
+;; ;; ;; 	  newq))))
+;; ;; ;; 
+;; ;; ;; (define (db:add-to-transaction-queue dbstruct proc params)
+;; ;; ;;   (let* ((mbox (make-mailbox))
+;; ;; ;; 	 (q    (db:get-queue run-id)))
+;; ;; ;;     (queue-add! *transaction-queue* (list dbstruct proc mbox))
+;; ;; ;;     (mailbox-receive mbox)))
+;; ;; ;; 
+;; ;; ;; (define (db:process-transaction-queue *dbstruct-dbs*)
+;; ;; ;;   (for-each
+;; ;; ;;    (lambda (run-id)
+;; ;; ;;      (let* ((q (hash-table-ref *transaction-queue* run-id)))
+;; ;; ;;        ;; with-transaction
+;; ;; ;;        ;;     dbstruct
+;; ;; ;;        ;; pop items from queue and execute them, return results via mailbox
+;; ;; ;;        q
+;; ;; ;;        ;; pop 
+;; ;; ;;        ))
+;; ;; ;;    (hash-table-keys *transaction-queues*)))
 
 ;;======================================================================
 ;; file utils
 ;;======================================================================
 

Index: http-transport.scm
==================================================================
--- http-transport.scm
+++ http-transport.scm
@@ -483,11 +483,16 @@
           ) 
 	  (if (and no-sync-db
 		   (common:low-noise-print 5 "sync-all")) ;; cheesy way to reduce frequency of running sync :)
               (begin
                 (debug:print 0 *default-log-port* "keep-running calling db:all-db-sync at " (time->string (seconds->local-time) "%H:%M:%S"))
-                (db:all-db-sync *dbstruct-dbs*)
+
+		;; This is tougher than it seems - have to deal with multiple dbs
+		;; (db:process-transaction-queue *dbstruct-dbs*)
+
+		(db:all-db-sync *dbstruct-dbs*)
+		
                 ;; (db:do-sync no-sync-db)
 	        ;; (db:run-lock-and-sync *no-sync-db*)
               )
           )
       )