module Master_process:sig
..end
init
initializes the system and creates the master process. master_init
, if
specified, is called in the master process and may be used for cleanup/initialization
such as closing file descriptors. init
should be called before any threads are
created. If your program daemonizes, call init
after you daemonize, but before you
start the async scheduler. init
may only be called once.
If cluster
is specified, and it specifies a set of host names or ips that you can
ssh to without a password, and have permission to run programs on, then a master
process will also be started on these machines, and you will be able to spawn worker
processes on these machines. The current machine is implicitly included in the set of
available machines.
exception Error_initializing_worker_machine of string * exn
val init : ?cluster:Import.Cluster.t -> unit -> Core.Std.Pid.t
init
initializes the system and creates the master process. master_init
, if
specified, is called in the master process and may be used for cleanup/initialization
such as closing file descriptors. init
should be called before any threads are
created. If your program daemonizes, call init
after you daemonize, but before you
start the async scheduler. init
may only be called once.
If cluster
is specified, and it specifies a set of host names or ips that you can
ssh to without a password, and have permission to run programs on, then a master
process will also be started on these machines, and you will be able to spawn worker
processes on these machines. The current machine is implicitly included in the set of
available machines.
val create_process : ?where:[ `F of unit -> string | `Local | `On of string ] ->
unit ->
(Async.Std.Unix.Inet_addr.t * int) Core.Std.Or_error.t Async.Std.Deferred.t
where
determines which machine the process will be spawned on, the default
is `Local (the current machine).val shutdown : unit -> unit Async.Std.Deferred.t
val round_robin : [> `F of unit -> string ]
val random : [> `F of unit -> string ]
val random_in : string list -> [> `F of unit -> string ]