minor changes
This commit is contained in:
parent
be06f24c46
commit
a927ca8bc4
|
@ -660,8 +660,9 @@ static int32_t mndTransExecuteActions(SMnode *pMnode, STrans *pTrans, SArray *pA
|
||||||
for (int32_t action = 0; action < numOfActions; ++action) {
|
for (int32_t action = 0; action < numOfActions; ++action) {
|
||||||
STransAction *pAction = taosArrayGet(pArray, action);
|
STransAction *pAction = taosArrayGet(pArray, action);
|
||||||
if (pAction == NULL) continue;
|
if (pAction == NULL) continue;
|
||||||
if (pAction->msgSent && !pAction->msgReceived) continue;
|
// if (pAction->msgSent && !pAction->msgReceived) continue;
|
||||||
if (pAction->msgSent && pAction->msgReceived && pAction->errCode == 0) continue;
|
// if (pAction->msgSent && pAction->msgReceived && pAction->errCode == 0) continue;
|
||||||
|
if (pAction->msgSent) continue;
|
||||||
|
|
||||||
int64_t signature = pTrans->id;
|
int64_t signature = pTrans->id;
|
||||||
signature = (signature << 32);
|
signature = (signature << 32);
|
||||||
|
|
Loading…
Reference in New Issue