Tcp supports connection to inet sockets and unix sockets. These are two
different types. We use 'a where_to_connect to specify a socket to connect to,
where the 'a identifies the type of socket.
val to_host_and_port : ?via_local_interface:Async_extra.Import.Unix.Inet_addr.t ‑> ?via_local_port:int ‑> string ‑> int ‑> Async_extra.Import.Socket.Address.Inet.t where_to_connectval to_inet_address : ?via_local_interface:Async_extra.Import.Unix.Inet_addr.t ‑> ?via_local_port:int ‑> Async_extra.Import.Socket.Address.Inet.t ‑> Async_extra.Import.Socket.Address.Inet.t where_to_connectval to_file : string ‑> Async_extra.Import.Socket.Address.Unix.t where_to_connectval to_unix_address : Async_extra.Import.Socket.Address.Unix.t ‑> Async_extra.Import.Socket.Address.Unix.t where_to_connecttype 'a with_connect_options = ?buffer_age_limit:[ `At_most of Core.Time.Span.t | `Unlimited ] ‑> ?interrupt:unit Async_extra.Import.Deferred.t ‑> ?reader_buffer_size:int ‑> ?timeout:Core.Time.Span.t ‑> 'aval with_connection : ('addr where_to_connect ‑> (([ `Active ], 'addr) Async_extra.Import.Socket.t ‑> Async_extra.Import.Reader.t ‑> Async_extra.Import.Writer.t ‑> 'a Async_extra.Import.Deferred.t) ‑> 'a Async_extra.Import.Deferred.t) with_connect_optionswith_connection ~host ~port f looks up host from a string (using DNS as needed),
connects, then calls f, passing the connected socket and a reader and writer for it.
When the deferred returned by f is determined, or any exception is thrown, the
socket, reader and writer are closed. The return deferred is fulfilled after f has
finished processing and the file descriptor for the socket is closed. If interrupt
is supplied then the connection attempt will be aborted if interrupt is fulfilled
before the connection has been established. Similarly, all connection attempts have a
timeout (default 10s), that can be overridden with timeout.
It is fine for f to ignore the supplied socket and just use the reader and writer.
The socket is there to make it convenient to call Socket functions.
val connect_sock : ?socket:([ `Unconnected ], 'addr) Async_extra.Import.Socket.t ‑> ?interrupt:unit Async_extra.Import.Deferred.t ‑> ?timeout:Core.Time.Span.t ‑> 'addr where_to_connect ‑> ([ `Active ], 'addr) Async_extra.Import.Socket.t Async_extra.Import.Deferred.tconnect_sock where_to_connect creates a socket and opens a TCP connection. To use
an existing socket, supply ~socket. Any errors in the connection will be reported
to the monitor that was current when connect_sock was called.
val connect : ?socket:([ `Unconnected ], 'addr) Async_extra.Import.Socket.t ‑> ('addr where_to_connect ‑> (([ `Active ], 'addr) Async_extra.Import.Socket.t * Async_extra.Import.Reader.t * Async_extra.Import.Writer.t) Async_extra.Import.Deferred.t) with_connect_optionsconnect ~host ~port is a convenience wrapper around connect_sock that returns the
socket, and a reader and writer for the socket. The reader and writer share a file
descriptor, and so closing one will affect the other by closing its underlying fd. In
particular, closing the reader before closing the writer will cause the writer to
subsequently raise an exception when it attempts to flush internally-buffered bytes to
the OS, due to a closed fd. You should close the Writer first to avoid this
problem.
If possible, use with_connection, which automatically handles closing.
It is fine to ignore the returned socket and just use the reader and writer. The
socket is there to make it convenient to call Socket functions.
module Where_to_listen : sig ... endA Where_to_listen describes the socket that a tcp server should listen on.
module Bind_to_address : sig ... endmodule Bind_to_port : sig ... endval bind_to : Bind_to_address.t ‑> Bind_to_port.t ‑> Where_to_listen.inetListen on the specified port on the specified addresses
val on_port_chosen_by_os : Where_to_listen.ineton_port_chosen_by_os port is bind_to All_addresses On_port_chosen_by_os