Skip to content

Commit 3f3ce18

Browse files
committed
Merge pull request #590 from fjjiaboming/master
logging when error occours on ZK
2 parents 24ca7cf + d6a3bc0 commit 3f3ce18

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

pkg/models/server_group.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -302,6 +302,9 @@ func (self *ServerGroup) AddServer(zkConn zkhelper.Conn, s *Server, passwd strin
302302

303303
zkPath := fmt.Sprintf("/zk/codis/db_%s/servers/group_%d/%s", self.ProductName, self.Id, s.Addr)
304304
_, err = zkhelper.CreateOrUpdate(zkConn, zkPath, string(val), 0, zkhelper.DefaultFileACLs(), true)
305+
if err != nil {
306+
return errors.Trace(err)
307+
}
305308

306309
// update servers
307310
servers, err = self.GetServers(zkConn)

0 commit comments

Comments
 (0)