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)
	Create TCP transport from existing socket.
void	acip_transport_destroy (acip_transport_t *transport)
	Destroy transport and free all resources.

Function Documentation

acip_tcp_transport_create()

acip_transport_t * acip_tcp_transport_create	(	socket_t	sockfd,
		crypto_context_t *	crypto_ctx
	)

Create TCP transport from existing socket.

Parameters

sockfd	Connected socket descriptor
crypto_ctx	Optional crypto context (may be NULL)

Returns

Transport instance or NULL on error

Note

Caller retains socket ownership (transport doesn't close on destroy)

Definition at line 208 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;
 
  // 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 acip_transport::crypto_ctx, ERROR_INVALID_PARAM, ERROR_MEMORY, acip_transport::impl_data, INVALID_SOCKET_VALUE, tcp_transport_data_t::is_connected, log_debug, acip_transport::methods, SAFE_FREE, SAFE_MALLOC, SET_ERRNO, and tcp_transport_data_t::sockfd.

Referenced by server_connection_establish(), and server_main().

acip_transport_destroy()

void acip_transport_destroy

(

acip_transport_t *

transport

)

Destroy transport and free all resources.

Parameters

transport

Transport to destroy (may be NULL)

Note

Calls close() first if still connected

Frees the transport structure itself

Safe to pass NULL

Definition at line 247 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");
}

References acip_transport_methods_t::close, acip_transport_methods_t::destroy_impl, acip_transport::impl_data, acip_transport_methods_t::is_connected, log_debug, acip_transport::methods, and SAFE_FREE.

Referenced by connection_context_cleanup(), server_connection_close(), server_connection_set_transport(), and server_main().