Try to establish more connections at once
This commit is contained in:
parent
9fd1006f2d
commit
a815fb2f7c
|
@ -71,13 +71,13 @@ class Manager(threading.Thread):
|
||||||
outgoing_connections += 1
|
outgoing_connections += 1
|
||||||
if outgoing_connections < shared.outgoing_connections and shared.send_outgoing_connections:
|
if outgoing_connections < shared.outgoing_connections and shared.send_outgoing_connections:
|
||||||
to_connect = set()
|
to_connect = set()
|
||||||
if len(shared.unchecked_node_pool) > 12:
|
if len(shared.unchecked_node_pool) > 16:
|
||||||
to_connect.update(random.sample(shared.unchecked_node_pool, 12))
|
to_connect.update(random.sample(shared.unchecked_node_pool, 16))
|
||||||
else:
|
else:
|
||||||
to_connect.update(shared.unchecked_node_pool)
|
to_connect.update(shared.unchecked_node_pool)
|
||||||
shared.unchecked_node_pool.difference_update(to_connect)
|
shared.unchecked_node_pool.difference_update(to_connect)
|
||||||
if len(shared.node_pool) > 6:
|
if len(shared.node_pool) > 8:
|
||||||
to_connect.update(random.sample(shared.node_pool, 6))
|
to_connect.update(random.sample(shared.node_pool, 8))
|
||||||
else:
|
else:
|
||||||
to_connect.update(shared.node_pool)
|
to_connect.update(shared.node_pool)
|
||||||
for addr in to_connect:
|
for addr in to_connect:
|
||||||
|
|
Loading…
Reference in New Issue
Block a user