sig
exception Message_lost
exception Message_timeout
exception Communication_error of exn
exception Client_is_down
exception Keep_call
exception Unbound_exception of exn
type t
type connector =
Inet of (string * int)
| Internet of (Unix.inet_addr * int)
| Unix of string
| Descriptor of Unix.file_descr
| Dynamic_descriptor of (unit -> Unix.file_descr)
| Portmapped of string
val shutdown_connector :
Rpc_client.t -> Rpc_transport.rpc_multiplex_controller -> unit
val create :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
?initial_xid:int ->
?shutdown:(Rpc_client.t -> Rpc_transport.rpc_multiplex_controller -> unit) ->
Unixqueue.event_system ->
Rpc_client.connector -> Rpc.protocol -> Rpc_program.t -> Rpc_client.t
class type socket_config =
object
method multiplexing :
close_inactive_descr:bool ->
Rpc.protocol ->
Unix.file_descr ->
Unixqueue.event_system ->
Rpc_transport.rpc_multiplex_controller Uq_engines.engine
method non_blocking_connect : bool
end
val default_socket_config : Rpc_client.socket_config
class default_socket_config : socket_config
val blocking_socket_config : Rpc_client.socket_config
class blocking_socket_config : socket_config
type mode2 =
[ `Multiplexer_endpoint of Rpc_transport.rpc_multiplex_controller
| `Socket of
Rpc.protocol * Rpc_client.connector * Rpc_client.socket_config
| `Socket_endpoint of Rpc.protocol * Unix.file_descr ]
val create2 :
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
?initial_xid:int ->
?shutdown:(Rpc_client.t -> Rpc_transport.rpc_multiplex_controller -> unit) ->
Rpc_client.mode2 ->
Rpc_program.t -> Unixqueue.event_system -> Rpc_client.t
val configure : Rpc_client.t -> int -> float -> unit
val set_dgram_destination : Rpc_client.t -> Unix.sockaddr option -> unit
val set_exception_handler : Rpc_client.t -> (exn -> unit) -> unit
val add_call :
?when_sent:(unit -> bool) ->
Rpc_client.t ->
string -> Xdr.xdr_value -> ((unit -> Xdr.xdr_value) -> unit) -> unit
val event_system : Rpc_client.t -> Unixqueue.event_system
val program : Rpc_client.t -> Rpc_program.t
val get_socket_name : Rpc_client.t -> Unix.sockaddr
val get_peer_name : Rpc_client.t -> Unix.sockaddr
val get_sender_of_last_response : Rpc_client.t -> Unix.sockaddr
val get_protocol : Rpc_client.t -> Rpc.protocol
val sync_call : Rpc_client.t -> string -> Xdr.xdr_value -> Xdr.xdr_value
val shut_down : Rpc_client.t -> unit
class type auth_session =
object
method next_credentials :
Rpc_client.t -> string * string * string * string
method server_accepts : string -> string -> unit
method server_rejects : Rpc.server_error -> unit
end
class type auth_method =
object
method name : string
method new_session : unit -> Rpc_client.auth_session
end
val auth_none : Rpc_client.auth_method
val set_auth_methods : Rpc_client.t -> Rpc_client.auth_method list -> unit
val verbose : bool -> unit
end
