| /third_party/grpc/src/ruby/spec/support/ |
| D | helpers.rb | 90 def new_core_server_for_testing(server_args) argument
91 server_args.nil? && server_args = {}
92 update_server_args_hash(server_args)
93 GRPC::Core::Server.new(server_args)
96 def update_server_args_hash(server_args) argument
98 unless server_args[so_reuseport_arg].nil?
103 server_args[so_reuseport_arg] = 0
|
| /third_party/grpc/test/core/end2end/fixtures/ |
| D | h2_ssl_proxy.cc | 44 grpc_channel_args* server_args) { in create_proxy_server() argument
45 grpc_server* s = grpc_server_create(server_args, nullptr); in create_proxy_server()
90 grpc_channel_args* client_args, grpc_channel_args* server_args) { in chttp2_create_fixture_secure_fullstack() argument
97 ffd->proxy = grpc_end2end_proxy_create(&proxy_def, client_args, server_args); in chttp2_create_fixture_secure_fullstack()
128 grpc_end2end_test_fixture* f, grpc_channel_args* server_args, in chttp2_init_server_secure_fullstack() argument
135 f->server = grpc_server_create(server_args, nullptr); in chttp2_init_server_secure_fullstack()
167 static int fail_server_auth_check(grpc_channel_args* server_args) { in fail_server_auth_check() argument
169 if (server_args == nullptr) return 0; in fail_server_auth_check()
170 for (i = 0; i < server_args->num_args; i++) { in fail_server_auth_check()
171 if (strcmp(server_args->args[i].key, FAIL_AUTH_CHECK_SERVER_ARG_NAME) == in fail_server_auth_check()
[all …]
|
| D | h2_ssl.cc | 64 grpc_channel_args* client_args, grpc_channel_args* server_args) { in chttp2_create_fixture_secure_fullstack_tls1_2() argument
65 return chttp2_create_fixture_secure_fullstack(client_args, server_args, in chttp2_create_fixture_secure_fullstack_tls1_2()
70 grpc_channel_args* client_args, grpc_channel_args* server_args) { in chttp2_create_fixture_secure_fullstack_tls1_3() argument
71 return chttp2_create_fixture_secure_fullstack(client_args, server_args, in chttp2_create_fixture_secure_fullstack_tls1_3()
96 grpc_end2end_test_fixture* f, grpc_channel_args* server_args, in chttp2_init_server_secure_fullstack() argument
103 f->server = grpc_server_create(server_args, nullptr); in chttp2_init_server_secure_fullstack()
140 static int fail_server_auth_check(grpc_channel_args* server_args) { in fail_server_auth_check() argument
142 if (server_args == nullptr) return 0; in fail_server_auth_check()
143 for (i = 0; i < server_args->num_args; i++) { in fail_server_auth_check()
144 if (strcmp(server_args->args[i].key, FAIL_AUTH_CHECK_SERVER_ARG_NAME) == in fail_server_auth_check()
[all …]
|
| D | h2_ssl_cred_reload.cc | 99 grpc_channel_args* client_args, grpc_channel_args* server_args) { in chttp2_create_fixture_secure_fullstack_tls1_2() argument
100 return chttp2_create_fixture_secure_fullstack(client_args, server_args, in chttp2_create_fixture_secure_fullstack_tls1_2()
105 grpc_channel_args* client_args, grpc_channel_args* server_args) { in chttp2_create_fixture_secure_fullstack_tls1_3() argument
106 return chttp2_create_fixture_secure_fullstack(client_args, server_args, in chttp2_create_fixture_secure_fullstack_tls1_3()
131 grpc_end2end_test_fixture* f, grpc_channel_args* server_args, in chttp2_init_server_secure_fullstack() argument
139 f->server = grpc_server_create(server_args, nullptr); in chttp2_init_server_secure_fullstack()
176 static int fail_server_auth_check(grpc_channel_args* server_args) { in fail_server_auth_check() argument
178 if (server_args == nullptr) return 0; in fail_server_auth_check()
179 for (i = 0; i < server_args->num_args; i++) { in fail_server_auth_check()
180 if (strcmp(server_args->args[i].key, FAIL_AUTH_CHECK_SERVER_ARG_NAME) == in fail_server_auth_check()
[all …]
|
| D | h2_fakesec.cc | 73 grpc_end2end_test_fixture* f, grpc_channel_args* server_args, in chttp2_init_server_secure_fullstack() argument
80 f->server = grpc_server_create(server_args, nullptr); in chttp2_init_server_secure_fullstack()
101 static int fail_server_auth_check(grpc_channel_args* server_args) { in fail_server_auth_check() argument
103 if (server_args == nullptr) return 0; in fail_server_auth_check()
104 for (i = 0; i < server_args->num_args; i++) { in fail_server_auth_check()
105 if (strcmp(server_args->args[i].key, FAIL_AUTH_CHECK_SERVER_ARG_NAME) == in fail_server_auth_check()
114 grpc_end2end_test_fixture* f, grpc_channel_args* server_args) { in chttp2_init_server_fake_secure_fullstack() argument
117 if (fail_server_auth_check(server_args)) { in chttp2_init_server_fake_secure_fullstack()
123 chttp2_init_server_secure_fullstack(f, server_args, fake_ts_creds); in chttp2_init_server_fake_secure_fullstack()
|
| D | h2_oauth2.cc | 113 grpc_channel_args* client_args, grpc_channel_args* server_args) { in chttp2_create_fixture_secure_fullstack_tls1_2() argument
114 return chttp2_create_fixture_secure_fullstack(client_args, server_args, in chttp2_create_fixture_secure_fullstack_tls1_2()
119 grpc_channel_args* client_args, grpc_channel_args* server_args) { in chttp2_create_fixture_secure_fullstack_tls1_3() argument
120 return chttp2_create_fixture_secure_fullstack(client_args, server_args, in chttp2_create_fixture_secure_fullstack_tls1_3()
136 grpc_end2end_test_fixture* f, grpc_channel_args* server_args, in chttp2_init_server_secure_fullstack() argument
143 f->server = grpc_server_create(server_args, nullptr); in chttp2_init_server_secure_fullstack()
194 static int fail_server_auth_check(grpc_channel_args* server_args) { in fail_server_auth_check() argument
196 if (server_args == nullptr) return 0; in fail_server_auth_check()
197 for (i = 0; i < server_args->num_args; i++) { in fail_server_auth_check()
198 if (strcmp(server_args->args[i].key, FAIL_AUTH_CHECK_SERVER_ARG_NAME) == in fail_server_auth_check()
[all …]
|
| D | local_util.cc | 64 static bool fail_server_auth_check(grpc_channel_args* server_args) { in fail_server_auth_check() argument
66 if (server_args == nullptr) return 0; in fail_server_auth_check()
67 for (i = 0; i < server_args->num_args; i++) { in fail_server_auth_check()
68 if (strcmp(server_args->args[i].key, FAIL_AUTH_CHECK_SERVER_ARG_NAME) == in fail_server_auth_check()
86 grpc_end2end_test_fixture* f, grpc_channel_args* server_args, in grpc_end2end_local_chttp2_init_server_fullstack() argument
94 f->server = grpc_server_create(server_args, nullptr); in grpc_end2end_local_chttp2_init_server_fullstack()
96 if (fail_server_auth_check(server_args)) { in grpc_end2end_local_chttp2_init_server_fullstack()
|
| D | h2_tls.cc | 75 grpc_channel_args* client_args, grpc_channel_args* server_args) { in chttp2_create_fixture_secure_fullstack_tls1_2() argument
76 return chttp2_create_fixture_secure_fullstack(client_args, server_args, in chttp2_create_fixture_secure_fullstack_tls1_2()
81 grpc_channel_args* client_args, grpc_channel_args* server_args) { in chttp2_create_fixture_secure_fullstack_tls1_3() argument
82 return chttp2_create_fixture_secure_fullstack(client_args, server_args, in chttp2_create_fixture_secure_fullstack_tls1_3()
107 grpc_end2end_test_fixture* f, grpc_channel_args* server_args, in chttp2_init_server_secure_fullstack() argument
114 f->server = grpc_server_create(server_args, nullptr); in chttp2_init_server_secure_fullstack()
287 static int fail_server_auth_check(grpc_channel_args* server_args) { in fail_server_auth_check() argument
289 if (server_args == nullptr) return 0; in fail_server_auth_check()
290 for (i = 0; i < server_args->num_args; i++) { in fail_server_auth_check()
291 if (strcmp(server_args->args[i].key, FAIL_AUTH_CHECK_SERVER_ARG_NAME) == in fail_server_auth_check()
[all …]
|
| D | h2_proxy.cc | 42 grpc_channel_args* server_args) { in create_proxy_server() argument
43 grpc_server* s = grpc_server_create(server_args, nullptr); in create_proxy_server()
67 grpc_channel_args* client_args, grpc_channel_args* server_args) { in chttp2_create_fixture_fullstack() argument
73 ffd->proxy = grpc_end2end_proxy_create(&proxy_def, client_args, server_args); in chttp2_create_fixture_fullstack()
92 grpc_channel_args* server_args) { in chttp2_init_server_fullstack() argument
98 f->server = grpc_server_create(server_args, nullptr); in chttp2_init_server_fullstack()
|
| D | h2_census.cc | 81 grpc_channel_args* server_args) { in chttp2_init_server_fullstack() argument
88 server_args = grpc_channel_args_copy_and_add(server_args, &arg, 1); in chttp2_init_server_fullstack()
89 f->server = grpc_server_create(server_args, nullptr); in chttp2_init_server_fullstack()
92 grpc_channel_args_destroy(server_args); in chttp2_init_server_fullstack()
|
| D | proxy.h | 30 grpc_channel_args* server_args);
37 grpc_channel_args* server_args);
|
| /third_party/grpc/test/core/network_benchmarks/ |
| D | low_level_ping_pong.cc | 577 thread_args* server_args) { in run_benchmark() argument
580 rv = create_socket(socket_type, &client_args->fds, &server_args->fds); in run_benchmark()
588 grpc_core::Thread server("server_thread", server_thread_wrap, server_args); in run_benchmark()
605 thread_args* server_args = in run_all_benchmarks() local
614 server_args->read_bytes = strategy->read_strategy; in run_all_benchmarks()
615 server_args->write_bytes = blocking_write_bytes; in run_all_benchmarks()
616 server_args->setup = strategy->setup; in run_all_benchmarks()
617 server_args->msg_size = msg_size; in run_all_benchmarks()
618 server_args->strategy_name = strategy->name; in run_all_benchmarks()
619 error = run_benchmark(socket_type, client_args, server_args); in run_all_benchmarks()
[all …]
|
| /third_party/grpc/src/core/ext/transport/chttp2/server/insecure/ |
| D | server_chttp2_posix.cc | 46 const grpc_channel_args* server_args = core_server->channel_args(); in grpc_server_add_insecure_channel_from_fd() local
49 grpc_fd_create(fd, name.c_str(), true), server_args, name.c_str()); in grpc_server_add_insecure_channel_from_fd()
52 server_args, server_endpoint, false /* is_client */); in grpc_server_add_insecure_channel_from_fd()
55 core_server->SetupTransport(transport, nullptr, server_args, nullptr); in grpc_server_add_insecure_channel_from_fd()
|
| /third_party/grpc/test/core/end2end/tests/ |
| D | compressed_payload.cc | 47 grpc_channel_args* server_args, in begin_test() argument
53 f = config.create_fixture(client_args, server_args); in begin_test()
54 config.init_server(&f, server_args); in begin_test()
113 grpc_channel_args* server_args; in request_for_disabled_algorithm() local
136 server_args = grpc_channel_args_set_channel_default_compression_algorithm( in request_for_disabled_algorithm()
138 server_args = grpc_channel_args_compression_algorithm_set_state( in request_for_disabled_algorithm()
139 &server_args, algorithm_to_disable, false); in request_for_disabled_algorithm()
145 grpc_channel_args* old_server_args = server_args; in request_for_disabled_algorithm()
148 server_args = grpc_channel_args_copy_and_add( in request_for_disabled_algorithm()
149 server_args, &disable_decompression_in_core_arg, 1); in request_for_disabled_algorithm()
[all …]
|
| D | stream_compression_compressed_payload.cc | 47 grpc_channel_args* server_args) { in begin_test() argument
50 f = config.create_fixture(client_args, server_args); in begin_test()
51 config.init_server(&f, server_args); in begin_test()
109 grpc_channel_args* server_args; in request_for_disabled_algorithm() local
132 server_args = grpc_channel_args_set_channel_default_compression_algorithm( in request_for_disabled_algorithm()
136 server_args = grpc_channel_args_compression_algorithm_set_state( in request_for_disabled_algorithm()
137 &server_args, algorithm_to_disable, false); in request_for_disabled_algorithm()
140 f = begin_test(config, test_name, client_args, server_args); in request_for_disabled_algorithm()
261 grpc_channel_args_destroy(server_args); in request_for_disabled_algorithm()
285 grpc_channel_args* server_args; in request_with_payload_template() local
[all …]
|
| D | workaround_cronet_compression.cc | 44 grpc_channel_args* server_args) { in begin_test() argument
47 f = config.create_fixture(client_args, server_args); in begin_test()
48 config.init_server(&f, server_args); in begin_test()
110 grpc_channel_args* server_args; in request_with_payload_template() local
141 server_args = grpc_channel_args_set_channel_default_compression_algorithm( in request_with_payload_template()
148 grpc_channel_args* old_server_args = server_args; in request_with_payload_template()
151 server_args = grpc_channel_args_copy_and_add( in request_with_payload_template()
152 server_args, &disable_decompression_in_core_arg, 1); in request_with_payload_template()
167 f = begin_test(config, test_name, client_args, server_args); in request_with_payload_template()
368 grpc_channel_args_destroy(server_args); in request_with_payload_template()
|
| D | hpack_size.cc | 183 grpc_channel_args* server_args) { in begin_test() argument
186 f = config.create_fixture(client_args, server_args); in begin_test()
187 config.init_server(&f, server_args); in begin_test()
358 grpc_channel_args server_args; in test_size() local
365 server_args.num_args = 1; in test_size()
366 server_args.args = &server_arg; in test_size()
378 decode_size != 4096 ? &server_args : nullptr); in test_size()
|
| D | max_message_length.cc | 42 grpc_channel_args* server_args) { in begin_test() argument
49 config.init_server(&f, server_args); in begin_test()
129 grpc_channel_args* server_args = nullptr; in test_max_message_length_on_request() local
169 server_args = args; in test_max_message_length_on_request()
174 server_args); in test_max_message_length_on_request()
178 if (server_args != nullptr) grpc_channel_args_destroy(server_args); in test_max_message_length_on_request()
320 grpc_channel_args* server_args = nullptr; in test_max_message_length_on_response() local
356 server_args = args; in test_max_message_length_on_response()
363 server_args); in test_max_message_length_on_response()
367 if (server_args != nullptr) grpc_channel_args_destroy(server_args); in test_max_message_length_on_response()
[all …]
|
| D | no_op.cc | 35 grpc_channel_args* server_args) { in begin_test() argument
38 f = config.create_fixture(client_args, server_args); in begin_test()
39 config.init_server(&f, server_args); in begin_test()
|
| D | stream_compression_ping_pong_streaming.cc | 40 grpc_channel_args* server_args) { in begin_test() argument
43 f = config.create_fixture(client_args, server_args); in begin_test()
44 config.init_server(&f, server_args); in begin_test()
97 grpc_channel_args* server_args = in test_pingpong_streaming() local
101 begin_test(config, "test_pingpong_streaming", client_args, server_args); in test_pingpong_streaming()
284 grpc_channel_args_destroy(server_args); in test_pingpong_streaming()
|
| D | stream_compression_payload.cc | 39 grpc_channel_args* server_args) { in begin_test() argument
42 f = config.create_fixture(client_args, server_args); in begin_test()
43 config.init_server(&f, server_args); in begin_test()
269 grpc_channel_args* server_args = in test_invoke_request_response_with_payload() local
274 client_args, server_args); in test_invoke_request_response_with_payload()
281 grpc_channel_args_destroy(server_args); in test_invoke_request_response_with_payload()
|
| D | shutdown_finishes_tags.cc | 35 grpc_channel_args* server_args) { in begin_test() argument
38 f = config.create_fixture(client_args, server_args); in begin_test()
39 config.init_server(&f, server_args); in begin_test()
|
| D | cancel_in_a_vacuum.cc | 39 grpc_channel_args* server_args) { in begin_test() argument
43 f = config.create_fixture(client_args, server_args); in begin_test()
44 config.init_server(&f, server_args); in begin_test()
|
| /third_party/grpc/test/core/end2end/ |
| D | h2_ssl_cert_test.cc | 89 grpc_end2end_test_fixture* f, grpc_channel_args* server_args, in chttp2_init_server_secure_fullstack() argument
96 f->server = grpc_server_create(server_args, nullptr); in chttp2_init_server_secure_fullstack()
110 static int fail_server_auth_check(grpc_channel_args* server_args) { in fail_server_auth_check() argument
112 if (server_args == nullptr) return 0; in fail_server_auth_check()
113 for (i = 0; i < server_args->num_args; i++) { in fail_server_auth_check()
114 if (strcmp(server_args->args[i].key, FAIL_AUTH_CHECK_SERVER_ARG_NAME) == in fail_server_auth_check()
127 grpc_end2end_test_fixture * f, grpc_channel_args * server_args) { \
139 if (fail_server_auth_check(server_args)) { \
145 chttp2_init_server_secure_fullstack(f, server_args, ssl_creds); \
|
| /third_party/grpc/src/objective-c/tests/CronetTests/ |
| D | CoreCronetEnd2EndTests.mm | 59 grpc_channel_args *client_args, grpc_channel_args *server_args) {
91 grpc_channel_args *server_args,
97 f->server = grpc_server_create(server_args, NULL);
119 static int fail_server_auth_check(grpc_channel_args *server_args) {
121 if (server_args == NULL) return 0;
122 for (i = 0; i < server_args->num_args; i++) {
123 if (strcmp(server_args->args[i].key, FAIL_AUTH_CHECK_SERVER_ARG_NAME) == 0) {
131 grpc_channel_args *server_args) {
135 if (fail_server_auth_check(server_args)) {
139 chttp2_init_server_secure_fullstack(f, server_args, ssl_creds);
|