diff --git a/src/lib_p2p/p2p_socket.ml b/src/lib_p2p/p2p_socket.ml index fe4f4d5e3..2b7911d14 100644 --- a/src/lib_p2p/p2p_socket.ml +++ b/src/lib_p2p/p2p_socket.ml @@ -99,7 +99,7 @@ end bytes, whereas the option is set in kbytes. Also, since the default size is 64kB-1, it is actually impossible to set the default size using the option (the max is 63 kB). *) -let check_binary_chunks_size size = +let check_binary_chunks_size size = let value = size - Crypto.extrabytes in fail_unless (value > 0 && @@ -347,7 +347,7 @@ module Reader = struct match status with | Success { result ; size ; stream } -> return_some (result, size, stream) - | Error _ -> + | Error _err -> lwt_debug "[read_message] incremental decoding error" >>= fun () -> return_none | Await decode_next_buf -> diff --git a/src/lib_p2p/p2p_socket.mli b/src/lib_p2p/p2p_socket.mli index 755b32fe6..9688d5fef 100644 --- a/src/lib_p2p/p2p_socket.mli +++ b/src/lib_p2p/p2p_socket.mli @@ -74,7 +74,7 @@ val authenticate: [P2P_io_scheduler.connection] into an [authenticated_connection] (auth correct, acceptation undecided). *) -val kick: 'meta authenticated_connection -> unit Lwt.t +val kick: 'meta authenticated_connection -> P2p_point.Id.t list -> unit Lwt.t (** (Low-level) (Cancelable) [kick afd] notifies the remote peer that we refuse this connection and then closes [afd]. Used in [P2p_connection_pool] to reject an [authenticated_connection] which we do @@ -90,7 +90,7 @@ val accept: authenticated_connection. Used in [P2p_connection_pool], to promote an [authenticated_connection] to the status of an active peer. *) -val check_binary_chunks_size: int -> unit tzresult Lwt.t +val check_binary_chunks_size: int -> unit tzresult Lwt.t (** Precheck for the [?binary_chunks_size] parameter of [accept]. *) (** {1 IO functions on connections} *)