Functions | Variables
daemon.c File Reference

The daemon consists of global settings and a number of workers. More...

#include "config.h"
#include <sys/time.h>
#include "daemon/daemon.h"
#include "daemon/worker.h"
#include "daemon/remote.h"
#include "daemon/acl_list.h"
#include "util/log.h"
#include "util/config_file.h"
#include "util/data/msgreply.h"
#include "util/shm_side/shm_main.h"
#include "util/storage/lookup3.h"
#include "util/storage/slabhash.h"
#include "services/listen_dnsport.h"
#include "services/cache/rrset.h"
#include "services/cache/infra.h"
#include "services/localzone.h"
#include "services/view.h"
#include "services/modstack.h"
#include "util/module.h"
#include "util/random.h"
#include "util/tube.h"
#include "util/net_help.h"
#include "sldns/keyraw.h"
#include "respip/respip.h"
#include <signal.h>

Functions

static RETSIGTYPE record_sigh (int sig)
 used when no other sighandling happens, so we don't die when multiple signals in quick succession are sent to us. More...
 
static void signal_handling_record (void)
 Signal handling during the time when netevent is disabled. More...
 
static void signal_handling_playback (struct worker *wrk)
 Replay old signals. More...
 
struct daemondaemon_init (void)
 Initialize daemon structure. More...
 
int daemon_open_shared_ports (struct daemon *daemon)
 Open shared listening ports (if needed). More...
 
static void daemon_setup_modules (struct daemon *daemon)
 Setup modules. More...
 
static int daemon_get_shufport (struct daemon *daemon, int *shufport)
 Obtain allowed port numbers, concatenate the list, and shuffle them (ready to be handed out to threads). More...
 
static void daemon_create_workers (struct daemon *daemon)
 Allocate empty worker structures. More...
 
static void * thread_start (void *arg)
 Function to start one thread. More...
 
static void daemon_start_others (struct daemon *daemon)
 Fork and init the other threads. More...
 
static void daemon_stop_others (struct daemon *daemon)
 Stop the other threads. More...
 
void daemon_fork (struct daemon *daemon)
 Fork workers and start service. More...
 
void daemon_cleanup (struct daemon *daemon)
 Close off the worker thread information. More...
 
void daemon_delete (struct daemon *daemon)
 Delete workers, close listening ports. More...
 
void daemon_apply_cfg (struct daemon *daemon, struct config_file *cfg)
 Apply config settings. More...
 

Variables

static int sig_record_quit = 0
 How many quit requests happened. More...
 
static int sig_record_reload = 0
 How many reload requests happened. More...
 

Detailed Description

The daemon consists of global settings and a number of workers.

Function Documentation

◆ record_sigh()

static RETSIGTYPE record_sigh ( int  sig)
static

used when no other sighandling happens, so we don't die when multiple signals in quick succession are sent to us.

Parameters
sigsignal number.
Returns
signal handler return type (void or int).

References sig_record_quit, and sig_record_reload.

Referenced by signal_handling_record().

◆ signal_handling_record()

static void signal_handling_record ( void  )
static

Signal handling during the time when netevent is disabled.

Stores signals to replay later.

References log_err(), and record_sigh().

Referenced by daemon_cleanup().

◆ signal_handling_playback()

static void signal_handling_playback ( struct worker wrk)
static

Replay old signals.

Parameters
wrkworker that handles signals.

References sig_record_quit, sig_record_reload, and worker_sighandler().

◆ daemon_init()

struct daemon* daemon_init ( void  )

Initialize daemon structure.

Returns
: The daemon structure, or NULL on error.

Referenced by run_daemon().

◆ daemon_open_shared_ports()

int daemon_open_shared_ports ( struct daemon daemon)

◆ daemon_setup_modules()

static void daemon_setup_modules ( struct daemon daemon)
static

◆ daemon_get_shufport()

static int daemon_get_shufport ( struct daemon daemon,
int *  shufport 
)
static

Obtain allowed port numbers, concatenate the list, and shuffle them (ready to be handed out to threads).

Parameters
daemonthe daemon. Uses rand and cfg.
shufportthe portlist output.
Returns
number of ports available.

References daemon::cfg, and config_file::outgoing_avail_ports.

◆ daemon_create_workers()

static void daemon_create_workers ( struct daemon daemon)
static

Allocate empty worker structures.

With backptr and thread-number, from 0..numthread initialised. Used as user arguments to new threads. Creates the daemon random generator if it does not exist yet. The random generator stays existing between reloads with a unique state.

Parameters
daemonthe daemon with (new) config settings.

References daemon::cfg, log_assert, daemon::rand, and ub_initstate().

◆ thread_start()

static void* thread_start ( void *  arg)
static

Function to start one thread.

Parameters
arguser argument.
Returns
: void* user return value could be used for thread_join results.

References daemon::cfg, worker::cmd, worker::daemon, log_thread_set(), daemon::num_ports, daemon::ports, config_file::so_reuseport, worker::thread_num, tube_close_write(), ub_thread_blocksigs(), and worker_init().

Referenced by daemon_start_others().

◆ daemon_start_others()

static void daemon_start_others ( struct daemon daemon)
static

Fork and init the other threads.

Main thread returns for special handling.

Parameters
daemonthe daemon with other threads to fork.

References worker::cmd, log_assert, daemon::num, worker::thr_id, thread_start(), tube_close_read(), VERB_ALGO, verbose(), and daemon::workers.

◆ daemon_stop_others()

static void daemon_stop_others ( struct daemon daemon)
static

Stop the other threads.

Parameters
daemonthe daemon with other threads.

References log_assert, daemon::num, worker::thr_id, VERB_ALGO, verbose(), worker_cmd_quit, worker_send_cmd(), and daemon::workers.

◆ daemon_fork()

void daemon_fork ( struct daemon daemon)

Fork workers and start service.

When the routine exits, it is no longer forked.

Parameters
daemonthe daemon.

References log_assert, daemon::views, and views_create().

◆ daemon_cleanup()

void daemon_cleanup ( struct daemon daemon)

◆ daemon_delete()

void daemon_delete ( struct daemon daemon)

◆ daemon_apply_cfg()

void daemon_apply_cfg ( struct daemon daemon,
struct config_file cfg 
)

Variable Documentation

◆ sig_record_quit

int sig_record_quit = 0
static

How many quit requests happened.

Referenced by record_sigh(), and signal_handling_playback().

◆ sig_record_reload

int sig_record_reload = 0
static

How many reload requests happened.

Referenced by record_sigh(), and signal_handling_playback().