worker.h File Reference

Go to the source code of this file.

Typedefs
typedef struct quic_worker	quic_worker_t
typedef bool(*	quic_worker_failure_fn) (quic_connection_t *, asciichat_error_t, void *)

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 *worker)
asciichat_error_t	quic_worker_stop (quic_worker_t **worker)

Typedef Documentation

quic_worker_failure_fn

typedef bool(* quic_worker_failure_fn) (quic_connection_t *, asciichat_error_t, void *)

Definition at line 12 of file worker.h.

quic_worker_t

typedef struct quic_worker quic_worker_t

Definition at line 11 of file worker.h.

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 *

worker

)

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