|
|
|
@ -121,7 +121,7 @@ static void session_shutdown_cb(grpc_exec_ctx *exec_ctx, void *arg, /*session */ |
|
|
|
|
int success) { |
|
|
|
|
session *se = arg; |
|
|
|
|
server *sv = se->sv; |
|
|
|
|
grpc_fd_orphan(exec_ctx, se->em_fd, NULL, "a"); |
|
|
|
|
grpc_fd_orphan(exec_ctx, se->em_fd, NULL, 0, "a"); |
|
|
|
|
gpr_free(se); |
|
|
|
|
/* Start to shutdown listen fd. */ |
|
|
|
|
grpc_fd_shutdown(exec_ctx, sv->em_fd); |
|
|
|
@ -177,7 +177,7 @@ static void listen_shutdown_cb(grpc_exec_ctx *exec_ctx, void *arg /*server */, |
|
|
|
|
int success) { |
|
|
|
|
server *sv = arg; |
|
|
|
|
|
|
|
|
|
grpc_fd_orphan(exec_ctx, sv->em_fd, NULL, "b"); |
|
|
|
|
grpc_fd_orphan(exec_ctx, sv->em_fd, NULL, 0, "b"); |
|
|
|
|
|
|
|
|
|
gpr_mu_lock(GRPC_POLLSET_MU(&g_pollset)); |
|
|
|
|
sv->done = 1; |
|
|
|
@ -294,7 +294,7 @@ static void client_init(client *cl) { |
|
|
|
|
static void client_session_shutdown_cb(grpc_exec_ctx *exec_ctx, |
|
|
|
|
void *arg /*client */, int success) { |
|
|
|
|
client *cl = arg; |
|
|
|
|
grpc_fd_orphan(exec_ctx, cl->em_fd, NULL, "c"); |
|
|
|
|
grpc_fd_orphan(exec_ctx, cl->em_fd, NULL, 0, "c"); |
|
|
|
|
cl->done = 1; |
|
|
|
|
grpc_pollset_kick(&g_pollset, NULL); |
|
|
|
|
} |
|
|
|
@ -503,7 +503,7 @@ static void test_grpc_fd_change(void) { |
|
|
|
|
GPR_ASSERT(b.cb_that_ran == second_read_callback); |
|
|
|
|
gpr_mu_unlock(GRPC_POLLSET_MU(&g_pollset)); |
|
|
|
|
|
|
|
|
|
grpc_fd_orphan(&exec_ctx, em_fd, NULL, "d"); |
|
|
|
|
grpc_fd_orphan(&exec_ctx, em_fd, NULL, 0, "d"); |
|
|
|
|
grpc_exec_ctx_finish(&exec_ctx); |
|
|
|
|
destroy_change_data(&a); |
|
|
|
|
destroy_change_data(&b); |
|
|
|
|