| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| D | bidi_call.rb | 104 write_loop(replies, is_client: false)
114 def read_next_loop(finalize_stream, is_client = false) argument
115 read_loop(finalize_stream, is_client: is_client)
142 def write_loop(requests, is_client: true, set_output_stream_done: nil)
162 if is_client
176 if is_client
183 set_output_stream_done.call if is_client
187 def read_loop(set_input_stream_done, is_client: true)
190 is_client: is_client) unless block_given?
204 if is_client
[all …]
|
| /external/grpc-grpc/test/core/tsi/alts/frame_protector/ |
| D | alts_counter_test.cc | 85 static void alts_counter_test_overflow_full_range(bool is_client, in alts_counter_test_overflow_full_range() argument
91 is_client, counter_size, overflow_size, &ctr, &error_details); in alts_counter_test_overflow_full_range()
95 if (is_client) { in alts_counter_test_overflow_full_range()
100 counter_size) == is_client); in alts_counter_test_overflow_full_range()
116 counter_size) == is_client); in alts_counter_test_overflow_full_range()
122 counter_size) == is_client); in alts_counter_test_overflow_full_range()
131 static void alts_counter_test_overflow_single_increment(bool is_client, in alts_counter_test_overflow_single_increment() argument
137 is_client, counter_size, overflow_size, &ctr, &error_details); in alts_counter_test_overflow_single_increment()
144 if (is_client) { in alts_counter_test_overflow_single_increment()
149 counter_size) == is_client); in alts_counter_test_overflow_single_increment()
[all …]
|
| /external/grpc-grpc/src/core/tsi/ |
| D | local_transport_security.cc | 42 bool is_client; member
48 bool is_client; member
143 static tsi_result create_handshaker_result(bool is_client, in create_handshaker_result() argument
151 result->is_client = is_client; in create_handshaker_result()
174 create_handshaker_result(handshaker->is_client, result); in handshaker_next()
198 tsi_result local_tsi_handshaker_create(bool is_client, tsi_handshaker** self) { in local_tsi_handshaker_create() argument
205 handshaker->is_client = is_client; in local_tsi_handshaker_create()
|
| D | fake_transport_security.cc | 63 int is_client; member
590 impl->is_client ? "Client" : "Server", in fake_handshaker_get_bytes_to_send_to_peer()
597 if (!impl->is_client && in fake_handshaker_get_bytes_to_send_to_peer()
640 gpr_log(GPR_INFO, "%s received %s.", impl->is_client ? "Client" : "Server", in fake_handshaker_process_bytes_from_peer()
648 gpr_log(GPR_INFO, "%s is done.", impl->is_client ? "Client" : "Server"); in fake_handshaker_process_bytes_from_peer()
744 tsi_handshaker* tsi_create_fake_handshaker(int is_client) { in tsi_create_fake_handshaker() argument
748 impl->is_client = is_client; in tsi_create_fake_handshaker()
754 if (is_client) { in tsi_create_fake_handshaker()
|
| /external/grpc-grpc/test/core/tsi/ |
| D | transport_security_test_lib.cc | 50 bool is_client; member
57 bool is_client) { in handshaker_args_create() argument
66 args->is_client = is_client; in handshaker_args_create()
127 bool is_client) { in send_bytes_to_peer() argument
131 is_client ? test_channel->server_channel : test_channel->client_channel; in send_bytes_to_peer()
133 size_t* bytes_written = is_client in send_bytes_to_peer()
152 strlen(TSI_TEST_UNUSED_BYTES), args->is_client); in maybe_append_unused_bytes()
162 bool is_client) { in receive_bytes_from_peer() argument
167 is_client ? test_channel->client_channel : test_channel->server_channel; in receive_bytes_from_peer()
169 size_t* bytes_read = is_client in receive_bytes_from_peer()
[all …]
|
| D | transport_security_test_lib.h | 208 tsi_frame_protector* protector, bool is_client);
214 size_t* bytes_received, bool is_client);
|
| /external/grpc-grpc/src/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker.cc | 53 bool is_client; member
66 bool is_client; member
130 kAltsAes128GcmRekeyKeyLength, /*is_rekey=*/true, result->is_client, in handshaker_result_create_zero_copy_grpc_protector()
152 kAltsAes128GcmRekeyKeyLength, result->is_client, /*is_rekey=*/true, in handshaker_result_create_frame_protector()
197 bool is_client, in create_handshaker_result() argument
231 result->is_client = is_client; in create_handshaker_result()
266 ok = handshaker->is_client in handshaker_next()
350 const char* handshaker_service_url, bool is_client, tsi_handshaker** self) { in alts_tsi_handshaker_create() argument
352 options == nullptr || (is_client && target_name == nullptr)) { in alts_tsi_handshaker_create()
369 handshaker->is_client = is_client; in alts_tsi_handshaker_create()
[all …]
|
| /external/grpc-grpc/src/core/tsi/alts/zero_copy_frame_protector/ |
| D | alts_zero_copy_grpc_protector.cc | 112 const uint8_t* key, size_t key_size, bool is_rekey, bool is_client, in create_alts_grpc_record_protocol() argument
135 crypter, overflow_limit, is_client, is_protect, in create_alts_grpc_record_protocol()
138 crypter, overflow_limit, is_client, is_protect, in create_alts_grpc_record_protocol()
243 const uint8_t* key, size_t key_size, bool is_rekey, bool is_client, in alts_zero_copy_grpc_protector_create() argument
260 key, key_size, is_rekey, is_client, is_integrity_only, in alts_zero_copy_grpc_protector_create()
264 key, key_size, is_rekey, is_client, is_integrity_only, in alts_zero_copy_grpc_protector_create()
|
| D | alts_grpc_privacy_integrity_record_protocol.cc | 124 gsec_aead_crypter* crypter, size_t overflow_size, bool is_client, in alts_grpc_privacy_integrity_record_protocol_create() argument
135 alts_grpc_record_protocol_init(impl, crypter, overflow_size, is_client, in alts_grpc_privacy_integrity_record_protocol_create()
|
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 58 bool is_client; member
183 static void log_metadata(const grpc_metadata_batch* md_batch, bool is_client, in log_metadata() argument
190 is_client ? "CLI" : "SVR", key, value); in log_metadata()
201 log_metadata(metadata, s->t->is_client, outflags != nullptr); in fill_in_metadata()
429 if (!s->t->is_client) { in fail_helper_locked()
610 } else if (!s->t->is_client && in op_state_machine()
627 (s->t->is_client && in op_state_machine()
648 if (!s->t->is_client && s->trailing_md_recvd && s->recv_trailing_md_op) { in op_state_machine()
726 if (s->recv_trailing_md_op && s->t->is_client && other && in op_state_machine()
760 if ((s->trailing_md_sent || s->t->is_client) && s->send_message_op) { in op_state_machine()
[all …]
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | writing.cc | 56 t->is_client ? "CLIENT" : "SERVER", t->peer_string); in maybe_initiate_ping()
65 t->is_client ? "CLIENT" : "SERVER", t->peer_string, in maybe_initiate_ping()
87 t->is_client ? "CLIENT" : "SERVER", t->peer_string, in maybe_initiate_ping()
111 t->is_client ? "CLIENT" : "SERVER", t->peer_string, in maybe_initiate_ping()
278 if (!t_->is_client) { in ResetPingClock()
410 t_->is_client ? "CLIENT" : "SERVER", s->id, in StreamWriteContext()
426 if (!t_->is_client && s_->fetching_send_message == nullptr && in FlushInitialMetadata()
573 if (!t_->is_client && !s_->read_closed) { in SentLastFrame()
578 grpc_chttp2_mark_stream_closed(t_, s_, !t_->is_client, true, in SentLastFrame()
|
| D | chttp2_transport.cc | 236 bool is_client) { in read_channel_args() argument
251 is_client ? "client" : "server"); in read_channel_args()
303 grpc_integer_options{t->is_client in read_channel_args()
312 grpc_integer_options{t->is_client in read_channel_args()
371 if (!settings_map[j].availability[is_client]) { in read_channel_args()
374 is_client ? "clients" : "servers"); in read_channel_args()
422 if (t->is_client) { in init_transport_keepalive_settings()
468 grpc_endpoint* ep, bool is_client) { in init_transport() argument
479 t->next_stream_id = is_client ? 1 : 2; in init_transport()
480 t->is_client = is_client; in init_transport()
[all …]
|
| D | stream_lists.cc | 72 t->is_client ? "cli" : "svr", stream_list_id_string(id)); in stream_list_pop()
94 t->is_client ? "cli" : "svr", stream_list_id_string(id)); in stream_list_remove()
126 t->is_client ? "cli" : "svr", stream_list_id_string(id)); in stream_list_add_tail()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 132 bool is_client; member
316 call->is_client = args->server_transport_data == nullptr; in grpc_call_create()
319 if (call->is_client) { in grpc_call_create()
354 GPR_ASSERT(call->is_client); in grpc_call_create()
355 GPR_ASSERT(!args->parent->is_client); in grpc_call_create()
439 if (call->is_client) { in grpc_call_create()
700 gpr_log(GPR_DEBUG, "set_final_status %s", call->is_client ? "CLI" : "SVR"); in set_final_status()
703 if (call->is_client) { in set_final_status()
952 if (!call->is_client && is_trailing) return; in publish_app_metadata()
1032 } else if (!call->is_client) { in recv_trailing_filter()
[all …]
|
| /external/grpc-grpc/test/core/tsi/alts/fake_handshaker/ |
| D | fake_handshaker_server.cc | 89 bool is_client = true; member
132 context->is_client = true; in ProcessClientStart()
169 context->is_client = false; in ProcessServerStart()
177 if (context->is_client) { in ProcessNext()
|
| /external/grpc-grpc/src/core/tsi/alts/frame_protector/ |
| D | alts_crypter.h | 215 grpc_status_code alts_seal_crypter_create(gsec_aead_crypter* gc, bool is_client,
241 bool is_client,
|
| D | alts_frame_protector.cc | 329 size_t key_size, bool is_client, in create_alts_crypters() argument
350 status = alts_seal_crypter_create(aead_crypter_seal, is_client, overflow_size, in create_alts_crypters()
356 alts_unseal_crypter_create(aead_crypter_unseal, is_client, overflow_size, in create_alts_crypters()
362 bool is_client, bool is_rekey, in alts_create_frame_protector() argument
374 key, key_size, is_client, is_rekey, impl, &error_details); in alts_create_frame_protector()
|
| D | alts_counter.cc | 34 grpc_status_code alts_counter_create(bool is_client, size_t counter_size, in alts_counter_create() argument
60 if (is_client) { in alts_counter_create()
|
| D | alts_unseal_privacy_integrity_crypter.cc | 86 bool is_client, in alts_unseal_crypter_create() argument
96 alts_crypter_create_common(gc, is_client, overflow_size, error_details); in alts_unseal_crypter_create()
|
| D | alts_seal_privacy_integrity_crypter.cc | 88 grpc_status_code alts_seal_crypter_create(gsec_aead_crypter* gc, bool is_client, in alts_seal_crypter_create() argument
98 alts_crypter_create_common(gc, !is_client, overflow_size, error_details); in alts_seal_crypter_create()
|
| D | alts_record_protocol_crypter_common.cc | 91 gsec_aead_crypter* crypter, bool is_client, size_t overflow_size, in alts_crypter_create_common() argument
103 status = alts_counter_create(is_client, counter_size, overflow_size, in alts_crypter_create_common()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | socket_utils_posix.h | 57 void config_default_tcp_user_timeout(bool enable, int timeout, bool is_client);
61 int fd, const grpc_channel_args* channel_args, bool is_client);
|
| D | socket_utils_common_posix.cc | 239 void config_default_tcp_user_timeout(bool enable, int timeout, bool is_client) { in config_default_tcp_user_timeout() argument
240 if (is_client) { in config_default_tcp_user_timeout()
255 int fd, const grpc_channel_args* channel_args, bool is_client) { in grpc_set_socket_tcp_user_timeout() argument
259 if (is_client) { in grpc_set_socket_tcp_user_timeout()
|
| /external/grpc-grpc/test/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker_test.cc | 366 bool is_client = in mock_next() local
368 if (is_client) { in mock_next()
386 if (is_client) { in mock_next()
392 if (is_client) { in mock_next()
418 bool is_client) { in create_test_handshaker() argument
424 alts_tsi_handshaker_create(options, "target_name", "lame", is_client, in create_test_handshaker()
|
| /external/grpc-grpc/test/core/end2end/ |
| D | invalid_call_argument_test.cc | 36 int is_client; member
55 static void prepare_test(int is_client) { in prepare_test() argument
59 g_state.is_client = is_client; in prepare_test()
68 if (is_client) { in prepare_test()
124 if (!g_state.is_client) { in cleanup_test()
|