We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a2a686b commit 7e93d70Copy full SHA for 7e93d70
pglogical_receiver.c
@@ -43,6 +43,7 @@
43
#include "multimaster.h"
44
#include "spill.h"
45
#include "state.h"
46
+#include "bgwpool.h"
47
48
#define ERRCODE_DUPLICATE_OBJECT_STR "42710"
49
#define RECEIVER_SUSPEND_TIMEOUT (1*USECS_PER_SEC)
@@ -418,7 +419,10 @@ pglogical_receiver_main(Datum main_arg)
418
419
420
/* Emergency bailout if postmaster has died */
421
if (rc & WL_POSTMASTER_DEATH)
422
+ {
423
+ BgwPoolStop(&Mtm->pool);
424
proc_exit(1);
425
+ }
426
427
if (Mtm->status == MTM_DISABLED || (Mtm->status == MTM_RECOVERY && Mtm->recoverySlot != nodeId))
428
{
0 commit comments