Merge pull request #2 from paneda/input-buffer-delay-fix

Change zmq HWM from 1000 to 1
paneda · Oct 18, 2016 · f67a263 · f67a263
2 parents 565fe1b + 60392c3
commit f67a263
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/InputZeroMQReader.cpp b/src/InputZeroMQReader.cpp
@@ -134,9 +134,13 @@ void InputZeroMQWorker::RecvProcess(struct InputZeroMQThreadData* workerdata)
     // zmq sockets are not thread safe. That's why
     // we create it here, and not at object creation.
 
+    const int hwm = 1;
+    const int linger = 0;
     try {
+	     subscriber.setsockopt(ZMQ_RCVHWM, &hwm, sizeof(hwm));
+		  subscriber.setsockopt(ZMQ_SNDHWM, &hwm, sizeof(hwm));
+		  subscriber.setsockopt(ZMQ_LINGER, &linger, sizeof(linger));
         subscriber.connect(workerdata->uri.c_str());
-
         subscriber.setsockopt(ZMQ_SUBSCRIBE, NULL, 0); // subscribe to all messages
 
         while (running)