ocamlnet 4.1.9-2 · OCaml Package

exception Message_lost

exception Message_timeout

exception Response_dropped

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
| W32_pipe of string
| Descriptor of Unix.file_descr
| Dynamic_descriptor of unit -> Unix.file_descr
| Portmapped of string

val connector_of_sockaddr : Unix.sockaddr -> connector

val connector_of_socksymbol : Netsockaddr.socksymbol -> connector

val shutdown_connector : 
  t ->
  Rpc_transport.rpc_multiplex_controller ->
  (unit -> unit) ->
  unit

class type socket_config = object ... end

val default_socket_config : socket_config

class default_socket_config : socket_config

val blocking_socket_config : socket_config

class blocking_socket_config : socket_config

val tls_socket_config : 
  (module Netsys_crypto_types.TLS_CONFIG) ->
  socket_config

class tls_socket_config : (module Netsys_crypto_types.TLS_CONFIG) -> socket_config

type internal_pipe = Netxdr.xdr_value Netsys_polypipe.polypipe

type internal_socket = Netxdr.xdr_value Netsys_polysocket.polyclient

type mode2 = [

| `Internal_endpoint of internal_pipe * internal_pipe
| `Internal_socket of internal_socket
| `Multiplexer_endpoint of Rpc_transport.rpc_multiplex_controller
| `Socket of Rpc.protocol * connector * socket_config
| `Socket_endpoint of Rpc.protocol * Unix.file_descr

]

val create2 : 
  ?program_number:Netnumber.uint4 ->
  ?version_number:Netnumber.uint4 ->
  ?initial_xid:int ->
  ?shutdown:
    (t -> Rpc_transport.rpc_multiplex_controller -> (unit -> unit) -> unit) ->
  mode2 ->
  Rpc_program.t ->
  Unixqueue.event_system ->
  t

val unbound_create : 
  ?initial_xid:int ->
  ?shutdown:
    (t -> Rpc_transport.rpc_multiplex_controller -> (unit -> unit) -> unit) ->
  mode2 ->
  Unixqueue.event_system ->
  t

val bind : t -> Rpc_program.t -> unit

val use : t -> Rpc_program.t -> unit

val configure : t -> int -> float -> unit

val configure_next_call : t -> int -> float -> unit

val set_dgram_destination : t -> Unix.sockaddr option -> unit

val set_batch_call : t -> unit

val set_user_name : t -> string option -> unit

val set_max_response_length : t -> int -> unit

val set_exception_handler : t -> (exn -> unit) -> unit

val set_mstring_factories : t -> Netxdr_mstring.named_mstring_factories -> unit

val event_system : t -> Unixqueue.event_system

val programs : t -> Rpc_program.t list

val get_socket_name : t -> Unix.sockaddr

val get_peer_name : t -> Unix.sockaddr

val get_sender_of_last_response : t -> Unix.sockaddr

val get_xid_of_last_call : t -> Netnumber.uint4

val get_protocol : t -> Rpc.protocol

val get_tls_session_props : t -> Nettls_support.tls_session_props option

val get_gssapi_props : t -> Netsys_gssapi.client_props option

val abandon_call : t -> Netnumber.uint4 -> unit

val is_up : t -> bool

val get_stats : t -> int * int * int

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

class unbound_async_call : t -> Rpc_program.t -> string -> Netxdr.xdr_value -> Uq_engines.engine

val synchronize : 
  Unixqueue.event_system ->
  ('a -> ((unit -> 'b) -> unit) -> unit) ->
  'a ->
  'b

val shut_down : t -> unit

val sync_shutdown : t -> unit

val trigger_shutdown : t -> (unit -> unit) -> unit

val set_debug_name : t -> string -> unit

val get_debug_name : t -> string

type reject_code = [

| `Fail
| `Next
| `Renew
| `Retry

]

class type auth_session = object ... end

class type auth_protocol = object ... end

class type auth_method = object ... end

val auth_none : auth_method

val set_auth_methods : t -> auth_method list -> unit

module type USE_CLIENT = sig ... end

val xdr_ctx : t -> Netxdr.ctx

val create : 
  ?program_number:Netnumber.uint4 ->
  ?version_number:Netnumber.uint4 ->
  ?initial_xid:int ->
  ?shutdown:
    (t -> Rpc_transport.rpc_multiplex_controller -> (unit -> unit) -> unit) ->
  Unixqueue.event_system ->
  connector ->
  Rpc.protocol ->
  Rpc_program.t ->
  t

val program : t -> Rpc_program.t

val add_call : 
  t ->
  string ->
  Netxdr.xdr_value ->
  ((unit -> Netxdr.xdr_value) -> unit) ->
  unit

val sync_call : t -> string -> Netxdr.xdr_value -> Netxdr.xdr_value

val verbose : bool -> unit

module Debug : sig ... end

package ocamlnet