Searched refs:ClientConnection (Results 1 – 9 of 9) sorted by relevance
| /external/perfetto/src/ipc/ |
| D | host_impl.h | 63 struct ClientConnection { struct
64 ~ClientConnection();
99 void OnReceivedFrame(ClientConnection*, const Frame&); argument
100 void OnBindService(ClientConnection*, const Frame&);
101 void OnInvokeMethod(ClientConnection*, const Frame&);
102 void OnSetPeerIdentity(ClientConnection*, const Frame&);
107 static void SendFrame(ClientConnection*, const Frame&, int fd = -1);
112 std::map<ClientID, std::unique_ptr<ClientConnection>> clients_;
113 std::map<base::UnixSocket*, ClientConnection*> clients_by_socket_;
|
| D | host_impl.cc | 91 uid_t HostImpl::ClientConnection::GetPosixPeerUid() const { in GetPosixPeerUid()
106 pid_t HostImpl::ClientConnection::GetLinuxPeerPid() const { in GetLinuxPeerPid()
197 ClientConnection* client_connection = clients_by_socket_[unix_socket_ptr]; in AdoptConnectedSocket_Fuchsia()
212 std::unique_ptr<ClientConnection> client(new ClientConnection()); in OnNewIncomingConnection()
226 ClientConnection* client = it->second; in OnDataAvailable()
253 void HostImpl::OnReceivedFrame(ClientConnection* client, in OnReceivedFrame()
269 void HostImpl::OnBindService(ClientConnection* client, const Frame& req_frame) { in OnBindService()
290 void HostImpl::OnInvokeMethod(ClientConnection* client, in OnInvokeMethod()
338 void HostImpl::OnSetPeerIdentity(ClientConnection* client, in OnSetPeerIdentity()
367 ClientConnection* client = client_iter->second.get(); in ReplyToMethodInvocation()
[all …]
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/eventstream/ |
| D | ClientConnectionHandler.java | 13 protected ClientConnection clientConnection;
24 protected abstract void onConnectionSetup(final ClientConnection connection, int errorCode); in onConnectionSetup()
33 clientConnection = new ClientConnection(connectionPtr); in onConnectionSetupShim()
|
| D | ClientConnection.java | 17 public class ClientConnection extends CrtResource { class
23 ClientConnection(long clientConnection) { in ClientConnection() method in ClientConnection
147 protected void onConnectionSetup(ClientConnection connection, int errorCode) { in connect()
|
| /external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/ |
| D | EventStreamClientConnectionTest.java | 68 final ClientConnection[] clientConnectionArray = {null}; in testConnectionHandling()
70 …CompletableFuture<Void> connectFuture = ClientConnection.connect("127.0.0.1", (short)8033, socketO… in testConnectionHandling()
72 protected void onConnectionSetup(ClientConnection connection, int errorCode) { in testConnectionHandling()
159 final ClientConnection[] clientConnectionArray = {null}; in testConnectionProtocolMessageHandling()
166 …CompletableFuture<Void> connectFuture = ClientConnection.connect("127.0.0.1", (short)8034, socketO… in testConnectionProtocolMessageHandling()
168 protected void onConnectionSetup(ClientConnection connection, int errorCode) { in testConnectionProtocolMessageHandling()
274 final ClientConnection[] clientConnectionArray = {null}; in testConnectionProtocolMessageWithExtraHeadersHandling()
280 …CompletableFuture<Void> connectFuture = ClientConnection.connect("127.0.0.1", (short)8035, socketO… in testConnectionProtocolMessageWithExtraHeadersHandling()
282 protected void onConnectionSetup(ClientConnection connection, int errorCode) { in testConnectionProtocolMessageWithExtraHeadersHandling()
413 final ClientConnection[] clientConnectionArray = {null}; in testContinuationMessageHandling()
[all …]
|
| /external/bazelbuild-rules_rust/examples/crate_universe/multi_package/sub_pkgs/pkg_b/src/ |
| D | lib.rs | 169 ClientConfig, ClientConnection, ConnectionCommon, Error, RootCertStore, ServerConfig,
216 client: &mut ClientConnection, in do_handshake_until_error() argument
270 ) -> (ClientConnection, ServerConnection) { in make_pair_for_arc_configs() argument
272 ClientConnection::new(Arc::clone(client_config), dns_name("localhost")).unwrap(), in make_pair_for_arc_configs()
|
| /external/rust/android-crates-io/crates/tungstenite/src/ |
| D | stream.rs | 71 Rustls(rustls::StreamOwned<rustls::ClientConnection, S>),
83 &'a rustls::StreamOwned<rustls::ClientConnection, S>, in fmt()
|
| D | tls.rs | 73 use rustls::{ClientConfig, ClientConnection, RootCertStore, StreamOwned};
129 let client = ClientConnection::new(config, domain).map_err(TlsError::Rustls)?; in wrap_stream()
|
| /external/flatbuffers/grpc/examples/swift/Greeter/Sources/client/ |
| D | main.swift | 91 let channel = ClientConnection.insecure(group: group) in main()
|