Plasma GitLab Archive
Projects Blog Knowledge

sig
  type mclient
  type mclient_config = {
    mclient_rcache : Rpc_proxy.ReliabilityCache.rcache;
    mclient_socket_config : Rpc_client.socket_config;
    mclient_idle_timeout : float;
    mclient_programs : Rpc_program.t list;
    mclient_msg_timeout : float;
    mclient_msg_timeout_is_fatal : bool;
    mclient_exception_handler : (exn -> unit) option;
    mclient_auth_methods : Rpc_client.auth_method list;
    mclient_user_name : string option;
    mclient_initial_ping : bool;
    mclient_max_response_length : int option;
    mclient_mstring_factories : Netxdr_mstring.named_mstring_factories option;
  }
  exception Service_unavailable
  val create_mclient_config :
    ?rcache:Rpc_proxy.ReliabilityCache.rcache ->
    ?socket_config:Rpc_client.socket_config ->
    ?idle_timeout:float ->
    ?programs:Rpc_program.t list ->
    ?msg_timeout:float ->
    ?msg_timeout_is_fatal:bool ->
    ?exception_handler:(exn -> unit) ->
    ?auth_methods:Rpc_client.auth_method list ->
    ?user_name:string option ->
    ?initial_ping:bool ->
    ?max_response_length:int ->
    ?mstring_factories:Netxdr_mstring.named_mstring_factories ->
    unit -> Rpc_proxy.ManagedClient.mclient_config
  val create_mclient :
    Rpc_proxy.ManagedClient.mclient_config ->
    Rpc_client.connector ->
    Unixqueue.event_system -> Rpc_proxy.ManagedClient.mclient
  type state = [ `Connecting | `Down | `Up of Unix.sockaddr option ]
  val mclient_state :
    Rpc_proxy.ManagedClient.mclient -> Rpc_proxy.ManagedClient.state
  val mclient_serial : Rpc_proxy.ManagedClient.mclient -> int
  val pending_calls : Rpc_proxy.ManagedClient.mclient -> int
  val event_system :
    Rpc_proxy.ManagedClient.mclient -> Unixqueue.event_system
  val shut_down : Rpc_proxy.ManagedClient.mclient -> unit
  val sync_shutdown : Rpc_proxy.ManagedClient.mclient -> unit
  val trigger_shutdown :
    Rpc_proxy.ManagedClient.mclient -> (unit -> unit) -> unit
  val record_unavailability : Rpc_proxy.ManagedClient.mclient -> unit
  val enforce_unavailability : Rpc_proxy.ManagedClient.mclient -> unit
  val set_batch_call : Rpc_proxy.ManagedClient.mclient -> unit
  val rpc_engine :
    Rpc_proxy.ManagedClient.mclient ->
    (Rpc_proxy.ManagedClient.mclient -> '-> ((unit -> 'b) -> unit) -> unit) ->
    '-> 'Uq_engines.engine
  val compare :
    Rpc_proxy.ManagedClient.mclient -> Rpc_proxy.ManagedClient.mclient -> int
  type t = mclient
  val use : t -> Rpc_program.t -> unit
  val unbound_sync_call :
    t -> Rpc_program.t -> string -> Netxdr.xdr_value -> Netxdr.xdr_value
  val unbound_async_call :
    t ->
    Rpc_program.t ->
    string ->
    Netxdr.xdr_value -> ((unit -> Netxdr.xdr_value) -> unit) -> unit
  val xdr_ctx : t -> Netxdr.ctx
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml