Searched refs:gpr_mpscq_node (Results 1 – 9 of 9) sorted by relevance
36 bool gpr_mpscq_push(gpr_mpscq* q, gpr_mpscq_node* n) { in gpr_mpscq_push()38 gpr_mpscq_node* prev = in gpr_mpscq_push()39 (gpr_mpscq_node*)gpr_atm_full_xchg(&q->head, (gpr_atm)n); in gpr_mpscq_push()44 gpr_mpscq_node* gpr_mpscq_pop(gpr_mpscq* q) { in gpr_mpscq_pop()49 gpr_mpscq_node* gpr_mpscq_pop_and_check_end(gpr_mpscq* q, bool* empty) { in gpr_mpscq_pop_and_check_end()50 gpr_mpscq_node* tail = q->tail; in gpr_mpscq_pop_and_check_end()51 gpr_mpscq_node* next = (gpr_mpscq_node*)gpr_atm_acq_load(&tail->next); in gpr_mpscq_pop_and_check_end()60 next = (gpr_mpscq_node*)gpr_atm_acq_load(&tail->next); in gpr_mpscq_pop_and_check_end()67 gpr_mpscq_node* head = (gpr_mpscq_node*)gpr_atm_acq_load(&q->head); in gpr_mpscq_pop_and_check_end()74 next = (gpr_mpscq_node*)gpr_atm_acq_load(&tail->next); in gpr_mpscq_pop_and_check_end()[all …]
35 typedef struct gpr_mpscq_node { struct37 } gpr_mpscq_node; argument44 gpr_mpscq_node* tail;45 gpr_mpscq_node stub;54 bool gpr_mpscq_push(gpr_mpscq* q, gpr_mpscq_node* n);58 gpr_mpscq_node* gpr_mpscq_pop(gpr_mpscq* q);60 gpr_mpscq_node* gpr_mpscq_pop_and_check_end(gpr_mpscq* q, bool* empty);75 bool gpr_locked_mpscq_push(gpr_locked_mpscq* q, gpr_mpscq_node* n);80 gpr_mpscq_node* gpr_locked_mpscq_try_pop(gpr_locked_mpscq* q);84 gpr_mpscq_node* gpr_locked_mpscq_pop(gpr_locked_mpscq* q);
33 gpr_mpscq_node node;95 gpr_mpscq_node* n; in test_mt()132 gpr_mpscq_node* n; in pull_thread()
39 gpr_mpscq_node node;
429 gpr_mpscq_push(&q->queue, reinterpret_cast<gpr_mpscq_node*>(c)); in cq_event_queue_push()
65 gpr_mpscq_node request_link; /* must be first */
96 reinterpret_cast<gpr_mpscq_node*>(closure)); in grpc_call_combiner_start()
72 gpr_mpscq_node atm_next;
244 gpr_mpscq_node* n = gpr_mpscq_pop(&lock->queue); in grpc_combiner_continue_exec_ctx()