diff options
Diffstat (limited to 'clustercontroller-core')
-rw-r--r-- | clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlimeClusterStateBundleCodec.java | 9 |
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); } |