| /external/libchrome/mojo/public/js/lib/ |
| D | router.js | 86 var endpoint = new InterfaceEndpoint(this, id);
87 this.endpoints_.set(id, endpoint);
89 this.updateEndpointStateMayRemove(endpoint,
92 endpoint.handleCreated = true;
97 this.updateEndpointStateMayRemove(endpoint,
112 var endpoint = this.endpoints_.get(interfaceEndpointHandle.id());
113 check(endpoint);
114 check(!endpoint.client);
115 check(!endpoint.closed);
116 endpoint.client = interfaceEndpointClient;
[all …]
|
| /external/libchrome/ipc/ |
| D | ipc_mojo_bootstrap.cc | 216 Endpoint* endpoint = new Endpoint(this, id); in AssociateInterface() local
218 endpoint->set_peer_closed(); in AssociateInterface()
219 endpoint->set_handle_created(); in AssociateInterface()
220 endpoints_.insert({id, endpoint}); in AssociateInterface()
228 Endpoint* endpoint = FindEndpoint(id); in AssociateInterface() local
229 if (endpoint) in AssociateInterface()
230 MarkClosedAndMaybeRemove(endpoint); in AssociateInterface()
255 Endpoint* endpoint = FindOrInsertEndpoint(id, &inserted); in CreateLocalEndpointHandle() local
257 DCHECK(!endpoint->handle_created()); in CreateLocalEndpointHandle()
259 endpoint->set_peer_closed(); in CreateLocalEndpointHandle()
[all …]
|
| /external/mesa3d/src/mesa/main/ |
| D | texcompress_bptc_tmp.h | 53 int8_t endpoint; member
361 int endpoint; in extract_unorm_endpoints() local
368 for (endpoint = 0; endpoint < 2; endpoint++) { in extract_unorm_endpoints()
369 endpoints[subset * 2 + endpoint][component] = in extract_unorm_endpoints()
379 for (endpoint = 0; endpoint < 2; endpoint++) { in extract_unorm_endpoints()
380 endpoints[subset * 2 + endpoint][3] = in extract_unorm_endpoints()
389 for (endpoint = 0; endpoint < 2; endpoint++) in extract_unorm_endpoints()
390 endpoints[subset * 2 + endpoint][3] = 255; in extract_unorm_endpoints()
398 for (endpoint = 0; endpoint < 2; endpoint++) { in extract_unorm_endpoints()
403 endpoints[subset * 2 + endpoint][component] <<= 1; in extract_unorm_endpoints()
[all …]
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | multiplex_router.cc | 290 InterfaceEndpoint* endpoint) { in CreateNotifyErrorTask()
292 task->endpoint_to_notify = endpoint; in CreateNotifyErrorTask()
390 InterfaceEndpoint* endpoint = new InterfaceEndpoint(this, id); in AssociateInterface() local
391 endpoints_[id] = endpoint; in AssociateInterface()
393 UpdateEndpointStateMayRemove(endpoint, PEER_ENDPOINT_CLOSED); in AssociateInterface()
394 endpoint->set_handle_created(); in AssociateInterface()
402 InterfaceEndpoint* endpoint = FindEndpoint(id); in AssociateInterface() local
403 if (endpoint) in AssociateInterface()
404 UpdateEndpointStateMayRemove(endpoint, ENDPOINT_CLOSED); in AssociateInterface()
420 InterfaceEndpoint* endpoint = FindOrInsertEndpoint(id, &inserted); in CreateLocalEndpointHandle() local
[all …]
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | Cut.java | 37 final C endpoint; field in Cut
39 Cut(C endpoint) { in Cut() argument
40 this.endpoint = endpoint; in Cut()
80 int result = Range.compareOrThrow(endpoint, that.endpoint); in compareTo()
88 C endpoint() { in endpoint() method in Cut
89 return endpoint; in endpoint()
137 Comparable<?> endpoint() { in endpoint() method in Cut.BelowAll
237 Comparable<?> endpoint() { in endpoint() method in Cut.AboveAll
310 static <C extends Comparable> Cut<C> belowValue(C endpoint) { in belowValue() argument
311 return new BelowValue<C>(endpoint); in belowValue()
[all …]
|
| /external/guava/android/guava/src/com/google/common/collect/ |
| D | Cut.java | 37 final C endpoint; field in Cut
39 Cut(C endpoint) { in Cut() argument
40 this.endpoint = endpoint; in Cut()
80 int result = Range.compareOrThrow(endpoint, that.endpoint); in compareTo()
88 C endpoint() { in endpoint() method in Cut
89 return endpoint; in endpoint()
137 Comparable<?> endpoint() { in endpoint() method in Cut.BelowAll
237 Comparable<?> endpoint() { in endpoint() method in Cut.AboveAll
310 static <C extends Comparable> Cut<C> belowValue(C endpoint) { in belowValue() argument
311 return new BelowValue<C>(endpoint); in belowValue()
[all …]
|
| /external/openscreen/cast/sender/channel/ |
| D | sender_socket_factory.cc | 47 void SenderSocketFactory::Connect(const IPEndpoint& endpoint, in Connect() argument
52 auto it = FindPendingConnection(endpoint); in Connect()
55 PendingConnection{endpoint, media_policy, client}); in Connect()
56 factory_->Connect(endpoint, TlsConnectOptions{true}); in Connect()
72 const IPEndpoint& endpoint = connection->GetRemoteEndpoint(); in OnConnected() local
73 auto it = FindPendingConnection(endpoint); in OnConnected()
76 << endpoint; in OnConnected()
86 client_->OnError(this, endpoint, peer_cert.error()); in OnConnected()
93 new PendingAuth{endpoint, media_policy, std::move(socket), client, in OnConnected()
103 client_->OnError(this, endpoint, error); in OnConnected()
[all …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/ip/detail/ |
| D | endpoint.hpp | 29 class endpoint class
33 ASIO_DECL endpoint();
36 ASIO_DECL endpoint(int family, unsigned short port_num);
39 ASIO_DECL endpoint(const asio::ip::address& addr,
43 endpoint(const endpoint& other) in endpoint() function in asio::ip::detail::endpoint
49 endpoint& operator=(const endpoint& other) in operator =()
99 const endpoint& e1, const endpoint& e2);
103 const endpoint& e1, const endpoint& e2);
|
| /external/parameter-framework/asio-1.10.6/include/asio/local/detail/ |
| D | endpoint.hpp | 30 class endpoint class
34 ASIO_DECL endpoint();
37 ASIO_DECL endpoint(const char* path_name);
40 ASIO_DECL endpoint(const std::string& path_name);
43 endpoint(const endpoint& other) in endpoint() function in asio::local::detail::endpoint
50 endpoint& operator=(const endpoint& other) in operator =()
96 const endpoint& e1, const endpoint& e2);
100 const endpoint& e1, const endpoint& e2);
|
| /external/autotest/client/cros/chameleon/ |
| D | audio_board.py | 134 def _connect_endpoint(self, endpoint): argument
141 endpoint)
142 self._chameleond_proxy.AudioBoardConnect(self.bus_index, endpoint)
143 self._connected_endpoints.add(endpoint)
145 def _disconnect_endpoint(self, endpoint): argument
152 self.bus_index, endpoint)
153 self._chameleond_proxy.AudioBoardDisconnect(self.bus_index, endpoint)
154 self._connected_endpoints.remove(endpoint)
163 endpoint = self._get_endpoint_name(port_id)
164 self._connect_endpoint(endpoint)
[all …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/generic/detail/ |
| D | endpoint.hpp | 27 class endpoint class
31 ASIO_DECL endpoint();
34 ASIO_DECL endpoint(const void* sock_addr,
38 endpoint(const endpoint& other) in endpoint() function in asio::generic::detail::endpoint
46 endpoint& operator=(const endpoint& other) in operator =()
95 const endpoint& e1, const endpoint& e2);
99 const endpoint& e1, const endpoint& e2);
|
| /external/parameter-framework/asio-1.10.6/include/asio/local/detail/impl/ |
| D | endpoint.ipp | 2 // local/detail/impl/endpoint.hpp
23 #include "asio/local/detail/endpoint.hpp"
31 endpoint::endpoint()
36 endpoint::endpoint(const char* path_name)
42 endpoint::endpoint(const std::string& path_name)
47 void endpoint::resize(std::size_t new_size)
69 std::string endpoint::path() const
74 void endpoint::path(const char* p)
80 void endpoint::path(const std::string& p)
85 bool operator==(const endpoint& e1, const endpoint& e2)
[all …]
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/client/ |
| D | chttp2_connector.cc | 54 grpc_endpoint* endpoint; // Non-NULL until handshaking starts. member
72 if (c->endpoint != nullptr) grpc_endpoint_destroy(c->endpoint); in chttp2_connector_unref()
86 if (!c->connecting && c->endpoint != nullptr) { in chttp2_connector_shutdown()
87 grpc_endpoint_shutdown(c->endpoint, GRPC_ERROR_REF(why)); in chttp2_connector_shutdown()
106 grpc_endpoint_shutdown(args->endpoint, GRPC_ERROR_REF(error)); in on_handshake_done()
107 grpc_endpoint_destroy(args->endpoint); in on_handshake_done()
116 grpc_endpoint_delete_from_pollset_set(args->endpoint, in on_handshake_done()
119 grpc_create_chttp2_transport(args->args, args->endpoint, true); in on_handshake_done()
162 grpc_endpoint_add_to_pollset_set(c->endpoint, c->args.interested_parties); in start_handshake_locked()
164 c->handshake_mgr, c->args.interested_parties, c->endpoint, in start_handshake_locked()
[all …]
|
| /external/webrtc/test/network/ |
| D | emulated_network_manager.cc | 34 void EmulatedNetworkManager::EnableEndpoint(EmulatedEndpointImpl* endpoint) { in EnableEndpoint() argument
35 RTC_CHECK(endpoints_container_->HasEndpoint(endpoint)) in EnableEndpoint()
36 << "No such interface: " << endpoint->GetPeerLocalAddress().ToString(); in EnableEndpoint()
37 network_thread_->PostTask(RTC_FROM_HERE, [this, endpoint]() { in EnableEndpoint()
38 endpoint->Enable(); in EnableEndpoint()
43 void EmulatedNetworkManager::DisableEndpoint(EmulatedEndpointImpl* endpoint) { in DisableEndpoint() argument
44 RTC_CHECK(endpoints_container_->HasEndpoint(endpoint)) in DisableEndpoint()
45 << "No such interface: " << endpoint->GetPeerLocalAddress().ToString(); in DisableEndpoint()
46 network_thread_->PostTask(RTC_FROM_HERE, [this, endpoint]() { in DisableEndpoint()
47 endpoint->Disable(); in DisableEndpoint()
|
| D | network_emulation_manager.cc | 108 void NetworkEmulationManagerImpl::EnableEndpoint(EmulatedEndpoint* endpoint) { in EnableEndpoint() argument
110 endpoint_to_network_manager_[endpoint]; in EnableEndpoint()
112 network_manager->EnableEndpoint(static_cast<EmulatedEndpointImpl*>(endpoint)); in EnableEndpoint()
115 void NetworkEmulationManagerImpl::DisableEndpoint(EmulatedEndpoint* endpoint) { in DisableEndpoint() argument
117 endpoint_to_network_manager_[endpoint]; in DisableEndpoint()
120 static_cast<EmulatedEndpointImpl*>(endpoint)); in DisableEndpoint()
174 EmulatedEndpoint* endpoint = CreateEndpoint(EmulatedEndpointConfig()); in CreateTrafficRoute() local
179 cur_node->router()->SetReceiver(endpoint->GetPeerLocalAddress(), in CreateTrafficRoute()
183 cur_node->router()->SetReceiver(endpoint->GetPeerLocalAddress(), endpoint); in CreateTrafficRoute()
186 std::make_unique<TrafficRoute>(clock_, via_nodes[0], endpoint); in CreateTrafficRoute()
[all …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/ip/detail/impl/ |
| D | endpoint.ipp | 2 // ip/detail/impl/endpoint.ipp
20 #include "asio/ip/detail/endpoint.hpp"
28 endpoint::endpoint()
36 endpoint::endpoint(int family, unsigned short port_num)
65 endpoint::endpoint(const asio::ip::address& addr,
95 void endpoint::resize(std::size_t new_size)
104 unsigned short endpoint::port() const
118 void endpoint::port(unsigned short port_num)
132 asio::ip::address endpoint::address() const
149 void endpoint::address(const asio::ip::address& addr)
[all …]
|
| /external/walt/ios/WALT/ |
| D | MIDIEndpoint.m | 20 @property (readwrite, nonatomic, assign) MIDIEndpointRef endpoint;
26 MIDIObjectGetStringProperty(self.endpoint, kMIDIPropertyDisplayName, &result);
32 MIDIObjectGetIntegerProperty(self.endpoint, kMIDIPropertyOffline, &result);
44 MIDIEndpointRef endpoint = MIDIGetDestination(i);
45 if (endpoint) {
47 destination.endpoint = endpoint;
64 MIDIEndpointRef endpoint = MIDIGetSource(i);
65 if (endpoint) {
67 source.endpoint = endpoint;
|
| /external/parameter-framework/asio-1.10.6/include/asio/generic/detail/impl/ |
| D | endpoint.ipp | 2 // generic/detail/impl/endpoint.hpp
23 #include "asio/generic/detail/endpoint.hpp"
31 endpoint::endpoint()
36 endpoint::endpoint(const void* sock_addr,
42 void endpoint::resize(std::size_t new_size)
56 bool operator==(const endpoint& e1, const endpoint& e2)
62 bool operator<(const endpoint& e1, const endpoint& e2)
83 void endpoint::init(const void* sock_addr,
|
| /external/parameter-framework/upstream/remote-processor/ |
| D | RemoteProcessorServer.cpp | 60 generic::stream_protocol::endpoint endpoint; in start() local
105 endpoint = ip::tcp::endpoint(ip::tcp::v6(), port); in start()
107 endpoint = local::stream_protocol::endpoint(endpointName); in start()
110 _acceptor.open(endpoint.protocol()); in start()
112 if (endpoint.protocol().protocol() == ASIO_OS_DEF(IPPROTO_TCP)) { in start()
114 } else if (endpoint.protocol().protocol() == AF_UNSPEC) { in start()
121 _acceptor.bind(endpoint); in start()
146 const auto &endpoint = _socket.local_endpoint(); in acceptRegister() local
147 if (endpoint.protocol().protocol() == ASIO_OS_DEF(IPPROTO_TCP)) { in acceptRegister()
|
| /external/python/bumble/bumble/ |
| D | avdtp.py | 714 self.payload = b''.join([bytes(endpoint) for endpoint in endpoints])
718 for endpoint in self.endpoints:
1210 endpoint = DiscoveredStreamEndPoint(
1218 self.remote_endpoints[endpoint_entry.seid] = endpoint
1223 for endpoint in self.remote_endpoints.values():
1224 … if not endpoint.in_use and endpoint.media_type == media_type and endpoint.tsep == AVDTP_TSEP_SNK:
1227 for capabilities in endpoint.capabilities:
1234 return endpoint
1375 EndPointInfo(endpoint.seid, 0, endpoint.media_type, endpoint.tsep)
1376 for endpoint in self.local_endpoints
[all …]
|
| /external/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-staticpolicy/ |
| D | static-policy.h | 1317 .endpoint = "connectivitycheck.android.com",
1333 .endpoint = "a1ygonr3im5cv2-ats.iot.us-west-2.amazonaws.com",
1351 .endpoint = "a1ygonr3im5cv2-ats.iot.us-west-2.amazonaws.com",
1368 .endpoint = "warmcat.com",
1384 .endpoint = "warmcat.com",
1400 .endpoint = "warmcat.com",
1416 .endpoint = "warmcat.com",
1434 .endpoint = "alexa.na.gateway.devices.a2z.com",
1456 .endpoint = "alexa.na.gateway.devices.a2z.com",
1479 .endpoint = "alexa.na.gateway.devices.a2z.com",
[all …]
|
| /external/openscreen/osp/impl/quic/ |
| D | quic_client.cc | 73 const IPEndpoint& endpoint, in Connect() argument
77 auto endpoint_entry = endpoint_map_.find(endpoint); in Connect()
85 return CreatePendingConnection(endpoint, request); in Connect()
114 const IPEndpoint& endpoint = delegate->endpoint(); in OnCryptoHandshakeComplete() local
115 auto pending_entry = pending_connections_.find(endpoint); in OnCryptoHandshakeComplete()
122 endpoint_map_[endpoint] = endpoint_id; in OnCryptoHandshakeComplete()
177 const IPEndpoint& endpoint, in CreatePendingConnection() argument
179 auto pending_entry = pending_connections_.find(endpoint); in CreatePendingConnection()
181 uint64_t request_id = StartConnectionRequest(endpoint, request); in CreatePendingConnection()
191 const IPEndpoint& endpoint, in StartConnectionRequest() argument
[all …]
|
| /external/openscreen/platform/impl/ |
| D | socket_address_posix.cc | 27 SocketAddressPosix::SocketAddressPosix(const IPEndpoint& endpoint) in SocketAddressPosix() argument
28 : endpoint_(endpoint) { in SocketAddressPosix()
29 if (endpoint.address.IsV4()) { in SocketAddressPosix()
31 internal_address_.v4.sin_port = htons(endpoint.port); in SocketAddressPosix()
32 endpoint.address.CopyToV4( in SocketAddressPosix()
35 OSP_DCHECK(endpoint.address.IsV6()); in SocketAddressPosix()
40 internal_address_.v6.sin6_port = htons(endpoint.port); in SocketAddressPosix()
41 endpoint.address.CopyToV6( in SocketAddressPosix()
|
| /external/perfetto/src/tracing/internal/ |
| D | system_tracing_backend.cc | 41 auto endpoint = ProducerIPCClient::Connect( in ConnectProducer() local
46 PERFETTO_CHECK(endpoint); in ConnectProducer()
47 return endpoint; in ConnectProducer()
52 auto endpoint = ConsumerIPCClient::Connect(GetConsumerSocket(), args.consumer, in ConnectConsumer() local
54 PERFETTO_CHECK(endpoint); in ConnectConsumer()
55 return endpoint; in ConnectConsumer()
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| D | resolver_service.hpp | 39 typedef typename Protocol::endpoint endpoint_type;
87 const endpoint_type& endpoint, asio::error_code& ec) in resolve() argument
91 socket_ops::sync_getnameinfo(endpoint.data(), endpoint.size(), in resolve()
93 endpoint.protocol().type(), ec); in resolve()
96 endpoint, host_name, service_name); in resolve()
102 const endpoint_type& endpoint, Handler& handler) in async_resolve() argument
109 p.p = new (p.v) op(impl, endpoint, io_service_impl_, handler); in async_resolve()
|