summaryrefslogtreecommitdiffstats
path: root/src/stateless/messaging/trex_stateless_messaging.cpp
diff options
context:
space:
mode:
authorimarom <imarom@cisco.com>2015-11-19 12:49:10 +0200
committerimarom <imarom@cisco.com>2015-11-19 12:49:10 +0200
commit76248b13906f575f709ed2270d63ec41131f4bdf (patch)
tree6b5313815b6181aed313ea6fc58b6ec311d554ea /src/stateless/messaging/trex_stateless_messaging.cpp
parenta7317d45787669af71ca8c65fd1e51f8a47d2c1e (diff)
parent91a4e6cc117076d3f5d34437581f7ffe91e6892b (diff)
Merge branch 'master' of csi-sceasr-b45:/auto/proj-pcube-b/apps/PL-b/tools/repo//trex-core
Conflicts: src/stateless/cp/trex_streams_compiler.h src/stateless/dp/trex_stateless_dp_core.cpp src/stateless/dp/trex_stateless_dp_core.h src/stateless/messaging/trex_stateless_messaging.cpp src/stateless/messaging/trex_stateless_messaging.h
Diffstat (limited to 'src/stateless/messaging/trex_stateless_messaging.cpp')
-rw-r--r--src/stateless/messaging/trex_stateless_messaging.cpp20
1 files changed, 19 insertions, 1 deletions
diff --git a/src/stateless/messaging/trex_stateless_messaging.cpp b/src/stateless/messaging/trex_stateless_messaging.cpp
index a2d00f8b..c92ad68a 100644
--- a/src/stateless/messaging/trex_stateless_messaging.cpp
+++ b/src/stateless/messaging/trex_stateless_messaging.cpp
@@ -1,5 +1,6 @@
/*
Itay Marom
+ Hanoch Haim
Cisco Systems, Inc.
*/
@@ -98,7 +99,6 @@ TrexStatelessDpQuit::clone(){
}
-
bool TrexStatelessDpQuit::handle(TrexStatelessDpCore *dp_core){
/* quit */
@@ -106,6 +106,23 @@ bool TrexStatelessDpQuit::handle(TrexStatelessDpCore *dp_core){
return (true);
}
+bool TrexStatelessDpCanQuit::handle(TrexStatelessDpCore *dp_core){
+
+ if ( dp_core->are_all_ports_idle() ){
+ /* if all ports are idle quit now */
+ set_quit(true);
+ }
+ return (true);
+}
+
+TrexStatelessCpToDpMsgBase *
+TrexStatelessDpCanQuit::clone(){
+
+ TrexStatelessCpToDpMsgBase *new_msg = new TrexStatelessDpCanQuit();
+
+ return new_msg;
+}
+
/************************* messages from DP to CP **********************/
bool
@@ -115,3 +132,4 @@ TrexDpPortEventMsg::handle() {
return (true);
}
+