Commit 27ca2d66 authored by unknown's avatar unknown

Handle temporary errors in clearTable

parent 9acbb9c0
...@@ -383,11 +383,20 @@ UtilTransactions::clearTable3(Ndb* pNdb, ...@@ -383,11 +383,20 @@ UtilTransactions::clearTable3(Ndb* pNdb,
pOp = pTrans->getNdbScanOperation(tab.getName()); pOp = pTrans->getNdbScanOperation(tab.getName());
if (pOp == NULL) { if (pOp == NULL) {
err = pTrans->getNdbError();
if(err.status == NdbError::TemporaryError){
ERR(err);
pNdb->closeTransaction(pTrans);
NdbSleep_MilliSleep(50);
par = 1;
goto restart;
}
goto failed; goto failed;
} }
NdbResultSet * rs = pOp->readTuplesExclusive(par); NdbResultSet * rs = pOp->readTuplesExclusive(par);
if( rs == 0 ) { if( rs == 0 ) {
err = pTrans->getNdbError();
goto failed; goto failed;
} }
...@@ -647,8 +656,16 @@ UtilTransactions::scanReadRecords(Ndb* pNdb, ...@@ -647,8 +656,16 @@ UtilTransactions::scanReadRecords(Ndb* pNdb,
pOp = pTrans->getNdbScanOperation(tab.getName()); pOp = pTrans->getNdbScanOperation(tab.getName());
if (pOp == NULL) { if (pOp == NULL) {
ERR(pTrans->getNdbError()); const NdbError err = pNdb->getNdbError();
pNdb->closeTransaction(pTrans); pNdb->closeTransaction(pTrans);
if (err.status == NdbError::TemporaryError){
ERR(err);
NdbSleep_MilliSleep(50);
retryAttempt++;
continue;
}
ERR(err);
return NDBT_FAILED; return NDBT_FAILED;
} }
......
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