diff options
author | 2017-05-11 12:27:45 -0700 | |
---|---|---|
committer | 2017-05-11 12:27:45 -0700 | |
commit | 54773cfed86f011b791984f9e7a1084807d9f007 (patch) | |
tree | b3293bc8a90411527fc6561a8bd9e5ad2394941a /src/core/lib/support/mpscq.h | |
parent | b79e809918aeea3f5a64aea6b870bec57128bd6f (diff) | |
parent | 45b89fb11ca3cd524787aeba7a1270f744a1256c (diff) |
Merge github.com:grpc/grpc into serve_fries
Diffstat (limited to 'src/core/lib/support/mpscq.h')
-rw-r--r-- | src/core/lib/support/mpscq.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/core/lib/support/mpscq.h b/src/core/lib/support/mpscq.h index cb6456f2c8..b3a171678a 100644 --- a/src/core/lib/support/mpscq.h +++ b/src/core/lib/support/mpscq.h @@ -67,6 +67,8 @@ bool gpr_mpscq_push(gpr_mpscq *q, gpr_mpscq_node *n); // the queue is empty!!) // Thread compatible - can only be called from one thread at a time gpr_mpscq_node *gpr_mpscq_pop(gpr_mpscq *q); +// Pop a node; sets *empty to true if the queue is empty, or false if it is not +gpr_mpscq_node *gpr_mpscq_pop_and_check_end(gpr_mpscq *q, bool *empty); // An mpscq with a spinlock: it's safe to pop from multiple threads, but doing // only one thread will succeed concurrently |