commit 646aa0261452f590ac06802409eb1522aebb5a43
author yjimmyy <yjimmyy@gmail.com> Tue Jul 05 12:09:50 2016 -0700
committer Gerrit Code Review <gerrit@onlab.us> Thu Jul 07 03:30:46 2016 +0000
tree 725ea864335d0c4dafed31299d145ffc8ca813a4
parent 0f87d48190903398a2899715a0309acb18fcb102

Implement PowerConfig for Oplink Devices

Change-Id: I939126580f8d3cdcdbcd9a46f6ee5cacbd25051d

providers/openflow/device/src/main/java/org/onosproject/provider/of/device/impl/OpenFlowDeviceProvider.java

diff --git a/providers/openflow/device/src/main/java/org/onosproject/provider/of/device/impl/OpenFlowDeviceProvider.java b/providers/openflow/device/src/main/java/org/onosproject/provider/of/device/impl/OpenFlowDeviceProvider.java
index 1f6a888..177cf1a 100644
--- a/providers/openflow/device/src/main/java/org/onosproject/provider/of/device/impl/OpenFlowDeviceProvider.java
+++ b/providers/openflow/device/src/main/java/org/onosproject/provider/of/device/impl/OpenFlowDeviceProvider.java
@@ -547,7 +547,7 @@
 
         private PortDescription buildPortDescription(PortDescPropertyType ptype, OFObject port,
                 OpenFlowOpticalSwitch opsw) {
-            if (port instanceof  OFPortOptical) {
+            if (port instanceof OFPortOptical) {
                 return buildPortDescription(ptype, (OFPortOptical) port, opsw);
             }
             return buildPortDescription(ptype, (OFExpPort) port);
@@ -833,6 +833,16 @@
                                     statsEntries.clear();
                                 }
                             }
+                        } else if (((OFStatsReply) msg).getStatsType() == OFStatsType.EXPERIMENTER) {
+                            OpenFlowSwitch sw = controller.getSwitch(dpid);
+                            if (sw instanceof OpenFlowOpticalSwitch) {
+                                // Optical switch uses experimenter stats message to update power
+                                List<PortDescription> portDescs =
+                                        ((OpenFlowOpticalSwitch) sw).processExpPortStats(msg);
+                                if (!portDescs.isEmpty()) {
+                                    providerService.updatePorts(DeviceId.deviceId(Dpid.uri(dpid)), portDescs);
+                                }
+                            }
                         }
                         break;
                     case ERROR: