From 88c434f75c99ab62a8d755b3ecc07e1ac367b45b Mon Sep 17 00:00:00 2001 From: Yu Watanabe Date: Sat, 11 May 2024 20:41:07 +0900 Subject: [PATCH] journal-rate-limit: rename variables 'r' is usually used for storing return value. --- src/journal/journald-rate-limit.c | 40 ++++++++++++++++++++----------- src/journal/journald-rate-limit.h | 8 ++++++- 2 files changed, 33 insertions(+), 15 deletions(-) diff --git a/src/journal/journald-rate-limit.c b/src/journal/journald-rate-limit.c index 1ea60c22cf4..69f19bdc362 100644 --- a/src/journal/journald-rate-limit.c +++ b/src/journal/journald-rate-limit.c @@ -121,10 +121,15 @@ static void journal_ratelimit_vacuum(JournalRateLimit *r, usec_t ts) { journal_ratelimit_group_free(r->lru_tail); } -static JournalRateLimitGroup* journal_ratelimit_group_new(JournalRateLimit *r, const char *id, usec_t interval, usec_t ts) { +static JournalRateLimitGroup* journal_ratelimit_group_new( + JournalRateLimit *rl, + const char *id, + usec_t interval, + usec_t ts) { + JournalRateLimitGroup *g; - assert(r); + assert(rl); assert(id); g = new0(JournalRateLimitGroup, 1); @@ -135,19 +140,19 @@ static JournalRateLimitGroup* journal_ratelimit_group_new(JournalRateLimit *r, c if (!g->id) goto fail; - g->hash = siphash24_string(g->id, r->hash_key); + g->hash = siphash24_string(g->id, rl->hash_key); g->interval = interval; - journal_ratelimit_vacuum(r, ts); + journal_ratelimit_vacuum(rl, ts); - LIST_PREPEND(bucket, r->buckets[g->hash % BUCKETS_MAX], g); - LIST_PREPEND(lru, r->lru, g); + LIST_PREPEND(bucket, rl->buckets[g->hash % BUCKETS_MAX], g); + LIST_PREPEND(lru, rl->lru, g); if (!g->lru_next) - r->lru_tail = g; - r->n_groups++; + rl->lru_tail = g; + rl->n_groups++; - g->parent = r; + g->parent = rl; return g; fail: @@ -183,7 +188,14 @@ static unsigned burst_modulate(unsigned burst, uint64_t available) { return burst; } -int journal_ratelimit_test(JournalRateLimit *r, const char *id, usec_t rl_interval, unsigned rl_burst, int priority, uint64_t available) { +int journal_ratelimit_test( + JournalRateLimit *rl, + const char *id, + usec_t rl_interval, + unsigned rl_burst, + int priority, + uint64_t available) { + JournalRateLimitGroup *g, *found = NULL; JournalRateLimitPool *p; unsigned burst; @@ -199,13 +211,13 @@ int journal_ratelimit_test(JournalRateLimit *r, const char *id, usec_t rl_interv * < 0 → error */ - if (!r) + if (!rl) return 1; ts = now(CLOCK_MONOTONIC); - h = siphash24_string(id, r->hash_key); - g = r->buckets[h % BUCKETS_MAX]; + h = siphash24_string(id, rl->hash_key); + g = rl->buckets[h % BUCKETS_MAX]; LIST_FOREACH(bucket, i, g) if (streq(i->id, id)) { @@ -214,7 +226,7 @@ int journal_ratelimit_test(JournalRateLimit *r, const char *id, usec_t rl_interv } if (!found) { - found = journal_ratelimit_group_new(r, id, rl_interval, ts); + found = journal_ratelimit_group_new(rl, id, rl_interval, ts); if (!found) return -ENOMEM; } else diff --git a/src/journal/journald-rate-limit.h b/src/journal/journald-rate-limit.h index 8def60f052b..4539e174c3e 100644 --- a/src/journal/journald-rate-limit.h +++ b/src/journal/journald-rate-limit.h @@ -7,4 +7,10 @@ typedef struct JournalRateLimit JournalRateLimit; JournalRateLimit *journal_ratelimit_new(void); void journal_ratelimit_free(JournalRateLimit *r); -int journal_ratelimit_test(JournalRateLimit *r, const char *id, usec_t rl_interval, unsigned rl_burst, int priority, uint64_t available); +int journal_ratelimit_test( + JournalRateLimit *rl, + const char *id, + usec_t rl_interval, + unsigned rl_burst, + int priority, + uint64_t available); -- 2.47.3