From 4d53d6e2633caed782067965b1b4422b45dab4a2 Mon Sep 17 00:00:00 2001
From: imarom <imarom@cisco.com>
Date: Wed, 7 Oct 2015 14:57:48 +0200
Subject: added async publisher to the RPC server
---
src/gtest/rpc_test.cpp | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
(limited to 'src/gtest/rpc_test.cpp')
diff --git a/src/gtest/rpc_test.cpp b/src/gtest/rpc_test.cpp
index 38d34320..4084b664 100644
--- a/src/gtest/rpc_test.cpp
+++ b/src/gtest/rpc_test.cpp
@@ -42,9 +42,10 @@ protected:
m_verbose = false;
- TrexRpcServerConfig cfg = TrexRpcServerConfig(TrexRpcServerConfig::RPC_PROT_TCP, 5050);
+ TrexRpcServerConfig req_resp_cfg = TrexRpcServerConfig(TrexRpcServerConfig::RPC_PROT_TCP, 5050);
+ TrexRpcServerConfig async_cfg = TrexRpcServerConfig(TrexRpcServerConfig::RPC_PROT_TCP, 5051);
- m_rpc = new TrexRpcServer(cfg);
+ m_rpc = new TrexRpcServer(req_resp_cfg, async_cfg);
m_rpc->start();
m_context = zmq_ctx_new ();
--
cgit
From 09c9d77dc2f5a89924bd27226727220801a5df13 Mon Sep 17 00:00:00 2001
From: imarom <imarom@cisco.com>
Date: Thu, 8 Oct 2015 10:23:33 +0200
Subject: fixed some bugs in the async server also added affinity to the
stateless main object
---
src/gtest/rpc_test.cpp | 10 +---------
1 file changed, 1 insertion(+), 9 deletions(-)
(limited to 'src/gtest/rpc_test.cpp')
diff --git a/src/gtest/rpc_test.cpp b/src/gtest/rpc_test.cpp
index 4084b664..250d5342 100644
--- a/src/gtest/rpc_test.cpp
+++ b/src/gtest/rpc_test.cpp
@@ -42,12 +42,6 @@ protected:
m_verbose = false;
- TrexRpcServerConfig req_resp_cfg = TrexRpcServerConfig(TrexRpcServerConfig::RPC_PROT_TCP, 5050);
- TrexRpcServerConfig async_cfg = TrexRpcServerConfig(TrexRpcServerConfig::RPC_PROT_TCP, 5051);
-
- m_rpc = new TrexRpcServer(req_resp_cfg, async_cfg);
- m_rpc->start();
-
m_context = zmq_ctx_new ();
m_socket = zmq_socket (m_context, ZMQ_REQ);
zmq_connect (m_socket, "tcp://localhost:5050");
@@ -55,9 +49,6 @@ protected:
}
virtual void TearDown() {
- m_rpc->stop();
-
- delete m_rpc;
zmq_close(m_socket);
zmq_term(m_context);
}
@@ -658,3 +649,4 @@ TEST_F(RpcTestOwned, start_stop_traffic) {
send_request(request, response);
EXPECT_EQ(response["result"], "ACK");
}
+
--
cgit