From 02104b161cdffc984c8df2abdc955ee426c884ac Mon Sep 17 00:00:00 2001 From: Steve Fan <29133953+stevefan1999-personal@users.noreply.github.com> Date: Sat, 13 Jun 2020 02:47:26 +0800 Subject: [PATCH 1/4] Update mod.rs --- tarpc/src/serde_transport/mod.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/tarpc/src/serde_transport/mod.rs b/tarpc/src/serde_transport/mod.rs index 7c1b7ff9a..e3b81d0e8 100644 --- a/tarpc/src/serde_transport/mod.rs +++ b/tarpc/src/serde_transport/mod.rs @@ -91,8 +91,10 @@ where Codec: Serializer + Deserializer, { fn from((inner, codec): (S, Codec)) -> Self { + let inner_frame = LengthDelimitedCodec::new(); + inner_codec.set_max_frame_length(128 * 1024 * 1024); Transport { - inner: SerdeFramed::new(Framed::new(inner, LengthDelimitedCodec::new()), codec), + inner: SerdeFramed::new(Framed::new(inner, inner_frame), codec), } } } From 4111dcc21eb978c53ee08840e7c8afb0a44d17b7 Mon Sep 17 00:00:00 2001 From: Steve Fan <29133953+stevefan1999-personal@users.noreply.github.com> Date: Sat, 13 Jun 2020 02:48:18 +0800 Subject: [PATCH 2/4] Update mod.rs --- tarpc/src/serde_transport/mod.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tarpc/src/serde_transport/mod.rs b/tarpc/src/serde_transport/mod.rs index e3b81d0e8..207892cdf 100644 --- a/tarpc/src/serde_transport/mod.rs +++ b/tarpc/src/serde_transport/mod.rs @@ -91,7 +91,7 @@ where Codec: Serializer + Deserializer, { fn from((inner, codec): (S, Codec)) -> Self { - let inner_frame = LengthDelimitedCodec::new(); + let inner_codec = LengthDelimitedCodec::new(); inner_codec.set_max_frame_length(128 * 1024 * 1024); Transport { inner: SerdeFramed::new(Framed::new(inner, inner_frame), codec), From 2b65fc4c17dfce5aa674b6c6d681c56cd568cd5f Mon Sep 17 00:00:00 2001 From: Steve Fan <29133953+stevefan1999-personal@users.noreply.github.com> Date: Sat, 13 Jun 2020 02:49:24 +0800 Subject: [PATCH 3/4] Update mod.rs --- tarpc/src/serde_transport/mod.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tarpc/src/serde_transport/mod.rs b/tarpc/src/serde_transport/mod.rs index 207892cdf..99e274adb 100644 --- a/tarpc/src/serde_transport/mod.rs +++ b/tarpc/src/serde_transport/mod.rs @@ -91,10 +91,10 @@ where Codec: Serializer + Deserializer, { fn from((inner, codec): (S, Codec)) -> Self { - let inner_codec = LengthDelimitedCodec::new(); + let mut inner_codec = LengthDelimitedCodec::new(); inner_codec.set_max_frame_length(128 * 1024 * 1024); Transport { - inner: SerdeFramed::new(Framed::new(inner, inner_frame), codec), + inner: SerdeFramed::new(Framed::new(inner, inner_codec), codec), } } } From 57f9294427dd34c449862612ccdc9524454f9288 Mon Sep 17 00:00:00 2001 From: Steve Fan <29133953+stevefan1999-personal@users.noreply.github.com> Date: Thu, 11 Jul 2024 03:09:19 +0800 Subject: [PATCH 4/4] add msgpack and cbor --- tarpc/Cargo.toml | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/tarpc/Cargo.toml b/tarpc/Cargo.toml index 879c01bce..83836a940 100644 --- a/tarpc/Cargo.toml +++ b/tarpc/Cargo.toml @@ -24,6 +24,8 @@ tokio1 = ["tokio/rt"] serde-transport = ["serde1", "tokio1", "tokio-serde", "tokio-util/codec"] serde-transport-json = ["tokio-serde/json"] serde-transport-bincode = ["tokio-serde/bincode"] +serde-transport-messagepack = ["tokio-serde/messagepack"] +serde-transport-cbor = ["tokio-serde/cbor"] tcp = ["tokio/net"] unix = ["tokio/net"] @@ -33,6 +35,8 @@ full = [ "serde-transport", "serde-transport-json", "serde-transport-bincode", + "serde-transport-messagepack", + "serde-transport-cbor", "tcp", "unix", ]