Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit 7bdaa1f

Browse files
committed
rework DDL handling at receiver side
1 parent 40c5d18 commit 7bdaa1f

File tree

4 files changed

+349
-241
lines changed

4 files changed

+349
-241
lines changed

src/commit.c

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -150,9 +150,13 @@ MtmTwoPhaseCommit(MtmCurrentTrans* x)
150150

151151
x->xid = xid;
152152

153+
MtmLock(LW_SHARED);
153154
participantsMask = (((nodemask_t)1 << Mtm->nAllNodes) - 1) &
154155
~Mtm->disabledNodeMask &
155156
~((nodemask_t)1 << (MtmNodeId-1));
157+
if (Mtm->status != MTM_ONLINE)
158+
mtm_log(ERROR, "This node became offline during current transaction");
159+
MtmUnlock();
156160

157161
ret = PrepareTransactionBlock(gid);
158162
if (!ret)

0 commit comments

Comments
 (0)