Searched refs:nodeFailed (Results 1 – 9 of 9) sorted by relevance
37 s.nodeFailed(e.(serf.MemberEvent))230 func (s *Server) nodeFailed(me serf.MemberEvent) { func
37 s.nodeFailed(e.(serf.MemberEvent))237 func (s *Server) nodeFailed(me serf.MemberEvent) { func
66 #define nodeFailed(n) ((n)->flags & CLUSTER_NODE_FAIL) macro
933 if (!nodeFailed(n->slaves[j])) okslaves++; in clusterCountNonFailingSlaves()1275 if (nodeFailed(node)) return; /* Already FAILing. */ in markNodeAsFailingIfNeeded()1305 serverAssert(nodeFailed(node)); in clearNodeFailureIfNeeded()1976 } else if (nodeFailed(link->node)) { in clusterProcessPacket()2898 (!nodeFailed(master) && !force_ack)) in clusterSendFailoverAuthIfNeeded()2908 } else if (!nodeFailed(master)) { in clusterSendFailoverAuthIfNeeded()3028 nodeFailed(myself->slaveof) && in clusterLogCantFailover()3309 if (!nodeFailed(mymaster->slaves[j]) && in clusterHandleSlaveMigration()4280 if (nodeFailed(node->slaves[i])) continue; in clusterReplyMultiBulkSlots()4578 if (nodeFailed(n)) { in clusterCommand()[all …]
68 #define nodeFailed(n) ((n)->flags & CLUSTER_NODE_FAIL) macro
880 if (!nodeFailed(n->slaves[j])) okslaves++; in clusterCountNonFailingSlaves()1222 if (nodeFailed(node)) return; /* Already FAILing. */ in markNodeAsFailingIfNeeded()1249 serverAssert(nodeFailed(node)); in clearNodeFailureIfNeeded()1918 } else if (nodeFailed(link->node)) { in clusterProcessPacket()2786 (!nodeFailed(master) && !force_ack)) in clusterSendFailoverAuthIfNeeded()2796 } else if (!nodeFailed(master)) { in clusterSendFailoverAuthIfNeeded()2916 nodeFailed(myself->slaveof) && in clusterLogCantFailover()3197 if (!nodeFailed(mymaster->slaves[j]) && in clusterHandleSlaveMigration()4191 if (nodeFailed(node->slaves[i])) continue; in clusterReplyMultiBulkSlots()4491 if (nodeFailed(n)) { in clusterCommand()[all …]
834 if (!nodeFailed(n->slaves[j])) okslaves++; in clusterCountNonFailingSlaves()1176 if (nodeFailed(node)) return; /* Already FAILing. */ in markNodeAsFailingIfNeeded()1203 serverAssert(nodeFailed(node)); in clearNodeFailureIfNeeded()1830 } else if (nodeFailed(link->node)) { in clusterProcessPacket()2634 (!nodeFailed(master) && !force_ack)) in clusterSendFailoverAuthIfNeeded()2644 } else if (!nodeFailed(master)) { in clusterSendFailoverAuthIfNeeded()2762 nodeFailed(myself->slaveof) && in clusterLogCantFailover()2860 (!nodeFailed(myself->slaveof) && !manual_failover) || in clusterHandleSlaveFailover()3039 if (!nodeFailed(mymaster->slaves[j]) && in clusterHandleSlaveMigration()4279 if (nodeFailed(n)) { in clusterCommand()[all …]
64 #define nodeFailed(n) ((n)->flags & CLUSTER_NODE_FAIL) macro
1027 if (!nodeFailed(n->slaves[j])) okslaves++; in clusterCountNonFailingSlaves()1369 if (nodeFailed(node)) return; /* Already FAILing. */ in markNodeAsFailingIfNeeded()1399 serverAssert(nodeFailed(node)); in clearNodeFailureIfNeeded()2087 } else if (nodeFailed(link->node)) { in clusterProcessPacket()3022 (!nodeFailed(master) && !force_ack)) in clusterSendFailoverAuthIfNeeded()3032 } else if (!nodeFailed(master)) { in clusterSendFailoverAuthIfNeeded()3152 nodeFailed(myself->slaveof) && in clusterLogCantFailover()3433 if (!nodeFailed(mymaster->slaves[j]) && in clusterHandleSlaveMigration()4440 if (nodeFailed(node)) { in isReplicaAvailable()4863 if (nodeFailed(n)) { in clusterCommand()[all …]