make PipelineCountLimit worked

2 years ago · afcc5fab51
parent 3be71d3840
commit afcc5fab51
1 changed files with 2 additions and 2 deletions
--- a/internal/writer/redis.go
+++ b/internal/writer/redis.go
@ -44,11 +44,11 @@ func (w *redisWriter) Write(e *entry.Entry) {
 	client.EncodeArgv(e.Argv, w.cmdBuffer)
 	e.EncodedSize = uint64(w.cmdBuffer.Len())
 	for e.EncodedSize+atomic.LoadUint64(&w.UpdateUnansweredBytesCount) > config.Config.Advanced.TargetRedisClientMaxQuerybufLen {
-		time.Sleep(1 * time.Millisecond)
+		time.Sleep(1 * time.Nanosecond)
 	}
+	w.chWaitReply <- e
 	atomic.AddUint64(&w.UpdateUnansweredBytesCount, e.EncodedSize)
 	w.client.SendBytes(w.cmdBuffer.Bytes())
-	w.chWaitReply <- e
 }

 func (w *redisWriter) switchDbTo(newDbId int) {