Commit ae736acf authored by unknown's avatar unknown

ndb - getTable retry if DICT busy


ndb/src/ndbapi/NdbDictionaryImpl.cpp:
  getTable retry if DICT busy
BitKeeper/etc/logging_ok:
  Logging to logging@openlogging.org accepted
parent 0e29e5e7
...@@ -96,6 +96,7 @@ jcole@tetra.spaceapes.com ...@@ -96,6 +96,7 @@ jcole@tetra.spaceapes.com
jimw@mysql.com jimw@mysql.com
joerg@mysql.com joerg@mysql.com
jon@gigan. jon@gigan.
jonas@mysql.com
joreland@bk-internal.mysql.com joreland@bk-internal.mysql.com
joreland@mysql.com joreland@mysql.com
jorge@linux.jorge.mysql.com jorge@linux.jorge.mysql.com
......
...@@ -941,7 +941,7 @@ NdbDictInterface::dictSignal(NdbApiSignal* signal, ...@@ -941,7 +941,7 @@ NdbDictInterface::dictSignal(NdbApiSignal* signal,
for (int j=0; j < noerrcodes; j++) for (int j=0; j < noerrcodes; j++)
if(m_error.code == errcodes[j]) { if(m_error.code == errcodes[j]) {
doContinue = 1; doContinue = 1;
continue; break;
} }
if (doContinue) if (doContinue)
continue; continue;
...@@ -1007,12 +1007,14 @@ NdbDictInterface::getTable(class NdbApiSignal * signal, ...@@ -1007,12 +1007,14 @@ NdbDictInterface::getTable(class NdbApiSignal * signal,
Uint32 noOfSections, bool fullyQualifiedNames) Uint32 noOfSections, bool fullyQualifiedNames)
{ {
//GetTabInfoReq * const req = CAST_PTR(GetTabInfoReq, signal->getDataPtrSend()); //GetTabInfoReq * const req = CAST_PTR(GetTabInfoReq, signal->getDataPtrSend());
int errCodes[] = {GetTabInfoRef::Busy };
int r = dictSignal(signal,ptr,noOfSections, int r = dictSignal(signal,ptr,noOfSections,
0/*do not use masternode id*/, 0/*do not use masternode id*/,
100, 100,
WAIT_GET_TAB_INFO_REQ, WAIT_GET_TAB_INFO_REQ,
WAITFOR_RESPONSE_TIMEOUT, WAITFOR_RESPONSE_TIMEOUT,
NULL,0); errCodes, 1);
if (r) return 0; if (r) return 0;
NdbTableImpl * rt = 0; NdbTableImpl * rt = 0;
......
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