X-Git-Url: https://git.octo.it/?p=collectd.git;a=blobdiff_plain;f=src%2Fconnectivity.c;h=45b65aab5b09c1c5ba35110bbff618f6144de153;hp=3b160e767a57a9d8cb39189a20986f6055bbec35;hb=48efd3deb4c9139fd060ff3d289896e9031bcc7c;hpb=d93c31e59d1bbb5ed8c2ef624ef8ffa800bc5961 diff --git a/src/connectivity.c b/src/connectivity.c index 3b160e76..45b65aab 100644 --- a/src/connectivity.c +++ b/src/connectivity.c @@ -27,10 +27,10 @@ #include "collectd.h" -#include "common.h" #include "plugin.h" +#include "utils/common/common.h" +#include "utils/ignorelist/ignorelist.h" #include "utils_complain.h" -#include "utils_ignorelist.h" #include #include @@ -306,10 +306,11 @@ static int gen_message_payload(int state, int old_state, const char *interface, (state == 0 ? strlen(CONNECTIVITY_NEW_STATE_FIELD_DOWN_VALUE) : strlen(CONNECTIVITY_NEW_STATE_FIELD_UP_VALUE)); - if (yajl_gen_string( - g, (u_char *)(state == 0 ? CONNECTIVITY_NEW_STATE_FIELD_DOWN_VALUE - : CONNECTIVITY_NEW_STATE_FIELD_UP_VALUE), - new_state_len) != yajl_gen_status_ok) + if (yajl_gen_string(g, + (u_char *)(state == 0 + ? CONNECTIVITY_NEW_STATE_FIELD_DOWN_VALUE + : CONNECTIVITY_NEW_STATE_FIELD_UP_VALUE), + new_state_len) != yajl_gen_status_ok) goto err; // oldState @@ -322,10 +323,11 @@ static int gen_message_payload(int state, int old_state, const char *interface, (old_state == 0 ? strlen(CONNECTIVITY_OLD_STATE_FIELD_DOWN_VALUE) : strlen(CONNECTIVITY_OLD_STATE_FIELD_UP_VALUE)); - if (yajl_gen_string( - g, (u_char *)(old_state == 0 ? CONNECTIVITY_OLD_STATE_FIELD_DOWN_VALUE - : CONNECTIVITY_OLD_STATE_FIELD_UP_VALUE), - old_state_len) != yajl_gen_status_ok) + if (yajl_gen_string(g, + (u_char *)(old_state == 0 + ? CONNECTIVITY_OLD_STATE_FIELD_DOWN_VALUE + : CONNECTIVITY_OLD_STATE_FIELD_UP_VALUE), + old_state_len) != yajl_gen_status_ok) goto err; // stateChangeFieldsVersion @@ -472,7 +474,8 @@ static int connectivity_link_state(struct nlmsghdr *msg) { } DEBUG("connectivity plugin (%llu): Interface %s status is now %s", - il->timestamp, dev, ((ifi->ifi_flags & IFF_RUNNING) ? "UP" : "DOWN")); + (unsigned long long)il->timestamp, dev, + ((ifi->ifi_flags & IFF_RUNNING) ? "UP" : "DOWN")); // no need to loop again, we found the interface name attr // (otherwise the first if-statement in the loop would @@ -694,7 +697,9 @@ static void *connectivity_dequeue_thread(void *arg) /* {{{ */ static int nl_connect() { struct sockaddr_nl sa_nl = { - .nl_family = AF_NETLINK, .nl_groups = RTMGRP_LINK, .nl_pid = getpid(), + .nl_family = AF_NETLINK, + .nl_groups = RTMGRP_LINK, + .nl_pid = getpid(), }; nl_sock = socket(AF_NETLINK, SOCK_DGRAM, NETLINK_ROUTE);