Lines Matching refs:getNodeInfo
277 Uint32 type = getNodeInfo(nodePtr.i).m_type; in execSTART_ORD()
363 Uint32 type = getNodeInfo(nodePtr.i).m_type; in execSTTOR()
499 NodeInfo nodeInfo = getNodeInfo(nodeId); in execCONNECT_REP()
517 ndbrequire(getNodeInfo(nodeId).m_type == NodeInfo::MGM); in execCONNECT_REP()
649 if(getNodeInfo(nodePtr.i).getType() != NodeInfo::DB) in cmInfoconf010Lab()
906 if (getNodeInfo(addNodePtr.i).m_type != NodeInfo::DB) in execCM_REGREQ()
992 cmRegConf->presidentVersion = getNodeInfo(getOwnNodeId()).m_version; in execCM_REGREQ()
993 cmRegConf->presidentMysqlVersion = getNodeInfo(getOwnNodeId()).m_mysql_version; in execCM_REGREQ()
1223 bool sendSourceId = ndbd_fail_rep_source_node((getNodeInfo(i)).m_version); in check_readnodes_reply()
1229 bool sendSourceId = ndbd_fail_rep_source_node((getNodeInfo(nodeId)).m_version); in check_readnodes_reply()
1252 req->version = getNodeInfo(getOwnNodeId()).m_version; in sendCmNodeInfoReq()
1253 req->mysql_version = getNodeInfo(getOwnNodeId()).m_mysql_version; in sendCmNodeInfoReq()
1254 req->lqh_workers = getNodeInfo(getOwnNodeId()).m_lqh_workers; in sendCmNodeInfoReq()
2012 conf->version = getNodeInfo(getOwnNodeId()).m_version; in cmAddPrepare()
2013 conf->mysql_version = getNodeInfo(getOwnNodeId()).m_mysql_version; in cmAddPrepare()
2014 conf->lqh_workers = getNodeInfo(getOwnNodeId()).m_lqh_workers; in cmAddPrepare()
2023 if (getNodeInfo(nodePtr.i).m_version >= NDBD_NODE_VERSION_REP) in sendApiVersionRep()
2030 Uint32 version = getNodeInfo(i).m_version; in sendApiVersionRep()
2031 Uint32 type = getNodeInfo(i).m_type; in sendApiVersionRep()
2330 cmAdd->startingVersion = getNodeInfo(addNodePtr.i).m_version; in execCM_ACKADD()
2331 cmAdd->startingMysqlVersion = getNodeInfo(addNodePtr.i).m_mysql_version; in execCM_ACKADD()
2351 cmAdd->startingVersion = getNodeInfo(addNodePtr.i).m_version; in execCM_ACKADD()
2352 cmAdd->startingMysqlVersion = getNodeInfo(addNodePtr.i).m_mysql_version; in execCM_ACKADD()
2597 if (nodeId < MAX_NDB_NODES && getNodeInfo(nodeId).m_type == NodeInfo::DB) in initData()
2776 ndbrequire(getNodeInfo(nodePtr.i).m_type == NodeInfo::DB); in checkHeartbeat()
2778 if(getNodeInfo(nodePtr.i).m_heartbeat_cnt > 2){ in checkHeartbeat()
2781 signal->theData[2] = getNodeInfo(nodePtr.i).m_heartbeat_cnt - 1; in checkHeartbeat()
2785 if (getNodeInfo(nodePtr.i).m_heartbeat_cnt > 4) { in checkHeartbeat()
2818 const NodeInfo::NodeType type = getNodeInfo(nodeId).getType(); in apiHbHandlingLab()
2830 if(getNodeInfo(TnodePtr.i).m_heartbeat_cnt > 2) in apiHbHandlingLab()
2834 signal->theData[2] = getNodeInfo(TnodePtr.i).m_heartbeat_cnt - 1; in apiHbHandlingLab()
2838 if (getNodeInfo(TnodePtr.i).m_heartbeat_cnt > 4) in apiHbHandlingLab()
2877 Uint32 type = getNodeInfo(nodePtr.i).m_type; in checkStartInterface()
2889 if ((getNodeInfo(nodePtr.i).m_heartbeat_cnt > 3) in checkStartInterface()
2935 if(((getNodeInfo(nodePtr.i).m_heartbeat_cnt + 1) % 60) == 0) in checkStartInterface()
2939 if (getNodeInfo(nodePtr.i).m_type == NodeInfo::DB) in checkStartInterface()
2946 (getNodeInfo(nodePtr.i).m_heartbeat_cnt+1)/60, in checkStartInterface()
2949 if (((getNodeInfo(nodePtr.i).m_heartbeat_cnt + 1) % 300) == 0) in checkStartInterface()
2967 (getNodeInfo(nodePtr.i).m_heartbeat_cnt+1)/60, in checkStartInterface()
3077 ndbrequire(getNodeInfo(failedNodePtr.i).getType() != NodeInfo::DB); in execAPI_FAILREQ()
3292 ndb_takeovertc(getNodeInfo(nodePtr.i).m_version)) in execNF_COMPLETEREP()
3313 const NodeInfo nodeInfo = getNodeInfo(nodeId); in execDISCONNECT_REP()
3337 if (getNodeInfo(nodeId).getType() != NodeInfo::DB) in execDISCONNECT_REP()
3381 ndbrequire(getNodeInfo(failedNodePtr.i).getType() == NodeInfo::DB); in node_failed()
3483 recompute_version_info(getNodeInfo(failedNodePtr.i).m_type); in api_failed()
3535 NodeInfo::NodeType type= getNodeInfo(apiNodePtr.i).getType(); in execAPI_REGREQ()
3614 NodeInfo::NodeType type = getNodeInfo(node).getType(); in handleEnableComApiRegreq()
3615 Uint32 version = getNodeInfo(node).m_version; in handleEnableComApiRegreq()
3687 if (getNodeInfo(i).m_version >= minversion) in sendVersionedDb()
3708 if(getNodeInfo(nodeId).m_connected) in execAPI_VERSION_REQ()
3710 conf->version = getNodeInfo(nodeId).m_version; in execAPI_VERSION_REQ()
3711 conf->mysql_version = getNodeInfo(nodeId).m_mysql_version; in execAPI_VERSION_REQ()
3739 Uint32 type = getNodeInfo(nodeId).m_type; in execNODE_VERSION_REP()
3781 if (getNodeInfo(i).m_type == type) in recompute_version_info()
3783 Uint32 version = getNodeInfo(i).m_version; in recompute_version_info()
3812 if ( getNodeInfo(nodeId).getType() != NodeInfo::MGM ) {
4106 ndbrequire(getNodeInfo(nodeId).getType() != NodeInfo::DB); in handleApiCloseComConf()
4143 if (getNodeInfo(failedNodePtr.i).getType() == NodeInfo::MGM) in handleApiCloseComConf()
4803 if (getNodeInfo(i).getType() == NODE_TYPE_DB) in failReport()
6022 if (getNodeInfo(aPtr.i).getType() == NodeInfo::DB && aPtr.p->phase == ZRUNNING){ in computeArbitNdbMask()
6037 if (getNodeInfo(aPtr.i).getType() == NodeInfo::DB && aPtr.p->phase == ZRUNNING){ in computeArbitNdbMask()
6146 Uint32 type = getNodeInfo(nodePtr.i).m_type; in execDUMP_STATE_ORD()
6231 getNodeInfo(nodePtr.i).m_version >= api.minVersion) in execAPI_BROADCAST_REP()
6332 getNodeInfo(refToNode(req.senderRef)).m_connectCount; in execALLOC_NODEID_REQ()
6353 else if (req.nodeType != getNodeInfo(req.nodeId).m_type) in execALLOC_NODEID_REQ()
6466 getNodeInfo(refToNode(opAllocNodeIdReq.m_req.senderRef)).m_connectCount) in completeAllocNodeIdReq()
6561 const NodeInfo& nodeInfo = getNodeInfo(nodePtr.i); in check_hb_order_config()
6583 const NodeInfo& nodeInfo = getNodeInfo(nodePtr.i); in check_hb_order_config()
6590 const NodeInfo& nodeInfo2 = getNodeInfo(nodePtr2.i); in check_hb_order_config()