diff options
| author |   imarom <imarom@cisco.com> | 2015-10-07 14:57:48 +0200 |
|---|---|---|
| committer | imarom <imarom@cisco.com> | 2015-10-07 14:57:48 +0200 |
| commit | 4d53d6e2633caed782067965b1b4422b45dab4a2 (patch) | |
| tree | 84966bcdb944027ded09c78f57f6de0f991cc1f6 /src/rpc-server/trex_rpc_server.cpp | |
| parent | 73574943ae438985f37aae3ea52e9713c55ef62e (diff) | |
added async publisher to the RPC server
Diffstat (limited to 'src/rpc-server/trex_rpc_server.cpp')
| -rw-r--r-- | src/rpc-server/trex_rpc_server.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/rpc-server/trex_rpc_server.cpp b/src/rpc-server/trex_rpc_server.cpp index 6b8c200d..18265a0e 100644 --- a/src/rpc-server/trex_rpc_server.cpp +++ b/src/rpc-server/trex_rpc_server.cpp @@ -21,6 +21,7 @@ limitations under the License. #include <trex_rpc_server_api.h> #include <trex_rpc_req_resp_server.h> +#include <trex_rpc_async_server.h> #include <trex_rpc_jsonrpc_v2_parser.h> #include <unistd.h> #include <zmq.h> @@ -112,10 +113,13 @@ get_current_date_time() { const std::string TrexRpcServer::s_server_uptime = get_current_date_time(); -TrexRpcServer::TrexRpcServer(const TrexRpcServerConfig &req_resp_cfg) { +TrexRpcServer::TrexRpcServer(const TrexRpcServerConfig &req_resp_cfg, + const TrexRpcServerConfig &async_cfg) { /* add the request response server */ m_servers.push_back(new TrexRpcServerReqRes(req_resp_cfg)); + /* add async publisher */ + m_servers.push_back(new TrexRpcServerAsync(async_cfg)); } TrexRpcServer::~TrexRpcServer() { |