summaryrefslogtreecommitdiffstats
path: root/src/stateless/cp/trex_stateless_port.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/stateless/cp/trex_stateless_port.h')
-rw-r--r--src/stateless/cp/trex_stateless_port.h10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/stateless/cp/trex_stateless_port.h b/src/stateless/cp/trex_stateless_port.h
index 915c5325..7d976e46 100644
--- a/src/stateless/cp/trex_stateless_port.h
+++ b/src/stateless/cp/trex_stateless_port.h
@@ -178,7 +178,7 @@ public:
* start traffic
* throws TrexException in case of an error
*/
- void start_traffic(const TrexPortMultiplier &mul, double duration, bool force = false);
+ void start_traffic(const TrexPortMultiplier &mul, double duration, bool force = false, uint64_t core_mask = UINT64_MAX);
/**
* stop traffic
@@ -376,10 +376,12 @@ public:
void get_pci_info(std::string &pci_addr, int &numa_node);
+
private:
+ bool is_core_active(int core_id);
- const std::vector<int> get_core_id_list () {
+ const std::vector<uint8_t> get_core_id_list () {
return m_cores_id_list;
}
@@ -393,7 +395,7 @@ private:
* send message to all cores using duplicate
*
*/
- void send_message_to_all_dp(TrexStatelessCpToDpMsgBase *msg);
+ void send_message_to_all_dp(TrexStatelessCpToDpMsgBase *msg, bool send_to_active_only = false);
/**
* send message to specific DP core
@@ -445,7 +447,7 @@ private:
uint16_t m_rx_caps;
/* holds the DP cores associated with this port */
- std::vector<int> m_cores_id_list;
+ std::vector<uint8_t> m_cores_id_list;
bool m_last_all_streams_continues;
double m_last_duration;