From 86c99580a0891697f3c5227ae2fd2911734098fc Mon Sep 17 00:00:00 2001 From: Craig Tiller Date: Wed, 25 Nov 2015 15:22:26 -0800 Subject: Load balancing interest management fixes --- test/core/end2end/fixtures/h2_uchannel.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'test/core/end2end') diff --git a/test/core/end2end/fixtures/h2_uchannel.c b/test/core/end2end/fixtures/h2_uchannel.c index a1b64573b8..25540256c4 100644 --- a/test/core/end2end/fixtures/h2_uchannel.c +++ b/test/core/end2end/fixtures/h2_uchannel.c @@ -247,9 +247,11 @@ static void destroy_pollset(grpc_exec_ctx *exec_ctx, void *arg, int success) { static grpc_connected_subchannel *connect_subchannel(grpc_subchannel *c) { grpc_pollset pollset; + grpc_pollset_set interested_parties; grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; grpc_pollset_init(&pollset); - grpc_subchannel_add_interested_party(&exec_ctx, c, &pollset); + grpc_pollset_set_add_pollset(&exec_ctx, &interested_parties, &pollset); + grpc_subchannel_add_interested_parties(&exec_ctx, c, &interested_parties); grpc_subchannel_notify_on_state_change(&exec_ctx, c, &g_state, grpc_closure_create(state_changed, c)); grpc_exec_ctx_flush(&exec_ctx); @@ -266,7 +268,7 @@ static grpc_connected_subchannel *connect_subchannel(grpc_subchannel *c) { grpc_pollset_shutdown(&exec_ctx, &pollset, grpc_closure_create(destroy_pollset, &pollset)); gpr_mu_unlock(GRPC_POLLSET_MU(&pollset)); - grpc_subchannel_del_interested_party(&exec_ctx, c, &pollset); + grpc_subchannel_del_interested_parties(&exec_ctx, c, &interested_parties); grpc_exec_ctx_finish(&exec_ctx); return grpc_subchannel_get_connected_subchannel(c); } -- cgit v1.2.3