Commit ad7a86fb authored by antirez's avatar antirez
Browse files

just minor aesthetic changes to cluster.c

parent eab0e26e
...@@ -493,6 +493,7 @@ void nodeIp2String(char *buf, clusterLink *link) { ...@@ -493,6 +493,7 @@ void nodeIp2String(char *buf, clusterLink *link) {
/* Update the node address to the IP address that can be extracted /* Update the node address to the IP address that can be extracted
* from link->fd, and at the specified port. */ * from link->fd, and at the specified port. */
void nodeUpdateAddress(clusterNode *node, clusterLink *link, int port) { void nodeUpdateAddress(clusterNode *node, clusterLink *link, int port) {
/* TODO */
} }
/* When this function is called, there is a packet to process starting /* When this function is called, there is a packet to process starting
...@@ -510,8 +511,8 @@ int clusterProcessPacket(clusterLink *link) { ...@@ -510,8 +511,8 @@ int clusterProcessPacket(clusterLink *link) {
uint16_t type = ntohs(hdr->type); uint16_t type = ntohs(hdr->type);
clusterNode *sender; clusterNode *sender;
redisLog(REDIS_DEBUG,"--- packet to process %lu bytes (%lu) ---", redisLog(REDIS_DEBUG,"--- Processing packet of type %d, %lu bytes",
(unsigned long) totlen, sdslen(link->rcvbuf)); type, (unsigned long) totlen);
if (totlen < 8) return 1; if (totlen < 8) return 1;
if (totlen > sdslen(link->rcvbuf)) return 1; if (totlen > sdslen(link->rcvbuf)) return 1;
if (type == CLUSTERMSG_TYPE_PING || type == CLUSTERMSG_TYPE_PONG || if (type == CLUSTERMSG_TYPE_PING || type == CLUSTERMSG_TYPE_PONG ||
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment