What: configurable of pipeline feature

Why:

  * can disable pipeline support by config

How:

  * nop

redistest/server.go

@@ -128,12 +128,13 @@ func FakeTimeoutServer(handler redis.Handler, timeout time.Duration) (srv *redis
 	}
 
 	srv = &redis.Server{
-		Handler:      handler,
-		ReadTimeout:  3 * time.Second,
-		WriteTimeout: 5 * time.Second,
-		IdleTimeout:  timeout,
-		EnableRetry:  true,
-		ErrorLog:     log.New(os.Stdout, "[Server Timeout] ", os.O_CREATE|os.O_WRONLY|os.O_APPEND),
+		Handler:        handler,
+		ReadTimeout:    3 * time.Second,
+		WriteTimeout:   5 * time.Second,
+		IdleTimeout:    timeout,
+		EnableRetry:    true,
+		EnablePipeline: true,
+		ErrorLog:       log.New(os.Stdout, "[Server Timeout] ", os.O_CREATE|os.O_WRONLY|os.O_APPEND),
 	}
 
 	go func() {

server.go

@@ -70,7 +70,9 @@ type Server struct {
 	// Handler invoked to handle Redis requests, must not be nil.
 	Handler Handler
 
-	EnableRetry bool
+	// features of command retry and pipeline
+	EnableRetry    bool
+	EnablePipeline bool
 
 	// ReadTimeout is the maximum duration for reading the entire request,
 	// including the reading the argument list.
@@ -370,7 +372,7 @@ func (s *Server) serveCommands(c *Conn, addr string, cmds []Command, config serv
 
 	// is this a pipeline?
 	reqErr := req.Close()
-	if err == nil && reqErr == nil {
+	if s.EnablePipeline && err == nil && reqErr == nil {
 		pipeErr := s.servePipeline(c, addr, cmds, config)
 		if pipeErr != ErrNotPipeline {
 			err = pipeErr