Home
last modified time | relevance | path

Searched refs:CLUSTER_NODE_HANDSHAKE (Results 1 – 3 of 3) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dcluster.h55 #define CLUSTER_NODE_HANDSHAKE 32 /* We have still to exchange the first ping */ macro
64 #define nodeInHandshake(n) ((n)->flags & CLUSTER_NODE_HANDSHAKE)
H A Dcluster.c202 n->flags |= CLUSTER_NODE_HANDSHAKE; in clusterLoadConfig()
322 ci = clusterGenNodesDescription(CLUSTER_NODE_HANDSHAKE); in clusterSaveConfig()
1326 n = createClusterNode(NULL,CLUSTER_NODE_HANDSHAKE|CLUSTER_NODE_MEET); in clusterStartHandshake()
1770 node = createClusterNode(NULL,CLUSTER_NODE_HANDSHAKE); in clusterProcessPacket()
1819 link->node->flags &= ~CLUSTER_NODE_HANDSHAKE; in clusterProcessPacket()
2238 if (node->flags & (CLUSTER_NODE_MYSELF|CLUSTER_NODE_HANDSHAKE)) in clusterBroadcastMessage()
2430 if (this->flags & (CLUSTER_NODE_HANDSHAKE|CLUSTER_NODE_NOADDR) || in clusterSendPing()
2454 if (node->flags & CLUSTER_NODE_HANDSHAKE) continue; in clusterSendPing()
3449 if (this->flags & (CLUSTER_NODE_MYSELF|CLUSTER_NODE_HANDSHAKE)) in clusterCron()
3478 (CLUSTER_NODE_MYSELF|CLUSTER_NODE_NOADDR|CLUSTER_NODE_HANDSHAKE)) in clusterCron()
[all …]
H A Dmodule.c4152 if (node->flags & (CLUSTER_NODE_NOADDR|CLUSTER_NODE_HANDSHAKE)) continue; in RM_GetClusterNodesList()
4213 if (node->flags & (CLUSTER_NODE_NOADDR|CLUSTER_NODE_HANDSHAKE)) in RM_GetClusterNodeInfo()