DellEMC S6000 xcvrd support

device/dell/x86_64-dell_s6000_s1220-r0/plugins/sfputil.py

@@ -20,6 +20,7 @@ class SfpUtil(SfpUtilBase):
     EEPROM_OFFSET = 20
 
     _port_to_eeprom_mapping = {}
+    port_dict = {}
 
     @property
     def port_start(self):
@@ -37,12 +38,33 @@ def qsfp_ports(self):
     def port_to_eeprom_mapping(self):
         return self._port_to_eeprom_mapping
 
+    @property
+    def get_transceiver_status(self):
+
+        try:
+            reg_file = open("/sys/devices/platform/dell-s6000-cpld.0/qsfp_modprs")
+
+        except IOError as e:
+            print "Error: unable to open file: %s" % str(e)
+            return False
+
+        content = reg_file.readline().rstrip()
+
+        reg_file.close()
+
+        return int(content, 16)
+
+
     def __init__(self):
+
         eeprom_path = "/sys/class/i2c-adapter/i2c-{0}/{0}-0050/eeprom"
 
         for x in range(0, self.port_end + 1):
             self._port_to_eeprom_mapping[x] = eeprom_path.format(x + self.EEPROM_OFFSET)
 
+        # Get Transceiver status 
+        self.modprs_register = self.get_transceiver_status
+
         SfpUtilBase.__init__(self)
 
     def get_presence(self, port_num):
@@ -175,9 +197,38 @@ def reset(self, port_num):
         return True
 
     def get_transceiver_change_event(self):
-        """
-        TODO: This function need to be implemented
-        when decide to support monitoring SFP(Xcvrd)
-        on this platform.
-        """
-        raise NotImplementedError
+
+        port_dict = {}
+        port = self.port_start
+
+        # Sleep for a minute
+        if self.modprs_register == self.get_transceiver_status:
+            time.sleep(1)
+            if self.modprs_register == self.get_transceiver_status:
+                state_change = 0
+            else:
+                state_change = 1
+
+        # Check OIR change events
+        if not state_change:
+            return True, {}
+        else:
+            changed_ports = self.modprs_register ^ reg_value
+            while port >= self.port_start and port <= self.port_end:
+
+                # Mask off the bit corresponding to our port
+                mask = (1 << port)
+
+                if changed_ports & mask:
+                    # ModPrsL is active low
+                    if reg_value & mask == 0:
+                        port_dict[port] = '1'
+                    else:
+                        port_dict[port] = '0'
+
+                port += 1
+
+            # Update reg value
+            self.modprs_register = reg_value
+
+            return True, port_dict