aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--lualib/lua_redis.lua3
-rw-r--r--src/lua/lua_upstream.c111
2 files changed, 82 insertions, 32 deletions
diff --git a/lualib/lua_redis.lua b/lualib/lua_redis.lua
index 017381e02..296638078 100644
--- a/lualib/lua_redis.lua
+++ b/lualib/lua_redis.lua
@@ -64,7 +64,8 @@ local function redis_query_sentinel(ev_base, params, initialised)
end
-- Coroutines syntax
local rspamd_redis = require "rspamd_redis"
- local addr = params.sentinels:get_upstream_round_robin()
+ local sentinels = params.sentinels
+ local addr = sentinels:get_upstream_round_robin()
local host = addr:get_addr()
local masters = {}
diff --git a/src/lua/lua_upstream.c b/src/lua/lua_upstream.c
index 2f04d7059..c259c22db 100644
--- a/src/lua/lua_upstream.c
+++ b/src/lua/lua_upstream.c
@@ -78,24 +78,31 @@ static const struct luaL_reg upstream_list_f[] = {
LUA_FUNCTION_DEF (upstream, ok);
LUA_FUNCTION_DEF (upstream, fail);
LUA_FUNCTION_DEF (upstream, get_addr);
+LUA_FUNCTION_DEF (upstream, destroy);
static const struct luaL_reg upstream_m[] = {
LUA_INTERFACE_DEF (upstream, ok),
LUA_INTERFACE_DEF (upstream, fail),
LUA_INTERFACE_DEF (upstream, get_addr),
{"__tostring", rspamd_lua_class_tostring},
+ {"__gc", lua_upstream_destroy},
{NULL, NULL}
};
/* Upstream class */
-static struct upstream *
+struct rspamd_lua_upstream {
+ struct upstream *up;
+ gint upref;
+};
+
+static struct rspamd_lua_upstream *
lua_check_upstream (lua_State * L)
{
void *ud = rspamd_lua_check_udata (L, 1, "rspamd{upstream}");
luaL_argcheck (L, ud != NULL, 1, "'upstream' expected");
- return ud ? *((struct upstream **)ud) : NULL;
+ return ud ? (struct rspamd_lua_upstream *)ud : NULL;
}
/***
@@ -107,10 +114,10 @@ static gint
lua_upstream_get_addr (lua_State *L)
{
LUA_TRACE_POINT;
- struct upstream *up = lua_check_upstream (L);
+ struct rspamd_lua_upstream *up = lua_check_upstream (L);
if (up) {
- rspamd_lua_ip_push (L, rspamd_upstream_addr_next (up));
+ rspamd_lua_ip_push (L, rspamd_upstream_addr_next (up->up));
}
else {
lua_pushnil (L);
@@ -127,7 +134,7 @@ static gint
lua_upstream_fail (lua_State *L)
{
LUA_TRACE_POINT;
- struct upstream *up = lua_check_upstream (L);
+ struct rspamd_lua_upstream *up = lua_check_upstream (L);
gboolean fail_addr = FALSE;
const gchar *reason = "unknown";
@@ -144,7 +151,7 @@ lua_upstream_fail (lua_State *L)
reason = lua_tostring (L, 2);
}
- rspamd_upstream_fail (up, fail_addr, reason);
+ rspamd_upstream_fail (up->up, fail_addr, reason);
}
return 0;
@@ -158,10 +165,25 @@ static gint
lua_upstream_ok (lua_State *L)
{
LUA_TRACE_POINT;
- struct upstream *up = lua_check_upstream (L);
+ struct rspamd_lua_upstream *up = lua_check_upstream (L);
if (up) {
- rspamd_upstream_ok (up);
+ rspamd_upstream_ok (up->up);
+ }
+
+ return 0;
+}
+
+static gint
+lua_upstream_destroy (lua_State *L)
+{
+ LUA_TRACE_POINT;
+ struct rspamd_lua_upstream *up = lua_check_upstream (L);
+
+ if (up) {
+ /* Remove reference to the parent */
+ luaL_unref (L, LUA_REGISTRYINDEX, up->upref);
+ /* Upstream belongs to the upstream list, so no free here */
}
return 0;
@@ -178,6 +200,25 @@ lua_check_upstream_list (lua_State * L)
return ud ? *((struct upstream_list **)ud) : NULL;
}
+static struct rspamd_lua_upstream *
+lua_push_upstream (lua_State * L, gint up_idx, struct upstream *up)
+{
+ struct rspamd_lua_upstream *lua_ups;
+
+ if (up_idx < 0) {
+ up_idx = lua_gettop (L) + up_idx + 1;
+ }
+
+ lua_ups = lua_newuserdata (L, sizeof (*lua_ups));
+ lua_ups->up = up;
+ rspamd_lua_setclass (L, "rspamd{upstream}", -1);
+ /* Store parent in the upstream to prevent gc */
+ lua_pushvalue (L, up_idx);
+ lua_ups->upref = luaL_ref (L, LUA_REGISTRYINDEX);
+
+ return lua_ups;
+}
+
/***
* @function upstream_list.create(cfg, def, [default_port])
* Create new upstream list from its string definition in form `<upstream>,<upstream>;<upstream>`
@@ -276,7 +317,7 @@ lua_upstream_list_get_upstream_by_hash (lua_State *L)
{
LUA_TRACE_POINT;
struct upstream_list *upl;
- struct upstream *selected, **pselected;
+ struct upstream *selected;
const gchar *key;
gsize keyl;
@@ -286,10 +327,9 @@ lua_upstream_list_get_upstream_by_hash (lua_State *L)
if (key) {
selected = rspamd_upstream_get (upl, RSPAMD_UPSTREAM_HASHED, key,
(guint)keyl);
+
if (selected) {
- pselected = lua_newuserdata (L, sizeof (struct upstream *));
- rspamd_lua_setclass (L, "rspamd{upstream}", -1);
- *pselected = selected;
+ lua_push_upstream (L, 1, selected);
}
else {
lua_pushnil (L);
@@ -316,16 +356,14 @@ lua_upstream_list_get_upstream_round_robin (lua_State *L)
{
LUA_TRACE_POINT;
struct upstream_list *upl;
- struct upstream *selected, **pselected;
+ struct upstream *selected;
upl = lua_check_upstream_list (L);
if (upl) {
selected = rspamd_upstream_get (upl, RSPAMD_UPSTREAM_ROUND_ROBIN, NULL, 0);
if (selected) {
- pselected = lua_newuserdata (L, sizeof (struct upstream *));
- rspamd_lua_setclass (L, "rspamd{upstream}", -1);
- *pselected = selected;
+ lua_push_upstream (L, 1, selected);
}
else {
lua_pushnil (L);
@@ -348,7 +386,7 @@ lua_upstream_list_get_upstream_master_slave (lua_State *L)
{
LUA_TRACE_POINT;
struct upstream_list *upl;
- struct upstream *selected, **pselected;
+ struct upstream *selected;
upl = lua_check_upstream_list (L);
if (upl) {
@@ -357,9 +395,7 @@ lua_upstream_list_get_upstream_master_slave (lua_State *L)
NULL,
0);
if (selected) {
- pselected = lua_newuserdata (L, sizeof (struct upstream *));
- rspamd_lua_setclass (L, "rspamd{upstream}", -1);
- *pselected = selected;
+ lua_push_upstream (L, 1, selected);
}
else {
lua_pushnil (L);
@@ -372,16 +408,17 @@ lua_upstream_list_get_upstream_master_slave (lua_State *L)
return 1;
}
+struct upstream_foreach_cbdata {
+ lua_State *L;
+ gint ups_pos;
+};
+
static void lua_upstream_inserter (struct upstream *up, guint idx, void *ud)
{
- struct upstream **pup;
- lua_State *L = (lua_State *)ud;
-
- pup = lua_newuserdata (L, sizeof (struct upstream *));
- rspamd_lua_setclass (L, "rspamd{upstream}", -1);
- *pup = up;
+ struct upstream_foreach_cbdata *cbd = (struct upstream_foreach_cbdata *)ud;
- lua_rawseti (L, -2, idx + 1);
+ lua_push_upstream (cbd->L, cbd->ups_pos, up);
+ lua_rawseti (cbd->L, -2, idx + 1);
}
/***
* @method upstream_list:all_upstreams()
@@ -393,11 +430,15 @@ lua_upstream_list_all_upstreams (lua_State *L)
{
LUA_TRACE_POINT;
struct upstream_list *upl;
+ struct upstream_foreach_cbdata cbd;
upl = lua_check_upstream_list (L);
if (upl) {
+ cbd.L = L;
+ cbd.ups_pos = 1;
+
lua_createtable (L, rspamd_upstreams_count (upl), 0);
- rspamd_upstreams_foreach (upl, lua_upstream_inserter, L);
+ rspamd_upstreams_foreach (upl, lua_upstream_inserter, &cbd);
}
else {
return luaL_error (L, "invalid arguments");
@@ -458,6 +499,7 @@ lua_upstream_flag_to_str (enum rspamd_upstreams_watch_event fl)
struct rspamd_lua_upstream_watcher_cbdata {
lua_State *L;
gint cbref;
+ gint parent_cbref; /* Reference to the upstream list */
struct upstream_list *upl;
};
@@ -470,7 +512,6 @@ lua_upstream_watch_func (struct upstream *up,
struct rspamd_lua_upstream_watcher_cbdata *cdata =
(struct rspamd_lua_upstream_watcher_cbdata *)ud;
lua_State *L;
- struct upstream **pup;
const gchar *what;
gint err_idx;
@@ -481,9 +522,14 @@ lua_upstream_watch_func (struct upstream *up,
lua_rawgeti (L, LUA_REGISTRYINDEX, cdata->cbref);
lua_pushstring (L, what);
- pup = lua_newuserdata (L, sizeof (*pup));
- *pup = up;
+
+ struct rspamd_lua_upstream *lua_ups = lua_newuserdata (L, sizeof (*lua_ups));
+ lua_ups->up = up;
rspamd_lua_setclass (L, "rspamd{upstream}", -1);
+ /* Store parent in the upstream to prevent gc */
+ lua_rawgeti (L, LUA_REGISTRYINDEX, cdata->parent_cbref);
+ lua_ups->upref = luaL_ref (L, LUA_REGISTRYINDEX);
+
lua_pushinteger (L, cur_errors);
if (lua_pcall (L, 3, 0, err_idx) != 0) {
@@ -503,6 +549,7 @@ lua_upstream_watch_dtor (gpointer ud)
(struct rspamd_lua_upstream_watcher_cbdata *)ud;
luaL_unref (cdata->L, LUA_REGISTRYINDEX, cdata->cbref);
+ luaL_unref (cdata->L, LUA_REGISTRYINDEX, cdata->parent_cbref);
g_free (cdata);
}
@@ -554,6 +601,8 @@ lua_upstream_list_add_watcher (lua_State *L)
cdata->cbref = luaL_ref (L, LUA_REGISTRYINDEX);
cdata->L = L;
cdata->upl = upl;
+ lua_pushvalue (L, 1); /* upstream list itself */
+ cdata->parent_cbref = luaL_ref (L, LUA_REGISTRYINDEX);
rspamd_upstreams_add_watch_callback (upl, flags,
lua_upstream_watch_func, lua_upstream_watch_dtor, cdata);
generated by cgit v1.2.3 (git 2.39.1) at 2024-12-23 04:45:22 +0000