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

RedisConnection#ExecuteQueries(): fire all queries at once

Browse Source 
refs #49
This commit is contained in:
Alexander A. Klimov 2019-07-25 17:41:07 +02:00 committed by Michael Friedrich
parent 74eccf60f2
commit bb333b535b
2 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
lib/redis/redisconnection.cpp
View File

@ -189,12 +189,10 @@ void RedisConnection::ExecuteQuery(const std::vector<String>& query, redisCallba
void void
RedisConnection::ExecuteQueries(const std::vector<std::vector<String> >& queries, redisCallbackFn *fn, void *privdata) RedisConnection::ExecuteQueries(const std::vector<std::vector<String> >& queries, redisCallbackFn *fn, void *privdata)
{ {
for (const auto& query : queries) { m_RedisConnectionWorkQueue.Enqueue([this, queries, fn, privdata]() {
m_RedisConnectionWorkQueue.Enqueue([this, query, fn, privdata]() { SendMessagesInternal(queries, fn, privdata);
SendMessageInternal(query, fn, privdata);
}); });
} }
}
void RedisConnection::SendMessageInternal(const std::vector<String>& query, redisCallbackFn *fn, void *privdata) void RedisConnection::SendMessageInternal(const std::vector<String>& query, redisCallbackFn *fn, void *privdata)
{ {
@ -248,3 +246,10 @@ void RedisConnection::SendMessageInternal(const std::vector<String>& query, redi
); );
} }
} }
void RedisConnection::SendMessagesInternal(const std::vector<std::vector<String>>& queries, redisCallbackFn *fn, void *privdata)
{
for (const auto& query : queries) {
SendMessageInternal(query, fn, privdata);
}
}

1
lib/redis/redisconnection.hpp
View File

@ -69,6 +69,7 @@ namespace icinga
static void StaticInitialize(); static void StaticInitialize();
void SendMessageInternal(const std::vector<String>& query, redisCallbackFn *fn, void *privdata); void SendMessageInternal(const std::vector<String>& query, redisCallbackFn *fn, void *privdata);
void SendMessagesInternal(const std::vector<std::vector<String>>& queries, redisCallbackFn *fn, void *privdata);
void AssertOnWorkQueue(); void AssertOnWorkQueue();