mirror
/
tile38
mirror of https://github.com/tidwall/tile38.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Avoid failing if replconf isn't supported

This commit is contained in:
Steven Wolfe 2019-02-13 15:46:18 -07:00
parent 9d8ce14ffd
commit 224a0a28e0
1 changed files with 23 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
internal/server/follow.go
View File

@ -227,21 +227,31 @@ func (c *Server) followStep(host string, port int, followc int) error {
}
// Send the replication port to the leader
v, err := conn.Do("replconf", "listening-port", c.port)
if err != nil {
return err
}
if v.Error() != nil {
return v.Error()
}
if v.String() != "OK" {
return errors.New("invalid response to replconf request")
}
if core.ShowDebugMessages {
log.Debug("follow:", addr, ":replconf")
if err := func() error {
v, err := conn.Do("replconf", "listening-port", c.port)
if err != nil {
return err
}
if v.Error() != nil {
return v.Error()
}
if v.String() != "OK" {
return errors.New("invalid response to replconf request")
}
return nil
}(); err != nil {
if strings.HasPrefix(err.Error(), "ERR unknown command") {
log.Warn("follow:", addr, ":replconf", "not available on leader")
} else {
return err
}
} else {
if core.ShowDebugMessages {
log.Debug("follow:", addr, ":replconf")
}
}
v, err = conn.Do("aof", pos)
v, err := conn.Do("aof", pos)
if err != nil {
return err
}