add benchmark.

Author: caiweiwei03

.gitignore

@@ -1,3 +1,5 @@
-/target
+target/
 **/*.rs.bk
 Cargo.lock
+
+

Cargo.toml

@@ -12,4 +12,5 @@ members = [
 # internal
 "examples",
 "rsocket-test",
+"rsocket-benchmark",
 ]

examples/Cargo.toml

@@ -21,7 +21,7 @@ path = "../rsocket-transport-tcp"
 path = "../rsocket-transport-websocket"
 
 [dev-dependencies.tokio]
-version = "0.2.19"
+version = "0.2.20"
 default-features = false
 features = ["full"]
 

rsocket-benchmark/Cargo.toml

@@ -0,0 +1,40 @@
+[package]
+name = "rsocket_rust_benchmark"
+version = "0.0.0"
+authors = ["Jeffsky <jjeffcaii@outlook.com>"]
+edition = "2018"
+publish = false
+
+[dev-dependencies]
+log = "0.4"
+futures = "0.3.4"
+env_logger = "0.7.1"
+bytes = "0.5.4"
+hex = "0.4.2"
+rand = "0.7.3"
+serde = "1.0.106"
+serde_derive = "1.0.106"
+criterion = "0.3.2"
+
+[dev-dependencies.rsocket_rust]
+path = "../rsocket"
+features = ["frame"]
+
+[dev-dependencies.rsocket_rust_transport_tcp]
+path = "../rsocket-transport-tcp"
+
+[dev-dependencies.rsocket_rust_transport_websocket]
+path = "../rsocket-transport-websocket"
+
+[dev-dependencies.rsocket_rust_messaging]
+path = "../rsocket-messaging"
+
+[dev-dependencies.tokio]
+version = "0.2.20"
+default-features = false
+features = ["full"]
+
+[[bench]]
+name = "bench_main"
+path = "benchmark_main.rs"
+harness = false

rsocket-benchmark/benchmark_main.rs

@@ -0,0 +1,8 @@
+use criterion::criterion_main;
+
+mod benchmarks;
+
+criterion_main! {
+    benchmarks::fibonaccis::benches,
+    benchmarks::frames::benches,
+}

rsocket-benchmark/benchmarks/fibonaccis.rs

@@ -0,0 +1,15 @@
+use criterion::{black_box, criterion_group, Criterion};
+
+fn fibonacci(n: u64) -> u64 {
+    match n {
+        0 => 1,
+        1 => 1,
+        n => fibonacci(n - 1) + fibonacci(n - 2),
+    }
+}
+
+fn fibonaccis_benchmark(c: &mut Criterion) {
+    c.bench_function("fib 20", |b| b.iter(|| fibonacci(black_box(20))));
+}
+
+criterion_group!(benches, fibonaccis_benchmark);

rsocket-benchmark/benchmarks/frames.rs

@@ -0,0 +1,19 @@
+use bytes::{Bytes, BytesMut};
+use criterion::{criterion_group, Criterion};
+use rsocket_rust::frame::*;
+use rsocket_rust::utils::Writeable;
+
+fn bench_unmarshal_request_response(c: &mut Criterion) {
+    c.bench_function("unmarshal request_response", |b| {
+        b.iter(|| {
+            let f = RequestResponse::builder(1234, 0)
+                .set_data(Bytes::from("Hello World"))
+                .set_metadata(Bytes::from("Foobar"))
+                .build();
+            let mut bf = BytesMut::with_capacity(f.len() as usize);
+            f.write_to(&mut bf);
+        })
+    });
+}
+
+criterion_group!(benches, bench_unmarshal_request_response);

rsocket-benchmark/benchmarks/mod.rs

@@ -0,0 +1,2 @@
+pub mod fibonaccis;
+pub mod frames;

rsocket-messaging/src/lib.rs

@@ -1,6 +1,3 @@
-#[macro_use]
-extern crate log;
-
 mod misc;
 mod requester;
 

rsocket-messaging/src/requester.rs

@@ -1,5 +1,5 @@
 use super::misc::{marshal, unmarshal};
-use bytes::{BufMut, BytesMut};
+use bytes::BytesMut;
 use rsocket_rust::error::RSocketError;
 use rsocket_rust::extension::{
     CompositeMetadata, MimeType, RoutingMetadata, MIME_APPLICATION_JSON,