[VOL-2628] Fix issue with peer ports
There is a scenario where a request to add a PON peer port
is received before the OLT PON port has been created. When this occurs
the relationship between the parent device and that child device is
lost. Routes needed for flow decomposition cannot be created and
any request to retrieve child devices will fail. This fix creates
a default PON port on the OLT when the peer request is received
and update the PON port with the latest info when the actual OLT
PON port creation is received.
Change-Id: I81807b3f4cbe7e9c1e3bbcb138fa8d4f20c6edeb
diff --git a/rw_core/core/logical_device_agent.go b/rw_core/core/logical_device_agent.go
index 857776f..cfd486a 100644
--- a/rw_core/core/logical_device_agent.go
+++ b/rw_core/core/logical_device_agent.go
@@ -209,7 +209,7 @@
if loadFromdB {
go func() {
if err := agent.buildRoutes(context.Background()); err != nil {
- log.Warn("routes-not-ready", log.Fields{"logical-device-id": agent.logicalDeviceID, "error": err})
+ log.Warnw("routes-not-ready", log.Fields{"logical-device-id": agent.logicalDeviceID, "error": err})
}
}()
}
@@ -1320,7 +1320,7 @@
// Reset the logical device routes
go func() {
if err := agent.buildRoutes(context.Background()); err != nil {
- log.Warn("device-routes-not-ready", log.Fields{"logicalDeviceId": agent.logicalDeviceID, "error": err})
+ log.Warnw("device-routes-not-ready", log.Fields{"logicalDeviceId": agent.logicalDeviceID, "error": err})
}
}()
}
@@ -1355,7 +1355,7 @@
// Reset the logical device routes
go func() {
if err := agent.buildRoutes(context.Background()); err != nil {
- log.Warn("routes-not-ready", log.Fields{"logical-device-id": agent.logicalDeviceID, "error": err})
+ log.Warnw("routes-not-ready", log.Fields{"logical-device-id": agent.logicalDeviceID, "error": err})
}
}()
@@ -1507,7 +1507,7 @@
//rebuildRoutes rebuilds the device routes
func (agent *LogicalDeviceAgent) buildRoutes(ctx context.Context) error {
- log.Debugf("building-routes", log.Fields{"logical-device-id": agent.logicalDeviceID})
+ log.Debugw("building-routes", log.Fields{"logical-device-id": agent.logicalDeviceID})
agent.lockLogicalDevice.Lock()
defer agent.lockLogicalDevice.Unlock()
if agent.deviceRoutes == nil {