LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

some pep8 fixes

Browse source
This commit is contained in:
Kay Kurokawa 2017-08-15 20:05:03 -04:00
parent e2e28338f3
commit e0985695ac
1 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lbrynet/core/client/ConnectionManager.py
View file

@ -168,8 +168,7 @@ class ConnectionManager(object):
return [] return []
out = [peer for peer in peers if peer not in self._peer_connections] out = [peer for peer in peers if peer not in self._peer_connections]
random.shuffle(out) random.shuffle(out)
out = out[0:new_conns_needed] return out[0:new_conns_needed]
return out
@defer.inlineCallbacks @defer.inlineCallbacks
def _get_new_peers(self): def _get_new_peers(self):
@ -182,7 +181,7 @@ class ConnectionManager(object):
log.debug("%s Trying to get a new peer to connect to", self._get_log_name()) log.debug("%s Trying to get a new peer to connect to", self._get_log_name())
# find peers for the head blob if configured to do so # find peers for the head blob if configured to do so
if self.seek_head_blob_first is True: if self.seek_head_blob_first:
peers = yield request_creator.get_new_peers_for_head_blob() peers = yield request_creator.get_new_peers_for_head_blob()
peers = self.return_shuffled_peers_not_connected_to(peers, new_conns_needed) peers = self.return_shuffled_peers_not_connected_to(peers, new_conns_needed)
else: else:
@ -190,7 +189,7 @@ class ConnectionManager(object):
# we didn't find any new peers on the head blob, # we didn't find any new peers on the head blob,
# we have to look for the first unavailable blob # we have to look for the first unavailable blob
if len(peers) == 0: if not peers:
peers = yield request_creator.get_new_peers_for_next_unavailable() peers = yield request_creator.get_new_peers_for_next_unavailable()
peers = self.return_shuffled_peers_not_connected_to(peers, new_conns_needed) peers = self.return_shuffled_peers_not_connected_to(peers, new_conns_needed)