summaryrefslogtreecommitdiffstats
path: root/src/stateless/dp
diff options
context:
space:
mode:
authorHanoh Haim <hhaim@cisco.com>2016-05-10 17:27:07 +0300
committerHanoh Haim <hhaim@cisco.com>2016-05-10 17:27:07 +0300
commit996f2451dba01f534420418eaac2856510682757 (patch)
tree016d58d6e97c0fc22d0577f52b44530f5bf670fb /src/stateless/dp
parent4d319010eaeb17cce9af55ef00feb71a6930c931 (diff)
refactor the schduler to be with minimum TSC instructions
Diffstat (limited to 'src/stateless/dp')
-rw-r--r--src/stateless/dp/trex_stateless_dp_core.cpp5
-rw-r--r--src/stateless/dp/trex_stateless_dp_core.h2
2 files changed, 7 insertions, 0 deletions
diff --git a/src/stateless/dp/trex_stateless_dp_core.cpp b/src/stateless/dp/trex_stateless_dp_core.cpp
index 7e9bec1d..13bf5a5d 100644
--- a/src/stateless/dp/trex_stateless_dp_core.cpp
+++ b/src/stateless/dp/trex_stateless_dp_core.cpp
@@ -904,6 +904,11 @@ TrexStatelessDpCore::start_traffic(TrexStreamsCompiledObj *obj,
lp_port->m_active_streams = 0;
lp_port->set_event_id(event_id);
+ /* update cur time */
+ if ( CGlobalInfo::is_realtime() ){
+ m_core->m_cur_time_sec = now_sec() + SCHD_OFFSET_DTIME ;
+ }
+
/* no nodes in the list */
assert(lp_port->m_active_nodes.size()==0);
diff --git a/src/stateless/dp/trex_stateless_dp_core.h b/src/stateless/dp/trex_stateless_dp_core.h
index cd61b486..bdf84cfd 100644
--- a/src/stateless/dp/trex_stateless_dp_core.h
+++ b/src/stateless/dp/trex_stateless_dp_core.h
@@ -107,6 +107,8 @@ class TrexStatelessDpCore {
public:
+ #define SCHD_OFFSET_DTIME (10.0/1000000.0)
+
/* states */
enum state_e {
STATE_IDLE,