aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/performance
diff options
context:
space:
mode:
authorGravatar Yash Tibrewal <yashkt@google.com>2017-11-09 18:27:37 -0800
committerGravatar Yash Tibrewal <yashkt@google.com>2017-11-09 18:27:37 -0800
commit3150744c712449585e6c0a3347f2b9366671a8eb (patch)
tree7083a7582f910a40d3718d8f7b36b249f18d2961 /test/cpp/performance
parentcf9b084211d1f2d99b1ce4685801bca1557f2f7b (diff)
Removing more exec_ctx instances
Diffstat (limited to 'test/cpp/performance')
-rw-r--r--test/cpp/performance/writes_per_rpc_test.cc18
1 files changed, 9 insertions, 9 deletions
diff --git a/test/cpp/performance/writes_per_rpc_test.cc b/test/cpp/performance/writes_per_rpc_test.cc
index 0e5233403e..b05da25e1d 100644
--- a/test/cpp/performance/writes_per_rpc_test.cc
+++ b/test/cpp/performance/writes_per_rpc_test.cc
@@ -89,19 +89,19 @@ class EndpointPairFixture {
const grpc_channel_args* server_args =
grpc_server_get_channel_args(server_->c_server());
grpc_transport* transport = grpc_create_chttp2_transport(
- &exec_ctx, server_args, endpoints.server, 0 /* is_client */);
+ server_args, endpoints.server, 0 /* is_client */);
grpc_pollset** pollsets;
size_t num_pollsets = 0;
grpc_server_get_pollsets(server_->c_server(), &pollsets, &num_pollsets);
for (size_t i = 0; i < num_pollsets; i++) {
- grpc_endpoint_add_to_pollset(&exec_ctx, endpoints.server, pollsets[i]);
+ grpc_endpoint_add_to_pollset(endpoints.server, pollsets[i]);
}
- grpc_server_setup_transport(&exec_ctx, server_->c_server(), transport,
- NULL, server_args);
- grpc_chttp2_transport_start_reading(&exec_ctx, transport, NULL);
+ grpc_server_setup_transport(server_->c_server(), transport, NULL,
+ server_args);
+ grpc_chttp2_transport_start_reading(transport, NULL);
}
/* create channel */
@@ -112,16 +112,16 @@ class EndpointPairFixture {
grpc_channel_args c_args = args.c_channel_args();
grpc_transport* transport =
- grpc_create_chttp2_transport(&exec_ctx, &c_args, endpoints.client, 1);
+ grpc_create_chttp2_transport(&c_args, endpoints.client, 1);
GPR_ASSERT(transport);
grpc_channel* channel = grpc_channel_create(
- &exec_ctx, "target", &c_args, GRPC_CLIENT_DIRECT_CHANNEL, transport);
- grpc_chttp2_transport_start_reading(&exec_ctx, transport, NULL);
+ "target", &c_args, GRPC_CLIENT_DIRECT_CHANNEL, transport);
+ grpc_chttp2_transport_start_reading(transport, NULL);
channel_ = CreateChannelInternal("", channel);
}
- grpc_exec_ctx_finish(&exec_ctx);
+ grpc_exec_ctx_finish();
}
virtual ~EndpointPairFixture() {