From a66474c41883733413a6851d49fb5ade892764b3 Mon Sep 17 00:00:00 2001 From: Robert Varga Date: Sat, 6 Nov 2021 10:20:00 +0100 Subject: [PATCH] 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 --- .../datastore/persisted/FrontendClientMetadata.java | 7 ++++--- .../datastore/persisted/FrontendHistoryMetadata.java | 9 +++++---- 2 files changed, 9 insertions(+), 7 deletions(-) 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(); -- 2.36.6