File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -529,7 +529,7 @@ static void MtmTransSender(Datum arg)
529
529
530
530
static void MtmWakeUpBackend (MtmTransState * ts )
531
531
{
532
- ts -> done = true;
532
+ ts -> voteCompleted = true;
533
533
SetLatch (& ProcGlobal -> allProcs [ts -> procno ].procLatch );
534
534
}
535
535
Original file line number Diff line number Diff line change @@ -629,7 +629,7 @@ static void MtmPrecommitTransaction(MtmCurrentTrans* x)
629
629
ts -> cmd = MSG_INVALID ;
630
630
ts -> procno = MyProc -> pgprocno ;
631
631
ts -> nVotes = 0 ;
632
- ts -> done = false;
632
+ ts -> voteCompleted = false;
633
633
dtm -> transCount += 1 ;
634
634
635
635
if (TransactionIdIsValid (x -> gtid .xid )) {
@@ -1638,7 +1638,7 @@ MtmVoteForTransaction(MtmTransState* ts)
1638
1638
}
1639
1639
}
1640
1640
MTM_TRACE ("%d: Node %d waiting latch...\n" , MyProcPid , MtmNodeId );
1641
- while (!ts -> done ) {
1641
+ while (!ts -> voteCompleted ) {
1642
1642
MtmUnlock ();
1643
1643
WaitLatch (& MyProc -> procLatch , WL_LATCH_SET , -1 );
1644
1644
ResetLatch (& MyProc -> procLatch );
Original file line number Diff line number Diff line change @@ -85,7 +85,7 @@ typedef struct MtmTransState
85
85
int nSubxids ; /* Number of subtransanctions */
86
86
struct MtmTransState * nextVoting ; /* Next element in L1-list of voting transactions. */
87
87
struct MtmTransState * next ; /* Next element in L1 list of all finished transaction present in xid2state hash */
88
- bool done ;
88
+ bool voteCompleted ; /* Responses necessary to make a decision are received by coordinator of transaction */
89
89
TransactionId xids [1 ]; /* transaction ID at replicas: varying size MtmNodes */
90
90
} MtmTransState ;
91
91
You can’t perform that action at this time.
0 commit comments