Searched refs:reply_callback (Results 1 – 8 of 8) sorted by relevance
| /systemd-251/src/libsystemd/sd-netlink/ |
| D | sd-netlink.c | 346 struct reply_callback *c; in process_timeout()
369 slot = container_of(c, sd_netlink_slot, reply_callback); in process_timeout()
385 struct reply_callback *c; in process_reply()
411 slot = container_of(c, sd_netlink_slot, reply_callback); in process_reply()
586 const struct reply_callback *x = a, *y = b; in timeout_compare()
628 …k_slot_allocate(nl, !ret_slot, NETLINK_REPLY_CALLBACK, sizeof(struct reply_callback), userdata, de… in sd_netlink_call_async()
632 slot->reply_callback.callback = callback; in sd_netlink_call_async()
633 slot->reply_callback.timeout = calc_elapse(usec); in sd_netlink_call_async()
635 k = sd_netlink_send(nl, m, &slot->reply_callback.serial); in sd_netlink_call_async()
639 … hashmap_put(nl->reply_callbacks, UINT32_TO_PTR(slot->reply_callback.serial), &slot->reply_callbac… in sd_netlink_call_async()
[all …]
|
| D | netlink-slot.c | 26 slot = malloc0(offsetof(sd_netlink_slot, reply_callback) + extra); in netlink_slot_allocate()
64 (void) hashmap_remove(nl->reply_callbacks, &slot->reply_callback.serial); in netlink_slot_disconnect()
66 if (slot->reply_callback.timeout != 0) in netlink_slot_disconnect()
67 … prioq_remove(nl->reply_callbacks_prioq, &slot->reply_callback, &slot->reply_callback.prioq_idx); in netlink_slot_disconnect()
|
| D | netlink-internal.h | 19 struct reply_callback { struct
55 struct reply_callback reply_callback; member
|
| /systemd-251/src/libsystemd/sd-bus/ |
| D | bus-slot.c | 22 slot = malloc0(offsetof(sd_bus_slot, reply_callback) + extra); in bus_slot_allocate()
52 if (slot->reply_callback.cookie != 0) in bus_slot_disconnect()
53 … ordered_hashmap_remove(slot->bus->reply_callbacks, &slot->reply_callback.cookie); in bus_slot_disconnect()
55 if (slot->reply_callback.timeout_usec != 0) in bus_slot_disconnect()
56 …prioq_remove(slot->bus->reply_callbacks_prioq, &slot->reply_callback, &slot->reply_callback.prioq_… in bus_slot_disconnect()
|
| D | bus-internal.h | 23 struct reply_callback { struct
151 struct reply_callback reply_callback; member
|
| D | sd-bus.c | 599 struct reply_callback *c; in bus_start_running()
2226 const struct reply_callback *x = a, *y = b; in timeout_compare()
2283 … s = bus_slot_allocate(bus, !slot, BUS_REPLY_CALLBACK, sizeof(struct reply_callback), userdata); in sd_bus_call_async()
2287 s->reply_callback.callback = callback; in sd_bus_call_async()
2289 s->reply_callback.cookie = BUS_MESSAGE_COOKIE(m); in sd_bus_call_async()
2290 … r = ordered_hashmap_put(bus->reply_callbacks, &s->reply_callback.cookie, &s->reply_callback); in sd_bus_call_async()
2292 s->reply_callback.cookie = 0; in sd_bus_call_async()
2296 s->reply_callback.timeout_usec = calc_elapse(bus, m->timeout); in sd_bus_call_async()
2297 if (s->reply_callback.timeout_usec != 0) { 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()
[all …]
|
| /systemd-251/src/fuzz/ |
| D | fuzz-varlink.c | 20 static int reply_callback(Varlink *v, JsonVariant *p, const char *error_id, VarlinkReplyFlags flags… in reply_callback() function
119 assert_se(varlink_bind_reply(c, reply_callback) >= 0); in LLVMFuzzerTestOneInput()
|
| /systemd-251/src/shared/ |
| D | varlink.c | 125 VarlinkReply reply_callback; member
634 if (!v->reply_callback) in varlink_dispatch_local_error()
637 r = v->reply_callback(v, NULL, error, VARLINK_REPLY_ERROR|VARLINK_REPLY_LOCAL, v->userdata); in varlink_dispatch_local_error()
749 if (v->reply_callback) { in varlink_dispatch_reply()
750 r = v->reply_callback(v, parameters, error, flags, v->userdata); in varlink_dispatch_reply()
1760 if (callback && v->reply_callback && callback != v->reply_callback) in varlink_bind_reply()
1763 v->reply_callback = callback; in varlink_bind_reply()
|