connection.c File Reference

Go to the source code of this file.

Functions
void	session_connection_init (session_connection_t *connection, session_connection_ops_t ops, void *context)
asciichat_error_t	session_connection_start (session_connection_t *connection)
void	session_connection_request_stop (session_connection_t *connection)
asciichat_error_t	session_connection_stop (session_connection_t *connection)
void	session_connection_interrupt_transport (acip_transport_t *transport)

Function Documentation

session_connection_init()

void session_connection_init	(	session_connection_t *	connection,
		session_connection_ops_t	ops,
		void *	context )

Definition at line 3 of file src/common/session/connection.c.

                                                                                                            {
  connection->owner_thread = thread_self();
  connection->ops = ops;
  connection->context = context;
  atomic_store_int(&connection->state, SESSION_CONNECTION_STARTING);
}

References session_connection_t::context, session_connection_t::ops, session_connection_t::owner_thread, SESSION_CONNECTION_STARTING, and session_connection_t::state.

Referenced by client_connection_create().

session_connection_interrupt_transport()

void session_connection_interrupt_transport

(

acip_transport_t *

transport

)

Definition at line 44 of file src/common/session/connection.c.

                                                                         {
  acip_transport_interrupt(transport);
}

Referenced by server_connection_shutdown().

session_connection_request_stop()

void session_connection_request_stop

(

session_connection_t *

connection

)

Definition at line 19 of file src/common/session/connection.c.

                                                                       {
  if (!connection || atomic_load_int(&connection->state) == SESSION_CONNECTION_STOPPED)
    return;
  atomic_store_int(&connection->state, SESSION_CONNECTION_STOPPING);
  if (connection->ops.interrupt)
    connection->ops.interrupt(connection->context);
}

References session_connection_t::context, session_connection_ops_t::interrupt, session_connection_t::ops, SESSION_CONNECTION_STOPPED, SESSION_CONNECTION_STOPPING, and session_connection_t::state.

Referenced by client_connection_request_stop(), and session_connection_stop().

session_connection_start()

asciichat_error_t session_connection_start

(

session_connection_t *

connection

)

Definition at line 10 of file src/common/session/connection.c.

                                                                             {
  if (!connection || !thread_equal(connection->owner_thread, thread_self()))
    return SET_ERRNO(ERROR_INVALID_STATE, "Connection startup requires its controlling thread");
  int expected = SESSION_CONNECTION_STARTING;
  if (!atomic_cas_int(&connection->state, &expected, SESSION_CONNECTION_RUNNING))
    return SET_ERRNO(ERROR_INVALID_STATE, "Connection was stopped during startup");
  return ASCIICHAT_OK;
}

References ASCIICHAT_OK, ERROR_INVALID_STATE, session_connection_t::owner_thread, SESSION_CONNECTION_RUNNING, SESSION_CONNECTION_STARTING, SET_ERRNO, and session_connection_t::state.

Referenced by client_connection_start(), session_participant_connect(), session_participant_set_connection(), and session_participant_set_transport().

session_connection_stop()

asciichat_error_t session_connection_stop

(

session_connection_t *

connection

)

Definition at line 27 of file src/common/session/connection.c.

                                                                            {
  if (!connection || atomic_load_int(&connection->state) == SESSION_CONNECTION_STOPPED)
    return ASCIICHAT_OK;
  session_connection_request_stop(connection);
  if (!thread_equal(connection->owner_thread, thread_self()))
    return SET_ERRNO(ERROR_INVALID_STATE, "Connection cleanup requires its controlling thread");
  if (connection->ops.join) {
    asciichat_error_t result = connection->ops.join(connection->context);
    if (result != ASCIICHAT_OK)
      return result;
  }
  if (connection->ops.release)
    connection->ops.release(connection->context);
  atomic_store_int(&connection->state, SESSION_CONNECTION_STOPPED);
  return ASCIICHAT_OK;
}

References ASCIICHAT_OK, session_connection_t::context, ERROR_INVALID_STATE, session_connection_ops_t::join, session_connection_t::ops, session_connection_t::owner_thread, session_connection_ops_t::release, session_connection_request_stop(), SESSION_CONNECTION_STOPPED, SET_ERRNO, and session_connection_t::state.

Referenced by client_connection_stop(), session_participant_connect(), session_participant_disconnect(), and session_participant_set_transport().