mirror of
https://github.com/morgan9e/systemd
synced 2026-04-15 17:06:39 +09:00
40d60725ec
The ratelimit logging functions are only useful in a few scenarios so let's move them to ratelimit.h instead of keeping them in the generic log.h
83 lines
4.3 KiB
C
83 lines
4.3 KiB
C
/* SPDX-License-Identifier: LGPL-2.1-or-later */
|
|
#pragma once
|
|
|
|
#include <stdbool.h>
|
|
|
|
#include "time-util.h"
|
|
|
|
typedef struct RateLimit {
|
|
usec_t interval; /* Keep those two fields first so they can be initialized easily: */
|
|
unsigned burst; /* RateLimit rl = { INTERVAL, BURST }; */
|
|
unsigned num;
|
|
usec_t begin;
|
|
} RateLimit;
|
|
|
|
#define RATELIMIT_OFF (const RateLimit) { .interval = USEC_INFINITY, .burst = UINT_MAX }
|
|
|
|
static inline void ratelimit_reset(RateLimit *rl) {
|
|
rl->num = rl->begin = 0;
|
|
}
|
|
|
|
static inline bool ratelimit_configured(const RateLimit *rl) {
|
|
return rl->interval > 0 && rl->burst > 0;
|
|
}
|
|
|
|
bool ratelimit_below(RateLimit *rl);
|
|
|
|
unsigned ratelimit_num_dropped(const RateLimit *rl);
|
|
|
|
usec_t ratelimit_end(const RateLimit *rl);
|
|
usec_t ratelimit_left(const RateLimit *rl);
|
|
|
|
typedef struct LogRateLimit {
|
|
int error;
|
|
int level;
|
|
RateLimit ratelimit;
|
|
} LogRateLimit;
|
|
|
|
#define log_ratelimit_internal(_level, _error, _ratelimit, _file, _line, _func, _format, ...) \
|
|
({ \
|
|
int _log_ratelimit_error = (_error); \
|
|
int _log_ratelimit_level = (_level); \
|
|
static LogRateLimit _log_ratelimit = { \
|
|
.ratelimit = (_ratelimit), \
|
|
}; \
|
|
unsigned _num_dropped_errors = ratelimit_num_dropped(&_log_ratelimit.ratelimit); \
|
|
if (_log_ratelimit_error != _log_ratelimit.error || _log_ratelimit_level != _log_ratelimit.level) { \
|
|
ratelimit_reset(&_log_ratelimit.ratelimit); \
|
|
_log_ratelimit.error = _log_ratelimit_error; \
|
|
_log_ratelimit.level = _log_ratelimit_level; \
|
|
} \
|
|
if (log_get_max_level() == LOG_DEBUG || ratelimit_below(&_log_ratelimit.ratelimit)) \
|
|
_log_ratelimit_error = _num_dropped_errors > 0 \
|
|
? log_internal(_log_ratelimit_level, _log_ratelimit_error, _file, _line, _func, _format " (Dropped %u similar message(s))", ##__VA_ARGS__, _num_dropped_errors) \
|
|
: log_internal(_log_ratelimit_level, _log_ratelimit_error, _file, _line, _func, _format, ##__VA_ARGS__); \
|
|
_log_ratelimit_error; \
|
|
})
|
|
|
|
#define log_ratelimit_full_errno(level, error, _ratelimit, format, ...) \
|
|
({ \
|
|
int _level = (level), _e = (error); \
|
|
_e = (log_get_max_level() >= LOG_PRI(_level)) \
|
|
? log_ratelimit_internal(_level, _e, _ratelimit, PROJECT_FILE, __LINE__, __func__, format, ##__VA_ARGS__) \
|
|
: -ERRNO_VALUE(_e); \
|
|
_e < 0 ? _e : -ESTRPIPE; \
|
|
})
|
|
|
|
#define log_ratelimit_full(level, _ratelimit, format, ...) \
|
|
log_ratelimit_full_errno(level, 0, _ratelimit, format, ##__VA_ARGS__)
|
|
|
|
/* Normal logging */
|
|
#define log_ratelimit_info(...) log_ratelimit_full(LOG_INFO, __VA_ARGS__)
|
|
#define log_ratelimit_notice(...) log_ratelimit_full(LOG_NOTICE, __VA_ARGS__)
|
|
#define log_ratelimit_warning(...) log_ratelimit_full(LOG_WARNING, __VA_ARGS__)
|
|
#define log_ratelimit_error(...) log_ratelimit_full(LOG_ERR, __VA_ARGS__)
|
|
#define log_ratelimit_emergency(...) log_ratelimit_full(log_emergency_level(), __VA_ARGS__)
|
|
|
|
/* Logging triggered by an errno-like error */
|
|
#define log_ratelimit_info_errno(error, ...) log_ratelimit_full_errno(LOG_INFO, error, __VA_ARGS__)
|
|
#define log_ratelimit_notice_errno(error, ...) log_ratelimit_full_errno(LOG_NOTICE, error, __VA_ARGS__)
|
|
#define log_ratelimit_warning_errno(error, ...) log_ratelimit_full_errno(LOG_WARNING, error, __VA_ARGS__)
|
|
#define log_ratelimit_error_errno(error, ...) log_ratelimit_full_errno(LOG_ERR, error, __VA_ARGS__)
|
|
#define log_ratelimit_emergency_errno(error, ...) log_ratelimit_full_errno(log_emergency_level(), error, __VA_ARGS__)
|