File tree Expand file tree Collapse file tree 1 file changed +30
-0
lines changed
storage/ndb/src/kernel/blocks/dbtc Expand file tree Collapse file tree 1 file changed +30
-0
lines changed Original file line number Diff line number Diff line change @@ -4830,6 +4830,36 @@ void Dbtc::execSIGNAL_DROPPED_REP(Signal* signal)
4830
4830
signal, ScanTabRef::SignalLength, JBB);
4831
4831
break;
4832
4832
}
4833
+ case GSN_TRANSID_AI: //TUP -> TC
4834
+ {
4835
+ jam();
4836
+ /**
4837
+ * TRANSID_AI is received as a result of performing a read on
4838
+ * the index table as part of a (unique) index operation.
4839
+ */
4840
+ const TransIdAI * const truncatedTransIdAI =
4841
+ reinterpret_cast<const TransIdAI*>(&rep->originalData[0]);
4842
+
4843
+ TcIndexOperationPtr indexOpPtr;
4844
+ indexOpPtr.i = truncatedTransIdAI->connectPtr;
4845
+ TcIndexOperation* indexOp = c_theIndexOperationPool.getPtr(indexOpPtr.i);
4846
+ indexOpPtr.p = indexOp;
4847
+ if (indexOp == NULL) {
4848
+ jam();
4849
+ // Missing index operation - ignore
4850
+ break;
4851
+ }
4852
+
4853
+ /* No more TransIdAI will arrive, abort */
4854
+ apiConnectptr.i = indexOp->connectionIndex;
4855
+ ptrCheckGuard(apiConnectptr, capiConnectFilesize, apiConnectRecord);
4856
+
4857
+ terrorCode = ZGET_DATAREC_ERROR;
4858
+ abortErrorLab(signal);
4859
+ break;
4860
+ }
4861
+ case GSN_TRANSID_AI_R: //TODO
4862
+ jam();
4833
4863
default:
4834
4864
jam();
4835
4865
/* Don't expect dropped signals for other GSNs,
You can’t perform that action at this time.
0 commit comments