sig
type listen_address =
[ `Socket of Uq_engines.sockspec * Uq_server.listen_options
| `W32_pipe of
Netsys_win32.pipe_mode * string * Uq_server.listen_options ]
and listen_options =
Uq_engines.listen_options = {
lstn_backlog : int;
lstn_reuseaddr : bool;
}
val default_listen_options : Uq_server.listen_options
val listen_on_inet_socket :
Unix.inet_addr ->
int -> Unix.socket_type -> Uq_server.listen_options -> Unix.file_descr
val listen_on_unix_socket :
string -> Unix.socket_type -> Uq_server.listen_options -> Unix.file_descr
val listen_on_w32_pipe :
Netsys_win32.pipe_mode ->
string -> Uq_server.listen_options -> Unix.file_descr
val listen_on : Uq_server.listen_address -> Unix.file_descr
class type server_endpoint_acceptor =
object
method accept :
unit ->
(Unix.file_descr * Uq_engines.inetspec option) Uq_engines.engine
method multiple_connections : bool
method server_address : Uq_engines.connect_address
method shut_down : unit -> unit
end
class direct_acceptor :
?close_on_shutdown:bool ->
?preclose:(unit -> unit) ->
Unix.file_descr -> Unixqueue.event_system -> server_endpoint_acceptor
val listener :
?proxy:#Uq_engines.server_endpoint_listener ->
Uq_server.listen_address ->
Unixqueue.event_system ->
Uq_server.server_endpoint_acceptor Uq_engines.engine
end
