Plasma GitLab Archive
Projects Blog Knowledge

sig
  module Make'Datanode :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'null'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'null'res) -> unit) ->
              unit
            val identity :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'identity'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'identity'res
            val identity'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'identity'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'identity'res) -> unit) ->
              unit
            val size :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'size'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'size'res
            val size'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'size'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'size'res) -> unit) ->
              unit
            val blocksize :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'blocksize'res
            val blocksize'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'blocksize'res) -> unit) ->
              unit
            val clustername :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'clustername'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'clustername'res
            val clustername'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'clustername'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'clustername'res) -> unit) ->
              unit
            val read :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'read'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'read'res
            val read'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'read'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'read'res) -> unit) ->
              unit
            val write :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'write'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'write'res
            val write'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'write'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'write'res) -> unit) ->
              unit
            val copy :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'copy'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'copy'res
            val copy'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'copy'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'copy'res) -> unit) ->
              unit
            val zero :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'zero'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'zero'res
            val zero'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'zero'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'zero'res) -> unit) ->
              unit
            val sync :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'sync'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'sync'res
            val sync'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'sync'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'sync'res) -> unit) ->
              unit
            val alloc_shm_if_local :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res
            val alloc_shm_if_local'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res) ->
               unit) ->
              unit
            val udsocket_if_local :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
              Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res
            val udsocket_if_local'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res) ->
               unit) ->
              unit
          end
      end
  module Datanode :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'null'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'null'res) -> unit) -> unit
          val identity :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'identity'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'identity'res
          val identity'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'identity'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'identity'res) -> unit) ->
            unit
          val size :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'size'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'size'res
          val size'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'size'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'size'res) -> unit) -> unit
          val blocksize :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'blocksize'res
          val blocksize'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'blocksize'res) -> unit) ->
            unit
          val clustername :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'clustername'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'clustername'res
          val clustername'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'clustername'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'clustername'res) -> unit) ->
            unit
          val read :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'read'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'read'res
          val read'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'read'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'read'res) -> unit) -> unit
          val write :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'write'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'write'res
          val write'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'write'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'write'res) -> unit) ->
            unit
          val copy :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'copy'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'copy'res
          val copy'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'copy'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'copy'res) -> unit) -> unit
          val zero :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'zero'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'zero'res
          val zero'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'zero'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'zero'res) -> unit) -> unit
          val sync :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'sync'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'sync'res
          val sync'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'sync'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'sync'res) -> unit) -> unit
          val alloc_shm_if_local :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res
          val alloc_shm_if_local'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res) ->
             unit) ->
            unit
          val udsocket_if_local :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
            Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res
          val udsocket_if_local'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res) ->
             unit) ->
            unit
        end
    end
  module Make'Datanode_ctrl :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'arg ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'res) -> unit) ->
              unit
            val reset_all_safetrans :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'arg ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'res
            val reset_all_safetrans'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'arg ->
              ((unit ->
                Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'res) ->
               unit) ->
              unit
            val cancel_safetrans :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'arg ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'res
            val cancel_safetrans'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'arg ->
              ((unit ->
                Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'res) ->
               unit) ->
              unit
            val safetrans :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'arg ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'res
            val safetrans'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'res) ->
               unit) ->
              unit
          end
      end
  module Datanode_ctrl :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'arg ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'res) -> unit) ->
            unit
          val reset_all_safetrans :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'arg ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'res
          val reset_all_safetrans'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'arg ->
            ((unit ->
              Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'res) ->
             unit) ->
            unit
          val cancel_safetrans :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'arg ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'res
          val cancel_safetrans'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'res) ->
             unit) ->
            unit
          val safetrans :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'arg ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'res
          val safetrans'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'res) ->
             unit) ->
            unit
        end
    end
  module Make'Datanode_io :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'null'arg ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'null'res) -> unit) ->
              unit
            val read :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'read'arg ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'read'res
            val read'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'read'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'read'res) -> unit) ->
              unit
            val read_shm :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'arg ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'res
            val read_shm'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'res) -> unit) ->
              unit
            val write :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'write'arg ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'write'res
            val write'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'write'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'write'res) -> unit) ->
              unit
            val write_shm :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'arg ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'res
            val write_shm'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'res) ->
               unit) ->
              unit
            val copy :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'copy'arg ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'copy'res
            val copy'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'copy'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'copy'res) -> unit) ->
              unit
            val sync :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'sync'arg ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'sync'res
            val sync'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'sync'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'sync'res) -> unit) ->
              unit
            val size :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'size'arg ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'size'res
            val size'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'size'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'size'res) -> unit) ->
              unit
            val identity :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'identity'arg ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'identity'res
            val identity'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_io'V1'identity'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'identity'res) -> unit) ->
              unit
          end
      end
  module Datanode_io :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'null'arg ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'null'res) -> unit) ->
            unit
          val read :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'read'arg ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'read'res
          val read'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'read'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'read'res) -> unit) ->
            unit
          val read_shm :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'arg ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'res
          val read_shm'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'res) -> unit) ->
            unit
          val write :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'write'arg ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'write'res
          val write'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'write'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'write'res) -> unit) ->
            unit
          val write_shm :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'arg ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'res
          val write_shm'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'res) -> unit) ->
            unit
          val copy :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'copy'arg ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'copy'res
          val copy'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'copy'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'copy'res) -> unit) ->
            unit
          val sync :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'sync'arg ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'sync'res
          val sync'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'sync'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'sync'res) -> unit) ->
            unit
          val size :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'size'arg ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'size'res
          val size'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'size'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'size'res) -> unit) ->
            unit
          val identity :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'identity'arg ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'identity'res
          val identity'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_io'V1'identity'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'identity'res) -> unit) ->
            unit
        end
    end
  module Make'Datanode_discover :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_discover'V1'null'arg ->
              Pfs_rpcapi_aux.t_Datanode_discover'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_discover'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_discover'V1'null'res) ->
               unit) ->
              unit
            val identity :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'arg ->
              Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'res
            val identity'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'res) ->
               unit) ->
              unit
          end
      end
  module Datanode_discover :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_discover'V1'null'arg ->
            Pfs_rpcapi_aux.t_Datanode_discover'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_discover'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_discover'V1'null'res) -> unit) ->
            unit
          val identity :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'arg ->
            Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'res
          val identity'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'res) ->
             unit) ->
            unit
        end
    end
  module Make'Filesystem :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'null'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'null'res) -> unit) ->
              unit
            val begin_transaction :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'res
            val begin_transaction'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'res) ->
               unit) ->
              unit
            val commit_transaction :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'res
            val commit_transaction'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'res) ->
               unit) ->
              unit
            val abort_transaction :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'res
            val abort_transaction'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'res) ->
               unit) ->
              unit
            val get_inodeinfo :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res
            val get_inodeinfo'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res) ->
               unit) ->
              unit
            val allocate_inode :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'res
            val allocate_inode'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'res) ->
               unit) ->
              unit
            val update_inodeinfo :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res
            val update_inodeinfo'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res) ->
               unit) ->
              unit
            val delete_inode :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'res
            val delete_inode'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'res) ->
               unit) ->
              unit
            val get_blocks :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'res
            val get_blocks'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'res) ->
               unit) ->
              unit
            val allocate_blocks :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res
            val allocate_blocks'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res) ->
               unit) ->
              unit
            val free_blocks :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'res
            val free_blocks'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'res) ->
               unit) ->
              unit
            val get_fsstat :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'res
            val get_fsstat'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'res) ->
               unit) ->
              unit
            val rereplicate :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'res
            val rereplicate'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'res) ->
               unit) ->
              unit
            val get_blocksize :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'res
            val get_blocksize'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'res) ->
               unit) ->
              unit
            val get_params :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_params'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_params'res
            val get_params'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_params'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_params'res) ->
               unit) ->
              unit
            val lookup :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'lookup'res
            val lookup'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'lookup'res) -> unit) ->
              unit
            val rev_lookup :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'res
            val rev_lookup'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'res) ->
               unit) ->
              unit
            val rev_lookup_dir :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'res
            val rev_lookup_dir'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'res) ->
               unit) ->
              unit
            val link_count :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'link_count'res
            val link_count'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link_count'res) ->
               unit) ->
              unit
            val link :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'link'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'link'res
            val link'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'link'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link'res) -> unit) ->
              unit
            val link_at :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'link_at'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'link_at'res
            val link_at'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'link_at'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link_at'res) -> unit) ->
              unit
            val unlink :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'unlink'res
            val unlink'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'unlink'res) -> unit) ->
              unit
            val unlink_at :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'res
            val unlink_at'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'res) -> unit) ->
              unit
            val list :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'list'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'list'res
            val list'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'list'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'list'res) -> unit) ->
              unit
            val rename :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rename'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rename'res
            val rename'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rename'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rename'res) -> unit) ->
              unit
            val rename_at :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'res
            val rename_at'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'res) -> unit) ->
              unit
            val namelock :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'namelock'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'namelock'res
            val namelock'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'namelock'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'namelock'res) -> unit) ->
              unit
            val set_block_checksum :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res
            val set_block_checksum'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res) ->
               unit) ->
              unit
            val iterate :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'iterate'res
            val iterate'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'iterate'res) -> unit) ->
              unit
            val impersonate :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'res
            val impersonate'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'res) ->
               unit) ->
              unit
            val get_auth_ticket :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'res
            val get_auth_ticket'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'res) ->
               unit) ->
              unit
            val renew_auth_ticket :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'res
            val renew_auth_ticket'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'res) ->
               unit) ->
              unit
            val read_admin_table :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'res
            val read_admin_table'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'res) ->
               unit) ->
              unit
            val write_admin_table :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'res
            val write_admin_table'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'res) ->
               unit) ->
              unit
            val is_up_to_date :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'res
            val is_up_to_date'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'res) ->
               unit) ->
              unit
            val is_up_to_date_seqno :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'arg ->
              Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'res
            val is_up_to_date_seqno'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'arg ->
              ((unit ->
                Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'res) ->
               unit) ->
              unit
          end
      end
  module Filesystem :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'null'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'null'res) -> unit) ->
            unit
          val begin_transaction :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'res
          val begin_transaction'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'res) ->
             unit) ->
            unit
          val commit_transaction :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'res
          val commit_transaction'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'res) ->
             unit) ->
            unit
          val abort_transaction :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'res
          val abort_transaction'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'res) ->
             unit) ->
            unit
          val get_inodeinfo :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res
          val get_inodeinfo'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res) ->
             unit) ->
            unit
          val allocate_inode :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'res
          val allocate_inode'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'res) ->
             unit) ->
            unit
          val update_inodeinfo :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res
          val update_inodeinfo'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res) ->
             unit) ->
            unit
          val delete_inode :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'res
          val delete_inode'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'res) ->
             unit) ->
            unit
          val get_blocks :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'res
          val get_blocks'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'res) -> unit) ->
            unit
          val allocate_blocks :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res
          val allocate_blocks'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res) ->
             unit) ->
            unit
          val free_blocks :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'res
          val free_blocks'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'res) -> unit) ->
            unit
          val get_fsstat :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'res
          val get_fsstat'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'res) -> unit) ->
            unit
          val rereplicate :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'res
          val rereplicate'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'res) -> unit) ->
            unit
          val get_blocksize :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'res
          val get_blocksize'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'res) ->
             unit) ->
            unit
          val get_params :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_params'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_params'res
          val get_params'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_params'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_params'res) -> unit) ->
            unit
          val lookup :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'lookup'res
          val lookup'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'lookup'res) -> unit) ->
            unit
          val rev_lookup :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'res
          val rev_lookup'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'res) -> unit) ->
            unit
          val rev_lookup_dir :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'res
          val rev_lookup_dir'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'res) ->
             unit) ->
            unit
          val link_count :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'link_count'res
          val link_count'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link_count'res) -> unit) ->
            unit
          val link :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'link'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'link'res
          val link'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'link'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link'res) -> unit) ->
            unit
          val link_at :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'link_at'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'link_at'res
          val link_at'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'link_at'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link_at'res) -> unit) ->
            unit
          val unlink :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'unlink'res
          val unlink'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'unlink'res) -> unit) ->
            unit
          val unlink_at :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'res
          val unlink_at'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'res) -> unit) ->
            unit
          val list :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'list'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'list'res
          val list'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'list'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'list'res) -> unit) ->
            unit
          val rename :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rename'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rename'res
          val rename'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rename'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rename'res) -> unit) ->
            unit
          val rename_at :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'res
          val rename_at'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'res) -> unit) ->
            unit
          val namelock :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'namelock'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'namelock'res
          val namelock'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'namelock'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'namelock'res) -> unit) ->
            unit
          val set_block_checksum :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res
          val set_block_checksum'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res) ->
             unit) ->
            unit
          val iterate :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'iterate'res
          val iterate'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'iterate'res) -> unit) ->
            unit
          val impersonate :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'res
          val impersonate'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'res) -> unit) ->
            unit
          val get_auth_ticket :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'res
          val get_auth_ticket'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'res) ->
             unit) ->
            unit
          val renew_auth_ticket :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'res
          val renew_auth_ticket'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'res) ->
             unit) ->
            unit
          val read_admin_table :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'res
          val read_admin_table'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'res) ->
             unit) ->
            unit
          val write_admin_table :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'res
          val write_admin_table'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'res) ->
             unit) ->
            unit
          val is_up_to_date :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'res
          val is_up_to_date'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'res) ->
             unit) ->
            unit
          val is_up_to_date_seqno :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'arg ->
            Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'res
          val is_up_to_date_seqno'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'res) ->
             unit) ->
            unit
        end
    end
  module Make'Coordination :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'null'arg ->
              Pfs_rpcapi_aux.t_Coordination'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'null'res) -> unit) ->
              unit
            val find_coordinator :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
              Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'res
            val find_coordinator'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'res) ->
               unit) ->
              unit
            val find_namenodes :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
              Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'res
            val find_namenodes'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'res) ->
               unit) ->
              unit
            val is_coordinator :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
              Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'res
            val is_coordinator'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'res) ->
               unit) ->
              unit
            val clustername :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'clustername'arg ->
              Pfs_rpcapi_aux.t_Coordination'V1'clustername'res
            val clustername'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'clustername'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'clustername'res) ->
               unit) ->
              unit
            val local_identities :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
              Pfs_rpcapi_aux.t_Coordination'V1'local_identities'res
            val local_identities'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'local_identities'res) ->
               unit) ->
              unit
          end
      end
  module Coordination :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'null'arg ->
            Pfs_rpcapi_aux.t_Coordination'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'null'res) -> unit) ->
            unit
          val find_coordinator :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
            Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'res
          val find_coordinator'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'res) ->
             unit) ->
            unit
          val find_namenodes :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
            Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'res
          val find_namenodes'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'res) ->
             unit) ->
            unit
          val is_coordinator :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
            Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'res
          val is_coordinator'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'res) ->
             unit) ->
            unit
          val clustername :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'clustername'arg ->
            Pfs_rpcapi_aux.t_Coordination'V1'clustername'res
          val clustername'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'clustername'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'clustername'res) ->
             unit) ->
            unit
          val local_identities :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
            Pfs_rpcapi_aux.t_Coordination'V1'local_identities'res
          val local_identities'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Coordination'V1'local_identities'res) ->
             unit) ->
            unit
        end
    end
  module Make'Dn_admin :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'null'arg ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'null'res) -> unit) ->
              unit
            val add_datanode :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'res
            val add_datanode'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'res) ->
               unit) ->
              unit
            val enable_datanode :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res
            val enable_datanode'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res) ->
               unit) ->
              unit
            val disable_datanode :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res
            val disable_datanode'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res) ->
               unit) ->
              unit
            val is_enabled :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'res
            val is_enabled'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'res) -> unit) ->
              unit
            val is_alive :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'arg ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'res
            val is_alive'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'res) -> unit) ->
              unit
            val fsstat :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'arg ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'res
            val fsstat'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'res) -> unit) ->
              unit
            val lookup :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'res
            val lookup'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'res) -> unit) ->
              unit
            val datanodes :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'res
            val datanodes'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'res) -> unit) ->
              unit
            val destroy_datanode :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res
            val destroy_datanode'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res) ->
               unit) ->
              unit
          end
      end
  module Dn_admin :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'null'arg ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'null'res) -> unit) -> unit
          val add_datanode :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'res
          val add_datanode'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'res) -> unit) ->
            unit
          val enable_datanode :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res
          val enable_datanode'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res) ->
             unit) ->
            unit
          val disable_datanode :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res
          val disable_datanode'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res) ->
             unit) ->
            unit
          val is_enabled :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'res
          val is_enabled'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'res) -> unit) ->
            unit
          val is_alive :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'arg ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'res
          val is_alive'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'res) -> unit) ->
            unit
          val fsstat :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'arg ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'res
          val fsstat'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'res) -> unit) ->
            unit
          val lookup :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'res
          val lookup'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'res) -> unit) ->
            unit
          val datanodes :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'res
          val datanodes'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'res) -> unit) ->
            unit
          val destroy_datanode :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res
          val destroy_datanode'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res) ->
             unit) ->
            unit
        end
    end
  module Make'Elect :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Elect'V1'null'arg ->
              Pfs_rpcapi_aux.t_Elect'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Elect'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Elect'V1'null'res) -> unit) -> unit
            val announce :
              U'C.t ->
              Pfs_rpcapi_aux.t_Elect'V1'announce'arg ->
              Pfs_rpcapi_aux.t_Elect'V1'announce'res
            val announce'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Elect'V1'announce'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Elect'V1'announce'res) -> unit) ->
              unit
            val set_coordinator :
              U'C.t ->
              Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'arg ->
              Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'res
            val set_coordinator'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'res) ->
               unit) ->
              unit
          end
      end
  module Elect :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Elect'V1'null'arg ->
            Pfs_rpcapi_aux.t_Elect'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Elect'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Elect'V1'null'res) -> unit) -> unit
          val announce :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Elect'V1'announce'arg ->
            Pfs_rpcapi_aux.t_Elect'V1'announce'res
          val announce'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Elect'V1'announce'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Elect'V1'announce'res) -> unit) ->
            unit
          val set_coordinator :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'arg ->
            Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'res
          val set_coordinator'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'res) -> unit) ->
            unit
        end
    end
  module Make'Nameslave :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'null'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'null'res) -> unit) ->
              unit
            val begin_transaction :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'res
            val begin_transaction'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'res) ->
               unit) ->
              unit
            val prepare_commit :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'res
            val prepare_commit'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'res) ->
               unit) ->
              unit
            val commit :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'commit'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'commit'res
            val commit'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'commit'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'commit'res) -> unit) ->
              unit
            val set_ds_cache :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'res
            val set_ds_cache'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'res) ->
               unit) ->
              unit
            val push_inode_ins :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'res
            val push_inode_ins'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'res) ->
               unit) ->
              unit
            val push_inode_upd :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'res
            val push_inode_upd'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'res) ->
               unit) ->
              unit
            val push_inode_upd_time :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'res
            val push_inode_upd_time'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'res) ->
               unit) ->
              unit
            val push_inode_set_anonymous :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'res
            val push_inode_set_anonymous'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'arg ->
              ((unit ->
                Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'res) ->
               unit) ->
              unit
            val push_inode_del :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'res
            val push_inode_del'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'res) ->
               unit) ->
              unit
            val push_blockalloc_upd :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'res
            val push_blockalloc_upd'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'res) ->
               unit) ->
              unit
            val push_datastore_upd :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'res
            val push_datastore_upd'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'res) ->
               unit) ->
              unit
            val push_datastore_del :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'res
            val push_datastore_del'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'res) ->
               unit) ->
              unit
            val push_revision_upd :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'res
            val push_revision_upd'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'res) ->
               unit) ->
              unit
            val push_inodeblocks_ins :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'res
            val push_inodeblocks_ins'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'arg ->
              ((unit ->
                Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'res) ->
               unit) ->
              unit
            val push_inodeblocks_del :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'res
            val push_inodeblocks_del'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'arg ->
              ((unit ->
                Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'res) ->
               unit) ->
              unit
            val push_names_ins :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'res
            val push_names_ins'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'res) ->
               unit) ->
              unit
            val push_names_del :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'res
            val push_names_del'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'res) ->
               unit) ->
              unit
            val push_admin_table :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'res
            val push_admin_table'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'res) ->
               unit) ->
              unit
            val push_revision_clear :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'arg ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'res
            val push_revision_clear'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'res) ->
               unit) ->
              unit
          end
      end
  module Nameslave :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'null'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'null'res) -> unit) ->
            unit
          val begin_transaction :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'res
          val begin_transaction'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'res) ->
             unit) ->
            unit
          val prepare_commit :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'res
          val prepare_commit'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'res) ->
             unit) ->
            unit
          val commit :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'commit'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'commit'res
          val commit'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'commit'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'commit'res) -> unit) ->
            unit
          val set_ds_cache :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'res
          val set_ds_cache'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'res) -> unit) ->
            unit
          val push_inode_ins :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'res
          val push_inode_ins'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'res) ->
             unit) ->
            unit
          val push_inode_upd :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'res
          val push_inode_upd'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'res) ->
             unit) ->
            unit
          val push_inode_upd_time :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'res
          val push_inode_upd_time'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'res) ->
             unit) ->
            unit
          val push_inode_set_anonymous :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'res
          val push_inode_set_anonymous'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'arg ->
            ((unit ->
              Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'res) ->
             unit) ->
            unit
          val push_inode_del :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'res
          val push_inode_del'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'res) ->
             unit) ->
            unit
          val push_blockalloc_upd :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'res
          val push_blockalloc_upd'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'res) ->
             unit) ->
            unit
          val push_datastore_upd :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'res
          val push_datastore_upd'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'res) ->
             unit) ->
            unit
          val push_datastore_del :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'res
          val push_datastore_del'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'res) ->
             unit) ->
            unit
          val push_revision_upd :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'res
          val push_revision_upd'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'res) ->
             unit) ->
            unit
          val push_inodeblocks_ins :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'res
          val push_inodeblocks_ins'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'res) ->
             unit) ->
            unit
          val push_inodeblocks_del :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'res
          val push_inodeblocks_del'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'res) ->
             unit) ->
            unit
          val push_names_ins :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'res
          val push_names_ins'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'res) ->
             unit) ->
            unit
          val push_names_del :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'res
          val push_names_del'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'res) ->
             unit) ->
            unit
          val push_admin_table :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'res
          val push_admin_table'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'res) ->
             unit) ->
            unit
          val push_revision_clear :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'arg ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'res
          val push_revision_clear'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'res) ->
             unit) ->
            unit
        end
    end
  module Make'Monitor :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Monitor'V1'null'arg ->
              Pfs_rpcapi_aux.t_Monitor'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Monitor'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Monitor'V1'null'res) -> unit) ->
              unit
            val start :
              U'C.t ->
              Pfs_rpcapi_aux.t_Monitor'V1'start'arg ->
              Pfs_rpcapi_aux.t_Monitor'V1'start'res
            val start'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Monitor'V1'start'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Monitor'V1'start'res) -> unit) ->
              unit
          end
      end
  module Monitor :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Monitor'V1'null'arg ->
            Pfs_rpcapi_aux.t_Monitor'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Monitor'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Monitor'V1'null'res) -> unit) -> unit
          val start :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Monitor'V1'start'arg ->
            Pfs_rpcapi_aux.t_Monitor'V1'start'res
          val start'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Monitor'V1'start'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Monitor'V1'start'res) -> unit) -> unit
        end
    end
  module Make'Auth :
    functor (U'C : Rpc_client.USE_CLIENT->
      sig
        module V1 :
          sig
            type t = U'C.t
            val _program : Rpc_program.t
            val null :
              U'C.t ->
              Pfs_rpcapi_aux.t_Auth'V1'null'arg ->
              Pfs_rpcapi_aux.t_Auth'V1'null'res
            val null'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Auth'V1'null'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Auth'V1'null'res) -> unit) -> unit
            val get_auth_ticket :
              U'C.t ->
              Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'arg ->
              Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'res
            val get_auth_ticket'async :
              U'C.t ->
              Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'arg ->
              ((unit -> Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'res) -> unit) ->
              unit
          end
      end
  module Auth :
    sig
      module V1 :
        sig
          type t = Rpc_client.t
          val create_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
          val create_portmapped_client :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 ->
            string -> Rpc.protocol -> Rpc_client.t
          val create_client2 :
            ?esys:Unixqueue.event_system ->
            ?program_number:Rtypes.uint4 ->
            ?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
          val _program : Rpc_program.t
          val null :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Auth'V1'null'arg ->
            Pfs_rpcapi_aux.t_Auth'V1'null'res
          val null'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Auth'V1'null'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Auth'V1'null'res) -> unit) -> unit
          val get_auth_ticket :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'arg ->
            Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'res
          val get_auth_ticket'async :
            Rpc_client.t ->
            Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'arg ->
            ((unit -> Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'res) -> unit) ->
            unit
        end
    end
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml