*/
package org.opendaylight.controller.cluster.datastore;
+import com.google.common.base.MoreObjects;
import com.google.common.base.Preconditions;
import com.google.common.base.Verify;
import com.google.common.collect.Collections2;
private FrontendHistoryMetadataBuilder getHistory(final TransactionIdentifier txId) {
return currentHistories.get(txId.getHistoryId());
}
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper(this).add("identifier", identifier).add("current", currentHistories)
+ .add("purged", purgedHistories).toString();
+ }
}
@Override
void reset() {
+ LOG.debug("{}: clearing clients {}", shardName, clients);
clients.clear();
}
@Override
void doApplySnapshot(final FrontendShardDataTreeSnapshotMetadata snapshot) {
+ LOG.debug("{}: applying snapshot {} over clients {}", shardName, snapshot, clients);
clients.clear();
for (FrontendClientMetadata m : snapshot.getClients()) {
- clients.put(m.getIdentifier().getFrontendId(), new FrontendClientMetadataBuilder(m));
+ LOG.debug("{}: applying metadata {}", shardName, m);
+ final FrontendClientMetadataBuilder b = new FrontendClientMetadataBuilder(m);
+ final FrontendIdentifier client = m.getIdentifier().getFrontendId();
+
+ LOG.debug("{}: client {} updated to {}", shardName, client, b);
+ clients.put(client, b);
}
}
} else {
allMetadataClosedLocalHistory(((CloseLocalHistoryPayload) payload).getIdentifier());
}
- } else if (payload instanceof CloseLocalHistoryPayload) {
- if (identifier != null) {
- payloadReplicationComplete((CloseLocalHistoryPayload) payload);
- } else {
- allMetadataClosedLocalHistory(((CloseLocalHistoryPayload) payload).getIdentifier());
- }
} else if (payload instanceof CreateLocalHistoryPayload) {
if (identifier != null) {
payloadReplicationComplete((CreateLocalHistoryPayload)payload);
@Override
public void createSnapshot(final ActorRef actorRef, final Optional<OutputStream> installSnapshotStream) {
// Forward the request to the snapshot actor
- ShardSnapshotActor.requestSnapshot(snapshotActor, store.takeStateSnapshot(), installSnapshotStream, actorRef);
+ final ShardDataTreeSnapshot snapshot = store.takeStateSnapshot();
+ log.debug("{}: requesting serialization of snapshot {}", logId, snapshot);
+
+ ShardSnapshotActor.requestSnapshot(snapshotActor, snapshot, installSnapshotStream, actorRef);
}
@Override
}
@Override
- public State deserializeSnapshot(ByteSource snapshotBytes) throws IOException {
+ public State deserializeSnapshot(final ByteSource snapshotBytes) throws IOException {
try (final ObjectInputStream in = new ObjectInputStream(snapshotBytes.openStream())) {
return new ShardSnapshotState(ShardDataTreeSnapshot.deserialize(in));
}
@Override
public String toString() {
- return MoreObjects.toStringHelper(FrontendClientMetadata.class).add("Identifier", identifier)
- .add("CurrentHistory", currentHistories).add("Range", purgedHistories).toString();
+ return MoreObjects.toStringHelper(FrontendClientMetadata.class).add("identifer", identifier)
+ .add("current", currentHistories).add("purged", purgedHistories).toString();
}
}
@Override
public String toString() {
- return MoreObjects.toStringHelper(FrontendHistoryMetadata.class).add("historiId", historyId)
+ return MoreObjects.toStringHelper(FrontendHistoryMetadata.class).add("historyId", historyId)
.add("cookie", cookie).add("closed", closed).add("closedTransactions", closedTransactions)
.add("purgedTransactions", purgedTransactions).toString();
}
package org.opendaylight.controller.cluster.datastore.persisted;
import com.google.common.annotations.Beta;
+import com.google.common.base.MoreObjects;
import com.google.common.base.Preconditions;
import com.google.common.base.Verify;
import com.google.common.collect.ImmutableMap;
return new Proxy(this);
}
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper(this).add("metadata", metadata).toString();
+ }
}