|
|
|
@ -103,13 +103,12 @@ static void must_fail(void* arg, grpc_error_handle error) { |
|
|
|
|
/* connect to it */ |
|
|
|
|
GPR_ASSERT(getsockname(svr_fd, (struct sockaddr*)addr, (socklen_t*)&resolved_addr.len) == 0); |
|
|
|
|
GRPC_CLOSURE_INIT(&done, must_succeed, nullptr, grpc_schedule_on_exec_ctx); |
|
|
|
|
const grpc_channel_args* args = grpc_core::CoreConfiguration::Get() |
|
|
|
|
.channel_args_preconditioning() |
|
|
|
|
.PreconditionChannelArgs(nullptr) |
|
|
|
|
.ToC(); |
|
|
|
|
grpc_tcp_client_connect(&done, &g_connecting, nullptr, args, &resolved_addr, |
|
|
|
|
auto args = grpc_core::CoreConfiguration::Get() |
|
|
|
|
.channel_args_preconditioning() |
|
|
|
|
.PreconditionChannelArgs(nullptr) |
|
|
|
|
.ToC(); |
|
|
|
|
grpc_tcp_client_connect(&done, &g_connecting, nullptr, args.get(), &resolved_addr, |
|
|
|
|
grpc_core::Timestamp::InfFuture()); |
|
|
|
|
grpc_channel_args_destroy(args); |
|
|
|
|
|
|
|
|
|
/* await the connection */ |
|
|
|
|
do { |
|
|
|
@ -161,13 +160,12 @@ static void must_fail(void* arg, grpc_error_handle error) { |
|
|
|
|
|
|
|
|
|
/* connect to a broken address */ |
|
|
|
|
GRPC_CLOSURE_INIT(&done, must_fail, nullptr, grpc_schedule_on_exec_ctx); |
|
|
|
|
const grpc_channel_args* args = grpc_core::CoreConfiguration::Get() |
|
|
|
|
.channel_args_preconditioning() |
|
|
|
|
.PreconditionChannelArgs(nullptr) |
|
|
|
|
.ToC(); |
|
|
|
|
grpc_tcp_client_connect(&done, &g_connecting, nullptr, args, &resolved_addr, |
|
|
|
|
auto args = grpc_core::CoreConfiguration::Get() |
|
|
|
|
.channel_args_preconditioning() |
|
|
|
|
.PreconditionChannelArgs(nullptr) |
|
|
|
|
.ToC(); |
|
|
|
|
grpc_tcp_client_connect(&done, &g_connecting, nullptr, args.get(), &resolved_addr, |
|
|
|
|
grpc_core::Timestamp::InfFuture()); |
|
|
|
|
grpc_channel_args_destroy(args); |
|
|
|
|
|
|
|
|
|
grpc_core::ExecCtx::Get()->Flush(); |
|
|
|
|
|
|
|
|
|