fix: switchdb blocking after closing destination reply (#837)

#836
tair-opensource · Jul 1, 2024 · 040c64f · 040c64f
1 parent 10e2003
commit 040c64f
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/internal/writer/redis_standalone_writer.go b/internal/writer/redis_standalone_writer.go
@@ -92,9 +92,11 @@ func (w *redisStandaloneWriter) switchDbTo(newDbId int) {
 	log.Debugf("[%s] switch db to [%d]", w.stat.Name, newDbId)
 	w.client.Send("select", strconv.Itoa(newDbId))
 	w.DbId = newDbId
-	w.chWaitReply <- &entry.Entry{
-		Argv:    []string{"select", strconv.Itoa(newDbId)},
-		CmdName: "select",
+	if !w.offReply {
+		w.chWaitReply <- &entry.Entry{
+			Argv:    []string{"select", strconv.Itoa(newDbId)},
+			CmdName: "select",
+		}
 	}
 }