Merge pull request #28 from jumpeiMano/feature/lock

Get lock of conn and fix typo

README.md

@@ -39,7 +39,7 @@ func main() {
 ### SetConnMaxOpen
 SetConnMaxOpen sets the maximum amount of opening connections. Default is 0 (unlimited).
 
-### SetConnectTimeout
+### SetConnMaxLifetime
 SetConnMaxLifetime sets the maximum amount of time a connection may be reused.
 Expired connections may be closed lazily before reuse. If d <= 0, connections are reused forever.
 Default is 0.

cmd.go

@@ -326,6 +326,8 @@ func (cl *Client) Delete(noreply bool, keys ...string) (failedKeys []string, err
 			wg.Add(1)
 			go func(c *conn) {
 				defer wg.Done()
+				c.mu.Lock()
+				defer c.mu.Unlock()
 				if err := c.flush(); err != nil {
 					ec <- errors.Wrap(err, "Failed flush")
 				}
@@ -472,6 +474,8 @@ func (cl *Client) getOrGat(command string, exp int64, keys []string) ([]*Item, e
 		wg.Add(1)
 		go func(c *conn) {
 			defer wg.Done()
+			c.mu.Lock()
+			defer c.mu.Unlock()
 			if err := c.writestrings("\r\n"); err != nil {
 				ec <- errors.Wrap(err, "Failed writestrings")
 				return
@@ -618,7 +622,7 @@ func (cl *Client) store(command string, items []*Item, noreply bool) ([]string,
 			}
 			if item.Cas != 0 {
 				if err = c.writestring(" "); err != nil {
-					ec <- errors.Wrap(err, "Failed writestrint")
+					ec <- errors.Wrap(err, "Failed writestring")
 					return
 				}
 				if err := c.write(strconv.AppendUint(nil, item.Cas, 10)); err != nil {
@@ -664,6 +668,8 @@ func (cl *Client) store(command string, items []*Item, noreply bool) ([]string,
 			wg.Add(1)
 			go func(c *conn) {
 				defer wg.Done()
+				c.mu.Lock()
+				defer c.mu.Unlock()
 				if err := c.flush(); err != nil {
 					ec <- errors.Wrap(err, "Failed flush")
 				}

connection_pool.go

@@ -362,7 +362,7 @@ func needCloseConn(err error) bool {
 	if err == nil {
 		return false
 	}
-	errcouse := errors.Cause(err)
-	return errcouse == ErrBadConn ||
-		errcouse == ErrServer
+	errcause := errors.Cause(err)
+	return errcause == ErrBadConn ||
+		errcause == ErrServer
 }