Home
last modified time | relevance | path

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

12

/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/webrtc/test/network/
Dtraffic_route.cc33 : action_(action), endpoint_(endpoint) {} in ActionReceiver()
39 endpoint_->UnbindReceiver(port_.value()); in OnPacketReceived()
50 EmulatedEndpoint* endpoint_; member in webrtc::test::__anon2607d0170111::ActionReceiver
59 : clock_(clock), receiver_(receiver), endpoint_(endpoint) { in TrafficRoute()
62 endpoint_->BindReceiver(0, null_receiver_.get()); in TrafficRoute()
76 auto action_receiver = std::make_unique<ActionReceiver>(action, endpoint_); in NetworkDelayedAction()
78 endpoint_->BindReceiver(0, action_receiver.get()); in NetworkDelayedAction()
94 rtc::SocketAddress(endpoint_->GetPeerLocalAddress(), dest_port), data, in SendPacket()
Dfake_network_socket_server.cc69 EmulatedEndpointImpl* endpoint_ RTC_GUARDED_BY(&thread_);
95 if (!endpoint_->Enabled()) in OnPacketReceived()
126 endpoint_ = socket_server_->GetEndpointNode(local_addr_.ipaddr()); in Bind()
127 if (!endpoint_) { in Bind()
134 endpoint_->BindReceiver(local_addr_.port(), this); in Bind()
168 if (!endpoint_->Enabled()) { in SendTo()
173 endpoint_->SendPacket(local_addr_, addr, packet); in SendTo()
228 endpoint_->UnbindReceiver(local_addr_.port()); in Close()
/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()
162 endpoint_->NotifyFlushComplete(flush_request_id); in Flush()
168 auto* producer = static_cast<ProducerIPCClientImpl*>(endpoint_.get()); in unix_socket_fd()
Dtest_helper.cc130 endpoint_ = ConsumerIPCClient::Connect(consumer_socket_, this, task_runner_); in ConnectConsumer()
135 endpoint_->Detach(key); in DetachConsumer()
137 endpoint_.reset(); in DetachConsumer()
147 endpoint_->Attach(key); in AttachConsumer()
159 endpoint_->SaveTraceForBugreport(callback); in SaveTraceForBugreportAndWait()
186 endpoint_->EnableTracing(config, std::move(file)); in StartTracing()
190 endpoint_->DisableTracing(); in DisableTracing()
197 endpoint_->Flush(timeout_ms, [checkpoint](bool) { checkpoint(); }); in FlushAndWait()
204 endpoint_->ReadBuffers(); in ReadData()
208 endpoint_->FreeBuffers(); in FreeBuffers()
[all …]
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::__anon983fe3950111::FakeProducer
Dfake_producer.h69 return endpoint_->IsShmemProvidedByProducer(); in IsShmemProvidedByProducer()
102 std::unique_ptr<TracingService::ProducerEndpoint> endpoint_; variable
/external/perfetto/src/traced/probes/
Dprobes_producer.cc123 endpoint_->RegisterDataSource(proto_desc); in OnConnect()
215 endpoint_->NotifyDataSourceStarted(instance_id); in StartDataSource()
247 endpoint_->CreateTraceWriter(buffer_id))); in CreateFtraceDataSource()
265 &cache_, endpoint_->CreateTraceWriter(buffer_id))); in CreateInodeFileDataSource()
273 task_runner_, session_id, endpoint_->CreateTraceWriter(buffer_id), config, in CreateProcessStatsDataSource()
283 endpoint_->CreateTraceWriter(buffer_id))); in CreateAndroidPowerDataSource()
292 endpoint_->CreateTraceWriter(buffer_id))); in CreateAndroidLogDataSource()
300 config, session_id, endpoint_->CreateTraceWriter(buffer_id))); in CreatePackagesListDataSource()
309 endpoint_->CreateTraceWriter(buffer_id), config)); in CreateSysStatsDataSource()
317 task_runner_, session_id, endpoint_->CreateTraceWriter(buffer_id))); in CreateMetatraceDataSource()
[all …]
/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/perfetto/src/traced/service/
Dbuiltin_producer.cc64 endpoint_ = svc->ConnectProducer( in ConnectInProcess()
75 endpoint_->RegisterDataSource(metatrace_dsd); in OnConnect()
79 endpoint_->RegisterDataSource(lazy_heapprofd_dsd); in OnConnect()
84 endpoint_->RegisterDataSource(lazy_java_hprof_dsd); in OnConnect()
89 endpoint_->RegisterDataSource(lazy_traced_perf_dsd); in OnConnect()
116 auto writer = endpoint_->CreateTraceWriter( in StartDataSource()
135 endpoint_->NotifyDataSourceStopped(ds_id); in StopDataSource()
177 endpoint_->NotifyFlushComplete(flush_id); in Flush()
/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/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/webrtc/test/scenario/
Dnetwork_node.cc90 if (!endpoint_) in SendRtp()
93 endpoint_->SendPacket(local_address_, remote_address_, buffer, in SendRtp()
101 if (!endpoint_) in SendRtcp()
103 endpoint_->SendPacket(local_address_, remote_address_, buffer, in SendRtcp()
125 endpoint_ = endpoint; in Connect()
126 local_address_ = rtc::SocketAddress(endpoint_->GetPeerLocalAddress(), 0); in Connect()
142 endpoint_ = nullptr; in Disconnect()
/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/rust/crates/grpcio-sys/grpc/src/core/lib/security/authorization/
Devaluate_args.cc76 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()
Devaluate_args.h36 : metadata_(metadata), auth_context_(auth_context), endpoint_(endpoint) {} in EvaluateArgs()
54 grpc_endpoint* endpoint_; variable
/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/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::__anon93793cbd0111::Client
/external/rust/crates/grpcio-sys/grpc/test/core/security/
Devaluate_args_test.cc35 endpoint_ = CreateEvalArgsMockEndpoint(local_address_.c_str(), local_port_, in SetUp()
38 absl::make_unique<EvaluateArgs>(nullptr, nullptr, endpoint_); in SetUp()
40 void TearDown() override { grpc_endpoint_destroy(endpoint_); } in TearDown()
41 grpc_endpoint* endpoint_; member in grpc_core::EvaluateArgsTest
/external/webrtc/test/peer_scenario/
Dscenario_connection.cc36 EmulatedEndpoint* endpoint() override { return endpoint_; } in endpoint()
54 EmulatedEndpoint* const endpoint_; member in webrtc::ScenarioIceConnectionImpl
83 endpoint_(net->CreateEndpoint(EmulatedEndpointConfig())), in ScenarioIceConnectionImpl()
84 manager_(net->CreateEmulatedNetworkManagerInterface({endpoint_})), in ScenarioIceConnectionImpl()
/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()
80 std::string endpoint_; variable
/external/perfetto/src/profiling/memory/
Djava_hprof_producer.cc161 endpoint_->NotifyFlushComplete(flush_id); in Flush()
172 endpoint_->RegisterDataSource(desc); in OnConnect()
203 endpoint_ = std::move(endpoint); in SetProducerEndpoint()

12