tyler.durden
/
icinga2
mirror of https://github.com/Icinga/icinga2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "Merge branch 'bugfix/execute-quieries' into 'feature/redis'" 

This reverts commit f6c1fc3b43b1895eb87c1657f3e3355bfe9ddaac, reversing
changes made to ad1d448bcdead76a2bd45171a6efcd700b1c23d0.
This commit is contained in:
Jean Flach 2019-01-29 15:44:49 +01:00 committed by Michael Friedrich
parent 0ad008f465
commit 7890c37357
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
lib/redis/redisconnection.cpp
View File

@ -187,7 +187,6 @@ 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));
} }