2 * Copyright (c) 2022 PANTHEON.tech, s.r.o. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.controller.cluster.datastore.persisted;
10 import static com.google.common.base.Verify.verifyNotNull;
11 import static java.util.Objects.requireNonNull;
13 import java.io.Externalizable;
14 import java.io.IOException;
15 import java.io.ObjectInput;
16 import java.io.ObjectOutput;
17 import java.io.StreamCorruptedException;
18 import org.opendaylight.controller.cluster.datastore.persisted.CommitTransactionPayload.Chunked;
19 import org.opendaylight.controller.cluster.datastore.persisted.CommitTransactionPayload.Simple;
20 import org.opendaylight.controller.cluster.io.ChunkedByteArray;
23 * Serialization proxy for {@link CommitTransactionPayload}.
25 final class CT implements Externalizable {
27 private static final long serialVersionUID = 1L;
29 private CommitTransactionPayload payload;
31 @SuppressWarnings("checkstyle:RedundantModifier")
36 CT(final CommitTransactionPayload payload) {
37 this.payload = requireNonNull(payload);
41 public void writeExternal(final ObjectOutput out) throws IOException {
42 out.writeInt(payload.size());
43 payload.writeBytes(out);
47 public void readExternal(final ObjectInput in) throws IOException {
48 final int length = in.readInt();
50 throw new StreamCorruptedException("Invalid payload length " + length);
51 } else if (length < CommitTransactionPayload.MAX_ARRAY_SIZE) {
52 final byte[] serialized = new byte[length];
53 in.readFully(serialized);
54 payload = new Simple(serialized);
56 payload = new Chunked(ChunkedByteArray.readFrom(in, length, CommitTransactionPayload.MAX_ARRAY_SIZE));
61 private Object readResolve() {
62 return verifyNotNull(payload);