|
|
|
|
@ -308,7 +308,7 @@ static void waiter_defer_cb(void* arg) {
|
|
|
|
|
h->defer_cb(h->defer_q, h->defer_arg); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
inline void queue_waiter_call(struct ll_queue* q, queue_threshold_callback_fn cb, void* arg, |
|
|
|
|
static inline void queue_waiter_call(struct ll_queue* q, queue_threshold_callback_fn cb, void* arg, |
|
|
|
|
struct queue_waiter_handle* h) { |
|
|
|
|
if (q->waiter_defer) { |
|
|
|
|
h->defer_q = q; h->defer_cb = cb; h->defer_arg = arg; |
|
|
|
|
|