Skip to content

Commit 4fc008b

Browse files
committed
assign csn for local transactions. Fix by kk
1 parent 5c3740e commit 4fc008b

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

contrib/mmts/multimaster.c

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1529,6 +1529,10 @@ MtmEndTransaction(MtmCurrentTrans* x, bool commit)
15291529
ts->csn = x->csn;
15301530
MtmSyncClock(ts->csn);
15311531
}
1532+
if (ts->isLocal)
1533+
{
1534+
ts->csn = MtmAssignCSN();
1535+
}
15321536
Mtm->lastCsn = ts->csn;
15331537
ts->status = TRANSACTION_STATUS_COMMITTED;
15341538
MtmAdjustSubtransactions(ts);

0 commit comments

Comments
 (0)