| /external/libchrome/ipc/ |
| D | ipc_mojo_bootstrap.cc | 171 Endpoint* sender_endpoint = new Endpoint(this, sender_id); in CreateChannelEndpoints()
172 Endpoint* receiver_endpoint = new Endpoint(this, receiver_id); in CreateChannelEndpoints()
216 Endpoint* endpoint = new Endpoint(this, id); in AssociateInterface()
228 Endpoint* endpoint = FindEndpoint(id); in AssociateInterface()
255 Endpoint* endpoint = FindOrInsertEndpoint(id, &inserted); in CreateLocalEndpointHandle()
277 Endpoint* endpoint = endpoints_[id].get(); in CloseEndpointHandle()
299 Endpoint* endpoint = endpoints_[id].get(); in AttachEndpointClient()
317 Endpoint* endpoint = endpoints_[id].get(); in DetachEndpointClient()
350 class Endpoint;
352 friend class Endpoint;
[all …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| D | reactive_socket_sendto_op.hpp | 28 template <typename ConstBufferSequence, typename Endpoint>
33 const ConstBufferSequence& buffers, const Endpoint& endpoint, in reactive_socket_sendto_op_base()
60 Endpoint destination_;
64 template <typename ConstBufferSequence, typename Endpoint, typename Handler>
66 public reactive_socket_sendto_op_base<ConstBufferSequence, Endpoint>
72 const ConstBufferSequence& buffers, const Endpoint& endpoint, in reactive_socket_sendto_op()
74 : reactive_socket_sendto_op_base<ConstBufferSequence, Endpoint>(socket, in reactive_socket_sendto_op()
|
| D | reactive_socket_recvfrom_op.hpp | 28 template <typename MutableBufferSequence, typename Endpoint>
33 const MutableBufferSequence& buffers, Endpoint& endpoint, in reactive_socket_recvfrom_op_base()
68 Endpoint& sender_endpoint_;
72 template <typename MutableBufferSequence, typename Endpoint, typename Handler>
74 public reactive_socket_recvfrom_op_base<MutableBufferSequence, Endpoint>
80 const MutableBufferSequence& buffers, Endpoint& endpoint, in reactive_socket_recvfrom_op()
82 : reactive_socket_recvfrom_op_base<MutableBufferSequence, Endpoint>( in reactive_socket_recvfrom_op()
|
| /external/llvm-project/llvm/tools/llvm-jitlink/ |
| D | llvm-jitlink.h | 79 std::unique_ptr<LLVMJITLinkRPCEndpoint> Endpoint, in LLVMJITLinkRemoteTargetProcessControl() argument
81 : BaseT(std::move(SSP), *Endpoint, std::move(ReportError)), in LLVMJITLinkRemoteTargetProcessControl()
82 Channel(std::move(Channel)), Endpoint(std::move(Endpoint)) { in LLVMJITLinkRemoteTargetProcessControl()
87 if (auto Err = this->Endpoint->handleOne()) { in LLVMJITLinkRemoteTargetProcessControl()
106 std::unique_ptr<LLVMJITLinkRPCEndpoint> Endpoint; variable
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | memory_types.cc | 30 struct Endpoint { struct
36 uint32 operator()(const Endpoint& x) const { in operator ()()
43 uint32 operator()(const Endpoint& x, const Endpoint& y) const { in operator ()()
59 typedef std::unordered_map<Endpoint, MemoryType, EndpointHash, EndpointEq> in ProcessMemoryTypes()
182 std::unordered_map<Endpoint, Node*, EndpointHash, EndpointEq> recv_nodes; in EnsureMemoryTypes()
187 Endpoint key{e->src()->id(), e->src_output()}; in EnsureMemoryTypes()
|
| D | inline_function_utils.cc | 67 struct Endpoint { struct
84 uint64 operator()(const Endpoint& x) const { in operator ()()
91 bool operator()(const Endpoint& x, const Endpoint& y) const { in operator ()()
108 static Node* AddIdentity(StringPiece name, Graph* g, Endpoint input) { in AddIdentity()
522 const auto input_identity = [&](StringPiece name, Endpoint input, in InlineFunctionBody()
537 const auto output_identity = [&](StringPiece name, Endpoint input, in InlineFunctionBody()
569 std::vector<Endpoint> inputs(caller->num_inputs()); in InlineFunctionBody()
735 Endpoint data; // Data input for the ret node. in InlineFunctionBody()
|
| D | function_utils.cc | 34 struct Endpoint { struct
62 static Node* AddIdentity(StringPiece name, Graph* g, Endpoint input) { in AddIdentity()
184 const auto identity = [&](StringPiece name, Endpoint input) -> Node* { in RemoveListArrayConverter()
|
| /external/rust/crates/vmm_vhost/src/vhost_user/ |
| D | slave_fs_cache.rs | 10 use super::connection::Endpoint;
15 sock: Endpoint<SlaveReq>,
58 Endpoint::<SlaveReq>::close_rfds(rfds); in wait_for_ack()
85 fn new(ep: Endpoint<SlaveReq>) -> Self { in new()
112 Self::new(Endpoint::<SlaveReq>::from_stream(sock)) in from_stream()
187 let mut master = Endpoint::<SlaveReq>::from_stream(p2); in test_slave_fs_cache_recv_negative()
|
| D | connection.rs | 92 pub(super) struct Endpoint<R: Req> { struct
97 impl<R: Req> Endpoint<R> { argument
110 Endpoint { in from_stream()
578 impl<T: Req> AsRawFd for Endpoint<T> { implementation
646 let mut master = Endpoint::<MasterReq>::connect(&path).unwrap(); in send_data()
648 let mut slave = Endpoint::<MasterReq>::from_stream(sock); in send_data()
674 let mut master = Endpoint::<MasterReq>::connect(&path).unwrap(); in send_fd()
676 let mut slave = Endpoint::<MasterReq>::from_stream(sock); in send_fd()
819 Endpoint::<MasterReq>::close_rfds(rfds); in send_fd()
820 Endpoint::<MasterReq>::close_rfds(None); in send_fd()
[all …]
|
| D | slave_req_handler.rs | 10 use super::connection::Endpoint;
226 main_sock: Endpoint<MasterReq>,
243 pub(super) fn new(main_sock: Endpoint<MasterReq>, backend: Arc<S>) -> Self { in new()
262 Ok(Self::new(Endpoint::<MasterReq>::connect(path)?, backend)) in connect()
503 Endpoint::<MasterReq>::close_rfds(rfds); in set_mem_table()
508 Endpoint::<MasterReq>::close_rfds(rfds); in set_mem_table()
512 Endpoint::<MasterReq>::close_rfds(rfds); in set_mem_table()
521 Endpoint::<MasterReq>::close_rfds(Some(fds)); in set_mem_table()
537 Endpoint::<MasterReq>::close_rfds(Some(fds)); in set_mem_table()
654 Endpoint::<MasterReq>::close_rfds(Some(fds)); in handle_vring_fd_request()
[all …]
|
| D | slave.rs | 8 use super::connection::{Endpoint, Listener};
35 Endpoint::<MasterReq>::from_stream(fd), in accept()
|
| D | master.rs | 14 use super::connection::Endpoint;
76 fn new(ep: Endpoint<MasterReq>, max_queue_num: u64) -> Self { in new()
97 Self::new(Endpoint::<MasterReq>::from_stream(sock), max_queue_num) in from_stream()
109 match Endpoint::<MasterReq>::connect(&path) { in connect()
404 Endpoint::<MasterReq>::close_rfds(rfds); in get_config()
534 main_sock: Endpoint<MasterReq>,
634 Endpoint::<MasterReq>::close_rfds(rfds); in recv_reply()
660 Endpoint::<MasterReq>::close_rfds(rfds); in recv_reply_with_payload()
678 Endpoint::<MasterReq>::close_rfds(rfds); in wait_for_ack()
717 fn create_pair<P: AsRef<Path>>(path: P) -> (Master, Endpoint<MasterReq>) { in create_pair()
[all …]
|
| D | master_req_handler.rs | 9 use super::connection::Endpoint;
132 sub_sock: Endpoint<SlaveReq>,
155 sub_sock: Endpoint::<SlaveReq>::from_stream(rx), in new()
301 Endpoint::<SlaveReq>::close_rfds(Some(fds)); in check_attached_rfds()
311 Endpoint::<SlaveReq>::close_rfds(rfds); in check_attached_rfds()
|
| /external/bcc/src/cc/frontends/p4/test/ |
| D | endToEndTest.py | 31 class Endpoint(Base): class
61 assert isinstance(endpoint, Endpoint)
92 assert isinstance(destination, Endpoint)
134 assert isinstance(src, Endpoint)
135 assert isinstance(dest, Endpoint)
201 self.client_endpoint = Endpoint("10.0.0.11", "96:a4:85:fe:2a:11")
206 self.server_endpoint = Endpoint("10.0.0.10", "a2:59:94:cf:51:09")
211 self.sw_clt_endpoint = Endpoint(None, "62:ce:1b:48:3e:61")
212 self.sw_srv_endpoint = Endpoint(None, "62:ce:1b:48:3e:60")
|
| /external/opencensus-java/exporters/trace/zipkin/src/main/java/io/opencensus/exporter/trace/zipkin/ |
| D | ZipkinExporterHandler.java | 48 import zipkin2.Endpoint;
66 private final Endpoint localEndpoint;
75 static Endpoint produceLocalEndpoint(String serviceName) { in produceLocalEndpoint()
76 Endpoint.Builder builder = Endpoint.newBuilder().serviceName(serviceName); in produceLocalEndpoint()
103 static Span generateSpan(SpanData spanData, Endpoint localEndpoint) { in generateSpan()
|
| /external/grpc-grpc/test/core/tsi/alts/fake_handshaker/ |
| D | handshaker.proto | 40 message Endpoint { message
85 Endpoint local_endpoint = 6;
87 // (Optional) Endpoint information of the remote server, such as IP address,
89 Endpoint remote_endpoint = 7;
128 Endpoint local_endpoint = 4;
130 // (Optional) Endpoint information of the remote client, such as IP address,
132 Endpoint remote_endpoint = 5;
|
| /external/grpc-grpc-java/alts/src/main/proto/grpc/gcp/ |
| D | handshaker.proto | 40 message Endpoint { message
85 Endpoint local_endpoint = 6;
87 // (Optional) Endpoint information of the remote server, such as IP address,
89 Endpoint remote_endpoint = 7;
128 Endpoint local_endpoint = 4;
130 // (Optional) Endpoint information of the remote client, such as IP address,
132 Endpoint remote_endpoint = 5;
|
| /external/grpc-grpc/src/core/tsi/alts/handshaker/proto/ |
| D | handshaker.proto | 40 message Endpoint { message
85 Endpoint local_endpoint = 6;
87 // (Optional) Endpoint information of the remote server, such as IP address,
89 Endpoint remote_endpoint = 7;
128 Endpoint local_endpoint = 4;
130 // (Optional) Endpoint information of the remote client, such as IP address,
132 Endpoint remote_endpoint = 5;
|
| /external/rust/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/proto/ |
| D | handshaker.proto | 40 message Endpoint { message
85 Endpoint local_endpoint = 6;
87 // (Optional) Endpoint information of the remote server, such as IP address,
89 Endpoint remote_endpoint = 7;
128 Endpoint local_endpoint = 4;
130 // (Optional) Endpoint information of the remote client, such as IP address,
132 Endpoint remote_endpoint = 5;
|
| /external/grpc-grpc-java/alts/src/generated/main/java/io/grpc/alts/internal/ |
| D | Handshaker.java | 308 public static final class Endpoint extends class in Handshaker
314 private Endpoint(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in Endpoint() method in Handshaker.Endpoint
317 private Endpoint() { in Endpoint() method in Handshaker.Endpoint
328 private Endpoint( in Endpoint() method in Handshaker.Endpoint
392 …io.grpc.alts.internal.Handshaker.Endpoint.class, io.grpc.alts.internal.Handshaker.Endpoint.Builder… in internalGetFieldAccessorTable()
526 if (!(obj instanceof io.grpc.alts.internal.Handshaker.Endpoint)) { in equals()
529 … io.grpc.alts.internal.Handshaker.Endpoint other = (io.grpc.alts.internal.Handshaker.Endpoint) obj; in equals()
559 public static io.grpc.alts.internal.Handshaker.Endpoint parseFrom( in parseFrom()
564 public static io.grpc.alts.internal.Handshaker.Endpoint parseFrom( in parseFrom()
570 public static io.grpc.alts.internal.Handshaker.Endpoint parseFrom( in parseFrom()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/proto/grpc/gcp/ |
| D | handshaker.proto | 47 message Endpoint { message
95 Endpoint local_endpoint = 6;
97 // (Optional) Endpoint information of the remote server, such as IP address,
99 Endpoint remote_endpoint = 7;
141 Endpoint local_endpoint = 4;
143 // (Optional) Endpoint information of the remote client, such as IP address,
145 Endpoint remote_endpoint = 5;
|
| /external/crosvm/usb_util/src/ |
| D | types.rs | 15 Endpoint = 0x05, enumerator
148 DescriptorType::Endpoint in descriptor_type()
241 Endpoint = 2, enumerator
323 2 => ControlRequestRecipient::Endpoint, in get_recipient()
|
| /external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/xds/v3/ |
| D | endpoint.proto | 29 // Endpoint health status.
56 message Endpoint { message
69 // An Endpoint that Envoy can route traffic to.
74 Endpoint endpoint = 1;
118 // [#protodoc-title: Endpoint configuration]
119 // Endpoint discovery :ref:`architecture overview <arch_overview_service_discovery_types_eds>`
|
| /external/parameter-framework/asio-1.10.6/include/asio/generic/ |
| D | basic_endpoint.hpp | 62 template <typename Endpoint>
63 basic_endpoint(const Endpoint& endpoint) in basic_endpoint()
|
| /external/opencensus-java/exporters/trace/zipkin/src/test/java/io/opencensus/exporter/trace/zipkin/ |
| D | ZipkinExporterHandlerTest.java | 46 import zipkin2.Endpoint;
52 private static final Endpoint localEndpoint =
53 Endpoint.newBuilder().serviceName("tweetiebird").build();
|