connections.h File Reference

Go to the source code of this file.

Data Structures
struct	server_connection_state_t

Functions
asciichat_error_t	server_dispatch_packet (client_info_t *, packet_type_t, const void *, size_t)
asciichat_error_t	server_send_state (acip_transport_t *)
void	server_send_video (client_info_t *, acip_frame_workspace_t *, const char *, size_t, uint32_t, uint32_t, int, const acip_render_settings_t *)
asciichat_error_t	server_send_audio (client_info_t *, const void *, size_t)

Variables
const network_connection_callbacks_t	server_network_callbacks

Function Documentation

server_dispatch_packet()

asciichat_error_t server_dispatch_packet	(	client_info_t *	client,
		packet_type_t	type,
		const void *	data,
		size_t	length )

Definition at line 740 of file src/server/client.c.

                                                                                                                     {
  if (type == PACKET_TYPE_ACIP_SETTINGS_SYNC)
    return handle_runtime_settings(client, data, length);
  return acip_handle_server_packet(client->transport, type, data, length, client, &g_acip_server_callbacks);
}

References acip_handle_server_packet(), handle_runtime_settings(), PACKET_TYPE_ACIP_SETTINGS_SYNC, and client_info::transport.

server_send_audio()

asciichat_error_t server_send_audio	(	client_info_t *	client,
		const void *	data,
		size_t	length )

Definition at line 131 of file connections.c.

                                                                                            {
  mutex_lock(&client->send_mutex);
  asciichat_error_t result = ASCIICHAT_OK;
  if (client->transport && !atomic_load_bool(&client->shutting_down) && atomic_load_bool(&client->event_ready))
    result = packet_send_via_transport(client->transport, PACKET_TYPE_AUDIO_OPUS_BATCH, data, length,
                                       fnv1a_hash_string(client->client_id));
  mutex_unlock(&client->send_mutex);
  return result;
}

References ASCIICHAT_OK, client_info::client_id, client_info::event_ready, packet_send_via_transport(), PACKET_TYPE_AUDIO_OPUS_BATCH, client_info::send_mutex, client_info::shutting_down, and client_info::transport.

server_send_state()

asciichat_error_t server_send_state

(

acip_transport_t *

transport

)

Definition at line 777 of file src/server/client.c.

                                                                 {
  server_state_packet_t state = server_state_snapshot();
  return acip_send_server_state(transport, &state);
}

References acip_send_server_state().

server_send_video()

void server_send_video	(	client_info_t *	client,
		acip_frame_workspace_t *	workspace,
		const char *	data,
		size_t	length,
		uint32_t	width,
		uint32_t	height,
		int	sources,
		const acip_render_settings_t *	rendering )

Definition at line 113 of file connections.c.

                                                                                                              {
  mutex_lock(&client->send_mutex);
  acip_transport_t *transport = client->transport;
  if (transport && !atomic_load_bool(&client->shutting_down) && atomic_load_bool(&client->event_ready)) {
    if (sources > 0 && atomic_load_u64(&client->last_sent_grid_sources) != (uint64_t)sources) {
      acip_send_clear_console(transport);
      atomic_store_u64(&client->last_sent_grid_sources, (uint64_t)sources);
    }
    if (acip_send_ascii_frame_contract(
            transport, workspace, data, length, width, height, rendering,
            (rendering->caps.capabilities & TERM_CAP_MATRIX_RAIN) ? FRAME_RENDER_CONTRACT_RAIN : 0,
            client->client_id) == ASCIICHAT_OK)
      atomic_fetch_add_u64(&client->frames_sent_count, 1);
  }
  mutex_unlock(&client->send_mutex);
}

References acip_send_ascii_frame_contract(), acip_send_clear_console(), ASCIICHAT_OK, acip_render_settings_t::caps, client_info::client_id, client_info::event_ready, FRAME_RENDER_CONTRACT_RAIN, client_info::frames_sent_count, height, client_info::last_sent_grid_sources, client_info::send_mutex, client_info::shutting_down, client_info::transport, and width.

Referenced by client_video_render_thread().

Variable Documentation

server_network_callbacks

const network_connection_callbacks_t server_network_callbacks

extern

Definition at line 110 of file connections.c.

                                                                {server_connection_open, server_connection_packet,
                                                                 server_connection_closing, server_connection_closed};

Referenced by server_main().