Commit53bd83b

committed

fix temp replication slot for PG >= 11

1 parentd9cb01a commit53bd83bCopy full SHA for 53bd83b

File tree

+10

-0

lines changed

+10

-0

lines changed

Lines changed: 10 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -2772,6 +2772,14 @@ StreamLog(void *arg)`
`2772`	`2772`	`replication_slot="pg_probackup_slot";`
`2773`	`2773`	`#endif`
`2774`	`2774`
	`2775`	`+`
	`2776`	`+#ifPG_VERSION_NUM >=110000`
	`2777`	`+/* Create temp repslot */`
	`2778`	`+if (temp_slot)`
	`2779`	`+CreateReplicationSlot(stream_arg->conn,replication_slot,`
	`2780`	`+NULL,temp_slot, true, true, false);`
	`2781`	`+#endif`
	`2782`	`+`
`2775`	`2783`	`/*`
`2776`	`2784`	`* Start the replication`
`2777`	`2785`	`*/`
`@@ -2792,7 +2800,9 @@ StreamLog(void *arg)`
`2792`	`2800`	`ctl.walmethod=CreateWalDirectoryMethod(stream_arg->basedir,0, true);`
`2793`	`2801`	`ctl.replication_slot=replication_slot;`
`2794`	`2802`	`ctl.stop_socket=PGINVALID_SOCKET;`
	`2803`	`+#ifPG_VERSION_NUM >=100000&&PG_VERSION_NUM<110000`
`2795`	`2804`	`ctl.temp_slot=temp_slot;`
	`2805`	`+#endif`
`2796`	`2806`	`#else`
`2797`	`2807`	`ctl.basedir= (char*)stream_arg->basedir;`
`2798`	`2808`	`#endif`

Comments

(0)