diff options
author | GammaC0de <GammaC0de@users.noreply.github.com> | 2015-05-05 00:23:31 +0200 |
---|---|---|
committer | GammaC0de <GammaC0de@users.noreply.github.com> | 2015-05-05 00:23:31 +0200 |
commit | 8483aacbcd7f3f4c6ad92ef2255b449b88d64a35 (patch) | |
tree | e4a187af7e89a07608464a9678fb5dfabad72b31 | |
parent | Fix https://github.com/pyload/pyload/issues/1351 (diff) | |
download | pyload-8483aacbcd7f3f4c6ad92ef2255b449b88d64a35.tar.xz |
fix bug causing `extractQueued` called twice
-rw-r--r-- | module/plugins/hooks/ExtractArchive.py | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/module/plugins/hooks/ExtractArchive.py b/module/plugins/hooks/ExtractArchive.py index 05a1e368a..62eb36714 100644 --- a/module/plugins/hooks/ExtractArchive.py +++ b/module/plugins/hooks/ExtractArchive.py @@ -187,6 +187,11 @@ class ExtractArchive(Hook): @threaded def extractQueued(self, thread): + if self.extracting: #@NOTE: doing the check here for safty (called by coreReady) + return + + self.extracting = True + packages = self.queue.get() while packages: if self.lastPackage: #: called from allDownloadsProcessed @@ -200,6 +205,8 @@ class ExtractArchive(Hook): packages = self.queue.get() #: check for packages added during extraction + self.extracting = False + @Expose def extractPackage(self, *ids): @@ -222,7 +229,7 @@ class ExtractArchive(Hook): def allDownloadsProcessed(self): self.lastPackage = True - if not self.extracting: + if self.getConfig('waitall') and not self.extracting: self.extractQueued() @@ -231,8 +238,6 @@ class ExtractArchive(Hook): if not ids: return False - self.extracting = True - processed = [] extracted = [] failed = [] @@ -374,7 +379,6 @@ class ExtractArchive(Hook): self.queue.remove(pid) - self.extracting = False return True if not failed else False |