diff options
| author | Heikki Linnakangas <heikki.linnakangas@iki.fi> | 2010-03-26 12:23:34 +0000 |
|---|---|---|
| committer | Heikki Linnakangas <heikki.linnakangas@iki.fi> | 2010-03-26 12:23:34 +0000 |
| commit | 59292f28cace8c0d4b038cadbb127b440e3a7815 (patch) | |
| tree | d1f8400bd3e18cecb9fbcc46170f48b3cee4e516 /src | |
| parent | 65cd829232508405833ee5ae46c9fff42a2b215a (diff) | |
| download | postgresql-59292f28cace8c0d4b038cadbb127b440e3a7815.tar.gz postgresql-59292f28cace8c0d4b038cadbb127b440e3a7815.zip | |
Flush CopyOutResponse when starting streaming in walsender, so that it's
not delayed until the first WAL record is sent.
Fujii Masao
Diffstat (limited to 'src')
| -rw-r--r-- | src/backend/replication/walsender.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/backend/replication/walsender.c b/src/backend/replication/walsender.c index f1a995dccc4..21058d10ba7 100644 --- 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 |