Fix RedisTransactioner: handle empty deque

mint570 · Jan 2, 2021 · 6d1d33b · 6d1d33b
1 parent 624e0b8
commit 6d1d33b
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/common/redistran.cpp b/common/redistran.cpp
@@ -73,14 +73,21 @@ void RedisTransactioner::enqueue(const std::string &command, int expectedType)
 
 redisReply *RedisTransactioner::dequeueReply()
 {
+    if (m_results.empty())
+    {
+        return NULL;
+    }
     redisReply *ret = m_results.front();
     m_results.pop_front();
     return ret;
 }
 
 void RedisTransactioner::clearResults()
 {
-    if (m_results.empty()) return;
+    if (m_results.empty())
+    {
+        return;
+    }
     for (const auto& r: m_results)
     {
         freeReplyObject(r);