Welcome worker.
Accept incoming connections and add them to the pool.
type listening_socket_open_failure = {reason : Unix.error;The error we are re-raising
*)address : Tezos_base.P2p_addr.t;The interface we are trying to listen to
*)port : int;The port we are trying to listen to
*)}Type discribing an opening failure for the listening socket.
type Tezos_base__TzPervasives.error += | Failed_to_open_listening_socket of listening_socket_open_failureType of an error in case where the listening socket fails to open.
val create :
?addr:Tezos_base.P2p_addr.t ->
backlog:int ->
('msg, 'meta, 'meta_conn) P2p_connect_handler.t ->
Tezos_base.P2p_addr.port ->
(t, Tezos_error_monad.TzCore.error list) result Lwt.tcreate ?addr ~backlog pool port returns a running welcome worker adding connections into pool listening on addr:port. backlog is passed to Lwt_unix.listen.
val activate : t -> unitactivate t start the worker that will accept connections