sig
class type ro_transaction =
object
method connection : Pfs_db.ro_async_connection
method event_system : Unixqueue.event_system
method return : unit -> unit
end
class type transaction =
object
method commit : unit -> unit Uq_engines.engine
method connection : Pfs_db.rw_async_connection
method event_system : Unixqueue.event_system
method prepare : unit -> unit Uq_engines.engine
method return : unit -> unit
method ro_connection : Pfs_db.ro_async_connection
method rollback : unit -> unit Uq_engines.engine
end
type inodeinfo = Pfs_rpcapi_aux.inodeinfo
type allocinfo = {
ai_inode : int64;
ai_index : int64;
ai_identity : string;
ai_block : int64;
}
val update_allocinfo :
int64 ->
Nn_db.allocinfo list ->
Nn_blocklist.blocklist -> (string, Nn_db.allocinfo) Hashtbl.t
val init : Pfs_db.db_config -> Unixqueue.event_system -> unit
val ro_esys : unit -> Unixqueue.event_system
val commit_all_prepared_transactions : unit -> unit
val transact : Unixqueue.event_system -> Nn_db.transaction
val ro_transact : unit -> Nn_db.ro_transaction Uq_engines.engine
val with_ro_trans :
(Pfs_db.ro_async_connection ->
Unixqueue.event_system -> 'a Uq_engines.engine) ->
'a Uq_engines.engine
val datastore_list_e :
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> Nn_datastores.datastore list Uq_engines.engine
val datastore_list_ro_e :
unit -> Nn_datastores.datastore list Uq_engines.engine
val datastore_find_e :
identity:string ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system ->
Nn_datastores.datastore option Uq_engines.engine
val datastore_find_ro_e :
identity:string -> Nn_datastores.datastore option Uq_engines.engine
val datastore_upd_e :
id:int ->
identity:string ->
size:int64 ->
enabled:bool ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val datastore_del_e :
id:int ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
type ds_init_source =
[ `Datastores of Nn_datastores.datastore list
| `From_datastore_news_channel ]
val ds_cache_init : Nn_db.ds_init_source -> unit
val ds_cache_contents : unit -> Nn_datastores.datastore list
val revision_get_e :
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> string Uq_engines.engine
val revision_get_ro_e : unit -> string Uq_engines.engine
val revision_upd_e :
revstr:string ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val blockalloc_list_e :
datastore:int ->
blkidx_min:int64 ->
blkidx_max:int64 ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> (int64 * string) list Uq_engines.engine
val blockalloc_list_ro_e :
datastore:int ->
blkidx_min:int64 ->
blkidx_max:int64 -> (int64 * string) list Uq_engines.engine
val blockalloc_upd_e :
datastore:int ->
blkidx:int64 ->
blkmap:string ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val inode_listall_e :
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> int64 list Uq_engines.engine
val inode_get_e :
id:int64 ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> Nn_db.inodeinfo option Uq_engines.engine
val inode_get_ro_e : id:int64 -> Nn_db.inodeinfo option Uq_engines.engine
val inode_maxid_e :
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> int64 Uq_engines.engine
val inode_maxid_ro_e : unit -> int64 Uq_engines.engine
val inode_ins_e :
id:int64 ->
Nn_db.inodeinfo ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val inode_upd_e :
id:int64 ->
Nn_db.inodeinfo ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val inode_upd_time_e :
id:int64 ->
mtime:Pfs_rpcapi_aux.time option ->
ctime:Pfs_rpcapi_aux.time option ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val inode_del_e :
id:int64 ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val inodeblocks_get_e :
inode:int64 ->
blkidx:int64 ->
len:int64 ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> Nn_blocklist.blocklist Uq_engines.engine
val inodeblocks_get_ro_e :
inode:int64 ->
blkidx:int64 -> len:int64 -> Nn_blocklist.blocklist Uq_engines.engine
val inodeblocks_getall_e :
inode:int64 ->
dsid:int ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> (int64 * int64 * int64) list Uq_engines.engine
val inodeblocks_del_e :
inode:int64 ->
blkidx:int64 ->
len:int64 ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val inodeblocks_ins_e :
inode:int64 ->
Nn_blocklist.blocklist ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val allocinfo_get_e :
inode:int64 ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> Nn_db.allocinfo list Uq_engines.engine
val allocinfo_get_ro_e :
inode:int64 -> Nn_db.allocinfo list Uq_engines.engine
val names_get_e :
dir_inode:int64 ->
name:string ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> int64 option Uq_engines.engine
val names_get_ro_e :
dir_inode:int64 -> name:string -> int64 option Uq_engines.engine
val names_rev_get_e :
inode:int64 ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> (int64 * string) list Uq_engines.engine
val names_rev_get_ro_e :
inode:int64 -> (int64 * string) list Uq_engines.engine
val names_get_parent_e :
inode:int64 ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> int64 option Uq_engines.engine
val names_get_parent_ro_e : inode:int64 -> int64 option Uq_engines.engine
val names_count_e :
inode:int64 ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> int Uq_engines.engine
val names_count_ro_e : inode:int64 -> int Uq_engines.engine
val names_list_e :
dir_inode:int64 ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> (string * int64) list Uq_engines.engine
val names_list_ro_e :
dir_inode:int64 -> (string * int64) list Uq_engines.engine
val names_ins_e :
dir_inode:int64 ->
name:string ->
inode:int64 ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val names_del_e :
dir_inode:int64 ->
name:string ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val admin_table_get_e :
key:string ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> string Uq_engines.engine
val admin_table_get_ro_e : key:string -> string Uq_engines.engine
val admin_table_exists_e :
key:string ->
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> bool Uq_engines.engine
val admin_table_exists_ro_e : key:string -> bool Uq_engines.engine
val admin_table_put_e :
key:string ->
contents:string ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
val read_ug_admin_e :
Pfs_db.ro_async_connection ->
Unixqueue.event_system -> (string * string) list Uq_engines.engine
type modification =
[ `Admin_table_put of string * string
| `Blockalloc_upd of int * int64 * string
| `Datastore_del of int
| `Datastore_upd of int * string * int64 * bool
| `Inode_del of int64
| `Inode_ins of int64 * Nn_db.inodeinfo
| `Inode_upd of int64 * Nn_db.inodeinfo
| `Inode_upd_time of
int64 * Pfs_rpcapi_aux.time option * Pfs_rpcapi_aux.time option
| `Inodeblocks_del of int64 * int64 * int64
| `Inodeblocks_ins of int64 * Nn_blocklist.blocklist
| `Names_del of int64 * string
| `Names_ins of int64 * string * int64
| `Revision_upd of string ]
val exec_e :
Nn_db.modification ->
Pfs_db.rw_async_connection ->
Unixqueue.event_system -> unit Uq_engines.engine
end
