Module OUnitRunner.GenericWorkerSource

Build worker based runner.

Sourcetype message_to_worker =
  1. | Exit
  2. | AckLock of bool
  3. | RunTest of OUnitTest.path
Sourceval string_of_message_to_worker : message_to_worker -> string
Sourcetype message_from_worker =
  1. | AckExit
  2. | Log of OUnitTest.log_event_t
  3. | Lock of int
  4. | Unlock of int
  5. | TestDone of OUnitTest.result_full * OUnitTest.result_list
Sourceval string_of_message_from_worker : message_from_worker -> string
Sourcemodule MapPath : sig ... end
Sourcetype ('a, 'b) channel = {
  1. send_data : 'a -> unit;
  2. receive_data : unit -> 'b;
  3. close : unit -> unit;
}
Sourceval wrap_channel : string -> ('a -> string) -> ('b -> string) -> ('b, 'a) channel -> ('b, 'a) channel
Sourceval main_worker_loop : (int, unit -> unit) Hashtbl.t -> (unit -> 'a) -> (message_from_worker, message_to_worker) channel -> string -> (OUnitTest.path * 'b * (OUnitTest.ctxt -> 'c)) MapPath.t -> bool -> unit
Sourcetype 'a worker = {
  1. channel : (message_to_worker, message_from_worker) channel;
  2. close_worker : unit -> string option;
  3. select_fd : 'a;
  4. shard_id : string;
  5. is_running : unit -> bool;
}
Sourceval runner : ((int, unit -> unit) Hashtbl.t -> (MapPath.key * OUnitTest.test_length * OUnitTest.test_fun) MapPath.t -> string -> string -> bool -> 'a worker) -> ('a worker list -> float -> 'a worker list) -> (int, unit -> unit) Hashtbl.t -> (OUnitTest.path, OUnitTest.result) OUnitLogger.logger -> OUnitChooser.chooser -> (OUnitTest.path * OUnitTest.test_length * OUnitTest.test_fun) list -> OUnitTest.result_full list