github.com/joomcode/redispipe
Advanced tools
@@ -331,4 +331,6 @@ package redisconn | ||
| // Since we are under shard lock, it is safe to send notification before assigning futures. | ||
| if len(conn.futures) == 0 { | ||
| if conn.opts.WritePause > 0 { | ||
| // Special case for PING since it is used for latency measurement. | ||
| hasPing := req.Cmd == "PING" | ||
| if len(conn.futures) == 0 || hasPing { | ||
| if !hasPing && conn.opts.WritePause > 0 { | ||
| conn.futtimer.Reset(conn.opts.WritePause) | ||
@@ -335,0 +337,0 @@ } else { |