Skip to content

Commit c68af32

Browse files
author
Andrei Kruchinin
committed
fix deletion of replication origin
1 parent aa4c25b commit c68af32

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/state.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3918,7 +3918,7 @@ stop_node_workers(int node_id, MtmConfig *new_cfg, Datum arg)
39183918
ReplicationSlotDrop(filter_slot_name, true);
39193919

39203920
/* delete replication origin, was acquired by receiver */
3921-
replorigin_by_name(logical_slot, false);
3921+
replorigin_drop_by_name(logical_slot, false, true);
39223922

39233923
/*
39243924
* Delete logical slot. It is aquired by walsender, so call with nowait =

0 commit comments

Comments
 (0)