Commit 040cb6a4 authored by Josh Hershberg's avatar Josh Hershberg
Browse files

Cluster refactor: verifyClusterNodeId need not be 'public'


Signed-off-by: default avatarJosh Hershberg <yehoshua@redis.com>
parent 4944eda6
...@@ -38,7 +38,6 @@ void clusterInitListeners(void); ...@@ -38,7 +38,6 @@ void clusterInitListeners(void);
void clusterCron(void); void clusterCron(void);
void clusterBeforeSleep(void); void clusterBeforeSleep(void);
clusterNode *getNodeByQuery(client *c, struct redisCommand *cmd, robj **argv, int argc, int *hashslot, int *ask); clusterNode *getNodeByQuery(client *c, struct redisCommand *cmd, robj **argv, int argc, int *hashslot, int *ask);
int verifyClusterNodeId(const char *name, int length);
clusterNode *clusterLookupNode(const char *name, int length); clusterNode *clusterLookupNode(const char *name, int length);
int clusterRedirectBlockedClientIfNeeded(client *c); int clusterRedirectBlockedClientIfNeeded(client *c);
void clusterRedirectClient(client *c, clusterNode *n, int hashslot, int error_code); void clusterRedirectClient(client *c, clusterNode *n, int hashslot, int error_code);
......
...@@ -104,6 +104,7 @@ sds auxTlsPortGetter(clusterNode *n, sds s); ...@@ -104,6 +104,7 @@ sds auxTlsPortGetter(clusterNode *n, sds s);
int auxTlsPortPresent(clusterNode *n); int auxTlsPortPresent(clusterNode *n);
static void clusterBuildMessageHdr(clusterMsg *hdr, int type, size_t msglen); static void clusterBuildMessageHdr(clusterMsg *hdr, int type, size_t msglen);
void freeClusterLink(clusterLink *link); void freeClusterLink(clusterLink *link);
int verifyClusterNodeId(const char *name, int length);
int getNodeDefaultClientPort(clusterNode *n) { int getNodeDefaultClientPort(clusterNode *n) {
return server.tls_cluster ? n->tls_port : n->tcp_port; return server.tls_cluster ? n->tls_port : n->tcp_port;
......
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