diff options
| author | Simon Riggs <simon@2ndQuadrant.com> | 2011-07-19 03:40:03 +0100 |
|---|---|---|
| committer | Simon Riggs <simon@2ndQuadrant.com> | 2011-07-19 03:40:03 +0100 |
| commit | 5286105800c7d5902f98f32e11b209c471c0c69c (patch) | |
| tree | 59a5793296a3af901f864a16748e944edbd900ac /src/backend/replication/walreceiver.c | |
| parent | 3d4890c0c5d27dfdf7d1a8816d7bdcdba3c39d21 (diff) | |
| download | postgresql-5286105800c7d5902f98f32e11b209c471c0c69c.tar.gz postgresql-5286105800c7d5902f98f32e11b209c471c0c69c.zip | |
Cascading replication feature for streaming log-based replication.
Standby servers can now have WALSender processes, which can work with
either WALReceiver or archive_commands to pass data. Fully updated
docs, including new conceptual terms of sending server, upstream and
downstream servers. WALSenders terminated when promote to master.
Fujii Masao, review, rework and doc rewrite by Simon Riggs
Diffstat (limited to 'src/backend/replication/walreceiver.c')
| -rw-r--r-- | src/backend/replication/walreceiver.c | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/backend/replication/walreceiver.c b/src/backend/replication/walreceiver.c index ea6f6cdcdaf..c24fa87394d 100644 --- a/src/backend/replication/walreceiver.c +++ b/src/backend/replication/walreceiver.c @@ -44,6 +44,7 @@ #include "miscadmin.h" #include "replication/walprotocol.h" #include "replication/walreceiver.h" +#include "replication/walsender.h" #include "storage/ipc.h" #include "storage/pmsignal.h" #include "storage/procarray.h" @@ -564,8 +565,10 @@ XLogWalRcvFlush(bool dying) } SpinLockRelease(&walrcv->mutex); - /* Signal the startup process that new WAL has arrived */ + /* Signal the startup process and walsender that new WAL has arrived */ WakeupRecovery(); + if (AllowCascadeReplication()) + WalSndWakeup(); /* Report XLOG streaming progress in PS display */ if (update_process_title) @@ -625,7 +628,7 @@ XLogWalRcvSendReply(void) /* Construct a new message */ reply_message.write = LogstreamResult.Write; reply_message.flush = LogstreamResult.Flush; - reply_message.apply = GetXLogReplayRecPtr(); + reply_message.apply = GetXLogReplayRecPtr(NULL); reply_message.sendTime = now; elog(DEBUG2, "sending write %X/%X flush %X/%X apply %X/%X", |