Index of values

Closes the connection immediately (no close connection message).

Closes the connection immediately (no close connection message).

Returns the bound adapters (object dispatchers)

Returns the bound adapters (object dispatchers)

Binds an object dispatcher

Binds an object dispatcher

Create a set of call parameters.

Checks whether the object monobj is alive with respect to the given operation.

Returns an identifier for the client

Create a set of client parameters: trans_timeout: If non-negative, a timeout on the transport level is set. This means that connections that block for more than this number of seconds time out. In this case, the whole client fails, and all pending calls see a Client_condition `Transport_timeout if it happens in the middle of a connection, or Client_condition `Connect_timeout if it happens in the connect phase. (Default: -1), msg_timeout: If non-negative, the number tmo is the maximum number of seconds until when a response must have been arrived. Otherwise the call times out with a Client_condition `Message_timeout. This error is non-fatal, and only the single call times out. (Only used for twoway calls.) (Default: -1), idle_timeout: when the client has been idle for this number of seconds, it is automatically shut down. "Idle" means that there is neither something to send nor a message is expected to be received. (Default: -1), The exception_handler is invoked for exceptions that cannot be handled by the client. The handler is never invoked for Unbound_exceptions - these always fall through to the caller. In any case the client is shut down for exceptions that cannot be handled by the client. (Default: default_exception_handler), max_proto_minor and max_enc_minor are the maximum minor versions of the server. These values are only used in the datagram case; for stream connections they can be obtained directly from the server. If not set, minor numbers of 0 are assumed.

Compares two client params objects, and returns a result like Pervasives.compare.

Used with ["hydro:mapping:complex"]

Configures the client.

Configures the proxy such that the liveliness of the server port is checked before every call.

Create a new server

Create a new client

create_cache port period () : Create empty cache that is connected with the Hydromon instance port.

Create an empty type system

The multiplex controller for datagrams

decapsulate (nb,pos,len): Interprets the len bytes at pos in nb as encapsulation, and returns its contents also in the format (nb',pos',len').

The default handler just prints the exception to stderr

descriptor fd is_master tpt: Create a hydro descriptor

encapsulate f b e: Calls f b and prepends the encapsulation header.

Returns the endpoint name (for creating proxies)

Raise Error

Return a proxy referring to ::Ice::Locator for a host and a port

Return a proxy referring to ::Ice::Locator from the stringified representation

Get transporter or raise Limitation `UnsupportedEndpointType

The graceful flag is initially true, but set to false when a fatal error or a non-graceful shutdown happens

Used with ["hydro:mapping:hashtbl"]

A factory for TCP-based Hydro servers.

Reads the config from the config file, and starts the processor

Start the Hydromon processor for this configuration

Used with ["hydro:mapping:identity"]

Whether the client is up and idle

Whether the client is up (accepts new requests)

marshal sys ht class_flag val nb e: Encodes the value val which is supposed to be of type ht and appends the string to nb.

marshal_exn sys hx val nb e: Encodes the exception value val which is supposed to be of (static) exn type hx and appends the string to nb.

marshal_msg sys zstat msg p e: Returns a message buffer (header and bodies) for a message.

Maximum versions we can support

Create a proxy configuration that modifies the values found in the input configuration.

Creates a new object adapter

Get the `Value

Used with ["hydro:mapping:option"]

Default implementation of a pool.

Used by Hydro_proxy.pool: The callback function is invoked when is_up becomes false

Create a reference from a (low-level) proxy address

Create a reference from a stringified proxy address

Various printers

Create a proxy for this environment and this proxy address

Create a fresh proxy configuration.

A proxy_resolver that also supports indirect lookups through a locator service like icegridnode.

The default resolver looks for available endpoints and returns them in the order they occur in the address.

Number of requests in the queue (that are not yet responded)

register_adapter loc adapterId replicaGroupId ep: Register the endpoint ep as adapter with name adapterId and the optional replicaGroupId in the locator service.

register_adapters loc l ep: Registers all adapters in l for the endpoint ep in the locator service loc.

Registers new transporters.

Returns an identifier for the server

Create a set of server parameters: trans_timeout: If non-negative, a timeout on the transport level is set. This means that connections that block for more than this number of seconds time out. In this case, the connection is dropped

shuffle rnd (proxy_resolver params): shuffles the endpoints so that they are in random order

Shut the server gracefully down (by sending a close connection message)

Shut the client gracefully down (by sending a close connection message).

Shutdown gracefully the next time the client becomes idle

The multiplex controller for stream encapsulation

Used with ["hydro:mapping:strmap"]

Returns the TCP endpoint for the TCP address, the timeout value, and the compression flag.

Conversion from/to value

Starts a twoway call

Removes the object dispatcher binding

Removes the object dispatcher binding

unmarshal sys ht class_flag eb: Decodes the value at pos with length len in nb which is supposed to be of type ht and returns it.

unmarshal_exn sys (nb,pos,len) : Decodes the exception value at pos with length len in nb and returns it.

Returns a message for a message buffer (header and body)

unregister_adapter loc adapterId replicaGroupId: Remove the registration entry for the adapter called adapterId and the optional replicaGroupId from the locator service.

unregister_adapters loc l: Remove the registeration of all adapters in l for the from the locator service loc.

Get the proxy specification from a reference

Modifies the given call params

Modifies the given client params

Updates the trans_timeout, max_proto_minor and max_enc_minor parameters by the values found in the endpoint: trans_timeout: is compared with the timeout of the endpoint, and the smaller value is taken, max_proto_minor and max_enc_minor: taken from the endpoint

Modifies the given server params

Create a value from any object

Create a proxy reference.