run tasks as well

This commit is contained in:
Hannes Mehnert 2019-09-19 21:10:23 +02:00
parent 02a70f46ce
commit 158c4a5bb5

View file

@ -169,6 +169,7 @@ module M = struct
let get, reporter = R.store_reporter C.elapsed_ns () in let get, reporter = R.store_reporter C.elapsed_ns () in
Metrics.set_reporter reporter; Metrics.set_reporter reporter;
Metrics.enable_all (); Metrics.enable_all ();
Lwt.async (L.collect (fun () -> T.sleep_ns (Duration.of_sec interval)));
let host = match hostname with None -> [] | Some host -> [vmname host] in let host = match hostname with None -> [] | Some host -> [vmname host] in
Lwt.async (timer_loop get host interval { flows = [ flow ] }) Lwt.async (timer_loop get host interval { flows = [ flow ] })
end end