Module Tezos_base_unix.SocketSource

Sourcetype addr =
  1. | Unix of string
  2. | Tcp of string * string * Unix.getaddrinfo_option list
Sourceval connect : ?timeout:Ptime.Span.t -> addr -> Lwt_unix.file_descr Tezos_base.TzPervasives.Error_monad.tzresult Lwt.t

connect ?timeout addr tries connecting to addr and returns the resulting socket file descriptor on success. When using TCP, Unix.getaddrinfo is used to resolve the hostname and service (port). The different socket addresses returned by Unix.getaddrinfo are tried sequentially, and the ?timeout argument (default: 5s) governs how long it waits to get a connection. If a connection is not obtained in less than ?timeout, the connection is canceled and and the next socket address (if it exists) is tried.

Sourceval with_connection : ?timeout:Ptime.Span.t -> addr -> (Lwt_unix.file_descr -> 'a Tezos_base.TzPervasives.Error_monad.tzresult Lwt.t) -> 'a Tezos_base.TzPervasives.Error_monad.tzresult Lwt.t
Sourceval bind : ?backlog:int -> addr -> Lwt_unix.file_descr list Tezos_base.TzPervasives.Error_monad.tzresult Lwt.t
Sourceval send : Lwt_unix.file_descr -> 'a Tezos_base.TzPervasives.Data_encoding.t -> 'a -> unit Tezos_base.TzPervasives.Error_monad.tzresult Lwt.t
Sourceval recv : ?timeout:Ptime.Span.t -> Lwt_unix.file_descr -> 'a Tezos_base.TzPervasives.Data_encoding.t -> 'a Tezos_base.TzPervasives.Error_monad.tzresult Lwt.t
Sourceval handshake : Lwt_unix.file_descr -> bytes -> unit Tezos_base.TzPervasives.Error_monad.tzresult Lwt.t

handshake socket magic_bytes is a function to synchronize two separate processes and start a communication.

The scenario of the handshake is the following:

  • both processes simultaneously send some magic_bytes,
  • both processes wait and checks the received bytes validity,
  • handshake is finished.
Sourceval get_temporary_socket_dir : unit -> string

get_temporary_socket_dir () returns a temporary path for the socket to be spawned. $XDG_RUNTIME_DIR is returned if the environment variable is defined. Otherwise, the default temporary directory is used.