connections.c File Reference

Go to the source code of this file.

Functions
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)
asciichat_error_t	server_send_audio (client_info_t *client, const void *data, size_t length)

Variables
const network_connection_callbacks_t	server_network_callbacks

Function Documentation

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_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

Initial value:

= {server_connection_open, server_connection_packet,
                                                                 server_connection_closing, server_connection_closed}

Definition at line 110 of file connections.c.

                                                                {server_connection_open, server_connection_packet,
                                                                 server_connection_closing, server_connection_closed};

Referenced by server_main().