X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?p=elogind.git;a=blobdiff_plain;f=src%2Fsocket.h;h=fd13ac4e4c8e035033523f9b6bb64a085d7a813a;hp=de3e913f7cd787dc8826036bb9c10c3873bb939f;hb=1cc101f1e59ca2f5e87dea48ac9ed98c6f077b3b;hpb=0213c3f8102bdc934c629d11a44ca0b408762287 diff --git a/src/socket.h b/src/socket.h index de3e913f7..fd13ac4e4 100644 --- a/src/socket.h +++ b/src/socket.h @@ -1,4 +1,4 @@ -/*-*- Mode: C; c-basic-offset: 8 -*-*/ +/*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/ #ifndef foosockethfoo #define foosockethfoo @@ -41,7 +41,7 @@ typedef enum SocketState { SOCKET_STOP_POST, SOCKET_FINAL_SIGTERM, SOCKET_FINAL_SIGKILL, - SOCKET_MAINTENANCE, + SOCKET_FAILED, _SOCKET_STATE_MAX, _SOCKET_STATE_INVALID = -1 } SocketState; @@ -58,6 +58,8 @@ typedef enum SocketExecCommand { typedef enum SocketType { SOCKET_SOCKET, SOCKET_FIFO, + SOCKET_SPECIAL, + SOCKET_MQUEUE, _SOCKET_FIFO_MAX, _SOCKET_FIFO_INVALID = -1 } SocketType; @@ -78,36 +80,55 @@ struct Socket { LIST_HEAD(SocketPort, ports); - /* Only for INET6 sockets: issue IPV6_V6ONLY sockopt */ - SocketAddressBindIPv6Only bind_ipv6_only; - unsigned backlog; + unsigned n_accepted; + unsigned n_connections; + unsigned max_connections; + unsigned backlog; usec_t timeout_usec; ExecCommand* exec_command[_SOCKET_EXEC_COMMAND_MAX]; ExecContext exec_context; + /* For Accept=no sockets refers to the one service we'll + activate. For Accept=yes sockets is either NULL, or filled + when the next service we spawn. */ Service *service; SocketState state, deserialized_state; - KillMode kill_mode; + Watch timer_watch; ExecCommand* control_command; SocketExecCommand control_command_id; pid_t control_pid; - char *bind_to_device; + /* Only for INET6 sockets: issue IPV6_V6ONLY sockopt */ + SocketAddressBindIPv6Only bind_ipv6_only; + mode_t directory_mode; mode_t socket_mode; - char *tcpwrap_name; + bool failure; bool accept; - unsigned n_accepted; - bool failure; - Watch timer_watch; + /* Socket options */ + bool keep_alive; + bool free_bind; + bool transparent; + bool broadcast; + int priority; + int mark; + size_t receive_buffer; + size_t send_buffer; + int ip_tos; + int ip_ttl; + size_t pipe_size; + char *bind_to_device; + char *tcp_congestion; + long mq_maxmsg; + long mq_msgsize; }; /* Called from the service code when collecting fds */ @@ -120,6 +141,9 @@ void socket_notify_service_dead(Socket *s); * any of the sockets of this socket */ int socket_add_one_mount_link(Socket *s, Mount *m); +/* Called from the service code when a per-connection service ended */ +void socket_connection_unref(Socket *s); + extern const UnitVTable socket_vtable; const char* socket_state_to_string(SocketState i);