m_cmd_channel = m_client->connect(NULL);
retvm_if(!m_cmd_channel, false, "Failed to connect to server");
- m_evt_channel = m_client->connect(m_handler, &m_loop);
+ m_evt_channel = m_client->connect(m_handler, &m_loop, false);
retvm_if(!m_evt_channel, false, "Failed to connect to server");
ipc::message msg;
m_id = buf.listener_id;
m_connected.store(true);
+ m_evt_channel->bind();
+
_D("Listener ID[%d]", get_id());
return true;
ret_if(!is_connected());
m_connected.store(false);
- ipc::message msg;
- ipc::message reply;
-
- msg.set_type(CMD_LISTENER_DISCONNECT);
- m_evt_channel->send_sync(&msg);
-
- m_evt_channel->read_sync(reply);
m_evt_channel->disconnect();
-
delete m_evt_channel;
m_evt_channel = NULL;