mirror of
https://github.com/isc-projects/bind9.git
synced 2026-03-25 11:55:13 -04:00
1032681af0
Change the internal type used for isc_tid unit to isc_tid_t to hide the specific integer type being used for the 'tid'. Internally, the signed integer type is being used. This allows us to have negatively indexed arrays that works both for threads with assigned tid and the threads with unassigned tid. This should be used only in specific situations.
150 lines
2.9 KiB
C
150 lines
2.9 KiB
C
/*
|
|
* Copyright (C) Internet Systems Consortium, Inc. ("ISC")
|
|
*
|
|
* SPDX-License-Identifier: MPL-2.0
|
|
*
|
|
* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, you can obtain one at https://mozilla.org/MPL/2.0/.
|
|
*
|
|
* See the COPYRIGHT file distributed with this work for additional
|
|
* information regarding copyright ownership.
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <inttypes.h>
|
|
|
|
#include <isc/barrier.h>
|
|
#include <isc/job.h>
|
|
#include <isc/loop.h>
|
|
#include <isc/magic.h>
|
|
#include <isc/mem.h>
|
|
#include <isc/refcount.h>
|
|
#include <isc/result.h>
|
|
#include <isc/signal.h>
|
|
#include <isc/thread.h>
|
|
#include <isc/types.h>
|
|
#include <isc/urcu.h>
|
|
#include <isc/uv.h>
|
|
#include <isc/work.h>
|
|
|
|
#include "async_p.h"
|
|
#include "job_p.h"
|
|
|
|
/*
|
|
* Per-thread loop
|
|
*/
|
|
#define LOOP_MAGIC ISC_MAGIC('L', 'O', 'O', 'P')
|
|
#define VALID_LOOP(t) ISC_MAGIC_VALID(t, LOOP_MAGIC)
|
|
|
|
struct isc_loop {
|
|
int magic;
|
|
isc_refcount_t references;
|
|
isc_thread_t thread;
|
|
|
|
isc_loopmgr_t *loopmgr;
|
|
|
|
uv_loop_t loop;
|
|
isc_tid_t tid;
|
|
|
|
isc_mem_t *mctx;
|
|
|
|
/* states */
|
|
bool paused;
|
|
bool shuttingdown;
|
|
|
|
/* Async queue */
|
|
uv_async_t async_trigger;
|
|
isc_jobqueue_t async_jobs;
|
|
|
|
/* Jobs queue */
|
|
uv_idle_t run_trigger;
|
|
isc_joblist_t run_jobs;
|
|
|
|
/* Pause */
|
|
uv_async_t pause_trigger;
|
|
|
|
/* Shutdown */
|
|
uv_async_t shutdown_trigger;
|
|
isc_jobqueue_t setup_jobs;
|
|
isc_jobqueue_t teardown_jobs;
|
|
|
|
/* Destroy */
|
|
uv_async_t destroy_trigger;
|
|
|
|
/* safe memory reclamation */
|
|
uv_prepare_t quiescent;
|
|
};
|
|
|
|
/*
|
|
* Loop Manager
|
|
*/
|
|
#define LOOPMGR_MAGIC ISC_MAGIC('L', 'o', 'o', 'M')
|
|
#define VALID_LOOPMGR(t) ISC_MAGIC_VALID(t, LOOPMGR_MAGIC)
|
|
|
|
struct isc_loopmgr {
|
|
int magic;
|
|
isc_mem_t *mctx;
|
|
|
|
uint_fast32_t nloops;
|
|
|
|
atomic_bool shuttingdown;
|
|
atomic_bool running;
|
|
atomic_bool paused;
|
|
|
|
/* signal handling */
|
|
isc_signal_t *sigint;
|
|
isc_signal_t *sigterm;
|
|
|
|
/* pause/resume */
|
|
isc_barrier_t pausing;
|
|
isc_barrier_t resuming;
|
|
|
|
/* start/stop */
|
|
isc_barrier_t starting;
|
|
|
|
/* stopping */
|
|
isc_barrier_t stopping;
|
|
|
|
/* per-thread objects */
|
|
isc_loop_t *loops;
|
|
isc_loop_t *helpers;
|
|
};
|
|
|
|
/*
|
|
* Signal Handler
|
|
*/
|
|
#define SIGNAL_MAGIC ISC_MAGIC('S', 'I', 'G', ' ')
|
|
#define VALID_SIGNAL(t) ISC_MAGIC_VALID(t, SIGNAL_MAGIC)
|
|
|
|
struct isc_signal {
|
|
int magic;
|
|
uv_signal_t signal;
|
|
isc_loop_t *loop;
|
|
isc_signal_cb cb;
|
|
void *cbarg;
|
|
int signum;
|
|
};
|
|
|
|
/*
|
|
* Job to be scheduled in an event loop
|
|
*/
|
|
#define JOB_MAGIC ISC_MAGIC('J', 'O', 'B', ' ')
|
|
#define VALID_JOB(t) ISC_MAGIC_VALID(t, JOB_MAGIC)
|
|
|
|
/*
|
|
* Work to be offloaded to an external thread.
|
|
*/
|
|
struct isc_work {
|
|
uv_work_t work;
|
|
isc_loop_t *loop;
|
|
isc_work_cb work_cb;
|
|
isc_after_work_cb after_work_cb;
|
|
void *cbarg;
|
|
};
|
|
|
|
#define DEFAULT_LOOP(loopmgr) (&(loopmgr)->loops[0])
|
|
#define CURRENT_LOOP(loopmgr) (&(loopmgr)->loops[isc_tid()])
|
|
#define LOOP(loopmgr, tid) (&(loopmgr)->loops[tid])
|
|
#define ON_LOOP(loop) ((loop) == CURRENT_LOOP((loop)->loopmgr))
|