summaryrefslogtreecommitdiff
path: root/src/leap/base
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
parent95ce59c8833cb2ba951630080cdbc1e6d756a666 (diff)
pep8
Diffstat (limited to 'src/leap/base')
-rw-r--r--src/leap/base/checks.py5
-rw-r--r--src/leap/base/network.py13
-rw-r--r--src/leap/base/tests/test_checks.py3
3 files changed, 13 insertions, 8 deletions
diff --git a/src/leap/base/checks.py b/src/leap/base/checks.py
index a775e162..d02c9a3d 100644
--- a/src/leap/base/checks.py
+++ b/src/leap/base/checks.py
@@ -3,6 +3,7 @@
import logging
import platform
+import netifaces
import ping
import requests
@@ -11,6 +12,7 @@ from leap.base import exceptions
logger = logging.getLogger(name=__name__)
+
class LeapNetworkChecker(object):
"""
all network related checks
@@ -51,7 +53,7 @@ class LeapNetworkChecker(object):
def check_tunnel_default_interface(self):
"""
- Raises an TunnelNotDefaultRouteError
+ Raises an TunnelNotDefaultRouteError
(including when no routes are present)
"""
if not platform.system() == "Linux":
@@ -71,7 +73,6 @@ class LeapNetworkChecker(object):
if not destination == '00000000' or not iface == 'tun0':
raise exceptions.TunnelNotDefaultRouteError()
-
def get_default_interface_gateway(self):
"""only impletemented for linux so far."""
if not platform.system() == "Linux":
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,))
diff --git a/src/leap/base/tests/test_checks.py b/src/leap/base/tests/test_checks.py
index 30746991..bec09ce6 100644
--- a/src/leap/base/tests/test_checks.py
+++ b/src/leap/base/tests/test_checks.py
@@ -74,7 +74,8 @@ class LeapNetworkCheckTest(BaseLeapTest):
"Iface\tDestination Gateway\t"
"Flags\tRefCntd\tUse\tMetric\t"
"Mask\tMTU\tWindow\tIRTT\n"
- "wlan0\t00000000\t0102A8C0\t0003\t0\t0\t0\t00000000\t0\t0\t0")
+ "wlan0\t00000000\t0102A8C0\t"
+ "0003\t0\t0\t0\t00000000\t0\t0\t0")
checker.check_tunnel_default_interface()
with patch('leap.base.checks.open', create=True) as mock_open: