diff options
| author |  Yang Gao <yangg@google.com> | 2015-04-10 10:18:20 -0700 |
|---|---|---|
| committer | Yang Gao <yangg@google.com> | 2015-04-10 10:18:20 -0700 |
| commit | ffda06782526820efd77f6d1c61177daa7636462 (patch) | |
| tree | 141dfb367db99ec8ea9f56c71213db13fce13161 /src/core/surface/completion_queue.c | |
| parent | 8158c6b34e2be6f5cca9b2e4e800acb0ad692c47 (diff) | |
| parent | bad86a0ff26138fcf1a0d5cfab8dd3077db11339 (diff) | |
Merge remote-tracking branch 'upstream/master' into interop
Diffstat (limited to 'src/core/surface/completion_queue.c')
| -rw-r--r-- | src/core/surface/completion_queue.c | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/core/surface/completion_queue.c b/src/core/surface/completion_queue.c index 6a1d83ce5d..24f4a05071 100644 --- a/src/core/surface/completion_queue.c +++ b/src/core/surface/completion_queue.c @@ -432,3 +432,11 @@ void grpc_cq_dump_pending_ops(grpc_completion_queue *cc) { grpc_pollset *grpc_cq_pollset(grpc_completion_queue *cc) { return &cc->pollset; } + +void grpc_cq_hack_spin_pollset(grpc_completion_queue *cc) { + gpr_mu_lock(GRPC_POLLSET_MU(&cc->pollset)); + grpc_pollset_kick(&cc->pollset); + grpc_pollset_work(&cc->pollset, + gpr_time_add(gpr_now(), gpr_time_from_millis(100))); + gpr_mu_unlock(GRPC_POLLSET_MU(&cc->pollset)); +} |