Added CP to RX messages

1 files changed, 27 insertions, 15 deletions

diff --git a/src/stateless/messaging/trex_stateless_messaging.cpp b/src/stateless/messaging/trex_stateless_messaging.cpp
index 333aec88..3468d622 100644
--- a/src/stateless/messaging/trex_stateless_messaging.cpp
+++ b/src/stateless/messaging/trex_stateless_messaging.cpp
@@ -5,7 +5,7 @@
 */
 
 /*
-Copyright (c) 2015-2015 Cisco Systems, Inc.
+Copyright (c) 2015-2016 Cisco Systems, Inc.
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
@@ -19,17 +19,18 @@ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 See the License for the specific language governing permissions and
 limitations under the License.
 */
-#include <trex_stateless_messaging.h>
-#include <trex_stateless_dp_core.h>
-#include <trex_streams_compiler.h>
-#include <trex_stateless.h>
-#include <bp_sim.h>
-
 #include <string.h>
 
+#include "trex_stateless_messaging.h"
+#include "trex_stateless_dp_core.h"
+#include "trex_stateless_rx_core.h"
+#include "trex_streams_compiler.h"
+#include "trex_stateless.h"
+#include "bp_sim.h"
+
 /*************************
   start traffic message
- ************************/ 
+ ************************/
 TrexStatelessDpStart::TrexStatelessDpStart(uint8_t port_id, int event_id, TrexStreamsCompiledObj *obj, double duration) {
     m_port_id = port_id;
     m_event_id = event_id;
@@ -40,7 +41,7 @@ TrexStatelessDpStart::TrexStatelessDpStart(uint8_t port_id, int event_id, TrexSt
 
 /**
  * clone for DP start message
- * 
+ *
  */
 TrexStatelessCpToDpMsgBase *
 TrexStatelessDpStart::clone() {
@@ -69,7 +70,7 @@ TrexStatelessDpStart::handle(TrexStatelessDpCore *dp_core) {
 
 /*************************
   stop traffic message
- ************************/ 
+ ************************/
 bool
 TrexStatelessDpStop::handle(TrexStatelessDpCore *dp_core) {
 
@@ -114,7 +115,7 @@ bool TrexStatelessDpResume::handle(TrexStatelessDpCore *dp_core){
 
 /**
  * clone for DP stop message
- * 
+ *
  */
 TrexStatelessCpToDpMsgBase *
 TrexStatelessDpStop::clone() {
@@ -130,7 +131,7 @@ TrexStatelessDpStop::clone() {
 
 
 
-TrexStatelessCpToDpMsgBase * 
+TrexStatelessCpToDpMsgBase *
 TrexStatelessDpQuit::clone(){
 
     TrexStatelessCpToDpMsgBase *new_msg = new TrexStatelessDpQuit();
@@ -140,7 +141,7 @@ TrexStatelessDpQuit::clone(){
 
 
 bool TrexStatelessDpQuit::handle(TrexStatelessDpCore *dp_core){
-    
+
     /* quit  */
     dp_core->quit_main_loop();
     return (true);
@@ -155,7 +156,7 @@ bool TrexStatelessDpCanQuit::handle(TrexStatelessDpCore *dp_core){
     return (true);
 }
 
-TrexStatelessCpToDpMsgBase * 
+TrexStatelessCpToDpMsgBase *
 TrexStatelessDpCanQuit::clone(){
 
     TrexStatelessCpToDpMsgBase *new_msg = new TrexStatelessDpCanQuit();
@@ -165,7 +166,7 @@ TrexStatelessDpCanQuit::clone(){
 
 /*************************
   update traffic message
- ************************/ 
+ ************************/
 bool
 TrexStatelessDpUpdate::handle(TrexStatelessDpCore *dp_core) {
     dp_core->update_traffic(m_port_id, m_factor);
@@ -207,3 +208,14 @@ TrexDpPortEventMsg::handle() {
     return (true);
 }
 
+/************************* messages from CP to RX **********************/
+bool TrexRxStartMsg::handle (CRxCoreStateless *rx_core) {
+    rx_core->work();
+    return true;
+}
+
+/************************* messages from CP to RX **********************/
+bool TrexRxStopMsg::handle (CRxCoreStateless *rx_core) {
+    rx_core->idle();
+    return true;
+}