Lines Matching refs:flags
50 clusterNode *createClusterNode(char *nodename, int flags);
70 void clusterDoBeforeSleep(int flags);
76 sds representClusterNodeFlags(sds ci, uint16_t flags);
181 n->flags |= CLUSTER_NODE_MYSELF; in clusterLoadConfig()
183 n->flags |= CLUSTER_NODE_MASTER; in clusterLoadConfig()
185 n->flags |= CLUSTER_NODE_SLAVE; in clusterLoadConfig()
187 n->flags |= CLUSTER_NODE_PFAIL; in clusterLoadConfig()
189 n->flags |= CLUSTER_NODE_FAIL; in clusterLoadConfig()
192 n->flags |= CLUSTER_NODE_HANDSHAKE; in clusterLoadConfig()
194 n->flags |= CLUSTER_NODE_NOADDR; in clusterLoadConfig()
653 clusterNode *createClusterNode(char *nodename, int flags) { in createClusterNode() argument
662 node->flags = flags; in createClusterNode()
789 master->flags &= ~CLUSTER_NODE_MIGRATE_TO; in clusterNodeRemoveSlave()
806 master->flags |= CLUSTER_NODE_MIGRATE_TO; in clusterNodeAddSlave()
1167 node->flags &= ~CLUSTER_NODE_PFAIL; in markNodeAsFailingIfNeeded()
1168 node->flags |= CLUSTER_NODE_FAIL; in markNodeAsFailingIfNeeded()
1192 node->flags &= ~CLUSTER_NODE_FAIL; in clearNodeFailureIfNeeded()
1207 node->flags &= ~CLUSTER_NODE_FAIL; in clearNodeFailureIfNeeded()
1299 uint16_t flags = ntohs(g->flags); in clusterProcessGossipSection() local
1303 ci = representClusterNodeFlags(sdsempty(), flags); in clusterProcessGossipSection()
1317 if (flags & (CLUSTER_NODE_FAIL|CLUSTER_NODE_PFAIL)) { in clusterProcessGossipSection()
1338 if (node->flags & (CLUSTER_NODE_FAIL|CLUSTER_NODE_PFAIL) && in clusterProcessGossipSection()
1339 !(flags & CLUSTER_NODE_NOADDR) && in clusterProcessGossipSection()
1340 !(flags & (CLUSTER_NODE_FAIL|CLUSTER_NODE_PFAIL)) && in clusterProcessGossipSection()
1346 node->flags &= ~CLUSTER_NODE_NOADDR; in clusterProcessGossipSection()
1356 !(flags & CLUSTER_NODE_NOADDR) && in clusterProcessGossipSection()
1401 node->flags &= ~CLUSTER_NODE_NOADDR; in nodeUpdateAddressIfNeeded()
1420 if (n != myself) n->flags |= CLUSTER_NODE_MIGRATE_TO; in clusterSetNodeAsMaster()
1422 n->flags &= ~CLUSTER_NODE_SLAVE; in clusterSetNodeAsMaster()
1423 n->flags |= CLUSTER_NODE_MASTER; in clusterSetNodeAsMaster()
1559 uint16_t flags = ntohs(hdr->flags); in clusterProcessPacket() local
1715 link->node->flags &= ~CLUSTER_NODE_HANDSHAKE; in clusterProcessPacket()
1716 link->node->flags |= flags&(CLUSTER_NODE_MASTER|CLUSTER_NODE_SLAVE); in clusterProcessPacket()
1727 link->node->flags); in clusterProcessPacket()
1728 link->node->flags |= CLUSTER_NODE_NOADDR; in clusterProcessPacket()
1758 link->node->flags &= ~CLUSTER_NODE_PFAIL; in clusterProcessPacket()
1780 sender->flags &= ~(CLUSTER_NODE_MASTER| in clusterProcessPacket()
1782 sender->flags |= CLUSTER_NODE_SLAVE; in clusterProcessPacket()
1889 !(failing->flags & (CLUSTER_NODE_FAIL|CLUSTER_NODE_MYSELF))) in clusterProcessPacket()
1894 failing->flags |= CLUSTER_NODE_FAIL; in clusterProcessPacket()
1896 failing->flags &= ~CLUSTER_NODE_PFAIL; in clusterProcessPacket()
2107 if (node->flags & (CLUSTER_NODE_MYSELF|CLUSTER_NODE_HANDSHAKE)) in clusterBroadcastMessage()
2142 hdr->flags = htons(myself->flags); in clusterBuildMessageHdr()
2247 !(this->flags & (CLUSTER_NODE_PFAIL|CLUSTER_NODE_FAIL))) in clusterSendPing()
2255 if (this->flags & (CLUSTER_NODE_HANDSHAKE|CLUSTER_NODE_NOADDR) || in clusterSendPing()
2277 gossip->flags = htons(this->flags); in clusterSendPing()
2936 if (!(node->flags & CLUSTER_NODE_MIGRATE_TO)) is_orphaned = 0; in clusterHandleSlaveMigration()
3088 if (node->flags & (CLUSTER_NODE_MYSELF|CLUSTER_NODE_NOADDR)) continue; in clusterCron()
3129 clusterSendPing(link, node->flags & CLUSTER_NODE_MEET ? in clusterCron()
3142 node->flags &= ~CLUSTER_NODE_MEET; in clusterCron()
3163 if (this->flags & (CLUSTER_NODE_MYSELF|CLUSTER_NODE_HANDSHAKE)) in clusterCron()
3191 if (node->flags & in clusterCron()
3204 node->flags & CLUSTER_NODE_MIGRATE_TO) in clusterCron()
3262 if (!(node->flags & (CLUSTER_NODE_PFAIL|CLUSTER_NODE_FAIL))) { in clusterCron()
3265 node->flags |= CLUSTER_NODE_PFAIL; in clusterCron()
3329 void clusterDoBeforeSleep(int flags) { in clusterDoBeforeSleep() argument
3330 server.cluster->todo_before_sleep |= flags; in clusterDoBeforeSleep()
3396 n->flags |= CLUSTER_NODE_MIGRATE_TO; in clusterNodeSetSlotBit()
3497 server.cluster->slots[j]->flags & (CLUSTER_NODE_FAIL)) in clusterUpdateState()
3521 if ((node->flags & (CLUSTER_NODE_FAIL|CLUSTER_NODE_PFAIL)) == 0) in clusterUpdateState()
3643 myself->flags &= ~(CLUSTER_NODE_MASTER|CLUSTER_NODE_MIGRATE_TO); in clusterSetMaster()
3644 myself->flags |= CLUSTER_NODE_SLAVE; in clusterSetMaster()
3677 sds representClusterNodeFlags(sds ci, uint16_t flags) { in representClusterNodeFlags() argument
3678 if (flags == 0) { in representClusterNodeFlags()
3684 if (flags & nodeflag->flag) ci = sdscat(ci, nodeflag->name); in representClusterNodeFlags()
3706 ci = representClusterNodeFlags(ci, node->flags); in clusterGenNodeDescription()
3719 (node->link || node->flags & CLUSTER_NODE_MYSELF) ? in clusterGenNodeDescription()
3745 if (node->flags & CLUSTER_NODE_MYSELF) { in clusterGenNodeDescription()
3780 if (node->flags & filter) continue; in clusterGenNodesDescription()
4920 c->flags |= CLIENT_ASKING; in askingCommand()
4932 c->flags |= CLIENT_READONLY; in readonlyCommand()
4938 c->flags &= ~CLIENT_READONLY; in readwriteCommand()
4990 if (!(c->flags & CLIENT_MULTI)) return myself; in getNodeByQuery()
5110 (c->flags & CLIENT_ASKING || cmd->flags & CMD_ASKING)) in getNodeByQuery()
5123 if (c->flags & CLIENT_READONLY && in getNodeByQuery()
5124 cmd->flags & CMD_READONLY && in getNodeByQuery()
5180 if (c->flags & CLIENT_BLOCKED && c->btype == BLOCKED_LIST) { in clusterRedirectBlockedClientIfNeeded()