me._sigma_t = 0
me._sigma_t2 = 0
me._min = me._max = '-'
+ now = time()
if pingnow:
me._timer = None
me._ping()
else:
- me._timer = M.SelTimer(time() + me._every, me._time)
+ me._timer = M.SelTimer(now + me._every, me._time)
def update(me, peer):
"""
me._peer]))
def _reconnect(me):
+ now = time()
try:
peer = Peer(me._peer)
if me._connectp or me._knockp:
S.warn('connect', 'reconnecting', me._peer)
S.forcekx(me._peer, quiet = not me._knockp)
if me._connectp: T.spawn(run_connect, peer, peer.get('connect'))
- me._timer = M.SelTimer(time() + me._every, me._time)
+ me._timer = M.SelTimer(now + me._every, me._time)
me._sabotage = False
else:
S.kill(me._peer)
If the ping fails and we run out of retries, we attempt to restart the
connection.
"""
+ now = time()
if code == 'TIMER':
me._failures = 0
me._ping()
me._nping += 1
if me._min == '-' or t < me._min: me._min = t
if me._max == '-' or t > me._max: me._max = t
- me._timer = M.SelTimer(time() + me._every, me._time)
+ me._timer = M.SelTimer(now + me._every, me._time)
elif outcome == 'ping-timeout':
me._failures += 1
me._nlost += 1
Report a challenge; when (and if!) the server receives a greeting quoting
this challenge, add the corresponding peer to the server.
"""
+ now = time()
timeout = 30
op = T.OptParse(args, ['-timeout'])
for opt in op:
except KeyError: raise T.TripeJobError('unknown-peer', name)
chal = S.getchal()
cr = T.Coroutine.getcurrent()
- timer = M.SelTimer(time() + timeout, lambda: cr.switch(None))
+ timer = M.SelTimer(now + timeout, lambda: cr.switch(None))
try:
T.svcinfo(chal)
chalmap[chal] = cr