transport.c File Reference

Go to the source code of this file.

Data Structures
struct	tcp_transport_data_t
	TCP transport implementation data. More...

Functions
acip_transport_t *	acip_tcp_transport_create (socket_t sockfd, crypto_context_t *crypto_ctx)
void	acip_transport_destroy (acip_transport_t *transport)

Function Documentation

acip_tcp_transport_create()

acip_transport_t * acip_tcp_transport_create	(	socket_t	sockfd,
		crypto_context_t *	crypto_ctx
	)

Definition at line 218 of file tcp/transport.c.

                                                                                           {
  if (sockfd == INVALID_SOCKET_VALUE) {
    SET_ERRNO(ERROR_INVALID_PARAM, "Invalid socket descriptor");
    return NULL;
  }
 
  // Allocate transport structure
  acip_transport_t *transport = SAFE_MALLOC(sizeof(acip_transport_t), acip_transport_t *);
  if (!transport) {
    SET_ERRNO(ERROR_MEMORY, "Failed to allocate TCP transport");
    return NULL;
  }
 
  // Allocate TCP-specific data
  tcp_transport_data_t *tcp_data = SAFE_MALLOC(sizeof(tcp_transport_data_t), tcp_transport_data_t *);
  if (!tcp_data) {
    SAFE_FREE(transport);
    SET_ERRNO(ERROR_MEMORY, "Failed to allocate TCP transport data");
    return NULL;
  }
 
  // Initialize TCP data
  tcp_data->sockfd = sockfd;
  tcp_data->is_connected = true;
 
  // Enable TCP_NODELAY to disable Nagle's algorithm
  // This ensures small packets are sent immediately instead of being buffered
  int nodelay = 1;
  if (setsockopt(sockfd, IPPROTO_TCP, TCP_NODELAY, (const char *)&nodelay, sizeof(nodelay)) < 0) {
    log_warn("Failed to set TCP_NODELAY on socket %d: %s", sockfd, SAFE_STRERROR(errno));
    // Continue anyway - this is not fatal
  }
 
  // Initialize transport
  transport->methods = &tcp_methods;
  transport->crypto_ctx = crypto_ctx;
  transport->impl_data = tcp_data;
 
  log_debug("Created TCP transport for socket %d (crypto: %s)", sockfd, crypto_ctx ? "enabled" : "disabled");
 
  return transport;
}

References tcp_transport_data_t::is_connected, and tcp_transport_data_t::sockfd.

Referenced by acds_client_handler(), add_client(), connection_attempt_tcp(), crypto_handshake_client_auth_response_socket(), crypto_handshake_client_complete_socket(), crypto_handshake_client_key_exchange_socket(), crypto_handshake_server_auth_challenge_socket(), crypto_handshake_server_complete_socket(), crypto_handshake_server_start_socket(), server_connection_establish(), and server_main().

acip_transport_destroy()

void acip_transport_destroy

(

acip_transport_t *

transport

)

Definition at line 265 of file tcp/transport.c.

                                                         {
  if (!transport) {
    return;
  }
 
  // Close if still connected
  if (transport->methods && transport->methods->close && transport->methods->is_connected &&
      transport->methods->is_connected(transport)) {
    transport->methods->close(transport);
  }
 
  // Call custom destroy implementation if provided
  if (transport->methods && transport->methods->destroy_impl) {
    transport->methods->destroy_impl(transport);
  }
 
  // Free implementation data
  if (transport->impl_data) {
    SAFE_FREE(transport->impl_data);
  }
 
  // Free transport structure
  SAFE_FREE(transport);
 
  log_debug("Destroyed ACIP transport");
}

Referenced by connection_context_cleanup(), crypto_handshake_client_auth_response_socket(), crypto_handshake_client_complete_socket(), crypto_handshake_client_key_exchange_socket(), crypto_handshake_server_auth_challenge_socket(), crypto_handshake_server_complete_socket(), crypto_handshake_server_start_socket(), remove_client(), server_connection_close(), server_connection_establish(), server_connection_set_transport(), server_main(), and websocket_client_destroy().