diff options
| author | unknown <joreland@mysql.com> | 2005-02-03 11:41:36 +0100 |
|---|---|---|
| committer | unknown <joreland@mysql.com> | 2005-02-03 11:41:36 +0100 |
| commit | ed2632874548a37fc1d3b8c95a9deb8e54f56963 (patch) | |
| tree | f1b45bcefde1fb40ba9d1ce0c1c319e1bf33452a /ndb/src/ndbapi/Ndbif.cpp | |
| parent | 64412075e853fc3b5f8835ec4bc879591afaa20e (diff) | |
| download | mariadb-git-ed2632874548a37fc1d3b8c95a9deb8e54f56963.tar.gz | |
ndb -
Remove extra NdbCond_signal when receiving TRANSID_AI
and not being complete with operation
ndb/src/ndbapi/Ndbif.cpp:
Remove extra NdbCond_signal when receiving TRANSID_AI
and not being complete with operation
Diffstat (limited to 'ndb/src/ndbapi/Ndbif.cpp')
| -rw-r--r-- | ndb/src/ndbapi/Ndbif.cpp | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/ndb/src/ndbapi/Ndbif.cpp b/ndb/src/ndbapi/Ndbif.cpp index 40eb46ea397..40aaa1e3daa 100644 --- a/ndb/src/ndbapi/Ndbif.cpp +++ b/ndb/src/ndbapi/Ndbif.cpp @@ -388,24 +388,24 @@ Ndb::handleReceivedSignal(NdbApiSignal* aSignal, LinearSectionPtr ptr[3]) com = tRec->execTRANSID_AI(tDataPtr + TransIdAI::HeaderLength, tLen - TransIdAI::HeaderLength); } + + if(com == 0) + return; - if(com == 1){ - switch(tRec->getType()){ - case NdbReceiver::NDB_OPERATION: - case NdbReceiver::NDB_INDEX_OPERATION: - if(tCon->OpCompleteSuccess() != -1){ - completedTransaction(tCon); - return; - } - break; - case NdbReceiver::NDB_SCANRECEIVER: - tCon->theScanningOp->receiver_delivered(tRec); - theImpl->theWaiter.m_state = (((WaitSignalType) tWaitState) == WAIT_SCAN ? - (Uint32) NO_WAIT : tWaitState); - break; - default: - goto InvalidSignal; + switch(tRec->getType()){ + case NdbReceiver::NDB_OPERATION: + case NdbReceiver::NDB_INDEX_OPERATION: + if(tCon->OpCompleteSuccess() != -1){ + completedTransaction(tCon); } + return; + case NdbReceiver::NDB_SCANRECEIVER: + tCon->theScanningOp->receiver_delivered(tRec); + theImpl->theWaiter.m_state = (((WaitSignalType) tWaitState) == WAIT_SCAN ? + (Uint32) NO_WAIT : tWaitState); + break; + default: + goto InvalidSignal; } break; } else { |