Loading ndb/src/common/transporter/TransporterRegistry.cpp +1 −0 Original line number Diff line number Diff line Loading @@ -959,6 +959,7 @@ TransporterRegistry::performReceive() { Uint32 * ptr; Uint32 sz = t->getReceiveData(&ptr); transporter_recv_from(callbackObj, nodeId); Uint32 szUsed = unpack(ptr, sz, nodeId, ioStates[nodeId]); t->updateReceiveDataPtr(szUsed); } Loading ndb/test/ndbapi/testNdbApi.cpp +4 −0 Original line number Diff line number Diff line Loading @@ -1422,6 +1422,10 @@ TESTCASE("Scan_4006", INITIALIZER(runScan_4006); FINALIZER(runClearTable); } TESTCASE("Bug28443", ""){ INITIALIZER(runBug28443); } TESTCASE("ExecuteAsynch", "Check that executeAsync() works (BUG#27495)\n"){ INITIALIZER(runTestExecuteAsynch); Loading Loading
ndb/src/common/transporter/TransporterRegistry.cpp +1 −0 Original line number Diff line number Diff line Loading @@ -959,6 +959,7 @@ TransporterRegistry::performReceive() { Uint32 * ptr; Uint32 sz = t->getReceiveData(&ptr); transporter_recv_from(callbackObj, nodeId); Uint32 szUsed = unpack(ptr, sz, nodeId, ioStates[nodeId]); t->updateReceiveDataPtr(szUsed); } Loading
ndb/test/ndbapi/testNdbApi.cpp +4 −0 Original line number Diff line number Diff line Loading @@ -1422,6 +1422,10 @@ TESTCASE("Scan_4006", INITIALIZER(runScan_4006); FINALIZER(runClearTable); } TESTCASE("Bug28443", ""){ INITIALIZER(runBug28443); } TESTCASE("ExecuteAsynch", "Check that executeAsync() works (BUG#27495)\n"){ INITIALIZER(runTestExecuteAsynch); Loading