Home
last modified time | relevance | path

Searched refs:endpoint_ (Results 1 – 25 of 55) sorted by relevance

123

/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/client/
Dchttp2_connector.cc48 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 …]
/external/perfetto/src/traced/probes/
Dprobes_producer.cc145 endpoint_->CreateTraceWriter(buffer_id))); in CreateDSInstance()
165 endpoint_->CreateTraceWriter(buffer_id))); in CreateDSInstance()
175 task_runner_, session_id, endpoint_->CreateTraceWriter(buffer_id), config, in CreateDSInstance()
186 task_runner_, session_id, endpoint_->CreateTraceWriter(buffer_id), in CreateDSInstance()
198 endpoint_->CreateTraceWriter(buffer_id))); in CreateDSInstance()
209 endpoint_->CreateTraceWriter(buffer_id))); in CreateDSInstance()
220 endpoint_->CreateTraceWriter(buffer_id))); in CreateDSInstance()
230 config, session_id, endpoint_->CreateTraceWriter(buffer_id))); in CreateDSInstance()
241 config, session_id, endpoint_->CreateTraceWriter(buffer_id))); in CreateDSInstance()
251 task_runner_, session_id, endpoint_->CreateTraceWriter(buffer_id), config, in CreateDSInstance()
[all …]
/external/perfetto/test/
Dfake_producer.cc55 endpoint_ = ProducerIPCClient::Connect( in Connect()
70 endpoint_->RegisterDataSource(descriptor); in OnConnect()
73 endpoint_->Sync([task_runner, on_connect_callback] { in OnConnect()
93 endpoint_->MaybeSharedMemoryArbiter()->BindStartupTargetBuffer( in StartDataSource()
98 trace_writer_ = endpoint_->CreateTraceWriter( in StartDataSource()
141 task_runner_->PostTask([this, desc] { endpoint_->RegisterDataSource(desc); }); in RegisterDataSource()
147 [this, req, callback] { endpoint_->CommitData(req, callback); }); in CommitData()
151 task_runner_->PostTask([this, callback] { endpoint_->Sync(callback); }); in Sync()
156 [this, trigger_name] { endpoint_->ActivateTriggers({trigger_name}); }); in ActivateTrigger()
167 endpoint_->NotifyFlushComplete(flush_request_id); in Flush()
[all …]
Dtest_helper.cc137 endpoint_ = ConsumerIPCClient::Connect(consumer_socket_, this, task_runner_); in ConnectConsumer()
142 endpoint_->Detach(key); in DetachConsumer()
144 endpoint_.reset(); in DetachConsumer()
154 endpoint_->Attach(key); in AttachConsumer()
181 endpoint_->EnableTracing(config, std::move(file)); in StartTracing()
185 endpoint_->DisableTracing(); in DisableTracing()
192 endpoint_->Flush(timeout_ms, [checkpoint](bool) { checkpoint(); }); in FlushAndWait()
199 endpoint_->ReadBuffers(); in ReadData()
203 endpoint_->FreeBuffers(); in FreeBuffers()
269 endpoint_->QueryServiceState(callback); in QueryServiceStateAndWait()
Dend_to_end_shared_memory_fuzzer.cc65 endpoint_ = ProducerIPCClient::Connect( in Connect()
72 endpoint_->RegisterDataSource(descriptor); in OnConnect()
82 auto trace_writer = endpoint_->CreateTraceWriter( in StartDataSource()
106 std::unique_ptr<TracingService::ProducerEndpoint> endpoint_; member in perfetto::shm_fuzz::__anon289026f30111::FakeProducer
Dfake_producer.h70 return endpoint_->IsShmemProvidedByProducer(); in IsShmemProvidedByProducer()
103 std::unique_ptr<TracingService::ProducerEndpoint> endpoint_; variable
/external/perfetto/src/traced/service/
Dbuiltin_producer.cc82 endpoint_ = svc->ConnectProducer( in ConnectInProcess()
93 endpoint_->RegisterDataSource(metatrace_dsd); in OnConnect()
97 endpoint_->RegisterDataSource(lazy_heapprofd_dsd); in OnConnect()
102 endpoint_->RegisterDataSource(lazy_java_hprof_dsd); in OnConnect()
107 endpoint_->RegisterDataSource(lazy_traced_perf_dsd); in OnConnect()
112 endpoint_->RegisterDataSource(java_hprof_oome_dsd); in OnConnect()
146 auto writer = endpoint_->CreateTraceWriter( in StartDataSource()
165 endpoint_->NotifyDataSourceStopped(ds_id); in StopDataSource()
214 endpoint_->NotifyFlushComplete(flush_id); in Flush()
/external/parameter-framework/asio-1.10.6/include/asio/detail/
Dresolve_endpoint_op.hpp45 endpoint_(endpoint), in resolve_endpoint_op()
67 socket_ops::background_getnameinfo(o->cancel_token_, o->endpoint_.data(), in do_complete()
68 o->endpoint_.size(), host_name, NI_MAXHOST, service_name, NI_MAXSERV, in do_complete()
69 o->endpoint_.protocol().type(), o->ec_); in do_complete()
70 o->iter_ = iterator_type::create(o->endpoint_, host_name, service_name); in do_complete()
106 endpoint_type endpoint_; member in asio::detail::resolve_endpoint_op
/external/openscreen/platform/impl/
Dsocket_address_posix.cc28 : endpoint_(endpoint) { in SocketAddressPosix()
80 RecomputeEndpoint(endpoint_.address.version()); in RecomputeEndpoint()
86 endpoint_.address = IPAddress(IPAddress::Version::kV4, in RecomputeEndpoint()
89 endpoint_.port = ntohs(internal_address_.v4.sin_port); in RecomputeEndpoint()
92 endpoint_.address = IPAddress(IPAddress::Version::kV6, in RecomputeEndpoint()
94 endpoint_.port = ntohs(internal_address_.v6.sin6_port); in RecomputeEndpoint()
Dsocket_address_posix.h34 IPAddress::Version version() const { return endpoint_.address.version(); } in version()
35 IPEndpoint endpoint() const { return endpoint_; } in endpoint()
55 IPEndpoint endpoint_; variable
/external/webrtc/test/scenario/
Dnetwork_node.cc88 if (!endpoint_) in SendRtp()
91 endpoint_->SendPacket(local_address_, remote_address_, buffer, in SendRtp()
99 if (!endpoint_) in SendRtcp()
101 endpoint_->SendPacket(local_address_, remote_address_, buffer, in SendRtcp()
123 endpoint_ = endpoint; in Connect()
124 local_address_ = rtc::SocketAddress(endpoint_->GetPeerLocalAddress(), 0); in Connect()
140 endpoint_ = nullptr; in Disconnect()
/external/parameter-framework/asio-1.10.6/include/asio/ip/
Dbasic_resolver_entry.hpp50 : endpoint_(ep), in basic_resolver_entry()
59 return endpoint_; in endpoint()
65 return endpoint_; in operator endpoint_type()
81 endpoint_type endpoint_; member in asio::ip::basic_resolver_entry
/external/pigweed/pw_rpc/
Dcall.cc81 : endpoint_(&endpoint_ref), in Call()
139 endpoint_ = other.endpoint_; in MoveFrom()
198 endpoint_->CleanUpCall(*this); in CleanUpIfRequired()
209 Channel* channel = endpoint_->GetInternalChannel(channel_id_); in SendPacket()
235 endpoint_->CloseCallAndMarkForCleanup(*this, error); in CloseAndMarkForCleanup()
284 endpoint_->CleanUpCalls(); in HandlePayload()
/external/openscreen/discovery/mdns/
Dmdns_probe_manager_unittest.cc195 const IPEndpoint endpoint_{{192, 168, 0, 0}, 80}; member in openscreen::discovery::MdnsProbeManagerTests
236 manager_.RespondToProbeQuery(query, endpoint_); in TEST_F()
243 EXPECT_CALL(sender_, SendMessage(_, endpoint_)) in TEST_F()
251 manager_.RespondToProbeQuery(query, endpoint_); in TEST_F()
261 manager_.RespondToProbeQuery(query, endpoint_); in TEST_F()
266 manager_.RespondToProbeQuery(query, endpoint_); in TEST_F()
272 manager_.RespondToProbeQuery(query, endpoint_); in TEST_F()
287 manager_.RespondToProbeQuery(query, endpoint_); in TEST_F()
291 manager_.RespondToProbeQuery(query, endpoint_); in TEST_F()
296 manager_.RespondToProbeQuery(query, endpoint_); in TEST_F()
[all …]
Dmdns_responder_unittest.cc190 OnMessageReceived(message, endpoint_); in QueryForRecordTypeWhenNonePresent()
224 IPEndpoint endpoint_{IPAddress(192, 168, 0, 0), 80}; member in openscreen::discovery::MdnsResponderTest
237 OnMessageReceived(message, endpoint_); in TEST_F()
254 OnMessageReceived(message, endpoint_); in TEST_F()
276 OnMessageReceived(message, endpoint_); in TEST_F()
296 EXPECT_CALL(sender_, SendMessage(_, endpoint_)).Times(1); in TEST_F()
297 OnMessageReceived(message, endpoint_); in TEST_F()
308 OnMessageReceived(message, endpoint_); in TEST_F()
338 OnMessageReceived(message, endpoint_); in TEST_F()
376 OnMessageReceived(message, endpoint_); in TEST_F()
[all …]
/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/simulator/
Dquic_endpoint_base.cc119 : endpoint_(endpoint), is_blocked_(false) {} in Writer()
132 if (endpoint_->nic_tx_queue_.packets_queued() > kTxQueueSize) { in WritePacket()
134 endpoint_->write_blocked_count_++; in WritePacket()
139 packet->source = endpoint_->name(); in WritePacket()
140 packet->destination = endpoint_->peer_name_; in WritePacket()
141 packet->tx_timestamp = endpoint_->clock_->Now(); in WritePacket()
146 endpoint_->nic_tx_queue_.AcceptPacket(std::move(packet)); in WritePacket()
/external/webrtc/test/network/
Dtraffic_route.cc49 : clock_(clock), receiver_(receiver), endpoint_(endpoint) { in CrossTrafficRouteImpl()
52 endpoint_->BindReceiver(0, null_receiver_.get()); in CrossTrafficRouteImpl()
71 endpoint_->BindOneShotReceiver(0, action_receiver.get()); in NetworkDelayedAction()
86 rtc::SocketAddress(endpoint_->GetPeerLocalAddress(), dest_port), data, in SendPacket()
Dfake_network_socket_server.cc71 EmulatedEndpointImpl* endpoint_ RTC_GUARDED_BY(&thread_);
101 if (!endpoint_->Enabled()) in OnPacketReceived()
132 endpoint_ = socket_server_->GetEndpointNode(local_addr_.ipaddr()); in Bind()
133 if (!endpoint_) { in Bind()
140 endpoint_->BindReceiver(local_addr_.port(), this); in Bind()
174 if (!endpoint_->Enabled()) { in SendTo()
179 endpoint_->SendPacket(local_addr_, addr, packet); in SendTo()
234 endpoint_->UnbindReceiver(local_addr_.port()); in Close()
Demulated_turn_server.cc34 endpoint_(endpoint), in AsyncPacketSocketWrapper()
36 rtc::SocketAddress(endpoint_->GetPeerLocalAddress(), port)) {} in AsyncPacketSocketWrapper()
55 endpoint_->SendPacket(local_address_, addr, buf); in SendTo()
70 webrtc::EmulatedEndpoint* const endpoint_; member in __anona4d7e7d70111::AsyncPacketSocketWrapper
/external/grpc-grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc112 grpc_tcp_client_connect(state.closure(), &endpoint_, pollset_set, in Connect()
120 grpc_endpoint_add_to_pollset(endpoint_, pollset_); in Connect()
136 grpc_endpoint_read(endpoint_, &read_buffer, state.closure()); in ReadUntilError()
145 grpc_endpoint_shutdown(endpoint_, in ReadUntilError()
153 grpc_endpoint_destroy(endpoint_); in Shutdown()
212 grpc_endpoint* endpoint_; member in grpc_core::test::__anonb67388db0111::Client
/external/libchrome/mojo/core/
Dconnection_params.h28 const PlatformChannelEndpoint& endpoint() const { return endpoint_; } in endpoint()
33 PlatformChannelEndpoint TakeEndpoint() { return std::move(endpoint_); } in TakeEndpoint()
40 PlatformChannelEndpoint endpoint_;
Dmessage_pipe_dispatcher.cc93 endpoint_(endpoint), in MessagePipeDispatcher()
133 DVLOG(2) << "Closing message pipe " << pipe_id_ << " endpoint " << endpoint_ in Close()
145 DVLOG(4) << "Sent message on pipe " << pipe_id_ << " endpoint " << endpoint_ in WriteMessage()
281 state->endpoint = static_cast<int8_t>(endpoint_); in EndSerialize()
412 << " endpoint " << endpoint_ << " [port=" << port_.name() in OnPortStatusChanged()
417 << " endpoint " << endpoint_ << " [port=" << port_.name() << "]"; in OnPortStatusChanged()
/external/webrtc/test/peer_scenario/
Dscenario_connection.cc38 EmulatedEndpoint* endpoint() override { return endpoint_; } in endpoint()
56 EmulatedEndpoint* const endpoint_; member in webrtc::ScenarioIceConnectionImpl
85 endpoint_(net->CreateEndpoint(EmulatedEndpointConfig())), in ScenarioIceConnectionImpl()
86 manager_(net->CreateEmulatedNetworkManagerInterface({endpoint_})), in ScenarioIceConnectionImpl()
/external/perfetto/src/profiling/memory/
Djava_hprof_producer.cc167 endpoint_->NotifyFlushComplete(flush_id); in Flush()
178 endpoint_->RegisterDataSource(desc); in OnConnect()
209 endpoint_ = std::move(endpoint); in SetProducerEndpoint()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/xds/
Dgoogle_mesh_ca_certificate_provider_factory.h51 const std::string& endpoint() const { return endpoint_; } in endpoint()
81 std::string endpoint_; variable

123