Improve log compaction efficiency in AtomixWorkQueue.
Change-Id: I0fbe163e35b610f77d490364eecfad253df9c939
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixWorkQueueCommands.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixWorkQueueCommands.java
index 2e77da9..977470d 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixWorkQueueCommands.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixWorkQueueCommands.java
@@ -74,6 +74,11 @@
}
@Override
+ public CompactionMode compaction() {
+ return CompactionMode.QUORUM;
+ }
+
+ @Override
public String toString() {
return MoreObjects.toStringHelper(getClass())
.add("items", items)
@@ -111,6 +116,11 @@
}
@Override
+ public CompactionMode compaction() {
+ return CompactionMode.QUORUM;
+ }
+
+ @Override
public String toString() {
return MoreObjects.toStringHelper(getClass())
.add("maxTasks", maxTasks)
@@ -150,6 +160,11 @@
}
@Override
+ public CompactionMode compaction() {
+ return CompactionMode.QUORUM;
+ }
+
+ @Override
public String toString() {
return MoreObjects.toStringHelper(getClass())
.toString();
@@ -168,6 +183,11 @@
}
@Override
+ public CompactionMode compaction() {
+ return CompactionMode.TOMBSTONE;
+ }
+
+ @Override
public String toString() {
return MoreObjects.toStringHelper(getClass())
.toString();
@@ -200,6 +220,11 @@
}
@Override
+ public CompactionMode compaction() {
+ return CompactionMode.TOMBSTONE;
+ }
+
+ @Override
public String toString() {
return MoreObjects.toStringHelper(getClass())
.add("taskIds", taskIds)
@@ -219,6 +244,11 @@
}
@Override
+ public CompactionMode compaction() {
+ return CompactionMode.TOMBSTONE;
+ }
+
+ @Override
public String toString() {
return MoreObjects.toStringHelper(getClass())
.toString();