re
/
redis
forked from mirror/redis
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use simple PING for compatibility

This commit is contained in:
Vladimir Mihailenco 2017-02-23 15:29:38 +02:00
parent 6dfa30adb8
commit 58e9c55d8e
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pubsub.go
View File

@ -98,10 +98,10 @@ func (c *PubSub) Close() error {
return c.base.Close()
}
func (c *PubSub) Ping(payload string) error {
func (c *PubSub) Ping(payload ...string) error {
args := []interface{}{"PING"}
if payload != "" {
args = append(args, payload)
if len(payload) == 1 {
args = append(args, payload[0])
}
cmd := NewCmd(args...)
@ -239,7 +239,7 @@ func (c *PubSub) receiveMessage(timeout time.Duration) (*Message, error) {
errNum++
if errNum < 3 {
if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
err := c.Ping("hello")
err := c.Ping()
if err != nil {
internal.Logf("PubSub.Ping failed: %s", err)
}