Analogue to Lwt_main
exception Main_error of error * stringMain_error is thrown, when uv_run returns an error - or if lwt doesn't report any result and libuv reports, that there are no pending tasks.
You shouldn't raise exceptions, if you are using uwt. Always use Lwt.fail. If you throw exceptions nevertheless, uwt can sometines not propagate the exceptions to the OCaml runtime immediately. This applies for example to exceptions that occur inside iterative callbacks (like Stream.read_start, Timer.start, Poll.start, etc. ). They are passed to Lwt.async_exception_hook instead.
However, uwt cannot catch all exceptions at the right moment. Don't call any uwt function (especially run) again, if you catch such an exception below run. A workaround is currently not implemented, because only rare exceptions like Out_of_memory and Stackoverflow are 'fatal' under rare conditions - and they usually mean you are in unrecoverable trouble anyway.
let rec main t1 =
match Uwt.Main.run t1 with
| exception Uwt.Main.Fatal(e,p) -> (* fatal, restart your process *)
log_fatal e p ; cleanup () ; exit 2
| exception x -> log_normal x ; main t3 (* safe *)
| result -> let y = ... (* no error *)exception Fatal of exn * Printexc.raw_backtraceval enter_iter_hooks : (unit -> unit) Lwt_sequence.tval leave_iter_hooks : (unit -> unit) Lwt_sequence.tval yield : unit -> unit Lwt.tval run : 'a Lwt.t -> 'aUnlike Lwt_main.run, it's not allowed to nest calls to Uwt.Main.run. The following code is invalid, an exception Main_error will be thrown:
let help () =
let () = Uwt.Main.run foo in
Lwt.return_unit
in
Uwt.Main.run (help ())And Uwt.Main.run will complain about missing work (Main_error again):
let s,t = Lwt.task () in
Uwt.Main.run sWith lwt.unix the code above could lead to a busy loop (wasting your cpu time - but it's dependend on the selected Lwt_engine). If you really want your process to run forever, without waiting for any i/o, you can create a Uwt.Timer.t that gets called repeatedly, but does nothing.
val exit_hooks : (unit -> unit Lwt.t) Lwt_sequence.tval at_exit : (unit -> unit Lwt.t) -> unit