commit 8320088c69108bf4d9f7c02243423aff97b728cd
author Ray Milkey <ray@opennetworking.org> Mon Nov 13 19:18:21 2017 -0800
committer Thomas Vachuska <tom@opennetworking.org> Wed Nov 15 22:42:24 2017 +0000
tree 7e9af26397da6f7d9dd1a2a54ae752d1398d17ee
parent 1c4826636c8e552306f53c0f195393a036f350f1

Unit tests for Cluster Metadata Manager

Change-Id: I81de294844414778798645b95b5aaa18060e4c44

core/net/src/main/java/org/onosproject/cluster/impl/ConfigFileBasedClusterMetadataProvider.java

diff --git a/core/net/src/main/java/org/onosproject/cluster/impl/ConfigFileBasedClusterMetadataProvider.java b/core/net/src/main/java/org/onosproject/cluster/impl/ConfigFileBasedClusterMetadataProvider.java
index 3414033..cd21490 100644
--- a/core/net/src/main/java/org/onosproject/cluster/impl/ConfigFileBasedClusterMetadataProvider.java
+++ b/core/net/src/main/java/org/onosproject/cluster/impl/ConfigFileBasedClusterMetadataProvider.java
@@ -139,9 +139,11 @@
     @Override
     public void setClusterMetadata(ClusterMetadata metadata) {
         try {
-            Files.createParentDirs(CONFIG_FILE);
-            mapper.writeValue(CONFIG_FILE, metadata);
-            providerService.clusterMetadataChanged(new Versioned<>(metadata, CONFIG_FILE.lastModified()));
+            File configFile = new File(metadataUrl.replaceFirst("file://", ""));
+            Files.createParentDirs(configFile);
+            mapper.writeValue(configFile, metadata);
+            cachedMetadata.set(fetchMetadata(metadataUrl));
+            providerService.clusterMetadataChanged(new Versioned<>(metadata, configFile.lastModified()));
         } catch (IOException e) {
             Throwables.propagate(e);
         }