@@ -55,7 +55,6 @@ module ToLVM = struct
5555 | `Error (`Msg msg ) -> fatal_error_t msg
5656 | `Error `Suspended -> return ()
5757 | `Error `Retry ->
58- debug " ToLVM.suspend got `Retry; sleeping" ;
5958 Lwt_unix. sleep 5.
6059 >> = fun () ->
6160 suspend t
@@ -65,7 +64,6 @@ module ToLVM = struct
6564 >> = function
6665 | `Error _ -> fatal_error_t " reading state of ToLVM"
6766 | `Ok `Running ->
68- debug " ToLVM.suspend got `Running; sleeping" ;
6967 Lwt_unix. sleep 5.
7068 >> = fun () ->
7169 wait ()
@@ -76,7 +74,6 @@ module ToLVM = struct
7674 >> = function
7775 | `Error (`Msg msg ) -> fatal_error_t msg
7876 | `Error `Retry ->
79- debug " ToLVM.resume got `Retry; sleeping" ;
8077 Lwt_unix. sleep 5.
8178 >> = fun () ->
8279 resume t
@@ -87,7 +84,6 @@ module ToLVM = struct
8784 >> = function
8885 | `Error _ -> fatal_error_t " reading state of ToLVM"
8986 | `Ok `Suspended ->
90- debug " ToLVM.resume got `Suspended; sleeping" ;
9187 Lwt_unix. sleep 5.
9288 >> = fun () ->
9389 wait ()
@@ -110,7 +106,6 @@ module FromLVM = struct
110106 let initial_state = ref `Running in
111107 let rec loop () = R.Producer. attach ~queue: (name ^ " FromLVM Producer" ) ~client: " xenvmd" ~disk () >> = function
112108 | `Error `Suspended ->
113- debug " FromLVM.attach got `Suspended; sleeping" ;
114109 Lwt_unix. sleep 5.
115110 >> = fun () ->
116111 initial_state := `Suspended ;
@@ -125,12 +120,10 @@ module FromLVM = struct
125120 let rec push t item = R.Producer. push ~t ~item () >> = function
126121 | `Error (`Msg x ) -> fatal_error_t (Printf. sprintf " Error pushing to the FromLVM queue: %s" x)
127122 | `Error `Retry ->
128- debug " FromLVM.push got `Retry; sleeping" ;
129123 Lwt_unix. sleep 5.
130124 >> = fun () ->
131125 push t item
132126 | `Error `Suspended ->
133- debug " FromLVM.push got `Suspended; sleeping" ;
134127 Lwt_unix. sleep 5.
135128 >> = fun () ->
136129 push t item
@@ -578,7 +571,6 @@ module FreePool = struct
578571 FromLVM. state from_lvm
579572 >> = function
580573 | `Suspended ->
581- debug " FromLVM.state got `Suspended; sleeping" ;
582574 Lwt_unix. sleep 5.
583575 >> = fun () ->
584576 wait ()
@@ -761,7 +753,6 @@ let run port sock_path config =
761753 VolumeManager. flush_all ()
762754 >> = fun () ->
763755
764- debug " sleeping for 5s" ;
765756 Lwt_unix. sleep 5.
766757 >> = fun () ->
767758 service_queues () in
0 commit comments