summaryrefslogtreecommitdiffstats
path: root/module
diff options
context:
space:
mode:
authorGravatar Stefano <l.stickell@yahoo.it> 2014-03-31 15:42:28 +0200
committerGravatar Walter Purcaro <vuolter@gmail.com> 2014-06-28 02:50:17 +0200
commit10b0980e23835a02b598c63fca0ec0b02c64d47a (patch)
treeb71e716fbba802608d72cc8c37abef02db5770d0 /module
parentRemoved deprecated module. (diff)
downloadpyload-10b0980e23835a02b598c63fca0ec0b02c64d47a.tar.xz
Improved wait method
Diffstat (limited to 'module')
-rw-r--r--module/plugins/Plugin.py18
1 files changed, 13 insertions, 5 deletions
diff --git a/module/plugins/Plugin.py b/module/plugins/Plugin.py
index 584fcce49..1ba84a762 100644
--- a/module/plugins/Plugin.py
+++ b/module/plugins/Plugin.py
@@ -142,7 +142,7 @@ class Plugin(Base):
Overwrite `process` / `decrypt` in your subclassed plugin.
"""
__name__ = "Plugin"
- __version__ = "0.4"
+ __version__ = "0.5"
__pattern__ = None
__type__ = "hoster"
__config__ = [("name", "type", "desc", "default")]
@@ -261,7 +261,7 @@ class Plugin(Base):
return True, 10
- def setWait(self, seconds, reconnect=False):
+ def setWait(self, seconds, reconnect=None):
"""Set a specific wait time later used with `wait`
:param seconds: wait time in seconds
@@ -271,15 +271,23 @@ class Plugin(Base):
self.wantReconnect = True
self.pyfile.waitUntil = time() + int(seconds)
- def wait(self):
- """ waits the time previously set """
+ def wait(self, seconds=None, reconnect=None):
+ """ Waits the time previously set or use these from arguments. See `setWait`
+ """
+ if seconds:
+ self.setWait(seconds, reconnect)
+
+ self._wait()
+
+ def _wait(self):
self.waiting = True
self.pyfile.setStatus("waiting")
while self.pyfile.waitUntil > time():
self.thread.m.reconnecting.wait(2)
- if self.pyfile.abort: raise Abort
+ if self.pyfile.abort:
+ raise Abort
if self.thread.m.reconnecting.isSet():
self.waiting = False
self.wantReconnect = False