Lines Matching refs:rqueue_size
152 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()
2376 i = bus->rqueue_size; in sd_bus_call()
2395 while (i < bus->rqueue_size) { in sd_bus_call()
2538 if (bus->rqueue_size <= 0) in sd_bus_get_events()
2578 if (bus->rqueue_size > 0) { in sd_bus_get_timeout()
3335 if (bus->rqueue_size > 0) in sd_bus_wait()
4326 *ret = bus->rqueue_size; in sd_bus_get_n_queued_read()
4408 bus->rqueue[bus->rqueue_size++] = bus_message_ref_queued(m, bus); in sd_bus_enqueue_for_read()