diff options
| author |  Craig Tiller <ctiller@google.com> | 2016-05-07 11:26:50 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2016-05-07 11:26:50 -0700 |
| commit | 1aee5362f43ece8eb77ba219c163f1169d0d0b24 (patch) | |
| tree | e703e9cbfa3c11c904dd34bbd13936b7c406ecd1 /src/core/lib/iomgr/workqueue_posix.c | |
| parent | 0f75fbe7edf92d550c48f51555024b323396e210 (diff) | |
Progress converting to new error system
Diffstat (limited to 'src/core/lib/iomgr/workqueue_posix.c')
| -rw-r--r-- | src/core/lib/iomgr/workqueue_posix.c | 8 |
1 files changed, 1 insertions, 7 deletions
diff --git a/src/core/lib/iomgr/workqueue_posix.c b/src/core/lib/iomgr/workqueue_posix.c index 1187e627a2..66879ba7b3 100644 --- a/src/core/lib/iomgr/workqueue_posix.c +++ b/src/core/lib/iomgr/workqueue_posix.c @@ -106,16 +106,10 @@ void grpc_workqueue_add_to_pollset(grpc_exec_ctx *exec_ctx, grpc_pollset_add_fd(exec_ctx, pollset, workqueue->wakeup_read_fd); } -grpc_error *grpc_workqueue_flush(grpc_exec_ctx *exec_ctx, - grpc_workqueue *workqueue) { - grpc_error *error = GRPC_ERROR_NONE; +void grpc_workqueue_flush(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue) { gpr_mu_lock(&workqueue->mu); - if (grpc_closure_list_empty(workqueue->closure_list)) { - error = grpc_wakeup_fd_wakeup(&workqueue->wakeup_fd); - } grpc_exec_ctx_enqueue_list(exec_ctx, &workqueue->closure_list, NULL); gpr_mu_unlock(&workqueue->mu); - return error; } static void on_readable(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) { |