|
|
@ -526,7 +526,8 @@ static grpc_error *fd_shutdown_error(bool shutdown) { |
|
|
|
static void notify_on_locked(grpc_exec_ctx *exec_ctx, grpc_fd *fd, |
|
|
|
static void notify_on_locked(grpc_exec_ctx *exec_ctx, grpc_fd *fd, |
|
|
|
grpc_closure **st, grpc_closure *closure) { |
|
|
|
grpc_closure **st, grpc_closure *closure) { |
|
|
|
if (fd->shutdown) { |
|
|
|
if (fd->shutdown) { |
|
|
|
grpc_exec_ctx_enqueue(exec_ctx, closure, false, NULL); |
|
|
|
grpc_exec_ctx_sched(exec_ctx, closure, GRPC_ERROR_CREATE("FD shutdown"), |
|
|
|
|
|
|
|
NULL); |
|
|
|
} else if (*st == CLOSURE_NOT_READY) { |
|
|
|
} else if (*st == CLOSURE_NOT_READY) { |
|
|
|
/* not ready ==> switch to a waiting state by setting the closure */ |
|
|
|
/* not ready ==> switch to a waiting state by setting the closure */ |
|
|
|
*st = closure; |
|
|
|
*st = closure; |
|
|
|