Adjust HWM

sf-buffer/src/sf_replay.cpp

@@ -55,7 +55,7 @@ int main (int argc, char *argv[]) {
 
     int status = 0;
 
-    int sndhwm = 1;
+    int sndhwm = 1000;
     status += zmq_setsockopt(socket, ZMQ_SNDHWM, &sndhwm, sizeof(sndhwm));
     int linger_ms = 0;
     status += zmq_setsockopt(socket, ZMQ_LINGER, &linger_ms, sizeof(linger_ms));

sf-writer/sf_h5_writer.cpp

@@ -40,7 +40,7 @@ int main (int argc, char *argv[])
         throw runtime_error(strerror (errno));
     }
 
-    int rcvhwm = 1;
+    int rcvhwm = 10000;
     int status = zmq_setsockopt(socket, ZMQ_RCVHWM, &rcvhwm, sizeof(rcvhwm));
     if (status != 0) {
         throw runtime_error(strerror (errno));