| /third_party/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 …]
|
| /third_party/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 …]
|
| /third_party/grpc/src/core/tsi/ |
| D | local_transport_security.cc | 44 bool is_client; member
50 bool is_client; member
147 static tsi_result create_handshaker_result(bool is_client, in create_handshaker_result() argument
155 result->is_client = is_client; in create_handshaker_result()
178 create_handshaker_result(handshaker->is_client, result); in handshaker_next()
204 tsi_result tsi_local_handshaker_create(bool is_client, tsi_handshaker** self) { in tsi_local_handshaker_create() argument
211 handshaker->is_client = is_client; in tsi_local_handshaker_create()
|
| D | fake_transport_security.cc | 62 int is_client; member
594 impl->is_client ? "Client" : "Server", in fake_handshaker_get_bytes_to_send_to_peer()
601 if (!impl->is_client && in fake_handshaker_get_bytes_to_send_to_peer()
644 gpr_log(GPR_INFO, "%s received %s.", impl->is_client ? "Client" : "Server", in fake_handshaker_process_bytes_from_peer()
652 gpr_log(GPR_INFO, "%s is done.", impl->is_client ? "Client" : "Server"); in fake_handshaker_process_bytes_from_peer()
748 tsi_handshaker* tsi_create_fake_handshaker(int is_client) { in tsi_create_fake_handshaker() argument
752 impl->is_client = is_client; in tsi_create_fake_handshaker()
758 if (is_client) { in tsi_create_fake_handshaker()
|
| /third_party/glib/gio/ |
| D | gdbusauthmechanismanon.c | 31 gboolean is_client; member
169 …g_return_val_if_fail (m->priv->is_server && !m->priv->is_client, G_DBUS_AUTH_MECHANISM_STATE_INVAL… in mechanism_server_get_state()
182 g_return_if_fail (!m->priv->is_server && !m->priv->is_client); in mechanism_server_initiate()
198 g_return_if_fail (m->priv->is_server && !m->priv->is_client); in mechanism_server_data_receive()
212 g_return_val_if_fail (m->priv->is_server && !m->priv->is_client, NULL); in mechanism_server_data_send()
227 g_return_val_if_fail (m->priv->is_server && !m->priv->is_client, NULL); in mechanism_server_get_reject_reason()
242 g_return_if_fail (m->priv->is_server && !m->priv->is_client); in mechanism_server_shutdown()
255 …g_return_val_if_fail (m->priv->is_client && !m->priv->is_server, G_DBUS_AUTH_MECHANISM_STATE_INVAL… in mechanism_client_get_state()
268 g_return_val_if_fail (!m->priv->is_server && !m->priv->is_client, NULL); in mechanism_client_initiate()
270 m->priv->is_client = TRUE; in mechanism_client_initiate()
[all …]
|
| D | gdbusauthmechanismexternal.c | 34 gboolean is_client; member
174 …g_return_val_if_fail (m->priv->is_server && !m->priv->is_client, G_DBUS_AUTH_MECHANISM_STATE_INVAL… in mechanism_server_get_state()
225 g_return_if_fail (!m->priv->is_server && !m->priv->is_client); in mechanism_server_initiate()
256 g_return_if_fail (m->priv->is_server && !m->priv->is_client); in mechanism_server_data_receive()
278 g_return_val_if_fail (m->priv->is_server && !m->priv->is_client, NULL); in mechanism_server_data_send()
293 g_return_val_if_fail (m->priv->is_server && !m->priv->is_client, NULL); in mechanism_server_get_reject_reason()
308 g_return_if_fail (m->priv->is_server && !m->priv->is_client); in mechanism_server_shutdown()
321 …g_return_val_if_fail (m->priv->is_client && !m->priv->is_server, G_DBUS_AUTH_MECHANISM_STATE_INVAL… in mechanism_client_get_state()
335 g_return_val_if_fail (!m->priv->is_server && !m->priv->is_client, NULL); in mechanism_client_initiate()
337 m->priv->is_client = TRUE; in mechanism_client_initiate()
[all …]
|
| D | gdbusauthmechanismsha1.c | 80 gboolean is_client; member
959 …g_return_val_if_fail (m->priv->is_server && !m->priv->is_client, G_DBUS_AUTH_MECHANISM_STATE_INVAL… in mechanism_server_get_state()
972 g_return_if_fail (!m->priv->is_server && !m->priv->is_client); in mechanism_server_initiate()
1015 g_return_if_fail (m->priv->is_server && !m->priv->is_client); in mechanism_server_data_receive()
1062 g_return_val_if_fail (m->priv->is_server && !m->priv->is_client, NULL); in mechanism_server_data_send()
1104 g_return_val_if_fail (m->priv->is_server && !m->priv->is_client, NULL); in mechanism_server_get_reject_reason()
1116 g_return_if_fail (m->priv->is_server && !m->priv->is_client); in mechanism_server_shutdown()
1129 …g_return_val_if_fail (m->priv->is_client && !m->priv->is_server, G_DBUS_AUTH_MECHANISM_STATE_INVAL… in mechanism_client_get_state()
1142 g_return_val_if_fail (!m->priv->is_server && !m->priv->is_client, NULL); in mechanism_client_initiate()
1144 m->priv->is_client = TRUE; in mechanism_client_initiate()
[all …]
|
| /third_party/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 …]
|
| /third_party/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker.cc | 50 bool is_client; member
80 bool is_client; member
187 kAltsAes128GcmRekeyKeyLength, /*is_rekey=*/true, result->is_client, in handshaker_result_create_zero_copy_grpc_protector()
209 kAltsAes128GcmRekeyKeyLength, result->is_client, /*is_rekey=*/true, in handshaker_result_create_frame_protector()
255 bool is_client, in alts_tsi_handshaker_result_create() argument
368 sresult->is_client = is_client; in alts_tsi_handshaker_result_create()
427 handshaker->client_vtable_for_testing, handshaker->is_client, in alts_tsi_handshaker_continue_handshaker_next()
457 ok = handshaker->is_client in alts_tsi_handshaker_continue_handshaker_next()
622 const char* handshaker_service_url, bool is_client, in alts_tsi_handshaker_create() argument
626 options == nullptr || (is_client && target_name == nullptr)) { in alts_tsi_handshaker_create()
[all …]
|
| D | alts_tsi_handshaker.h | 71 const char* handshaker_service_url, bool is_client,
84 bool is_client,
|
| D | alts_handshaker_client.cc | 88 bool is_client; member
266 alts_tsi_handshaker_result_create(resp, client->is_client, &result); in alts_handshaker_client_handle_response()
414 void RequestHandshake(alts_grpc_handshaker_client* client, bool is_client) { in RequestHandshake() argument
417 is_client ? g_client_handshake_queue : g_server_handshake_queue; in RequestHandshake()
421 void HandshakeDone(bool is_client) { in HandshakeDone() argument
423 is_client ? g_client_handshake_queue : g_server_handshake_queue; in HandshakeDone()
438 RequestHandshake(client, client->is_client); in make_grpc_call()
462 HandshakeDone(client->is_client); in on_status_received()
692 bool is_client, size_t max_frame_size) { in alts_grpc_handshaker_client_create() argument
709 client->is_client = is_client; in alts_grpc_handshaker_client_create()
|
| /third_party/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 56 void log_metadata(const grpc_metadata_batch* md_batch, bool is_client,
78 bool is_client) in inproc_transport()
80 is_client(is_client), in inproc_transport()
81 state_tracker(is_client ? "inproc_client" : "inproc_server", in inproc_transport()
114 bool is_client; member
283 void log_metadata(const grpc_metadata_batch* md_batch, bool is_client, in log_metadata() argument
290 is_client ? "CLI" : "SVR", key, value); in log_metadata()
301 log_metadata(metadata, s->t->is_client, outflags != nullptr); in fill_in_metadata()
435 if (!s->t->is_client) { in fail_helper_locked()
615 } else if (!s->t->is_client && s->trailing_md_sent) { in op_state_machine_locked()
[all …]
|
| /third_party/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()
253 const uint8_t* key, size_t key_size, bool is_rekey, bool is_client, in alts_zero_copy_grpc_protector_create() argument
270 key, key_size, is_rekey, is_client, is_integrity_only, in alts_zero_copy_grpc_protector_create()
274 key, key_size, is_rekey, is_client, is_integrity_only, in alts_zero_copy_grpc_protector_create()
|
| /third_party/grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 231 bool is_client) { in read_channel_args() argument
247 is_client ? "client" : "server"); in read_channel_args()
290 grpc_integer_options{t->is_client in read_channel_args()
299 grpc_integer_options{t->is_client in read_channel_args()
348 if (!settings_map[j].availability[is_client]) { in read_channel_args()
351 is_client ? "clients" : "servers"); in read_channel_args()
375 if (t->is_client) { in init_transport_keepalive_settings()
420 const grpc_channel_args* channel_args, grpc_endpoint* ep, bool is_client, in grpc_chttp2_transport() argument
429 state_tracker(is_client ? "client_transport" : "server_transport", in grpc_chttp2_transport()
431 is_client(is_client), in grpc_chttp2_transport()
[all …]
|
| D | writing.cc | 61 t->is_client ? "CLIENT" : "SERVER", t->peer_string.c_str()); in maybe_initiate_ping()
72 t->is_client ? "CLIENT" : "SERVER", t->peer_string.c_str(), in maybe_initiate_ping()
97 t->is_client ? "CLIENT" : "SERVER", t->peer_string.c_str(), in maybe_initiate_ping()
127 t->is_client ? "CLIENT" : "SERVER", t->peer_string.c_str(), in maybe_initiate_ping()
433 t_->is_client ? "CLIENT" : "SERVER", s->id, in StreamWriteContext()
449 if (!t_->is_client && s_->fetching_send_message == nullptr && in FlushInitialMetadata()
616 if (!t_->is_client && !s_->read_closed) { in SentLastFrame()
621 grpc_chttp2_mark_stream_closed(t_, s_, !t_->is_client, true, in SentLastFrame()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | call.cc | 144 is_client(args.server_transport_data == nullptr), in grpc_call()
168 bool is_client; member
363 if (call->is_client) { in grpc_call_create()
396 GPR_ASSERT(call->is_client); in grpc_call_create()
397 GPR_ASSERT(!args->parent->is_client); in grpc_call_create()
479 if (call->is_client) { in grpc_call_create()
746 gpr_log(GPR_DEBUG, "set_final_status %s", call->is_client ? "CLI" : "SVR"); in set_final_status()
749 if (call->is_client) { in set_final_status()
1001 if (!call->is_client && is_trailing) return; in publish_app_metadata()
1084 } else if (!call->is_client) { in recv_trailing_filter()
[all …]
|
| /third_party/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()
|
| /third_party/gstreamer/gstplugins_bad/ext/dtls/ |
| D | README | 92 def dtls_tx_pipeline_description(name, is_client, port):
100 ]).format(name=name, client=is_client, port=port)
113 def __init__(self, name, is_client, tx_port, rx_port):
116 name, is_client, tx_port
143 blue = Endpoint("blue", is_client=True, tx_port=23000, rx_port=23002)
144 red = Endpoint("red", is_client=False, tx_port=23002, rx_port=23000)
|
| /third_party/grpc/test/core/tsi/alts/fake_handshaker/ |
| D | fake_handshaker_server.cc | 90 bool is_client = true; member
133 context->is_client = true; in ProcessClientStart()
170 context->is_client = false; in ProcessServerStart()
178 if (context->is_client) { in ProcessNext()
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | socket_utils_posix.h | 69 void config_default_tcp_user_timeout(bool enable, int timeout, bool is_client);
73 int fd, const grpc_channel_args* channel_args, bool is_client);
|
| D | socket_utils_common_posix.cc | 285 void config_default_tcp_user_timeout(bool enable, int timeout, bool is_client) { in config_default_tcp_user_timeout() argument
286 if (is_client) { in config_default_tcp_user_timeout()
301 int fd, const grpc_channel_args* channel_args, bool is_client) { in grpc_set_socket_tcp_user_timeout() argument
305 (void)is_client; in grpc_set_socket_tcp_user_timeout()
310 if (is_client) { in grpc_set_socket_tcp_user_timeout()
|