| /external/openthread/src/core/net/ |
| D | tcp6.cpp | 61 static_assert(sizeof(struct tcpcb) == sizeof(Tcp::Endpoint::mTcb), "mTcb field in otTcpEndpoint is …
62 static_assert(alignof(struct tcpcb) == alignof(decltype(Tcp::Endpoint::mTcb)),
64 static_assert(offsetof(Tcp::Endpoint, mTcb) == 0, "mTcb field in otTcpEndpoint has nonzero offset");
81 Error Tcp::Endpoint::Initialize(Instance &aInstance, const otTcpEndpointInitializeArgs &aArgs) in Initialize()
126 Instance &Tcp::Endpoint::GetInstance(void) const in GetInstance()
131 const SockAddr &Tcp::Endpoint::GetLocalAddress(void) const in GetLocalAddress()
143 const SockAddr &Tcp::Endpoint::GetPeerAddress(void) const in GetPeerAddress()
155 Error Tcp::Endpoint::Bind(const SockAddr &aSockName) in Bind()
171 Error Tcp::Endpoint::Connect(const SockAddr &aSockName, uint32_t aFlags) in Connect()
189 Error Tcp::Endpoint::SendByReference(otLinkedBuffer &aBuffer, uint32_t aFlags) in SendByReference()
[all …]
|
| D | tcp6.hpp | 86 …class Endpoint : public otTcpEndpoint, public LinkedListEntry<Endpoint>, public GetProvider<Endpoi… class in ot::Ip6::Tcp
89 friend class LinkedList<Endpoint>;
350 … static Endpoint &FromTcb(struct tcpcb &aTcb) { return *reinterpret_cast<Endpoint *>(&aTcb); } in FromTcb()
652 bool IsInitialized(const Endpoint &aEndpoint) const { return mEndpoints.Contains(aEndpoint); } in IsInitialized()
672 void ProcessSignals(Endpoint & aEndpoint,
689 LinkedList<Endpoint> mEndpoints;
696 DefineCoreType(otTcpEndpoint, Ip6::Tcp::Endpoint);
|
| /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/pigweed/pw_rpc/public/pw_rpc/ |
| D | client.h | 27 class Client : public internal::Endpoint {
37 _PW_RPC_CONSTEXPR Client(span<Channel> channels) : Endpoint(channels) {} in Client()
53 using Endpoint::active_call_count;
54 using Endpoint::ClaimLocked;
55 using Endpoint::CleanUpCalls;
56 using Endpoint::GetInternalChannel;
|
| D | server.h | 34 class Server : public internal::Endpoint {
44 _PW_RPC_CONSTEXPR Server(span<Channel> channels) : Endpoint(channels) {} in Server()
190 using Endpoint::active_call_count;
191 using Endpoint::ClaimLocked;
192 using Endpoint::CleanUpCalls;
193 using Endpoint::GetInternalChannel;
|
| /external/cronet/ipc/ |
| D | ipc_mojo_bootstrap.cc | 231 Endpoint* sender_endpoint = new Endpoint(this, sender_id); in Bind()
232 Endpoint* receiver_endpoint = new Endpoint(this, receiver_id); in Bind()
281 Endpoint* endpoint = new Endpoint(this, id); in AssociateInterface()
293 Endpoint* endpoint = FindEndpoint(id); in AssociateInterface()
320 Endpoint* endpoint = FindOrInsertEndpoint(id, &inserted); in CreateLocalEndpointHandle()
342 Endpoint* endpoint = endpoints_[id].get(); in CloseEndpointHandle()
364 Endpoint* endpoint = endpoints_[id].get(); in AttachEndpointClient()
382 Endpoint* endpoint = endpoints_[id].get(); in DetachEndpointClient()
415 class Endpoint;
417 friend class Endpoint;
[all …]
|
| /external/crosvm/third_party/vmm_vhost/src/connection/ |
| D | vfio.rs | 20 use crate::connection::Endpoint as EndpointTrait;
93 type Endpoint = Endpoint<MasterReq, D>; typedef
95 fn accept(&mut self) -> Result<Option<Self::Endpoint>> { in accept() argument
101 Ok(Some(Endpoint { in accept()
121 pub struct Endpoint<R: Req, D: Device> { struct
126 impl<D: Device, R: Req> From<D> for Endpoint<R, D> { argument
135 impl<R: Req, D: Device> EndpointTrait<R> for Endpoint<R, D> { implementation
175 impl<R: Req, D: Device> AsRawDescriptor for Endpoint<R, D> { implementation
|
| D | socket.rs | 21 use crate::connection::Endpoint as EndpointTrait;
76 type Endpoint = Endpoint<MasterReq>; typedef
84 fn accept(&mut self) -> Result<Option<Self::Endpoint>> { in accept() argument
88 return Ok(Some(Endpoint { in accept()
125 pub struct Endpoint<R: Req> { struct
130 impl<R: Req> From<SystemStream> for Endpoint<R> { argument
139 impl<R: Req> EndpointTrait<R> for Endpoint<R> { implementation
228 Ok(Box::new(Endpoint::from(tube))) in create_slave_request_endpoint()
232 impl<T: Req> AsRawDescriptor for Endpoint<T> { implementation
238 impl<T: Req> AsMut<SystemStream> for Endpoint<T> { implementation
[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/pigweed/pw_rpc/ |
| D | endpoint.cc | 88 Result<Packet> Endpoint::ProcessPacket(span<const std::byte> data, in ProcessPacket()
112 void Endpoint::RegisterCall(Call& new_call) { in RegisterCall()
124 Endpoint::FindIteratorsForCall(uint32_t channel_id, in FindIteratorsForCall()
151 Status Endpoint::CloseChannel(uint32_t channel_id) { in CloseChannel()
169 void Endpoint::AbortCalls(AbortIdType type, uint32_t id) { in AbortCalls()
185 void Endpoint::CleanUpCalls() { in CleanUpCalls()
209 void Endpoint::RemoveAllCalls() { in RemoveAllCalls()
|
| /external/pigweed/pw_rpc/public/pw_rpc/internal/ |
| D | endpoint.h | 41 class Endpoint {
45 ~Endpoint() PW_LOCKS_EXCLUDED(rpc_lock()) { RemoveAllCalls(); } in ~Endpoint()
107 _PW_RPC_CONSTEXPR Endpoint() = default;
110 _PW_RPC_CONSTEXPR Endpoint(span<rpc::Channel> channels) in Endpoint() function
257 class LockedEndpoint : public Endpoint {
259 friend class Endpoint;
265 inline LockedEndpoint& Endpoint::ClaimLocked() { in ClaimLocked()
|
| D | call_context.h | 28 class Endpoint; variable
37 constexpr CallContext(Endpoint& server, in CallContext()
59 constexpr Endpoint& server() const { return server_; } in server()
73 Endpoint& server_;
|
| /external/crosvm/third_party/vmm_vhost/src/ |
| D | slave.rs | 10 use crate::connection::Endpoint;
37 pub fn accept(&mut self) -> Result<Option<SlaveReqHandler<S, L::Endpoint>>> in accept()
39 <L as Listener>::Endpoint: Endpoint<MasterReq>, in accept()
88 use crate::connection::socket::Endpoint as SocketEndpoint; in test_slave_listener_accept()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/simulator/ |
| D | test_harness.h | 57 void set_client(Endpoint* client) { client_ = client; } in set_client()
58 void set_server(Endpoint* server) { server_ = server; } in set_server()
77 Endpoint* client_;
78 Endpoint* server_;
|
| D | packet_filter.h | 38 class PacketFilter : public Endpoint, public ConstrainedPortInterface {
42 PacketFilter(Simulator* simulator, std::string name, Endpoint* input);
70 Endpoint* input_;
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | memory_types.cc | 31 struct Endpoint { struct
37 uint32 operator()(const Endpoint& x) const { in operator ()()
44 uint32 operator()(const Endpoint& x, const Endpoint& y) const { in operator ()()
61 typedef std::unordered_map<Endpoint, MemoryType, EndpointHash, EndpointEq> in ProcessMemoryTypes()
184 std::unordered_map<Endpoint, Node*, EndpointHash, EndpointEq> recv_nodes; in EnsureMemoryTypes()
189 Endpoint key{e->src()->id(), e->src_output()}; in EnsureMemoryTypes()
|
| /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/cronet/net/socket/ |
| D | connect_job_factory.cc | 44 bool UsingSsl(const ConnectJobFactory::Endpoint& endpoint) { in UsingSsl()
55 HostPortPair ToHostPortPair(const ConnectJobFactory::Endpoint& endpoint) { in ToHostPortPair()
67 TransportSocketParams::Endpoint ToTransportEndpoint( in ToTransportEndpoint()
68 const ConnectJobFactory::Endpoint& endpoint) { in ToTransportEndpoint()
121 return CreateConnectJob(Endpoint(std::move(endpoint)), proxy_server, in CreateConnectJob()
155 Endpoint endpoint, in CreateConnectJob()
|
| D | transport_connect_job.h | 45 using Endpoint = absl::variant<url::SchemeHostPort, HostPortPair>;
54 TransportSocketParams(Endpoint destination,
63 const Endpoint& destination() const { return destination_; } in destination()
79 const Endpoint destination_;
|
| /external/rust/crates/grpcio-sys/grpc/include/grpc/event_engine/ |
| D | event_engine.h | 115 class Endpoint {
119 virtual ~Endpoint() = default;
164 std::function<void(absl::StatusOr<std::unique_ptr<Endpoint>>)>;
171 using AcceptCallback = std::function<void(std::unique_ptr<Endpoint>)>;
|
| /external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| D | FutureCall.java | 43 private FutureCall(Endpoint endpoint, PendingRpc rpc) { in FutureCall()
112 UnaryResponseFuture(Endpoint endpoint, PendingRpc rpc) { in UnaryResponseFuture()
143 BiFunction<Endpoint, PendingRpc, StreamResponseFuture<RequestT, ResponseT>> getFactory( in getFactory()
148 private StreamResponseFuture(Endpoint endpoint, PendingRpc rpc, Consumer<ResponseT> onNext) { in StreamResponseFuture()
|
| D | Endpoint.java | 42 class Endpoint { class
43 private static final Logger logger = Logger.forClass(Endpoint.class);
49 public Endpoint(List<Channel> channels) { in Endpoint() method in Endpoint
64 BiFunction<Endpoint, PendingRpc, CallT> createCall, in invokeRpc() argument
88 int channelId, Method method, BiFunction<Endpoint, PendingRpc, CallT> createCall) { in openRpc() argument
96 int channelId, Method method, BiFunction<Endpoint, PendingRpc, CallT> createCall) { in createCall() argument
|
| /external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/event_engine/ |
| D | event_engine.h | 115 class Endpoint {
119 virtual ~Endpoint() = default;
164 std::function<void(absl::StatusOr<std::unique_ptr<Endpoint>>)>;
171 using AcceptCallback = std::function<void(std::unique_ptr<Endpoint>)>;
|
| /external/arm-trusted-firmware/docs/threat_model/ |
| D | threat_model_spm.rst | 134 - NS-Endpoint identifies a non-secure endpoint: normal world client at NS-EL2
136 - S-Endpoint identifies a secure endpoint typically a secure partition.
175 | ``Threat Agent`` | NS-Endpoint, S-Endpoint |
225 | ``Threat Agent`` | NS-Endpoint, S-Endpoint |
276 | ``Threat Agent`` | NS-Endpoint, S-Endpoint |
348 | ``Threat Agent`` | NS-Endpoint, S-Endpoint |
392 | ``Threat Agent`` | NS-Endpoint, S-Endpoint |
424 | ``Threat Agent`` | NS-Endpoint, S-Endpoint |
468 | ``Threat Agent`` | NS-Endpoint, S-Endpoint |
541 | ``Threat Agent`` | NS-Endpoint, S-Endpoint |
[all …]
|