database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-07-31 22:04:40 +03:00
Code Activity

Minor sync rep corrections.

Browse Source 
Fujii Masao, with a bit of additional wordsmithing by me.
This commit is contained in:
Robert Haas
2011-03-10 14:57:02 -05:00
parent d16e290a8a
commit 6436098795
3 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/backend/replication/syncrep.c
View File

@ -447,9 +447,9 @@ SyncRepGetStandbyPriority(void)
} }
/* /*
* Walk queue from head setting setting the state of any backends that * Walk queue from head. Set the state of any backends that need to be woken,
* need to be woken, remove them from the queue and then wake them. * remove them from the queue, and then wake them. Pass all = true to wake
* Set all = true to wake whole queue, or just up to LSN. * whole queue; otherwise, just wake up to the walsender's LSN.
* *
* Must hold SyncRepLock. * Must hold SyncRepLock.
*/ */

2
src/backend/storage/ipc/shmqueue.c
View File

@ -157,7 +157,7 @@ SHMQueueNext(const SHM_QUEUE *queue, const SHM_QUEUE *curElem, Size linkOffset)
/*-------------------- /*--------------------
* SHMQueuePrev -- Get the previous element from a queue * SHMQueuePrev -- Get the previous element from a queue
* *
* Same as SHMQueueNext, just starting at tail and moving towards head * Same as SHMQueueNext, just starting at tail and moving towards head.
* All other comments and usage applies. * All other comments and usage applies.
*/ */
Pointer Pointer

3
src/include/replication/syncrep.h
View File

@ -29,7 +29,6 @@
/* user-settable parameters for synchronous replication */ /* user-settable parameters for synchronous replication */
extern bool sync_rep_mode; extern bool sync_rep_mode;
extern int sync_rep_timeout;
extern char *SyncRepStandbyNames; extern char *SyncRepStandbyNames;
/* called by user backend */ /* called by user backend */
@ -44,6 +43,6 @@ extern void SyncRepReleaseWaiters(void);
/* called by various procs */ /* called by various procs */
extern int SyncRepWakeQueue(bool all); extern int SyncRepWakeQueue(bool all);
const char *assign_synchronous_standby_names(const char *newval, bool doit, GucSource source); extern const char *assign_synchronous_standby_names(const char *newval, bool doit, GucSource source);
#endif /* _SYNCREP_H */ #endif /* _SYNCREP_H */