diff options
| author |  David Garcia Quintas <dgq@google.com> | 2016-01-29 15:05:53 -0800 |
|---|---|---|
| committer | David Garcia Quintas <dgq@google.com> | 2016-01-29 15:05:53 -0800 |
| commit | dd18c4a4a32f2038b16d22235e89c64a4ecb6b33 (patch) | |
| tree | da88b22ea1ade0616c201b40c83199321114a5b3 /src/core/iomgr/fd_posix.c | |
| parent | a4c9218889bdc1c90146d3ca179f2afc4d3c32f2 (diff) | |
| parent | ed00b0366d9022bdfe47bbf4c0b4bff1bf03d195 (diff) | |
Merge branch 'master' of github.com:grpc/grpc into grpclb_api
Diffstat (limited to 'src/core/iomgr/fd_posix.c')
| -rw-r--r-- | src/core/iomgr/fd_posix.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/core/iomgr/fd_posix.c b/src/core/iomgr/fd_posix.c index 89c938bc04..85eadd754b 100644 --- a/src/core/iomgr/fd_posix.c +++ b/src/core/iomgr/fd_posix.c @@ -218,7 +218,7 @@ static void close_fd_locked(grpc_exec_ctx *exec_ctx, grpc_fd *fd) { } else { grpc_remove_fd_from_all_epoll_sets(fd->fd); } - grpc_exec_ctx_enqueue(exec_ctx, fd->on_done_closure, 1); + grpc_exec_ctx_enqueue(exec_ctx, fd->on_done_closure, true, NULL); } int grpc_fd_wrapped_fd(grpc_fd *fd) { @@ -273,7 +273,7 @@ static void notify_on_locked(grpc_exec_ctx *exec_ctx, grpc_fd *fd, } else if (*st == CLOSURE_READY) { /* already ready ==> queue the closure to run immediately */ *st = CLOSURE_NOT_READY; - grpc_exec_ctx_enqueue(exec_ctx, closure, !fd->shutdown); + grpc_exec_ctx_enqueue(exec_ctx, closure, !fd->shutdown, NULL); maybe_wake_one_watcher_locked(fd); } else { /* upcallptr was set to a different closure. This is an error! */ @@ -296,7 +296,7 @@ static int set_ready_locked(grpc_exec_ctx *exec_ctx, grpc_fd *fd, return 0; } else { /* waiting ==> queue closure */ - grpc_exec_ctx_enqueue(exec_ctx, *st, !fd->shutdown); + grpc_exec_ctx_enqueue(exec_ctx, *st, !fd->shutdown, NULL); *st = CLOSURE_NOT_READY; return 1; } |