[p2p] fix space for semicolon and pipe
This commit is contained in:
parent
0f1916981b
commit
b27bb84861
@ -98,7 +98,7 @@ let rec maintain st =
|
|||||||
let older_than =
|
let older_than =
|
||||||
Time.(add (now ()) (Int64.of_int (- pool_cfg.greylist_timeout)))
|
Time.(add (now ()) (Int64.of_int (- pool_cfg.greylist_timeout)))
|
||||||
in
|
in
|
||||||
P2p_pool.gc_greylist pool ~older_than;
|
P2p_pool.gc_greylist pool ~older_than ;
|
||||||
if n_connected < st.bounds.min_threshold then
|
if n_connected < st.bounds.min_threshold then
|
||||||
too_few_connections st n_connected
|
too_few_connections st n_connected
|
||||||
else if st.bounds.max_threshold < n_connected then
|
else if st.bounds.max_threshold < n_connected then
|
||||||
|
@ -219,7 +219,7 @@ type ('msg, 'meta) t = {
|
|||||||
encoding : 'msg Message.t Data_encoding.t ;
|
encoding : 'msg Message.t Data_encoding.t ;
|
||||||
events : events ;
|
events : events ;
|
||||||
watcher : P2p_connection.Pool_event.t Lwt_watcher.input ;
|
watcher : P2p_connection.Pool_event.t Lwt_watcher.input ;
|
||||||
acl : P2p_acl.t;
|
acl : P2p_acl.t ;
|
||||||
mutable new_connection_hook :
|
mutable new_connection_hook :
|
||||||
(P2p_peer.Id.t -> ('msg, 'meta) connection -> unit) list ;
|
(P2p_peer.Id.t -> ('msg, 'meta) connection -> unit) list ;
|
||||||
mutable latest_accepted_swap : Time.t ;
|
mutable latest_accepted_swap : Time.t ;
|
||||||
@ -414,8 +414,8 @@ let get_addr pool peer_id =
|
|||||||
| _ -> None)
|
| _ -> None)
|
||||||
in
|
in
|
||||||
match find_by_peer_id peer_id with
|
match find_by_peer_id peer_id with
|
||||||
|None -> None
|
| None -> None
|
||||||
|Some ci ->
|
| Some ci ->
|
||||||
let info = P2p_socket.info ci.conn in
|
let info = P2p_socket.info ci.conn in
|
||||||
Some(info.id_point)
|
Some(info.id_point)
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user