Merge branch 'pgrex90-base' into pgrex90

[pg-rex/syncrep.git] / src / backend / replication / libpqwalreceiver / libpqwalreceiver.c

diff --git a/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c b/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c
index 6b477fd..0d8c278 100644 (file)
--- a/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c
+++ b/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c
@@ -156,8 +156,9 @@ libpqrcv_connect(char *conninfo, XLogRecPtr startpoint)
        ThisTimeLineID = primary_tli;
 
        /* Start streaming from the point requested by startup process */
-       snprintf(cmd, sizeof(cmd), "START_REPLICATION %X/%X",
-                        startpoint.xlogid, startpoint.xrecoff);
+       snprintf(cmd, sizeof(cmd), "START_REPLICATION %X/%X MODE %s",
+                        startpoint.xlogid, startpoint.xrecoff,
+                        GetConfigOption("replication_mode", false));
        res = libpqrcv_PQexec(cmd);
        if (PQresultStatus(res) != PGRES_COPY_BOTH)
        {