WEBDIENSTE/unbound
1
0
Fork 0
mirror of https://github.com/NLnetLabs/unbound.git synced 2026-09-13 13:27:43 +02:00
Code Issues Packages Projects Releases Wiki Activity

- auth-load-thread, use define for constant for number of records before poll.

Browse Source
This commit is contained in:
W.C.A. Wijngaards
2026-07-07 16:26:42 +02:00
parent 425b701fb9
commit b4daa2d0fa
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/authzone.c
+7 -3
View File
@@ -99,6 +99,10 @@
#define NUM_TIMEOUTS_FALLBACK_IXFR 3
/** number of IXFRs before an AXFR is performed, to consolidate RPZ memory. */
#define NUM_IXFR_BEFORE_AXFR 5
/** number of records before polling if the auth-load-thread has to quit.
* It polls on the socket, once for this number of processed records, so
* it can quit when the signal is sent over the socket. */
#define NUM_RECORDS_BEFORE_SIGNAL_CHECK 10000
/** pick up nextprobe task to start waiting to perform transfer actions */
static void xfr_set_timeout(struct auth_xfer* xfr, struct module_env* env,
@@ -5122,7 +5126,7 @@ xfr_apply_ixfr(struct auth_chunk* chunk_list, uint32_t xfr_serial,
}
rr_counter++;
if(thr && rr_counter % 10000 == 0) {
if(thr && rr_counter % NUM_RECORDS_BEFORE_SIGNAL_CHECK == 0) {
if(auth_load_thread_poll_for_quit(thr))
return 0;
}
@@ -5195,7 +5199,7 @@ xfr_apply_axfr(struct auth_chunk* chunk_list, struct auth_zone* z,
}
rr_counter++;
if(thr && rr_counter % 10000 == 0) {
if(thr && rr_counter % NUM_RECORDS_BEFORE_SIGNAL_CHECK == 0) {
if(auth_load_thread_poll_for_quit(thr))
return 0;
}
@@ -5288,7 +5292,7 @@ xfr_apply_http(uint8_t* name, size_t namelen, const char* host,
/* process this line */
pstate.lineno++;
chunkline_newline_removal(scratch_buffer);
if(thr && pstate.lineno % 10000 == 0) {
if(thr && pstate.lineno % NUM_RECORDS_BEFORE_SIGNAL_CHECK == 0) {
if(auth_load_thread_poll_for_quit(thr))
return 0;
}