commit | 9b3a7ce954461935107075badeb2f802b2ad0675 | [log] [tgz] |
---|---|---|
author | Jordan Halterman <jordan@opennetworking.org> | Fri Aug 25 15:12:54 2017 -0700 |
committer | Ray Milkey <ray@opennetworking.org> | Thu Aug 31 21:27:36 2017 +0000 |
tree | 8b76bc05cb607759eabdbc711956ab3dcb1bec91 | |
parent | 9df5b7c1f79710a4339cfddda810368fe0081687 [diff] |
Store flows rules asynchronously via master in DistributedFlowRuleStore Change-Id: I5e41a982204e395d2a1ac05017905069d61dc702
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionClient.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionClient.java index ed46a96..8f1ffa3 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionClient.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/StoragePartitionClient.java
@@ -247,8 +247,8 @@ AtomixDocumentTree atomixDocumentTree = new AtomixDocumentTree(client.newProxyBuilder() .withName(name) .withServiceType(String.format("%s-%s", DistributedPrimitive.Type.DOCUMENT_TREE.name(), ordering)) - .withReadConsistency(ReadConsistency.LINEARIZABLE) - .withCommunicationStrategy(CommunicationStrategy.LEADER) + .withReadConsistency(ReadConsistency.SEQUENTIAL) + .withCommunicationStrategy(CommunicationStrategy.ANY) .withTimeout(Duration.ofSeconds(30)) .withMaxRetries(5) .build()