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

Log merger sites update time

Browse source
This commit is contained in:
shortcutme 2016-08-15 13:57:07 +02:00
parent 0b1ef00077
commit cb4cf564be
1 changed files with 3 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
plugins/MergerSite/MergerSitePlugin.py
View file

@ -1,4 +1,5 @@
import re import re
import time
from Plugin import PluginManager from Plugin import PluginManager
from util import RateLimit from util import RateLimit
@ -234,10 +235,6 @@ class SiteStoragePlugin(object):
else: else:
merger_site.storage.onUpdated(virtual_path) merger_site.storage.onUpdated(virtual_path)
# Send the event to merger site's websocket
for ws in merger_site.websockets:
ws.event("siteChanged", self.site, {"event": ["file_done", virtual_path]})
@PluginManager.registerTo("Site") @PluginManager.registerTo("Site")
class SitePlugin(object): class SitePlugin(object):
@ -265,7 +262,7 @@ class SiteManagerPlugin(object):
# Update merger site for site types # Update merger site for site types
def updateMergerSites(self): def updateMergerSites(self):
global merger_db, merged_db, merged_to_merger, site_manager global merger_db, merged_db, merged_to_merger, site_manager
self.log.debug("Update merger sites") s = time.time()
merger_db = {} merger_db = {}
merged_db = {} merged_db = {}
merged_to_merger = {} merged_to_merger = {}
@ -293,7 +290,7 @@ class SiteManagerPlugin(object):
if site.address not in merged_to_merger: if site.address not in merged_to_merger:
merged_to_merger[site.address] = [] merged_to_merger[site.address] = []
merged_to_merger[site.address].append(merger_site) merged_to_merger[site.address].append(merger_site)
self.log.debug("Updated merger sites in %.3fs" % (time.time() - s))
def load(self, *args, **kwags): def load(self, *args, **kwags):