| /third_party/grpc/src/core/ext/transport/chttp2/client/ |
| D | chttp2_connector.cc | 48 if (endpoint_ != nullptr) grpc_endpoint_destroy(endpoint_); in ~Chttp2Connector()
64 GPR_ASSERT(endpoint_ == nullptr); in Connect()
65 ep = &endpoint_; in Connect()
86 if (!connecting_ && endpoint_ != nullptr) { in Shutdown()
87 grpc_endpoint_shutdown(endpoint_, GRPC_ERROR_REF(error)); in Shutdown()
105 if (self->endpoint_ != nullptr) { in Connected()
106 grpc_endpoint_shutdown(self->endpoint_, GRPC_ERROR_REF(error)); in Connected()
114 GPR_ASSERT(self->endpoint_ != nullptr); in Connected()
126 grpc_endpoint_add_to_pollset_set(endpoint_, args_.interested_parties); in StartHandshakeLocked()
127 handshake_mgr_->DoHandshake(endpoint_, args_.channel_args, args_.deadline, in StartHandshakeLocked()
[all …]
|
| D | chttp2_connector.h | 64 grpc_endpoint* endpoint_ = nullptr; variable
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | resolve_endpoint_op.hpp | 62 endpoint_(endpoint), in resolve_endpoint_op()
85 socket_ops::background_getnameinfo(o->cancel_token_, o->endpoint_.data(), in do_complete()
86 o->endpoint_.size(), host_name, NI_MAXHOST, service_name, NI_MAXSERV, in do_complete()
87 o->endpoint_.protocol().type(), o->ec_); in do_complete()
88 o->results_ = results_type::create(o->endpoint_, host_name, service_name); in do_complete()
129 endpoint_type endpoint_; member in boost::asio::detail::resolve_endpoint_op
|
| D | win_iocp_socket_recvfrom_op.hpp | 51 endpoint_(endpoint), in win_iocp_socket_recvfrom_op()
95 o->endpoint_.resize(o->endpoint_size_); in do_complete()
119 Endpoint& endpoint_; member in boost::asio::detail::win_iocp_socket_recvfrom_op
|
| /third_party/boost/boost/asio/detail/ |
| D | resolve_endpoint_op.hpp | 62 endpoint_(endpoint), in resolve_endpoint_op()
85 socket_ops::background_getnameinfo(o->cancel_token_, o->endpoint_.data(), in do_complete()
86 o->endpoint_.size(), host_name, NI_MAXHOST, service_name, NI_MAXSERV, in do_complete()
87 o->endpoint_.protocol().type(), o->ec_); in do_complete()
88 o->results_ = results_type::create(o->endpoint_, host_name, service_name); in do_complete()
129 endpoint_type endpoint_; member in boost::asio::detail::resolve_endpoint_op
|
| D | win_iocp_socket_recvfrom_op.hpp | 51 endpoint_(endpoint), in win_iocp_socket_recvfrom_op()
95 o->endpoint_.resize(o->endpoint_size_); in do_complete()
119 Endpoint& endpoint_; member in boost::asio::detail::win_iocp_socket_recvfrom_op
|
| /third_party/boost/libs/asio/example/cpp03/multicast/ |
| D | sender.cpp | 25 : endpoint_(multicast_address, multicast_port), in sender()
26 socket_(io_context, endpoint_.protocol()), in sender()
35 boost::asio::buffer(message_), endpoint_, in sender()
60 boost::asio::buffer(message_), endpoint_, in handle_timeout()
67 boost::asio::ip::udp::endpoint endpoint_; member in sender
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/multicast/ |
| D | sender.cpp | 25 : endpoint_(multicast_address, multicast_port), in sender()
26 socket_(io_context, endpoint_.protocol()), in sender()
35 boost::asio::buffer(message_), endpoint_, in sender()
60 boost::asio::buffer(message_), endpoint_, in handle_timeout()
67 boost::asio::ip::udp::endpoint endpoint_; member in sender
|
| /third_party/boost/boost/asio/ip/ |
| D | basic_resolver_entry.hpp | 55 : endpoint_(ep), in basic_resolver_entry()
64 return endpoint_; in endpoint()
70 return endpoint_; in operator endpoint_type()
104 endpoint_type endpoint_; member in boost::asio::ip::basic_resolver_entry
|
| /third_party/boost/libs/asio/include/boost/asio/ip/ |
| D | basic_resolver_entry.hpp | 55 : endpoint_(ep), in basic_resolver_entry()
64 return endpoint_; in endpoint()
70 return endpoint_; in operator endpoint_type()
104 endpoint_type endpoint_; member in boost::asio::ip::basic_resolver_entry
|
| /third_party/grpc/src/core/lib/security/authorization/ |
| D | evaluate_args.cc | 76 absl::string_view addr = grpc_endpoint_get_local_address(endpoint_); in GetLocalAddress()
87 if (endpoint_ == nullptr) { in GetLocalPort()
91 URI::Parse(grpc_endpoint_get_local_address(endpoint_)); in GetLocalPort()
100 absl::string_view addr = grpc_endpoint_get_peer(endpoint_); in GetPeerAddress()
111 if (endpoint_ == nullptr) { in GetPeerPort()
114 absl::StatusOr<URI> uri = URI::Parse(grpc_endpoint_get_peer(endpoint_)); in GetPeerPort()
|
| D | evaluate_args.h | 36 : metadata_(metadata), auth_context_(auth_context), endpoint_(endpoint) {} in EvaluateArgs()
54 grpc_endpoint* endpoint_; variable
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/multicast/ |
| D | sender.cpp | 24 : endpoint_(multicast_address, multicast_port), in sender()
25 socket_(io_context, endpoint_.protocol()), in sender()
40 boost::asio::buffer(message_), endpoint_, in do_send()
60 boost::asio::ip::udp::endpoint endpoint_; member in sender
|
| /third_party/boost/libs/asio/example/cpp11/multicast/ |
| D | sender.cpp | 24 : endpoint_(multicast_address, multicast_port), in sender()
25 socket_(io_context, endpoint_.protocol()), in sender()
40 boost::asio::buffer(message_), endpoint_, in do_send()
60 boost::asio::ip::udp::endpoint endpoint_; member in sender
|
| /third_party/grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 114 grpc_tcp_client_connect(state.closure(), &endpoint_, pollset_set, in Connect()
122 grpc_endpoint_add_to_pollset(endpoint_, pollset_); in Connect()
138 grpc_endpoint_read(endpoint_, &read_buffer, state.closure(), in ReadUntilError()
148 grpc_endpoint_shutdown(endpoint_, in ReadUntilError()
156 grpc_endpoint_destroy(endpoint_); in Shutdown()
217 grpc_endpoint* endpoint_; member in grpc_core::test::__anon50662e6e0111::Client
|
| /third_party/grpc/src/core/ext/xds/ |
| D | google_mesh_ca_certificate_provider_factory.h | 51 const std::string& endpoint() const { return endpoint_; } in endpoint()
80 std::string endpoint_; variable
|
| D | google_mesh_ca_certificate_provider_factory.cc | 113 if (!ParseJsonObjectField(google_grpc, "target_uri", &endpoint_, in ParseJsonObjectGoogleGrpc()
115 endpoint_ = "meshca.googleapis.com"; // Default target in ParseJsonObjectGoogleGrpc()
|