VOL-1497 : Further improved data synchronization between cores
- Introduced locking when modifying branches
- Introduced locking when modifying rev children
- Rewrote persistence loading logic to avoid unecessary changes
- Access controlled CreateProxy to ensure a proxy is not created
against an incomplete device entry
- Removed locking logic from etcd client
- Replaced revision merging logic with persistence loading
VOL-1544 : Cleanup revisions to improve overall performance
- Ensure that old revisions are discarded
- Ensure that children do not contain discarded revisions
- Disabled cache logic for now
Change-Id: I1b952c82aba379fce64a47a71b5309a6f28fb5ff
diff --git a/rw_core/core/logical_device_agent.go b/rw_core/core/logical_device_agent.go
index e123be7..193ba9a 100644
--- a/rw_core/core/logical_device_agent.go
+++ b/rw_core/core/logical_device_agent.go
@@ -121,13 +121,13 @@
}
agent.lockLogicalDevice.Lock()
- agent.flowProxy = agent.clusterDataProxy.Root.CreateProxy(
+ agent.flowProxy = agent.clusterDataProxy.CreateProxy(
fmt.Sprintf("/logical_devices/%s/flows", agent.logicalDeviceId),
false)
- agent.groupProxy = agent.clusterDataProxy.Root.CreateProxy(
+ agent.groupProxy = agent.clusterDataProxy.CreateProxy(
fmt.Sprintf("/logical_devices/%s/flow_groups", agent.logicalDeviceId),
false)
- agent.ldProxy = agent.clusterDataProxy.Root.CreateProxy(
+ agent.ldProxy = agent.clusterDataProxy.CreateProxy(
fmt.Sprintf("/logical_devices/%s", agent.logicalDeviceId),
false)
@@ -1084,7 +1084,7 @@
// Set the proxy and callback for that port
agent.portProxiesLock.Lock()
- agent.portProxies[port.Id] = agent.clusterDataProxy.Root.CreateProxy(
+ agent.portProxies[port.Id] = agent.clusterDataProxy.CreateProxy(
fmt.Sprintf("/logical_devices/%s/ports/%s", agent.logicalDeviceId, port.Id),
false)
agent.portProxies[port.Id].RegisterCallback(model.POST_UPDATE, agent.portUpdated)