transport.h File Reference

Go to the source code of this file.

Functions
asciichat_error_t	quic_transport_attach (quic_connection_t *connection, crypto_context_t *crypto, acip_transport_t **out)
asciichat_error_t	quic_transport_attach_serialized (quic_connection_t *connection, crypto_context_t *crypto, mutex_t *lane, acip_transport_t **out)
asciichat_error_t	quic_transport_attach_on_lane (quic_connection_t *connection, crypto_context_t *crypto, mutex_t *lane, acip_transport_t **out)
asciichat_error_t	quic_transport_attach_on_lane_with_waker (quic_connection_t *connection, mutex_t *lane, void(*wake)(void *), void *context, void(*on_destroy)(acip_transport_t *, void *), void *destroy_context, acip_transport_t **out)
asciichat_error_t	quic_transport_fail (acip_transport_t *transport, asciichat_error_t reason)
asciichat_error_t	quic_transport_fail_on_lane (acip_transport_t *transport, asciichat_error_t reason)
asciichat_error_t	quic_transport_destroy_unclaimed_on_lane (acip_transport_t **transport, asciichat_error_t reason)
asciichat_error_t	quic_transport_set_waker_on_lane (acip_transport_t *transport, void(*wake)(void *), void *context)
void	quic_transport_set_close_on_lane (acip_transport_t *transport, void(*close)(quic_connection_t *, void *), void *context)
asciichat_error_t	quic_transport_set_waker (acip_transport_t *transport, void(*wake)(void *), void *context)
asciichat_error_t	quic_transport_begin_security (acip_transport_t *transport, crypto_context_t *crypto)
bool	quic_transport_security_ready (acip_transport_t *transport)
asciichat_error_t	quic_transport_allow_media (acip_transport_t *transport)

Function Documentation

quic_transport_allow_media()

asciichat_error_t quic_transport_allow_media

(

acip_transport_t *

transport

)

Definition at line 378 of file quic/transport.c.

                                                                          {
  if (!transport || transport->methods != &quic_methods)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC transport");
  quic_transport_t *quic = transport->impl_data;
  lane_lock(quic);
  asciichat_error_t result = quic->connected ? quic_connection_allow_media(quic->connection)
                                             : SET_ERRNO(quic->failure, "QUIC transport is closed");
  lane_unlock(quic);
  return result;
}

quic_transport_attach()

asciichat_error_t quic_transport_attach	(	quic_connection_t *	connection,
		crypto_context_t *	crypto,
		acip_transport_t **	out )

Definition at line 538 of file quic/transport.c.

                                                                {
  return attach_transport(connection, crypto, NULL, false, NULL, NULL, NULL, NULL, out);
}

References out.

quic_transport_attach_on_lane()

asciichat_error_t quic_transport_attach_on_lane	(	quic_connection_t *	connection,
		crypto_context_t *	crypto,
		mutex_t *	lane,
		acip_transport_t **	out )

Definition at line 553 of file quic/transport.c.

                                                                        {
  if (!lane) {
    if (out)
      *out = NULL;
    return SET_ERRNO(ERROR_INVALID_PARAM, "Missing QUIC lane mutex");
  }
  return attach_transport(connection, crypto, lane, true, NULL, NULL, NULL, NULL, out);
}

References ERROR_INVALID_PARAM, out, and SET_ERRNO.

quic_transport_attach_on_lane_with_waker()

asciichat_error_t quic_transport_attach_on_lane_with_waker	(	quic_connection_t *	connection,
		mutex_t *	lane,
		void(*	wake )(void *),
		void *	context,
		void(*	on_destroy )(acip_transport_t *, void *),
		void *	destroy_context,
		acip_transport_t **	out )

Definition at line 563 of file quic/transport.c.

                                                                                                          {
  if (!lane) {
    if (out)
      *out = NULL;
    return SET_ERRNO(ERROR_INVALID_PARAM, "Missing QUIC lane mutex");
  }
  return attach_transport(connection, NULL, lane, true, wake, context, on_destroy, destroy_context, out);
}

References ERROR_INVALID_PARAM, out, and SET_ERRNO.

quic_transport_attach_serialized()

asciichat_error_t quic_transport_attach_serialized	(	quic_connection_t *	connection,
		crypto_context_t *	crypto,
		mutex_t *	lane,
		acip_transport_t **	out )

Definition at line 543 of file quic/transport.c.

                                                                                          {
  if (!lane) {
    if (out)
      *out = NULL;
    return SET_ERRNO(ERROR_INVALID_PARAM, "Missing QUIC lane mutex");
  }
  return attach_transport(connection, crypto, lane, false, NULL, NULL, NULL, NULL, out);
}

References ERROR_INVALID_PARAM, out, and SET_ERRNO.

quic_transport_begin_security()

asciichat_error_t quic_transport_begin_security	(	acip_transport_t *	transport,
		crypto_context_t *	crypto )

Definition at line 324 of file quic/transport.c.

                                                                                                       {
  if (!transport || transport->methods != &quic_methods || !crypto)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC transport security context");
  quic_transport_t *quic = transport->impl_data;
  lane_lock(quic);
  asciichat_error_t result = quic->connected ? quic_connection_enable_security(quic->connection, crypto)
                                             : SET_ERRNO(quic->failure, "QUIC transport is closed");
  if (result == ASCIICHAT_OK) {
    transport->crypto_ctx = crypto;
    result = acip_security_activate(transport);
    if (quic->wake)
      quic->wake(quic->wake_context);
  }
  lane_unlock(quic);
  if (result == ASCIICHAT_OK && quic->lane)
    result = acip_outbound_create(transport);
  return result;
}

quic_transport_destroy_unclaimed_on_lane()

asciichat_error_t quic_transport_destroy_unclaimed_on_lane	(	acip_transport_t **	transport,
		asciichat_error_t	reason )

Definition at line 285 of file quic/transport.c.

                                                                                                                   {
  if (!transport || !*transport || (*transport)->methods != &quic_methods || (*transport)->outbound ||
      (*transport)->stats_peer || reason == ASCIICHAT_OK)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid unclaimed QUIC transport");
  quic_transport_t *quic = (*transport)->impl_data;
  asciichat_error_t result = quic_close_locked(quic, reason);
  if (result != ASCIICHAT_OK)
    return result;
  if (quic->lane)
    cond_destroy(&quic->received);
  if (quic->lane)
    cond_destroy(&quic->security_changed);
  SAFE_FREE((*transport)->impl_data);
  SAFE_FREE(*transport);
  *transport = NULL;
  return ASCIICHAT_OK;
}

References ASCIICHAT_OK, ERROR_INVALID_PARAM, quic_transport_t::lane, acip_transport::methods, quic_transport_t::received, SAFE_FREE, quic_transport_t::security_changed, and SET_ERRNO.

quic_transport_fail()

asciichat_error_t quic_transport_fail	(	acip_transport_t *	transport,
		asciichat_error_t	reason )

Definition at line 269 of file quic/transport.c.

                                                                                             {
  if (!transport || transport->methods != &quic_methods || reason == ASCIICHAT_OK)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC transport failure");
  quic_transport_t *quic = transport->impl_data;
  lane_lock(quic);
  asciichat_error_t result = quic_close_locked(quic, reason);
  lane_unlock(quic);
  return result;
}

References ASCIICHAT_OK, ERROR_INVALID_PARAM, acip_transport::impl_data, acip_transport::methods, and SET_ERRNO.

quic_transport_fail_on_lane()

asciichat_error_t quic_transport_fail_on_lane	(	acip_transport_t *	transport,
		asciichat_error_t	reason )

Definition at line 279 of file quic/transport.c.

                                                                                                     {
  if (!transport || transport->methods != &quic_methods || reason == ASCIICHAT_OK)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC transport failure");
  return quic_close_locked(transport->impl_data, reason);
}

References ASCIICHAT_OK, ERROR_INVALID_PARAM, acip_transport::impl_data, acip_transport::methods, and SET_ERRNO.

Referenced by quic_endpoint_stop(), and quic_release().

quic_transport_security_ready()

bool quic_transport_security_ready

(

acip_transport_t *

transport

)

Definition at line 343 of file quic/transport.c.

                                                                {
  if (!transport || transport->methods != &quic_methods)
    return false;
  quic_transport_t *quic = transport->impl_data;
  lane_lock(quic);
  bool ready = quic->connected && quic_connection_security_ready(quic->connection);
  lane_unlock(quic);
  return ready;
}

quic_transport_set_close_on_lane()

void quic_transport_set_close_on_lane	(	acip_transport_t *	transport,
		void(*	close )(quic_connection_t *, void *),
		void *	context )

Definition at line 262 of file quic/transport.c.

                                                     {
  quic_transport_t *quic = transport->impl_data;
  quic->on_close = close;
  quic->close_context = context;
}

References quic_transport_t::close_context, acip_transport::impl_data, and quic_transport_t::on_close.

quic_transport_set_waker()

asciichat_error_t quic_transport_set_waker	(	acip_transport_t *	transport,
		void(*	wake )(void *),
		void *	context )

Definition at line 314 of file quic/transport.c.

                                                                                                             {
  if (!transport || transport->methods != &quic_methods)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC transport waker");
  quic_transport_t *quic = transport->impl_data;
  lane_lock(quic);
  asciichat_error_t result = quic_transport_set_waker_on_lane(transport, wake, context);
  lane_unlock(quic);
  return result;
}

References ERROR_INVALID_PARAM, acip_transport::impl_data, acip_transport::methods, quic_transport_set_waker_on_lane(), and SET_ERRNO.

quic_transport_set_waker_on_lane()

asciichat_error_t quic_transport_set_waker_on_lane	(	acip_transport_t *	transport,
		void(*	wake )(void *),
		void *	context )

Definition at line 303 of file quic/transport.c.

                                                                                                                     {
  if (!transport || transport->methods != &quic_methods)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC transport waker");
  quic_transport_t *quic = transport->impl_data;
  if (!quic->connected)
    return SET_ERRNO(ERROR_INVALID_STATE, "QUIC transport is closed");
  quic->wake = wake;
  quic->wake_context = wake ? context : NULL;
  return ASCIICHAT_OK;
}

References ASCIICHAT_OK, quic_transport_t::connected, ERROR_INVALID_PARAM, ERROR_INVALID_STATE, acip_transport::impl_data, acip_transport::methods, SET_ERRNO, quic_transport_t::wake, and quic_transport_t::wake_context.

Referenced by quic_transport_set_waker().