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

Lock before queueing multiple queries

Browse Source
This commit is contained in:
Jean Flach 2019-01-28 15:52:09 +01:00 committed by Michael Friedrich
parent 03a61347cd
commit d2dc0047a3
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
lib/redis/redisconnection.cpp
View File

@ -187,6 +187,7 @@ 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)
{ {
boost::mutex::scoped_lock lock = m_RedisConnectionWorkQueue.AcquireLock();
for (const auto& query : queries) { for (const auto& query : queries) {
m_RedisConnectionWorkQueue.Enqueue(std::bind(&RedisConnection::SendMessageInternal, this, query, fn, privdata)); m_RedisConnectionWorkQueue.Enqueue(std::bind(&RedisConnection::SendMessageInternal, this, query, fn, privdata));
} }