Searched refs:reply_callbacks_prioq (Results 1 – 6 of 6) sorted by relevance
/systemd-251/src/libsystemd/sd-netlink/ |
D | sd-netlink.c | 191 prioq_free(nl->reply_callbacks_prioq); in netlink_free() 353 c = prioq_peek(nl->reply_callbacks_prioq); in process_timeout() 365 assert_se(prioq_pop(nl->reply_callbacks_prioq) == c); in process_timeout() 400 prioq_remove(nl->reply_callbacks_prioq, c, &c->prioq_idx); in process_reply() 623 r = prioq_ensure_allocated(&nl->reply_callbacks_prioq, timeout_compare); in sd_netlink_call_async() 644 … r = prioq_put(nl->reply_callbacks_prioq, &slot->reply_callback, &slot->reply_callback.prioq_idx); in sd_netlink_call_async() 778 c = prioq_peek(nl->reply_callbacks_prioq); in sd_netlink_get_timeout()
|
D | netlink-internal.h | 87 struct Prioq *reply_callbacks_prioq; member
|
D | netlink-slot.c | 67 … prioq_remove(nl->reply_callbacks_prioq, &slot->reply_callback, &slot->reply_callback.prioq_idx); in netlink_slot_disconnect()
|
/systemd-251/src/libsystemd/sd-bus/ |
D | bus-internal.h | 237 Prioq *reply_callbacks_prioq; member
|
D | sd-bus.c | 211 prioq_free(b->reply_callbacks_prioq); in bus_free() 2270 r = prioq_ensure_allocated(&bus->reply_callbacks_prioq, timeout_compare); in sd_bus_call_async() 2298 … r = prioq_put(bus->reply_callbacks_prioq, &s->reply_callback, &s->reply_callback.prioq_idx); in sd_bus_call_async() 2583 c = prioq_peek(bus->reply_callbacks_prioq); in sd_bus_get_timeout() 2623 c = prioq_peek(bus->reply_callbacks_prioq); in process_timeout() 2645 assert_se(prioq_pop(bus->reply_callbacks_prioq) == c); in process_timeout() 2757 prioq_remove(bus->reply_callbacks_prioq, c, &c->prioq_idx); in process_reply() 3091 prioq_remove(bus->reply_callbacks_prioq, c, &c->prioq_idx); in process_closing_reply_callback()
|
D | bus-slot.c | 56 …prioq_remove(slot->bus->reply_callbacks_prioq, &slot->reply_callback, &slot->reply_callback.prioq_… in bus_slot_disconnect()
|