bugfix pika_to_redis sender thread early exit in some scenarios (#272)

OpenAtomFoundation · May 11, 2018 · a44f878 · a44f878
1 parent a6b4793
commit a44f878
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tools/pika_to_redis/sender.cc b/tools/pika_to_redis/sender.cc
@@ -150,7 +150,7 @@ void *Sender::ThreadMain() {
 
  if (cli_ == NULL) {
  ConnectRedis();
- if (should_exit_) {
+ if (QueueSize() == 0 && should_exit_) {
  return NULL;
  }
  } else {