"""
S.rawcommand(T.TripeAsynchronousCommand(
me._q, (me._peer, me.seq),
- ['PING',
+ ['EPING',
'-background', S.bgtag(),
'-timeout', str(me._timeout),
'--',
me._ping()
elif code == 'FAIL':
S.notify('watch', 'ping-failed', me._peer, *stuff)
- if stuff and stuff[0] == 'unknown-peer':
+ if not stuff:
+ pass
+ elif stuff[0] == 'unknown-peer':
me._pinger.kill(me._peer)
+ elif stuff[0] == 'ping-send-failed':
+ me._reconnect()
elif code == 'INFO':
if stuff[0] == 'ping-ok':
if me._failures > 0: