Flush CopyOutResponse when starting streaming in walsender, so that it's

hlinnaka · hlinnaka · commit 59292f28cace · 2010-03-26T12:23:34.000Z
not delayed until the first WAL record is sent.

Fujii Masao
diff --git a/src/backend/replication/walsender.c b/src/backend/replication/walsender.c
@@ -30,7 +30,7 @@
  *
  *
  * IDENTIFICATION
- *	  $PostgreSQL: pgsql/src/backend/replication/walsender.c,v 1.12 2010/03/24 21:41:57 sriggs Exp $
+ *	  $PostgreSQL: pgsql/src/backend/replication/walsender.c,v 1.13 2010/03/26 12:23:34 heikki Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -263,6 +263,7 @@ WalSndHandshake(void)
 						pq_sendbyte(&buf, 0);
 						pq_sendint(&buf, 0, 2);
 						pq_endmessage(&buf);
+						pq_flush();
 
 						/*
 						 * Initialize position to the received one, then the

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.12 2010/03/24 21:41:57 sriggs Exp $`
	`33`	`+ * $PostgreSQL: pgsql/src/backend/replication/walsender.c,v 1.13 2010/03/26 12:23:34 heikki Exp $`
`34`	`34`	`*`
`35`	`35`	`*-------------------------------------------------------------------------`
`36`	`36`	`*/`
`@@ -263,6 +263,7 @@ WalSndHandshake(void)`
`263`	`263`	`pq_sendbyte(&buf, 0);`
`264`	`264`	`pq_sendint(&buf, 0, 2);`
`265`	`265`	`pq_endmessage(&buf);`
	`266`	`+ pq_flush();`
`266`	`267`
`267`	`268`	`/*`
`268`	`269`	`* Initialize position to the received one, then the`