diff options
Diffstat (limited to 'module/FileDatabase.py')
| -rw-r--r-- | module/FileDatabase.py | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/module/FileDatabase.py b/module/FileDatabase.py index 57339a128..5f1a903a4 100644 --- a/module/FileDatabase.py +++ b/module/FileDatabase.py @@ -107,9 +107,11 @@ class FileHandler: def lock(func): def new(*args): + #print "Handler: %s args: %s" % (func,args[1:]) args[0].lock.acquire() res = func(*args) args[0].lock.release() + #print "Handler: %s return: %s" % (func, res) return res return new @@ -169,6 +171,7 @@ class FileHandler: #@TODO package update event #---------------------------------------------------------------------- + @lock @change def addPackage(self, name, folder, queue=0): """adds a package, default to link collector""" @@ -538,18 +541,21 @@ class FileDatabaseBackend(Thread): def queue(func): """use as decorator when fuction directly executes sql commands""" def new(*args): + #print "DataBase: %s args: %s" % (func, args[1:]) args[0].lock.acquire() args[0].jobs.put((func, args, 0)) res = args[0].res.get() args[0].lock.release() + #print "DataBase: %s return: %s" % (func, res) return res - - + + return new def async(func): """use as decorator when function does not return anything and asynchron execution is wanted""" def new(*args): + #print "DataBase async: %s args: %s" % (func, args[1:]) args[0].lock.acquire() args[0].jobs.put((func, args, 1)) args[0].lock.release() @@ -803,7 +809,7 @@ class FileDatabaseBackend(Thread): @async def updateLinkInfo(self, data): """ data is list of tupels (name, size, status, url) """ - self.c.executemany('UPDATE links SET name=?, size=?, status=? WHERE url=? AND status NOT IN (0,12,13)', data) + self.c.executemany('UPDATE links SET name=?, size=?, status=? WHERE url=? AND status NOT IN (0,8,12,13)', data) @queue def reorderPackage(self, p, position, noMove=False): |