Commitcd2b7d3

committed

Fix streaming replication starting at the very first WAL segment.

Per complaint from Greg Stark.

1 parentaed0829 commitcd2b7d3Copy full SHA for cd2b7d3

File tree

-13

lines changed

-13

lines changed

Lines changed: 1 addition & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -10,7 +10,7 @@`
`10`	`10`	`*`
`11`	`11`	`*`
`12`	`12`	`* IDENTIFICATION`
`13`		`- * $PostgreSQL: pgsql/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c,v 1.3 2010/02/03 09:47:19 heikki Exp $`
	`13`	`+ * $PostgreSQL: pgsql/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c,v 1.4 2010/02/25 07:31:40 heikki Exp $`
`14`	`14`	`*`
`15`	`15`	`*-------------------------------------------------------------------------`
`16`	`16`	`*/`
`@@ -84,8 +84,6 @@ libpqrcv_connect(char *conninfo, XLogRecPtr startpoint)`
`84`	`84`	`PGresult*res;`
`85`	`85`	`charcmd[64];`
`86`	`86`
`87`		`-Assert(startpoint.xlogid!=0\|\|startpoint.xrecoff!=0);`
`88`		`-`
`89`	`87`	`/* Connect */`
`90`	`88`	`snprintf(conninfo_repl,sizeof(conninfo_repl),"%s replication=true",conninfo);`
`91`	`89`

Lines changed: 1 addition & 10 deletions

Original file line number	Diff line number	Diff line change
`@@ -30,7 +30,7 @@`
`30`	`30`	`*`
`31`	`31`	`*`
`32`	`32`	`* IDENTIFICATION`
`33`		`- * $PostgreSQL: pgsql/src/backend/replication/walsender.c,v 1.7 2010/02/18 11:13:46 heikki Exp $`
	`33`	`+ * $PostgreSQL: pgsql/src/backend/replication/walsender.c,v 1.8 2010/02/25 07:31:40 heikki Exp $`
`34`	`34`	`*`
`35`	`35`	`*-------------------------------------------------------------------------`
`36`	`36`	`*/`
`@@ -573,15 +573,6 @@ XLogSend(StringInfo outMsg)`
`573`	`573`	`/* use volatile pointer to prevent code rearrangement */`
`574`	`574`	`volatileWalSnd*walsnd=MyWalSnd;`
`575`	`575`
`576`		`-/*`
`577`		`- * Invalid position means that we have not yet received the initial`
`578`		`- * CopyData message from the slave that indicates where to start the`
`579`		`- * streaming.`
`580`		`- */`
`581`		`-if (sentPtr.xlogid==0&&`
`582`		`-sentPtr.xrecoff==0)`
`583`		`-return true;`
`584`		`-`
`585`	`576`	`/* Attempt to send all records flushed to the disk already */`
`586`	`577`	`SendRqstPtr=GetWriteRecPtr();`
`587`	`578`

Comments

(0)