Dump i2c log using a flag (at end of test)

Summary: This will help us debug issues when running specific tests which fail on certain transceivers. This diff was used during debug of some Source Photonics issues

Reviewed By: harshitgulati18

Differential Revision: D90719842

fbshipit-source-id: 1bf6b404bfb143ec86df90eb39e6d5549ca6d8a9

Author: Mohammed Al-Sanabani

fboss/agent/test/link_tests/AgentEnsembleLinkTest.cpp

@@ -106,6 +106,9 @@ void AgentEnsembleLinkTest::TearDown() {
           qsfpServiceClient.get()->sync_getQsfpServiceRunState())
           << "QSFP Service run state no longer active after the test";
 
+      // Dump the I2C Logs at the end of the test.
+      dumpTransceiverI2cLogs(*qsfpServiceClient);
+
     } catch (const std::exception& ex) {
       XLOG(ERR) << "Failed to call qsfp_service getStatus(). " << ex.what();
     }
@@ -126,6 +129,47 @@ void AgentEnsembleLinkTest::TearDown() {
   AgentEnsembleTest::TearDown();
 }
 
+std::vector<std::string>
+AgentEnsembleLinkTest::getPrimaryPortNamesCabledPorts() {
+  const auto& ports = getCabledPorts();
+  std::unordered_set<std::string> uniqueSet;
+  std::vector<std::string> result_list;
+  for (const auto& port : ports) {
+    auto portName =
+        getSw()->getPlatformMapping()->getPortNameByPortId(port).value_or("");
+    if (portName.empty()) {
+      continue;
+    }
+    size_t firstSlash = portName.find('/');
+    size_t secondSlash = portName.find('/', firstSlash + 1);
+    if (firstSlash == std::string::npos || secondSlash == std::string::npos) {
+      // Skip wrong input
+      continue;
+    }
+    std::string firstTwoParams = portName.substr(0, secondSlash);
+    if (uniqueSet.find(firstTwoParams) == uniqueSet.end()) {
+      uniqueSet.insert(firstTwoParams);
+      result_list.push_back(portName);
+    }
+  }
+  return result_list;
+}
+
+void AgentEnsembleLinkTest::dumpTransceiverI2cLogs(
+    apache::thrift::Client<facebook::fboss::QsfpService>& qsfpServiceClient) {
+  auto ports = getPrimaryPortNamesCabledPorts();
+  for (auto& port : ports) {
+    try {
+      qsfpServiceClient.sync_dumpTransceiverI2cLog(port);
+    } catch (const std::exception& ex) {
+      // Passive cables may not have EEPROM, ignore the error if the i2c log
+      // does not exist.
+      XLOG(ERR) << "Failed to dump i2c log for port " << port << " Exception "
+                << ex.what();
+    }
+  }
+}
+
 void AgentEnsembleLinkTest::checkAgentMemoryInBounds() const {
 #ifndef IS_OSS
   int64_t memUsage = facebook::Proc::getMemoryUsage();

fboss/agent/test/link_tests/AgentEnsembleLinkTest.h

@@ -9,6 +9,7 @@
 #include "fboss/agent/test/link_tests/gen-cpp2/link_test_production_features_types.h"
 #include "fboss/agent/types.h"
 #include "fboss/lib/phy/gen-cpp2/phy_types.h"
+#include "fboss/qsfp_service/if/gen-cpp2/qsfp_clients.h"
 
 DECLARE_string(config);
 DECLARE_bool(disable_neighbor_updates);
@@ -78,6 +79,17 @@ class AgentEnsembleLinkTest : public AgentEnsembleTest {
     return xphyPorts;
   }
 
+  /*
+   * Get Primary port names (e.g. eth1/1/1) from list of cabled ports
+   */
+  std::vector<std::string> getPrimaryPortNamesCabledPorts();
+
+  /*
+   * Dumps The transceiver I2c Logs at the end of a test run.
+   */
+  void dumpTransceiverI2cLogs(
+      apache::thrift::Client<facebook::fboss::QsfpService>& qsfpClient);
+
   void checkAgentMemoryInBounds() const;
 
   /*