Permalink
Browse files

Even then, only query nodes which are still in the cache

  • Loading branch information...
1 parent 03546f9 commit a7b05b8d62d8f1cddf9ff747ff491bc08217711d @richo committed Dec 29, 2012
Showing with 4 additions and 4 deletions.
  1. +4 −4 stationd
View
@@ -82,10 +82,10 @@ while True:
# Peer's uuid is larger, we should connect and initiate sync
if peer[0] not in peer_sockets:
# Ensure that they're in our object cache- we're updating it now
- station.recently_queried(event.payload)
- client = StreamClient(peer[0])
- peer_sockets.append(client)
- client.begin_handshake(station)
+ if not station.recently_queried(event.payload):
+ client = StreamClient(peer[0])
+ peer_sockets.append(client)
+ client.begin_handshake(station)
else:
# Peer's uuid is smaller, we should do nothing and await connection
log.info("Peer's uuid is smaller, awaiting connection")

0 comments on commit a7b05b8

Please sign in to comment.