-def waitForSet(target, sleep=0.1, maxsecs=20, attrs=())
-Block until the specified attributes are set. Returns True if config has been received.
def waitForSet(target, sleep=.1, maxsecs=20, attrs=()):
- """Block until the specified attributes are set. Returns True if config has been received."""
- for _ in range(int(maxsecs/sleep)):
- if all(map(lambda a: getattr(target, a, None), attrs)):
- return True
- time.sleep(sleep)
- return Falsedef waitForConfig(self):
"""Block until radio config is received. Returns True if config has been received."""
- success = waitForSet(self, attrs=('myInfo', 'nodes')
+ success = self._timeout.waitForSet(self, attrs=('myInfo', 'nodes')
) and self.localNode.waitForConfig()
if not success:
raise Exception("Timed out waiting for interface config")
-def waitForConfig(self, maxsecs=20)
+def waitForConfig(self)
Block until radio config is received. Returns True if config has been received.
def waitForConfig(self, maxsecs=20):
+def waitForConfig(self):
"""Block until radio config is received. Returns True if config has been received."""
- return waitForSet(self, attrs=('radioConfig', 'channels'), maxsecs=maxsecs)
+ return self._timeout.waitForSet(self, attrs=('radioConfig', 'channels'))
@@ -3456,6 +3473,72 @@ hostname {string} – Hostname/IP address of the device to connect to
+
+class Timeout
+(maxSecs=20)
+
+
+
+
+Expand source code
+
+class Timeout:
+ def __init__(self, maxSecs = 20):
+ self.expireTime = 0
+ self.sleepInterval = 0.1
+ self.expireTimeout = maxSecs
+
+ def reset(self):
+ """Restart the waitForSet timer"""
+ self.expireTime = time.time() + self.expireTimeout
+
+ def waitForSet(self, target, attrs=()):
+ """Block until the specified attributes are set. Returns True if config has been received."""
+ self.reset()
+ while time.time() < self.expireTime:
+ if all(map(lambda a: getattr(target, a, None), attrs)):
+ return True
+ time.sleep(self.sleepInterval)
+ return False
+
+Methods
+
+
+def reset(self)
+-
+
Restart the waitForSet timer
+
+
+Expand source code
+
+def reset(self):
+ """Restart the waitForSet timer"""
+ self.expireTime = time.time() + self.expireTimeout
+
+
+
+def waitForSet(self, target, attrs=())
+-
+
Block until the specified attributes are set. Returns True if config has been received.
+
+
+Expand source code
+
+def waitForSet(self, target, attrs=()):
+ """Block until the specified attributes are set. Returns True if config has been received."""
+ self.reset()
+ while time.time() < self.expireTime:
+ if all(map(lambda a: getattr(target, a, None), attrs)):
+ return True
+ time.sleep(self.sleepInterval)
+ return False
+
+
+
+
TCPInterfaceTimeoutresetwaitForSet