summaryrefslogtreecommitdiff
path: root/src/leap/base/network.py
diff options
context:
space:
mode:
authorkali <kali@leap.se>2012-10-05 20:15:12 +0900
committerkali <kali@leap.se>2012-10-05 20:15:12 +0900
commit31c0afa5eb9bc7566ca39099520e8adc7b531e22 (patch)
tree5850ec279a39479209fa8d5f36137b56a18af329 /src/leap/base/network.py
parent95ce59c8833cb2ba951630080cdbc1e6d756a666 (diff)
pep8
Diffstat (limited to 'src/leap/base/network.py')
-rw-r--r--src/leap/base/network.py13
1 files changed, 8 insertions, 5 deletions
diff --git a/src/leap/base/network.py b/src/leap/base/network.py
index 159e9b21..4a90f2f4 100644
--- a/src/leap/base/network.py
+++ b/src/leap/base/network.py
@@ -21,13 +21,15 @@ class NetworkChecker(object):
def __init__(self, *args, **kwargs):
self.status_signals = kwargs.pop('status_signals', None)
self.watcher_cb = kwargs.pop('status_signals', None)
- self.error_cb = kwargs.pop('error_cb',
- lambda exc: logger.error("%s", exc.message))
+ self.error_cb = kwargs.pop(
+ 'error_cb',
+ lambda exc: logger.error("%s", exc.message))
self.shutdown = threading.Event()
self.checker = LeapNetworkChecker()
def start(self):
- self.process_handle = self._launch_recurrent_network_checks((self.error_cb,))
+ self.process_handle = self._launch_recurrent_network_checks(
+ (self.error_cb,))
def stop(self):
self.shutdown.set()
@@ -51,7 +53,8 @@ class NetworkChecker(object):
sleep(1)
observer_dict = dict(((
- observer, process_events(observer)) for observer in fail_callbacks))
+ observer,
+ process_events(observer)) for observer in fail_callbacks))
while not self.shutdown.is_set():
try:
self.checker.check_tunnel_default_interface()
@@ -65,7 +68,7 @@ class NetworkChecker(object):
self.shutdown.clear()
def _launch_recurrent_network_checks(self, fail_callbacks):
- #we need to wrap the fail callback in a turple
+ #we need to wrap the fail callback in a tuple
watcher = launch_thread(
self._network_checks_thread,
(fail_callbacks,))