Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit7667d0f

Browse files
afiskonkelvich
authored andcommitted
Typos fixed
1 parent4710350 commit7667d0f

File tree

1 file changed

+15
-15
lines changed

1 file changed

+15
-15
lines changed

‎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 notavaiable to to critical, non-recoverable error */
141+
MTM_OUT_OF_SERVICE/* Node is notavailable to to critical, non-recoverable error */
142142
}MtmNodeStatus;
143143

144144
typedefenum
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,/* performrecorvery of the node by applying all data from the slot from specified point */
148+
REPLMODE_RECOVERY,/* performrecovery 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 therememered position */
150+
REPLMODE_OPEN_EXISTED/* normal mode: use existed slot or create new one and start receiving data from it from theremembered position */
151151
}MtmReplicationMode;
152152

153153
typedefstruct
@@ -161,7 +161,7 @@ typedef struct
161161
csn_tcsn;/* Local CSN in case of sending data from replica to master, global CSN master->replica */
162162
csn_toldestSnapshot;/* Oldest snapshot used by active transactions at this node */
163163
nodemask_tdisabledNodeMask;/* Bitmask of disabled nodes at the sender of message */
164-
nodemask_tconnectivityMask;/* Connectivitybittmask at the sender of message */
164+
nodemask_tconnectivityMask;/* Connectivitybitmask at the sender of message */
165165
pgid_tgid;/* Global transaction identifier */
166166
}MtmArbiterMessage;
167167

@@ -249,12 +249,12 @@ typedef struct MtmTransState
249249
structMtmTransState*next;/* Next element in L1 list of all finished transaction present in xid2state hash */
250250
MtmL2ListactiveList;/* L2-list of active transactions */
251251
boolvotingCompleted;/* 2PC voting is completed */
252-
boolisLocal;/* Transaction is either replicated, either doesn't contain DML statements, so itshoudl be ignored by pglogical replication */
252+
boolisLocal;/* Transaction is either replicated, either doesn't contain DML statements, so itshould be ignored by pglogical replication */
253253
boolisEnqueued;/* Transaction is inserted in queue */
254254
boolisPrepared;/* Transaction is prepared: now it is safe to commit transaction */
255255
boolisActive;/* Transaction is active */
256256
boolisTwoPhase;/* User level 2PC */
257-
boolisPinned;/* Transaction oidpotected from GC */
257+
boolisPinned;/* Transaction oidprotected from GC */
258258
intnConfigChanges;/* Number of cluster configuration changes at moment of transaction start */
259259
nodemask_tparticipantsMask;/* Mask of nodes involved in transaction */
260260
nodemask_tvotedMask;/* Mask of voted nodes */
@@ -277,38 +277,38 @@ typedef struct
277277
LWLockPadded*locks;/* multimaster lock tranche */
278278
TransactionIdoldestXid;/* XID of oldest transaction visible by any active transaction (local or global) */
279279
nodemask_tdisabledNodeMask;/* bitmask of disabled nodes */
280-
nodemask_tstalledNodeMask;/* bitmask of stalled nodes (node with droppedrelication slot which makes it not possible automatic recovery of such node) */
280+
nodemask_tstalledNodeMask;/* bitmask of stalled nodes (node with droppedreplication slot which makes it not possible automatic recovery of such node) */
281281
nodemask_tstoppedNodeMask;/* Bitmask of stopped (permanently disabled nodes) */
282282
nodemask_tpglogicalReceiverMask;/* bitmask of started pglogic receivers */
283283
nodemask_tpglogicalSenderMask;/* bitmask of started pglogic senders */
284284
nodemask_twalSenderLockerMask;/* Mask of WAL-senders IDs locking the cluster */
285285
nodemask_tglobalLockerMask;/* Global cluster mask of locked nodes to perform caught-up (updated using heartbeats) */
286286
nodemask_tnodeLockerMask;/* Mask of node IDs which WAL-senders are locking the cluster */
287287
nodemask_treconnectMask;/* Mask of nodes connection to which has to be reestablished by sender */
288-
intlastLockHolder;/* PID of process lastobtaning the node lock */
288+
intlastLockHolder;/* PID of process lastobtaining the node lock */
289289
boollocalTablesHashLoaded;/* Whether data from local_tables table is loaded in shared memory hash table */
290290
boolpreparedTransactionsLoaded;/* GIDs of prepared transactions are loaded at startup */
291291
intinject2PCError;/* Simulate error during 2PC commit at this node */
292292
intnLiveNodes;/* Number of active nodes */
293-
intnAllNodes;/* Totalnumbber of nodes */
294-
intnReceivers;/* Number of initialized logical receivers (used to determine moment whenintialization/recovery is completed) */
293+
intnAllNodes;/* Totalnumber of nodes */
294+
intnReceivers;/* Number of initialized logical receivers (used to determine moment wheninitialization/recovery is completed) */
295295
intnSenders;/* Number of started WAL senders (used to determine moment when recovery) */
296296
intnLockers;/* Number of lockers */
297-
intnActiveTransactions;/*Nunmber of active 2PC transactions */
297+
intnActiveTransactions;/*Number of active 2PC transactions */
298298
intnConfigChanges;/* Number of cluster configuration changes */
299299
intrecoveryCount;/* Number of completed recoveries */
300300
intdonorNodeId;/* Cluster node from which this node was populated */
301301
int64timeShift;/* Local time correction */
302-
csn_tcsn;/* Last obtained timestamp: used to provide uniqueacending CSNs based on system time */
302+
csn_tcsn;/* Last obtained timestamp: used to provide uniqueascending CSNs based on system time */
303303
csn_tlastCsn;/* CSN of last committed transaction */
304-
MtmTransState*votingTransactions;/* L1-list of replicated transactionssendingsnotifications 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 finishedtransactionds, used to append new elements.
308+
MtmTransState**transListTail;/* Tail of L1 list of all finishedtransactions, used to append new elements.
309309
This list is expected to be in CSN ascending order, by strict order may be violated */
310310
MtmL2ListactiveTransList;/* List of active transactions */
311-
ulong64transCount;/* Counter of transactionsperfromed by this node */
311+
ulong64transCount;/* Counter of transactionsperformed by this node */
312312
ulong64gcCount;/* 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)
[8]ページ先頭
©2009-2025 Movatter.jp