Merge joreland@bk-internal.mysql.com:/home/bk/mysql-5.1-jonas
into perch.ndb.mysql.com:/home/jonas/src/51-jonas
This commit is contained in:
commit
246d76f154
@ -478,10 +478,14 @@ int NdbScanOperation::nextResultImpl(bool fetchAllowed, bool forceSend)
|
|||||||
*/
|
*/
|
||||||
PollGuard poll_guard(tp, &theNdb->theImpl->theWaiter,
|
PollGuard poll_guard(tp, &theNdb->theImpl->theWaiter,
|
||||||
theNdb->theNdbBlockNumber);
|
theNdb->theNdbBlockNumber);
|
||||||
if(theError.code)
|
|
||||||
return -1;
|
|
||||||
|
|
||||||
Uint32 seq = theNdbCon->theNodeSequence;
|
const Uint32 seq = theNdbCon->theNodeSequence;
|
||||||
|
|
||||||
|
if(theError.code)
|
||||||
|
{
|
||||||
|
goto err4;
|
||||||
|
}
|
||||||
|
|
||||||
if(seq == tp->getNodeSequence(nodeId) && send_next_scan(idx, false) == 0)
|
if(seq == tp->getNodeSequence(nodeId) && send_next_scan(idx, false) == 0)
|
||||||
{
|
{
|
||||||
|
|
||||||
@ -564,6 +568,10 @@ int NdbScanOperation::nextResultImpl(bool fetchAllowed, bool forceSend)
|
|||||||
if(theError.code == 0)
|
if(theError.code == 0)
|
||||||
setErrorCode(4028); // seq changed = Node fail
|
setErrorCode(4028); // seq changed = Node fail
|
||||||
break;
|
break;
|
||||||
|
case -4:
|
||||||
|
err4:
|
||||||
|
setErrorCode(theError.code);
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
theNdbCon->theTransactionIsStarted = false;
|
theNdbCon->theTransactionIsStarted = false;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user