diff options
Diffstat (limited to 'src/libsystemd/sd-netlink')
| -rw-r--r-- | src/libsystemd/sd-netlink/netlink-message.c | 23 | ||||
| -rw-r--r-- | src/libsystemd/sd-netlink/netlink-socket.c | 12 | ||||
| -rw-r--r-- | src/libsystemd/sd-netlink/rtnl-message.c | 2 | ||||
| -rw-r--r-- | src/libsystemd/sd-netlink/sd-netlink.c | 4 | ||||
| -rw-r--r-- | src/libsystemd/sd-netlink/test-netlink.c | 6 | 
5 files changed, 22 insertions, 25 deletions
| diff --git a/src/libsystemd/sd-netlink/netlink-message.c b/src/libsystemd/sd-netlink/netlink-message.c index 3a866fdafe..f56798674c 100644 --- a/src/libsystemd/sd-netlink/netlink-message.c +++ b/src/libsystemd/sd-netlink/netlink-message.c @@ -34,7 +34,7 @@  #include "util.h"  #define GET_CONTAINER(m, i) ((i) < (m)->n_containers ? (struct rtattr*)((uint8_t*)(m)->hdr + (m)->containers[i].offset) : NULL) -#define PUSH_CONTAINER(m, new) (m)->container_offsets[(m)->n_containers ++] = (uint8_t*)(new) - (uint8_t*)(m)->hdr; +#define PUSH_CONTAINER(m, new) (m)->container_offsets[(m)->n_containers++] = (uint8_t*)(new) - (uint8_t*)(m)->hdr;  #define RTA_TYPE(rta) ((rta)->rta_type & NLA_TYPE_MASK)  #define RTA_FLAGS(rta) ((rta)->rta_type & ~NLA_TYPE_MASK) @@ -107,10 +107,7 @@ int sd_netlink_message_request_dump(sd_netlink_message *m, int dump) {                        m->hdr->nlmsg_type == RTM_GETNEIGH,                        -EINVAL); -        if (dump) -                m->hdr->nlmsg_flags |= NLM_F_DUMP; -        else -                m->hdr->nlmsg_flags &= ~NLM_F_DUMP; +        SET_FLAG(m->hdr->nlmsg_flags, NLM_F_DUMP, dump);          return 0;  } @@ -467,7 +464,7 @@ int sd_netlink_message_open_container(sd_netlink_message *m, unsigned short type          if (r < 0)                  return r; -        m->containers[m->n_containers ++].offset = r; +        m->containers[m->n_containers++].offset = r;          return 0;  } @@ -498,7 +495,7 @@ int sd_netlink_message_open_container_union(sd_netlink_message *m, unsigned shor          if (r < 0)                  return r; -        m->containers[m->n_containers ++].offset = r; +        m->containers[m->n_containers++].offset = r;          return 0;  } @@ -510,7 +507,7 @@ int sd_netlink_message_close_container(sd_netlink_message *m) {          assert_return(m->n_containers > 0, -EINVAL);          m->containers[m->n_containers].type_system = NULL; -        m->n_containers --; +        m->n_containers--;          return 0;  } @@ -528,7 +525,7 @@ static int netlink_message_read_internal(sd_netlink_message *m, unsigned short t          attribute = &m->containers[m->n_containers].attributes[type]; -        if(!attribute->offset) +        if (!attribute->offset)                  return -ENODATA;          rta = (struct rtattr*)((uint8_t *) m->hdr + attribute->offset); @@ -735,7 +732,7 @@ static int netlink_container_parse(sd_netlink_message *m,          _cleanup_free_ struct netlink_attribute *attributes = NULL;          attributes = new0(struct netlink_attribute, count); -        if(!attributes) +        if (!attributes)                  return -ENOMEM;          for (; RTA_OK(rta, rt_len); rta = RTA_NEXT(rta, rt_len)) { @@ -842,7 +839,7 @@ int sd_netlink_message_enter_container(sd_netlink_message *m, unsigned short typ          else                  size = (size_t)r; -        m->n_containers ++; +        m->n_containers++;          r = netlink_container_parse(m,                                      &m->containers[m->n_containers], @@ -850,7 +847,7 @@ int sd_netlink_message_enter_container(sd_netlink_message *m, unsigned short typ                                      container,                                      size);          if (r < 0) { -                m->n_containers --; +                m->n_containers--;                  return r;          } @@ -867,7 +864,7 @@ int sd_netlink_message_exit_container(sd_netlink_message *m) {          m->containers[m->n_containers].attributes = mfree(m->containers[m->n_containers].attributes);          m->containers[m->n_containers].type_system = NULL; -        m->n_containers --; +        m->n_containers--;          return 0;  } diff --git a/src/libsystemd/sd-netlink/netlink-socket.c b/src/libsystemd/sd-netlink/netlink-socket.c index 590fc53fc7..c165fa3359 100644 --- a/src/libsystemd/sd-netlink/netlink-socket.c +++ b/src/libsystemd/sd-netlink/netlink-socket.c @@ -82,7 +82,7 @@ static int broadcast_groups_get(sd_netlink *nl) {                  return r;          for (i = 0; i < len; i++) { -                for (j = 0; j < sizeof(uint32_t) * 8; j ++) { +                for (j = 0; j < sizeof(uint32_t) * 8; j++) {                          uint32_t offset;                          unsigned group; @@ -168,7 +168,7 @@ int socket_broadcast_group_ref(sd_netlink *nl, unsigned group) {          n_ref = broadcast_group_get_ref(nl, group); -        n_ref ++; +        n_ref++;          r = hashmap_ensure_allocated(&nl->broadcast_group_refs, NULL);          if (r < 0) @@ -216,7 +216,7 @@ int socket_broadcast_group_unref(sd_netlink *nl, unsigned group) {          assert(n_ref > 0); -        n_ref --; +        n_ref--;          r = broadcast_group_set_ref(nl, group, n_ref);          if (r < 0) @@ -444,14 +444,14 @@ int socket_read_message(sd_netlink *rtnl) {                  if (r < 0)                          return r; -                rtnl->rqueue[rtnl->rqueue_size ++] = first; +                rtnl->rqueue[rtnl->rqueue_size++] = first;                  first = NULL;                  if (multi_part && (i < rtnl->rqueue_partial_size)) {                          /* remove the message form the partial read queue */                          memmove(rtnl->rqueue_partial + i,rtnl->rqueue_partial + i + 1,                                  sizeof(sd_netlink_message*) * (rtnl->rqueue_partial_size - i - 1)); -                        rtnl->rqueue_partial_size --; +                        rtnl->rqueue_partial_size--;                  }                  return 1; @@ -465,7 +465,7 @@ int socket_read_message(sd_netlink *rtnl) {                          if (r < 0)                                  return r; -                        rtnl->rqueue_partial[rtnl->rqueue_partial_size ++] = first; +                        rtnl->rqueue_partial[rtnl->rqueue_partial_size++] = first;                  }                  first = NULL; diff --git a/src/libsystemd/sd-netlink/rtnl-message.c b/src/libsystemd/sd-netlink/rtnl-message.c index 090552f576..255526bf32 100644 --- a/src/libsystemd/sd-netlink/rtnl-message.c +++ b/src/libsystemd/sd-netlink/rtnl-message.c @@ -616,7 +616,7 @@ int sd_rtnl_message_link_get_flags(sd_netlink_message *m, unsigned *flags) {          return 0;  } -int sd_rtnl_message_link_get_type(sd_netlink_message *m, unsigned *type) { +int sd_rtnl_message_link_get_type(sd_netlink_message *m, unsigned short *type) {          struct ifinfomsg *ifi;          assert_return(m, -EINVAL); diff --git a/src/libsystemd/sd-netlink/sd-netlink.c b/src/libsystemd/sd-netlink/sd-netlink.c index 4833815b43..91701405a5 100644 --- a/src/libsystemd/sd-netlink/sd-netlink.c +++ b/src/libsystemd/sd-netlink/sd-netlink.c @@ -279,7 +279,7 @@ static int dispatch_rqueue(sd_netlink *rtnl, sd_netlink_message **message) {          /* Dispatch a queued message */          *message = rtnl->rqueue[0]; -        rtnl->rqueue_size --; +        rtnl->rqueue_size--;          memmove(rtnl->rqueue, rtnl->rqueue + 1, sizeof(sd_netlink_message*) * rtnl->rqueue_size);          return 1; @@ -774,7 +774,7 @@ static int prepare_callback(sd_event_source *s, void *userdata) {          return 1;  } -int sd_netlink_attach_event(sd_netlink *rtnl, sd_event *event, int priority) { +int sd_netlink_attach_event(sd_netlink *rtnl, sd_event *event, int64_t priority) {          int r;          assert_return(rtnl, -EINVAL); diff --git a/src/libsystemd/sd-netlink/test-netlink.c b/src/libsystemd/sd-netlink/test-netlink.c index de5e0ffc8f..f9b6787187 100644 --- a/src/libsystemd/sd-netlink/test-netlink.c +++ b/src/libsystemd/sd-netlink/test-netlink.c @@ -234,7 +234,7 @@ static int pipe_handler(sd_netlink *rtnl, sd_netlink_message *m, void *userdata)          int *counter = userdata;          int r; -        (*counter) --; +        (*counter)--;          r = sd_netlink_message_get_errno(m); @@ -276,10 +276,10 @@ static void test_pipe(int ifindex) {          assert_se(sd_rtnl_message_new_link(rtnl, &m1, RTM_GETLINK, ifindex) >= 0);          assert_se(sd_rtnl_message_new_link(rtnl, &m2, RTM_GETLINK, ifindex) >= 0); -        counter ++; +        counter++;          assert_se(sd_netlink_call_async(rtnl, m1, &pipe_handler, &counter, 0, NULL) >= 0); -        counter ++; +        counter++;          assert_se(sd_netlink_call_async(rtnl, m2, &pipe_handler, &counter, 0, NULL) >= 0);          while (counter > 0) { | 
