Merge pull request #2618 from ajssmith/amqp1_dev1_branch
[collectd.git] / src / libcollectdclient / server.c
1 /**
2  * Copyright 2017 Florian Forster
3  *
4  * Permission is hereby granted, free of charge, to any person obtaining a copy
5  * of this software and associated documentation files (the "Software"), to deal
6  * in the Software without restriction, including without limitation the rights
7  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
8  * copies of the Software, and to permit persons to whom the Software is
9  * furnished to do so, subject to the following conditions:
10  *
11  * The above copyright notice and this permission notice shall be included in
12  * all copies or substantial portions of the Software.
13  *
14  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
15  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
16  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
17  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
18  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
19  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
20  * SOFTWARE.
21  *
22  * Authors:
23  *   Florian octo Forster <octo at collectd.org>
24  **/
25
26 #include "config.h"
27
28 #if !defined(__GNUC__) || !__GNUC__
29 #define __attribute__(x) /**/
30 #endif
31
32 #include "collectd/lcc_features.h"
33 #include "collectd/network_parse.h" /* for lcc_network_parse_options_t */
34 #include "collectd/server.h"
35
36 // clang-format off
37 #include <errno.h>
38 #include <stdbool.h>
39 #include <string.h>
40 #include <unistd.h>
41 #include <sys/socket.h>
42 #include <sys/types.h>
43 #include <net/if.h>
44 #include <netdb.h>
45 #include <netinet/in.h>
46 // clang-format on
47
48 #include <stdio.h>
49 #define DEBUG(...) printf(__VA_ARGS__)
50
51 static bool is_multicast(struct addrinfo const *ai) {
52   if (ai->ai_family == AF_INET) {
53     struct sockaddr_in *addr = (struct sockaddr_in *)ai->ai_addr;
54     return IN_MULTICAST(ntohl(addr->sin_addr.s_addr));
55   } else if (ai->ai_family == AF_INET6) {
56     struct sockaddr_in6 *addr = (struct sockaddr_in6 *)ai->ai_addr;
57     return IN6_IS_ADDR_MULTICAST(&addr->sin6_addr);
58   }
59   return 0;
60 }
61
62 static int server_multicast_join(lcc_listener_t *srv,
63                                  struct sockaddr_storage *group, int loop_back,
64                                  int ttl) {
65   if (group->ss_family == AF_INET) {
66     struct sockaddr_in *sa = (struct sockaddr_in *)group;
67
68     int status = setsockopt(srv->conn, IPPROTO_IP, IP_MULTICAST_LOOP,
69                             &loop_back, sizeof(loop_back));
70     if (status == -1) {
71       DEBUG("setsockopt(IP_MULTICAST_LOOP, %d) = %d\n", loop_back, errno);
72       return errno;
73     }
74
75     status =
76         setsockopt(srv->conn, IPPROTO_IP, IP_MULTICAST_TTL, &ttl, sizeof(ttl));
77     if (status == -1)
78       return errno;
79
80 #if HAVE_STRUCT_IP_MREQN_IMR_IFINDEX
81     struct ip_mreqn mreq = {
82         .imr_address.s_addr = INADDR_ANY,
83         .imr_multiaddr.s_addr = sa->sin_addr.s_addr,
84         .imr_ifindex = if_nametoindex(srv->interface),
85     };
86 #else
87     struct ip_mreq mreq = {
88         .imr_multiaddr.s_addr = sa->sin_addr.s_addr,
89     };
90 #endif
91     status = setsockopt(srv->conn, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq,
92                         sizeof(mreq));
93     if (status == -1)
94       return errno;
95   } else if (group->ss_family == AF_INET6) {
96     struct sockaddr_in6 *sa = (struct sockaddr_in6 *)group;
97
98     int status = setsockopt(srv->conn, IPPROTO_IPV6, IPV6_MULTICAST_LOOP,
99                             &loop_back, sizeof(loop_back));
100     if (status == -1)
101       return errno;
102
103     status = setsockopt(srv->conn, IPPROTO_IPV6, IPV6_MULTICAST_HOPS, &ttl,
104                         sizeof(ttl));
105     if (status == -1)
106       return errno;
107
108     struct ipv6_mreq mreq6 = {
109         .ipv6mr_interface = if_nametoindex(srv->interface),
110     };
111     memmove(&mreq6.ipv6mr_multiaddr, &sa->sin6_addr, sizeof(struct in6_addr));
112
113     status = setsockopt(srv->conn, IPPROTO_IPV6, IPV6_JOIN_GROUP, &mreq6,
114                         sizeof(mreq6));
115     if (status == -1)
116       return errno;
117   } else {
118     return EINVAL;
119   }
120
121   return 0;
122 }
123
124 static int server_bind_socket(lcc_listener_t *srv, struct addrinfo const *ai) {
125   /* allow multiple sockets to use the same PORT number */
126   if (setsockopt(srv->conn, SOL_SOCKET, SO_REUSEADDR, &(int){1}, sizeof(int)) ==
127       -1) {
128     return errno;
129   }
130
131   if (bind(srv->conn, ai->ai_addr, ai->ai_addrlen) == -1) {
132     return -1;
133   }
134
135   if (is_multicast(ai)) {
136     int status = server_multicast_join(srv, (void *)ai->ai_addr, /* loop = */ 1,
137                                        /* ttl = */ 16);
138     if (status != 0)
139       return status;
140   }
141
142   return 0;
143 }
144
145 static int server_open(lcc_listener_t *srv) {
146   struct addrinfo *res = NULL;
147   int status = getaddrinfo(srv->node ? srv->node : "::",
148                            srv->service ? srv->service : LCC_DEFAULT_PORT,
149                            &(struct addrinfo){
150                                .ai_flags = AI_ADDRCONFIG,
151                                .ai_family = AF_UNSPEC,
152                                .ai_socktype = SOCK_DGRAM,
153                            },
154                            &res);
155   if (status != 0)
156     return status;
157
158   for (struct addrinfo *ai = res; ai != NULL; ai = ai->ai_next) {
159     srv->conn = socket(ai->ai_family, ai->ai_socktype, 0);
160     if (srv->conn == -1)
161       continue;
162
163     status = server_bind_socket(srv, ai);
164     if (status != 0) {
165       close(srv->conn);
166       srv->conn = -1;
167       continue;
168     }
169
170     break;
171   }
172
173   freeaddrinfo(res);
174
175   if (srv->conn >= 0)
176     return 0;
177   return status != 0 ? status : -1;
178 }
179
180 int lcc_listen_and_write(lcc_listener_t srv) {
181   bool close_socket = 0;
182
183   if (srv.conn < 0) {
184     int status = server_open(&srv);
185     if (status != 0)
186       return status;
187     close_socket = 1;
188   }
189
190   if (srv.buffer_size == 0)
191     srv.buffer_size = LCC_NETWORK_BUFFER_SIZE;
192
193   if (srv.parser == NULL)
194     srv.parser = lcc_network_parse;
195
196   int ret = 0;
197   while (42) {
198     char buffer[srv.buffer_size];
199     ssize_t len = recv(srv.conn, buffer, sizeof(buffer), /* flags = */ 0);
200     if (len == -1) {
201       ret = errno;
202       break;
203     } else if (len == 0) {
204       break;
205     }
206
207     (void)srv.parser(buffer, (size_t)len, srv.parse_options);
208   }
209
210   if (close_socket) {
211     close(srv.conn);
212     srv.conn = -1;
213   }
214
215   return ret;
216 }