diff options
| author | Peter Eisentraut <peter@eisentraut.org> | 2020-01-14 14:05:25 +0100 |
|---|---|---|
| committer | Peter Eisentraut <peter@eisentraut.org> | 2020-01-14 14:40:41 +0100 |
| commit | ee4ac46c8eb289bc200d0fd682e75d11b4c55b5a (patch) | |
| tree | 6b875ecda6910f8f9563149ab16d5d33a21d9b9c /src/backend | |
| parent | f595117e24a79db6072979ab5a757431fd17232f (diff) | |
| download | postgresql-ee4ac46c8eb289bc200d0fd682e75d11b4c55b5a.tar.gz postgresql-ee4ac46c8eb289bc200d0fd682e75d11b4c55b5a.zip | |
Expose PQbackendPID() through walreceiver API
This will be used by a subsequent patch.
Reviewed-by: Masahiko Sawada <masahiko.sawada@2ndquadrant.com>
Discussion: https://www.postgresql.org/message-id/CA%2Bfd4k4dM0iEPLxyVyme2RAFsn8SUgrNtBJOu81YqTY4V%2BnqZA%40mail.gmail.com
Diffstat (limited to 'src/backend')
| -rw-r--r-- | src/backend/replication/libpqwalreceiver/libpqwalreceiver.c | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c b/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c index 658af71fec9..b731d3fd04e 100644 --- a/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c +++ b/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c @@ -74,6 +74,7 @@ static char *libpqrcv_create_slot(WalReceiverConn *conn, bool temporary, CRSSnapshotAction snapshot_action, XLogRecPtr *lsn); +static pid_t libpqrcv_get_backend_pid(WalReceiverConn *conn); static WalRcvExecResult *libpqrcv_exec(WalReceiverConn *conn, const char *query, const int nRetTypes, @@ -93,6 +94,7 @@ static WalReceiverFunctionsType PQWalReceiverFunctions = { libpqrcv_receive, libpqrcv_send, libpqrcv_create_slot, + libpqrcv_get_backend_pid, libpqrcv_exec, libpqrcv_disconnect }; @@ -859,6 +861,15 @@ libpqrcv_create_slot(WalReceiverConn *conn, const char *slotname, } /* + * Return PID of remote backend process. + */ +static pid_t +libpqrcv_get_backend_pid(WalReceiverConn *conn) +{ + return PQbackendPID(conn->streamConn); +} + +/* * Convert tuple query result to tuplestore. */ static void |