mir/bind
2
0
Fork 0
mirror of https://gitlab.isc.org/isc-projects/bind9 synced 2025-09-01 15:05:23 +00:00
Code Issues Releases Wiki Activity

Fix small problems in the isc_ratelimiter

Browse Source
This commit is contained in:
Ondřej Surý
2022-09-29 18:06:05 +02:00
parent 1e2ededb07
commit 09b50d2237
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
lib/isc/ratelimiter.c
View File

@@ -57,10 +57,13 @@ ratelimiter_tick(void *arg);
isc_result_t isc_result_t
isc_ratelimiter_create(isc_loop_t *loop, isc_ratelimiter_t **ratelimiterp) { isc_ratelimiter_create(isc_loop_t *loop, isc_ratelimiter_t **ratelimiterp) {
isc_ratelimiter_t *rl = NULL; isc_ratelimiter_t *rl = NULL;
isc_mem_t *mctx = isc_loop_getmctx(loop); isc_mem_t *mctx;
INSIST(loop != NULL);
INSIST(ratelimiterp != NULL && *ratelimiterp == NULL); INSIST(ratelimiterp != NULL && *ratelimiterp == NULL);
mctx = isc_loop_getmctx(loop);
rl = isc_mem_get(mctx, sizeof(*rl)); rl = isc_mem_get(mctx, sizeof(*rl));
*rl = (isc_ratelimiter_t){ *rl = (isc_ratelimiter_t){
.pertic = 1, .pertic = 1,
@@ -237,6 +240,7 @@ isc_ratelimiter_shutdown(isc_ratelimiter_t *rl) {
REQUIRE(VALID_RATELIMITER(rl)); REQUIRE(VALID_RATELIMITER(rl));
LOCK(&rl->lock); LOCK(&rl->lock);
if (rl->state != isc_ratelimiter_shuttingdown) {
rl->state = isc_ratelimiter_shuttingdown; rl->state = isc_ratelimiter_shuttingdown;
while ((event = ISC_LIST_HEAD(rl->pending)) != NULL) { while ((event = ISC_LIST_HEAD(rl->pending)) != NULL) {
@@ -245,6 +249,7 @@ isc_ratelimiter_shutdown(isc_ratelimiter_t *rl) {
isc_task_send(event->ev_sender, &event); isc_task_send(event->ev_sender, &event);
} }
isc_loop_detach(&rl->loop); isc_loop_detach(&rl->loop);
}
UNLOCK(&rl->lock); UNLOCK(&rl->lock);
} }