diff options
author | Hanoh Haim <hhaim@cisco.com> | 2015-11-18 16:23:55 +0200 |
---|---|---|
committer | Hanoh Haim <hhaim@cisco.com> | 2015-11-18 16:23:55 +0200 |
commit | 0e8c9ae666d61897cb405c469a71be09d54a649b (patch) | |
tree | a35686155fa9f5834acd85ae6f1f4beeeab59b12 /src/stateless/messaging/trex_stateless_messaging.h | |
parent | aa9bf54e6f892168482ed647a0e67ab10b1cf34a (diff) |
add support for a program of streams. refactor the dp code
Diffstat (limited to 'src/stateless/messaging/trex_stateless_messaging.h')
-rw-r--r-- | src/stateless/messaging/trex_stateless_messaging.h | 30 |
1 files changed, 29 insertions, 1 deletions
diff --git a/src/stateless/messaging/trex_stateless_messaging.h b/src/stateless/messaging/trex_stateless_messaging.h index 6473a6a4..7dc307c7 100644 --- a/src/stateless/messaging/trex_stateless_messaging.h +++ b/src/stateless/messaging/trex_stateless_messaging.h @@ -36,6 +36,7 @@ class TrexStatelessCpToDpMsgBase { public: TrexStatelessCpToDpMsgBase() { + m_quit_scheduler=false; } virtual ~TrexStatelessCpToDpMsgBase() { @@ -54,9 +55,19 @@ public: */ virtual TrexStatelessCpToDpMsgBase * clone() = 0; + /* do we want to quit scheduler, can be set by handle function */ + void set_quit(bool enable){ + m_quit_scheduler=enable; + } + + bool is_quit(){ + return ( m_quit_scheduler); + } + /* no copy constructor */ TrexStatelessCpToDpMsgBase(TrexStatelessCpToDpMsgBase &) = delete; - +private: + bool m_quit_scheduler; }; /** @@ -116,5 +127,22 @@ public: virtual TrexStatelessCpToDpMsgBase * clone(); }; +/** + * a message to check if both port are idel and exit + * + * @author hhaim + */ +class TrexStatelessDpCanQuit : public TrexStatelessCpToDpMsgBase { +public: + + TrexStatelessDpCanQuit() { + } + + virtual bool handle(TrexStatelessDpCore *dp_core); + + virtual TrexStatelessCpToDpMsgBase * clone(); +}; + + #endif /* __TREX_STATELESS_MESSAGING_H__ */ |