Home
last modified time | relevance | path

Searched refs:channel_args (Results 1 – 25 of 101) sorted by relevance

12345

/external/grpc-grpc/test/cpp/qps/
Djson_run_localhost_scenarios.bzl3 …channel_args": [{"str_value": "latency", "name": "grpc.optimization_target"}]}, "client_config": {…
Dqps_json_driver_scenarios.bzl3 …channel_args": [{"str_value": "throughput", "name": "grpc.optimization_target"}, {"int_value": 1, …
/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_client_posix.cc63 grpc_channel_args* channel_args; member
67 const grpc_channel_args* channel_args) { in prepare_socket() argument
79 err = grpc_set_socket_tcp_user_timeout(fd, channel_args, in prepare_socket()
85 if (channel_args) { in prepare_socket()
86 for (size_t i = 0; i < channel_args->num_args; i++) { in prepare_socket()
87 if (0 == strcmp(channel_args->args[i].key, GRPC_ARG_SOCKET_MUTATOR)) { in prepare_socket()
88 GPR_ASSERT(channel_args->args[i].type == GRPC_ARG_POINTER); in prepare_socket()
90 channel_args->args[i].value.pointer.p); in prepare_socket()
124 grpc_channel_args_destroy(ac->channel_args); in tc_on_alarm()
130 grpc_fd* fd, const grpc_channel_args* channel_args, const char* addr_str) { in grpc_tcp_client_create_from_fd() argument
[all …]
Dtcp_client_custom.cc105 const grpc_channel_args* channel_args, in tcp_connect() argument
109 (void)channel_args; in tcp_connect()
113 if (channel_args != nullptr) { in tcp_connect()
114 for (size_t i = 0; i < channel_args->num_args; i++) { in tcp_connect()
115 if (0 == strcmp(channel_args->args[i].key, GRPC_ARG_RESOURCE_QUOTA)) { in tcp_connect()
118 (grpc_resource_quota*)channel_args->args[i].value.pointer.p); in tcp_connect()
Dtcp_server_utils_posix_common.cc169 err = grpc_set_socket_tcp_user_timeout(fd, s->channel_args, in grpc_tcp_server_prepare_socket()
176 if (s->channel_args) { in grpc_tcp_server_prepare_socket()
177 for (size_t i = 0; i < s->channel_args->num_args; i++) { in grpc_tcp_server_prepare_socket()
178 if (0 == strcmp(s->channel_args->args[i].key, GRPC_ARG_SOCKET_MUTATOR)) { in grpc_tcp_server_prepare_socket()
179 GPR_ASSERT(s->channel_args->args[i].type == GRPC_ARG_POINTER); in grpc_tcp_server_prepare_socket()
181 s->channel_args->args[i].value.pointer.p); in grpc_tcp_server_prepare_socket()
Dtcp_client_windows.cc53 grpc_channel_args* channel_args; member
61 grpc_channel_args_destroy(ac->channel_args); in async_connect_unlock_and_cleanup()
109 *ep = grpc_tcp_create(socket, ac->channel_args, ac->addr_name); in on_connect()
127 const grpc_channel_args* channel_args, in tcp_connect() argument
205 ac->channel_args = grpc_channel_args_copy(channel_args); in tcp_connect()
Dtcp_client_posix.h36 grpc_fd* fd, const grpc_channel_args* channel_args, const char* addr_str);
48 grpc_error* grpc_tcp_client_prepare_fd(const grpc_channel_args* channel_args,
65 const grpc_channel_args* channel_args, const grpc_resolved_address* addr,
Dsocket_utils_common_posix.cc255 int fd, const grpc_channel_args* channel_args, bool is_client) { in grpc_set_socket_tcp_user_timeout() argument
266 if (channel_args) { in grpc_set_socket_tcp_user_timeout()
267 for (unsigned int i = 0; i < channel_args->num_args; i++) { in grpc_set_socket_tcp_user_timeout()
268 if (0 == strcmp(channel_args->args[i].key, GRPC_ARG_KEEPALIVE_TIME_MS)) { in grpc_set_socket_tcp_user_timeout()
270 &channel_args->args[i], grpc_integer_options{0, 1, INT_MAX}); in grpc_set_socket_tcp_user_timeout()
277 } else if (0 == strcmp(channel_args->args[i].key, in grpc_set_socket_tcp_user_timeout()
280 &channel_args->args[i], grpc_integer_options{0, 1, INT_MAX}); in grpc_set_socket_tcp_user_timeout()
Dtcp_client_cfstream.cc158 const grpc_channel_args* channel_args, in CFStreamClientConnect() argument
178 if (channel_args != NULL) { in CFStreamClientConnect()
179 for (size_t i = 0; i < channel_args->num_args; i++) { in CFStreamClientConnect()
180 if (0 == strcmp(channel_args->args[i].key, GRPC_ARG_RESOURCE_QUOTA)) { in CFStreamClientConnect()
183 (grpc_resource_quota*)channel_args->args[i].value.pointer.p); in CFStreamClientConnect()
Dendpoint_pair_windows.cc74 const char* name, grpc_channel_args* channel_args) { in grpc_iomgr_create_endpoint_pair() argument
80 channel_args, "endpoint:server"); in grpc_iomgr_create_endpoint_pair()
82 channel_args, "endpoint:client"); in grpc_iomgr_create_endpoint_pair()
/external/grpc-grpc/test/cpp/util/
Dcreate_test_channel.cc74 ChannelArguments channel_args(args); in CreateTestChannel() local
82 kProdTlsCredentialsType, &channel_args); in CreateTestChannel()
84 channel_args.SetSslTargetNameOverride(override_hostname); in CreateTestChannel()
89 testing::kTlsCredentialsType, &channel_args); in CreateTestChannel()
98 return CreateCustomChannel(connect_to, channel_creds, channel_args); in CreateTestChannel()
101 cred_type, &channel_args); in CreateTestChannel()
146 ChannelArguments channel_args; in CreateTestChannel() local
149 &channel_args); in CreateTestChannel()
154 return CreateCustomChannel(server, channel_creds, channel_args); in CreateTestChannel()
/external/grpc-grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc259 const grpc_channel_args* channel_args) { in get_message_size_limits() argument
262 default_size(channel_args, GRPC_DEFAULT_MAX_SEND_MESSAGE_LENGTH); in get_message_size_limits()
264 default_size(channel_args, GRPC_DEFAULT_MAX_RECV_MESSAGE_LENGTH); in get_message_size_limits()
265 for (size_t i = 0; i < channel_args->num_args; ++i) { in get_message_size_limits()
266 if (strcmp(channel_args->args[i].key, GRPC_ARG_MAX_SEND_MESSAGE_LENGTH) == in get_message_size_limits()
270 grpc_channel_arg_get_integer(&channel_args->args[i], options); in get_message_size_limits()
272 if (strcmp(channel_args->args[i].key, in get_message_size_limits()
276 grpc_channel_arg_get_integer(&channel_args->args[i], options); in get_message_size_limits()
287 chand->limits = get_message_size_limits(args->channel_args); in init_channel_elem()
290 grpc_channel_args_find(args->channel_args, GRPC_ARG_SERVICE_CONFIG); in init_channel_elem()
[all …]
/external/grpc-grpc/test/core/channel/
Dminimal_stack_is_minimal_test.cc125 grpc_channel_args* channel_args = grpc_channel_args_copy(init_args); in check_stack() local
131 grpc_channel_stack_builder_set_channel_arguments(builder, channel_args); in check_stack()
170 for (size_t i = 0; i < channel_args->num_args; i++) { in check_stack()
172 gpr_strvec_add(&v, gpr_strdup(channel_args->args[i].key)); in check_stack()
174 switch (channel_args->args[i].type) { in check_stack()
177 gpr_asprintf(&tmp, "%d", channel_args->args[i].value.integer); in check_stack()
182 gpr_strvec_add(&v, gpr_strdup(channel_args->args[i].value.string)); in check_stack()
186 gpr_asprintf(&tmp, "%p", channel_args->args[i].value.pointer.p); in check_stack()
217 grpc_channel_args_destroy(channel_args); in check_stack()
Dchannel_stack_test.cc32 GPR_ASSERT(args->channel_args->num_args == 1); in channel_init_func()
33 GPR_ASSERT(args->channel_args->args[0].type == GRPC_ARG_INTEGER); in channel_init_func()
34 GPR_ASSERT(0 == strcmp(args->channel_args->args[0].key, "test_key")); in channel_init_func()
35 GPR_ASSERT(args->channel_args->args[0].value.integer == 42); in channel_init_func()
/external/grpc-grpc/src/ruby/lib/grpc/generic/
Dclient_stub.rb33 def self.setup_channel(alt_chan, host, creds, channel_args = {}) argument
38 if channel_args['grpc.primary_user_agent'].nil?
39 channel_args['grpc.primary_user_agent'] = ''
41 channel_args['grpc.primary_user_agent'] += ' '
43 channel_args['grpc.primary_user_agent'] += "grpc-ruby/#{VERSION}"
47 Core::Channel.new(host, channel_args, creds)
100 channel_args: {}, argument
103 channel_args)
104 alt_host = channel_args[Core::Channel::SSL_TARGET]
/external/tensorflow/tensorflow/core/profiler/rpc/client/
Dcapture_profile.cc90 ::grpc::ChannelArguments channel_args; in Profile()
93 channel_args.SetInt(GRPC_ARG_MAX_MESSAGE_LENGTH, in Profile()
98 channel_args)); in Profile()
140 ::grpc::ChannelArguments channel_args; in NewSession()
143 channel_args.SetMaxReceiveMessageSize(std::numeric_limits<int32>::max()); in NewSession()
152 channel_args)); in NewSession()
251 ::grpc::ChannelArguments channel_args; in StartMonitoring()
252 channel_args.SetInt(GRPC_ARG_MAX_MESSAGE_LENGTH, in StartMonitoring()
257 channel_args)); in StartMonitoring()
/external/grpc-grpc/test/cpp/naming/
Dresolver_component_test.cc162 grpc_channel_args* channel_args; member
176 args->channel_args = nullptr; in ArgsInit()
190 grpc_channel_args_destroy(args->channel_args); in ArgsFinish()
226 void CheckServiceConfigResultLocked(grpc_channel_args* channel_args, in CheckServiceConfigResultLocked() argument
229 grpc_channel_args_find(channel_args, GRPC_ARG_SERVICE_CONFIG); in CheckServiceConfigResultLocked()
240 void CheckLBPolicyResultLocked(grpc_channel_args* channel_args, in CheckLBPolicyResultLocked() argument
243 grpc_channel_args_find(channel_args, GRPC_ARG_LB_POLICY_NAME); in CheckLBPolicyResultLocked()
384 grpc_channel_args* channel_args = args->channel_args; in CheckResolverResultLocked() local
386 grpc_channel_args_find(channel_args, GRPC_ARG_LB_ADDRESSES); in CheckResolverResultLocked()
412 CheckServiceConfigResultLocked(channel_args, args); in CheckResolverResultLocked()
[all …]
/external/grpc-grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc433 for (size_t i = 0; i < args->channel_args->num_args; ++i) { in init_channel_elem()
434 if (0 == strcmp(args->channel_args->args[i].key, in init_channel_elem()
437 &args->channel_args->args[i], MAX_CONNECTION_AGE_INTEGER_OPTIONS); in init_channel_elem()
441 } else if (0 == strcmp(args->channel_args->args[i].key, in init_channel_elem()
444 &args->channel_args->args[i], in init_channel_elem()
448 } else if (0 == strcmp(args->channel_args->args[i].key, in init_channel_elem()
451 &args->channel_args->args[i], MAX_CONNECTION_IDLE_INTEGER_OPTIONS); in init_channel_elem()
519 const grpc_channel_args* channel_args = in maybe_add_max_age_filter() local
523 grpc_channel_args_find(channel_args, GRPC_ARG_MAX_CONNECTION_AGE_MS), in maybe_add_max_age_filter()
526 grpc_channel_args_find(channel_args, GRPC_ARG_MAX_CONNECTION_IDLE_MS), in maybe_add_max_age_filter()
/external/grpc-grpc/src/cpp/client/
Dinsecure_credentials.cc35 grpc_channel_args channel_args; in CreateChannel() local
36 args.SetChannelArgs(&channel_args); in CreateChannel()
39 grpc_insecure_channel_create(target.c_str(), &channel_args, nullptr)); in CreateChannel()
Dcronet_credentials.cc34 grpc_channel_args channel_args; in CreateChannel() local
35 args.SetChannelArgs(&channel_args); in CreateChannel()
38 &channel_args, nullptr)); in CreateChannel()
Dcreate_channel_posix.cc43 grpc_channel_args channel_args; in CreateCustomInsecureChannelFromFd() local
44 args.SetChannelArgs(&channel_args); in CreateCustomInsecureChannelFromFd()
46 target.c_str(), fd, &channel_args)); in CreateCustomInsecureChannelFromFd()
/external/grpc-grpc/src/core/ext/filters/http/
Dhttp_filters_plugin.cc49 const grpc_channel_args* channel_args = in maybe_add_optional_filter() local
52 grpc_channel_args_find(channel_args, filtarg->control_channel_arg), in maybe_add_optional_filter()
53 !grpc_channel_args_want_minimal_stack(channel_args)); in maybe_add_optional_filter()
Dclient_authority_filter.cc93 grpc_channel_args_find(args->channel_args, GRPC_ARG_DEFAULT_AUTHORITY); in init_channel_elem()
133 const grpc_channel_args* channel_args = in add_client_authority_filter() local
136 channel_args, GRPC_ARG_DISABLE_CLIENT_AUTHORITY_FILTER); in add_client_authority_filter()
/external/grpc-grpc/src/core/ext/transport/chttp2/client/
Dchttp2_connector.cc147 c->result->channel_args = args->args; in on_handshake_done()
160 grpc_handshakers_add(HANDSHAKER_CLIENT, c->args.channel_args, in start_handshake_locked()
165 c->args.channel_args, c->args.deadline, nullptr /* acceptor */, in start_handshake_locked()
203 grpc_get_subchannel_address_arg(args->channel_args, &addr); in chttp2_connector_connect()
215 args->channel_args, &addr, args->deadline); in chttp2_connector_connect()
/external/grpc-grpc/test/cpp/interop/
Dreconnect_interop_client.cc74 ChannelArguments channel_args; in main() local
76 channel_args.SetInt(GRPC_ARG_MAX_RECONNECT_BACKOFF_MS, in main()
81 std::shared_ptr<CallCredentials>(), channel_args); in main()

12345