tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-23 13:45:04 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #8754 from Icinga/feature/icingadb-replace-lua-with-xadd-maxlen

Browse Source 
Icinga DB: Use XADD ... MAXLEN 1 instead of a custom Lua script
This commit is contained in:
Julian Brost 2021-06-04 13:52:30 +02:00 committed by GitHub
commit 9f6cbc38f2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
lib/icingadb/icingadb-objects.cpp
View File

@ -40,19 +40,6 @@ using namespace icinga;
using Prio = RedisConnection::QueryPriority; using Prio = RedisConnection::QueryPriority;
static const char * const l_LuaResetDump = R"EOF(
local id = redis.call('XADD', KEYS[1], '*', 'key', '*', 'state', 'wip')
local xr = redis.call('XRANGE', KEYS[1], '-', '+')
for i = 1, #xr - 1 do
redis.call('XDEL', KEYS[1], xr[i][1])
end
return id
)EOF";
INITIALIZE_ONCE(&IcingaDB::ConfigStaticInitialize); INITIALIZE_ONCE(&IcingaDB::ConfigStaticInitialize);
void IcingaDB::ConfigStaticInitialize() void IcingaDB::ConfigStaticInitialize()
@ -151,7 +138,8 @@ void IcingaDB::UpdateAllConfigObjects()
m_Rcon->UnsuppressQueryKind(Prio::CheckResult); m_Rcon->UnsuppressQueryKind(Prio::CheckResult);
}); });
m_Rcon->FireAndForgetQuery({"EVAL", l_LuaResetDump, "1", "icinga:dump"}, Prio::Config); // Add a new type=* state=wip entry to the stream and remove all previous entries (MAXLEN 1).
m_Rcon->FireAndForgetQuery({"XADD", "icinga:dump", "MAXLEN", "1", "*", "key", "*", "state", "wip"}, Prio::Config);
const std::vector<String> globalKeys = { const std::vector<String> globalKeys = {
m_PrefixConfigObject + "customvar", m_PrefixConfigObject + "customvar",

27
lib/icingadb/icingadb.cpp
View File

@ -17,25 +17,6 @@ using namespace icinga;
using Prio = RedisConnection::QueryPriority; using Prio = RedisConnection::QueryPriority;
static const char * const l_LuaPublishStats = R"EOF(
local xa = {'XADD', KEYS[1], '*'}
for i = 1, #ARGV do
table.insert(xa, ARGV[i])
end
local id = redis.call(unpack(xa))
local xr = redis.call('XRANGE', KEYS[1], '-', '+')
for i = 1, #xr - 1 do
redis.call('XDEL', KEYS[1], xr[i][1])
end
return id
)EOF";
String IcingaDB::m_EnvironmentId; String IcingaDB::m_EnvironmentId;
boost::once_flag IcingaDB::m_EnvironmentIdOnce = BOOST_ONCE_INIT; boost::once_flag IcingaDB::m_EnvironmentIdOnce = BOOST_ONCE_INIT;
@ -128,17 +109,17 @@ void IcingaDB::PublishStats()
status->Set("config_dump_in_progress", m_ConfigDumpInProgress); status->Set("config_dump_in_progress", m_ConfigDumpInProgress);
status->Set("timestamp", TimestampToMilliseconds(Utility::GetTime())); status->Set("timestamp", TimestampToMilliseconds(Utility::GetTime()));
std::vector<String> eval ({"EVAL", l_LuaPublishStats, "1", "icinga:stats"}); std::vector<String> query {"XADD", "icinga:stats", "MAXLEN", "1", "*"};
{ {
ObjectLock statusLock (status); ObjectLock statusLock (status);
for (auto& kv : status) { for (auto& kv : status) {
eval.emplace_back(kv.first); query.emplace_back(kv.first);
eval.emplace_back(JsonEncode(kv.second)); query.emplace_back(JsonEncode(kv.second));
} }
} }
m_Rcon->FireAndForgetQuery(std::move(eval), Prio::Heartbeat); m_Rcon->FireAndForgetQuery(std::move(query), Prio::Heartbeat);
} }
void IcingaDB::Stop(bool runtimeRemoved) void IcingaDB::Stop(bool runtimeRemoved)