Lines Matching refs:c_start
154 if(cmasterNodeId == getOwnNodeId() && c_start.m_starting.isclear()){ in execCONTINUEB()
161 if(now > c_start.m_startFailureTimeout) in execCONTINUEB()
668 c_start.m_lastGci = 0; in startPhase2Lab()
669 c_start.m_lastGciNodeId = getOwnNodeId(); in startPhase2Lab()
687 c_start.m_lastGci = conf->latest_gci; in execDIH_RESTARTCONF()
755 c_start.m_startTime = NdbTick_CurrentMillisecond(); in execREAD_NODESCONF()
756 c_start.m_startPartialTimeout = setTimeout(c_start.m_startTime, to_1); in execREAD_NODESCONF()
757 c_start.m_startPartitionedTimeout = setTimeout(c_start.m_startTime, to_2); in execREAD_NODESCONF()
758 c_start.m_startFailureTimeout = setTimeout(c_start.m_startTime, to_3); in execREAD_NODESCONF()
780 req->lastGci = c_start.m_lastGci; in sendCntrStartReq()
828 c_start.m_lastGci = conf->startGci; in execCNTR_START_CONF()
833 c_start.m_starting.assign(NdbNodeBitmask::Size, conf->startingNodes); in execCNTR_START_CONF()
863 c_start.m_starting.clear(nodeId); in execCNTR_START_REP()
881 c_start.m_starting.clear(nodeId); in execSTART_PERMREP()
883 if(!c_start.m_starting.isclear()){ in execSTART_PERMREP()
890 c_start.reset(); in execSTART_PERMREP()
894 if(c_start.m_waiting.isclear()){ in execSTART_PERMREP()
896 c_start.reset(); in execSTART_PERMREP()
951 c_start.m_waiting.set(nodeId); in execCNTR_START_REQ()
955 c_start.m_withoutLog.set(nodeId); in execCNTR_START_REQ()
959 c_start.m_withLog.set(nodeId); in execCNTR_START_REQ()
960 if(starting && lastGci > c_start.m_lastGci){ in execCNTR_START_REQ()
965 NodeReceiverGroup rg (NDBCNTR, c_start.m_waiting); in execCNTR_START_REQ()
972 Uint32 i = c_start.m_logNodesCount++; in execCNTR_START_REQ()
973 c_start.m_logNodes[i].m_nodeId = nodeId; in execCNTR_START_REQ()
974 c_start.m_logNodes[i].m_lastGci = req->lastGci; in execCNTR_START_REQ()
983 const bool startInProgress = !c_start.m_starting.isclear(); in execCNTR_START_REQ()
1006 if (!c_start.m_waitTO.isclear()) in startWaitingNodes()
1012 ndbout_c("starting (TO) %s", c_start.m_waitTO.getText(buf)); in startWaitingNodes()
1019 NodeReceiverGroup rg(NDBCNTR, c_start.m_waitTO); in startWaitingNodes()
1020 c_start.m_starting.bitOR(c_start.m_waitTO); in startWaitingNodes()
1021 c_start.m_waiting.bitANDC(c_start.m_waitTO); in startWaitingNodes()
1022 c_start.m_waitTO.clear(); in startWaitingNodes()
1035 const Uint32 nodeId = c_start.m_waiting.find(0); in startWaitingNodes()
1037 ndbrequire(nodeId != c_start.m_waiting.NotFound); in startWaitingNodes()
1040 if(c_start.m_withoutLog.get(nodeId)) in startWaitingNodes()
1060 c_start.m_waiting.clear(nodeId); in startWaitingNodes()
1061 c_start.m_withLog.clear(nodeId); in startWaitingNodes()
1062 c_start.m_withoutLog.clear(nodeId); in startWaitingNodes()
1063 c_start.m_starting.set(nodeId); in startWaitingNodes()
1067 c_start.m_starting = c_start.m_waiting; in startWaitingNodes()
1068 c_start.m_waiting.clear(); in startWaitingNodes()
1074 c_start.m_starting.copyto(NdbNodeBitmask::Size, conf->startingNodes); in startWaitingNodes()
1078 if(!c_start.m_withLog.isclear()){ in startWaitingNodes()
1080 ndbout_c("Starting nodes w/ log: %s", c_start.m_withLog.getText(buf)); in startWaitingNodes()
1082 NodeReceiverGroup rg(NDBCNTR, c_start.m_withLog); in startWaitingNodes()
1089 if(!c_start.m_withoutLog.isclear()){ in startWaitingNodes()
1091 ndbout_c("Starting nodes wo/ log: %s", c_start.m_withoutLog.getText(buf)); in startWaitingNodes()
1092 NodeReceiverGroup rg(NDBCNTR, c_start.m_withoutLog); in startWaitingNodes()
1099 c_start.m_waiting.clear(); in startWaitingNodes()
1100 c_start.m_withLog.clear(); in startWaitingNodes()
1101 c_start.m_withoutLog.clear(); in startWaitingNodes()
1132 const bool allNodes = c_start.m_waiting.equal(c_allDefinedNodes); in trySystemRestart()
1133 const bool allClusterNodes = c_start.m_waiting.equal(c_clusterNodes); in trySystemRestart()
1141 if(c_start.m_waiting.equal(c_start.m_withoutLog)) in trySystemRestart()
1145 c_start.m_starting = c_start.m_withoutLog; // Used for starting... in trySystemRestart()
1146 c_start.m_withoutLog.clear(); in trySystemRestart()
1149 CheckNodeGroups::Output wLog = checkNodeGroups(signal, c_start.m_withLog); in trySystemRestart()
1162 bool allowPartition = (c_start.m_startPartitionedTimeout != (Uint64)~0); in trySystemRestart()
1177 c_start.m_starting = c_start.m_withLog; in trySystemRestart()
1178 c_start.m_withLog.clear(); in trySystemRestart()
1185 conf->noStartNodes = c_start.m_starting.count(); in trySystemRestart()
1187 conf->startGci = c_start.m_lastGci; in trySystemRestart()
1188 conf->masterNodeId = c_start.m_lastGciNodeId; in trySystemRestart()
1189 c_start.m_starting.copyto(NdbNodeBitmask::Size, conf->startingNodes); in trySystemRestart()
1192 ndbrequire(c_start.m_lastGciNodeId == getOwnNodeId()); in trySystemRestart()
1194 NodeReceiverGroup rg(NDBCNTR, c_start.m_starting); in trySystemRestart()
1197 c_start.m_waiting.bitANDC(c_start.m_starting); in trySystemRestart()
1402 if (!c_start.m_starting.equal(tmp)) in execNDB_STARTCONF()
1409 c_start.m_starting.getText(buf0), in execNDB_STARTCONF()
1412 NdbNodeBitmask waiting = c_start.m_starting; in execNDB_STARTCONF()
1415 c_start.m_waiting.bitOR(waiting); in execNDB_STARTCONF()
1416 c_start.m_waitTO.bitOR(waiting); in execNDB_STARTCONF()
1418 c_start.m_starting.assign(tmp); in execNDB_STARTCONF()
1419 cnoStartNodes = c_start.m_starting.count(); in execNDB_STARTCONF()
1423 NodeReceiverGroup rg(NDBCNTR, c_start.m_starting); in execNDB_STARTCONF()
1426 c_start.m_starting.copyto(NdbNodeBitmask::Size, signal->theData+2); in execNDB_STARTCONF()
1586 NodeReceiverGroup rg(NDBCNTR, c_start.m_starting); in ph6ALab()
1635 NodeReceiverGroup rg(NDBCNTR, c_start.m_starting); in waitpoint61Lab()
1681 NodeReceiverGroup rg(NDBCNTR, c_start.m_starting); in waitpoint71Lab()
1765 c_start.m_wait_sp[rep.nodeId] = rep.sp; in wait_sp_rep()
1770 Uint32 node = c_start.m_starting.find(0); in wait_sp_rep()
1771 ndbrequire(node < NDB_ARRAY_SIZE(c_start.m_wait_sp)); in wait_sp_rep()
1772 Uint32 min = c_start.m_wait_sp[node]; in wait_sp_rep()
1774 node = c_start.m_starting.find(node + 1)) in wait_sp_rep()
1779 if (c_start.m_wait_sp[node] < min) in wait_sp_rep()
1781 min = c_start.m_wait_sp[node]; in wait_sp_rep()
1794 node = c_start.m_starting.find(0); in wait_sp_rep()
1796 node = c_start.m_starting.find(node + 1)) in wait_sp_rep()
1801 if (c_start.m_wait_sp[node] == min) in wait_sp_rep()
1804 c_start.m_wait_sp[node] = 0; in wait_sp_rep()
1833 c_start.m_starting.assign(NdbNodeBitmask::Size, signal->theData + 2); in execCNTR_WAITREP()
1894 NdbNodeBitmask failedStarting = c_start.m_starting; in execNODE_FAILREP()
1895 NdbNodeBitmask failedWaiting = c_start.m_waiting; in execNODE_FAILREP()
1916 c_start.m_starting.bitANDC(allFailed); in execNODE_FAILREP()
1917 c_start.m_waiting.bitANDC(allFailed); in execNODE_FAILREP()
1918 c_start.m_withLog.bitANDC(allFailed); in execNODE_FAILREP()
1919 c_start.m_withoutLog.bitANDC(allFailed); in execNODE_FAILREP()
1920 c_start.m_waitTO.bitANDC(allFailed); in execNODE_FAILREP()
2103 tmp1.bitOR(c_start.m_starting); in execREAD_NODESREQ()
2118 c_start.m_starting.copyto(NdbNodeBitmask::Size, readNodes->startingNodes); in execREAD_NODESREQ()
2733 c_start.reset(); in initData()
2940 (cmasterNodeId == getOwnNodeId() && !c_start.m_starting.isclear())) in execSTOP_REQ()