debug_set_trace(): cleanups, remove dead code
This commit is contained in:
parent
bdef446ad4
commit
a1f0d1bbf7
|
@ -86,7 +86,7 @@ class Boss(object):
|
||||||
def start(self):
|
def start(self):
|
||||||
self._RC.start()
|
self._RC.start()
|
||||||
|
|
||||||
def _set_trace(self, client_name, which, logger):
|
def _set_trace(self, client_name, which, file):
|
||||||
names = {"B": self, "N": self._N, "M": self._M, "S": self._S,
|
names = {"B": self, "N": self._N, "M": self._M, "S": self._S,
|
||||||
"O": self._O, "K": self._K, "SK": self._K._SK, "R": self._R,
|
"O": self._O, "K": self._K, "SK": self._K._SK, "R": self._R,
|
||||||
"RC": self._RC, "L": self._L, "C": self._C,
|
"RC": self._RC, "L": self._L, "C": self._C,
|
||||||
|
@ -97,17 +97,20 @@ class Boss(object):
|
||||||
if new_state:
|
if new_state:
|
||||||
print("%s.%s[%s].%s -> [%s]" %
|
print("%s.%s[%s].%s -> [%s]" %
|
||||||
(client_name, machine, old_state, input,
|
(client_name, machine, old_state, input,
|
||||||
new_state))
|
new_state), file=file)
|
||||||
else:
|
else:
|
||||||
# the RendezvousConnector emits message events as if
|
# the RendezvousConnector emits message events as if
|
||||||
# they were state transitions, except that old_state
|
# they were state transitions, except that old_state
|
||||||
# and new_state are empty strings. "input" is one of
|
# and new_state are empty strings. "input" is one of
|
||||||
# R.connected, R.rx(type phase+side), R.tx(type
|
# R.connected, R.rx(type phase+side), R.tx(type
|
||||||
# phase), R.lost .
|
# phase), R.lost .
|
||||||
print("%s.%s.%s" % (client_name, machine, input))
|
print("%s.%s.%s" % (client_name, machine, input),
|
||||||
|
file=file)
|
||||||
else:
|
else:
|
||||||
if new_state:
|
if new_state:
|
||||||
print(" %s.%s.%s()" % (client_name, machine, output))
|
print(" %s.%s.%s()" % (client_name, machine, output),
|
||||||
|
file=file)
|
||||||
|
file.flush()
|
||||||
names[machine].set_trace(tracer)
|
names[machine].set_trace(tracer)
|
||||||
|
|
||||||
def serialize(self):
|
def serialize(self):
|
||||||
|
|
|
@ -34,10 +34,6 @@ from .util import to_bytes
|
||||||
# wormhole(delegate=app, delegate_prefix="wormhole_",
|
# wormhole(delegate=app, delegate_prefix="wormhole_",
|
||||||
# delegate_args=(args, kwargs))
|
# delegate_args=(args, kwargs))
|
||||||
|
|
||||||
def _log(client_name, machine_name, old_state, input, new_state):
|
|
||||||
print("%s.%s[%s].%s -> [%s]" % (client_name, machine_name,
|
|
||||||
old_state, input, new_state))
|
|
||||||
|
|
||||||
class _WelcomeHandler:
|
class _WelcomeHandler:
|
||||||
def __init__(self, url, stderr=sys.stderr):
|
def __init__(self, url, stderr=sys.stderr):
|
||||||
self.relay_url = url
|
self.relay_url = url
|
||||||
|
@ -93,9 +89,9 @@ class _DelegatedWormhole(object):
|
||||||
def close(self):
|
def close(self):
|
||||||
self._boss.close()
|
self._boss.close()
|
||||||
|
|
||||||
def debug_set_trace(self, client_name, which="B N M S O K R RC NL C T",
|
def debug_set_trace(self, client_name, which="B N M S O K R RC L C T",
|
||||||
logger=_log):
|
file=sys.stderr):
|
||||||
self._boss.set_trace(client_name, which, logger)
|
self._boss._set_trace(client_name, which, file)
|
||||||
|
|
||||||
# from below
|
# from below
|
||||||
def got_code(self, code):
|
def got_code(self, code):
|
||||||
|
@ -203,8 +199,8 @@ class _DeferredWormhole(object):
|
||||||
return d
|
return d
|
||||||
|
|
||||||
def debug_set_trace(self, client_name, which="B N M S O K R RC L C T",
|
def debug_set_trace(self, client_name, which="B N M S O K R RC L C T",
|
||||||
logger=_log):
|
file=sys.stderr):
|
||||||
self._boss._set_trace(client_name, which, logger)
|
self._boss._set_trace(client_name, which, file)
|
||||||
|
|
||||||
# from below
|
# from below
|
||||||
def got_code(self, code):
|
def got_code(self, code):
|
||||||
|
|
Loading…
Reference in New Issue
Block a user