X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_prometheus.c;h=572ba561995953adeff43f69d56308272bdc1fa3;hb=80294418289129eb75c9f07e2043adcbd02941a4;hp=21bfb54ff9eaad6920abfd79db4b7350cc6316da;hpb=94c4cad8053d0a0cec77fefeccaaa70d75573e1a;p=collectd.git

diff --git a/src/write_prometheus.c b/src/write_prometheus.c
index 21bfb54f..572ba561 100644
--- a/src/write_prometheus.c
+++ b/src/write_prometheus.c
@@ -731,56 +731,90 @@ metric_family_get(data_set_t const *ds, value_list_t const *vl, size_t ds_index,
 }
 /* }}} */
 
-#if MHD_VERSION >= 0x00090000
-static int prom_open_socket(int domain, struct sockaddr const *addr,
-                            socklen_t addrlen) {
-  int fd = socket(domain, SOCK_STREAM | SOCK_CLOEXEC, 0);
-  if (fd == -1)
-    return errno;
+static void prom_logger(__attribute__((unused)) void *arg, char const *fmt,
+                        va_list ap) {
+  /* {{{ */
+  char errbuf[1024];
+  vsnprintf(errbuf, sizeof(errbuf), fmt, ap);
 
-  if (bind(fd, addr, addrlen) != 0) {
-    close(fd);
-    return -1;
-  }
+  ERROR("write_prometheus plugin: %s", errbuf);
+} /* }}} prom_logger */
 
-  if (listen(fd, /* backlog = */ 16) != 0) {
-    close(fd);
+#if MHD_VERSION >= 0x00090000
+static int prom_open_socket(int addrfamily) {
+  /* {{{ */
+  char service[NI_MAXSERV];
+  snprintf(service, sizeof(service), "%hu", httpd_port);
+
+  struct addrinfo *res;
+  int status = getaddrinfo(NULL, service,
+                           &(struct addrinfo){
+                               .ai_flags = AI_PASSIVE | AI_ADDRCONFIG,
+                               .ai_family = addrfamily,
+                               .ai_socktype = SOCK_STREAM,
+                           },
+                           &res);
+  if (status != 0) {
     return -1;
   }
 
-  return fd;
-}
+  int fd = -1;
+  for (struct addrinfo *ai = res; ai != NULL; ai = ai->ai_next) {
+    int flags = ai->ai_socktype;
+#ifdef SOCK_CLOEXEC
+    flags |= SOCK_CLOEXEC;
+#endif
 
-static struct MHD_Daemon *prom_start_daemon() {
-  struct sockaddr_in6 sa6 = {
-      .sin6_family = AF_INET6,
-      .sin6_port = htons(httpd_port),
-      .sin6_addr = IN6ADDR_ANY_INIT,
-  };
-  int fd = prom_open_socket(PF_INET6, (void *)&sa6, sizeof(sa6));
+    fd = socket(ai->ai_family, flags, 0);
+    if (fd == -1)
+      continue;
 
-  if (fd == -1) {
-    struct sockaddr_in sa4 = {
-        .sin_family = AF_INET,
-        .sin_port = htons(httpd_port),
-        .sin_addr =
-            {
-                .s_addr = INADDR_ANY,
-            },
-    };
-    fd = prom_open_socket(PF_INET, (void *)&sa4, sizeof(sa4));
+    int tmp = 1;
+    if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &tmp, sizeof(tmp)) != 0) {
+      char errbuf[1024];
+      WARNING("write_prometheus: setsockopt(SO_REUSEADDR) failed: %s",
+              sstrerror(errno, errbuf, sizeof(errbuf)));
+      close(fd);
+      fd = -1;
+      continue;
+    }
+
+    if (bind(fd, ai->ai_addr, ai->ai_addrlen) != 0) {
+      close(fd);
+      fd = -1;
+      continue;
+    }
+
+    if (listen(fd, /* backlog = */ 16) != 0) {
+      close(fd);
+      fd = -1;
+      continue;
+    }
+
+    break;
   }
 
+  freeaddrinfo(res);
+
+  return fd;
+} /* }}} int prom_open_socket */
+
+static struct MHD_Daemon *prom_start_daemon() {
+  /* {{{ */
+  int fd = prom_open_socket(PF_INET6);
+  if (fd == -1)
+    fd = prom_open_socket(PF_INET);
   if (fd == -1) {
     ERROR("write_prometheus plugin: Opening a listening socket failed.");
     return NULL;
   }
 
-  struct MHD_Daemon *d =
-      MHD_start_daemon(MHD_USE_THREAD_PER_CONNECTION, 0,
-                       /* MHD_AcceptPolicyCallback = */ NULL,
-                       /* MHD_AcceptPolicyCallback arg = */ NULL, http_handler,
-                       NULL, MHD_OPTION_LISTEN_SOCKET, fd, MHD_OPTION_END);
+  struct MHD_Daemon *d = MHD_start_daemon(
+      MHD_USE_THREAD_PER_CONNECTION | MHD_USE_DEBUG, httpd_port,
+      /* MHD_AcceptPolicyCallback = */ NULL,
+      /* MHD_AcceptPolicyCallback arg = */ NULL, http_handler, NULL,
+      MHD_OPTION_LISTEN_SOCKET, fd, MHD_OPTION_EXTERNAL_LOGGER, prom_logger,
+      NULL, MHD_OPTION_END);
   if (d == NULL) {
     ERROR("write_prometheus plugin: MHD_start_daemon() failed.");
     close(fd);
@@ -788,21 +822,22 @@ static struct MHD_Daemon *prom_start_daemon() {
   }
 
   return d;
-}
+} /* }}} struct MHD_Daemon *prom_start_daemon */
 #else /* if MHD_VERSION < 0x00090000 */
 static struct MHD_Daemon *prom_start_daemon() {
-  struct MHD_Daemon *d =
-      MHD_start_daemon(MHD_USE_THREAD_PER_CONNECTION, 0,
-                       /* MHD_AcceptPolicyCallback = */ NULL,
-                       /* MHD_AcceptPolicyCallback arg = */ NULL, http_handler,
-                       NULL, MHD_OPTION_END);
+  /* {{{ */
+  struct MHD_Daemon *d = MHD_start_daemon(
+      MHD_USE_THREAD_PER_CONNECTION | MHD_USE_DEBUG, httpd_port,
+      /* MHD_AcceptPolicyCallback = */ NULL,
+      /* MHD_AcceptPolicyCallback arg = */ NULL, http_handler, NULL,
+      MHD_OPTION_EXTERNAL_LOGGER, prom_logger, NULL, MHD_OPTION_END);
   if (d == NULL) {
     ERROR("write_prometheus plugin: MHD_start_daemon() failed.");
     return NULL;
   }
 
   return d;
-}
+} /* }}} struct MHD_Daemon *prom_start_daemon */
 #endif
 
 /*