Lines Matching refs:wqueue_size
157 while (b->wqueue_size > 0) in bus_reset_queues()
158 bus_message_unref_queued(b->wqueue[--b->wqueue_size], b); in bus_reset_queues()
2008 while (bus->wqueue_size > 0) { in dispatch_wqueue()
2027 bus->wqueue_size--; in dispatch_wqueue()
2029 … memmove(bus->wqueue, bus->wqueue + 1, sizeof(sd_bus_message*) * bus->wqueue_size); in dispatch_wqueue()
2137 if (IN_SET(bus->state, BUS_RUNNING, BUS_HELLO) && bus->wqueue_size <= 0) { in sd_bus_send()
2157 bus->wqueue_size = 1; in sd_bus_send()
2164 if (bus->wqueue_size >= BUS_WQUEUE_MAX) 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()
2540 if (bus->wqueue_size > 0) in sd_bus_get_events()
3362 if (bus->wqueue_size <= 0) in sd_bus_flush()
3376 if (bus->wqueue_size <= 0) in sd_bus_flush()
4336 *ret = bus->wqueue_size; in sd_bus_get_n_queued_write()