sig
class type multiplexed_descriptor =
object
method ctrl : Hydro_transport.hydro_multiplex_controller
method file_descr : Unix.file_descr
method is_master : bool
method proto_type : Hydro_types.transport_protocol_type
method shutdown : unit -> unit
end
type client_connector =
[ `Endpoint of Hydro_types.endpoint * Hydro_types.network_port option ]
val client_endpoint_type :
Hydro_connector.client_connector -> Hydro_types.endpoint_type
type master_connector =
[ `Anon_endpoint_IPv4 of Hydro_types.endpoint_type
| `Anon_endpoint_IPv6 of Hydro_types.endpoint_type
| `Named_endpoint of Unix.sockaddr * Hydro_types.endpoint_type ]
val master_endpoint_type :
Hydro_connector.master_connector -> Hydro_types.endpoint_type
class type transporter =
object
method client_connect_engine :
Hydro_connector.client_connector ->
Unixqueue.event_system ->
Hydro_connector.multiplexed_descriptor Uq_engines.engine
method endpoint_type : Hydro_types.endpoint_type
method proxy_modes : Hydro_types.proxy_mode list
method server_accept_engine :
Hydro_types.descriptor ->
Unixqueue.event_system -> Hydro_types.descriptor Uq_engines.engine
method server_create_engine :
Hydro_connector.master_connector ->
Unixqueue.event_system -> Hydro_types.descriptor Uq_engines.engine
method server_endpoint :
Hydro_types.descriptor ->
Hydro_types.server_params -> Hydro_types.endpoint
method server_multiplex_connection :
Hydro_types.descriptor ->
Unixqueue.event_system ->
Hydro_connector.multiplexed_descriptor Uq_engines.engine
end
val register_transporter : Hydro_connector.transporter -> unit
val get_transporter :
Hydro_types.endpoint_type -> Hydro_connector.transporter
val descriptor :
Unix.file_descr ->
bool -> Hydro_types.transport_protocol_type -> Hydro_types.descriptor
val tcp_endpoint_of_file_descr :
Unix.sockaddr -> float -> bool -> Hydro_types.tcp_endpoint
end
