Flush CopyOutResponse when starting streaming in walsender, so that it's
authorHeikki Linnakangas
Fri, 26 Mar 2010 12:23:34 +0000 (12:23 +0000)
committerHeikki Linnakangas
Fri, 26 Mar 2010 12:23:34 +0000 (12:23 +0000)
not delayed until the first WAL record is sent.

Fujii Masao

src/backend/replication/walsender.c

index f1a995dccc4d817488d2a0a48fa33d10c0205efd..21058d10ba799ed5f62b68120b430c502c323618 100644 (file)
@@ -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