worker.c File Reference

Go to the source code of this file.

Data Structures
struct	quic_worker
	For acip quic worker, this is the live record that ties endpoint, lane, failure, context together. The owning code creates it, updates it while work is active, and releases its handles and pointed-to storage before freeing the record. More...

Functions
asciichat_error_t	quic_worker_start (quic_udp_endpoint_t *endpoint, mutex_t *lane, quic_worker_failure_fn failure, void *context, quic_worker_t **out)
asciichat_error_t	quic_worker_start_locked_failure (quic_udp_endpoint_t *endpoint, mutex_t *lane, quic_worker_failure_fn failure, void *context, quic_worker_t **out)
void	quic_worker_wake (void *arg)
asciichat_error_t	quic_worker_stop (quic_worker_t **worker)

Function Documentation

quic_worker_start()

asciichat_error_t quic_worker_start	(	quic_udp_endpoint_t *	endpoint,
		mutex_t *	lane,
		quic_worker_failure_fn	failure,
		void *	context,
		quic_worker_t **	out )

Definition at line 102 of file worker.c.

                                                                        {
  return worker_start(endpoint, lane, failure, context, false, out);
}

References out.

quic_worker_start_locked_failure()

asciichat_error_t quic_worker_start_locked_failure	(	quic_udp_endpoint_t *	endpoint,
		mutex_t *	lane,
		quic_worker_failure_fn	failure,
		void *	context,
		quic_worker_t **	out )

Definition at line 107 of file worker.c.

                                                                                                                       {
  return worker_start(endpoint, lane, failure, context, true, out);
}

References out.

Referenced by quic_endpoint_migrate(), and quic_endpoint_open().

quic_worker_stop()

asciichat_error_t quic_worker_stop

(

quic_worker_t **

worker

)

Definition at line 118 of file worker.c.

                                                           {
  if (!worker || !*worker)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid QUIC worker stop");
  atomic_store_u64(&(*worker)->stopping, 1);
  quic_worker_wake(*worker);
  if (thread_join(&(*worker)->thread, NULL) != 0)
    return SET_ERRNO(ERROR_THREAD, "Cannot join QUIC worker");
  asciichat_error_t result = (*worker)->result;
  SAFE_FREE(*worker);
  *worker = NULL;
  return result;
}

References ERROR_INVALID_PARAM, ERROR_THREAD, quic_worker_wake(), SAFE_FREE, and SET_ERRNO.

Referenced by quic_endpoint_migrate(), and quic_endpoint_stop().

quic_worker_wake()

void quic_worker_wake

(

void *

arg

)

Definition at line 112 of file worker.c.

                                 {
  quic_worker_t *worker = arg;
  if (worker && atomic_exchange_u64(&worker->wake_pending, 1) == 0 && quic_udp_wake(worker->endpoint) != ASCIICHAT_OK)
    atomic_store_u64(&worker->wake_pending, 0);
}

References ASCIICHAT_OK, and quic_udp_wake().

Referenced by quic_worker_stop().