aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/end2end
diff options
context:
space:
mode:
authorGravatar Craig Tiller <craig.tiller@gmail.com>2015-11-25 15:22:26 -0800
committerGravatar Craig Tiller <craig.tiller@gmail.com>2015-11-25 15:22:26 -0800
commit86c99580a0891697f3c5227ae2fd2911734098fc (patch)
treebdb4a2bf6b12e45d504ac622968b979ab4f3dec4 /test/core/end2end
parentee7531cd7c0ef681d104ab0ec83a8fb151ebb62b (diff)
Load balancing interest management fixes
Diffstat (limited to 'test/core/end2end')
-rw-r--r--test/core/end2end/fixtures/h2_uchannel.c6
1 files changed, 4 insertions, 2 deletions
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);
}