709 |
pp.peer_last_recv <- p.peer_last_recv; |
pp.peer_last_recv <- p.peer_last_recv; |
710 |
pp |
pp |
711 |
with _ -> |
with _ -> |
712 |
|
|
713 |
|
let bucket = bucket_number p.peer_md4 in |
714 |
(* First, enter the peer in the boot_peers to be able to use at next |
(* First, enter the peer in the boot_peers to be able to use at next |
715 |
restart. *) |
restart. *) |
716 |
bootstrap p.peer_ip p.peer_port; |
if bucket <> 128 then |
717 |
|
bootstrap p.peer_ip p.peer_port; |
718 |
|
|
719 |
(* Now, enter it in the buckets *) |
(* bucket = 128 is returned for our very own ID, we dont want it in our buckets |
720 |
let bucket = bucket_number p.peer_md4 in |
Then, enter it in the buckets *) |
721 |
if bucket < !n_used_buckets then begin |
if bucket < !n_used_buckets && bucket <> 128 then begin |
722 |
|
|
723 |
if Fifo.length prebuckets.(bucket) = max_peers_per_prebucket then |
if Fifo.length prebuckets.(bucket) = max_peers_per_prebucket then |
724 |
begin |
begin |
743 |
incr pre_connected_peers |
incr pre_connected_peers |
744 |
end |
end |
745 |
end |
end |
746 |
else if !n_used_buckets < 128 then begin |
else if !n_used_buckets < 128 && bucket <> 128 then begin |
747 |
Fifo.put prebuckets.(!n_used_buckets) p; |
Fifo.put prebuckets.(!n_used_buckets) p; |
748 |
|
|
749 |
while !n_used_buckets < 128 && |
while !n_used_buckets < 128 && |