Commitee4ac46

committed

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

1 parentf595117 commitee4ac46Copy full SHA for ee4ac46

File tree

+15

-0

lines changed

src
- backend/replication/libpqwalreceiver
  - libpqwalreceiver.c
- include/replication
  - walreceiver.h

+15

-0

lines changed

Lines changed: 11 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -74,6 +74,7 @@ static char libpqrcv_create_slot(WalReceiverConn conn,`
`74`	`74`	`booltemporary,`
`75`	`75`	`CRSSnapshotActionsnapshot_action,`
`76`	`76`	`XLogRecPtr*lsn);`
	`77`	`+staticpid_tlibpqrcv_get_backend_pid(WalReceiverConn*conn);`
`77`	`78`	`staticWalRcvExecResultlibpqrcv_exec(WalReceiverConnconn,`
`78`	`79`	`constchar*query,`
`79`	`80`	`constintnRetTypes,`
`@@ -93,6 +94,7 @@ static WalReceiverFunctionsType PQWalReceiverFunctions = {`
`93`	`94`	`libpqrcv_receive,`
`94`	`95`	`libpqrcv_send,`
`95`	`96`	`libpqrcv_create_slot,`
	`97`	`+libpqrcv_get_backend_pid,`
`96`	`98`	`libpqrcv_exec,`
`97`	`99`	`libpqrcv_disconnect`
`98`	`100`	`};`
`@@ -858,6 +860,15 @@ libpqrcv_create_slot(WalReceiverConn conn, const char slotname,`
`858`	`860`	`returnsnapshot;`
`859`	`861`	`}`
`860`	`862`
	`863`	`+/*`
	`864`	`+ * Return PID of remote backend process.`
	`865`	`+ */`
	`866`	`+staticpid_t`
	`867`	`+libpqrcv_get_backend_pid(WalReceiverConn*conn)`
	`868`	`+{`
	`869`	`+returnPQbackendPID(conn->streamConn);`
	`870`	`+}`
	`871`	`+`
`861`	`872`	`/*`
`862`	`873`	`* Convert tuple query result to tuplestore.`
`863`	`874`	`*/`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -226,6 +226,7 @@ typedef char (walrcv_create_slot_fn) (WalReceiverConn *conn,`
`226`	`226`	`constchar*slotname,booltemporary,`
`227`	`227`	`CRSSnapshotActionsnapshot_action,`
`228`	`228`	`XLogRecPtr*lsn);`
	`229`	`+typedefpid_t (walrcv_get_backend_pid_fn) (WalReceiverConnconn);`
`229`	`230`	`typedefWalRcvExecResult(walrcv_exec_fn) (WalReceiverConn*conn,`
`230`	`231`	`constchar*query,`
`231`	`232`	`constintnRetTypes,`
`@@ -246,6 +247,7 @@ typedef struct WalReceiverFunctionsType`
`246`	`247`	`walrcv_receive_fnwalrcv_receive;`
`247`	`248`	`walrcv_send_fnwalrcv_send;`
`248`	`249`	`walrcv_create_slot_fnwalrcv_create_slot;`
	`250`	`+walrcv_get_backend_pid_fnwalrcv_get_backend_pid;`
`249`	`251`	`walrcv_exec_fnwalrcv_exec;`
`250`	`252`	`walrcv_disconnect_fnwalrcv_disconnect;`
`251`	`253`	`}WalReceiverFunctionsType;`
`@@ -276,6 +278,8 @@ extern PGDLLIMPORT WalReceiverFunctionsType *WalReceiverFunctions;`
`276`	`278`	`WalReceiverFunctions->walrcv_send(conn, buffer, nbytes)`
`277`	`279`	`#definewalrcv_create_slot(conn,slotname,temporary,snapshot_action,lsn) \`
`278`	`280`	`WalReceiverFunctions->walrcv_create_slot(conn, slotname, temporary, snapshot_action, lsn)`
	`281`	`+#definewalrcv_get_backend_pid(conn) \`
	`282`	`+WalReceiverFunctions->walrcv_get_backend_pid(conn)`
`279`	`283`	`#definewalrcv_exec(conn,exec,nRetTypes,retTypes) \`
`280`	`284`	`WalReceiverFunctions->walrcv_exec(conn, exec, nRetTypes, retTypes)`
`281`	`285`	`#definewalrcv_disconnect(conn) \`

Comments

(0)