summaryrefslogtreecommitdiffstats
path: root/src/libsystemd/sd-netlink/netlink-socket.c
diff options
context:
space:
mode:
authorYu Watanabe <watanabe.yu+github@gmail.com>2021-07-07 02:42:41 +0200
committerYu Watanabe <watanabe.yu+github@gmail.com>2021-08-29 10:14:03 +0200
commit409856d328b5bcb7b5305bf835a846d3985442f1 (patch)
treeeb9764f5a7c2c3328c87f0674eb657e6f49bd51c /src/libsystemd/sd-netlink/netlink-socket.c
parenttest: add usual log messages in test-netlink (diff)
downloadsystemd-409856d328b5bcb7b5305bf835a846d3985442f1.tar.xz
systemd-409856d328b5bcb7b5305bf835a846d3985442f1.zip
sd-netlink: rename variables, arguments, and functions
Most changes are 'rtnl' -> 'nl' where the function is not only for rtnl.
Diffstat (limited to 'src/libsystemd/sd-netlink/netlink-socket.c')
-rw-r--r--src/libsystemd/sd-netlink/netlink-socket.c60
1 files changed, 30 insertions, 30 deletions
diff --git a/src/libsystemd/sd-netlink/netlink-socket.c b/src/libsystemd/sd-netlink/netlink-socket.c
index 21ec00cca0..1168f4edc0 100644
--- a/src/libsystemd/sd-netlink/netlink-socket.c
+++ b/src/libsystemd/sd-netlink/netlink-socket.c
@@ -238,7 +238,7 @@ static int socket_recv_message(int fd, struct iovec *iov, uint32_t *ret_mcast_gr
n = recvmsg_safe(fd, &msg, MSG_TRUNC | (peek ? MSG_PEEK : 0));
if (n == -ENOBUFS)
- return log_debug_errno(n, "rtnl: kernel receive buffer overrun");
+ return log_debug_errno(n, "sd-netlink: kernel receive buffer overrun");
if (IN_SET(n, -EAGAIN, -EINTR))
return 0;
if (n < 0)
@@ -246,7 +246,7 @@ static int socket_recv_message(int fd, struct iovec *iov, uint32_t *ret_mcast_gr
if (sender.nl.nl_pid != 0) {
/* not from the kernel, ignore */
- log_debug("rtnl: ignoring message from PID %"PRIu32, sender.nl.nl_pid);
+ log_debug("sd-netlink: ignoring message from PID %"PRIu32, sender.nl.nl_pid);
if (peek) {
/* drop the message */
@@ -276,7 +276,7 @@ static int socket_recv_message(int fd, struct iovec *iov, uint32_t *ret_mcast_gr
* If nothing useful was received 0 is returned.
* On failure, a negative error code is returned.
*/
-int socket_read_message(sd_netlink *rtnl) {
+int socket_read_message(sd_netlink *nl) {
_cleanup_(sd_netlink_message_unrefp) sd_netlink_message *first = NULL;
bool multi_part = false, done = false;
size_t len, allocated;
@@ -285,25 +285,25 @@ int socket_read_message(sd_netlink *rtnl) {
unsigned i = 0;
int r;
- assert(rtnl);
- assert(rtnl->rbuffer);
+ assert(nl);
+ assert(nl->rbuffer);
/* read nothing, just get the pending message size */
- r = socket_recv_message(rtnl->fd, &iov, NULL, true);
+ r = socket_recv_message(nl->fd, &iov, NULL, true);
if (r <= 0)
return r;
else
len = (size_t) r;
/* make room for the pending message */
- if (!greedy_realloc((void **)&rtnl->rbuffer, len, sizeof(uint8_t)))
+ if (!greedy_realloc((void**) &nl->rbuffer, len, sizeof(uint8_t)))
return -ENOMEM;
- allocated = MALLOC_SIZEOF_SAFE(rtnl->rbuffer);
- iov = IOVEC_MAKE(rtnl->rbuffer, allocated);
+ allocated = MALLOC_SIZEOF_SAFE(nl->rbuffer);
+ iov = IOVEC_MAKE(nl->rbuffer, allocated);
/* read the pending message */
- r = socket_recv_message(rtnl->fd, &iov, &group, false);
+ r = socket_recv_message(nl->fd, &iov, &group, false);
if (r <= 0)
return r;
else
@@ -313,22 +313,22 @@ int socket_read_message(sd_netlink *rtnl) {
/* message did not fit in read buffer */
return -EIO;
- if (NLMSG_OK(rtnl->rbuffer, len) && rtnl->rbuffer->nlmsg_flags & NLM_F_MULTI) {
+ if (NLMSG_OK(nl->rbuffer, len) && nl->rbuffer->nlmsg_flags & NLM_F_MULTI) {
multi_part = true;
- for (i = 0; i < rtnl->rqueue_partial_size; i++)
- if (rtnl_message_get_serial(rtnl->rqueue_partial[i]) ==
- rtnl->rbuffer->nlmsg_seq) {
- first = rtnl->rqueue_partial[i];
+ for (i = 0; i < nl->rqueue_partial_size; i++)
+ if (message_get_serial(nl->rqueue_partial[i]) ==
+ nl->rbuffer->nlmsg_seq) {
+ first = nl->rqueue_partial[i];
break;
}
}
- for (struct nlmsghdr *new_msg = rtnl->rbuffer; NLMSG_OK(new_msg, len) && !done; new_msg = NLMSG_NEXT(new_msg, len)) {
+ for (struct nlmsghdr *new_msg = nl->rbuffer; NLMSG_OK(new_msg, len) && !done; new_msg = NLMSG_NEXT(new_msg, len)) {
_cleanup_(sd_netlink_message_unrefp) sd_netlink_message *m = NULL;
const NLType *nl_type;
- if (!group && new_msg->nlmsg_pid != rtnl->sockaddr.nl.nl_pid)
+ if (!group && new_msg->nlmsg_pid != nl->sockaddr.nl.nl_pid)
/* not broadcast and not for us */
continue;
@@ -346,7 +346,7 @@ int socket_read_message(sd_netlink *rtnl) {
}
/* check that we support this message type */
- r = type_system_root_get_type(rtnl, &nl_type, new_msg->nlmsg_type);
+ r = type_system_root_get_type(nl, &nl_type, new_msg->nlmsg_type);
if (r < 0) {
if (r == -EOPNOTSUPP)
log_debug("sd-netlink: ignored message with unknown type: %i",
@@ -361,7 +361,7 @@ int socket_read_message(sd_netlink *rtnl) {
continue;
}
- r = message_new_empty(rtnl, &m);
+ r = message_new_empty(nl, &m);
if (r < 0)
return r;
@@ -372,7 +372,7 @@ int socket_read_message(sd_netlink *rtnl) {
return -ENOMEM;
/* seal and parse the top-level message */
- r = sd_netlink_message_rewind(m, rtnl);
+ r = sd_netlink_message_rewind(m, nl);
if (r < 0)
return r;
@@ -390,31 +390,31 @@ int socket_read_message(sd_netlink *rtnl) {
if (!multi_part || done) {
/* we got a complete message, push it on the read queue */
- r = rtnl_rqueue_make_room(rtnl);
+ r = netlink_rqueue_make_room(nl);
if (r < 0)
return r;
- rtnl->rqueue[rtnl->rqueue_size++] = TAKE_PTR(first);
+ nl->rqueue[nl->rqueue_size++] = TAKE_PTR(first);
- if (multi_part && (i < rtnl->rqueue_partial_size)) {
+ if (multi_part && (i < nl->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--;
+ memmove(nl->rqueue_partial + i, nl->rqueue_partial + i + 1,
+ sizeof(sd_netlink_message*) * (nl->rqueue_partial_size - i - 1));
+ nl->rqueue_partial_size--;
}
return 1;
} else {
/* we only got a partial multi-part message, push it on the
partial read queue */
- if (i < rtnl->rqueue_partial_size)
- rtnl->rqueue_partial[i] = TAKE_PTR(first);
+ if (i < nl->rqueue_partial_size)
+ nl->rqueue_partial[i] = TAKE_PTR(first);
else {
- r = rtnl_rqueue_partial_make_room(rtnl);
+ r = netlink_rqueue_partial_make_room(nl);
if (r < 0)
return r;
- rtnl->rqueue_partial[rtnl->rqueue_partial_size++] = TAKE_PTR(first);
+ nl->rqueue_partial[nl->rqueue_partial_size++] = TAKE_PTR(first);
}
return 0;