|
|
|
@ -165,7 +165,7 @@ static void maybe_wake_one_watcher(grpc_fd *fd) { |
|
|
|
|
gpr_mu_unlock(&fd->watcher_mu); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static void wake_all_watchers(grpc_fd *fd) { |
|
|
|
|
static void wake_all_watchers_locked(grpc_fd *fd) { |
|
|
|
|
grpc_fd_watcher *watcher; |
|
|
|
|
for (watcher = fd->inactive_watcher_root.next; |
|
|
|
|
watcher != &fd->inactive_watcher_root; watcher = watcher->next) { |
|
|
|
@ -185,7 +185,7 @@ void grpc_fd_orphan(grpc_fd *fd, grpc_iomgr_cb_func on_done, void *user_data) { |
|
|
|
|
shutdown(fd->fd, SHUT_RDWR); |
|
|
|
|
ref_by(fd, 1); /* remove active status, but keep referenced */ |
|
|
|
|
gpr_mu_lock(&fd->watcher_mu); |
|
|
|
|
wake_all_watchers(fd); |
|
|
|
|
wake_all_watchers_locked(fd); |
|
|
|
|
gpr_mu_unlock(&fd->watcher_mu); |
|
|
|
|
unref_by(fd, 2); /* drop the reference */ |
|
|
|
|
} |
|
|
|
|