oci/zeronet
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Run connection cleanup every 15 seconds

Browse source
This commit is contained in:
shortcutme 2017-10-03 14:32:31 +02:00
parent e76164c7a9
commit 2cf86642a2
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/Connection/ConnectionServer.py
View file

@ -170,10 +170,11 @@ class ConnectionServer:
run_i = 0 run_i = 0
while self.running: while self.running:
run_i += 1 run_i += 1
time.sleep(60) # Check every minute time.sleep(15) # Check every minute
self.ip_incoming = {} # Reset connected ips counter self.ip_incoming = {} # Reset connected ips counter
self.broken_ssl_peer_ids = {} # Reset broken ssl peerids count self.broken_ssl_peer_ids = {} # Reset broken ssl peerids count
last_message_time = 0 last_message_time = 0
s = time.time()
for connection in self.connections[:]: # Make a copy for connection in self.connections[:]: # Make a copy
idle = time.time() - max(connection.last_recv_time, connection.start_time, connection.last_message_time) idle = time.time() - max(connection.last_recv_time, connection.start_time, connection.last_message_time)
last_message_time = max(last_message_time, connection.last_message_time) last_message_time = max(last_message_time, connection.last_message_time)
@ -220,7 +221,7 @@ class ConnectionServer:
"[Cleanup] No site for connection" "[Cleanup] No site for connection"
) )
elif run_i % 30 == 0: elif run_i % 90 == 0:
# Reset bad action counter every 30 min # Reset bad action counter every 30 min
connection.bad_actions = 0 connection.bad_actions = 0
@ -236,6 +237,9 @@ class ConnectionServer:
self.has_internet = True self.has_internet = True
self.onInternetOnline() self.onInternetOnline()
if time.time() - s > 0.01:
self.log.debug("Connection cleanup in %.3fs" % (time.time() - s))
def onInternetOnline(self): def onInternetOnline(self):
self.log.info("Internet online") self.log.info("Internet online")