diff --git a/src/replication.c b/src/replication.c index 5f4c2d38d2e27ba3317183669676f6b752c476ad..d15d2fef6b055ec4bb1f6d588ecee393badabec0 100644 --- a/src/replication.c +++ b/src/replication.c @@ -1353,11 +1353,23 @@ void roleCommand(redisClient *c) { } setDeferredMultiBulkLength(c,mbcount,slaves); } else { + char *slavestate = NULL; + addReplyMultiBulkLen(c,4); addReplyBulkCBuffer(c,"slave",5); addReplyBulkCString(c,server.masterhost); addReplyLongLong(c,server.masterport); - addReplyLongLong(c,server.master->reploff); + switch(server.repl_state) { + case REDIS_REPL_NONE: slavestate = "none"; break; + case REDIS_REPL_CONNECT: slavestate = "connect"; break; + case REDIS_REPL_CONNECTING: slavestate = "connecting"; break; + case REDIS_REPL_RECEIVE_PONG: /* see next */ + case REDIS_REPL_TRANSFER: slavestate = "sync"; break; + case REDIS_REPL_CONNECTED: slavestate = "connected"; break; + default: slavestate = "unknown"; break; + } + addReplyBulkCString(c,slavestate); + addReplyLongLong(c,server.master ? server.master->reploff : -1); } }