Index: lock-queue.scm
==================================================================
--- lock-queue.scm
+++ lock-queue.scm
@@ -139,10 +139,11 @@
       (sqlite3:finalize! mklckqry)
       result)))
 
 (define (lock-queue:release-lock fname test-id #!key (count 10))
   (let* ((dbdat (lock-queue:open-db fname)))
+    (tasks:wait-on-journal (lock-queue:db-dat-get-path dbdat) 1200 "lock-queue:release-lock; waiting on journal")
     (handle-exceptions
      exn
      (begin
        (debug:print 0 "WARNING: Failed to release queue lock. Will try again in few seconds")
        (debug:print 0 " message: " ((condition-property-accessor 'exn 'message) exn))
@@ -167,11 +168,11 @@
   (debug:print-info 0 "Attempting to steal lock at " (lock-queue:db-dat-get-path dbdat))
   (tasks:wait-on-journal (lock-queue:db-dat-get-path dbdat) 1200 "lock-queue:steal-lock; waiting on journal")
   (handle-exceptions
    exn
    (begin
-     (debug:print 0 "WARNING: Failed to steal queue lock. Will try again in few seconds")
+     (tadebug:print 0 "WARNING: Failed to steal queue lock. Will try again in few seconds")
      (debug:print 0 " message: " ((condition-property-accessor 'exn 'message) exn))
      (thread-sleep! 10)
      (if (> count 0)
 	 (lock-queue:steal-lock dbdat test-id count: (- count 1))
 	 #f))
@@ -184,10 +185,11 @@
 ;;
 (define (lock-queue:wait-turn fname test-id #!key (count 10)(waiting-msg #f))
   (let* ((dbdat   (lock-queue:open-db fname))
 	 (mystart (current-seconds))
 	 (db      (lock-queue:db-dat-get-db dbdat)))
+    (tasks:wait-on-journal (lock-queue:db-dat-get-path dbdat) 1200 waiting-msg: "lock-queue:wait-turn; waiting on journal file")
     (handle-exceptions
      exn
      (begin
        (debug:print 0 "WARNING: Failed to find out if it is ok to skip the wait queue. Will try again in few seconds")
        (debug:print 0 " message: " ((condition-property-accessor 'exn 'message) exn))