Bugfixes for DistributedLockManager functionality
Added a method called broadcastIncludeSelf to ClusterCommunicationService.
Cosmetic improvements: added toString methods
Change-Id: I1d58720c29e6f8642f950670c3a6d95a7019a491
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java
index 0021eb7..a6320ed 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java
@@ -3,6 +3,7 @@
import static com.google.common.base.Preconditions.checkNotNull;
import java.util.List;
+import java.util.Set;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
@@ -37,7 +38,7 @@
public boolean createTable(String tableName, int ttlMillis) {
- CompletableFuture<Boolean> future = copycat.submit("createTable", tableName, ttlMillis);
+ CompletableFuture<Boolean> future = copycat.submit("createTableWithExpiration", tableName);
try {
return future.get();
} catch (InterruptedException | ExecutionException e) {
@@ -65,9 +66,9 @@
}
}
- public List<String> listTables() {
+ public Set<String> listTables() {
- CompletableFuture<List<String>> future = copycat.submit("listTables");
+ CompletableFuture<Set<String>> future = copycat.submit("listTables");
try {
return future.get();
} catch (InterruptedException | ExecutionException e) {