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

Shell/mempool: bounded peer-workers request-queue size

Browse Source
This commit is contained in:
Raphaël Proust 2018-11-15 12:28:48 +08:00 committed by MBourgoin
parent 31242ebcb9
commit 7cbf457888
No known key found for this signature in database
GPG Key ID: 4B3F7008ABB5B2D0
2 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/lib_shell/mempool_peer_worker.ml
View File

@ -44,7 +44,12 @@ module type T = sig
end end
module Make (Mempool_worker: Mempool_worker.T)
module type STATIC = sig
val max_pending_requests : int
end
module Make (Static: STATIC) (Mempool_worker: Mempool_worker.T)
: T with module Mempool_worker = Mempool_worker : T with module Mempool_worker = Mempool_worker
= struct = struct
@ -318,8 +323,10 @@ module Make (Mempool_worker: Mempool_worker.T)
end end
module Worker = Worker.Make (Name) (Event) (Request) (Types) module Worker = Worker.Make (Name) (Event) (Request) (Types)
type t = Worker.infinite Worker.queue Worker.t type t = Worker.bounded Worker.queue Worker.t
let table = Worker.create_table Queue let table =
let open Worker in
create_table (Bounded { size = Static.max_pending_requests })
(* 3. Workers' work: setting workers' callbacks to perform core work *) (* 3. Workers' work: setting workers' callbacks to perform core work *)

6
src/lib_shell/mempool_peer_worker.mli
View File

@ -63,5 +63,9 @@ module type T = sig
end end
module Make (Mempool_worker : Mempool_worker.T) module type STATIC = sig
val max_pending_requests : int
end
module Make (Static: STATIC) (Mempool_worker: Mempool_worker.T)
: T with module Mempool_worker = Mempool_worker : T with module Mempool_worker = Mempool_worker