mirror of
https://github.com/zap-proto/ocaml-rpc.git
synced 2026-10-30 15:04:28 +00:00
Thomas Leonard
dd0c6029d9
Sending each message in its own TCP packet isn't very efficient, and also interacts very badly with Nagle's algorithm. See https://roscidus.com/blog/blog/2024/07/22/performance/ for details. Note: The Prometheus metrics `messages_outbound_sent_total` and `messages_outbound_dropped_total` have gone. They weren't very useful and we no longer know the number of messages by the time the connection is dropped (could report dropped bytes if needed though). dune exec -- ./test-bin/echo/echo_bench.exe echo_bench.exe: [INFO] rate = 522.989613 # Before echo_bench.exe: [INFO] rate = 62439.433376 # After This commit also improves the log messages a bit.
42 lines
1.2 KiB
OCaml
42 lines
1.2 KiB
OCaml
(** A network using TCP and Unix-domain sockets. *)
|
|
|
|
open Eio.Std
|
|
|
|
module Location : sig
|
|
type t = [
|
|
| `Unix of string
|
|
| `TCP of string * int
|
|
]
|
|
|
|
val validate_public : t -> unit
|
|
(** Raises an exception if [t] is not a valid public address (e.g. the Unix path is relative) *)
|
|
|
|
val pp : t Fmt.t
|
|
|
|
val equal : t -> t -> bool
|
|
|
|
val unix : string -> t
|
|
(** [unix path] is a Unix-domain socket address. [path] is made absolute if it isn't already. *)
|
|
|
|
val tcp : host:string -> port:int -> t
|
|
(** [tcp ~host port] is [`TCP (host, port)]. *)
|
|
|
|
val of_string : string -> (t, [> `Msg of string]) result
|
|
|
|
val cmdliner_conv : t Cmdliner.Arg.conv
|
|
end
|
|
|
|
include Capnp_rpc_net.S.NETWORK with
|
|
type t = [`Generic] Eio.Net.ty Eio.Resource.t and
|
|
type Address.t = Location.t * Capnp_rpc_net.Auth.Digest.t
|
|
|
|
val v : _ Eio.Net.t -> t
|
|
|
|
val accept_connection :
|
|
secret_key:Capnp_rpc_net.Auth.Secret_key.t option ->
|
|
[> Eio.Flow.two_way_ty | Eio.Resource.close_ty] r ->
|
|
(Capnp_rpc_net.Endpoint.t, [> `Msg of string]) result
|
|
(** [accept_connection ~secret_key flow] is a new endpoint for [flow].
|
|
If [secret_key] is not [None], it is used to perform a TLS server-side handshake.
|
|
Otherwise, the connection is not encrypted. *)
|