Commit7cf7dc7

committed

Add missing PQclear() calls into pg_receivexlog.

Back-patch to 9.3.

1 parent38803d8 commit7cf7dc7Copy full SHA for 7cf7dc7

File tree

-0

lines changed

-0

lines changed

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -626,6 +626,7 @@ ReceiveXlogStream(PGconn *conn, XLogRecPtr startpos, uint32 timeline,`
`626`	`626`	`fprintf(stderr,`
`627`	`627`	`_("%s: unexpected termination of replication stream: %s"),`
`628`	`628`	`progname,PQresultErrorMessage(res));`
	`629`	`+PQclear(res);`
`629`	`630`	`gotoerror;`
`630`	`631`	`}`
`631`	`632`	`PQclear(res);`
`@@ -640,6 +641,8 @@ ReceiveXlogStream(PGconn *conn, XLogRecPtr startpos, uint32 timeline,`
`640`	`641`	`}`
`641`	`642`	`elseif (PQresultStatus(res)==PGRES_COMMAND_OK)`
`642`	`643`	`{`
	`644`	`+PQclear(res);`
	`645`	`+`
`643`	`646`	`/*`
`644`	`647`	`* End of replication (ie. controlled shut down of the server).`
`645`	`648`	`*`
`@@ -661,6 +664,7 @@ ReceiveXlogStream(PGconn *conn, XLogRecPtr startpos, uint32 timeline,`
`661`	`664`	`fprintf(stderr,`
`662`	`665`	`_("%s: unexpected termination of replication stream: %s"),`
`663`	`666`	`progname,PQresultErrorMessage(res));`
	`667`	`+PQclear(res);`
`664`	`668`	`gotoerror;`
`665`	`669`	`}`
`666`	`670`	`}`
`@@ -871,6 +875,7 @@ HandleCopyStream(PGconn *conn, XLogRecPtr startpos, uint32 timeline,`
`871`	`875`	`PQclear(res);`
`872`	`876`	`gotoerror;`
`873`	`877`	`}`
	`878`	`+PQclear(res);`
`874`	`879`	`res=PQgetResult(conn);`
`875`	`880`	`}`
`876`	`881`	`still_sending= false;`

Comments

(0)