Plasma GitLab Archive
Projects Blog Knowledge

sig
  class type ro_transaction =
    object
      method connection : Pfs_db.ro_async_connection
      method event_system : Unixqueue.event_system
      method is_returned : bool
      method return : unit -> unit
    end
  class type transaction =
    object
      method commit : unit -> unit Uq_engines.engine
      method commit_and_continue : unit -> unit Uq_engines.engine
      method connection : Pfs_db.rw_async_connection
      method event_system : Unixqueue.event_system
      method is_returned : bool
      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 -> int -> 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 -> 'Uq_engines.engine) ->
    '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_get_checksum_e :
    Pfs_db.ro_async_connection ->
    Unixqueue.event_system -> string Uq_engines.engine
  val revision_upd_e :
    revstr:string ->
    commit_id:int ->
    Pfs_db.rw_async_connection ->
    Unixqueue.event_system -> unit Uq_engines.engine
  val revision_clear_e :
    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_set_anonymous_e :
    id:int64 ->
    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 inode_get_anonymous_e :
    n:int ->
    Pfs_db.ro_async_connection ->
    Unixqueue.event_system -> int64 list Uq_engines.engine
  val inode_get_anonymous_ro_e : n:int -> int64 list 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_set_anonymous of int64
      | `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_clear
      | `Revision_upd of int * string ]
  val exec_e :
    Nn_db.modification ->
    Pfs_db.rw_async_connection ->
    Unixqueue.event_system -> unit Uq_engines.engine
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml