format

Signed-off-by: Hoooao <hao021014@163.com>

Author: Hoooao

include/bm/bm_sim/action_profile.h

@@ -297,6 +297,10 @@ class ActionProfile : public NamedP4Object {
 
   bool group_is_empty(grp_hdl_t grp) const;
 
+  bool is_selector_fanout_enabled() const {
+    return selector_fanout_enabled;
+  }
+
   const ActionEntry &lookup(const Packet &pkt,
                             const IndirectIndex &index) const;
 
@@ -313,6 +317,7 @@ class ActionProfile : public NamedP4Object {
   std::shared_ptr<GroupSelectionIface> grp_selector_{nullptr};
   GroupSelectionIface *grp_selector{&grp_mgr};
   std::unique_ptr<Calculation> hash{nullptr};
+  bool selector_fanout_enabled{false};
 };
 
 }  // namespace bm

include/bm/bm_sim/fanout_pkt_mgr.h

@@ -1,4 +1,4 @@
-/* Copyright 2013-present Contributors to the P4 Project
+/* Copyright 2025-present Contributors to the P4 Project
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -15,8 +15,9 @@
 #ifndef BM_BM_SIM_FANOUT_PKT_MGR_H_
 #define BM_BM_SIM_FANOUT_PKT_MGR_H_
 
-#include <vector>
+#include <memory>
 #include <unordered_map>
+#include <vector>
 #include "logger.h"
 #include "packet.h"
 #include "match_tables.h"
@@ -35,7 +36,8 @@ struct FanoutCtx {
   MatchTableIndirect *cur_table{nullptr};
   std::function<void(const bm::Packet *)> buffer_push_fn;
 
-  FanoutCtx(const std::function<void(const bm::Packet *)> &buffer_push_fn)
+  explicit FanoutCtx(
+    const std::function<void(const bm::Packet *)> &buffer_push_fn)
       : buffer_push_fn(buffer_push_fn) { }
 };
 
@@ -97,12 +99,12 @@ class FanoutPktMgr {
 #endif
     std::mutex fanout_pkt_mutex;
     std::vector<ActionProfile*> act_profs;
-    
+
  private:
     FanoutPktMgr() = default;
     std::unordered_map<std::thread::id, FanoutCtx> fanout_ctx_map;
-    std::shared_ptr<SelectorIface> 
-    grp_selector{std::make_shared<FanoutPktSelection>()};
+    std::shared_ptr<SelectorIface>
+      grp_selector{std::make_shared<FanoutPktSelection>()};
 };
 
 }  // namespace bm

src/bm_sim/P4Objects.cpp

@@ -2509,7 +2509,7 @@ P4Objects::check_hash(const std::string &name) const {
 bool P4Objects::is_selector_fanout(const Json::Value &cfg_selector) const {
   bool is_fanout = cfg_selector.isMember("algo") &&
          cfg_selector["algo"].asString() == "selector_fanout";
-  if(is_fanout && !FanoutPktMgr::pkt_fanout_on){
+  if (is_fanout && !FanoutPktMgr::pkt_fanout_on) {
     throw std::runtime_error("Selector fanout is not enabled, but"
                              " found selector_fanout mode used");
   }

src/bm_sim/action_profile.cpp

@@ -643,4 +643,8 @@ ActionProfile::choose_from_group(grp_hdl_t grp, const Packet &pkt) const {
   return grp_selector->get_from_hash(grp, h);
 }
 
+void ActionProfile::set_selector_fanout() {
+  selector_fanout_enabled = true;
+}
+
 }  // namespace bm

src/bm_sim/match_tables.cpp

@@ -722,7 +722,7 @@ MatchTableIndirect::lookup(const Packet &pkt,
       FanoutPktMgr::instance().set_ctx(this, pkt, action_profile, *hit);
     }
   }
-  
+
   const auto &entry = action_profile->lookup(pkt, index);
   // Unfortunately this has to be done at this stage and cannot be done when
   // inserting a member because for 2 match tables sharing the same action

targets/simple_switch/simple_switch.cpp

@@ -289,7 +289,7 @@ SimpleSwitch::start_and_return_() {
          BMLOG_DEBUG_PKT(*pkt,
            "SELECTOR_FANOUT packet pushed to ingress_buffer");
         });
-        
+
     threads_.push_back(std::move(ingress_thread));
     for (size_t i = 0; i < nb_egress_threads; i++) {
       auto egress_thread = std::thread(&SimpleSwitch::egress_thread, this, i);
@@ -298,7 +298,7 @@ SimpleSwitch::start_and_return_() {
           egress_thread.get_id(), [&](const bm::Packet *pkt) {
             this->egress_buffers.push_front(i, 0,
               std::unique_ptr<bm::Packet>(const_cast<bm::Packet *>(pkt)));
-            BMLOG_DEBUG_PKT(*pkt, 
+            BMLOG_DEBUG_PKT(*pkt,
               "SELECTOR_FANOUT packet pushed to egress_buffer");
           });
 
@@ -696,7 +696,7 @@ SimpleSwitch::egress_thread(size_t worker_id) {
 
     phv = packet->get_phv();
     Field &f_egress_spec = phv->get_field("standard_metadata.egress_spec");
-    
+
     if (packet->has_next_node()) {
       egress_mau->apply_from_next_node(packet.get());
     } else {