1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
from __future__ import print_function
import logging
import time
logger = logging.getLogger(name=__name__)
from leap.base.network import NetworkChecker
from leap.baseapp.dialogs import ErrorDialog
class NetworkCheckerAppMixin(object):
"""
initialize an instance of the Network Checker,
which gathers error and passes them on.
"""
def __init__(self, *args, **kwargs):
opts = kwargs.pop('opts', None)
config_file = getattr(opts, 'config_file', None)
self.network_checker_started = False
self.network_checker = NetworkChecker(
watcher_cb=self.newLogLine.emit,
status_signals=(self.statusChange.emit, ),
debug=self.debugmode)
self.network_checker.run_checks()
self.error_check()
def error_check(self):
"""
consumes the conductor error queue.
pops errors, and acts accordingly (launching user dialogs).
"""
logger.debug('error check')
errq = self.conductor.error_queue
while errq.qsize() != 0:
logger.debug('%s errors left in network queue', errq.qsize())
# we get exception and original traceback from queue
error, tb = errq.get()
# redundant log, debugging the loop.
logger.error('%s: %s', error.__class__.__name__, error.message)
if issubclass(error.__class__, eip_exceptions.EIPClientError):
self.handle_network_error(error)
else:
# deprecated form of raising exception.
raise error, None, tb
if error.failfirst is True:
break
def handle_network_error(self, error):
pass
|
