Adjust hwm size

This commit is contained in:
2020-04-23 10:15:21 +02:00
parent 97685dce9c
commit 75c470bd65
+2 -1
View File
@@ -93,7 +93,8 @@ int main (int argc, char *argv[]) {
auto ctx = zmq_ctx_new();
auto socket = zmq_socket(ctx, ZMQ_PUSH);
int sndhwm = REPLAY_BLOCK_SIZE;
// The +1 is important so we pre-load the next chunk.
int sndhwm = REPLAY_BLOCK_SIZE + 1;
if (zmq_setsockopt(socket, ZMQ_SNDHWM, &sndhwm, sizeof(sndhwm)) != 0) {
throw runtime_error(strerror (errno));
};