diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-08-30 19:45:30 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-08-30 19:45:30 +0200 |
commit | 193dc7fa8cf4b4d5c8ca9cb1a1836821e2069d87 (patch) | |
tree | a4296d890eedba5d52c9e3d3018e778443cc4fd6 /messagebus | |
parent | 3c3e1ce18b44e379dc8cc01455c18a39bb0d3306 (diff) | |
parent | 1cfca4dd53342f139866de60c570e5767ba5153f (diff) |
Merge pull request #18903 from vespa-engine/balder/avoid-copying-data
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, 2 insertions, 4 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 6ec3ea5ec7d..dbc6af42295 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,8 +100,7 @@ public class RPCSendV2 extends RPCSend { root.setLong(TRACELEVEL_F, traceLevel); root.setData(BLOB_F, payload); - byte[] serializedSlime = BinaryFormat.encode(slime); - Compressor.Compression compressionResult = compressor.compress(serializedSlime); + Compressor.Compression compressionResult = BinaryFormat.encode_and_compress(slime, compressor); v.add(new Int8Value(compressionResult.type().getCode())); v.add(new Int32Value(compressionResult.uncompressedSize())); @@ -200,8 +199,7 @@ public class RPCSendV2 extends RPCSend { } } - byte[] serializedSlime = BinaryFormat.encode(slime); - Compressor.Compression compressionResult = compressor.compress(serializedSlime); + Compressor.Compression compressionResult = BinaryFormat.encode_and_compress(slime, compressor); ret.add(new Int8Value(compressionResult.type().getCode())); ret.add(new Int32Value(compressionResult.uncompressedSize())); |