X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_prometheus.c;h=572ba561995953adeff43f69d56308272bdc1fa3;hb=80294418289129eb75c9f07e2043adcbd02941a4;hp=68ec4e438d50978a654ad2d365bdaf72236f36e8;hpb=c7fa5db74dc5ba0d8ace1149caaa545f4891bb47;p=collectd.git diff --git a/src/write_prometheus.c b/src/write_prometheus.c index 68ec4e43..572ba561 100644 --- a/src/write_prometheus.c +++ b/src/write_prometheus.c @@ -760,10 +760,25 @@ static int prom_open_socket(int addrfamily) { int fd = -1; for (struct addrinfo *ai = res; ai != NULL; ai = ai->ai_next) { - fd = socket(ai->ai_family, ai->ai_socktype | SOCK_CLOEXEC, 0); + int flags = ai->ai_socktype; +#ifdef SOCK_CLOEXEC + flags |= SOCK_CLOEXEC; +#endif + + fd = socket(ai->ai_family, flags, 0); if (fd == -1) continue; + 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; @@ -795,7 +810,7 @@ static struct MHD_Daemon *prom_start_daemon() { } struct MHD_Daemon *d = MHD_start_daemon( - MHD_USE_THREAD_PER_CONNECTION | MHD_USE_DEBUG, 0, + 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, @@ -812,7 +827,7 @@ static struct MHD_Daemon *prom_start_daemon() { static struct MHD_Daemon *prom_start_daemon() { /* {{{ */ struct MHD_Daemon *d = MHD_start_daemon( - MHD_USE_THREAD_PER_CONNECTION | MHD_USE_DEBUG, 0, + 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);