Commit 51722e02 authored by joreland@mysql.com's avatar joreland@mysql.com

wl2025 - bug fix for filter fail (tupkeyref)

parent eff1123f
......@@ -12562,7 +12562,7 @@ void Dbacc::releaseLcpConnectRec(Signal* signal)
/* --------------------------------------------------------------------------------- */
void Dbacc::releaseOpRec(Signal* signal)
{
#ifdef NDB_DEBUG_FULL
#if 0
// DEBUG CODE
// Check that the operation to be released isn't
// already in the list of free operations
......
......@@ -8174,13 +8174,14 @@ void Dblqh::continueScanAfterBlockedLab(Signal* signal)
jam();
scanptr.p->scanFlag = NextScanReq::ZSCAN_NEXT_COMMIT;
accOpPtr= get_acc_ptr_from_scan_record(scanptr.p,
scanptr.p->m_curr_batch_size_rows,
false);
scanptr.p->m_curr_batch_size_rows,
false);
scanptr.p->scan_acc_index--;
} else if (scanptr.p->scanFlag == NextScanReq::ZSCAN_NEXT_COMMIT) {
jam();
accOpPtr= get_acc_ptr_from_scan_record(scanptr.p,
scanptr.p->m_curr_batch_size_rows - 1,
false);
scanptr.p->m_curr_batch_size_rows-1,
false);
} else {
jam();
accOpPtr = RNIL; // The value is not used in ACC
......@@ -8190,9 +8191,9 @@ void Dblqh::continueScanAfterBlockedLab(Signal* signal)
signal->theData[1] = accOpPtr;
signal->theData[2] = scanptr.p->scanFlag;
if (! scanptr.p->rangeScan)
sendSignal(tcConnectptr.p->tcAccBlockref, GSN_NEXT_SCANREQ, signal, 3, JBB);
sendSignal(tcConnectptr.p->tcAccBlockref, GSN_NEXT_SCANREQ, signal, 3,JBB);
else
sendSignal(tcConnectptr.p->tcTuxBlockref, GSN_NEXT_SCANREQ, signal, 3, JBB);
sendSignal(tcConnectptr.p->tcTuxBlockref, GSN_NEXT_SCANREQ, signal, 3,JBB);
}//Dblqh::continueScanAfterBlockedLab()
/* -------------------------------------------------------------------------
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment