sig
module I64Set :
sig
type elt = int64
type t
val empty : t
val is_empty : t -> bool
val mem : elt -> t -> bool
val add : elt -> t -> t
val singleton : elt -> t
val remove : elt -> t -> t
val union : t -> t -> t
val inter : t -> t -> t
val diff : t -> t -> t
val compare : t -> t -> int
val equal : t -> t -> bool
val subset : t -> t -> bool
val iter : (elt -> unit) -> t -> unit
val fold : (elt -> 'a -> 'a) -> t -> 'a -> 'a
val for_all : (elt -> bool) -> t -> bool
val exists : (elt -> bool) -> t -> bool
val filter : (elt -> bool) -> t -> t
val partition : (elt -> bool) -> t -> t * t
val cardinal : t -> int
val elements : t -> elt list
val min_elt : t -> elt
val max_elt : t -> elt
val choose : t -> elt
val split : elt -> t -> t * bool * t
end
module BRowSet :
sig
type elt = int * int64
type t
val empty : t
val is_empty : t -> bool
val mem : elt -> t -> bool
val add : elt -> t -> t
val singleton : elt -> t
val remove : elt -> t -> t
val union : t -> t -> t
val inter : t -> t -> t
val diff : t -> t -> t
val compare : t -> t -> int
val equal : t -> t -> bool
val subset : t -> t -> bool
val iter : (elt -> unit) -> t -> unit
val fold : (elt -> 'a -> 'a) -> t -> 'a -> 'a
val for_all : (elt -> bool) -> t -> bool
val exists : (elt -> bool) -> t -> bool
val filter : (elt -> bool) -> t -> t
val partition : (elt -> bool) -> t -> t * t
val cardinal : t -> int
val elements : t -> elt list
val min_elt : t -> elt
val max_elt : t -> elt
val choose : t -> elt
val split : elt -> t -> t * bool * t
end
type update_characteristics = {
upd_ds : bool;
upd_inodes : Nn_commit_monitor.I64Set.t;
upd_blocks : Nn_commit_monitor.BRowSet.t;
}
type commit_monitor
type commit_monitor_shm
val create_commit_monitor_heap :
Netmcore.res_id -> Nn_commit_monitor.commit_monitor_shm Netmcore_ref.sref
val create_commit_monitor :
Netmcore.res_id ->
Nn_commit_monitor.commit_monitor_shm Netmcore_ref.sref ->
Unixqueue.event_system -> Nn_commit_monitor.commit_monitor
val monitor_e :
Nn_commit_monitor.commit_monitor ->
Nn_commit_monitor.update_characteristics ->
(int -> 'a Uq_engines.engine) -> 'a Uq_engines.engine
val get_update_characteristics :
Nn_db.modification Queue.t list ->
Nn_commit_monitor.update_characteristics
end
