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

Avoid sending too many publish request to an outdated client

Browse source
This commit is contained in:
shortcutme 2019-12-04 17:15:42 +01:00
parent 23f851343f
commit 04ecb89e9a
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/Site/Site.py
View file

@ -394,6 +394,7 @@ class Site(object):
queried.append(peer) queried.append(peer)
modified_contents = [] modified_contents = []
my_modified = self.content_manager.listModified(since) my_modified = self.content_manager.listModified(since)
num_old_files = 0
for inner_path, modified in res["modified_files"].items(): # Check if the peer has newer files than we for inner_path, modified in res["modified_files"].items(): # Check if the peer has newer files than we
has_newer = int(modified) > my_modified.get(inner_path, 0) has_newer = int(modified) > my_modified.get(inner_path, 0)
has_older = int(modified) < my_modified.get(inner_path, 0) has_older = int(modified) < my_modified.get(inner_path, 0)
@ -402,8 +403,9 @@ class Site(object):
# We dont have this file or we have older # We dont have this file or we have older
modified_contents.append(inner_path) modified_contents.append(inner_path)
self.bad_files[inner_path] = self.bad_files.get(inner_path, 0) + 1 self.bad_files[inner_path] = self.bad_files.get(inner_path, 0) + 1
if has_older: if has_older and num_old_files < 5:
self.log.debug("%s client has older version of %s, publishing there..." % (peer, inner_path)) num_old_files += 1
self.log.debug("%s client has older version of %s, publishing there (%s/5)..." % (peer, inner_path, num_old_files))
gevent.spawn(self.publisher, inner_path, [peer], [], 1) gevent.spawn(self.publisher, inner_path, [peer], [], 1)
if modified_contents: if modified_contents:
self.log.debug("%s new modified file from %s" % (len(modified_contents), peer)) self.log.debug("%s new modified file from %s" % (len(modified_contents), peer))