Remove buffer size increase

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