| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | http_connect_handshaker.cc | 66 static void http_connect_handshaker_unref(http_connect_handshaker* handshaker) { in http_connect_handshaker_unref() argument
67 if (gpr_unref(&handshaker->refcount)) { in http_connect_handshaker_unref()
68 gpr_mu_destroy(&handshaker->mu); in http_connect_handshaker_unref()
69 if (handshaker->endpoint_to_destroy != nullptr) { in http_connect_handshaker_unref()
70 grpc_endpoint_destroy(handshaker->endpoint_to_destroy); in http_connect_handshaker_unref()
72 if (handshaker->read_buffer_to_destroy != nullptr) { in http_connect_handshaker_unref()
73 grpc_slice_buffer_destroy_internal(handshaker->read_buffer_to_destroy); in http_connect_handshaker_unref()
74 gpr_free(handshaker->read_buffer_to_destroy); in http_connect_handshaker_unref()
76 grpc_slice_buffer_destroy_internal(&handshaker->write_buffer); in http_connect_handshaker_unref()
77 grpc_http_parser_destroy(&handshaker->http_parser); in http_connect_handshaker_unref()
[all …]
|
| /external/grpc-grpc/src/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker.cc | 250 alts_tsi_handshaker* handshaker = in handshaker_next() local
254 ok = alts_tsi_event_create(handshaker, cb, user_data, handshaker->options, in handshaker_next()
255 handshaker->target_name, &event); in handshaker_next()
265 if (!handshaker->has_sent_start_message) { in handshaker_next()
266 ok = handshaker->is_client in handshaker_next()
267 ? alts_handshaker_client_start_client(handshaker->client, event) in handshaker_next()
268 : alts_handshaker_client_start_server(handshaker->client, event, in handshaker_next()
270 handshaker->has_sent_start_message = true; in handshaker_next()
272 if (!GRPC_SLICE_IS_EMPTY(handshaker->recv_bytes)) { in handshaker_next()
273 grpc_slice_unref_internal(handshaker->recv_bytes); in handshaker_next()
[all …]
|
| D | alts_tsi_handshaker_private.h | 33 void alts_tsi_handshaker_set_client_for_testing(alts_tsi_handshaker* handshaker,
37 alts_tsi_handshaker* handshaker);
41 alts_tsi_handshaker* handshaker);
44 alts_tsi_handshaker* handshaker);
47 alts_tsi_handshaker* handshaker, grpc_slice* slice);
50 alts_tsi_handshaker* handshaker);
|
| D | alts_tsi_event.cc | 29 tsi_result alts_tsi_event_create(alts_tsi_handshaker* handshaker, in alts_tsi_event_create() argument
35 if (event == nullptr || handshaker == nullptr || cb == nullptr) { in alts_tsi_event_create()
40 e->handshaker = handshaker; in alts_tsi_event_create()
58 alts_tsi_handshaker_handle_response(event->handshaker, event->recv_buffer, in alts_tsi_event_dispatch_to_handshaker()
|
| D | alts_tsi_event.h | 44 alts_tsi_handshaker* handshaker; member
71 tsi_result alts_tsi_event_create(alts_tsi_handshaker* handshaker,
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| D | AltsHandshakerClientTest.java | 55 private AltsHandshakerClient handshaker; field in AltsHandshakerClientTest
66 handshaker = new AltsHandshakerClient(mockStub, clientOptions); in setUp()
75 handshaker.startClientHandshake(); in startClientHandshakeFailure()
87 ByteBuffer outFrame = handshaker.startClientHandshake(); in startClientHandshakeSuccess()
90 assertFalse(handshaker.isFinished()); in startClientHandshakeSuccess()
91 assertNull(handshaker.getResult()); in startClientHandshakeSuccess()
92 assertNull(handshaker.getKey()); in startClientHandshakeSuccess()
100 ByteBuffer outFrame = handshaker.startClientHandshake(); in startClientHandshakeWithOptions()
125 handshaker.startServerHandshake(inBytes); in startServerHandshakeFailure()
138 ByteBuffer outFrame = handshaker.startServerHandshake(inBytes); in startServerHandshakeSuccess()
[all …]
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsTsiHandshaker.java | 37 private final AltsHandshakerClient handshaker; field in AltsTsiHandshaker
45 handshaker = new AltsHandshakerClient(stub, options); in AltsTsiHandshaker()
49 AltsTsiHandshaker(boolean isClient, AltsHandshakerClient handshaker) { in AltsTsiHandshaker() argument
51 this.handshaker = handshaker; in AltsTsiHandshaker()
76 outputFrame = handshaker.startServerHandshake(bytes); in processBytesFromPeer()
78 outputFrame = handshaker.next(bytes); in processBytesFromPeer()
81 if (handshaker.isFinished() || outputFrame.hasRemaining()) { in processBytesFromPeer()
106 handshaker.getResult().getPeerIdentity().getServiceAccount()));
118 return new AltsAuthContext(handshaker.getResult());
140 outputFrame = handshaker.startClientHandshake();
[all …]
|
| D | TsiHandshakeHandler.java | 39 private final NettyTsiHandshaker handshaker; field in TsiHandshakeHandler
48 public TsiHandshakeHandler(NettyTsiHandshaker handshaker) { in TsiHandshakeHandler() argument
49 this.handshaker = checkNotNull(handshaker); in TsiHandshakeHandler()
145 if (handshaker.processBytesFromPeer(in) && handshaker.isInProgress()) { in decode()
150 if (!handshaker.isInProgress()) { in decode()
155 handshaker.createFrameProtector(ctx.alloc()), in decode()
156 handshaker.extractPeer(), in decode()
157 handshaker.extractPeerObject())); in decode()
181 handshaker.getBytesToSendToPeer(buffer); in sendHandshake()
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | handshaker.h | 73 void (*destroy)(grpc_handshaker* handshaker);
77 void (*shutdown)(grpc_handshaker* handshaker, grpc_error* why);
83 void (*do_handshake)(grpc_handshaker* handshaker,
100 grpc_handshaker* handshaker);
102 void grpc_handshaker_destroy(grpc_handshaker* handshaker);
103 void grpc_handshaker_shutdown(grpc_handshaker* handshaker, grpc_error* why);
104 void grpc_handshaker_do_handshake(grpc_handshaker* handshaker,
108 const char* grpc_handshaker_name(grpc_handshaker* handshaker);
122 grpc_handshaker* handshaker);
|
| D | handshaker.cc | 40 grpc_handshaker* handshaker) { in grpc_handshaker_init() argument
41 handshaker->vtable = vtable; in grpc_handshaker_init()
44 void grpc_handshaker_destroy(grpc_handshaker* handshaker) { in grpc_handshaker_destroy() argument
45 handshaker->vtable->destroy(handshaker); in grpc_handshaker_destroy()
48 void grpc_handshaker_shutdown(grpc_handshaker* handshaker, grpc_error* why) { in grpc_handshaker_shutdown() argument
49 handshaker->vtable->shutdown(handshaker, why); in grpc_handshaker_shutdown()
52 void grpc_handshaker_do_handshake(grpc_handshaker* handshaker, in grpc_handshaker_do_handshake() argument
56 handshaker->vtable->do_handshake(handshaker, acceptor, on_handshake_done, in grpc_handshaker_do_handshake()
60 const char* grpc_handshaker_name(grpc_handshaker* handshaker) { in grpc_handshaker_name() argument
61 return handshaker->vtable->name; in grpc_handshaker_name()
[all …]
|
| /external/grpc-grpc/test/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker_test.cc | 325 event->handshaker)); in mock_client_start()
349 event->handshaker)); in mock_server_start()
367 alts_tsi_handshaker_get_is_client_for_testing(event->handshaker); in mock_next()
379 event->handshaker), in mock_next()
382 event->handshaker)); in mock_next()
391 alts_tsi_handshaker_set_recv_bytes_for_testing(event->handshaker, &out_frame); in mock_next()
419 tsi_handshaker* handshaker = nullptr; in create_test_handshaker() local
425 &handshaker); in create_test_handshaker()
427 reinterpret_cast<alts_tsi_handshaker*>(handshaker); in create_test_handshaker()
430 return handshaker; in create_test_handshaker()
[all …]
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | security_handshaker.cc | 45 tsi_handshaker* handshaker; member
91 tsi_handshaker_destroy(h->handshaker); in security_handshaker_unref()
301 h->handshaker, bytes_received, bytes_received_size, &bytes_to_send, in do_handshaker_next_locked()
372 static void security_handshaker_destroy(grpc_handshaker* handshaker) { in security_handshaker_destroy() argument
373 security_handshaker* h = reinterpret_cast<security_handshaker*>(handshaker); in security_handshaker_destroy()
377 static void security_handshaker_shutdown(grpc_handshaker* handshaker, in security_handshaker_shutdown() argument
379 security_handshaker* h = reinterpret_cast<security_handshaker*>(handshaker); in security_handshaker_shutdown()
383 tsi_handshaker_shutdown(h->handshaker); in security_handshaker_shutdown()
391 static void security_handshaker_do_handshake(grpc_handshaker* handshaker, in security_handshaker_do_handshake() argument
395 security_handshaker* h = reinterpret_cast<security_handshaker*>(handshaker); in security_handshaker_do_handshake()
[all …]
|
| /external/grpc-grpc/src/core/tsi/ |
| D | local_transport_security.cc | 171 local_tsi_handshaker* handshaker = in handshaker_next() local
174 create_handshaker_result(handshaker->is_client, result); in handshaker_next()
182 local_tsi_handshaker* handshaker = in handshaker_destroy() local
184 gpr_free(handshaker); in handshaker_destroy()
203 local_tsi_handshaker* handshaker = in local_tsi_handshaker_create() local
204 static_cast<local_tsi_handshaker*>(gpr_zalloc(sizeof(*handshaker))); in local_tsi_handshaker_create()
205 handshaker->is_client = is_client; in local_tsi_handshaker_create()
206 handshaker->base.vtable = &handshaker_vtable; in local_tsi_handshaker_create()
207 *self = &handshaker->base; in local_tsi_handshaker_create()
|
| D | fake_transport_security.cc | 679 tsi_fake_handshaker* handshaker = in fake_handshaker_next() local
695 size_t sent_bytes_size = handshaker->outgoing_bytes_buffer_size - offset; in fake_handshaker_next()
697 self, handshaker->outgoing_bytes_buffer + offset, &sent_bytes_size); in fake_handshaker_next()
700 handshaker->outgoing_bytes_buffer_size *= 2; in fake_handshaker_next()
701 handshaker->outgoing_bytes_buffer = static_cast<unsigned char*>( in fake_handshaker_next()
702 gpr_realloc(handshaker->outgoing_bytes_buffer, in fake_handshaker_next()
703 handshaker->outgoing_bytes_buffer_size)); in fake_handshaker_next()
707 *bytes_to_send = handshaker->outgoing_bytes_buffer; in fake_handshaker_next()
|
| /external/boringssl/src/ssl/test/ |
| D | CMakeLists.txt | 21 handshaker target
25 handshaker.cc
32 add_dependencies(handshaker global_target)
34 target_link_libraries(handshaker test_support_lib ssl crypto)
37 add_custom_target(handshaker) target
|
| /external/grpc-grpc/test/core/handshake/ |
| D | readahead_handshaker_server_ssl.cc | 52 static void readahead_handshaker_destroy(grpc_handshaker* handshaker) { in readahead_handshaker_destroy() argument
53 gpr_free(handshaker); in readahead_handshaker_destroy()
56 static void readahead_handshaker_shutdown(grpc_handshaker* handshaker, in readahead_handshaker_shutdown() argument
60 grpc_handshaker* handshaker, grpc_tcp_server_acceptor* acceptor, in readahead_handshaker_do_handshake() argument
|
| /external/grpc-grpc-java/alts/src/main/proto/grpc/gcp/ |
| 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 …]
|
| /external/grpc-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 …]
|
| /external/grpc-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 …]
|
| /external/grpc-grpc/src/core/lib/security/security_connector/ |
| D | local_security_connector.cc | 73 tsi_handshaker* handshaker = nullptr; in local_channel_add_handshakers() local
74 GPR_ASSERT(local_tsi_handshaker_create(true /* is_client */, &handshaker) == in local_channel_add_handshakers()
77 handshaker, &sc->base)); in local_channel_add_handshakers()
83 tsi_handshaker* handshaker = nullptr; in local_server_add_handshakers() local
84 GPR_ASSERT(local_tsi_handshaker_create(false /* is_client */, &handshaker) == in local_server_add_handshakers()
87 handshaker, &sc->base)); in local_server_add_handshakers()
|
| D | alts_security_connector.cc | 69 tsi_handshaker* handshaker = nullptr; in alts_channel_add_handshakers() local
75 &handshaker) == TSI_OK); in alts_channel_add_handshakers()
77 handshaker, &sc->base)); in alts_channel_add_handshakers()
83 tsi_handshaker* handshaker = nullptr; in alts_server_add_handshakers() local
89 &handshaker) == TSI_OK); in alts_server_add_handshakers()
91 handshaker, &sc->base)); in alts_server_add_handshakers()
|
| /external/grpc-grpc/tools/distrib/ |
| D | check_nanopb_output.sh | 76 src/core/tsi/alts/handshaker/proto/handshaker.proto \
80 src/core/tsi/alts/handshaker/proto/transport_security_common.proto \
84 src/core/tsi/alts/handshaker/proto/altscontext.proto \
|
| /external/grpc-grpc/src/core/lib/http/ |
| D | httpcli.cc | 50 const grpc_httpcli_handshaker* handshaker; member
189 req->handshaker->handshake( in on_connected()
240 req->handshaker = in internal_request_begin()
241 request->handshaker ? request->handshaker : &grpc_httpcli_plaintext; in internal_request_begin()
259 request->host, req->handshaker->default_port, req->context->pollset_set, in internal_request_begin()
|
| D | httpcli_security_connector.cc | 57 tsi_handshaker* handshaker = nullptr; in httpcli_ssl_add_handshakers() local
60 c->handshaker_factory, c->secure_peer_name, &handshaker); in httpcli_ssl_add_handshakers()
67 handshake_mgr, grpc_security_handshaker_create(handshaker, &sc->base)); in httpcli_ssl_add_handshakers()
|
| /external/grpc-grpc/test/core/tsi/ |
| D | ssl_transport_security_test.cc | 695 tsi_handshaker* handshaker[3]; in test_tsi_ssl_client_handshaker_factory_refcounting() local
699 client_handshaker_factory, "google.com", &handshaker[i]) == in test_tsi_ssl_client_handshaker_factory_refcounting()
703 tsi_handshaker_destroy(handshaker[1]); in test_tsi_ssl_client_handshaker_factory_refcounting()
706 tsi_handshaker_destroy(handshaker[0]); in test_tsi_ssl_client_handshaker_factory_refcounting()
712 tsi_handshaker_destroy(handshaker[2]); in test_tsi_ssl_client_handshaker_factory_refcounting()
721 tsi_handshaker* handshaker[3]; in test_tsi_ssl_server_handshaker_factory_refcounting() local
741 server_handshaker_factory, &handshaker[i]) == TSI_OK); in test_tsi_ssl_server_handshaker_factory_refcounting()
744 tsi_handshaker_destroy(handshaker[1]); in test_tsi_ssl_server_handshaker_factory_refcounting()
747 tsi_handshaker_destroy(handshaker[0]); in test_tsi_ssl_server_handshaker_factory_refcounting()
753 tsi_handshaker_destroy(handshaker[2]); in test_tsi_ssl_server_handshaker_factory_refcounting()
|