sig
type condition
type wait_entry
type wait_set
val dummy_condition : unit -> Pfs_condition.condition
val dummy_wait_set : unit -> Pfs_condition.wait_set
val create_condition : Netmcore_heap.mutator -> Pfs_condition.condition
val create_wait_set :
Netmcore_heap.mutator -> string -> Pfs_condition.wait_set
val alloc_wait_entry :
Netmcore_heap.mutator ->
Pfs_condition.wait_set -> Pfs_condition.wait_entry
val free_wait_entry :
Netmcore_heap.mutator ->
Pfs_condition.wait_set -> Pfs_condition.wait_entry -> unit
val pipe_file : Pfs_condition.wait_entry -> string
val wait_e :
Pfs_condition.wait_entry ->
Pfs_condition.condition ->
Netmcore_mutex.mutex ->
Unixqueue.event_system ->
(unit -> 'a Uq_engines.engine) -> 'a Uq_engines.engine
val signal : Pfs_condition.condition -> unit
val broadcast : Pfs_condition.condition -> unit
val destroy_condition : Pfs_condition.condition -> unit
val destroy_wait_set : Pfs_condition.wait_set -> unit
type ser
val serializer_heap :
Netmcore.res_id -> Pfs_condition.ser Netmcore_ref.sref
val serializer :
Pfs_condition.ser Netmcore_ref.sref ->
Unixqueue.event_system -> string -> 'a Uq_engines.serializer_t
class type ['a] int64_serializer_t =
object
method multi_serialized :
int64 list ->
(Unixqueue.event_system -> 'a Uq_engines.engine) ->
'a Uq_engines.engine
method serialized :
int64 ->
(Unixqueue.event_system -> 'a Uq_engines.engine) ->
'a Uq_engines.engine
end
type int64_ser
val int64_serializer_heap :
Netmcore.res_id -> int -> Pfs_condition.int64_ser Netmcore_ref.sref
val int64_serializer :
Pfs_condition.int64_ser Netmcore_ref.sref ->
Unixqueue.event_system -> string -> 'a Pfs_condition.int64_serializer_t
end
