| /third_party/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker.cc | 405 alts_tsi_handshaker* handshaker, const unsigned char* received_bytes, in alts_tsi_handshaker_continue_handshaker_next() argument
408 if (!handshaker->has_created_handshaker_client) { in alts_tsi_handshaker_continue_handshaker_next()
409 if (handshaker->channel == nullptr) { in alts_tsi_handshaker_continue_handshaker_next()
411 handshaker->handshaker_service_url); in alts_tsi_handshaker_continue_handshaker_next()
412 handshaker->interested_parties = in alts_tsi_handshaker_continue_handshaker_next()
414 GPR_ASSERT(handshaker->interested_parties != nullptr); in alts_tsi_handshaker_continue_handshaker_next()
416 grpc_iomgr_cb_func grpc_cb = handshaker->channel == nullptr in alts_tsi_handshaker_continue_handshaker_next()
420 handshaker->channel == nullptr in alts_tsi_handshaker_continue_handshaker_next()
422 : handshaker->channel; in alts_tsi_handshaker_continue_handshaker_next()
424 handshaker, channel, handshaker->handshaker_service_url, in alts_tsi_handshaker_continue_handshaker_next()
[all …]
|
| D | alts_tsi_handshaker_private.h | 33 alts_tsi_handshaker* handshaker);
36 alts_tsi_handshaker* handshaker);
39 alts_tsi_handshaker* handshaker, alts_handshaker_client_vtable* vtable);
42 alts_tsi_handshaker* handshaker);
64 alts_handshaker_client* client, alts_tsi_handshaker* handshaker,
|
| D | alts_handshaker_client.cc | 59 alts_tsi_handshaker* handshaker; member
201 alts_tsi_handshaker* handshaker = client->handshaker; in alts_handshaker_client_handle_response() local
208 if (handshaker == nullptr) { in alts_handshaker_client_handle_response()
215 if (alts_tsi_handshaker_has_shutdown(handshaker)) { in alts_handshaker_client_handle_response()
687 alts_tsi_handshaker* handshaker, grpc_channel* channel, in alts_grpc_handshaker_client_create() argument
702 client->handshaker = handshaker; in alts_grpc_handshaker_client_create()
776 alts_handshaker_client* c, alts_tsi_handshaker* handshaker, in alts_handshaker_client_set_fields_for_testing() argument
782 client->handshaker = handshaker; in alts_handshaker_client_set_fields_for_testing()
801 client->handshaker) == has_sent_start_message); in alts_handshaker_client_check_fields_for_testing()
818 return client->handshaker; in alts_handshaker_client_get_handshaker_for_testing()
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | http_connect_handshaker.cc | 137 auto* handshaker = static_cast<HttpConnectHandshaker*>(arg); in OnWriteDoneScheduler() local
140 GRPC_CLOSURE_INIT(&handshaker->request_done_closure_, in OnWriteDoneScheduler()
141 &HttpConnectHandshaker::OnWriteDone, handshaker, in OnWriteDoneScheduler()
148 auto* handshaker = static_cast<HttpConnectHandshaker*>(arg); in OnWriteDone() local
149 ReleasableMutexLock lock(&handshaker->mu_); in OnWriteDone()
150 if (error != GRPC_ERROR_NONE || handshaker->is_shutdown_) { in OnWriteDone()
153 handshaker->HandshakeFailedLocked(GRPC_ERROR_REF(error)); in OnWriteDone()
155 handshaker->Unref(); in OnWriteDone()
160 handshaker->args_->endpoint, handshaker->args_->read_buffer, in OnWriteDone()
161 GRPC_CLOSURE_INIT(&handshaker->response_read_closure_, in OnWriteDone()
[all …]
|
| /third_party/grpc/test/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker_test.cc | 473 alts_tsi_handshaker* handshaker = in mock_next() local
475 bool is_client = alts_tsi_handshaker_get_is_client_for_testing(handshaker); in mock_next()
507 tsi_handshaker* handshaker = nullptr; in create_test_handshaker() local
512 nullptr, &handshaker, 0); in create_test_handshaker()
514 reinterpret_cast<alts_tsi_handshaker*>(handshaker); in create_test_handshaker()
517 return handshaker; in create_test_handshaker()
521 tsi_handshaker* handshaker) { in run_tsi_handshaker_destroy_with_exec_ctx() argument
523 tsi_handshaker_destroy(handshaker); in run_tsi_handshaker_destroy_with_exec_ctx()
528 tsi_handshaker* handshaker = create_test_handshaker(true); in check_handshaker_next_invalid_input() local
534 GPR_ASSERT(tsi_handshaker_next(handshaker, nullptr, 0, nullptr, nullptr, in check_handshaker_next_invalid_input()
[all …]
|
| /third_party/grpc/src/core/tsi/ |
| D | local_transport_security.cc | 175 local_tsi_handshaker* handshaker = in handshaker_next() local
178 create_handshaker_result(handshaker->is_client, result); in handshaker_next()
186 local_tsi_handshaker* handshaker = in handshaker_destroy() local
188 gpr_free(handshaker); in handshaker_destroy()
209 local_tsi_handshaker* handshaker = in tsi_local_handshaker_create() local
210 static_cast<local_tsi_handshaker*>(gpr_zalloc(sizeof(*handshaker))); in tsi_local_handshaker_create()
211 handshaker->is_client = is_client; in tsi_local_handshaker_create()
212 handshaker->base.vtable = &handshaker_vtable; in tsi_local_handshaker_create()
213 *self = &handshaker->base; in tsi_local_handshaker_create()
|
| D | fake_transport_security.cc | 683 tsi_fake_handshaker* handshaker = in fake_handshaker_next() local
699 size_t sent_bytes_size = handshaker->outgoing_bytes_buffer_size - offset; in fake_handshaker_next()
701 self, handshaker->outgoing_bytes_buffer + offset, &sent_bytes_size); in fake_handshaker_next()
704 handshaker->outgoing_bytes_buffer_size *= 2; in fake_handshaker_next()
705 handshaker->outgoing_bytes_buffer = static_cast<unsigned char*>( in fake_handshaker_next()
706 gpr_realloc(handshaker->outgoing_bytes_buffer, in fake_handshaker_next()
707 handshaker->outgoing_bytes_buffer_size)); in fake_handshaker_next()
711 *bytes_to_send = handshaker->outgoing_bytes_buffer; in fake_handshaker_next()
|
| D | ssl_transport_security.h | 194 const char* server_name_indication, tsi_handshaker** handshaker);
321 tsi_ssl_server_handshaker_factory* factory, tsi_handshaker** handshaker);
|
| D | ssl_transport_security.cc | 1365 tsi_ssl_handshaker* handshaker, unsigned char* unused_bytes, in ssl_handshaker_result_create() argument
1367 if (handshaker == nullptr || handshaker_result == nullptr || in ssl_handshaker_result_create()
1375 result->ssl = handshaker->ssl; in ssl_handshaker_result_create()
1376 handshaker->ssl = nullptr; in ssl_handshaker_result_create()
1377 result->network_io = handshaker->network_io; in ssl_handshaker_result_create()
1378 handshaker->network_io = nullptr; in ssl_handshaker_result_create()
1596 tsi_handshaker** handshaker) { in create_tsi_ssl_handshaker() argument
1601 *handshaker = nullptr; in create_tsi_ssl_handshaker()
1659 *handshaker = &impl->base; in create_tsi_ssl_handshaker()
1695 const char* server_name_indication, tsi_handshaker** handshaker) { in tsi_ssl_client_handshaker_factory_create_handshaker() argument
[all …]
|
| /third_party/grpc/src/core/lib/channel/ |
| D | handshaker.cc | 96 void HandshakeManager::Add(RefCountedPtr<Handshaker> handshaker) { in Add() argument
101 this, handshaker->name(), handshaker.get(), handshakers_.size()); in Add()
104 handshakers_.push_back(std::move(handshaker)); in Add()
170 auto handshaker = handshakers_[index_]; in CallNextHandshakerLocked() local
175 this, handshaker->name(), handshaker.get(), index_); in CallNextHandshakerLocked()
177 handshaker->DoHandshake(acceptor_, &call_next_handshaker_, &args_); in CallNextHandshakerLocked()
254 grpc_handshaker* handshaker) { in grpc_handshake_manager_add() argument
257 static_cast<grpc_core::Handshaker*>(handshaker)); in grpc_handshake_manager_add()
|
| D | handshaker.h | 112 void Add(RefCountedPtr<Handshaker> handshaker);
177 grpc_handshaker* handshaker);
|
| /third_party/grpc/src/core/lib/security/security_connector/insecure/ |
| D | insecure_security_connector.cc | 71 tsi_handshaker* handshaker = nullptr; in add_handshakers() local
73 GPR_ASSERT(tsi_local_handshaker_create(true /* is_client */, &handshaker) == in add_handshakers()
75 handshake_manager->Add(SecurityHandshakerCreate(handshaker, this, args)); in add_handshakers()
99 tsi_handshaker* handshaker = nullptr; in add_handshakers() local
101 GPR_ASSERT(tsi_local_handshaker_create(false /* is_client */, &handshaker) == in add_handshakers()
103 handshake_manager->Add(SecurityHandshakerCreate(handshaker, this, args)); in add_handshakers()
|
| /third_party/grpc/test/core/tsi/alts/fake_handshaker/ |
| D | handshaker.proto | 80 // handshaker chooses a default local identity.
106 // specified. Otherwise, the handshaker chooses a default local identity.
166 // required for the record protocol, thus the client of the handshaker
176 // Indicate whether the handshaker service client should keep the channel
177 // between the handshaker service open, e.g., in order to handle
197 // the peer even if the handshaker status is not OK as these frames may
201 // Number of bytes in the in_bytes consumed by the handshaker. It is possible
210 // Status of the handshaker.
215 // Handshaker service accepts a stream of handshaker request, returning a
216 // stream of handshaker response. Client is expected to send exactly one
[all …]
|
| /third_party/grpc/src/core/tsi/alts/handshaker/proto/ |
| D | handshaker.proto | 80 // handshaker chooses a default local identity.
106 // specified. Otherwise, the handshaker chooses a default local identity.
166 // required for the record protocol, thus the client of the handshaker
176 // Indicate whether the handshaker service client should keep the channel
177 // between the handshaker service open, e.g., in order to handle
197 // the peer even if the handshaker status is not OK as these frames may
201 // Number of bytes in the in_bytes consumed by the handshaker. It is possible
210 // Status of the handshaker.
215 // Handshaker service accepts a stream of handshaker request, returning a
216 // stream of handshaker response. Client is expected to send exactly one
[all …]
|
| D | handshaker.options | 1 handshaker.proto no_unions:true
|
| /third_party/grpc/src/proto/grpc/gcp/ |
| D | handshaker.proto | 16 // https://github.com/grpc/grpc-proto/blob/master/grpc/gcp/handshaker.proto
90 // handshaker chooses a default local identity.
119 // specified. Otherwise, the handshaker chooses a default local identity.
182 // required for the record protocol, thus the client of the handshaker
192 // Indicate whether the handshaker service client should keep the channel
193 // between the handshaker service open, e.g., in order to handle
216 // the peer even if the handshaker status is not OK as these frames may
220 // Number of bytes in the in_bytes consumed by the handshaker. It is possible
229 // Status of the handshaker.
234 // Handshaker service accepts a stream of handshaker request, returning a
[all …]
|
| /third_party/grpc/src/core/lib/security/security_connector/local/ |
| D | local_security_connector.cc | 159 tsi_handshaker* handshaker = nullptr; in add_handshakers() local
160 GPR_ASSERT(tsi_local_handshaker_create(true /* is_client */, &handshaker) == in add_handshakers()
163 grpc_core::SecurityHandshakerCreate(handshaker, this, args)); in add_handshakers()
217 tsi_handshaker* handshaker = nullptr; in add_handshakers() local
219 &handshaker) == TSI_OK); in add_handshakers()
221 grpc_core::SecurityHandshakerCreate(handshaker, this, args)); in add_handshakers()
|
| /third_party/grpc/src/core/lib/security/security_connector/alts/ |
| D | alts_security_connector.cc | 82 tsi_handshaker* handshaker = nullptr; in add_handshakers() local
95 &handshaker, user_specified_max_frame_size) == TSI_OK); in add_handshakers()
97 grpc_core::SecurityHandshakerCreate(handshaker, this, args)); in add_handshakers()
147 tsi_handshaker* handshaker = nullptr; in add_handshakers() local
159 false, interested_parties, &handshaker, in add_handshakers()
162 grpc_core::SecurityHandshakerCreate(handshaker, this, args)); in add_handshakers()
|
| /third_party/grpc/src/core/lib/security/transport/ |
| D | security_handshaker.h | 31 tsi_handshaker* handshaker, grpc_security_connector* connector,
42 tsi_handshaker* handshaker, grpc_security_connector* connector,
|
| D | security_handshaker.cc | 49 SecurityHandshaker(tsi_handshaker* handshaker,
109 SecurityHandshaker::SecurityHandshaker(tsi_handshaker* handshaker, in SecurityHandshaker() argument
112 : handshaker_(handshaker), in SecurityHandshaker()
546 tsi_handshaker* handshaker, grpc_security_connector* connector, in SecurityHandshakerCreate() argument
550 if (handshaker == nullptr) { in SecurityHandshakerCreate()
553 return MakeRefCounted<SecurityHandshaker>(handshaker, connector, args); in SecurityHandshakerCreate()
569 tsi_handshaker* handshaker, grpc_security_connector* connector, in grpc_security_handshaker_create() argument
571 return SecurityHandshakerCreate(handshaker, connector, args).release(); in grpc_security_handshaker_create()
|
| /third_party/grpc/src/core/lib/http/ |
| D | httpcli.cc | 55 const grpc_httpcli_handshaker* handshaker; member
192 req->handshaker->handshake( in on_connected()
244 req->handshaker = in internal_request_begin()
245 request->handshaker ? request->handshaker : &grpc_httpcli_plaintext; in internal_request_begin()
263 request->host, req->handshaker->default_port, req->context->pollset_set, in internal_request_begin()
|
| D | httpcli_security_connector.cc | 74 tsi_handshaker* handshaker = nullptr; in add_handshakers() local
77 handshaker_factory_, secure_peer_name_, &handshaker); in add_handshakers()
84 grpc_core::SecurityHandshakerCreate(handshaker, this, args)); in add_handshakers()
|
| /third_party/grpc/test/core/tsi/ |
| D | ssl_transport_security_test.cc | 788 tsi_handshaker* handshaker[3]; in test_tsi_ssl_client_handshaker_factory_refcounting() local
792 client_handshaker_factory, "google.com", &handshaker[i]) == in test_tsi_ssl_client_handshaker_factory_refcounting()
796 tsi_handshaker_destroy(handshaker[1]); in test_tsi_ssl_client_handshaker_factory_refcounting()
799 tsi_handshaker_destroy(handshaker[0]); in test_tsi_ssl_client_handshaker_factory_refcounting()
805 tsi_handshaker_destroy(handshaker[2]); in test_tsi_ssl_client_handshaker_factory_refcounting()
814 tsi_handshaker* handshaker[3]; in test_tsi_ssl_server_handshaker_factory_refcounting() local
837 server_handshaker_factory, &handshaker[i]) == TSI_OK); in test_tsi_ssl_server_handshaker_factory_refcounting()
840 tsi_handshaker_destroy(handshaker[1]); in test_tsi_ssl_server_handshaker_factory_refcounting()
843 tsi_handshaker_destroy(handshaker[0]); in test_tsi_ssl_server_handshaker_factory_refcounting()
849 tsi_handshaker_destroy(handshaker[2]); in test_tsi_ssl_server_handshaker_factory_refcounting()
|
| /third_party/grpc/test/core/security/ |
| D | jwt_verifier_test.cc | 350 GPR_ASSERT(request->handshaker == &grpc_httpcli_ssl); in httpcli_get_google_keys_for_email()
396 GPR_ASSERT(request->handshaker == &grpc_httpcli_ssl); in httpcli_get_custom_keys_for_email()
429 GPR_ASSERT(request->handshaker == &grpc_httpcli_ssl); in httpcli_get_jwk_set()
441 GPR_ASSERT(request->handshaker == &grpc_httpcli_ssl); in httpcli_get_openid_config()
484 GPR_ASSERT(request->handshaker == &grpc_httpcli_ssl); in httpcli_get_bad_json()
|
| /third_party/grpc/test/core/http/ |
| D | httpcli_test.cc | 77 req.handshaker = &grpc_httpcli_plaintext; in test_get()
116 req.handshaker = &grpc_httpcli_plaintext; in test_post()
|