sig
module Datanode :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Datanode'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'null'res) ->
proc_identity:(Pfs_rpcapi_aux.t_Datanode'V1'identity'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'identity'res) ->
proc_size:(Pfs_rpcapi_aux.t_Datanode'V1'size'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'size'res) ->
proc_blocksize:(Pfs_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'blocksize'res) ->
proc_clustername:(Pfs_rpcapi_aux.t_Datanode'V1'clustername'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'clustername'res) ->
proc_read:(Pfs_rpcapi_aux.t_Datanode'V1'read'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'read'res) ->
proc_write:(Pfs_rpcapi_aux.t_Datanode'V1'write'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'write'res) ->
proc_copy:(Pfs_rpcapi_aux.t_Datanode'V1'copy'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'copy'res) ->
proc_zero:(Pfs_rpcapi_aux.t_Datanode'V1'zero'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'zero'res) ->
proc_sync:(Pfs_rpcapi_aux.t_Datanode'V1'sync'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'sync'res) ->
proc_alloc_shm_if_local:(Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res) ->
proc_udsocket_if_local:(Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'null'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'null'res -> unit) ->
unit) ->
proc_identity:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'identity'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'identity'res -> unit) ->
unit) ->
proc_size:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'size'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'size'res -> unit) ->
unit) ->
proc_blocksize:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'blocksize'res ->
unit) ->
unit) ->
proc_clustername:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'clustername'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'clustername'res ->
unit) ->
unit) ->
proc_read:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'read'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'read'res -> unit) ->
unit) ->
proc_write:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'write'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'write'res -> unit) ->
unit) ->
proc_copy:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'copy'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'copy'res -> unit) ->
unit) ->
proc_zero:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'zero'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'zero'res -> unit) ->
unit) ->
proc_sync:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'sync'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'sync'res -> unit) ->
unit) ->
proc_alloc_shm_if_local:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res ->
unit) ->
unit) ->
proc_udsocket_if_local:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
(Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res ->
unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Datanode_ctrl :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'res) ->
proc_reset_all_safetrans:(Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'res) ->
proc_cancel_safetrans:(Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'res) ->
proc_safetrans:(Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'arg ->
(Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'res -> unit) ->
unit) ->
proc_reset_all_safetrans:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'arg ->
(Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'res ->
unit) ->
unit) ->
proc_cancel_safetrans:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'arg ->
(Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'res ->
unit) ->
unit) ->
proc_safetrans:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'arg ->
(Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'res ->
unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Datanode_io :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Datanode_io'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'null'res) ->
proc_read:(Pfs_rpcapi_aux.t_Datanode_io'V1'read'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read'res) ->
proc_read_shm:(Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'res) ->
proc_write:(Pfs_rpcapi_aux.t_Datanode_io'V1'write'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write'res) ->
proc_write_shm:(Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'res) ->
proc_copy:(Pfs_rpcapi_aux.t_Datanode_io'V1'copy'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'copy'res) ->
proc_sync:(Pfs_rpcapi_aux.t_Datanode_io'V1'sync'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'sync'res) ->
proc_size:(Pfs_rpcapi_aux.t_Datanode_io'V1'size'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'size'res) ->
proc_identity:(Pfs_rpcapi_aux.t_Datanode_io'V1'identity'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'identity'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_io'V1'null'arg ->
(Pfs_rpcapi_aux.t_Datanode_io'V1'null'res -> unit) ->
unit) ->
proc_read:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read'arg ->
(Pfs_rpcapi_aux.t_Datanode_io'V1'read'res -> unit) ->
unit) ->
proc_read_shm:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'arg ->
(Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'res ->
unit) ->
unit) ->
proc_write:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write'arg ->
(Pfs_rpcapi_aux.t_Datanode_io'V1'write'res -> unit) ->
unit) ->
proc_write_shm:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'arg ->
(Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'res ->
unit) ->
unit) ->
proc_copy:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_io'V1'copy'arg ->
(Pfs_rpcapi_aux.t_Datanode_io'V1'copy'res -> unit) ->
unit) ->
proc_sync:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_io'V1'sync'arg ->
(Pfs_rpcapi_aux.t_Datanode_io'V1'sync'res -> unit) ->
unit) ->
proc_size:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_io'V1'size'arg ->
(Pfs_rpcapi_aux.t_Datanode_io'V1'size'res -> unit) ->
unit) ->
proc_identity:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Datanode_io'V1'identity'arg ->
(Pfs_rpcapi_aux.t_Datanode_io'V1'identity'res ->
unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Filesystem :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Filesystem'V1'null'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'null'res) ->
proc_begin_transaction:(Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'res) ->
proc_commit_transaction:(Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'res) ->
proc_abort_transaction:(Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'res) ->
proc_get_inodeinfo:(Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res) ->
proc_allocate_inode:(Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'res) ->
proc_update_inodeinfo:(Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res) ->
proc_delete_inode:(Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'res) ->
proc_get_blocks:(Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'res) ->
proc_allocate_blocks:(Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res) ->
proc_free_blocks:(Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'res) ->
proc_get_fsstat:(Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'res) ->
proc_rereplicate:(Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'res) ->
proc_get_blocksize:(Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'res) ->
proc_lookup:(Pfs_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'lookup'res) ->
proc_rev_lookup:(Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'res) ->
proc_link_count:(Pfs_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_count'res) ->
proc_link:(Pfs_rpcapi_aux.t_Filesystem'V1'link'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'link'res) ->
proc_unlink:(Pfs_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink'res) ->
proc_list:(Pfs_rpcapi_aux.t_Filesystem'V1'list'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'list'res) ->
proc_set_block_checksum:(Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res) ->
proc_iterate:(Pfs_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'iterate'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'null'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'null'res -> unit) ->
unit) ->
proc_begin_transaction:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'res ->
unit) ->
unit) ->
proc_commit_transaction:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'res ->
unit) ->
unit) ->
proc_abort_transaction:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'res ->
unit) ->
unit) ->
proc_get_inodeinfo:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res ->
unit) ->
unit) ->
proc_allocate_inode:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'res ->
unit) ->
unit) ->
proc_update_inodeinfo:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res ->
unit) ->
unit) ->
proc_delete_inode:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'res ->
unit) ->
unit) ->
proc_get_blocks:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'res ->
unit) ->
unit) ->
proc_allocate_blocks:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res ->
unit) ->
unit) ->
proc_free_blocks:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'res ->
unit) ->
unit) ->
proc_get_fsstat:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'res ->
unit) ->
unit) ->
proc_rereplicate:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'res ->
unit) ->
unit) ->
proc_get_blocksize:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'res ->
unit) ->
unit) ->
proc_lookup:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'lookup'res -> unit) ->
unit) ->
proc_rev_lookup:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'res ->
unit) ->
unit) ->
proc_link_count:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'link_count'res ->
unit) ->
unit) ->
proc_link:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'link'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'link'res -> unit) ->
unit) ->
proc_unlink:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'unlink'res -> unit) ->
unit) ->
proc_list:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'list'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'list'res -> unit) ->
unit) ->
proc_set_block_checksum:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res ->
unit) ->
unit) ->
proc_iterate:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
(Pfs_rpcapi_aux.t_Filesystem'V1'iterate'res -> unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Coordination :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Coordination'V1'null'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'null'res) ->
proc_find_coordinator:(Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'res) ->
proc_find_namenodes:(Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'res) ->
proc_is_coordinator:(Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'res) ->
proc_clustername:(Pfs_rpcapi_aux.t_Coordination'V1'clustername'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'clustername'res) ->
proc_find_inodecaches:(Pfs_rpcapi_aux.t_Coordination'V1'find_inodecaches'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'find_inodecaches'res) ->
proc_local_identities:(Pfs_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'local_identities'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Coordination'V1'null'arg ->
(Pfs_rpcapi_aux.t_Coordination'V1'null'res -> unit) ->
unit) ->
proc_find_coordinator:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
(Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'res ->
unit) ->
unit) ->
proc_find_namenodes:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
(Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'res ->
unit) ->
unit) ->
proc_is_coordinator:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
(Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'res ->
unit) ->
unit) ->
proc_clustername:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Coordination'V1'clustername'arg ->
(Pfs_rpcapi_aux.t_Coordination'V1'clustername'res ->
unit) ->
unit) ->
proc_find_inodecaches:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Coordination'V1'find_inodecaches'arg ->
(Pfs_rpcapi_aux.t_Coordination'V1'find_inodecaches'res ->
unit) ->
unit) ->
proc_local_identities:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
(Pfs_rpcapi_aux.t_Coordination'V1'local_identities'res ->
unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Dn_admin :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Dn_admin'V1'null'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'null'res) ->
proc_add_datanode:(Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'res) ->
proc_enable_datanode:(Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res) ->
proc_disable_datanode:(Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res) ->
proc_is_enabled:(Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'res) ->
proc_lookup:(Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'res) ->
proc_datanodes:(Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'res) ->
proc_destroy_datanode:(Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Dn_admin'V1'null'arg ->
(Pfs_rpcapi_aux.t_Dn_admin'V1'null'res -> unit) ->
unit) ->
proc_add_datanode:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
(Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'res ->
unit) ->
unit) ->
proc_enable_datanode:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
(Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res ->
unit) ->
unit) ->
proc_disable_datanode:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
(Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res ->
unit) ->
unit) ->
proc_is_enabled:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
(Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'res ->
unit) ->
unit) ->
proc_lookup:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
(Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'res -> unit) ->
unit) ->
proc_datanodes:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
(Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'res ->
unit) ->
unit) ->
proc_destroy_datanode:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
(Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res ->
unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Inode_cache :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Inode_cache'V1'null'arg ->
Pfs_rpcapi_aux.t_Inode_cache'V1'null'res) ->
proc_is_up_to_date:(Pfs_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'arg ->
Pfs_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'res) ->
proc_is_up_to_date_seqno:(Pfs_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'arg ->
Pfs_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Inode_cache'V1'null'arg ->
(Pfs_rpcapi_aux.t_Inode_cache'V1'null'res -> unit) ->
unit) ->
proc_is_up_to_date:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'arg ->
(Pfs_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'res ->
unit) ->
unit) ->
proc_is_up_to_date_seqno:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'arg ->
(Pfs_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'res ->
unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Elect :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Elect'V1'null'arg ->
Pfs_rpcapi_aux.t_Elect'V1'null'res) ->
proc_announce:(Pfs_rpcapi_aux.t_Elect'V1'announce'arg ->
Pfs_rpcapi_aux.t_Elect'V1'announce'res) ->
proc_set_coordinator:(Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'arg ->
Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Elect'V1'null'arg ->
(Pfs_rpcapi_aux.t_Elect'V1'null'res -> unit) -> unit) ->
proc_announce:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Elect'V1'announce'arg ->
(Pfs_rpcapi_aux.t_Elect'V1'announce'res -> unit) ->
unit) ->
proc_set_coordinator:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'arg ->
(Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'res ->
unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Nameslave :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Nameslave'V1'null'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'null'res) ->
proc_begin_transaction:(Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'res) ->
proc_prepare_commit:(Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'res) ->
proc_commit:(Pfs_rpcapi_aux.t_Nameslave'V1'commit'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'commit'res) ->
proc_push_inode_ins:(Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'res) ->
proc_push_inode_upd:(Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'res) ->
proc_push_inode_upd_time:(Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'res) ->
proc_push_inode_del:(Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'res) ->
proc_push_blockalloc_upd:(Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'res) ->
proc_push_datastore_upd:(Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'res) ->
proc_push_datastore_del:(Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'res) ->
proc_push_revision_upd:(Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'res) ->
proc_push_inodeblocks_ins:(Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'res) ->
proc_push_inodeblocks_del:(Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'res) ->
proc_push_names_ins:(Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'res) ->
proc_push_names_del:(Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'null'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'null'res -> unit) ->
unit) ->
proc_begin_transaction:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'res ->
unit) ->
unit) ->
proc_prepare_commit:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'res ->
unit) ->
unit) ->
proc_commit:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'commit'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'commit'res -> unit) ->
unit) ->
proc_push_inode_ins:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'res ->
unit) ->
unit) ->
proc_push_inode_upd:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'res ->
unit) ->
unit) ->
proc_push_inode_upd_time:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'res ->
unit) ->
unit) ->
proc_push_inode_del:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'res ->
unit) ->
unit) ->
proc_push_blockalloc_upd:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'res ->
unit) ->
unit) ->
proc_push_datastore_upd:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'res ->
unit) ->
unit) ->
proc_push_datastore_del:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'res ->
unit) ->
unit) ->
proc_push_revision_upd:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'res ->
unit) ->
unit) ->
proc_push_inodeblocks_ins:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'res ->
unit) ->
unit) ->
proc_push_inodeblocks_del:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'res ->
unit) ->
unit) ->
proc_push_names_ins:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'res ->
unit) ->
unit) ->
proc_push_names_del:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'arg ->
(Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'res ->
unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Monitor :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Monitor'V1'null'arg ->
Pfs_rpcapi_aux.t_Monitor'V1'null'res) ->
proc_start:(Pfs_rpcapi_aux.t_Monitor'V1'start'arg ->
Pfs_rpcapi_aux.t_Monitor'V1'start'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Monitor'V1'null'arg ->
(Pfs_rpcapi_aux.t_Monitor'V1'null'res -> unit) -> unit) ->
proc_start:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Monitor'V1'start'arg ->
(Pfs_rpcapi_aux.t_Monitor'V1'start'res -> unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Request_notifications :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Request_notifications'V1'null'arg ->
Pfs_rpcapi_aux.t_Request_notifications'V1'null'res) ->
proc_on_inode_update:(Pfs_rpcapi_aux.t_Request_notifications'V1'on_inode_update'arg ->
Pfs_rpcapi_aux.t_Request_notifications'V1'on_inode_update'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Request_notifications'V1'null'arg ->
(Pfs_rpcapi_aux.t_Request_notifications'V1'null'res ->
unit) ->
unit) ->
proc_on_inode_update:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Request_notifications'V1'on_inode_update'arg ->
(Pfs_rpcapi_aux.t_Request_notifications'V1'on_inode_update'res ->
unit) ->
unit) ->
Rpc_server.t -> unit
end
end
module Notifications :
sig
module V1 :
sig
val bind :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Pfs_rpcapi_aux.t_Notifications'V1'null'arg ->
Pfs_rpcapi_aux.t_Notifications'V1'null'res) ->
proc_inode_update:(Pfs_rpcapi_aux.t_Notifications'V1'inode_update'arg ->
Pfs_rpcapi_aux.t_Notifications'V1'inode_update'res) ->
Rpc_server.t -> unit
val bind_async :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
proc_null:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Notifications'V1'null'arg ->
(Pfs_rpcapi_aux.t_Notifications'V1'null'res -> unit) ->
unit) ->
proc_inode_update:(Rpc_server.session ->
Pfs_rpcapi_aux.t_Notifications'V1'inode_update'arg ->
(Pfs_rpcapi_aux.t_Notifications'V1'inode_update'res ->
unit) ->
unit) ->
Rpc_server.t -> unit
end
end
end
