balsoft/ligo
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Shell/Distributed_db: tune requests delay

Browse Source
This commit is contained in:
Grégoire Henry 2018-04-20 21:04:29 +02:00 committed by Benjamin Canou
parent f2db5ffde3
commit c9eab8689a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/lib_shell/distributed_db_functors.ml
View File

@ -406,7 +406,7 @@ end = struct
| Some peer -> P2p_peer.Id.pp_short ppf peer | Some peer -> P2p_peer.Id.pp_short ppf peer
(* TODO should depend on the ressource kind... *) (* TODO should depend on the ressource kind... *)
let initial_delay = 0.1 let initial_delay = 0.5
let process_event state now = function let process_event state now = function
| Request (peer, key) -> begin | Request (peer, key) -> begin
@ -503,7 +503,7 @@ end = struct
else remaining_peers) in else remaining_peers) in
let next = { peers = remaining_peers ; let next = { peers = remaining_peers ;
next_request = now +. delay ; next_request = now +. delay ;
delay = delay *. 1.2 } in delay = delay *. 1.5 } in
Table.replace state.pending key next ; Table.replace state.pending key next ;
let requests = let requests =
try key :: P2p_peer.Map.find requested_peer acc try key :: P2p_peer.Map.find requested_peer acc