diff options
author | shahan <shahan@google.com> | 2018-05-10 09:32:47 -0700 |
---|---|---|
committer | Copybara-Service <copybara-piper@google.com> | 2018-05-10 09:34:31 -0700 |
commit | 494161c52c886c198f8d71b22896923ea536aa3d (patch) | |
tree | fd562202b674b8b86bd7498fd9b4ce85f73b8449 /src/main/java/com/google/devtools/build/lib/skyframe/serialization | |
parent | feeccd8c0a5d97493cabfeb9481cf6f3800b9b84 (diff) |
Codec for FluentIterable - needed to serialize results of Iterables.concat.
PiperOrigin-RevId: 196127040
Diffstat (limited to 'src/main/java/com/google/devtools/build/lib/skyframe/serialization')
-rw-r--r-- | src/main/java/com/google/devtools/build/lib/skyframe/serialization/FluentIterableCodec.java | 51 |
1 files changed, 51 insertions, 0 deletions
diff --git a/src/main/java/com/google/devtools/build/lib/skyframe/serialization/FluentIterableCodec.java b/src/main/java/com/google/devtools/build/lib/skyframe/serialization/FluentIterableCodec.java new file mode 100644 index 0000000000..13774bdfc6 --- /dev/null +++ b/src/main/java/com/google/devtools/build/lib/skyframe/serialization/FluentIterableCodec.java @@ -0,0 +1,51 @@ +// Copyright 2018 The Bazel Authors. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +package com.google.devtools.build.lib.skyframe.serialization; + +import com.google.common.collect.FluentIterable; +import com.google.protobuf.CodedInputStream; +import com.google.protobuf.CodedOutputStream; +import java.io.IOException; + +/** An {@link ObjectCodec} for {@link FluentIterable}. */ +@SuppressWarnings("rawtypes") // Deliberate erasure of FluentIterable. +final class FluentIterableCodec implements ObjectCodec<FluentIterable> { + + @Override + public Class<FluentIterable> getEncodedClass() { + return FluentIterable.class; + } + + @Override + public void serialize( + SerializationContext context, FluentIterable object, CodedOutputStream codedOut) + throws IOException, SerializationException { + codedOut.writeInt32NoTag(object.size()); + for (Object obj : object) { + context.serialize(obj, codedOut); + } + } + + @Override + public FluentIterable deserialize(DeserializationContext context, CodedInputStream codedIn) + throws IOException, SerializationException { + int size = codedIn.readInt32(); + Object[] list = new Object[size]; + for (int i = 0; i < size; ++i) { + list[i] = context.deserialize(codedIn); + } + return FluentIterable.from(list); + } +} |