This commit cleans up the python directory to ensure the adapters
and the cli runs properly.
Change-Id: Ic68a3ecd1f16a5af44296e3c020c808b185f4c18
diff --git a/rw_core/core/logical_device_manager.go b/rw_core/core/logical_device_manager.go
index 9d365aa..4625518 100644
--- a/rw_core/core/logical_device_manager.go
+++ b/rw_core/core/logical_device_manager.go
@@ -324,3 +324,23 @@
}
sendAPIResponse(ctx, ch, res)
}
+
+func (ldMgr *LogicalDeviceManager) packetOut( packetOut *openflow_13.PacketOut) {
+ log.Debugw("packetOut", log.Fields{"logicalDeviceId": packetOut.Id})
+ if agent := ldMgr.getLogicalDeviceAgent(packetOut.Id); agent != nil {
+ agent.packetOut(packetOut.PacketOut)
+ } else {
+ log.Error("logical-device-not-exist", log.Fields{"logicalDeviceId": packetOut.Id})
+ }
+}
+
+func (ldMgr *LogicalDeviceManager) packetIn(logicalDeviceId string, port uint32, packet []byte) error {
+ log.Debugw("packetIn", log.Fields{"logicalDeviceId": logicalDeviceId, "port": port})
+ if agent := ldMgr.getLogicalDeviceAgent(logicalDeviceId); agent != nil {
+ agent.packetIn(port, packet)
+ } else {
+ log.Error("logical-device-not-exist", log.Fields{"logicalDeviceId": logicalDeviceId})
+ }
+ return nil
+}
+