@@ -79,13 +79,13 @@ typedef struct {
7979bool isTwoPhase ;/* user level 2PC */
8080bool isReplicated ;/* transaction on replica */
8181bool isDistributed ;/* transaction performed INSERT/UPDATE/DELETE and has to be replicated to other nodes */
82- bool isPrepared ;/* transaction isperpared at first stage of 2PC */
82+ bool isPrepared ;/* transaction isprepared at first stage of 2PC */
8383bool isSuspended ;/* prepared transaction is suspended because coordinator node is switch to offline */
8484bool isTransactionBlock ;/* is transaction block */
8585bool containsDML ;/* transaction contains DML statements */
8686bool isActive ;/* transaction is active (nActiveTransaction counter is incremented) */
8787XidStatus status ;/* transaction status */
88- csn_t snapshot ;/* transactionsnaphsot */
88+ csn_t snapshot ;/* transactionsnapshot */
8989csn_t csn ;/* CSN */
9090pgid_t gid ;/* global transaction identifier (used by 2pc) */
9191}MtmCurrentTrans ;
@@ -425,7 +425,7 @@ MtmInitializeSequence(int64* start, int64* step)
425425/*
426426 * Get snapshot of transaction proceed by WAL sender pglogical plugin.
427427 * If it is local transaction or replication node is not in participant mask, then return INVALID_CSN.
428- * Transaction should beskept by WAL sender in the following cases:
428+ * Transaction should beskipped by WAL sender in the following cases:
429429 * 1. Transaction was replicated from some other node and it is not a recovery process.
430430 * 2. State of transaction is unknown
431431 * 3. Replication node is not participated in transaction
@@ -439,7 +439,7 @@ csn_t MtmDistributedTransactionSnapshot(TransactionId xid, int nodeId, nodemask_
439439MtmTransState * ts = (MtmTransState * )hash_search (MtmXid2State ,& xid ,HASH_FIND ,NULL );
440440if (ts != NULL ) {
441441* participantsMask = ts -> participantsMask ;
442- /* If node is disables, then we in process ofrecovring this node */
442+ /* If node is disables, then weare ina process ofrecovery of this node */
443443if (!ts -> isLocal && BIT_CHECK (ts -> participantsMask |Mtm -> disabledNodeMask ,nodeId - 1 )) {
444444snapshot = ts -> snapshot ;
445445Assert (ts -> gtid .node == MtmNodeId || MtmIsRecoverySession );
@@ -503,7 +503,7 @@ bool MtmXidInMVCCSnapshot(TransactionId xid, Snapshot snapshot)
503503if (ts != NULL /*&& ts->status != TRANSACTION_STATUS_IN_PROGRESS*/ )
504504 {
505505if (ts -> csn > MtmTx .snapshot ) {
506- MTM_LOG4 ("%d: tuple with xid=%d(csn=%lld) isinvisibile in snapshot %lld" ,
506+ MTM_LOG4 ("%d: tuple with xid=%d(csn=%lld) isinvisible in snapshot %lld" ,
507507MyProcPid ,xid ,ts -> csn ,MtmTx .snapshot );
508508if (MtmGetSystemTime ()- start > USECS_PER_SEC ) {
509509MTM_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)
556556 }
557557else
558558 {
559- MTM_LOG4 ("%d: visibility check isskept for transaction %u in snapshot %llu" ,MyProcPid ,xid ,MtmTx .snapshot );
559+ MTM_LOG4 ("%d: visibility check isskipped for transaction %u in snapshot %llu" ,MyProcPid ,xid ,MtmTx .snapshot );
560560MtmUnlock ();
561561return PgXidInMVCCSnapshot (xid ,snapshot );
562562 }
@@ -570,7 +570,7 @@ bool MtmXidInMVCCSnapshot(TransactionId xid, Snapshot snapshot)
570570
571571/*
572572 * There can be different oldest XIDs at different cluster node.
573- * Wecollest oldest CSNs from all nodes and choose minimum from them.
573+ * Wecollect oldest CSNs from all nodes and choose minimum from them.
574574 * If no such XID can be located, then return previously observed oldest XID
575575 */
576576static TransactionId