Loading ndb/src/ndbapi/NdbScanOperation.cpp +7 −1 Original line number Diff line number Diff line Loading @@ -505,6 +505,8 @@ int NdbScanOperation::nextResultImpl(bool fetchAllowed, bool forceSend) int return_code = theNdb->receiveResponse(WAITFOR_SCAN_TIMEOUT); if (return_code == 0 && seq == tp->getNodeSequence(nodeId)) { continue; } else if(return_code == -1){ retVal = -1; } else { idx = last; retVal = -2; //return_code; Loading Loading @@ -1377,7 +1379,11 @@ NdbIndexScanOperation::next_result_ordered(bool fetchAllowed, continue; } if(DEBUG_NEXT_RESULT) ndbout_c("return -1"); if(return_code == -1){ setErrorCode(4008); } else { setErrorCode(4028); } return -1; } Loading Loading
ndb/src/ndbapi/NdbScanOperation.cpp +7 −1 Original line number Diff line number Diff line Loading @@ -505,6 +505,8 @@ int NdbScanOperation::nextResultImpl(bool fetchAllowed, bool forceSend) int return_code = theNdb->receiveResponse(WAITFOR_SCAN_TIMEOUT); if (return_code == 0 && seq == tp->getNodeSequence(nodeId)) { continue; } else if(return_code == -1){ retVal = -1; } else { idx = last; retVal = -2; //return_code; Loading Loading @@ -1377,7 +1379,11 @@ NdbIndexScanOperation::next_result_ordered(bool fetchAllowed, continue; } if(DEBUG_NEXT_RESULT) ndbout_c("return -1"); if(return_code == -1){ setErrorCode(4008); } else { setErrorCode(4028); } return -1; } Loading