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

EquentR · web-flow · commit 040c64f0d533 · 2024-07-01T19:12:52.000+08:00
#836
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",
+		}
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -92,9 +92,11 @@ func (w *redisStandaloneWriter) switchDbTo(newDbId int) {`
`92`	`92`	`log.Debugf("[%s] switch db to [%d]", w.stat.Name, newDbId)`
`93`	`93`	`w.client.Send("select", strconv.Itoa(newDbId))`
`94`	`94`	`w.DbId = newDbId`
`95`		`- w.chWaitReply <- &entry.Entry{`
`96`		`- Argv: []string{"select", strconv.Itoa(newDbId)},`
`97`		`- CmdName: "select",`
	`95`	`+ if !w.offReply {`
	`96`	`+ w.chWaitReply <- &entry.Entry{`
	`97`	`+ Argv: []string{"select", strconv.Itoa(newDbId)},`
	`98`	`+ CmdName: "select",`
	`99`	`+ }`
`98`	`100`	`}`
`99`	`101`	`}`
`100`	`102`