diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-08-30 20:52:50 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-08-30 20:52:50 +0200 |
commit | 26b09e283a21d3e123f63db041d16e2eae0a54e0 (patch) | |
tree | f7f31ba59b708ee9c93a48629f3d1f24a32a886f /messagebus | |
parent | 193dc7fa8cf4b4d5c8ca9cb1a1836821e2069d87 (diff) |
Revert "Avoid copying data just to compress them when it is not necessary."
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendV2.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendV2.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendV2.java index dbc6af42295..6ec3ea5ec7d 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendV2.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendV2.java @@ -100,7 +100,8 @@ public class RPCSendV2 extends RPCSend { root.setLong(TRACELEVEL_F, traceLevel); root.setData(BLOB_F, payload); - Compressor.Compression compressionResult = BinaryFormat.encode_and_compress(slime, compressor); + byte[] serializedSlime = BinaryFormat.encode(slime); + Compressor.Compression compressionResult = compressor.compress(serializedSlime); v.add(new Int8Value(compressionResult.type().getCode())); v.add(new Int32Value(compressionResult.uncompressedSize())); @@ -199,7 +200,8 @@ public class RPCSendV2 extends RPCSend { } } - Compressor.Compression compressionResult = BinaryFormat.encode_and_compress(slime, compressor); + byte[] serializedSlime = BinaryFormat.encode(slime); + Compressor.Compression compressionResult = compressor.compress(serializedSlime); ret.add(new Int8Value(compressionResult.type().getCode())); ret.add(new Int32Value(compressionResult.uncompressedSize())); |