Home
last modified time | relevance | path

Searched refs:rqueue_size (Results 1 – 6 of 6) sorted by relevance

/systemd-251/src/libsystemd/sd-netlink/
Dsd-netlink.c176 for (i = 0; i < nl->rqueue_size; i++) in netlink_free()
294 if (nl->rqueue_size >= NETLINK_RQUEUE_MAX) in netlink_rqueue_make_room()
299 if (!GREEDY_REALLOC(nl->rqueue, nl->rqueue_size + 1)) in netlink_rqueue_make_room()
325 if (nl->rqueue_size <= 0) { in dispatch_rqueue()
338 nl->rqueue_size--; in dispatch_rqueue()
339 memmove(nl->rqueue, nl->rqueue + 1, sizeof(sd_netlink_message*) * nl->rqueue_size); in dispatch_rqueue()
579 if (nl->rqueue_size > 0) in sd_netlink_wait()
679 for (unsigned i = 0; i < nl->rqueue_size; i++) { in sd_netlink_read()
692 sizeof(sd_netlink_message*) * (nl->rqueue_size - i - 1)); in sd_netlink_read()
693 nl->rqueue_size--; in sd_netlink_read()
[all …]
Dnetlink-internal.h76 unsigned rqueue_size; member
Dnetlink-socket.c395 nl->rqueue[nl->rqueue_size++] = TAKE_PTR(first); in socket_read_message()
/systemd-251/src/libsystemd/sd-bus/
Dsd-bus.c152 while (b->rqueue_size > 0) in bus_reset_queues()
153 bus_message_unref_queued(b->rqueue[--b->rqueue_size], b); in bus_reset_queues()
499 memmove(bus->rqueue + 1, bus->rqueue, sizeof(sd_bus_message*) * bus->rqueue_size); in synthesize_connected_signal()
501 bus->rqueue_size++; in synthesize_connected_signal()
2048 if (bus->rqueue_size >= BUS_RQUEUE_MAX) in bus_rqueue_make_room()
2051 if (!GREEDY_REALLOC(bus->rqueue, bus->rqueue_size + 1)) in bus_rqueue_make_room()
2059 assert(i < bus->rqueue_size); in rqueue_drop_one()
2062 …memmove(bus->rqueue + i, bus->rqueue + i + 1, sizeof(sd_bus_message*) * (bus->rqueue_size - i - 1)… in rqueue_drop_one()
2063 bus->rqueue_size--; in rqueue_drop_one()
2074 if (bus->rqueue_size > 0) { in dispatch_rqueue()
[all …]
Dbus-internal.h224 size_t rqueue_size; member
Dbus-socket.c1178 bus->rqueue[bus->rqueue_size++] = bus_message_ref_queued(t, bus); in bus_socket_make_message()