@@ -79,13 +79,13 @@ typedef struct {
79
79
bool isTwoPhase ; /* user level 2PC */
80
80
bool isReplicated ; /* transaction on replica */
81
81
bool isDistributed ; /* transaction performed INSERT/UPDATE/DELETE and has to be replicated to other nodes */
82
- bool isPrepared ; /* transaction is perpared at first stage of 2PC */
82
+ bool isPrepared ; /* transaction is prepared at first stage of 2PC */
83
83
bool isSuspended ; /* prepared transaction is suspended because coordinator node is switch to offline */
84
84
bool isTransactionBlock ; /* is transaction block */
85
85
bool containsDML ; /* transaction contains DML statements */
86
86
bool isActive ; /* transaction is active (nActiveTransaction counter is incremented) */
87
87
XidStatus status ; /* transaction status */
88
- csn_t snapshot ; /* transaction snaphsot */
88
+ csn_t snapshot ; /* transaction snapshot */
89
89
csn_t csn ; /* CSN */
90
90
pgid_t gid ; /* global transaction identifier (used by 2pc) */
91
91
} MtmCurrentTrans ;
@@ -425,7 +425,7 @@ MtmInitializeSequence(int64* start, int64* step)
425
425
/*
426
426
* Get snapshot of transaction proceed by WAL sender pglogical plugin.
427
427
* If it is local transaction or replication node is not in participant mask, then return INVALID_CSN.
428
- * Transaction should be skept by WAL sender in the following cases:
428
+ * Transaction should be skipped by WAL sender in the following cases:
429
429
* 1. Transaction was replicated from some other node and it is not a recovery process.
430
430
* 2. State of transaction is unknown
431
431
* 3. Replication node is not participated in transaction
@@ -439,7 +439,7 @@ csn_t MtmDistributedTransactionSnapshot(TransactionId xid, int nodeId, nodemask_
439
439
MtmTransState * ts = (MtmTransState * )hash_search (MtmXid2State , & xid , HASH_FIND , NULL );
440
440
if (ts != NULL ) {
441
441
* participantsMask = ts -> participantsMask ;
442
- /* If node is disables, then we in process of recovring this node */
442
+ /* If node is disables, then we are in a process of recovery of this node */
443
443
if (!ts -> isLocal && BIT_CHECK (ts -> participantsMask |Mtm -> disabledNodeMask , nodeId - 1 )) {
444
444
snapshot = ts -> snapshot ;
445
445
Assert (ts -> gtid .node == MtmNodeId || MtmIsRecoverySession );
@@ -503,7 +503,7 @@ bool MtmXidInMVCCSnapshot(TransactionId xid, Snapshot snapshot)
503
503
if (ts != NULL /*&& ts->status != TRANSACTION_STATUS_IN_PROGRESS*/ )
504
504
{
505
505
if (ts -> csn > MtmTx .snapshot ) {
506
- MTM_LOG4 ("%d: tuple with xid=%d(csn=%lld) is invisibile in snapshot %lld" ,
506
+ MTM_LOG4 ("%d: tuple with xid=%d(csn=%lld) is invisible in snapshot %lld" ,
507
507
MyProcPid , xid , ts -> csn , MtmTx .snapshot );
508
508
if (MtmGetSystemTime () - start > USECS_PER_SEC ) {
509
509
MTM_ELOG (WARNING , "Backend %d waits for transaction %s (%llu) status %lld usecs" , MyProcPid , ts -> gid , (long64 )xid , MtmGetSystemTime () - start );
@@ -556,7 +556,7 @@ bool MtmXidInMVCCSnapshot(TransactionId xid, Snapshot snapshot)
556
556
}
557
557
else
558
558
{
559
- MTM_LOG4 ("%d: visibility check is skept for transaction %u in snapshot %llu" , MyProcPid , xid , MtmTx .snapshot );
559
+ MTM_LOG4 ("%d: visibility check is skipped for transaction %u in snapshot %llu" , MyProcPid , xid , MtmTx .snapshot );
560
560
MtmUnlock ();
561
561
return PgXidInMVCCSnapshot (xid , snapshot );
562
562
}
@@ -570,7 +570,7 @@ bool MtmXidInMVCCSnapshot(TransactionId xid, Snapshot snapshot)
570
570
571
571
/*
572
572
* There can be different oldest XIDs at different cluster node.
573
- * We collest oldest CSNs from all nodes and choose minimum from them.
573
+ * We collect oldest CSNs from all nodes and choose minimum from them.
574
574
* If no such XID can be located, then return previously observed oldest XID
575
575
*/
576
576
static TransactionId
0 commit comments