daily commit

1 files changed, 12 insertions, 3 deletions

diff --git a/module/HookManager.py b/module/HookManager.py
index 96815ef63..9579c74a1 100644
--- a/module/HookManager.py
+++ b/module/HookManager.py
@@ -20,7 +20,7 @@
 
 import traceback
 from threading import RLock
-
+from module.PluginThread import HookThread
 
 class HookManager():
     def __init__(self, core):
@@ -76,13 +76,19 @@ class HookManager():
     def downloadFinished(self, pyfile):
 
         for plugin in self.plugins:
-            plugin.downloadFinished(pyfile)
+            if "downloadFinished" in plugin.__threaded__:
+                self.startThread(plugin.downloadFinished, pyfile)
+            else:
+                plugin.downloadFinished(pyfile)
     
     @lock
     def packageFinished(self, package):
 
         for plugin in self.plugins:
-            plugin.packageFinished(package)
+            if "packageFinished" in plugin.__threaded__:
+                self.startThread(plugin.packageFinished, pyfile)
+            else:
+                plugin.packageFinished(package)
     
     @lock
     def beforeReconnecting(self, ip):
@@ -95,3 +101,6 @@ class HookManager():
 
         for plugin in self.plugins:
             plugin.afterReconnecting(ip)
+
+    def startThread(self, function, pyfile):
+        t = HookThread(self.core.threadManager, function, pyfile)