fix bug when proxy reading redis get error

CodisLabs · Sep 17, 2015 · b7639ef · b7639ef
1 parent 1eaeb08
commit b7639ef
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/proxy/router/backend.go b/pkg/proxy/router/backend.go
@@ -138,6 +138,10 @@ func (bc *BackendConn) newBackendReader() (*redis.Conn, chan<- *Request, error)
 		for r := range tasks {
 			resp, err := c.Reader.Decode()
 			bc.setResponse(r, resp, err)
+			if err != nil {
+				// close tcp to tell writer we are failed and should quit
+				c.Close()
+			}
 		}
 	}()
 	return c, tasks, nil