| /external/perfetto/include/perfetto/base/ |
| D | unix_socket.h | 149 class UnixSocket {
157 UnixSocket* self,
158 std::unique_ptr<UnixSocket> new_connection);
161 virtual void OnConnect(UnixSocket* self, bool connected);
165 virtual void OnDisconnect(UnixSocket* self);
170 virtual void OnDataAvailable(UnixSocket* self);
187 static std::unique_ptr<UnixSocket> Listen(const std::string& socket_name,
194 static std::unique_ptr<UnixSocket> Listen(ScopedFile,
202 static std::unique_ptr<UnixSocket> Connect(const std::string& socket_name,
208 static std::unique_ptr<UnixSocket> AdoptConnected(
[all …]
|
| /external/perfetto/src/base/ |
| D | unix_socket_unittest.cc | 49 constexpr auto kBlocking = UnixSocket::BlockingMode::kBlocking;
51 class MockEventListener : public UnixSocket::EventListener {
53 MOCK_METHOD2(OnNewIncomingConnection, void(UnixSocket*, UnixSocket*));
54 MOCK_METHOD2(OnConnect, void(UnixSocket*, bool));
55 MOCK_METHOD1(OnDisconnect, void(UnixSocket*));
56 MOCK_METHOD1(OnDataAvailable, void(UnixSocket*));
60 UnixSocket* self, in OnNewIncomingConnection()
61 std::unique_ptr<UnixSocket> new_connection) override { in OnNewIncomingConnection()
66 std::unique_ptr<UnixSocket> GetIncomingConnection() { in GetIncomingConnection()
69 std::unique_ptr<UnixSocket> sock = std::move(incoming_connections_.front()); in GetIncomingConnection()
[all …]
|
| D | unix_socket.cc | 371 std::unique_ptr<UnixSocket> UnixSocket::Listen(const std::string& socket_name, in Listen()
384 std::unique_ptr<UnixSocket> UnixSocket::Listen(ScopedFile fd, in Listen()
388 return std::unique_ptr<UnixSocket>( in Listen()
389 new UnixSocket(event_listener, task_runner, std::move(fd), in Listen()
394 std::unique_ptr<UnixSocket> UnixSocket::Connect(const std::string& socket_name, in Connect()
398 std::unique_ptr<UnixSocket> sock( in Connect()
399 new UnixSocket(event_listener, task_runner, sock_type)); in Connect()
405 std::unique_ptr<UnixSocket> UnixSocket::AdoptConnected( in AdoptConnected()
410 return std::unique_ptr<UnixSocket>( in AdoptConnected()
411 new UnixSocket(event_listener, task_runner, std::move(fd), in AdoptConnected()
[all …]
|
| /external/perfetto/src/ipc/ |
| D | host_impl.h | 37 class HostImpl : public Host, public base::UnixSocket::EventListener {
47 void OnNewIncomingConnection(base::UnixSocket*,
48 std::unique_ptr<base::UnixSocket>) override;
49 void OnDisconnect(base::UnixSocket*) override;
50 void OnDataAvailable(base::UnixSocket*) override;
52 const base::UnixSocket* sock() const { return sock_.get(); } in sock()
59 std::unique_ptr<base::UnixSocket> sock;
88 std::unique_ptr<base::UnixSocket> sock_; // The listening socket.
90 std::map<base::UnixSocket*, ClientConnection*> clients_by_socket_;
|
| D | client_impl.h | 42 class ClientImpl : public Client, public base::UnixSocket::EventListener {
53 void OnConnect(base::UnixSocket*, bool connected) override;
54 void OnDisconnect(base::UnixSocket*) override;
55 void OnDataAvailable(base::UnixSocket*) override;
85 std::unique_ptr<base::UnixSocket> sock_;
|
| D | host_impl.cc | 59 sock_ = base::UnixSocket::Listen(std::move(socket_fd), this, task_runner_); in HostImpl()
66 sock_ = base::UnixSocket::Listen(socket_name, this, task_runner_); in HostImpl()
85 base::UnixSocket*, in OnNewIncomingConnection() argument
86 std::unique_ptr<base::UnixSocket> new_conn) { in OnNewIncomingConnection()
96 void HostImpl::OnDataAvailable(base::UnixSocket* sock) { in OnDataAvailable()
241 base::UnixSocket::BlockingMode::kBlocking); in SendFrame()
245 void HostImpl::OnDisconnect(base::UnixSocket* sock) { in OnDisconnect()
|
| D | client_impl.cc | 47 sock_ = base::UnixSocket::Connect(socket_name, this, task_runner); in ClientImpl()
126 base::UnixSocket::BlockingMode::kBlocking); in SendFrame()
131 void ClientImpl::OnConnect(base::UnixSocket*, bool connected) { in OnConnect() argument
144 void ClientImpl::OnDisconnect(base::UnixSocket*) { in OnDisconnect() argument
156 void ClientImpl::OnDataAvailable(base::UnixSocket*) { in OnDataAvailable() argument
|
| D | client_impl_unittest.cc | 82 class FakeHost : public base::UnixSocket::EventListener {
107 listening_sock = base::UnixSocket::Listen(kSockName, this, task_runner); in FakeHost()
123 base::UnixSocket*, in OnNewIncomingConnection() argument
124 std::unique_ptr<base::UnixSocket> new_connection) override { in OnNewIncomingConnection()
129 void OnDataAvailable(base::UnixSocket* sock) override { in OnDataAvailable()
187 base::UnixSocket::BlockingMode::kBlocking)); in Reply()
192 std::unique_ptr<base::UnixSocket> listening_sock;
193 std::unique_ptr<base::UnixSocket> client_sock;
|
| D | host_impl_unittest.cc | 82 class FakeClient : public base::UnixSocket::EventListener {
92 sock_ = base::UnixSocket::Connect(kSockName, this, task_runner); in FakeClient()
123 void OnConnect(base::UnixSocket*, bool success) override { in OnConnect() argument
128 void OnDisconnect(base::UnixSocket*) override { OnDisconnect(); } in OnDisconnect() argument
130 void OnDataAvailable(base::UnixSocket* sock) override { in OnDataAvailable()
157 base::UnixSocket::BlockingMode::kBlocking)); in SendFrame()
161 std::unique_ptr<base::UnixSocket> sock_;
|
| /external/perfetto/src/profiling/memory/ |
| D | heapprofd_producer.h | 91 class SocketDelegate : public base::UnixSocket::EventListener {
95 void OnDisconnect(base::UnixSocket* self) override;
97 base::UnixSocket* self,
98 std::unique_ptr<base::UnixSocket> new_connection) override;
99 void OnDataAvailable(base::UnixSocket* self) override;
190 std::unique_ptr<base::UnixSocket> sock;
195 void HandleClientConnection(std::unique_ptr<base::UnixSocket> new_connection,
215 std::unique_ptr<base::UnixSocket> MakeListeningSocket();
258 std::unique_ptr<base::UnixSocket> listening_socket_;
|
| D | unwinding.h | 135 class UnwindingWorker : public base::UnixSocket::EventListener {
165 void OnDisconnect(base::UnixSocket* self) override;
166 void OnNewIncomingConnection(base::UnixSocket*, in OnNewIncomingConnection() argument
167 std::unique_ptr<base::UnixSocket>) override { in OnNewIncomingConnection() argument
170 void OnDataAvailable(base::UnixSocket* self) override;
188 std::unique_ptr<base::UnixSocket> sock;
|
| D | heapprofd_producer.cc | 143 std::unique_ptr<base::UnixSocket> HeapprofdProducer::MakeListeningSocket() { in MakeListeningSocket()
147 return base::UnixSocket::Listen(kHeapprofdSocketFile, &socket_delegate_, in MakeListeningSocket()
155 return base::UnixSocket::Listen(base::ScopedFile(raw_fd), &socket_delegate_, in MakeListeningSocket()
169 auto socket = base::UnixSocket::AdoptConnected( in AdoptTargetProcessSocket()
623 void HeapprofdProducer::SocketDelegate::OnDisconnect(base::UnixSocket* self) { in OnDisconnect()
635 base::UnixSocket*, in OnNewIncomingConnection() argument
636 std::unique_ptr<base::UnixSocket> new_connection) { in OnNewIncomingConnection()
646 base::UnixSocket* self) { in OnDataAvailable()
677 base::UnixSocket::BlockingMode::kBlocking); in OnDataAvailable()
720 std::unique_ptr<base::UnixSocket> new_connection, in HandleClientConnection()
|
| D | unwinding.cc | 246 void UnwindingWorker::OnDisconnect(base::UnixSocket* self) { in OnDisconnect()
282 void UnwindingWorker::OnDataAvailable(base::UnixSocket* self) { in OnDataAvailable()
386 auto sock = base::UnixSocket::AdoptConnected( in HandleHandoffSocket()
|