| /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/adhd/cras/src/server/ |
| D | cras_bt_endpoint.c | 43 static void cras_bt_endpoint_suspend(struct cras_bt_endpoint *endpoint) in cras_bt_endpoint_suspend() argument
47 if (!endpoint->transport) in cras_bt_endpoint_suspend()
50 endpoint->suspend(endpoint, endpoint->transport); in cras_bt_endpoint_suspend()
52 transport = endpoint->transport; in cras_bt_endpoint_suspend()
54 endpoint->transport = NULL; in cras_bt_endpoint_suspend()
71 struct cras_bt_endpoint *endpoint; in cras_bt_endpoint_set_configuration() local
79 endpoint = cras_bt_endpoint_get(endpoint_path); in cras_bt_endpoint_set_configuration()
80 if (!endpoint) in cras_bt_endpoint_set_configuration()
115 cras_bt_transport_set_endpoint(transport, endpoint); in cras_bt_endpoint_set_configuration()
116 endpoint->transport = transport; in cras_bt_endpoint_set_configuration()
[all …]
|
| D | cras_bt_endpoint.h | 21 int (*get_capabilities)(struct cras_bt_endpoint *endpoint,
23 int (*select_configuration)(struct cras_bt_endpoint *endpoint,
27 void (*set_configuration)(struct cras_bt_endpoint *endpoint,
29 void (*suspend)(struct cras_bt_endpoint *endpoint,
32 void (*transport_state_changed)(struct cras_bt_endpoint *endpoint,
41 struct cras_bt_endpoint *endpoint);
45 struct cras_bt_endpoint *endpoint);
51 struct cras_bt_endpoint *endpoint);
53 struct cras_bt_endpoint *endpoint);
|
| /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 | 36 final @Nullable C endpoint; field in Cut
38 Cut(@Nullable C endpoint) { in Cut() argument
39 this.endpoint = endpoint; in Cut()
77 int result = Range.compareOrThrow(endpoint, that.endpoint); in compareTo()
85 C endpoint() { in endpoint() method in Cut
86 return endpoint; in endpoint()
127 Comparable<?> endpoint() { in endpoint() method in Cut.BelowAll
226 Comparable<?> endpoint() { in endpoint() method in Cut.AboveAll
299 static <C extends Comparable> Cut<C> belowValue(C endpoint) { in belowValue() argument
300 return new BelowValue<C>(endpoint); in belowValue()
[all …]
|
| /external/guava/android/guava/src/com/google/common/collect/ |
| D | Cut.java | 36 @NullableDecl final C endpoint; field in Cut
38 Cut(@NullableDecl C endpoint) { in Cut() argument
39 this.endpoint = endpoint; in Cut()
77 int result = Range.compareOrThrow(endpoint, that.endpoint); in compareTo()
85 C endpoint() { in endpoint() method in Cut
86 return endpoint; in endpoint()
127 Comparable<?> endpoint() { in endpoint() method in Cut.BelowAll
226 Comparable<?> endpoint() { in endpoint() method in Cut.AboveAll
299 static <C extends Comparable> Cut<C> belowValue(C endpoint) { in belowValue() argument
300 return new BelowValue<C>(endpoint); in belowValue()
[all …]
|
| /external/openscreen/cast/sender/channel/ |
| D | sender_socket_factory.cc | 45 void SenderSocketFactory::Connect(const IPEndpoint& endpoint, in Connect() argument
50 auto it = FindPendingConnection(endpoint); in Connect()
53 PendingConnection{endpoint, media_policy, client}); in Connect()
54 factory_->Connect(endpoint, TlsConnectOptions{true}); in Connect()
70 const IPEndpoint& endpoint = connection->GetRemoteEndpoint(); in OnConnected() local
71 auto it = FindPendingConnection(endpoint); in OnConnected()
74 << endpoint; in OnConnected()
84 client_->OnError(this, endpoint, peer_cert.error()); in OnConnected()
91 new PendingAuth{endpoint, media_policy, std::move(socket), client, in OnConnected()
101 client_->OnError(this, endpoint, error); in OnConnected()
[all …]
|
| /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/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/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/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/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()
|
| /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/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/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/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/opencensus-java/exporters/stats/signalfx/src/main/java/io/opencensus/exporter/stats/signalfx/ |
| D | SignalFxMetricsSenderFactory.java | 19 import com.signalfx.endpoint.SignalFxEndpoint;
40 AggregateMetricSender create(URI endpoint, String token, OnSendErrorHandler errorHandler); in create() argument
48 URI endpoint, String token, OnSendErrorHandler errorHandler) {
50 new SignalFxEndpoint(endpoint.getScheme(), endpoint.getHost(), endpoint.getPort());
|
| /external/parameter-framework/asio-1.10.6/include/asio/ip/ |
| D | basic_resolver_query.hpp | 65 typename InternetProtocol::endpoint endpoint; in basic_resolver_query() local
68 hints_.ai_socktype = endpoint.protocol().type(); in basic_resolver_query()
69 hints_.ai_protocol = endpoint.protocol().protocol(); in basic_resolver_query()
150 typename InternetProtocol::endpoint endpoint; in basic_resolver_query() local
153 hints_.ai_socktype = endpoint.protocol().type(); in basic_resolver_query()
154 hints_.ai_protocol = endpoint.protocol().protocol(); in basic_resolver_query()
|