X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fnet_socket.c;h=6af4f7386bcc37530057fc5251de2ff0103a1137;hb=da55b444c063c510f37e4f8527982eb86f01c7b3;hp=51a79c1d4cf54569aa74bdb37f34c297ea306ef0;hpb=fe7be9e345bcc652914ef6fc51302da13d4c9c8d;p=meshlink diff --git a/src/net_socket.c b/src/net_socket.c index 51a79c1d..6af4f738 100644 --- a/src/net_socket.c +++ b/src/net_socket.c @@ -71,6 +71,11 @@ static void configure_tcp(connection_t *c) { int lowdelay = IPTOS_LOWDELAY; setsockopt(c->socket, IPPROTO_IP, IP_TOS, (void *)&lowdelay, sizeof(lowdelay)); #endif + +#if defined(SO_NOSIGPIPE) + int nosigpipe = 1; + setsockopt(c->socket, SOL_SOCKET, SO_NOSIGPIPE, (void *)&nosigpipe, sizeof(nosigpipe)); +#endif } static void retry_outgoing_handler(event_loop_t *loop, void *data) { @@ -88,8 +93,8 @@ void retry_outgoing(meshlink_handle_t *mesh, outgoing_t *outgoing) { outgoing->timeout += 5; } - if(outgoing->timeout > mesh->maxtimeout) { - outgoing->timeout = mesh->maxtimeout; + if(outgoing->timeout > mesh->dev_class_traits[mesh->devclass].maxtimeout) { + outgoing->timeout = mesh->dev_class_traits[mesh->devclass].maxtimeout; } timeout_add(&mesh->loop, &outgoing->ev, retry_outgoing_handler, outgoing, &(struct timespec) {