| … | |
… | |
| 37 | #include <sproto.h> |
37 | #include <sproto.h> |
| 38 | #include <sys/types.h> |
38 | #include <sys/types.h> |
| 39 | #include <sys/time.h> |
39 | #include <sys/time.h> |
| 40 | #include <sys/socket.h> |
40 | #include <sys/socket.h> |
| 41 | #include <netinet/in.h> |
41 | #include <netinet/in.h> |
|
|
42 | #include <netinet/tcp.h> |
|
|
43 | #include <netinet/ip.h> |
| 42 | #include <netdb.h> |
44 | #include <netdb.h> |
| 43 | |
45 | |
| 44 | #include <unistd.h> |
46 | #include <unistd.h> |
| 45 | #include <arpa/inet.h> |
47 | #include <arpa/inet.h> |
| 46 | |
48 | |
| … | |
… | |
| 61 | |
63 | |
| 62 | linger_opt.l_onoff = 0; |
64 | linger_opt.l_onoff = 0; |
| 63 | linger_opt.l_linger = 0; |
65 | linger_opt.l_linger = 0; |
| 64 | |
66 | |
| 65 | if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger))) |
67 | if (setsockopt (fd, SOL_SOCKET, SO_LINGER, &linger_opt, sizeof (struct linger))) |
| 66 | LOG (llevError, "Cannot setsockopt(SO_LINGER): %s\n", strerror (errno)); |
68 | LOG (llevError, "SO_LINGER: %s\n", strerror (errno)); |
| 67 | } |
69 | } |
|
|
70 | |
|
|
71 | { |
|
|
72 | int val = IPTOS_LOWDELAY; |
|
|
73 | |
|
|
74 | if (setsockopt (fd, IPPROTO_IP, IP_TOS, &val, sizeof (val))) |
|
|
75 | LOG (llevError, "IP_TOS: %s\n", strerror (errno)); |
|
|
76 | } |
|
|
77 | |
|
|
78 | { |
|
|
79 | int val = 1; |
|
|
80 | |
|
|
81 | if (setsockopt (fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof (val))) |
|
|
82 | LOG (llevError, "TCP_NODELAY: %s\n", strerror (errno)); |
|
|
83 | } |
|
|
84 | |
|
|
85 | #ifdef __linux__ |
|
|
86 | { |
|
|
87 | int val; |
|
|
88 | |
|
|
89 | // set some very aggressive keepalive parameters |
|
|
90 | val = 10; |
|
|
91 | if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPIDLE, &val, sizeof (val))) |
|
|
92 | LOG (llevError, "TCP_KEEPIDLE: %s\n", strerror (errno)); |
|
|
93 | |
|
|
94 | val = 5; |
|
|
95 | if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPCNT, &val, sizeof (val))) |
|
|
96 | LOG (llevError, "TCP_KEEPCNT: %s\n", strerror (errno)); |
|
|
97 | |
|
|
98 | val = 1; |
|
|
99 | if (setsockopt (fd, IPPROTO_TCP, TCP_KEEPINTVL, &val, sizeof (val))) |
|
|
100 | LOG (llevError, "TCP_KEEPINTVL: %s\n", strerror (errno)); |
|
|
101 | } |
|
|
102 | #endif |
| 68 | |
103 | |
| 69 | { |
104 | { |
| 70 | int bufsize = 65535; /*Supposed absolute upper limit */ |
105 | int bufsize = 65535; /*Supposed absolute upper limit */ |
| 71 | int oldbufsize; |
106 | int oldbufsize; |
| 72 | int buflen = sizeof (int); |
107 | int buflen = sizeof (int); |
| … | |
… | |
| 127 | pl->socket = 0; |
162 | pl->socket = 0; |
| 128 | |
163 | |
| 129 | if (fd >= 0) |
164 | if (fd >= 0) |
| 130 | close (fd); |
165 | close (fd); |
| 131 | |
166 | |
| 132 | free (faces_sent); |
167 | sfree<uint8> (faces_sent, nrofpixmaps); |
| 133 | free (stats.range); |
168 | free (stats.range); |
| 134 | free (stats.title); |
169 | free (stats.title); |
| 135 | free (host); |
170 | free (host); |
| 136 | } |
171 | } |
| 137 | |
172 | |
