X-Git-Url: https://git.verplant.org/?a=blobdiff_plain;f=src%2Fipvs.c;h=92690e88e0098635a8cc56fe9c6191116b81082e;hb=4d370741101aeb037ae52f3529a4a0869e0dc08a;hp=cbb554286bd08f292219ff91b8a81a601925638d;hpb=0750cc1006a6ccd906ae8031c1b13507aa47bdf6;p=collectd.git diff --git a/src/ipvs.c b/src/ipvs.c index cbb55428..92690e88 100644 --- a/src/ipvs.c +++ b/src/ipvs.c @@ -31,15 +31,13 @@ */ #include "collectd.h" + #include "plugin.h" #include "common.h" #if HAVE_ARPA_INET_H # include #endif /* HAVE_ARPA_INET_H */ -#if HAVE_SYS_SOCKET_H -# include -#endif /* HAVE_SYS_SOCKET_H */ #if HAVE_NETINET_IN_H # include #endif /* HAVE_NETINET_IN_H */ @@ -197,7 +195,7 @@ static int get_pi (struct ip_vs_service_entry *se, char *pi, size_t size) (se->protocol == IPPROTO_TCP) ? "TCP" : "UDP", ntohs (se->port)); - if ((0 > len) || (size <= len)) { + if ((0 > len) || (size <= ((size_t) len))) { log_err ("plugin instance truncated: %s", pi); return -1; } @@ -220,14 +218,15 @@ static int get_ti (struct ip_vs_dest_entry *de, char *ti, size_t size) len = ssnprintf (ti, size, "%s_%u", inet_ntoa (addr), ntohs (de->port)); - if ((0 > len) || (size <= len)) { + if ((0 > len) || (size <= ((size_t) len))) { log_err ("type instance truncated: %s", ti); return -1; } return 0; } /* get_ti */ -static void cipvs_submit_connections (char *pi, char *ti, derive_t value) +static void cipvs_submit_connections (const char *pi, const char *ti, + derive_t value) { value_t values[1]; value_list_t vl = VALUE_LIST_INIT; @@ -248,7 +247,7 @@ static void cipvs_submit_connections (char *pi, char *ti, derive_t value) return; } /* cipvs_submit_connections */ -static void cipvs_submit_if (char *pi, char *t, char *ti, +static void cipvs_submit_if (const char *pi, const char *t, const char *ti, derive_t rx, derive_t tx) { value_t values[2]; @@ -271,7 +270,8 @@ static void cipvs_submit_if (char *pi, char *t, char *ti, return; } /* cipvs_submit_if */ -static void cipvs_submit_dest (char *pi, struct ip_vs_dest_entry *de) { +static void cipvs_submit_dest (const char *pi, struct ip_vs_dest_entry *de) +{ struct ip_vs_stats_user stats = de->stats; char ti[DATA_MAX_NAME_LEN]; @@ -292,8 +292,6 @@ static void cipvs_submit_service (struct ip_vs_service_entry *se) char pi[DATA_MAX_NAME_LEN]; - int i = 0; - if (0 != get_pi (se, pi, sizeof (pi))) { free (dests); @@ -304,7 +302,7 @@ static void cipvs_submit_service (struct ip_vs_service_entry *se) cipvs_submit_if (pi, "if_packets", NULL, stats.inpkts, stats.outpkts); cipvs_submit_if (pi, "if_octets", NULL, stats.inbytes, stats.outbytes); - for (i = 0; i < dests->num_dests; ++i) + for (size_t i = 0; i < dests->num_dests; ++i) cipvs_submit_dest (pi, &dests->entrytable[i]); free (dests); @@ -314,7 +312,6 @@ static void cipvs_submit_service (struct ip_vs_service_entry *se) static int cipvs_read (void) { struct ip_vs_get_services *services = NULL; - int i = 0; if (sockfd < 0) return (-1); @@ -322,7 +319,7 @@ static int cipvs_read (void) if (NULL == (services = ipvs_get_services ())) return -1; - for (i = 0; i < services->num_services; ++i) + for (size_t i = 0; i < services->num_services; ++i) cipvs_submit_service (&services->entrytable[i]); free (services);