Lock when clearing resp.

sogou · Aug 19, 2024 · b262623 · b262623
1 parent fba3a92
commit b262623
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/factory/RedisTaskImpl.cc b/src/factory/RedisTaskImpl.cc
@@ -388,7 +388,9 @@ ComplexRedisSubscribeTask::SubscribeWrapper::next_in(ProtocolMessage *message)
 	task_->watching_ = true;
 	task_->extract_(task_);
 
+	task_.mutex.lock();
 	task_->clear_resp();
+	task_.mutex.unlock();
 	return task_->finished_ ? NULL : &task_->resp;
 }