module Uq_server:sig
..end
typelisten_address =
[ `Socket of Uq_engines.sockspec * listen_options
| `W32_pipe of Netsys_win32.pipe_mode * string * listen_options ]
`Socket(addr,opts)
: It is listened on a socket with address addr
`W32_pipe(mode,name,opts)
: It is listened on a pipe server with
name
which accepts pipe connections in mode
.typelisten_options =
Uq_engines.listen_options
= {
|
lstn_backlog : |
(* | The length of the queue of not yet accepted connections. | *) |
|
lstn_reuseaddr : |
(* | Whether to allow that the address can be immediately reused after the previous listener has its socket shut down. (Only for Internet sockets.) | *) |
val default_listen_options : listen_options
class type server_endpoint_acceptor =object
..end
class direct_acceptor :?close_on_shutdown:bool -> ?preclose:unit -> unit -> Unix.file_descr -> Unixqueue.event_system ->
server_endpoint_acceptor
server_endpoint_acceptor
for sockets and Win32
named pipes.
val listener : ?proxy:#Uq_engines.server_endpoint_listener ->
listen_address ->
Unixqueue.event_system ->
server_endpoint_acceptor Uq_engines.engine
listen_address
.
If passed, the proxy
is used to create the server socket.
On success, the engine goes to state `Done acc
, where acc
is
the acceptor object (see above). The acceptor object can be used
to accept incoming connections.