package ounit

  1. Overview
  2. Docs

Manipulate the state of OUnit runner.

type 'worker next_test_case_t =
  1. | Not_enough_worker
  2. | Try_again
  3. | Next_test_case of OUnitTest.path * OUnitTest.test_fun * 'worker
  4. | Finished
type time = float
type 'worker test_running = {
  1. test_length : OUnitTest.test_length;
  2. deadline : time;
  3. next_health_check : time;
  4. worker : 'worker;
}
type 'worker t = {
  1. tests_planned : (OUnitTest.path * (OUnitTest.test_length * OUnitTest.test_fun)) list;
  2. tests_running : (OUnitTest.path * 'worker test_running) list;
  3. tests_passed : (OUnitTest.result_full * OUnitTest.result_list) list;
  4. idle_workers : 'worker list;
  5. chooser : OUnitChooser.chooser;
  6. cache : OUnitCache.cache;
  7. health_check_interval : time;
}
val health_check_interval : (int, unit -> unit) Hashtbl.t -> float
val create : (int, unit -> unit) Hashtbl.t -> OUnitChooser.chooser -> (OUnitTest.path * OUnitTest.test_length * OUnitTest.test_fun) list -> 'a t
val filter_out : 'a -> ('b * 'c) list -> ('b * 'c) list
val maybe_dump_cache : (int, unit -> unit) Hashtbl.t -> 'a t -> 'a t
val add_test_results : (int, unit -> unit) Hashtbl.t -> (OUnitTest.result_full * OUnitTest.result_list) -> 'a t -> 'b t
val test_finished : (int, unit -> unit) Hashtbl.t -> (OUnitTest.result_full * OUnitTest.result_list) -> 'a -> 'b t -> 'c t
val add_worker : 'a -> 'b t -> 'c t
val remove_idle_worker : 'a -> 'b t -> 'c t
val count_worker : 'a t -> int
val count_tests_running : 'a t -> int
val get_workers : 'a t -> 'b list
val get_idle_workers : 'a t -> 'a list
val is_idle_worker : 'a -> 'b t -> bool
val get_tests_running : 'a t -> OUnitTest.path list
val next_test_case : (int, unit -> unit) Hashtbl.t -> (OUnitTest.path, OUnitTest.result) OUnitLogger.logger -> 'a t -> 'b next_test_case_t * 'a t
val get_results : 'a t -> OUnitTest.result_full list

Get all the results.

val get_worker_need_health_check : 'a t -> (OUnitTest.path * 'b) list

Get all the workers that need to be checked for their health.

val update_test_activity : OUnitTest.path -> 'a t -> 'b t

Update the activity of a worker, this postpone the next health check.

val get_worker_timed_out : 'a t -> (OUnitTest.path * OUnitTest.test_length * 'b) list

Get all the workers that are timed out, i.e. that need to be stopped.

val timeout : 'a t -> float

Compute when is the next time, we should either run health check or timeout a test.

OCaml

Innovation. Community. Security.