From 95f40b1ac84b67b5edb21aa03b537abe99d04e77 Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Wed, 22 Apr 2020 10:52:31 +0200
Subject: [PATCH] Shorten the queue

---
 sf-buffer/src/sf_replay.cpp | 4 ++--
 sf-writer/sf_h5_writer.cpp  | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/sf-buffer/src/sf_replay.cpp b/sf-buffer/src/sf_replay.cpp
index 3bfdba1..61896d3 100644
--- a/sf-buffer/src/sf_replay.cpp
+++ b/sf-buffer/src/sf_replay.cpp
@@ -55,9 +55,9 @@ int main (int argc, char *argv[]) {
 
     int status = 0;
 
-    int sndhwm = 10;
+    int sndhwm = 1;
     status += zmq_setsockopt(socket, ZMQ_SNDHWM, &sndhwm, sizeof(sndhwm));
-    int linger_ms = 10000;
+    int linger_ms = 0;
     status += zmq_setsockopt(socket, ZMQ_LINGER, &linger_ms, sizeof(linger_ms));
 
     //status += zmq_setsockopt(socket, ZMQ_SNDTIMEO, 1000);
diff --git a/sf-writer/sf_h5_writer.cpp b/sf-writer/sf_h5_writer.cpp
index 67b2905..1889f6d 100644
--- a/sf-writer/sf_h5_writer.cpp
+++ b/sf-writer/sf_h5_writer.cpp
@@ -39,7 +39,7 @@ int main (int argc, char *argv[])
         throw runtime_error(strerror (errno));
     }
 
-    int rcvhwm = 3;
+    int rcvhwm = 1;
     int status = zmq_setsockopt(socket, ZMQ_RCVHWM, &rcvhwm, sizeof(rcvhwm));
     if (status != 0) {
         throw runtime_error(strerror (errno));