From: Robert Varga Date: Sat, 6 Nov 2021 09:20:00 +0000 (+0100) Subject: Improve Frontend{Client,History}Metadata X-Git-Tag: v2.0.10~31 X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=commitdiff_plain;h=2fca7b79e92e8bd5a78c1ea530c04e67f4d81d4f Improve Frontend{Client,History}Metadata We are using Guava's immutable implementations, make sure we annotate fields with @NonNull and use concrete types. Change-Id: I4fc2a0ff39b2b8166deca41425771ea9ed04e469 Signed-off-by: Robert Varga (cherry picked from commit a66474c41883733413a6851d49fb5ade892764b3) (cherry picked from commit c3bbe471b3743b5145c67325839b0c2a36bc5275) --- diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/FrontendClientMetadata.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/FrontendClientMetadata.java index c9b2430528..c1199699ec 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/FrontendClientMetadata.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/FrontendClientMetadata.java @@ -22,15 +22,16 @@ import java.io.IOException; import java.util.ArrayList; import java.util.Collection; import java.util.Set; +import org.eclipse.jdt.annotation.NonNull; import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier; import org.opendaylight.yangtools.concepts.Identifiable; import org.opendaylight.yangtools.concepts.WritableObject; import org.opendaylight.yangtools.concepts.WritableObjects; public final class FrontendClientMetadata implements Identifiable, WritableObject { - private final Collection currentHistories; - private final RangeSet purgedHistories; - private final ClientIdentifier identifier; + private final @NonNull ImmutableList currentHistories; + private final @NonNull ImmutableRangeSet purgedHistories; + private final @NonNull ClientIdentifier identifier; public FrontendClientMetadata(final ClientIdentifier identifier, final RangeSet purgedHistories, final Collection currentHistories) { diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/FrontendHistoryMetadata.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/FrontendHistoryMetadata.java index fc0bd442c8..e9a076e5c7 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/FrontendHistoryMetadata.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/FrontendHistoryMetadata.java @@ -22,12 +22,13 @@ import java.util.HashMap; import java.util.Map; import java.util.Map.Entry; import java.util.Set; +import org.eclipse.jdt.annotation.NonNull; import org.opendaylight.yangtools.concepts.WritableObject; import org.opendaylight.yangtools.concepts.WritableObjects; public final class FrontendHistoryMetadata implements WritableObject { - private final RangeSet purgedTransactions; - private final Map closedTransactions; + private final @NonNull ImmutableRangeSet purgedTransactions; + private final @NonNull ImmutableMap closedTransactions; private final long historyId; private final long cookie; private final boolean closed; @@ -70,7 +71,7 @@ public final class FrontendHistoryMetadata implements WritableObject { WritableObjects.writeLongs(out, closedTransactions.size(), purgedRanges.size()); for (Entry e : closedTransactions.entrySet()) { WritableObjects.writeLong(out, e.getKey().longValue()); - out.writeBoolean(e.getValue().booleanValue()); + out.writeBoolean(e.getValue()); } for (Range r : purgedRanges) { WritableObjects.writeLongs(out, r.lowerEndpoint().longValue(), r.upperEndpoint().longValue()); @@ -95,7 +96,7 @@ public final class FrontendHistoryMetadata implements WritableObject { final Map closedTransactions = new HashMap<>(csize); for (int i = 0; i < csize; ++i) { final UnsignedLong key = UnsignedLong.fromLongBits(WritableObjects.readLong(in)); - final Boolean value = Boolean.valueOf(in.readBoolean()); + final Boolean value = in.readBoolean(); closedTransactions.put(key, value); } final RangeSet purgedTransactions = TreeRangeSet.create();