summaryrefslogtreecommitdiffstats
path: root/clustercontroller-core/src
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-08-30 20:54:26 +0200
committerGitHub <noreply@github.com>2021-08-30 20:54:26 +0200
commit2c08131faa2a3df78a47f4cdabd2ff7791d15c0c (patch)
treef7f31ba59b708ee9c93a48629f3d1f24a32a886f /clustercontroller-core/src
parent193dc7fa8cf4b4d5c8ca9cb1a1836821e2069d87 (diff)
parent26b09e283a21d3e123f63db041d16e2eae0a54e0 (diff)
Merge pull request #18905 from vespa-engine/revert-18903-balder/avoid-copying-data
Revert "Avoid copying data just to compress them when it is not necessary."
Diffstat (limited to 'clustercontroller-core/src')
-rw-r--r--clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlimeClusterStateBundleCodec.java9
1 files changed, 3 insertions, 6 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlimeClusterStateBundleCodec.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlimeClusterStateBundleCodec.java
index 5799406ef4b..1a3184955d5 100644
--- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlimeClusterStateBundleCodec.java
+++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlimeClusterStateBundleCodec.java
@@ -3,11 +3,7 @@ package com.yahoo.vespa.clustercontroller.core.rpc;
import com.yahoo.compress.CompressionType;
import com.yahoo.compress.Compressor;
-import com.yahoo.slime.BinaryFormat;
-import com.yahoo.slime.Cursor;
-import com.yahoo.slime.Inspector;
-import com.yahoo.slime.ObjectTraverser;
-import com.yahoo.slime.Slime;
+import com.yahoo.slime.*;
import com.yahoo.vdslib.state.ClusterState;
import com.yahoo.vespa.clustercontroller.core.AnnotatedClusterState;
import com.yahoo.vespa.clustercontroller.core.ClusterStateBundle;
@@ -51,7 +47,8 @@ public class SlimeClusterStateBundleCodec implements ClusterStateBundleCodec, En
feedBlock.setString("description", stateBundle.getFeedBlock().get().getDescription());
}
- Compressor.Compression compression = BinaryFormat.encode_and_compress(slime, compressor);
+ byte[] serialized = BinaryFormat.encode(slime);
+ Compressor.Compression compression = compressor.compress(serialized);
return EncodedClusterStateBundle.fromCompressionBuffer(compression);
}