package async_unix

You can search for identifiers within the package.

in-package search v0.2.0

async_unix
- Async_unix
  - Async_config
  - Clock
    
    Event
    
    Status
    
    Or_timeout
  - Dump_core_on_job_delay
    
    How_to_dump
  - Fd
    
    Close
    
    Kind
  - In_thread
    
    Helper_thread
    
    Priority
    
    When_finished
  - Io_stats
  - LargeFile
  - Log
    
    Blocking
    
    Output
    
    For_testing
    
    Global
    
    For_testing
    
    Global_intf
    
    For_testing
    
    Level
    
    Stable
    
    V1
    
    Make_global
    
    For_testing
    
    Message
    
    Stable
    
    V0
    
    V2
    
    Output
    
    Format
    
    Stable
    
    V1
    
    Reader
    
    Expert
    
    Rotation
    
    Id_intf
  - Overwrite_
  - Print
  - Printf
  - Process
    
    Lines_or_sexp
    
    Output
    
    Stable
    
    V1
  - Reader
    
    For_testing
    
    Id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Replace_polymorphic_compare
    
    Set
    
    Elt
    
    Named
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Elt
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Read_result
    
    Let_syntax
    
    Let_syntax
    
    Open_on_rhs
    
    Monad_infix
  - Require_explicit_time_source
    
    Clock
    
    Event
    
    Status
    
    Or_timeout
    
    Date
    
    Scheduler
    
    Time
    
    Ofday
    
    Time_ns
    
    Ofday
  - Scheduler
  - Sexp
  - Shutdown
  - Signal
  - Socket
    
    Address
    
    Blocking_sexp
    
    Inet
    
    Blocking_sexp
    
    Show_port_in_test
    
    Unix
    
    Family
    
    Opt
    
    Type
  - Sys
  - Tcp
    
    Bind_to_address
    
    Bind_to_port
    
    Server
    
    Where_to_connect
    
    Where_to_listen
  - Thread_safe
  - Unix
    
    Addr_info
    
    Blocking_sexp
    
    File_kind
    
    Map
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Replace_polymorphic_compare
    
    Set
    
    Elt
    
    Named
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Elt
    
    Provide_of_sexp
    
    Elt
    
    Group
    
    Fields
    
    Direct
    
    Host
    
    Inet_addr
    
    Lock
    
    Lock_mechanism
    
    Lock_mode
    
    Name_info
    
    Passwd
    
    Fields
    
    Direct
    
    Private
    
    Wait
    
    Protocol_family
    
    Socket
    
    Address
    
    Blocking_sexp
    
    Inet
    
    Blocking_sexp
    
    Show_port_in_test
    
    Unix
    
    Family
    
    Opt
    
    Type
    
    Stats
    
    Fields
    
    Direct
    
    Terminal_io
  - Writer
    
    Backing_out_channel
    
    Destroy_or_keep
    
    Flush_result
    
    Id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Replace_polymorphic_compare
    
    Set
    
    Elt
    
    Named
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Elt
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Line_ending
    
    Terminate_with
async_unix.thread_pool
- Thread_pool
  - Helper_thread
  - Priority
async_unix.thread_safe_ivar
- Thread_safe_ivar
async_unix.thread_safe_pipe
- Thread_safe_pipe
  - If_closed
  - Written_or_closed

Legend:
Library
Module
Module type
Parameter
Class
Class type

Tcp supports connection to inet sockets and unix sockets.

These are two different types. We use 'a Where_to_connect.t to specify a socket to connect to, where the 'a identifies the type of socket.

module Where_to_connect : sig ... end

A Where_to_connect describes the socket that a tcp client should connect to.

type 'a with_connect_options =
  ?buffer_age_limit:[ `At_most of Time_unix.Span.t | `Unlimited ] ->
  ?interrupt:unit Async_kernel.Deferred.t ->
  ?reader_buffer_size:int ->
  ?writer_buffer_size:int ->
  ?timeout:Time_unix.Span.t ->
  ?time_source:Async_kernel.Time_source.t ->
  'a

val with_connection : 
  ('addr Where_to_connect.t ->
    (([ `Active ], 'addr) Async_unix__.Unix_syscalls.Socket.t ->
      Reader.t ->
      Writer.t ->
      'a Async_kernel.Deferred.t) ->
    'a Async_kernel.Deferred.t)
    with_connect_options

with_connection where_to_connect f looks up where_to_connect (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 returned Deferred.t is fulfilled after f has finished processing and the file descriptor for the socket is closed. If interrupt is supplied, 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), which 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_unix__.Unix_syscalls.Socket.t ->
  ?interrupt:unit Async_kernel.Deferred.t ->
  ?timeout:Time_unix.Span.t ->
  ?time_source:[> Core.read ] Async_kernel.Time_source.T1.t ->
  'addr Where_to_connect.t ->
  ([ `Active ], 'addr) Async_unix__.Unix_syscalls.Socket.t
    Async_kernel.Deferred.t

connect_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_unix__.Unix_syscalls.Socket.t ->
  ('addr Where_to_connect.t ->
    (([ `Active ], 'addr) Async_unix__.Unix_syscalls.Socket.t
     * Reader.t
     * Writer.t)
      Async_kernel.Deferred.t)
    with_connect_options

connect where_to_connect 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 Bind_to_address : sig ... end

module Bind_to_port : sig ... end

module Where_to_listen : sig ... end

A Where_to_listen describes the socket that a tcp server should listen on.

module Server : sig ... end

A Server.t represents a TCP server listening on a socket.