From 4df2b77fdf42046fe19bd371be7c7255986b5980 Mon Sep 17 00:00:00 2001
From: RaNaN <Mast3rRaNaN@hotmail.de>
Date: Tue, 6 Mar 2012 13:36:39 +0100
Subject: renamed hooks to addons, new filemanager and database, many new api
 methods you will loose ALL your LINKS, webinterface will NOT work

---
 module/threads/AddonThread.py | 65 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 65 insertions(+)
 create mode 100644 module/threads/AddonThread.py

(limited to 'module/threads/AddonThread.py')

diff --git a/module/threads/AddonThread.py b/module/threads/AddonThread.py
new file mode 100644
index 000000000..3a378ad6e
--- /dev/null
+++ b/module/threads/AddonThread.py
@@ -0,0 +1,65 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+from copy import copy
+from traceback import print_exc
+
+from BaseThread import BaseThread
+
+class AddonThread(BaseThread):
+    """thread for addons"""
+
+    def __init__(self, m, function, args, kwargs):
+        """Constructor"""
+        BaseThread.__init__(self, m)
+
+        self.f = function
+        self.args = args
+        self.kwargs = kwargs
+
+        self.active = []
+
+        m.localThreads.append(self)
+
+        self.start()
+
+    def getActiveFiles(self):
+        return self.active
+
+    def addActive(self, pyfile):
+        """ Adds a pyfile to active list and thus will be displayed on overview"""
+        if pyfile not in self.active:
+            self.active.append(pyfile)
+
+    def finishFile(self, pyfile):
+        if pyfile in self.active:
+            self.active.remove(pyfile)
+
+        pyfile.finishIfDone()
+
+    def run(self):
+        try:
+            try:
+                self.kwargs["thread"] = self
+                self.f(*self.args, **self.kwargs)
+            except TypeError, e:
+                #dirty method to filter out exceptions
+                if "unexpected keyword argument 'thread'" not in e.args[0]:
+                    raise
+
+                del self.kwargs["thread"]
+                self.f(*self.args, **self.kwargs)
+        except Exception, e:
+            if hasattr(self.f, "im_self"):
+                addon = self.f.im_self
+                addon.logError(_("An Error occured"), e)
+                if self.m.core.debug:
+                    print_exc()
+                    self.writeDebugReport(addon.__name__, plugin=addon)
+
+        finally:
+            local = copy(self.active)
+            for x in local:
+                self.finishFile(x)
+
+            self.m.localThreads.remove(self)
\ No newline at end of file
-- 
cgit v1.2.3


From 2a74f88fcaf3d3baac24397de81a967c0b8c73e2 Mon Sep 17 00:00:00 2001
From: RaNaN <Mast3rRaNaN@hotmail.de>
Date: Thu, 17 May 2012 20:06:11 +0200
Subject: small typo fixes and TODOs

---
 module/threads/AddonThread.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'module/threads/AddonThread.py')

diff --git a/module/threads/AddonThread.py b/module/threads/AddonThread.py
index 3a378ad6e..b6a552e0e 100644
--- a/module/threads/AddonThread.py
+++ b/module/threads/AddonThread.py
@@ -37,7 +37,7 @@ class AddonThread(BaseThread):
 
         pyfile.finishIfDone()
 
-    def run(self):
+    def run(self): #TODO: approach via func_code
         try:
             try:
                 self.kwargs["thread"] = self
-- 
cgit v1.2.3