From 35bccd05b1054128ac83598d59e01f58a5b89371 Mon Sep 17 00:00:00 2001 From: Pietro Abate Date: Thu, 13 Dec 2018 09:03:43 +0100 Subject: [PATCH] Mempool: fix minor copyright and docstring strings and change Work.work in Work.process_batch --- src/lib_shell/mempool_peer_worker.ml | 6 +++--- src/lib_shell/mempool_peer_worker.mli | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/lib_shell/mempool_peer_worker.ml b/src/lib_shell/mempool_peer_worker.ml index 3f872b119..f97a9431e 100644 --- a/src/lib_shell/mempool_peer_worker.ml +++ b/src/lib_shell/mempool_peer_worker.ml @@ -100,7 +100,7 @@ module Make (Static: STATIC) (Mempool_worker: Mempool_worker.T) (* 1. Core: the carefully scheduled work performed by the worker *) module Work : sig - val work: Mempool_worker.t -> int -> input -> output Lwt.t + val process_batch: Mempool_worker.t -> int -> input -> output Lwt.t end = struct type t = { pool: unit Lwt_pool.t; @@ -217,7 +217,7 @@ module Make (Static: STATIC) (Mempool_worker: Mempool_worker.T) select pipeline >>= fun () -> Lwt.return_unit - let work mempool_worker pool_size input = + let process_batch mempool_worker pool_size input = let pipeline = create pool_size input in let rec loop () = if is_empty pipeline then @@ -342,7 +342,7 @@ module Make (Static: STATIC) (Mempool_worker: Mempool_worker.T) = fun t (Request.Batch os) -> let st = Worker.state t in Worker.record_event t (Event.Start os) ; - Work.work st.mempool_worker st.pool_size os >>= fun r -> + Work.process_batch st.mempool_worker st.pool_size os >>= fun r -> return r let on_no_request _ = return_unit diff --git a/src/lib_shell/mempool_peer_worker.mli b/src/lib_shell/mempool_peer_worker.mli index 144845dc7..105f5f4cb 100644 --- a/src/lib_shell/mempool_peer_worker.mli +++ b/src/lib_shell/mempool_peer_worker.mli @@ -2,6 +2,7 @@ (* *) (* Open Source License *) (* Copyright (c) 2018 Dynamic Ledger Solutions, Inc. *) +(* Copyright (c) 2018 Nomadic Labs, *) (* *) (* Permission is hereby granted, free of charge, to any person obtaining a *) (* copy of this software and associated documentation files (the "Software"),*) @@ -46,8 +47,7 @@ module type T = sig (** [create limits peer_id mempool_worker] creates a peer worker meant * to be used for validating batches of operations sent by the peer [peer_id]. - * The [mempool_worker] the underlying worker that individual validations of - * singular operations are delegated to. *) + * The validation of each operations is delegated to the associated [mempool_worker]. *) val create: limits -> P2p_peer.Id.t -> Mempool_worker.t -> t Lwt.t (** [shutdown t] closes the peer worker [t]. It returns a list of operation