feat(perf): support iperf-style intermittent results

Pull-Request: #4382.

.github/workflows/ci.yml

@@ -52,7 +52,7 @@ jobs:
         run: cargo build --package "$CRATE" --no-default-features
 
       - name: Enforce no dependency on meta crate
-        if: env.CRATE != 'libp2p-server'
+        if: env.CRATE != 'libp2p-server' && env.CRATE != 'libp2p-perf'
         run: |
           cargo metadata --format-version=1 --no-deps | \
           jq -e -r '.packages[] | select(.name == "'"$CRATE"'") | .dependencies | all(.name != "libp2p")'

Cargo.toml

@@ -90,7 +90,7 @@ libp2p-metrics = { version = "0.14.0", path = "misc/metrics" }
 libp2p-mplex = { version = "0.41.0", path = "muxers/mplex" }
 libp2p-muxer-test-harness = { path = "muxers/test-harness" }
 libp2p-noise = { version = "0.44.0", path = "transports/noise" }
-libp2p-perf = { version = "0.2.0", path = "protocols/perf" }
+libp2p-perf = { version = "0.3.0", path = "protocols/perf" }
 libp2p-ping = { version = "0.44.0", path = "protocols/ping" }
 libp2p-plaintext = { version = "0.41.0", path = "transports/plaintext" }
 libp2p-pnet = { version = "0.24.0", path = "transports/pnet" }

protocols/perf/CHANGELOG.md

@@ -1,4 +1,10 @@
-## 0.2.0 
+## 0.3.0 - unreleased
+
+- Continuously measure on single connection (iperf-style).
+  See https://github.com/libp2p/test-plans/issues/261 for high level overview.
+  See [PR 4382](https://github.com/libp2p/rust-libp2p/pull/4382).
+
+## 0.2.0
 
 - Raise MSRV to 1.65.
   See [PR 3715].

protocols/perf/Cargo.toml

@@ -3,7 +3,7 @@ name = "libp2p-perf"
 edition = "2021"
 rust-version = { workspace = true }
 description = "libp2p perf protocol implementation"
-version = "0.2.0"
+version = "0.3.0"
 authors = ["Max Inden <[email protected]>"]
 license = "MIT"
 repository = "https://github.com/libp2p/rust-libp2p"
@@ -12,25 +12,26 @@ categories = ["network-programming", "asynchronous"]
 
 [dependencies]
 anyhow = "1"
-async-trait = "0.1"
 clap = { version = "4.4.6", features = ["derive"] }
 env_logger = "0.10.0"
 futures = "0.3.28"
+futures-bounded = { workspace = true }
+futures-timer = "3.0"
 instant = "0.1.12"
+libp2p = { workspace = true, features = ["tokio", "tcp", "quic", "tls", "yamux", "dns"] }
 libp2p-core = { workspace = true }
 libp2p-dns = { workspace = true, features = ["tokio"] }
 libp2p-identity = { workspace = true, features = ["rand"] }
-libp2p-tls = { workspace = true }
 libp2p-quic = { workspace = true, features = ["tokio"] }
-libp2p-request-response = { workspace = true }
 libp2p-swarm = { workspace = true, features = ["macros", "tokio"] }
 libp2p-tcp = { workspace = true, features = ["tokio"] }
+libp2p-tls = { workspace = true }
 libp2p-yamux = { workspace = true }
 log = "0.4"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 thiserror = "1.0"
-tokio = { version = "1.33.0", features = ["full"] }
+tokio = { version = "1.33", default-features = false, features = ["macros", "rt", "rt-multi-thread"] }
 void = "1"
 
 [dev-dependencies]