From ed5114f6b8e9f6661aff5e19f06046fb1ce52ef4 Mon Sep 17 00:00:00 2001
From: inso <insomniak.fr@gmaiL.com>
Date: Thu, 30 Nov 2017 22:26:28 +0100
Subject: [PATCH] Forgot old nodes more regurarly
---
src/sakia/services/network.py | 16 +++++++++-------
1 file changed, 9 insertions(+), 7 deletions(-)
diff --git a/src/sakia/services/network.py b/src/sakia/services/network.py
index 9fd850ff..6bb0530e 100644
--- a/src/sakia/services/network.py
+++ b/src/sakia/services/network.py
@@ -147,18 +147,20 @@ class NetworkService(QObject):
asyncio.ensure_future(self.discovery_loop())
self.refresh_once()
while self.continue_crawling():
+ if not first_loop:
+ for connector in self._connectors:
+ if connector.node.state in (Node.OFFLINE, Node.CORRUPTED) \
+ and connector.node.last_state_change + 3600 < time.time():
+ connector.disconnect()
+ self._processor.delete_node(connector.node)
+ self._connectors.remove(connector)
+ self.node_removed.emit(connector.node)
+
for connector in self._connectors:
if self.continue_crawling():
await connector.init_session()
connector.refresh()
if not first_loop:
- if connector.node.state in (Node.OFFLINE, Node.CORRUPTED) \
- and connector.node.last_state_change + 3600 < time.time():
- connector.disconnect()
- self._processor.delete_node(connector.node)
- self._connectors.remove(connector)
- self.node_removed.emit(connector.node)
-
await asyncio.sleep(15)
first_loop = False
--
GitLab