connection.h File Reference

Go to the source code of this file.

Typedefs
typedef struct client_connection	client_connection_t

Functions
asciichat_error_t	client_connection_create (client_connection_t **out)
asciichat_error_t	client_connection_start (client_connection_t *connection, const char *address, uint16_t port, char *password, size_t password_capacity)
void	client_connection_request_stop (client_connection_t *connection)
asciichat_error_t	client_connection_stop (client_connection_t *connection)
asciichat_error_t	client_connection_destroy (client_connection_t **connection)
asciichat_error_t	client_connection_checkpoint (const char *stage)

Typedef Documentation

client_connection_t

typedef struct client_connection client_connection_t

Definition at line 8 of file src/client/connection.h.

Function Documentation

client_connection_checkpoint()

asciichat_error_t client_connection_checkpoint

(

const char *

stage

)

Definition at line 80 of file src/client/connection.c.

                                                                  {
#ifndef NDEBUG
  const char *failure = SAFE_GETENV("ASCII_CHAT_TEST_CLIENT_FAIL_STAGE");
  if (failure && strcmp(failure, stage) == 0) {
    log_debug("Injected client startup failure after %s", stage);
    return SET_ERRNO(ERROR_THREAD, "Injected client startup failure after %s", stage);
  }
#else
  (void)stage;
#endif
  return ASCIICHAT_OK;
}

References ASCIICHAT_OK, ERROR_THREAD, log_debug, SAFE_GETENV, and SET_ERRNO.

Referenced by audio_sender_init(), client_connection_create(), client_connection_start(), client_crypto_init(), and client_protocol_start().

client_connection_create()

asciichat_error_t client_connection_create

(

client_connection_t **

out

)

Definition at line 93 of file src/client/connection.c.

                                                                      {
  if (!out) {
    return SET_ERRNO(ERROR_INVALID_STATE, "Missing client connection output");
  }
  *out = SAFE_CALLOC(1, sizeof(client_connection_t), client_connection_t *);
  if (!*out)
    return SET_ERRNO(ERROR_MEMORY, "Could not allocate client connection");
  client_connection_t *connection = *out;
  client_sync_entries(connection, true);
  session_connection_init(&connection->lifecycle,
                          (session_connection_ops_t){client_interrupt, client_join, client_release}, connection);
  connection->crypto_mode = ACIP_CRYPTO_ENCRYPT;
  asciichat_error_t result = ASCIICHAT_OK;
  if (result == ASCIICHAT_OK && server_connection_init(connection) != 0)
    result = ERROR_THREAD;
  if (result == ASCIICHAT_OK)
    result = client_connection_checkpoint("send-mutex");
  if (result == ASCIICHAT_OK) {
    connection->client_worker_pool = thread_pool_create("client_connection");
    if (!connection->client_worker_pool)
      result = SET_ERRNO(ERROR_THREAD, "Could not create connection worker pool");
  }
  if (result == ASCIICHAT_OK)
    result = client_connection_checkpoint("worker-pool");
  if (result != ASCIICHAT_OK) {
    asciichat_error_t cleanup = client_connection_destroy(out);
    if (cleanup != ASCIICHAT_OK)
      return cleanup;
  }
  if (result == ASCIICHAT_OK)
    log_info("CLIENT_CONNECTION_CREATED: workers=0 frames=0");
  return result;
}

References ACIP_CRYPTO_ENCRYPT, ASCIICHAT_OK, client_connection_checkpoint(), client_connection_destroy(), client_connection::client_worker_pool, client_connection::crypto_mode, ERROR_INVALID_STATE, ERROR_MEMORY, ERROR_THREAD, client_connection::lifecycle, log_info, out, SAFE_CALLOC, server_connection_init(), session_connection_init(), SET_ERRNO, and thread_pool_create().

client_connection_destroy()

asciichat_error_t client_connection_destroy

(

client_connection_t **

connection

)

Definition at line 242 of file src/client/connection.c.

                                                                         {
  if (!owner || !*owner)
    return ASCIICHAT_OK;
  client_connection_t *connection = *owner;
  asciichat_error_t result = client_connection_stop(connection);
  if (result != ASCIICHAT_OK)
    return result;
  if (connection->client_worker_pool)
    thread_pool_destroy(connection->client_worker_pool);
  if (connection->send_mutex_initialized)
    mutex_destroy(&connection->send_mutex);
  log_info("CLIENT_CONNECTION_RELEASED");
  client_sync_entries(connection, false);
  SAFE_FREE(*owner);
  *owner = NULL;
  return ASCIICHAT_OK;
}

References ASCIICHAT_OK, client_connection_stop(), client_connection::client_worker_pool, log_info, SAFE_FREE, client_connection::send_mutex, client_connection::send_mutex_initialized, and thread_pool_destroy().

Referenced by client_connection_create().

client_connection_request_stop()

void client_connection_request_stop

(

client_connection_t *

connection

)

Definition at line 181 of file src/client/connection.c.

                                                                     {
  if (connection)
    session_connection_request_stop(&connection->lifecycle);
}

References client_connection::lifecycle, and session_connection_request_stop().

client_connection_start()

asciichat_error_t client_connection_start	(	client_connection_t *	connection,
		const char *	address,
		uint16_t	port,
		char *	password,
		size_t	password_capacity )

Reuse caller-owned session credentials across attempts; the owner wipes them at session shutdown.

Definition at line 143 of file src/client/connection.c.

                                                                                    {
  ASCII_OTEL_SCOPE(CONNECTION_ATTEMPT);
  if (!password || password_capacity < PASSWORD_BUFFER_SIZE)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Missing session password storage");
  if (!connection || atomic_load_int(&connection->lifecycle.state) != SESSION_CONNECTION_STARTING) {
    return SET_ERRNO(ERROR_INVALID_STATE, "Connection is not ready for startup");
  }
  network_connect_config_t quic_config = {.timeout_ms = 10000,
                                          .tls_ca_file = GET_OPTION(tls_ca_file)[0] ? GET_OPTION(tls_ca_file) : NULL,
                                          .quic_audio_datagrams = GET_OPTION(quic_audio_datagrams),
                                          .quic_visual_datagrams = GET_OPTION(quic_visual_datagrams)};
  const network_connect_config_t *connect_config = address && strncmp(address, "quic://", 7) == 0 ? &quic_config : NULL;
  asciichat_error_t result =
      session_connection_establish("client", address, port, connect_config, &connection->network, password,
                                   password_capacity, client_prepare, client_detach, connection);
  atomic_ptr_store(&connection->transport, network_connection_transport(connection->network));
  connection->crypto_ctx = connection->network ? network_connection_handshake(connection->network) : NULL;
  if (result != ASCIICHAT_OK)
    return result;
  if (should_exit())
    return SET_ERRNO(ERROR_NETWORK, "Connection startup interrupted");
  server_connection_set_transport(connection, atomic_ptr_load(&connection->transport));
  result = client_connection_checkpoint("transport");
  if (result != ASCIICHAT_OK)
    return result;
  result = client_protocol_start(connection);
  if (result != ASCIICHAT_OK)
    return result;
  if (atomic_load_bool(&connection->stop_requested))
    return SET_ERRNO(ERROR_NETWORK, "Connection stopped during startup");
  result = session_connection_start(&connection->lifecycle);
  if (result != ASCIICHAT_OK)
    return result;
  log_info("CLIENT_CONNECTION_RUNNING");
  return ASCIICHAT_OK;
}

References ASCII_OTEL_SCOPE, ASCIICHAT_OK, client_connection_checkpoint(), client_protocol_start(), client_connection::crypto_ctx, ERROR_INVALID_PARAM, ERROR_INVALID_STATE, ERROR_NETWORK, GET_OPTION, client_connection::lifecycle, log_info, client_connection::network, network_connection_handshake(), network_connection_transport(), PASSWORD_BUFFER_SIZE, server_connection_set_transport(), session_connection_establish(), session_connection_start(), SESSION_CONNECTION_STARTING, SET_ERRNO, should_exit(), session_connection_t::state, client_connection::stop_requested, and client_connection::transport.

client_connection_stop()

asciichat_error_t client_connection_stop

(

client_connection_t *

connection

)

Definition at line 192 of file src/client/connection.c.

                                                                          {
  return connection ? session_connection_stop(&connection->lifecycle) : ASCIICHAT_OK;
}

References ASCIICHAT_OK, client_connection::lifecycle, and session_connection_stop().

Referenced by client_connection_destroy().