aboutsummaryrefslogtreecommitdiffstats
path: root/src/lua/lua_logger.c
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@rspamd.com>2023-07-26 10:49:23 +0100
committerVsevolod Stakhov <vsevolod@rspamd.com>2023-07-26 10:49:23 +0100
commit537a7180a0d5132c11636c4fd8b1450cd99d352c (patch)
treefb9f8c84955a411bdffbd6371ea32f2716fb3687 /src/lua/lua_logger.c
parent5fd7a90fdaa33f52c59bdb0ca84451e5c1e22365 (diff)
downloadrspamd-537a7180a0d5132c11636c4fd8b1450cd99d352c.tar.gz
rspamd-537a7180a0d5132c11636c4fd8b1450cd99d352c.zip
[Rework] Use clang-format to unify formatting in all sources
No meaningful changes.
Diffstat (limited to 'src/lua/lua_logger.c')
-rw-r--r--src/lua/lua_logger.c618
1 files changed, 309 insertions, 309 deletions
diff --git a/src/lua/lua_logger.c b/src/lua/lua_logger.c
index 0f015f70a..aceb26a22 100644
--- a/src/lua/lua_logger.c
+++ b/src/lua/lua_logger.c
@@ -61,66 +61,66 @@ print(str)
* Log message as an error
* @param {string} msg string to be logged
*/
-LUA_FUNCTION_DEF (logger, err);
+LUA_FUNCTION_DEF(logger, err);
/***
* @function logger.warn(msg)
* Log message as a warning
* @param {string} msg string to be logged
*/
-LUA_FUNCTION_DEF (logger, warn);
+LUA_FUNCTION_DEF(logger, warn);
/***
* @function logger.info(msg)
* Log message as an informational message
* @param {string} msg string to be logged
*/
-LUA_FUNCTION_DEF (logger, info);
+LUA_FUNCTION_DEF(logger, info);
/***
* @function logger.message(msg)
* Log message as an notice message
* @param {string} msg string to be logged
*/
-LUA_FUNCTION_DEF (logger, message);
+LUA_FUNCTION_DEF(logger, message);
/***
* @function logger.debug(msg)
* Log message as a debug message
* @param {string} msg string to be logged
*/
-LUA_FUNCTION_DEF (logger, debug);
+LUA_FUNCTION_DEF(logger, debug);
/***
* @function logger.errx(fmt[, args)
* Extended interface to make an error log message
* @param {string} fmt format string, arguments are encoded as %<number>
* @param {any} args list of arguments to be replaced in %<number> positions
*/
-LUA_FUNCTION_DEF (logger, errx);
+LUA_FUNCTION_DEF(logger, errx);
/***
* @function logger.warn(fmt[, args)
* Extended interface to make a warning log message
* @param {string} fmt format string, arguments are encoded as %<number>
* @param {any} args list of arguments to be replaced in %<number> positions
*/
-LUA_FUNCTION_DEF (logger, warnx);
+LUA_FUNCTION_DEF(logger, warnx);
/***
* @function logger.infox(fmt[, args)
* Extended interface to make an informational log message
* @param {string} fmt format string, arguments are encoded as %<number>
* @param {any} args list of arguments to be replaced in %<number> positions
*/
-LUA_FUNCTION_DEF (logger, infox);
+LUA_FUNCTION_DEF(logger, infox);
/***
* @function logger.infox(fmt[, args)
* Extended interface to make an informational log message
* @param {string} fmt format string, arguments are encoded as %<number>
* @param {any} args list of arguments to be replaced in %<number> positions
*/
-LUA_FUNCTION_DEF (logger, messagex);
+LUA_FUNCTION_DEF(logger, messagex);
/***
* @function logger.debugx(fmt[, args)
* Extended interface to make a debug log message
* @param {string} fmt format string, arguments are encoded as %<number>
* @param {any} args list of arguments to be replaced in %<number> positions
*/
-LUA_FUNCTION_DEF (logger, debugx);
+LUA_FUNCTION_DEF(logger, debugx);
/***
* @function logger.debugm(module, id, fmt[, args)
@@ -130,7 +130,7 @@ LUA_FUNCTION_DEF (logger, debugx);
* @param {string} fmt format string, arguments are encoded as %<number>
* @param {any} args list of arguments to be replaced in %<number> positions
*/
-LUA_FUNCTION_DEF (logger, debugm);
+LUA_FUNCTION_DEF(logger, debugm);
/***
* @function logger.slog(fmt[, args)
* Create string replacing percent params with corresponding arguments
@@ -138,7 +138,7 @@ LUA_FUNCTION_DEF (logger, debugm);
* @param {any} args list of arguments to be replaced in %<number> positions
* @return {string} string with percent parameters substituted
*/
-LUA_FUNCTION_DEF (logger, slog);
+LUA_FUNCTION_DEF(logger, slog);
/***
* @function logger.logx(level, module, id, fmt[, args)
@@ -148,137 +148,136 @@ LUA_FUNCTION_DEF (logger, slog);
* @param {string} fmt format string, arguments are encoded as %<number>
* @param {any} args list of arguments to be replaced in %<number> positions
*/
-LUA_FUNCTION_DEF (logger, logx);
+LUA_FUNCTION_DEF(logger, logx);
/***
* @function logger.log_level()
* Returns log level for a logger
* @return {string} current log level
*/
-LUA_FUNCTION_DEF (logger, log_level);
+LUA_FUNCTION_DEF(logger, log_level);
static const struct luaL_reg loggerlib_f[] = {
- LUA_INTERFACE_DEF (logger, err),
- LUA_INTERFACE_DEF (logger, warn),
- LUA_INTERFACE_DEF (logger, message),
- {"msg", lua_logger_message},
- LUA_INTERFACE_DEF (logger, info),
- LUA_INTERFACE_DEF (logger, debug),
- LUA_INTERFACE_DEF (logger, errx),
- LUA_INTERFACE_DEF (logger, warnx),
- LUA_INTERFACE_DEF (logger, infox),
- LUA_INTERFACE_DEF (logger, messagex),
- {"msgx", lua_logger_messagex},
- LUA_INTERFACE_DEF (logger, debugx),
- LUA_INTERFACE_DEF (logger, debugm),
- LUA_INTERFACE_DEF (logger, slog),
- LUA_INTERFACE_DEF (logger, logx),
- LUA_INTERFACE_DEF (logger, log_level),
- {"__tostring", rspamd_lua_class_tostring},
- {NULL, NULL}
-};
+ LUA_INTERFACE_DEF(logger, err),
+ LUA_INTERFACE_DEF(logger, warn),
+ LUA_INTERFACE_DEF(logger, message),
+ {"msg", lua_logger_message},
+ LUA_INTERFACE_DEF(logger, info),
+ LUA_INTERFACE_DEF(logger, debug),
+ LUA_INTERFACE_DEF(logger, errx),
+ LUA_INTERFACE_DEF(logger, warnx),
+ LUA_INTERFACE_DEF(logger, infox),
+ LUA_INTERFACE_DEF(logger, messagex),
+ {"msgx", lua_logger_messagex},
+ LUA_INTERFACE_DEF(logger, debugx),
+ LUA_INTERFACE_DEF(logger, debugm),
+ LUA_INTERFACE_DEF(logger, slog),
+ LUA_INTERFACE_DEF(logger, logx),
+ LUA_INTERFACE_DEF(logger, log_level),
+ {"__tostring", rspamd_lua_class_tostring},
+ {NULL, NULL}};
static void
-lua_common_log_line (GLogLevelFlags level,
- lua_State *L,
- const gchar *msg,
- const gchar *uid,
- const gchar *module,
- gint stack_level)
+lua_common_log_line(GLogLevelFlags level,
+ lua_State *L,
+ const gchar *msg,
+ const gchar *uid,
+ const gchar *module,
+ gint stack_level)
{
lua_Debug d;
gchar func_buf[128], *p;
- if (lua_getstack (L, stack_level, &d) == 1) {
- (void) lua_getinfo (L, "Sl", &d);
- if ((p = strrchr (d.short_src, '/')) == NULL) {
+ if (lua_getstack(L, stack_level, &d) == 1) {
+ (void) lua_getinfo(L, "Sl", &d);
+ if ((p = strrchr(d.short_src, '/')) == NULL) {
p = d.short_src;
}
else {
p++;
}
- if (strlen (p) > 30) {
- rspamd_snprintf (func_buf, sizeof (func_buf), "%27s...:%d", p,
- d.currentline);
+ if (strlen(p) > 30) {
+ rspamd_snprintf(func_buf, sizeof(func_buf), "%27s...:%d", p,
+ d.currentline);
}
else {
- rspamd_snprintf (func_buf, sizeof (func_buf), "%s:%d", p,
- d.currentline);
+ rspamd_snprintf(func_buf, sizeof(func_buf), "%s:%d", p,
+ d.currentline);
}
- rspamd_common_log_function (NULL,
- level,
- module,
- uid,
- func_buf,
- "%s",
- msg);
+ rspamd_common_log_function(NULL,
+ level,
+ module,
+ uid,
+ func_buf,
+ "%s",
+ msg);
}
else {
- rspamd_common_log_function (NULL,
- level,
- module,
- uid,
- G_STRFUNC,
- "%s",
- msg);
+ rspamd_common_log_function(NULL,
+ level,
+ module,
+ uid,
+ G_STRFUNC,
+ "%s",
+ msg);
}
}
/*** Logger interface ***/
static gint
-lua_logger_err (lua_State *L)
+lua_logger_err(lua_State *L)
{
LUA_TRACE_POINT;
const gchar *msg;
- msg = luaL_checkstring (L, 1);
- lua_common_log_line (G_LOG_LEVEL_CRITICAL, L, msg, NULL, NULL, 1);
+ msg = luaL_checkstring(L, 1);
+ lua_common_log_line(G_LOG_LEVEL_CRITICAL, L, msg, NULL, NULL, 1);
return 0;
}
static gint
-lua_logger_warn (lua_State *L)
+lua_logger_warn(lua_State *L)
{
LUA_TRACE_POINT;
const gchar *msg;
- msg = luaL_checkstring (L, 1);
- lua_common_log_line (G_LOG_LEVEL_WARNING, L, msg, NULL, NULL, 1);
+ msg = luaL_checkstring(L, 1);
+ lua_common_log_line(G_LOG_LEVEL_WARNING, L, msg, NULL, NULL, 1);
return 0;
}
static gint
-lua_logger_info (lua_State *L)
+lua_logger_info(lua_State *L)
{
LUA_TRACE_POINT;
const gchar *msg;
- msg = luaL_checkstring (L, 1);
- lua_common_log_line (G_LOG_LEVEL_INFO, L, msg, NULL, NULL, 1);
+ msg = luaL_checkstring(L, 1);
+ lua_common_log_line(G_LOG_LEVEL_INFO, L, msg, NULL, NULL, 1);
return 0;
}
static gint
-lua_logger_message (lua_State *L)
+lua_logger_message(lua_State *L)
{
LUA_TRACE_POINT;
const gchar *msg;
- msg = luaL_checkstring (L, 1);
- lua_common_log_line (G_LOG_LEVEL_MESSAGE, L, msg, NULL, NULL, 1);
+ msg = luaL_checkstring(L, 1);
+ lua_common_log_line(G_LOG_LEVEL_MESSAGE, L, msg, NULL, NULL, 1);
return 0;
}
static gint
-lua_logger_debug (lua_State *L)
+lua_logger_debug(lua_State *L)
{
LUA_TRACE_POINT;
const gchar *msg;
- msg = luaL_checkstring (L, 1);
- lua_common_log_line (G_LOG_LEVEL_DEBUG, L, msg, NULL, NULL, 1);
+ msg = luaL_checkstring(L, 1);
+ lua_common_log_line(G_LOG_LEVEL_DEBUG, L, msg, NULL, NULL, 1);
return 0;
}
static inline bool
-lua_logger_char_safe (int t, unsigned int esc_type)
+lua_logger_char_safe(int t, unsigned int esc_type)
{
if (t & 0x80) {
if (esc_type & LUA_ESCAPE_8BIT) {
@@ -289,7 +288,7 @@ lua_logger_char_safe (int t, unsigned int esc_type)
}
if (esc_type & LUA_ESCAPE_UNPRINTABLE) {
- if (!g_ascii_isprint (t) && !g_ascii_isspace (t)) {
+ if (!g_ascii_isprint(t) && !g_ascii_isspace(t)) {
return false;
}
}
@@ -304,29 +303,29 @@ lua_logger_char_safe (int t, unsigned int esc_type)
}
static gsize
-lua_logger_out_str (lua_State *L, gint pos,
- gchar *outbuf, gsize len,
- struct lua_logger_trace *trace,
- enum lua_logger_escape_type esc_type)
+lua_logger_out_str(lua_State *L, gint pos,
+ gchar *outbuf, gsize len,
+ struct lua_logger_trace *trace,
+ enum lua_logger_escape_type esc_type)
{
gsize slen, flen;
- const gchar *str = lua_tolstring (L, pos, &slen);
+ const gchar *str = lua_tolstring(L, pos, &slen);
static const gchar hexdigests[16] = "0123456789abcdef";
gsize r = 0, s;
if (str) {
gboolean normal = TRUE;
- flen = MIN (slen, len - 1);
+ flen = MIN(slen, len - 1);
- for (r = 0; r < flen; r ++) {
- if (!lua_logger_char_safe (str[r], esc_type)) {
+ for (r = 0; r < flen; r++) {
+ if (!lua_logger_char_safe(str[r], esc_type)) {
normal = FALSE;
break;
}
}
if (normal) {
- r = rspamd_strlcpy (outbuf, str, flen + 1);
+ r = rspamd_strlcpy(outbuf, str, flen + 1);
}
else {
/* Need to escape non printed characters */
@@ -334,7 +333,7 @@ lua_logger_out_str (lua_State *L, gint pos,
s = 0;
while (slen > 0 && len > 1) {
- if (!lua_logger_char_safe (str[s], esc_type)) {
+ if (!lua_logger_char_safe(str[s], esc_type)) {
if (len >= 3) {
outbuf[r++] = '\\';
outbuf[r++] = hexdigests[((str[s] >> 4) & 0xF)];
@@ -351,8 +350,8 @@ lua_logger_out_str (lua_State *L, gint pos,
}
s++;
- slen --;
- len --;
+ slen--;
+ len--;
}
outbuf[r] = '\0';
@@ -363,135 +362,139 @@ lua_logger_out_str (lua_State *L, gint pos,
}
static gsize
-lua_logger_out_num (lua_State *L, gint pos, gchar *outbuf, gsize len,
- struct lua_logger_trace *trace)
+lua_logger_out_num(lua_State *L, gint pos, gchar *outbuf, gsize len,
+ struct lua_logger_trace *trace)
{
- gdouble num = lua_tonumber (L, pos);
+ gdouble num = lua_tonumber(L, pos);
glong inum;
gsize r = 0;
if ((gdouble) (glong) num == num) {
inum = num;
- r = rspamd_snprintf (outbuf, len + 1, "%l", inum);
+ r = rspamd_snprintf(outbuf, len + 1, "%l", inum);
}
else {
- r = rspamd_snprintf (outbuf, len + 1, "%f", num);
+ r = rspamd_snprintf(outbuf, len + 1, "%f", num);
}
return r;
}
static gsize
-lua_logger_out_boolean (lua_State *L, gint pos, gchar *outbuf, gsize len,
- struct lua_logger_trace *trace)
+lua_logger_out_boolean(lua_State *L, gint pos, gchar *outbuf, gsize len,
+ struct lua_logger_trace *trace)
{
- gboolean val = lua_toboolean (L, pos);
+ gboolean val = lua_toboolean(L, pos);
gsize r = 0;
- r = rspamd_strlcpy (outbuf, val ? "true" : "false", len + 1);
+ r = rspamd_strlcpy(outbuf, val ? "true" : "false", len + 1);
return r;
}
static gsize
-lua_logger_out_userdata (lua_State *L, gint pos, gchar *outbuf, gsize len,
- struct lua_logger_trace *trace)
+lua_logger_out_userdata(lua_State *L, gint pos, gchar *outbuf, gsize len,
+ struct lua_logger_trace *trace)
{
gint r = 0, top;
const gchar *str = NULL;
gboolean converted_to_str = FALSE;
- top = lua_gettop (L);
+ top = lua_gettop(L);
- if (!lua_getmetatable (L, pos)) {
+ if (!lua_getmetatable(L, pos)) {
return 0;
}
- lua_pushstring (L, "__index");
- lua_gettable (L, -2);
+ lua_pushstring(L, "__index");
+ lua_gettable(L, -2);
- if (!lua_istable (L, -1)) {
+ if (!lua_istable(L, -1)) {
- if (lua_isfunction (L, -1)) {
+ if (lua_isfunction(L, -1)) {
/* Functional metatable, try to get __tostring directly */
- lua_pushstring (L, "__tostring");
- lua_gettable (L, -3);
+ lua_pushstring(L, "__tostring");
+ lua_gettable(L, -3);
- if (lua_isfunction (L, -1)) {
- lua_pushvalue (L, pos);
+ if (lua_isfunction(L, -1)) {
+ lua_pushvalue(L, pos);
- if (lua_pcall (L, 1, 1, 0) != 0) {
- lua_settop (L, top);
+ if (lua_pcall(L, 1, 1, 0) != 0) {
+ lua_settop(L, top);
return 0;
}
- str = lua_tostring (L, -1);
+ str = lua_tostring(L, -1);
if (str) {
- r = rspamd_snprintf (outbuf, len, "%s", str);
+ r = rspamd_snprintf(outbuf, len, "%s", str);
}
- lua_settop (L, top);
+ lua_settop(L, top);
return r;
}
}
- lua_settop (L, top);
+ lua_settop(L, top);
return 0;
}
- lua_pushstring (L, "__tostring");
- lua_gettable (L, -2);
+ lua_pushstring(L, "__tostring");
+ lua_gettable(L, -2);
- if (lua_isfunction (L, -1)) {
- lua_pushvalue (L, pos);
+ if (lua_isfunction(L, -1)) {
+ lua_pushvalue(L, pos);
- if (lua_pcall (L, 1, 1, 0) != 0) {
- lua_settop (L, top);
+ if (lua_pcall(L, 1, 1, 0) != 0) {
+ lua_settop(L, top);
return 0;
}
- str = lua_tostring (L, -1);
+ str = lua_tostring(L, -1);
if (str) {
converted_to_str = TRUE;
}
}
else {
- lua_pop (L, 1);
- lua_pushstring (L, "class");
- lua_gettable (L, -2);
+ lua_pop(L, 1);
+ lua_pushstring(L, "class");
+ lua_gettable(L, -2);
- if (lua_isstring (L, -1)) {
- str = lua_tostring (L, -1);
+ if (lua_isstring(L, -1)) {
+ str = lua_tostring(L, -1);
converted_to_str = TRUE;
}
}
if (converted_to_str) {
- r = rspamd_snprintf (outbuf, len, "%s", str);
+ r = rspamd_snprintf(outbuf, len, "%s", str);
}
else {
/* Print raw pointer */
- r = rspamd_snprintf (outbuf, len, "%s(%p)", str, lua_touserdata (L, pos));
+ r = rspamd_snprintf(outbuf, len, "%s(%p)", str, lua_touserdata(L, pos));
}
- lua_settop (L, top);
+ lua_settop(L, top);
return r;
}
-#define MOVE_BUF(d, remain, r) \
- (d) += (r); (remain) -= (r); \
- if ((remain) == 0) { lua_pop (L, 1); break; }
+#define MOVE_BUF(d, remain, r) \
+ (d) += (r); \
+ (remain) -= (r); \
+ if ((remain) == 0) { \
+ lua_pop(L, 1); \
+ break; \
+ }
static gsize
-lua_logger_out_table (lua_State *L, gint pos, gchar *outbuf, gsize len,
- struct lua_logger_trace *trace,
- enum lua_logger_escape_type esc_type)
+lua_logger_out_table(lua_State *L, gint pos, gchar *outbuf, gsize len,
+ struct lua_logger_trace *trace,
+ enum lua_logger_escape_type esc_type)
{
gchar *d = outbuf;
gsize remain = len, r;
@@ -499,16 +502,16 @@ lua_logger_out_table (lua_State *L, gint pos, gchar *outbuf, gsize len,
gconstpointer self = NULL;
gint i, tpos, last_seq = -1;
- if (!lua_istable (L, pos) || remain == 0) {
+ if (!lua_istable(L, pos) || remain == 0) {
return 0;
}
- self = lua_topointer (L, pos);
+ self = lua_topointer(L, pos);
/* Check if we have seen this pointer */
- for (i = 0; i < TRACE_POINTS; i ++) {
+ for (i = 0; i < TRACE_POINTS; i++) {
if (trace->traces[i] == self) {
- r = rspamd_snprintf (d, remain + 1, "ref(%p)", self);
+ r = rspamd_snprintf(d, remain + 1, "ref(%p)", self);
d += r;
@@ -518,88 +521,88 @@ lua_logger_out_table (lua_State *L, gint pos, gchar *outbuf, gsize len,
trace->traces[trace->cur_level % TRACE_POINTS] = self;
- lua_pushvalue (L, pos);
- r = rspamd_snprintf (d, remain + 1, "{");
+ lua_pushvalue(L, pos);
+ r = rspamd_snprintf(d, remain + 1, "{");
remain -= r;
d += r;
/* Get numeric keys (ipairs) */
- for (i = 1; ; i++) {
- lua_rawgeti (L, -1, i);
+ for (i = 1;; i++) {
+ lua_rawgeti(L, -1, i);
- if (lua_isnil (L, -1)) {
- lua_pop (L, 1);
+ if (lua_isnil(L, -1)) {
+ lua_pop(L, 1);
break;
}
last_seq = i;
if (!first) {
- r = rspamd_snprintf (d, remain + 1, ", ");
+ r = rspamd_snprintf(d, remain + 1, ", ");
MOVE_BUF(d, remain, r);
}
- r = rspamd_snprintf (d, remain + 1, "[%d] = ", i);
+ r = rspamd_snprintf(d, remain + 1, "[%d] = ", i);
MOVE_BUF(d, remain, r);
- tpos = lua_gettop (L);
+ tpos = lua_gettop(L);
- if (lua_topointer (L, tpos) == self) {
- r = rspamd_snprintf (d, remain + 1, "__self");
+ if (lua_topointer(L, tpos) == self) {
+ r = rspamd_snprintf(d, remain + 1, "__self");
}
else {
- r = lua_logger_out_type (L, tpos, d, remain, trace, esc_type);
+ r = lua_logger_out_type(L, tpos, d, remain, trace, esc_type);
}
MOVE_BUF(d, remain, r);
first = FALSE;
- lua_pop (L, 1);
+ lua_pop(L, 1);
}
/* Get string keys (pairs) */
- for (lua_pushnil (L); lua_next (L, -2); lua_pop (L, 1)) {
+ for (lua_pushnil(L); lua_next(L, -2); lua_pop(L, 1)) {
/* 'key' is at index -2 and 'value' is at index -1 */
- if (lua_type (L, -2) == LUA_TNUMBER) {
+ if (lua_type(L, -2) == LUA_TNUMBER) {
if (last_seq > 0) {
- lua_pushvalue (L, -2);
+ lua_pushvalue(L, -2);
- if (lua_tonumber (L, -1) <= last_seq + 1) {
- lua_pop (L, 1);
+ if (lua_tonumber(L, -1) <= last_seq + 1) {
+ lua_pop(L, 1);
/* Already seen */
continue;
}
- lua_pop (L, 1);
+ lua_pop(L, 1);
}
}
if (!first) {
- r = rspamd_snprintf (d, remain + 1, ", ");
+ r = rspamd_snprintf(d, remain + 1, ", ");
MOVE_BUF(d, remain, r);
}
/* Preserve key */
- lua_pushvalue (L, -2);
- r = rspamd_snprintf (d, remain + 1, "[%s] = ",
- lua_tostring (L, -1));
- lua_pop (L, 1); /* Remove key */
+ lua_pushvalue(L, -2);
+ r = rspamd_snprintf(d, remain + 1, "[%s] = ",
+ lua_tostring(L, -1));
+ lua_pop(L, 1); /* Remove key */
MOVE_BUF(d, remain, r);
- tpos = lua_gettop (L);
+ tpos = lua_gettop(L);
- if (lua_topointer (L, tpos) == self) {
- r = rspamd_snprintf (d, remain + 1, "__self");
+ if (lua_topointer(L, tpos) == self) {
+ r = rspamd_snprintf(d, remain + 1, "__self");
}
else {
- r = lua_logger_out_type (L, tpos, d, remain, trace, esc_type);
+ r = lua_logger_out_type(L, tpos, d, remain, trace, esc_type);
}
MOVE_BUF(d, remain, r);
first = FALSE;
}
- lua_pop (L, 1);
+ lua_pop(L, 1);
- r = rspamd_snprintf (d, remain + 1, "}");
+ r = rspamd_snprintf(d, remain + 1, "}");
d += r;
return (d - outbuf);
@@ -607,11 +610,10 @@ lua_logger_out_table (lua_State *L, gint pos, gchar *outbuf, gsize len,
#undef MOVE_BUF
-gsize
-lua_logger_out_type (lua_State *L, gint pos,
- gchar *outbuf, gsize len,
- struct lua_logger_trace *trace,
- enum lua_logger_escape_type esc_type)
+gsize lua_logger_out_type(lua_State *L, gint pos,
+ gchar *outbuf, gsize len,
+ struct lua_logger_trace *trace,
+ enum lua_logger_escape_type esc_type)
{
gint type;
gsize r = 0;
@@ -620,88 +622,88 @@ lua_logger_out_type (lua_State *L, gint pos,
return 0;
}
- type = lua_type (L, pos);
- trace->cur_level ++;
+ type = lua_type(L, pos);
+ trace->cur_level++;
switch (type) {
case LUA_TNUMBER:
- r = lua_logger_out_num (L, pos, outbuf, len, trace);
+ r = lua_logger_out_num(L, pos, outbuf, len, trace);
break;
case LUA_TBOOLEAN:
- r = lua_logger_out_boolean (L, pos, outbuf, len, trace);
+ r = lua_logger_out_boolean(L, pos, outbuf, len, trace);
break;
case LUA_TTABLE:
- r = lua_logger_out_table (L, pos, outbuf, len, trace, esc_type);
+ r = lua_logger_out_table(L, pos, outbuf, len, trace, esc_type);
break;
case LUA_TUSERDATA:
- r = lua_logger_out_userdata (L, pos, outbuf, len, trace);
+ r = lua_logger_out_userdata(L, pos, outbuf, len, trace);
break;
case LUA_TFUNCTION:
- r = rspamd_snprintf (outbuf, len + 1, "function");
+ r = rspamd_snprintf(outbuf, len + 1, "function");
break;
case LUA_TLIGHTUSERDATA:
- r = rspamd_snprintf (outbuf, len + 1, "0x%p", lua_topointer (L, pos));
+ r = rspamd_snprintf(outbuf, len + 1, "0x%p", lua_topointer(L, pos));
break;
case LUA_TNIL:
- r = rspamd_snprintf (outbuf, len + 1, "nil");
+ r = rspamd_snprintf(outbuf, len + 1, "nil");
break;
case LUA_TNONE:
- r = rspamd_snprintf (outbuf, len + 1, "no value");
+ r = rspamd_snprintf(outbuf, len + 1, "no value");
break;
default:
/* Try to push everything as string using tostring magic */
- r = lua_logger_out_str (L, pos, outbuf, len, trace, esc_type);
+ r = lua_logger_out_str(L, pos, outbuf, len, trace, esc_type);
break;
}
- trace->cur_level --;
+ trace->cur_level--;
return r;
}
static const gchar *
-lua_logger_get_id (lua_State *L, gint pos, GError **err)
+lua_logger_get_id(lua_State *L, gint pos, GError **err)
{
const gchar *uid = NULL, *clsname;
- if (lua_getmetatable (L, pos) != 0) {
+ if (lua_getmetatable(L, pos) != 0) {
uid = "";
- lua_pushstring (L, "__index");
- lua_gettable (L, -2);
+ lua_pushstring(L, "__index");
+ lua_gettable(L, -2);
- lua_pushstring (L, "class");
- lua_gettable (L, -2);
+ lua_pushstring(L, "class");
+ lua_gettable(L, -2);
- clsname = lua_tostring (L, -1);
+ clsname = lua_tostring(L, -1);
- if (strcmp (clsname, "rspamd{task}") == 0) {
- struct rspamd_task *task = lua_check_task (L, pos);
+ if (strcmp(clsname, "rspamd{task}") == 0) {
+ struct rspamd_task *task = lua_check_task(L, pos);
if (task) {
uid = task->task_pool->tag.uid;
}
else {
- g_set_error (err, g_quark_from_static_string ("lua_logger"),
- EINVAL, "invalid rspamd{task}");
+ g_set_error(err, g_quark_from_static_string("lua_logger"),
+ EINVAL, "invalid rspamd{task}");
}
}
- else if (strcmp (clsname, "rspamd{mempool}") == 0) {
- rspamd_mempool_t *pool;
+ else if (strcmp(clsname, "rspamd{mempool}") == 0) {
+ rspamd_mempool_t *pool;
- pool = rspamd_lua_check_mempool (L, pos);
+ pool = rspamd_lua_check_mempool(L, pos);
if (pool) {
uid = pool->tag.uid;
}
else {
- g_set_error (err, g_quark_from_static_string ("lua_logger"),
- EINVAL, "invalid rspamd{mempool}");
+ g_set_error(err, g_quark_from_static_string("lua_logger"),
+ EINVAL, "invalid rspamd{mempool}");
}
}
- else if (strcmp (clsname, "rspamd{config}") == 0) {
+ else if (strcmp(clsname, "rspamd{config}") == 0) {
struct rspamd_config *cfg;
- cfg = lua_check_config (L, pos);
+ cfg = lua_check_config(L, pos);
if (cfg) {
if (cfg->checksum) {
@@ -709,14 +711,14 @@ lua_logger_get_id (lua_State *L, gint pos, GError **err)
}
}
else {
- g_set_error (err, g_quark_from_static_string ("lua_logger"),
- EINVAL, "invalid rspamd{config}");
+ g_set_error(err, g_quark_from_static_string("lua_logger"),
+ EINVAL, "invalid rspamd{config}");
}
}
- else if (strcmp (clsname, "rspamd{map}") == 0) {
+ else if (strcmp(clsname, "rspamd{map}") == 0) {
struct rspamd_lua_map *map;
- map = lua_check_map (L, pos);
+ map = lua_check_map(L, pos);
if (map) {
if (map->map) {
@@ -727,30 +729,30 @@ lua_logger_get_id (lua_State *L, gint pos, GError **err)
}
}
else {
- g_set_error (err, g_quark_from_static_string ("lua_logger"),
- EINVAL, "invalid rspamd{map}");
+ g_set_error(err, g_quark_from_static_string("lua_logger"),
+ EINVAL, "invalid rspamd{map}");
}
}
else {
- g_set_error (err, g_quark_from_static_string ("lua_logger"),
- EINVAL, "unknown class: %s", clsname);
+ g_set_error(err, g_quark_from_static_string("lua_logger"),
+ EINVAL, "unknown class: %s", clsname);
}
/* Metatable, __index, classname */
- lua_pop (L, 3);
+ lua_pop(L, 3);
}
else {
- g_set_error (err, g_quark_from_static_string ("lua_logger"),
- EINVAL, "no metatable found for userdata");
+ g_set_error(err, g_quark_from_static_string("lua_logger"),
+ EINVAL, "no metatable found for userdata");
}
return uid;
}
static gboolean
-lua_logger_log_format (lua_State *L, gint fmt_pos, gboolean is_string,
- gchar *logbuf, gsize remain)
+lua_logger_log_format(lua_State *L, gint fmt_pos, gboolean is_string,
+ gchar *logbuf, gsize remain)
{
gchar *d;
const gchar *s, *c;
@@ -765,7 +767,7 @@ lua_logger_log_format (lua_State *L, gint fmt_pos, gboolean is_string,
} state = copy_char;
d = logbuf;
- s = lua_tostring (L, fmt_pos);
+ s = lua_tostring(L, fmt_pos);
c = s;
cur_arg = fmt_pos;
@@ -780,19 +782,19 @@ lua_logger_log_format (lua_State *L, gint fmt_pos, gboolean is_string,
state = got_percent;
s++;
if (cpylen > 0) {
- memcpy (d, c, cpylen);
+ memcpy(d, c, cpylen);
d += cpylen;
}
cpylen = 0;
}
else {
s++;
- cpylen ++;
+ cpylen++;
remain--;
}
break;
case got_percent:
- if (g_ascii_isdigit (*s) || *s == 's') {
+ if (g_ascii_isdigit(*s) || *s == 's') {
state = parse_arg_num;
c = s;
}
@@ -803,33 +805,33 @@ lua_logger_log_format (lua_State *L, gint fmt_pos, gboolean is_string,
}
break;
case parse_arg_num:
- if (g_ascii_isdigit (*s)) {
+ if (g_ascii_isdigit(*s)) {
s++;
num_arg = true;
}
else {
if (num_arg) {
- arg_num = strtoul (c, NULL, 10);
+ arg_num = strtoul(c, NULL, 10);
arg_num += fmt_pos - 1;
/* Update the current argument */
cur_arg = arg_num;
}
else {
/* We have non numeric argument, e.g. %s */
- arg_num = cur_arg ++;
- s ++;
+ arg_num = cur_arg++;
+ s++;
}
- if (arg_num < 1 || arg_num > (guint) lua_gettop (L) + 1) {
- msg_err ("wrong argument number: %ud", arg_num);
+ if (arg_num < 1 || arg_num > (guint) lua_gettop(L) + 1) {
+ msg_err("wrong argument number: %ud", arg_num);
return FALSE;
}
- memset (&tr, 0, sizeof (tr));
- r = lua_logger_out_type (L, arg_num + 1, d, remain, &tr,
- is_string ? LUA_ESCAPE_UNPRINTABLE : LUA_ESCAPE_LOG);
- g_assert (r <= remain);
+ memset(&tr, 0, sizeof(tr));
+ r = lua_logger_out_type(L, arg_num + 1, d, remain, &tr,
+ is_string ? LUA_ESCAPE_UNPRINTABLE : LUA_ESCAPE_LOG);
+ g_assert(r <= remain);
remain -= r;
d += r;
state = copy_char;
@@ -841,7 +843,7 @@ lua_logger_log_format (lua_State *L, gint fmt_pos, gboolean is_string,
if (state == parse_arg_num) {
if (num_arg) {
- arg_num = strtoul (c, NULL, 10);
+ arg_num = strtoul(c, NULL, 10);
arg_num += fmt_pos - 1;
}
else {
@@ -849,22 +851,22 @@ lua_logger_log_format (lua_State *L, gint fmt_pos, gboolean is_string,
arg_num = cur_arg;
}
- if (arg_num < 1 || arg_num > (guint) lua_gettop (L) + 1) {
- msg_err ("wrong argument number: %ud", arg_num);
+ if (arg_num < 1 || arg_num > (guint) lua_gettop(L) + 1) {
+ msg_err("wrong argument number: %ud", arg_num);
return FALSE;
}
- memset (&tr, 0, sizeof (tr));
- r = lua_logger_out_type (L, arg_num + 1, d, remain, &tr,
- is_string ? LUA_ESCAPE_UNPRINTABLE : LUA_ESCAPE_LOG);
- g_assert (r <= remain);
+ memset(&tr, 0, sizeof(tr));
+ r = lua_logger_out_type(L, arg_num + 1, d, remain, &tr,
+ is_string ? LUA_ESCAPE_UNPRINTABLE : LUA_ESCAPE_LOG);
+ g_assert(r <= remain);
remain -= r;
d += r;
}
else if (state == copy_char) {
if (cpylen > 0 && remain > 0) {
- memcpy (d, c, cpylen);
+ memcpy(d, c, cpylen);
d += cpylen;
}
}
@@ -876,10 +878,10 @@ lua_logger_log_format (lua_State *L, gint fmt_pos, gboolean is_string,
}
static gint
-lua_logger_do_log (lua_State *L,
- GLogLevelFlags level,
- gboolean is_string,
- gint start_pos)
+lua_logger_do_log(lua_State *L,
+ GLogLevelFlags level,
+ gboolean is_string,
+ gint start_pos)
{
gchar logbuf[RSPAMD_LOGBUF_SIZE - 128];
const gchar *uid = NULL;
@@ -887,20 +889,20 @@ lua_logger_do_log (lua_State *L,
gint ret;
GError *err = NULL;
- if (lua_type (L, start_pos) == LUA_TSTRING) {
+ if (lua_type(L, start_pos) == LUA_TSTRING) {
fmt_pos = start_pos;
}
- else if (lua_type (L, start_pos) == LUA_TUSERDATA) {
+ else if (lua_type(L, start_pos) == LUA_TUSERDATA) {
fmt_pos = start_pos + 1;
- uid = lua_logger_get_id (L, start_pos, &err);
+ uid = lua_logger_get_id(L, start_pos, &err);
if (uid == NULL) {
- ret = luaL_error (L, "bad userdata for logging: %s",
- err ? err->message : "unknown error");
+ ret = luaL_error(L, "bad userdata for logging: %s",
+ err ? err->message : "unknown error");
if (err) {
- g_error_free (err);
+ g_error_free(err);
}
return ret;
@@ -908,25 +910,25 @@ lua_logger_do_log (lua_State *L,
}
else {
/* Bad argument type */
- return luaL_error (L, "bad format string type: %s",
- lua_typename (L, lua_type (L, start_pos)));
+ return luaL_error(L, "bad format string type: %s",
+ lua_typename(L, lua_type(L, start_pos)));
}
- ret = lua_logger_log_format (L, fmt_pos, is_string,
- logbuf, sizeof (logbuf) - 1);
+ ret = lua_logger_log_format(L, fmt_pos, is_string,
+ logbuf, sizeof(logbuf) - 1);
if (ret) {
if (is_string) {
- lua_pushstring (L, logbuf);
+ lua_pushstring(L, logbuf);
return 1;
}
else {
- lua_common_log_line (level, L, logbuf, uid, "lua", 1);
+ lua_common_log_line(level, L, logbuf, uid, "lua", 1);
}
}
else {
if (is_string) {
- lua_pushnil (L);
+ lua_pushnil(L);
return 1;
}
@@ -936,78 +938,78 @@ lua_logger_do_log (lua_State *L,
}
static gint
-lua_logger_errx (lua_State *L)
+lua_logger_errx(lua_State *L)
{
LUA_TRACE_POINT;
- return lua_logger_do_log (L, G_LOG_LEVEL_CRITICAL, FALSE, 1);
+ return lua_logger_do_log(L, G_LOG_LEVEL_CRITICAL, FALSE, 1);
}
static gint
-lua_logger_warnx (lua_State *L)
+lua_logger_warnx(lua_State *L)
{
LUA_TRACE_POINT;
- return lua_logger_do_log (L, G_LOG_LEVEL_WARNING, FALSE, 1);
+ return lua_logger_do_log(L, G_LOG_LEVEL_WARNING, FALSE, 1);
}
static gint
-lua_logger_infox (lua_State *L)
+lua_logger_infox(lua_State *L)
{
LUA_TRACE_POINT;
- return lua_logger_do_log (L, G_LOG_LEVEL_INFO, FALSE, 1);
+ return lua_logger_do_log(L, G_LOG_LEVEL_INFO, FALSE, 1);
}
static gint
-lua_logger_messagex (lua_State *L)
+lua_logger_messagex(lua_State *L)
{
LUA_TRACE_POINT;
- return lua_logger_do_log (L, G_LOG_LEVEL_MESSAGE, FALSE, 1);
+ return lua_logger_do_log(L, G_LOG_LEVEL_MESSAGE, FALSE, 1);
}
static gint
-lua_logger_debugx (lua_State *L)
+lua_logger_debugx(lua_State *L)
{
LUA_TRACE_POINT;
- return lua_logger_do_log (L, G_LOG_LEVEL_DEBUG, FALSE, 1);
+ return lua_logger_do_log(L, G_LOG_LEVEL_DEBUG, FALSE, 1);
}
static gint
-lua_logger_logx (lua_State *L)
+lua_logger_logx(lua_State *L)
{
LUA_TRACE_POINT;
- GLogLevelFlags flags = lua_tonumber (L, 1);
- const gchar *modname = lua_tostring (L, 2), *uid = NULL;
+ GLogLevelFlags flags = lua_tonumber(L, 1);
+ const gchar *modname = lua_tostring(L, 2), *uid = NULL;
gchar logbuf[RSPAMD_LOGBUF_SIZE - 128];
gboolean ret;
gint stack_pos = 1;
- if (lua_type (L, 3) == LUA_TSTRING) {
- uid = luaL_checkstring (L, 3);
+ if (lua_type(L, 3) == LUA_TSTRING) {
+ uid = luaL_checkstring(L, 3);
}
- else if (lua_type (L, 3) == LUA_TUSERDATA) {
- uid = lua_logger_get_id (L, 3, NULL);
+ else if (lua_type(L, 3) == LUA_TUSERDATA) {
+ uid = lua_logger_get_id(L, 3, NULL);
}
else {
uid = "???";
}
if (uid && modname) {
- if (lua_type (L, 4) == LUA_TSTRING) {
- ret = lua_logger_log_format (L, 4, FALSE, logbuf, sizeof (logbuf) - 1);
+ if (lua_type(L, 4) == LUA_TSTRING) {
+ ret = lua_logger_log_format(L, 4, FALSE, logbuf, sizeof(logbuf) - 1);
}
- else if (lua_type (L, 4) == LUA_TNUMBER) {
- stack_pos = lua_tonumber (L, 4);
- ret = lua_logger_log_format (L, 5, FALSE, logbuf, sizeof (logbuf) - 1);
+ else if (lua_type(L, 4) == LUA_TNUMBER) {
+ stack_pos = lua_tonumber(L, 4);
+ ret = lua_logger_log_format(L, 5, FALSE, logbuf, sizeof(logbuf) - 1);
}
else {
- return luaL_error (L, "invalid argument on pos 4");
+ return luaL_error(L, "invalid argument on pos 4");
}
if (ret) {
- lua_common_log_line (flags, L, logbuf, uid, modname, stack_pos);
+ lua_common_log_line(flags, L, logbuf, uid, modname, stack_pos);
}
}
else {
- return luaL_error (L, "invalid arguments");
+ return luaL_error(L, "invalid arguments");
}
return 0;
@@ -1015,7 +1017,7 @@ lua_logger_logx (lua_State *L)
static gint
-lua_logger_debugm (lua_State *L)
+lua_logger_debugm(lua_State *L)
{
LUA_TRACE_POINT;
gchar logbuf[RSPAMD_LOGBUF_SIZE - 128];
@@ -1023,52 +1025,51 @@ lua_logger_debugm (lua_State *L)
gint stack_pos = 1;
gboolean ret;
- module = luaL_checkstring (L, 1);
+ module = luaL_checkstring(L, 1);
- if (lua_type (L, 2) == LUA_TSTRING) {
- uid = luaL_checkstring (L, 2);
+ if (lua_type(L, 2) == LUA_TSTRING) {
+ uid = luaL_checkstring(L, 2);
}
else {
- uid = lua_logger_get_id (L, 2, NULL);
+ uid = lua_logger_get_id(L, 2, NULL);
}
if (uid && module) {
- if (lua_type (L, 3) == LUA_TSTRING) {
- ret = lua_logger_log_format (L, 3, FALSE, logbuf, sizeof (logbuf) - 1);
+ if (lua_type(L, 3) == LUA_TSTRING) {
+ ret = lua_logger_log_format(L, 3, FALSE, logbuf, sizeof(logbuf) - 1);
}
- else if (lua_type (L, 3) == LUA_TNUMBER) {
- stack_pos = lua_tonumber (L, 3);
- ret = lua_logger_log_format (L, 4, FALSE, logbuf, sizeof (logbuf) - 1);
+ else if (lua_type(L, 3) == LUA_TNUMBER) {
+ stack_pos = lua_tonumber(L, 3);
+ ret = lua_logger_log_format(L, 4, FALSE, logbuf, sizeof(logbuf) - 1);
}
else {
- return luaL_error (L, "invalid argument on pos 3");
+ return luaL_error(L, "invalid argument on pos 3");
}
if (ret) {
- lua_common_log_line (G_LOG_LEVEL_DEBUG, L, logbuf, uid, module, stack_pos);
+ lua_common_log_line(G_LOG_LEVEL_DEBUG, L, logbuf, uid, module, stack_pos);
}
}
else {
- return luaL_error (L, "invalid arguments");
+ return luaL_error(L, "invalid arguments");
}
return 0;
}
-
static gint
-lua_logger_slog (lua_State *L)
+lua_logger_slog(lua_State *L)
{
- return lua_logger_do_log (L, 0, TRUE, 1);
+ return lua_logger_do_log(L, 0, TRUE, 1);
}
static gint
-lua_logger_log_level (lua_State *L)
+lua_logger_log_level(lua_State *L)
{
- gint log_level = rspamd_log_get_log_level (NULL);
+ gint log_level = rspamd_log_get_log_level(NULL);
- lua_pushstring (L, rspamd_get_log_severity_string(log_level));
+ lua_pushstring(L, rspamd_get_log_severity_string(log_level));
return 1;
}
@@ -1076,16 +1077,15 @@ lua_logger_log_level (lua_State *L)
/*** Init functions ***/
static gint
-lua_load_logger (lua_State *L)
+lua_load_logger(lua_State *L)
{
- lua_newtable (L);
- luaL_register (L, NULL, loggerlib_f);
+ lua_newtable(L);
+ luaL_register(L, NULL, loggerlib_f);
return 1;
}
-void
-luaopen_logger (lua_State *L)
+void luaopen_logger(lua_State *L)
{
- rspamd_lua_add_preload (L, "rspamd_logger", lua_load_logger);
+ rspamd_lua_add_preload(L, "rspamd_logger", lua_load_logger);
}