Make use of the thread queue.

Signed-off-by: Zheng Li <[email protected]>

Author: zli

ocaml/database/db_cache_impl.ml

@@ -23,6 +23,7 @@
 open Db_exn
 open Db_lock
 open Pervasiveext
+open Threadext
 
 module D = Debug.Debugger(struct let name = "sql" end)
 open D

ocaml/database/master_connection.ml

@@ -18,6 +18,8 @@
    restarts in emergency mode.
 *)
 
+open Threadext
+
 type db_record = (string * string) list * (string * (string list)) list
 module D = Debug.Debugger(struct let name = "master_connection" end)
 open D

ocaml/idl/ocaml_backend/server_helpers.ml

@@ -14,6 +14,7 @@
 open Locking_helpers
 open Stringext
 open Pervasiveext
+open Threadext
 
 module D = Debug.Debugger(struct let name = "dispatcher" end)
 open D

ocaml/xapi/import.ml

@@ -22,6 +22,7 @@ open Http
 open Importexport
 open Unixext
 open Pervasiveext
+open Threadext
 
 open Client
 

ocaml/xapi/startup.ml

@@ -14,6 +14,8 @@
 (**
  * @group Main Loop and Start-up
  *)
+
+open Threadext
 
 module D=Debug.Debugger(struct let name="startup" end)
 open D
@@ -77,4 +79,4 @@ let run ~__context tasks =
         raise exn
   ) tasks
 
-let run ~__context tasks = Stats.time_this "overall xapi startup" (fun () -> run ~__context tasks)
+let run ~__context tasks = Stats.time_this "overall xapi startup" (fun () -> run ~__context tasks)

ocaml/xapi/upload_receive.ml

@@ -12,6 +12,7 @@
  * GNU Lesser General Public License for more details.
  *)
 open Printf
+open Threadext
 
 (** Start the XML-RPC server. *)
 let _ =

ocaml/xapi/xapi_fuse.ml

@@ -14,6 +14,8 @@
 (* Xapi_fuse: Code to cause Xapi to commit not-completely-terminal hari-kiri *)
 (* The watchdog catches the exit()s and restarts us *)
 
+open Threadext
+
 module D = Debug.Debugger(struct let name="xapi_fuse" end)
 open D
 

ocaml/xapi/xapi_pool_transition.ml

@@ -15,6 +15,7 @@
  * @group Pool Management
  *)
 
+open Threadext
 open Client
 
 module D = Debug.Debugger(struct let name="xapi" end)