1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
|
/* Copyright (C) 2022 CZ.NIC, z.s.p.o. <knot-dns@labs.nic.cz>
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
#pragma once
#include <stdatomic.h>
#include "knot/conf/conf.h"
#include "knot/catalog/catalog_update.h"
#include "knot/common/evsched.h"
#include "knot/common/fdset.h"
#include "knot/journal/knot_lmdb.h"
#include "knot/server/dthreads.h"
#include "knot/worker/pool.h"
#include "knot/zone/backup.h"
#include "knot/zone/zonedb.h"
struct server;
struct knot_xdp_socket;
struct knot_quic_creds;
/*!
* \brief I/O handler structure.
*/
typedef struct {
struct server *server; /*!< Reference to server. */
dt_unit_t *unit; /*!< Threading unit. */
unsigned *thread_state; /*!< Thread states. */
unsigned *thread_id; /*!< Thread identifiers per all handlers. */
} iohandler_t;
/*!
* \brief Server state flags.
*/
typedef enum {
ServerIdle = 0 << 0, /*!< Server is idle. */
ServerRunning = 1 << 0, /*!< Server is running. */
} server_state_t;
/*!
* \brief Server reload kinds.
*/
typedef enum {
RELOAD_NONE = 0,
RELOAD_FULL = 1 << 0, /*!< Reload the server and all zones. */
RELOAD_COMMIT = 1 << 1, /*!< Process changes from dynamic configuration. */
RELOAD_ZONES = 1 << 2, /*!< Reload all zones. */
RELOAD_CATALOG = 1 << 3, /*!< Process catalog zone changes. */
} reload_t;
/*!
* \brief Server interface structure.
*/
typedef struct {
int *fd_udp;
unsigned fd_udp_count;
int *fd_tcp;
unsigned fd_tcp_count;
int *fd_xdp;
unsigned fd_xdp_count;
unsigned xdp_first_thread_id;
struct knot_xdp_socket **xdp_sockets;
struct sockaddr_storage addr;
} iface_t;
/*!
* \brief Handler indexes.
*/
enum {
IO_UDP = 0,
IO_TCP = 1,
IO_XDP = 2,
};
/*!
* \brief Main server structure.
*
* Keeps references to all important structures needed for operation.
*/
typedef struct server {
/*! \brief Server state tracking. */
volatile unsigned state;
knot_zonedb_t *zone_db;
knot_lmdb_db_t timerdb;
knot_lmdb_db_t journaldb;
knot_lmdb_db_t kaspdb;
catalog_t catalog;
/*! \brief I/O handlers. */
struct {
unsigned size;
iohandler_t handler;
} handlers[3];
/*! \brief Background jobs. */
worker_pool_t *workers;
/*! \brief Event scheduler. */
evsched_t sched;
/*! \brief List of interfaces. */
iface_t *ifaces;
size_t n_ifaces;
/*! \brief Pending changes to catalog member zones, update indication. */
catalog_update_t catalog_upd;
atomic_bool catalog_upd_signal;
/*! \brief Context of pending zones' backup. */
zone_backup_ctxs_t backup_ctxs;
/*! \brief Crendentials context for QUIC. */
struct knot_quic_creds *quic_creds;
} server_t;
/*!
* \brief Initializes the server structure.
*
* \retval KNOT_EOK on success.
* \retval KNOT_EINVAL on invalid parameters.
*/
int server_init(server_t *server, int bg_workers);
/*!
* \brief Properly destroys the server structure.
*
* \param server Server structure to be used for operation.
*/
void server_deinit(server_t *server);
/*!
* \brief Starts the server.
*
* \param server Server structure to be used for operation.
* \param async Don't wait for zones to load if true.
*
* \retval KNOT_EOK on success.
* \retval KNOT_EINVAL on invalid parameters.
*
*/
int server_start(server_t *server, bool async);
/*!
* \brief Waits for the server to finish.
*
* \param server Server structure to be used for operation.
*
*/
void server_wait(server_t *server);
/*!
* \brief Reload server configuration.
*
* \param server Server instance.
* \param mode Reload mode.
*
* \return Error code, KNOT_EOK if success.
*/
int server_reload(server_t *server, reload_t mode);
/*!
* \brief Requests server to stop.
*
* \param server Server structure to be used for operation.
*/
void server_stop(server_t *server);
/*!
* \brief Server reconfiguration routine.
*
* Routine for dynamic server reconfiguration.
*
* \param conf Configuration.
* \param server Server instance.
*
* \return Error code, KNOT_EOK if success.
*/
int server_reconfigure(conf_t *conf, server_t *server);
/*!
* \brief Reconfigure zone database.
*
* Routine for dynamic server zones reconfiguration.
*
* \param conf Configuration.
* \param server Server instance.
* \param mode Reload mode.
*/
void server_update_zones(conf_t *conf, server_t *server, reload_t mode);
|
