Index: api.scm
==================================================================
--- api.scm
+++ api.scm
@@ -186,12 +186,14 @@
     (mutex-unlock! *api-print-db-stats-mutex*)
     (thread-sleep! 5)
     (loop)))
 
 (define *api:queue-mutex* (make-mutex))
+(define *api:queue-id* 0)
+
 (define *api:in-queue* '())
-(define *api:out-queue* '())
+(define *api:results* (make-hash-table)) ;; id->queue-item
 
 (define (api:start-queue-processor)
   ;; look for work in in-queue
   ;; process it
   ;; put result in out-queue
@@ -206,11 +208,33 @@
   (start-time (current-seconds))
   (end-time   #f)
   (id   #f))
 
 (define (api:add-queue-item proc cmd params)
-  #f)
+  (mutex-lock *api:queue-mutex*)
+  (set! *api:queue-id* (+ *api:queue-id* 1))
+  (set! *api:in-queue*
+	(cons (make-api:queue-item
+	       proc: proc
+	       cmd: cmd
+	       params: params
+	       id: *api:queue-id*
+	       )
+	      *api:in-queue*))
+  (let ((id *api:queue-id*))
+    (mutex-unlock *apt:queue-mutex*)
+    id)) ;; return id so calling proc can find the result in *api:results*
+
+(define (api:get-queue-item)
+  (mutex-lock *api:queue-mutex*)
+  (let* ((res (if (null? *api:in-queue*)
+		  #f
+		  (let* ((revlst (reverse *api:in-queue*)))
+		    (set! *api:in-queue* (reverse (cdr revlist)))
+		    (car revlist)))))
+    (mutex-unlock *api:queue-mutex*)
+    res))
 
 (define (api:tcp-dispatch-request-make-handler-new dbstruct) ;; cmd run-id params)
 
   ;;  put proc into in-queue
   ;;  poll out-queue for result evey 25ms