server.h File Reference

Go to the source code of this file.

Data Structures
struct	tcp_server_config_t
struct	tcp_server
	The useful part of tcp server is in event_loop, listen_socket, listen_socket6, running: together they describe what is pending, who owns it, and how much data is valid. Keep the object with its parent operation and use the parent cleanup path. More...

Typedefs
typedef struct tcp_client_entry	tcp_client_entry_t
typedef struct tcp_server	tcp_server_t

Functions
asciichat_error_t	tcp_server_init (tcp_server_t *server, const tcp_server_config_t *config)
asciichat_error_t	tcp_server_run (tcp_server_t *server)
void	tcp_server_destroy (tcp_server_t *server)

Typedef Documentation

tcp_client_entry_t

typedef struct tcp_client_entry tcp_client_entry_t

Internal TCP listener backend. Application connections belong to network_server_t.

Definition at line 13 of file include/ascii-chat/network/tcp/server.h.

tcp_server_t

typedef struct tcp_server tcp_server_t

Definition at line 14 of file include/ascii-chat/network/tcp/server.h.

Function Documentation

tcp_server_destroy()

void tcp_server_destroy

(

tcp_server_t *

server

)

Definition at line 203 of file lib/network/tcp/server.c.

                                              {
  if (!server) {
    return;
  }
 
  log_debug("Shutting down TCP server...");
 
  // Signal server to stop
  atomic_store_bool(&server->running, false);
 
  // Close listen sockets
  if (server->listen_socket != INVALID_SOCKET_VALUE) {
    log_debug("Closing IPv4 listen socket");
    socket_close(server->listen_socket);
    server->listen_socket = INVALID_SOCKET_VALUE;
  }
 
  if (server->listen_socket6 != INVALID_SOCKET_VALUE) {
    log_debug("Closing IPv6 listen socket");
    socket_close(server->listen_socket6);
    server->listen_socket6 = INVALID_SOCKET_VALUE;
  }
 
  log_debug("TCP listener shutdown complete");
  NAMED_UNREGISTER(&server->running);
  NAMED_UNREGISTER(server);
}

References tcp_server::listen_socket, tcp_server::listen_socket6, log_debug, NAMED_UNREGISTER, and tcp_server::running.

Referenced by network_server_destroy().

tcp_server_init()

asciichat_error_t tcp_server_init	(	tcp_server_t *	server,
		const tcp_server_config_t *	config )

Definition at line 108 of file lib/network/tcp/server.c.

                                                                                           {
  if (!server || !config) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "server or config is NULL");
  }
 
  // Initialize server state
  memset(server, 0, sizeof(*server));
  server->listen_socket = INVALID_SOCKET_VALUE;
  server->listen_socket6 = INVALID_SOCKET_VALUE;
  atomic_store_bool(&server->running, true);
  server->config = *config; // Copy config
 
  // Determine which IP versions to bind
  bool should_bind_ipv4 = config->bind_ipv4;
  bool should_bind_ipv6 = config->bind_ipv6;
 
  // Bind IPv4 socket if requested
  if (should_bind_ipv4) {
    const char *ipv4_addr = (config->ipv4_address && config->ipv4_address[0] != '\0') ? config->ipv4_address : NULL;
    server->listen_socket = bind_and_listen(ipv4_addr, AF_INET, config->port);
 
    if (server->listen_socket == INVALID_SOCKET_VALUE) {
      log_warn("Failed to bind IPv4 socket");
    }
  }
 
  // Bind IPv6 socket if requested
  if (should_bind_ipv6) {
    const char *ipv6_addr = (config->ipv6_address && config->ipv6_address[0] != '\0') ? config->ipv6_address : NULL;
    server->listen_socket6 = bind_and_listen(ipv6_addr, AF_INET6, config->port);
 
    if (server->listen_socket6 == INVALID_SOCKET_VALUE) {
      log_warn("Failed to bind IPv6 socket");
    }
  }
 
  // Ensure at least one socket bound successfully
  if (server->listen_socket == INVALID_SOCKET_VALUE && server->listen_socket6 == INVALID_SOCKET_VALUE) {
    NAMED_UNREGISTER(&server->running);
    return SET_ERRNO(ERROR_NETWORK_BIND, "Failed to bind any sockets (IPv4 and IPv6 both failed)");
  }
 
  /* Register server with named registry, identified by port */
  char port_name[NETWORK_TCP_SERVER_PORT_NAME_BUFFER_SIZE];
  snprintf(port_name, sizeof(port_name), "server:%d", server->config.port);
  NAMED_REGISTER(server, port_name, "tcp_server", "0x%tx", NULL);
 
  /* Register server's sync primitives with hierarchical naming */
  NAMED_REGISTER_ATOMIC(&server->running, "is_running", (uintptr_t)(const void *)(server));
 
  return ASCIICHAT_OK;
}

References ASCIICHAT_OK, tcp_server_config_t::bind_ipv4, tcp_server_config_t::bind_ipv6, tcp_server::config, ERROR_INVALID_PARAM, ERROR_NETWORK_BIND, tcp_server_config_t::ipv4_address, tcp_server_config_t::ipv6_address, tcp_server::listen_socket, tcp_server::listen_socket6, log_warn, NAMED_REGISTER, NAMED_REGISTER_ATOMIC, NAMED_UNREGISTER, NETWORK_TCP_SERVER_PORT_NAME_BUFFER_SIZE, tcp_server_config_t::port, tcp_server::running, and SET_ERRNO.

Referenced by network_server_create().

tcp_server_run()

asciichat_error_t tcp_server_run

(

tcp_server_t *

server

)

Definition at line 193 of file lib/network/tcp/server.c.

                                                       {
  if (!server) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "server is NULL");
  }
 
  if (!server->config.event_handler)
    return SET_ERRNO(ERROR_INVALID_PARAM, "TCP event handler is required");
  return tcp_server_run_events(server);
}

References tcp_server::config, ERROR_INVALID_PARAM, tcp_server_config_t::event_handler, and SET_ERRNO.

Referenced by network_server_run().