Home
last modified time | relevance | path

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

/systemd-251/src/libsystemd/sd-netlink/
Dsd-netlink.c177 sd_netlink_message_unref(nl->rqueue[i]); in netlink_free()
178 free(nl->rqueue); in netlink_free()
299 if (!GREEDY_REALLOC(nl->rqueue, nl->rqueue_size + 1)) in netlink_rqueue_make_room()
337 *message = nl->rqueue[0]; in dispatch_rqueue()
339 memmove(nl->rqueue, nl->rqueue + 1, sizeof(sd_netlink_message*) * nl->rqueue_size); in dispatch_rqueue()
684 received_serial = message_get_serial(nl->rqueue[i]); in sd_netlink_read()
688 incoming = nl->rqueue[i]; in sd_netlink_read()
691 memmove(nl->rqueue + i, nl->rqueue + i + 1, in sd_netlink_read()
Dnetlink-internal.h75 sd_netlink_message **rqueue; member
Dnetlink-socket.c395 nl->rqueue[nl->rqueue_size++] = TAKE_PTR(first); in socket_read_message()
/systemd-251/src/libsystemd/sd-bus/
Dsd-bus.c153 bus_message_unref_queued(b->rqueue[--b->rqueue_size], b); in bus_reset_queues()
155 b->rqueue = mfree(b->rqueue); in bus_reset_queues()
499 memmove(bus->rqueue + 1, bus->rqueue, sizeof(sd_bus_message*) * bus->rqueue_size); in synthesize_connected_signal()
500 bus->rqueue[0] = bus_message_ref_queued(m, bus); in synthesize_connected_signal()
2051 if (!GREEDY_REALLOC(bus->rqueue, bus->rqueue_size + 1)) in bus_rqueue_make_room()
2061 bus_message_unref_queued(bus->rqueue[i], bus); 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()
2076 *m = sd_bus_message_ref(bus->rqueue[0]); in dispatch_rqueue()
2398 incoming = sd_bus_message_ref(bus->rqueue[i]); in sd_bus_call()
4408 bus->rqueue[bus->rqueue_size++] = bus_message_ref_queued(m, bus); in sd_bus_enqueue_for_read()
Dbus-internal.h223 sd_bus_message **rqueue; member
Dbus-socket.c1178 bus->rqueue[bus->rqueue_size++] = bus_message_ref_queued(t, bus); in bus_socket_make_message()