fixed some bugs in the async server

also added affinity to the stateless main object

1 files changed, 3 insertions, 3 deletions

diff --git a/src/rpc-server/trex_rpc_async_server.cpp b/src/rpc-server/trex_rpc_async_server.cpp
index 01f03af3..3313e42e 100644
--- a/src/rpc-server/trex_rpc_async_server.cpp
+++ b/src/rpc-server/trex_rpc_async_server.cpp
@@ -87,13 +87,13 @@ TrexRpcServerAsync::_rpc_thread_cb() {
 
         /* relax for some time */
         std::this_thread::sleep_for (std::chrono::milliseconds(1000));
-
     }
+
+    /* must be closed from the same thread */
+    zmq_close(m_socket);
 }
 
 void 
 TrexRpcServerAsync::_stop_rpc_thread() {
-    m_is_running = false;
-    this->m_thread->join();
     zmq_term(m_context);
 }