Skip to content

Commit 5530d33

Browse files
afiskonafiskon
committed
Typos fixed
1 parent 3a5fce2 commit 5530d33

File tree

1 file changed

+15
-15
lines changed

1 file changed

+15
-15
lines changed

‎contrib/mmts/multimaster.h

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -138,16 +138,16 @@ typedef enum
138138
MTM_RECOVERY, /* Node is in recovery process */
139139
MTM_RECOVERED, /* Node is recovered by is not yet switched to ONLINE because not all sender/receivers are restarted */
140140
MTM_IN_MINORITY, /* Node is out of quorum */
141-
MTM_OUT_OF_SERVICE /* Node is not avaiable to to critical, non-recoverable error */
141+
MTM_OUT_OF_SERVICE /* Node is not available to to critical, non-recoverable error */
142142
} MtmNodeStatus;
143143

144144
typedef enum
145145
{
146146
REPLMODE_EXIT, /* receiver should exit */
147147
REPLMODE_RECOVERED, /* recovery of receiver node is completed so drop old slot and restart replication from the current position in WAL */
148-
REPLMODE_RECOVERY, /* perform recorvery of the node by applying all data from the slot from specified point */
148+
REPLMODE_RECOVERY, /* perform recovery of the node by applying all data from the slot from specified point */
149149
REPLMODE_CREATE_NEW, /* destination node is recovered: drop old slot and restart from roveredLsn position */
150-
REPLMODE_OPEN_EXISTED /* normal mode: use existed slot or create new one and start receiving data from it from the rememered position */
150+
REPLMODE_OPEN_EXISTED /* normal mode: use existed slot or create new one and start receiving data from it from the remembered position */
151151
} MtmReplicationMode;
152152

153153
typedef struct
@@ -161,7 +161,7 @@ typedef struct
161161
csn_t csn; /* Local CSN in case of sending data from replica to master, global CSN master->replica */
162162
csn_t oldestSnapshot; /* Oldest snapshot used by active transactions at this node */
163163
nodemask_t disabledNodeMask; /* Bitmask of disabled nodes at the sender of message */
164-
nodemask_t connectivityMask; /* Connectivity bittmask at the sender of message */
164+
nodemask_t connectivityMask; /* Connectivity bitmask at the sender of message */
165165
pgid_t gid; /* Global transaction identifier */
166166
} MtmArbiterMessage;
167167

@@ -249,12 +249,12 @@ typedef struct MtmTransState
249249
struct MtmTransState* next; /* Next element in L1 list of all finished transaction present in xid2state hash */
250250
MtmL2List activeList; /* L2-list of active transactions */
251251
bool votingCompleted; /* 2PC voting is completed */
252-
bool isLocal; /* Transaction is either replicated, either doesn't contain DML statements, so it shoudl be ignored by pglogical replication */
252+
bool isLocal; /* Transaction is either replicated, either doesn't contain DML statements, so it should be ignored by pglogical replication */
253253
bool isEnqueued; /* Transaction is inserted in queue */
254254
bool isPrepared; /* Transaction is prepared: now it is safe to commit transaction */
255255
bool isActive; /* Transaction is active */
256256
bool isTwoPhase; /* User level 2PC */
257-
bool isPinned; /* Transaction oid potected from GC */
257+
bool isPinned; /* Transaction oid protected from GC */
258258
int nConfigChanges; /* Number of cluster configuration changes at moment of transaction start */
259259
nodemask_t participantsMask; /* Mask of nodes involved in transaction */
260260
nodemask_t votedMask; /* Mask of voted nodes */
@@ -277,38 +277,38 @@ typedef struct
277277
LWLockPadded *locks; /* multimaster lock tranche */
278278
TransactionId oldestXid; /* XID of oldest transaction visible by any active transaction (local or global) */
279279
nodemask_t disabledNodeMask; /* bitmask of disabled nodes */
280-
nodemask_t stalledNodeMask; /* bitmask of stalled nodes (node with dropped relication slot which makes it not possible automatic recovery of such node) */
280+
nodemask_t stalledNodeMask; /* bitmask of stalled nodes (node with dropped replication slot which makes it not possible automatic recovery of such node) */
281281
nodemask_t stoppedNodeMask; /* Bitmask of stopped (permanently disabled nodes) */
282282
nodemask_t pglogicalReceiverMask; /* bitmask of started pglogic receivers */
283283
nodemask_t pglogicalSenderMask; /* bitmask of started pglogic senders */
284284
nodemask_t walSenderLockerMask; /* Mask of WAL-senders IDs locking the cluster */
285285
nodemask_t globalLockerMask; /* Global cluster mask of locked nodes to perform caught-up (updated using heartbeats) */
286286
nodemask_t nodeLockerMask; /* Mask of node IDs which WAL-senders are locking the cluster */
287287
nodemask_t reconnectMask; /* Mask of nodes connection to which has to be reestablished by sender */
288-
int lastLockHolder; /* PID of process last obtaning the node lock */
288+
int lastLockHolder; /* PID of process last obtaining the node lock */
289289
bool localTablesHashLoaded; /* Whether data from local_tables table is loaded in shared memory hash table */
290290
bool preparedTransactionsLoaded; /* GIDs of prepared transactions are loaded at startup */
291291
int inject2PCError; /* Simulate error during 2PC commit at this node */
292292
int nLiveNodes; /* Number of active nodes */
293-
int nAllNodes; /* Total numbber of nodes */
294-
int nReceivers; /* Number of initialized logical receivers (used to determine moment when intialization/recovery is completed) */
293+
int nAllNodes; /* Total number of nodes */
294+
int nReceivers; /* Number of initialized logical receivers (used to determine moment when initialization/recovery is completed) */
295295
int nSenders; /* Number of started WAL senders (used to determine moment when recovery) */
296296
int nLockers; /* Number of lockers */
297-
int nActiveTransactions; /* Nunmber of active 2PC transactions */
297+
int nActiveTransactions; /* Number of active 2PC transactions */
298298
int nConfigChanges; /* Number of cluster configuration changes */
299299
int recoveryCount; /* Number of completed recoveries */
300300
int donorNodeId; /* Cluster node from which this node was populated */
301301
int64 timeShift; /* Local time correction */
302-
csn_t csn; /* Last obtained timestamp: used to provide unique acending CSNs based on system time */
302+
csn_t csn; /* Last obtained timestamp: used to provide unique ascending CSNs based on system time */
303303
csn_t lastCsn; /* CSN of last committed transaction */
304-
MtmTransState* votingTransactions; /* L1-list of replicated transactions sendings notifications to coordinator.
304+
MtmTransState* votingTransactions; /* L1-list of replicated transactions notifications to coordinator.
305305
This list is used to pass information to mtm-sender BGW */
306306
MtmTransState* transListHead; /* L1 list of all finished transactions present in xid2state hash.
307307
It is cleanup by MtmGetOldestXmin */
308-
MtmTransState** transListTail; /* Tail of L1 list of all finished transactionds, used to append new elements.
308+
MtmTransState** transListTail; /* Tail of L1 list of all finished transactions, used to append new elements.
309309
This list is expected to be in CSN ascending order, by strict order may be violated */
310310
MtmL2List activeTransList; /* List of active transactions */
311-
ulong64 transCount; /* Counter of transactions perfromed by this node */
311+
ulong64 transCount; /* Counter of transactions performed by this node */
312312
ulong64 gcCount; /* Number of global transactions performed since last GC */
313313
MtmMessageQueue* sendQueue; /* Messages to be sent by arbiter sender */
314314
MtmMessageQueue* freeQueue; /* Free messages */

0 commit comments

Comments
 (0)