Plasma GitLab Archive
Projects Blog Knowledge

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
      | `Posix_shm_preallocated_sc
      | `Posix_shm_sc ]
  type inherit_request = [ `All | `Resources of Netmcore.res_id list ]
  type compute_resource_repr =
      [ `File of string
      | `Fork_point of
          Netmcore.inherit_request * 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
      | `Posix_shm_preallocated_sc of
          string * Netsys_mem.memory * Netsys_sem.container
      | `Posix_shm_sc of string * Netsys_sem.prefix ]
  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.inherit_request ->
    Netmcore.res_id -> Netplex_encap.encap -> Netmcore.process_id
  val join :
    Netmcore.res_id -> Netmcore.process_id -> Netplex_encap.encap option
  val join_nowait :
    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 manage_shm_sc :
    string -> Netsys_sem.container -> Netmcore.compute_resource
  val get_shm : Netmcore.res_id -> string
  val get_sem_container : Netmcore.res_id -> Netsys_sem.container
  val create_preallocated_shm :
    ?value_area:bool -> string -> int -> Netmcore.res_id * string
  val create_preallocated_shm_sc :
    ?value_area:bool ->
    string -> int -> Netmcore.res_id * string * Netsys_sem.container
  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) ->
    ?disable_pmanage:bool ->
    ?no_unlink:bool ->
    first_process:('-> Netmcore.process_id) -> '-> unit
  val run :
    socket_directory:string ->
    ?pidfile:string ->
    ?init_ctrl:(Netplex_types.controller -> unit) ->
    ?disable_pmanage:bool ->
    ?no_unlink:bool ->
    first_process:('-> Netmcore.process_id) ->
    extract_result:(Netplex_types.controller -> Netmcore.process_id -> 'b) ->
    '-> 'b
  val destroy_resources : unit -> unit
  module Debug : sig val enable : bool Stdlib.ref end
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml