aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/lib/iomgr/workqueue_posix.c
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2016-08-31 12:59:24 -0700
committerGravatar Craig Tiller <ctiller@google.com>2016-08-31 12:59:24 -0700
commita7cd41cc46bf60aed17dea8ea2d3787814c45475 (patch)
treedc1b2f991fcbac444056df0aab9d1b8d8a8b8881 /src/core/lib/iomgr/workqueue_posix.c
parentd58daa2b2f577dbf6c629e9914f405df223aac8d (diff)
Note polling coverage when taking combiner locks: resolves offload issues
Diffstat (limited to 'src/core/lib/iomgr/workqueue_posix.c')
-rw-r--r--src/core/lib/iomgr/workqueue_posix.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/core/lib/iomgr/workqueue_posix.c b/src/core/lib/iomgr/workqueue_posix.c
index ecfea68f56..6c27c3b41e 100644
--- a/src/core/lib/iomgr/workqueue_posix.c
+++ b/src/core/lib/iomgr/workqueue_posix.c
@@ -171,7 +171,7 @@ static void on_readable(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) {
wakeup(exec_ctx, workqueue);
}
grpc_closure *cl = (grpc_closure *)n;
- grpc_error *clerr = cl->error;
+ grpc_error *clerr = cl->error_data.error;
cl->cb(exec_ctx, cl->cb_arg, clerr);
GRPC_ERROR_UNREF(clerr);
}
@@ -185,7 +185,7 @@ void grpc_workqueue_enqueue(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue,
GPR_TIMER_BEGIN("workqueue.enqueue", 0);
gpr_atm last = gpr_atm_full_fetch_add(&workqueue->state, 2);
GPR_ASSERT(last & 1);
- closure->error = error;
+ closure->error_data.error = error;
gpr_mpscq_push(&workqueue->queue, &closure->next_data.atm_next);
if (last == 1) {
wakeup(exec_ctx, workqueue);