Commit b4a57619 authored by fred's avatar fred
Browse files

zerogw payload api refactoring

parent c1157524
......@@ -52,12 +52,8 @@ void ZerogwProxy::init()
zerogw->bind (zgw_uri.toLatin1());
worker_payload = new zmq::socket_t(*zeromq_->m_context, ZMQ_DEALER);
QString uri = "ipc://" + m_ncs_params.base_directory + "/payloads";
worker_payload->bind (uri.toLatin1());
//api_payload = new Api_payload(Api_payload, 0);
//api_payload2 = new Api_payload(m_ncs_params.base_directory, 1);
for(int i=0; i<2; i++)
{
api_payload_thread[i] = QSharedPointer<Api_payload> (new Api_payload(m_ncs_params.base_directory, 0));
......
......@@ -59,11 +59,11 @@ void Zerogw::init()
// socket from ZEROGW
m_message = new zmq::message_t(2);
m_socket_zerogw = new zmq::socket_t (*m_context, ZMQ_REP);
int hwm = 0;
int hwm = 1;
m_socket_zerogw->setsockopt(ZMQ_SNDHWM, &hwm, sizeof (hwm));
m_socket_zerogw->setsockopt(ZMQ_RCVHWM, &hwm, sizeof (hwm));
if (m_port == 0 || m_port == 1)
if (m_port == 0)
{
// QString uri = "tcp://127.0.0.1:2504" + QString::number(port);
QString uri = "ipc://" + m_basedirectory + "/payloads";
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment