Skip to content

Commit 6431c51

Browse files
committed
Use delay in sockhub
1 parent c3c872b commit 6431c51

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

contrib/multimaster/dtmd/include/limits.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,6 @@
66
#define BUFFER_SIZE (256 * 1024)
77
#define LISTEN_QUEUE_SIZE 100
88
#define MAX_STREAMS 4096
9-
#define SOCKET_BUFFER_SIZE (16*1024*1024)
9+
#define SOCKET_BUFFER_SIZE (1024*1024)
1010

1111
#endif

contrib/multimaster/sockhub/sockhub.c

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919

2020
#include "sockhub.h"
2121

22-
#define SOCKHUB_BUFFER_SIZE (16*1024*1024)
22+
#define SOCKHUB_BUFFER_SIZE (1024*1024)
2323

2424
void ShubAddSocket(Shub* shub, int fd);
2525

@@ -57,6 +57,7 @@ void ShubInitParams(ShubParams* params)
5757
params->port = 54321;
5858
params->queue_size = 100;
5959
params->max_attempts = 10;
60+
params->delay = 10;
6061
params->error_handler = default_error_handler;
6162
}
6263

0 commit comments

Comments
 (0)