Home
last modified time | relevance | path

Searched refs:peer_pid (Results 1 – 18 of 18) sorted by relevance

/external/perfetto/src/profiling/memory/
Dunwinding.cc192 auto it = client_data_.find(self->peer_pid()); in OnDisconnect()
209 pid_t peer_pid = self->peer_pid(); in OnDisconnect() local
213 delegate_->PostSocketDisconnected(ds_id, peer_pid, stats); in OnDisconnect()
220 HandleUnwindBatch(self->peer_pid()); in OnDataAvailable()
223 void UnwindingWorker::HandleUnwindBatch(pid_t peer_pid) { in HandleUnwindBatch() argument
224 auto it = client_data_.find(peer_pid); in HandleUnwindBatch()
245 client_data.sock->peer_pid(), delegate_); in HandleUnwindBatch()
261 [this, peer_pid] { HandleUnwindBatch(peer_pid); }); in HandleUnwindBatch()
269 pid_t peer_pid, in HandleBuffer() argument
283 rec.pid = peer_pid; in HandleBuffer()
[all …]
Dheapprofd_producer.cc745 auto it = producer_->pending_processes_.find(self->peer_pid()); in OnDisconnect()
759 peer_process.pid = new_connection->peer_pid(); in OnNewIncomingConnection()
768 auto it = producer_->pending_processes_.find(self->peer_pid()); in OnDataAvailable()
799 std::piecewise_construct, std::forward_as_tuple(self->peer_pid()), in OnDataAvailable()
816 PERFETTO_DLOG("%d: Received FDs.", self->peer_pid()); in OnDataAvailable()
836 producer_->UnwinderForPID(self->peer_pid()) in OnDataAvailable()
841 PERFETTO_DFATAL_OR_ELOG("%d: Received partial FDs.", self->peer_pid()); in OnDataAvailable()
844 PERFETTO_ELOG("%d: Received no FDs.", self->peer_pid()); in OnDataAvailable()
890 pid_t peer_pid = new_connection->peer_pid(); in HandleClientConnection() local
891 if (peer_pid != process.pid) { in HandleClientConnection()
[all …]
Dunwinding.h83 pid_t peer_pid,
/external/perfetto/src/profiling/perf/
Dproc_descriptors.cc91 static_cast<int>(new_connection->peer_pid())); in OnNewIncomingConnection()
98 static_cast<int>(self->peer_pid())); in OnDisconnect()
119 delegate_->OnProcDescriptors(self->peer_pid(), std::move(fds[0]), in OnDataAvailable()
/external/libchrome/ipc/
Dipc_message_pipe_reader.h49 virtual void OnPeerPidReceived(int32_t peer_pid) = 0; in COMPONENT_EXPORT()
96 void SetPeerPid(int32_t peer_pid) override; in COMPONENT_EXPORT()
Dipc_mojo_bootstrap_unittest.cc89 int32_t peer_pid() const { return peer_pid_; } in peer_pid() function in __anon7564218b0111::PeerPidReceiver
125 EXPECT_EQ(kTestClientPid, impl.peer_pid()); in TEST_F()
150 EXPECT_EQ(kTestServerPid, impl.peer_pid()); in MULTIPROCESS_TEST_MAIN_WITH_SETUP()
Dipc_channel_proxy.cc134 void ChannelProxy::Context::OnChannelConnected(int32_t peer_pid) { in OnChannelConnected() argument
138 peer_pid_ = peer_pid; in OnChannelConnected()
335 base::ProcessId peer_pid; in OnDispatchConnected() local
338 peer_pid = peer_pid_; in OnDispatchConnected()
342 listener_->OnChannelConnected(peer_pid); in OnDispatchConnected()
Dipc_message_pipe_reader.cc80 void MessagePipeReader::SetPeerPid(int32_t peer_pid) { in SetPeerPid() argument
81 delegate_->OnPeerPidReceived(peer_pid); in SetPeerPid()
Dmessage_filter.cc20 void MessageFilter::OnChannelConnected(int32_t peer_pid) {} in OnChannelConnected() argument
Dipc_listener.h29 virtual void OnChannelConnected(int32_t peer_pid) {} in COMPONENT_EXPORT()
Dmessage_filter.h39 virtual void OnChannelConnected(int32_t peer_pid); in COMPONENT_EXPORT()
Dipc_channel_mojo_unittest.cc131 void OnChannelConnected(int32_t peer_pid) override { in OnChannelConnected() argument
132 IPC::TestChannelListener::OnChannelConnected(peer_pid); in OnChannelConnected()
133 EXPECT_TRUE(base::kNullProcessId != peer_pid); in OnChannelConnected()
204 void OnChannelConnected(int32_t peer_pid) override { in OnChannelConnected() argument
258 void OnChannelConnected(int32_t peer_pid) override {} in OnChannelConnected() argument
293 void OnChannelConnected(int32_t peer_pid) override { in OnChannelConnected() argument
639 void OnChannelConnected(int32_t peer_pid) override { in OnChannelConnected() argument
723 void OnChannelConnected(int32_t peer_pid) override { in OnChannelConnected() argument
1751 void OnChannelConnected(int32_t peer_pid) override { in OnChannelConnected() argument
1752 EXPECT_EQ(peer_pid, kMagicChildId); in OnChannelConnected()
Dipc_channel_proxy_unittest.cc159 void OnChannelConnected(int32_t peer_pid) override { in OnChannelConnected() argument
161 EXPECT_NE(static_cast<int32_t>(base::kNullProcessId), peer_pid); in OnChannelConnected()
Dipc_channel_mojo.cc255 void ChannelMojo::OnPeerPidReceived(int32_t peer_pid) { in OnPeerPidReceived() argument
256 listener_->OnChannelConnected(peer_pid); in OnPeerPidReceived()
Dipc_channel_mojo.h90 void OnPeerPidReceived(int32_t peer_pid) override; in COMPONENT_EXPORT()
Dipc_channel_proxy.h279 void OnChannelConnected(int32_t peer_pid) override; in COMPONENT_EXPORT()
/external/perfetto/include/perfetto/ext/base/
Dunix_socket.h294 pid_t peer_pid() const { in peer_pid() function
/external/perfetto/src/base/
Dunix_socket_unittest.cc439 EXPECT_EQ(getpid(), static_cast<pid_t>(srv_conn->peer_pid())); in TEST_F()
470 EXPECT_EQ(getpid(), static_cast<pid_t>(srv_client_conn->peer_pid())); in TEST_F()