commit 48ee992fc00eb35eb29cfb7b5e256820a6beb5f3
author Yuta HIGUCHI <y-higuchi@onlab.us> Tue Nov 11 09:19:13 2014 -0800
committer Yuta HIGUCHI <y-higuchi@onlab.us> Tue Nov 11 09:20:19 2014 -0800
tree e292b9221fbea42711af36f7cbf9f29d6a353c53
parent 3f03d4a14ea904db19463c82b94693b4810c49eb

Adding async backups to MastershipStore

Change-Id: I36acece744b67a129a1073e08cd90690a91836ce

core/store/dist/src/main/java/org/onlab/onos/store/hz/StoreManager.java

diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/hz/StoreManager.java b/core/store/dist/src/main/java/org/onlab/onos/store/hz/StoreManager.java
index b598616..6256364 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/hz/StoreManager.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/hz/StoreManager.java
@@ -17,6 +17,7 @@
 
 import com.hazelcast.config.Config;
 import com.hazelcast.config.FileSystemXmlConfig;
+import com.hazelcast.config.MapConfig;
 import com.hazelcast.core.Hazelcast;
 import com.hazelcast.core.HazelcastInstance;
 
@@ -46,6 +47,13 @@
     public void activate() {
         try {
             Config config = new FileSystemXmlConfig(HAZELCAST_XML_FILE);
+
+            MapConfig roles = config.getMapConfig("nodeRoles");
+            roles.setAsyncBackupCount(MapConfig.MAX_BACKUP_COUNT - roles.getBackupCount());
+
+            MapConfig terms = config.getMapConfig("terms");
+            terms.setAsyncBackupCount(MapConfig.MAX_BACKUP_COUNT - terms.getBackupCount());
+
             instance = Hazelcast.newHazelcastInstance(config);
             log.info("Started");
         } catch (FileNotFoundException e) {