|
|
@ -628,6 +628,7 @@ ReceiveXlogStream(PGconn *conn, XLogRecPtr startpos, uint32 timeline, |
|
|
|
fprintf(stderr, |
|
|
|
fprintf(stderr, |
|
|
|
_("%s: unexpected termination of replication stream: %s"), |
|
|
|
_("%s: unexpected termination of replication stream: %s"), |
|
|
|
progname, PQresultErrorMessage(res)); |
|
|
|
progname, PQresultErrorMessage(res)); |
|
|
|
|
|
|
|
PQclear(res); |
|
|
|
goto error; |
|
|
|
goto error; |
|
|
|
} |
|
|
|
} |
|
|
|
PQclear(res); |
|
|
|
PQclear(res); |
|
|
@ -642,6 +643,8 @@ ReceiveXlogStream(PGconn *conn, XLogRecPtr startpos, uint32 timeline, |
|
|
|
} |
|
|
|
} |
|
|
|
else if (PQresultStatus(res) == PGRES_COMMAND_OK) |
|
|
|
else if (PQresultStatus(res) == PGRES_COMMAND_OK) |
|
|
|
{ |
|
|
|
{ |
|
|
|
|
|
|
|
PQclear(res); |
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
|
* End of replication (ie. controlled shut down of the server). |
|
|
|
* End of replication (ie. controlled shut down of the server). |
|
|
|
* |
|
|
|
* |
|
|
@ -663,6 +666,7 @@ ReceiveXlogStream(PGconn *conn, XLogRecPtr startpos, uint32 timeline, |
|
|
|
fprintf(stderr, |
|
|
|
fprintf(stderr, |
|
|
|
_("%s: unexpected termination of replication stream: %s"), |
|
|
|
_("%s: unexpected termination of replication stream: %s"), |
|
|
|
progname, PQresultErrorMessage(res)); |
|
|
|
progname, PQresultErrorMessage(res)); |
|
|
|
|
|
|
|
PQclear(res); |
|
|
|
goto error; |
|
|
|
goto error; |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
@ -839,6 +843,7 @@ HandleCopyStream(PGconn *conn, XLogRecPtr startpos, uint32 timeline, |
|
|
|
PQclear(res); |
|
|
|
PQclear(res); |
|
|
|
goto error; |
|
|
|
goto error; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
PQclear(res); |
|
|
|
res = PQgetResult(conn); |
|
|
|
res = PQgetResult(conn); |
|
|
|
} |
|
|
|
} |
|
|
|
still_sending = false; |
|
|
|
still_sending = false; |
|
|
|