chiark
/
gitweb
/
~mdw
/
tripe
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
svc/watch.in: Add some debugging output to the `rescan' function.
[tripe]
/
svc
/
watch.in
diff --git
a/svc/watch.in
b/svc/watch.in
index e058ed8e7db17fa98d4c2b098c239ec73d980389..97a12bfd60ccad2d2f3773d68d6ba4551fd7cc1b 100644
(file)
--- a/
svc/watch.in
+++ b/
svc/watch.in
@@
-525,6
+525,7
@@
class Pinger (T.Coroutine):
installed, and again by the dbwatcher coroutine when it detects a change
to the database.
"""
installed, and again by the dbwatcher coroutine when it detects a change
to the database.
"""
+ if T._debug: print '# rescan peers'
correct = {}
for peer in S.list():
try:
correct = {}
for peer in S.list():
try:
@@
-532,19
+533,23
@@
class Pinger (T.Coroutine):
except KeyError:
continue
if boolean(info, 'watch', False):
except KeyError:
continue
if boolean(info, 'watch', False):
+ if T._debug: print '# interesting peer %s' % peer
correct[peer] = info
for peer, obj in me._peers.items():
if peer in correct:
obj.update(correct[peer])
else:
correct[peer] = info
for peer, obj in me._peers.items():
if peer in correct:
obj.update(correct[peer])
else:
+ if T._debug: print '# peer %s vanished' % peer
del me._peers[peer]
for peer, info in correct.iteritems():
if peer not in me._peers:
if startup:
del me._peers[peer]
for peer, info in correct.iteritems():
if peer not in me._peers:
if startup:
+ if T._debug: print '# setting up peer %s' % peer
ifname = S.ifname(peer)
addr = S.addr(peer)
T.defer(addpeer, info, peer, ifname, *addr)
else:
ifname = S.ifname(peer)
addr = S.addr(peer)
T.defer(addpeer, info, peer, ifname, *addr)
else:
+ if T._debug: print '# adopting new peer %s' % peer
me.add(peer, info, True)
return me
me.add(peer, info, True)
return me