transport.c File Reference

Go to the source code of this file.

Data Structures
struct	received_packet
struct	quic_transport_t

Macros
#define	QUIC_RECEIVE_BUDGET   (16U * 1024U * 1024U)

Typedefs
typedef struct received_packet	received_packet_t

Functions
asciichat_error_t	quic_transport_peer_address (acip_transport_t *transport, struct sockaddr_storage *address, socklen_t *length)
void	quic_transport_set_close_on_lane (acip_transport_t *transport, void(*close)(quic_connection_t *, void *), void *context)
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)
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_wait_security (acip_transport_t *transport, uint64_t timeout_ns)
asciichat_error_t	quic_transport_allow_media (acip_transport_t *transport)
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)

Macro Definition Documentation

QUIC_RECEIVE_BUDGET

#define QUIC_RECEIVE_BUDGET   (16U * 1024U * 1024U)

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

Typedef Documentation

received_packet_t

typedef struct received_packet received_packet_t

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;
}

References quic_transport_t::connected, quic_transport_t::connection, ERROR_INVALID_PARAM, quic_transport_t::failure, acip_transport::impl_data, acip_transport::methods, quic_connection_allow_media(), and SET_ERRNO.

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 )

Start the authenticated transition after the existing ACIP handshake. crypto is borrowed and must outlive the transport. After this call the caller must not access or rekey it until the transport has been released.

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;
}

References acip_outbound_create(), acip_security_activate(), ASCIICHAT_OK, quic_transport_t::connected, quic_transport_t::connection, acip_transport::crypto_ctx, ERROR_INVALID_PARAM, quic_transport_t::failure, acip_transport::impl_data, quic_transport_t::lane, acip_transport::methods, quic_connection_enable_security(), SET_ERRNO, quic_transport_t::wake, and quic_transport_t::wake_context.

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_peer_address()

asciichat_error_t quic_transport_peer_address	(	acip_transport_t *	transport,
		struct sockaddr_storage *	address,
		socklen_t *	length )

Copy the current peer address. It may change after a validated migration.

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

                                                                 {
  if (!transport || transport->methods != &quic_methods || !address || !length)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC peer address query");
  quic_transport_t *quic = transport->impl_data;
  if (quic->lane)
    mutex_lock(quic->lane);
  asciichat_error_t result = quic->connected ? quic_connection_peer_address(quic->connection, address, length)
                                             : SET_ERRNO(quic->failure, "QUIC transport is closed");
  if (quic->lane)
    mutex_unlock(quic->lane);
  return result;
}

References quic_transport_t::connected, quic_transport_t::connection, ERROR_INVALID_PARAM, quic_transport_t::failure, acip_transport::impl_data, quic_transport_t::lane, acip_transport::methods, quic_connection_peer_address(), and SET_ERRNO.

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;
}

References quic_transport_t::connected, quic_transport_t::connection, acip_transport::impl_data, acip_transport::methods, and quic_connection_security_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().

quic_transport_wait_security()

asciichat_error_t quic_transport_wait_security	(	acip_transport_t *	transport,
		uint64_t	timeout_ns )

Wait at most timeout_ns for the authenticated readiness exchange.

Definition at line 353 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;
  if (!quic->lane)
    return SET_ERRNO(ERROR_NOT_SUPPORTED, "QUIC security wait requires a serialized endpoint");
  uint64_t start = time_get_ns();
  lane_lock(quic);
  while (quic->connected && !quic_connection_security_ready(quic->connection)) {
    uint64_t elapsed = time_get_ns() - start;
    if (elapsed >= timeout_ns) {
      lane_unlock(quic);
      return SET_ERRNO(ERROR_NETWORK_TIMEOUT, "QUIC security readiness timed out");
    }
    int rc = cond_timedwait(&quic->security_changed, quic->lane, timeout_ns - elapsed);
    if (rc != 0 && rc != ETIMEDOUT) {
      lane_unlock(quic);
      return SET_ERRNO(ERROR_THREAD, "QUIC security readiness wait failed");
    }
  }
  asciichat_error_t result = quic->connected ? ASCIICHAT_OK : SET_ERRNO(quic->failure, "QUIC transport is closed");
  lane_unlock(quic);
  return result;
}

References ASCIICHAT_OK, quic_transport_t::connected, quic_transport_t::connection, ERROR_INVALID_PARAM, ERROR_NETWORK_TIMEOUT, ERROR_NOT_SUPPORTED, ERROR_THREAD, ETIMEDOUT, quic_transport_t::failure, acip_transport::impl_data, quic_transport_t::lane, acip_transport::methods, quic_connection_security_ready(), quic_transport_t::security_changed, and SET_ERRNO.