sig
type res_id = [ `Resource of int ]
type process_id = [ `Process of int ]
type compute_resource_type =
[ `File
| `Fork_point
| `Join_point
| `Posix_sem
| `Posix_shm
| `Posix_shm_preallocated ]
type compute_resource_repr =
[ `File of string
| `Fork_point of
Netmcore.res_id list * Netplex_encap.encap -> Netmcore.process_id
| `Join_point of Netmcore.process_id -> Netplex_encap.encap option
| `Posix_sem of string
| `Posix_shm of string
| `Posix_shm_preallocated of string * Netsys_mem.memory ]
exception No_resource of Netmcore.res_id
class type compute_resource =
object
method id : Netmcore.res_id
method release : unit -> unit
method repr : Netmcore.compute_resource_repr
method typ : Netmcore.compute_resource_type
end
val def_process :
(Netplex_encap.encap -> Netplex_encap.encap) ->
Netmcore.res_id * Netmcore.res_id
val start :
?inherit_resources:Netmcore.res_id list ->
Netmcore.res_id -> Netplex_encap.encap -> Netmcore.process_id
val join :
Netmcore.res_id -> Netmcore.process_id -> Netplex_encap.encap option
val get_resource : Netmcore.res_id -> Netmcore.compute_resource
val release : Netmcore.res_id -> unit
val manage_file : string -> Netmcore.compute_resource
val get_file : Netmcore.res_id -> string
val manage_shm : string -> Netmcore.compute_resource
val get_shm : Netmcore.res_id -> string
val create_preallocated_shm : string -> int -> Netmcore.res_id
val manage_sem : string -> Netmcore.compute_resource
val get_sem : Netmcore.res_id -> string
val self_process_id : unit -> Netmcore.process_id
val add_plugins : Netplex_types.controller -> unit
val startup :
socket_directory:string ->
?pidfile:string ->
?init_ctrl:(Netplex_types.controller -> unit) ->
first_process:Netmcore.res_id * Netplex_encap.encap -> unit -> unit
val destroy_resources : unit -> unit
module Debug : sig val enable : bool Pervasives.ref end
end
