Skip to content

P
paho.mqtt.c
Commit 2761fcea authored by Juergen Kosel's avatar Juergen Kosel
Browse files
Options

Reduce the tcp snd buffer to provocate issue #385 

Signed-off-by: 's avatarJuergen Kosel <juergen.kosel@softing.com>
parent 2c3dc75e
Hide whitespace changes
Inline Side-by-side
Showing with 7 additions and 0 deletions
src/Socket.c
View file @ 2761fcea
...@@ -679,6 +679,13 @@ int Socket_new(char* addr, int port, int* sock) ...@@ -679,6 +679,13 @@ int Socket_new(char* addr, int port, int* sock)
if (setsockopt(*sock, SOL_SOCKET, SO_NOSIGPIPE, (void*)&opt, sizeof(opt)) != 0) if (setsockopt(*sock, SOL_SOCKET, SO_NOSIGPIPE, (void*)&opt, sizeof(opt)) != 0)
Log(LOG_ERROR, -1, "Could not set SO_NOSIGPIPE for socket %d", *sock); Log(LOG_ERROR, -1, "Could not set SO_NOSIGPIPE for socket %d", *sock);
#endif #endif
#if 1
{
int optsend = 2 * 1440;
if (setsockopt(*sock, SOL_SOCKET, SO_SNDBUF, (void*)&optsend, sizeof(optsend)) != 0)
Log(LOG_ERROR, -1, "Could not set SO_SNDBUF for socket %d", *sock);
}
#endif
Log(TRACE_MIN, -1, "New socket %d for %s, port %d", *sock, addr, port); Log(TRACE_MIN, -1, "New socket %d for %s, port %d", *sock, addr, port);
if (Socket_addSocket(*sock) == SOCKET_ERROR) if (Socket_addSocket(*sock) == SOCKET_ERROR)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment