acds_handlers.h File Reference

ACIP Discovery Server (ACDS) packet handlers. More...

Go to the source code of this file.

Data Structures
struct	acip_acds_callbacks_t
	ACDS packet handler callbacks. More...

Functions
asciichat_error_t	acip_handle_acds_packet (acip_transport_t *transport, packet_type_t type, const void *payload, size_t payload_len, const char *client_ip, const acip_acds_callbacks_t *callbacks)
	ACDS packet handler callbacks.

Detailed Description

ACIP Discovery Server (ACDS) packet handlers.

Provides O(1) array-based packet dispatching for ascii-chat Discovery Server. Handles session management, WebRTC signaling, and discovery protocol packets.

Author

Zachary Fogg me@zf.nosp@m.o.gg

Date

January 2026

Definition in file acds_handlers.h.

Function Documentation

acip_handle_acds_packet()

asciichat_error_t acip_handle_acds_packet	(	acip_transport_t *	transport,
		packet_type_t	type,
		const void *	payload,
		size_t	payload_len,
		const char *	client_ip,
		const acip_acds_callbacks_t *	callbacks )

ACDS packet handler callbacks.

Handle incoming ACDS packet with O(1) dispatch

Dispatches packet to appropriate callback based on type. Uses array-based lookup for constant-time handler selection.

Parameters

transport	Transport instance for sending responses and accessing per-client state
type	Packet type
payload	Packet payload
payload_len	Payload length
client_ip	Client IP address string
callbacks	Application callbacks

Returns

ASCIICHAT_OK on success, error code on failure

Definition at line 128 of file acds_handlers.c.

                                                                                  {
  stats_runtime_packet(transport ? transport->stats_peer : NULL, type, payload_len, false, true);
  if (!callbacks) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid callbacks");
  }
 
  if (type == PACKET_TYPE_ACIP_NETWORK_QUALITY) {
    log_debug_every(US_PER_SEC_INT,
                    "★ ACIP_HANDLE_ACDS_PACKET: Dispatching type=%u (NETWORK_QUALITY) from %s, payload_len=%zu", type,
                    client_ip, payload_len);
  }
 
  if ((unsigned)type == CONSENSUS_HANDOFF_PACKET) {
    if (!callbacks->on_handoff)
      return SET_ERRNO(ERROR_INVALID_STATE, "Handoff unsupported");
    return callbacks->on_handoff(payload, payload_len, transport, callbacks->app_ctx);
  }
 
  // O(1) dispatch via hash table lookup
  int idx = acds_handler_hash_lookup(g_acds_handler_hash, type);
  if (idx < 0) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Unhandled ACDS packet type: %d from %s", type, client_ip);
  }
 
  if (type == PACKET_TYPE_ACIP_NETWORK_QUALITY) {
    log_debug_every(US_PER_SEC_INT, "★ ACIP_HANDLE_ACDS_PACKET: Found handler at index=%d", idx);
  }
 
  uint64_t stats_start = time_get_ns();
  asciichat_error_t result = g_acds_handlers[idx](payload, payload_len, transport, client_ip, callbacks);
  stats_duration_record(stats_runtime_scope(), STATS_DURATION_REQUEST, time_get_ns() - stats_start);
  if (result != ASCIICHAT_OK)
    stats_counter_add(stats_runtime_scope(), STATS_COUNTER_REQUEST_FAILURES, 1);
  return result;
}

References acip_acds_callbacks_t::app_ctx, ASCIICHAT_OK, CONSENSUS_HANDOFF_PACKET, ERROR_INVALID_PARAM, ERROR_INVALID_STATE, log_debug_every, acip_acds_callbacks_t::on_handoff, PACKET_TYPE_ACIP_NETWORK_QUALITY, SET_ERRNO, stats_counter_add(), STATS_COUNTER_REQUEST_FAILURES, stats_duration_record(), STATS_DURATION_REQUEST, acip_transport::stats_peer, stats_runtime_packet(), stats_runtime_scope(), and US_PER_SEC_INT.