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

Commite495c16

Browse files
committed
Spelling fixes in code comments
Author: Euler Taveira <euler@timbira.com.br>
1 parent1f8b060 commite495c16

File tree

6 files changed

+19
-19
lines changed

6 files changed

+19
-19
lines changed

‎src/backend/catalog/pg_publication.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -321,7 +321,7 @@ GetAllTablesPublicationRelations(void)
321321
/*
322322
* Get publication using oid
323323
*
324-
* The Publication struct andit's data arepalloced here.
324+
* The Publication struct andits data arepalloc'ed here.
325325
*/
326326
Publication*
327327
GetPublication(Oidpubid)

‎src/backend/catalog/pg_subscription.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -403,7 +403,7 @@ RemoveSubscriptionRel(Oid subid, Oid relid)
403403
/*
404404
* Get all relations for subscription.
405405
*
406-
* Returned list ispalloced in current memory context.
406+
* Returned list ispalloc'ed in current memory context.
407407
*/
408408
List*
409409
GetSubscriptionRelations(Oidsubid)
@@ -450,7 +450,7 @@ GetSubscriptionRelations(Oid subid)
450450
/*
451451
* Get all relations for subscription that are not in a ready state.
452452
*
453-
* Returned list ispalloced in current memory context.
453+
* Returned list ispalloc'ed in current memory context.
454454
*/
455455
List*
456456
GetSubscriptionNotReadyRelations(Oidsubid)

‎src/backend/replication/logical/message.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
* Non-transactional messages are sent to the plugin at the time when the
2121
* logical decoding reads them from XLOG. This also means that transactional
2222
* messages won't be delivered if the transaction was rolled back but the
23-
* non-transactional one will be delivered always.
23+
* non-transactional one willalwaysbe delivered.
2424
*
2525
* Every message carries prefix to avoid conflicts between different decoding
2626
* plugins. The plugin authors must take extra care to use unique prefix,

‎src/backend/replication/logical/origin.c

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
* two bytes allow us to be more space efficient.
2525
*
2626
* Replication progress is tracked in a shared memory table
27-
* (ReplicationStates) that's dumped to disk every checkpoint. Entries
27+
* (ReplicationState) that's dumped to disk every checkpoint. Entries
2828
* ('slots') in this table are identified by the internal id. That's the case
2929
* because it allows to increase replication progress during crash
3030
* recovery. To allow doing so we store the original LSN (from the originating
@@ -48,7 +48,7 @@
4848
* pg_replication_slot is required for the duration. That allows us to
4949
* safely and conflict free assign new origins using a dirty snapshot.
5050
*
51-
* * When creating an in-memory replication progress slot theReplicationOirgin
51+
* * When creating an in-memory replication progress slot theReplicationOrigin
5252
* LWLock has to be held exclusively; when iterating over the replication
5353
* progress a shared lock has to be held, the same when advancing the
5454
* replication progress of an individual backend that has not setup as the
@@ -162,8 +162,8 @@ static ReplicationState *replication_states;
162162
staticReplicationStateCtl*replication_states_ctl;
163163

164164
/*
165-
* Backend-local, cached element fromReplicationStates for use in a backend
166-
* replaying remote commits, so we don't have to searchReplicationStates for
165+
* Backend-local, cached element fromReplicationState for use in a backend
166+
* replaying remote commits, so we don't have to searchReplicationState for
167167
* the backends current RepOriginId.
168168
*/
169169
staticReplicationState*session_replication_state=NULL;
@@ -441,7 +441,7 @@ ReplicationOriginShmemSize(void)
441441
/*
442442
* XXX: max_replication_slots is arguably the wrong thing to use, as here
443443
* we keep the replay state of *remote* transactions. But for now it seems
444-
* sufficient to reuse it, lest we introduce a separateguc.
444+
* sufficient to reuse it, lest we introduce a separateGUC.
445445
*/
446446
if (max_replication_slots==0)
447447
returnsize;
@@ -497,7 +497,7 @@ ReplicationOriginShmemInit(void)
497497
*
498498
* So its just the magic, followed by the statically sized
499499
* ReplicationStateOnDisk structs. Note that the maximum number of
500-
*ReplicationStates is determined by max_replication_slots.
500+
*ReplicationState is determined by max_replication_slots.
501501
* ---------------------------------------------------------------------------
502502
*/
503503
void
@@ -1253,7 +1253,7 @@ pg_replication_origin_session_is_setup(PG_FUNCTION_ARGS)
12531253
* Return the replication progress for origin setup in the current session.
12541254
*
12551255
* If 'flush' is set to true it is ensured that the returned value corresponds
1256-
* to a local transaction that has been flushed.this is useful if asynchronous
1256+
* to a local transaction that has been flushed.This is useful if asynchronous
12571257
* commits are used when replaying replicated transactions.
12581258
*/
12591259
Datum
@@ -1327,7 +1327,7 @@ pg_replication_origin_advance(PG_FUNCTION_ARGS)
13271327
* set up the initial replication state, but not for replay.
13281328
*/
13291329
replorigin_advance(node,remote_commit,InvalidXLogRecPtr,
1330-
true/* go backward */ , true/*wal log */ );
1330+
true/* go backward */ , true/*WAL log */ );
13311331

13321332
UnlockRelationOid(ReplicationOriginRelationId,RowExclusiveLock);
13331333

@@ -1339,7 +1339,7 @@ pg_replication_origin_advance(PG_FUNCTION_ARGS)
13391339
* Return the replication progress for an individual replication origin.
13401340
*
13411341
* If 'flush' is set to true it is ensured that the returned value corresponds
1342-
* to a local transaction that has been flushed.this is useful if asynchronous
1342+
* to a local transaction that has been flushed.This is useful if asynchronous
13431343
* commits are used when replaying replicated transactions.
13441344
*/
13451345
Datum

‎src/backend/replication/logical/proto.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -377,7 +377,7 @@ logicalrep_read_typ(StringInfo in, LogicalRepTyp *ltyp)
377377
{
378378
ltyp->remoteid=pq_getmsgint(in,4);
379379

380-
/* Readtupe name from stream */
380+
/* Readtype name from stream */
381381
ltyp->nspname=pstrdup(logicalrep_read_namespace(in));
382382
ltyp->typname=pstrdup(pq_getmsgstring(in));
383383
}
@@ -459,7 +459,7 @@ logicalrep_read_tuple(StringInfo in, LogicalRepTupleData *tuple)
459459
inti;
460460
intnatts;
461461

462-
/* Get of attributes. */
462+
/* Getnumberof attributes */
463463
natts=pq_getmsgint(in,2);
464464

465465
memset(tuple->changed,0,sizeof(tuple->changed));

‎src/backend/replication/logical/tablesync.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,12 +33,12 @@
3333
* When the desired state appears it will compare its position in the
3434
* stream with the SYNCWAIT position and based on that changes the
3535
* state to based on following rules:
36-
* - if the apply is in front of the sync in thewal stream the new
36+
* - if the apply is in front of the sync in theWAL stream the new
3737
*state is set to CATCHUP and apply loops until the sync process
3838
*catches up to the same LSN as apply
39-
* - if the sync is in front of the apply in thewal stream the new
39+
* - if the sync is in front of the apply in theWAL stream the new
4040
*state is set to SYNCDONE
41-
* - if both apply and sync are at the same position in thewal stream
41+
* - if both apply and sync are at the same position in theWAL stream
4242
*the state of the table is set to READY
4343
* - If the state was set to CATCHUP sync will read the stream and
4444
* apply changes until it catches up to the specified stream
@@ -698,7 +698,7 @@ copy_table(Relation rel)
698698
/*
699699
* Start syncing the table in the sync worker.
700700
*
701-
* The returned slot name ispalloced in current memory context.
701+
* The returned slot name ispalloc'ed in current memory context.
702702
*/
703703
char*
704704
LogicalRepSyncTableStart(XLogRecPtr*origin_startpos)

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp