diff options
| author | 2015-05-05 00:23:31 +0200 | |
|---|---|---|
| committer | 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 | 
