better slots on dead iter

src/__init__.py

@@ -77,7 +77,7 @@ def read_config(filename=None, options=None):
             'certfile': None,
             'ca_cert': None,
             'verify_certs': 'no',
-            'drop_slot_countdown': 10,
+            'drop_slot_countdown': 300,
             'replication_slots_polling': None,
             'max_allowed_switchover_lag_ms': 60000,
         },

src/main.py

@@ -877,6 +877,7 @@ def dead_iter(self, db_state, zk_state, is_actually_dead):
         holder = self.zk.get_current_lock_holder()
         if holder and holder != helpers.get_hostname():
             if role == 'replica' and holder == last_primary:
+                self._acquire_replication_source_slot_lock(last_primary)
                 logging.info('Seems that primary has not changed but PostgreSQL is dead. Starting it.')
                 return self.db.start_postgresql()
 

tests/features/cascade.feature

@@ -364,6 +364,7 @@ Feature: Check not HA hosts
                     priority: 0
                     use_replication_slots: 'yes'
                     quorum_commit: 'yes'
+                    drop_slot_countdown: 10
                 primary:
                     change_replication_type: 'yes'
                     primary_switch_checks: 1

tests/features/kill_primary.feature

@@ -303,6 +303,7 @@ Feature: Destroy primary in various scenarios
                     priority: 0
                     use_replication_slots: 'yes'
                     quorum_commit: 'yes'
+                    drop_slot_countdown: 10
                 primary:
                     change_replication_type: 'yes'
                     primary_switch_checks: 1

tests/features/slot.feature

@@ -8,6 +8,7 @@ Feature: Replication slots
                 global:
                     priority: 0
                     use_replication_slots: 'yes'
+                    drop_slot_countdown: 10
                 primary:
                     change_replication_type: 'no'
                     primary_switch_checks: 1