Skip to content
Snippets Groups Projects
Commit 767adee1 authored by Yang Gao's avatar Yang Gao Committed by GitHub
Browse files

Merge pull request #10028 from yang-g/orphan

Only cleanup the listeners when shutdown is set
parents be9f8ae8 aef398bd
No related branches found
No related tags found
No related merge requests found
...@@ -260,10 +260,7 @@ static void deactivated_all_ports(grpc_exec_ctx *exec_ctx, grpc_tcp_server *s) { ...@@ -260,10 +260,7 @@ static void deactivated_all_ports(grpc_exec_ctx *exec_ctx, grpc_tcp_server *s) {
/* delete ALL the things */ /* delete ALL the things */
gpr_mu_lock(&s->mu); gpr_mu_lock(&s->mu);
if (!s->shutdown) { GPR_ASSERT(s->shutdown);
gpr_mu_unlock(&s->mu);
return;
}
if (s->head) { if (s->head) {
grpc_tcp_listener *sp; grpc_tcp_listener *sp;
...@@ -469,7 +466,7 @@ static void on_read(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *err) { ...@@ -469,7 +466,7 @@ static void on_read(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *err) {
error: error:
gpr_mu_lock(&sp->server->mu); gpr_mu_lock(&sp->server->mu);
if (0 == --sp->server->active_ports) { if (0 == --sp->server->active_ports && sp->server->shutdown) {
gpr_mu_unlock(&sp->server->mu); gpr_mu_unlock(&sp->server->mu);
deactivated_all_ports(exec_ctx, sp->server); deactivated_all_ports(exec_ctx, sp->server);
} else { } else {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment