Searched refs:wqueue (Results 1 – 2 of 2) sorted by relevance
| /systemd-251/src/libsystemd/sd-bus/ |
| D | sd-bus.c | 158 bus_message_unref_queued(b->wqueue[--b->wqueue_size], b); in bus_reset_queues()
160 b->wqueue = mfree(b->wqueue); in bus_reset_queues()
255 if (!GREEDY_REALLOC(b->wqueue, 1)) in sd_bus_new()
2010 r = bus_write_message(bus, bus->wqueue[0], &bus->windex); in dispatch_wqueue()
2016 else if (bus->windex >= BUS_MESSAGE_SIZE(bus->wqueue[0])) { in dispatch_wqueue()
2028 bus_message_unref_queued(bus->wqueue[0], bus); in dispatch_wqueue()
2029 … memmove(bus->wqueue, bus->wqueue + 1, sizeof(sd_bus_message*) * bus->wqueue_size); in dispatch_wqueue()
2156 bus->wqueue[0] = bus_message_ref_queued(m, bus); in sd_bus_send()
2167 if (!GREEDY_REALLOC(bus->wqueue, bus->wqueue_size + 1)) in sd_bus_send()
2170 bus->wqueue[bus->wqueue_size++] = bus_message_ref_queued(m, bus); in sd_bus_send()
|
| D | bus-internal.h | 226 sd_bus_message **wqueue; member
|