Home
last modified time | relevance | path

Searched refs:session (Results 1 – 25 of 36) sorted by relevance

12

/system/iorap/src/prefetcher/
Dsession_manager.cc56 it->second.session->Dump(os, /*multiline*/false); in Dump()
69 it->second.session->Dump(os, /*multiline*/true); in Dump()
82 return it->second.session; in FindSession()
99 void InsertNewSession(std::shared_ptr<Session> session, std::string description) { in InsertNewSession() argument
100 DCHECK(!FindSession(session->SessionId())) << "session cannot already exist"; in InsertNewSession()
102 size_t session_id = session->SessionId(); in InsertNewSession()
105 data.session = std::move(session); in InsertNewSession()
113 std::shared_ptr<Session> session; member
117 return session->SessionId(); in SessionId()
130 std::shared_ptr<Session> session = in CreateSession() local
[all …]
Dread_ahead.cc100 if (session != nullptr) { in SessionId()
101 DCHECK_EQ(session->SessionId(), task_id.id); in SessionId()
108 std::shared_ptr<Session> session; member
197 static bool PerformReadAhead(std::shared_ptr<Session> session, size_t path_id, ReadAheadKind kind, … in PerformReadAhead() argument
198 return session->ReadAhead(path_id, kind, length, offset); in PerformReadAhead()
247 std::shared_ptr<Session> session = in BeginTaskForSockets() local
251 task_data.session = session; in BeginTaskForSockets()
252 CHECK(session != nullptr); in BeginTaskForSockets()
257 session->Dump(LOG_STREAM(INFO), /*multiline*/true); in BeginTaskForSockets()
298 std::shared_ptr<Session> session = in BeginTask() local
[all …]
Dprefetcher_daemon.cc1228 std::shared_ptr<Session> session = session_manager_->FindSession(command.session_id); in ReceiveCommand() local
1230 if (!session) { in ReceiveCommand()
1236 return session->RegisterFilePath(command.id, *command.file_path); in ReceiveCommand()
1239 std::shared_ptr<Session> session = session_manager_->FindSession(command.session_id); in ReceiveCommand() local
1241 if (!session) { in ReceiveCommand()
1246 return session->UnregisterFilePath(command.id); in ReceiveCommand()
1249 std::shared_ptr<Session> session = session_manager_->FindSession(command.session_id); in ReceiveCommand() local
1251 if (!session) { in ReceiveCommand()
1256 … return session->ReadAhead(command.id, command.read_ahead_kind, command.length, command.offset); in ReceiveCommand()
1264 std::shared_ptr<Session> session = session_manager_->FindSession(command.session_id); in ReceiveCommand() local
[all …]
Dsession_manager.h85 std::ostream& operator<<(std::ostream&os, const SessionManager& session);
/system/apex/apexd/
Dapexd_session.cpp123 auto session = GetSessionFromFile(session_dir_path + "/" + kStateFileName); in GetSessions() local
124 if (!session.ok()) { in GetSessions()
125 LOG(WARNING) << session.error(); in GetSessions()
128 sessions.push_back(std::move(*session)); in GetSessions()
148 for (const ApexSession& session : sessions) { in GetActiveSessions() local
149 if (!session.IsFinalized() && session.GetState() != SessionState::UNKNOWN) { in GetActiveSessions()
150 active_sessions.push_back(session); in GetActiveSessions()
266 std::ostream& operator<<(std::ostream& out, const ApexSession& session) { in operator <<() argument
267 return out << "[id = " << session.GetId() in operator <<()
268 << "; state = " << SessionState::State_Name(session.GetState()) in operator <<()
[all …]
Dapexd_session_test.cpp86 SessionState session; in TEST() local
87 session.set_id(id); in TEST()
88 session.set_state(state); in TEST()
91 if (!session.SerializeToOstream(&state_file)) { in TEST()
Dapexd_test_utils.h143 inline void PrintTo(const ApexSessionInfo& session, std::ostream* os) { in PrintTo() argument
145 *os << " sessionId : " << session.sessionId << "\n"; in PrintTo()
146 *os << " isUnknown : " << session.isUnknown << "\n"; in PrintTo()
147 *os << " isVerified : " << session.isVerified << "\n"; in PrintTo()
148 *os << " isStaged : " << session.isStaged << "\n"; in PrintTo()
149 *os << " isActivated : " << session.isActivated << "\n"; in PrintTo()
150 *os << " isActivationFailed : " << session.isActivationFailed << "\n"; in PrintTo()
151 *os << " isSuccess : " << session.isSuccess << "\n"; in PrintTo()
152 *os << " isReverted : " << session.isReverted << "\n"; in PrintTo()
153 *os << " isRevertFailed : " << session.isRevertFailed << "\n"; in PrintTo()
Dapexd.cpp1521 auto session = ApexSession::GetSession(session_id); in AbortStagedSession() local
1522 if (!session.ok()) { in AbortStagedSession()
1525 switch (session->GetState()) { in AbortStagedSession()
1529 return session->DeleteSession(); in AbortStagedSession()
1531 return Error() << "Session " << *session << " can't be aborted"; in AbortStagedSession()
1756 const ApexSession& session) { in SnapshotOrRestoreDeIfNeeded() argument
1757 if (session.HasRollbackEnabled()) { in SnapshotOrRestoreDeIfNeeded()
1758 for (const auto& apex_name : session.GetApexNames()) { in SnapshotOrRestoreDeIfNeeded()
1760 SnapshotDataDirectory(base_dir, session.GetRollbackId(), apex_name); in SnapshotOrRestoreDeIfNeeded()
1766 } else if (session.IsRollback()) { in SnapshotOrRestoreDeIfNeeded()
[all …]
Dapexservice_test.cpp688 auto session = ApexSession::GetSession(1547); in TEST_F() local
689 ASSERT_FALSE(session->GetBuildFingerprint().empty()); in TEST_F()
821 auto session = ApexSession::GetSession(1547); in TEST_F() local
822 ASSERT_TRUE(session->GetChildSessionIds().empty()); in TEST_F()
823 ASSERT_FALSE(session->IsRollback()); in TEST_F()
824 ASSERT_FALSE(session->HasRollbackEnabled()); in TEST_F()
825 ASSERT_EQ(0, session->GetRollbackId()); in TEST_F()
1760 ApexSessionInfo session; in TEST_F() local
1761 ASSERT_TRUE(IsOk(service_->getStagedSessionInfo(123, &session))) in TEST_F()
1765 EXPECT_THAT(session, SessionInfoEq(expected)); in TEST_F()
[all …]
Dapexservice.cpp276 void ConvertToApexSessionInfo(const ApexSession& session, in ConvertToApexSessionInfo() argument
281 session_info->sessionId = session.GetId(); in ConvertToApexSessionInfo()
282 session_info->crashingNativeProcess = session.GetCrashingNativeProcess(); in ConvertToApexSessionInfo()
283 session_info->errorMessage = session.GetErrorMessage(); in ConvertToApexSessionInfo()
285 switch (session.GetState()) { in ConvertToApexSessionInfo()
349 for (const auto& session : sessions) { in getSessions() local
351 ConvertToApexSessionInfo(session, &session_info); in getSessions()
362 auto session = ApexSession::GetSession(session_id); in getStagedSessionInfo() local
363 if (!session.ok()) { in getStagedSessionInfo()
370 ConvertToApexSessionInfo(*session, apex_session_info); in getStagedSessionInfo()
[all …]
Dapexd_session.h87 std::ostream& operator<<(std::ostream& out, const ApexSession& session);
/system/extras/simpleperf/demo/CppApi/app/src/main/cpp/
Dnative-lib.cpp36 simpleperf::ProfileSession session; in ProfileThreadFunc() local
38 session.StartRecording(options); in ProfileThreadFunc()
42 session.PauseRecording(); in ProfileThreadFunc()
45 session.ResumeRecording(); in ProfileThreadFunc()
49 session.StopRecording(); in ProfileThreadFunc()
/system/apex/proto/
Dsession_state.proto37 // Current state of the session
40 // Child session ids
46 // True if rollback is enabled for this session
49 // True if this session is a rollback of a previous install
55 // The crashing native process that has caused this session to be reverted
58 // The names of the apexes within this session. Only populated for sessions
62 // Populated with error details when session fails to activate
/system/bt/gd/neighbor/cert/
Dneighbor_test.py61 session = self.dut_neighbor.set_inquiry_mode(inquiry_msg)
63 …assertThat(session).emits(NeighborMatchers.InquiryResult(self.cert_address), timeout=timedelta(sec…
71 session = self.dut_neighbor.set_inquiry_mode(inquiry_msg)
73 assertThat(session).emits(
90 session = self.dut_neighbor.set_inquiry_mode(inquiry_msg)
92 assertThat(session).emits(
97 session = self.dut_neighbor.get_remote_name(self.cert_address)
98 session.verify_name(self.cert_name)
/system/core/trusty/storage/lib/include/trusty/lib/
Dstorage.h54 void storage_close_session(storage_session_t session);
76 int storage_open_file(storage_session_t session, file_handle_t *handle_p,
93 int storage_delete_file(storage_session_t session, const char *name,
151 int storage_end_transaction(storage_session_t session, bool complete);
/system/bt/common/
Dmetrics_unittest.cc111 A2DPSession* session = new A2DPSession(); in MakeA2DPSession() local
112 session->set_media_timer_min_millis(metrics.media_timer_min_ms); in MakeA2DPSession()
113 session->set_media_timer_max_millis(metrics.media_timer_max_ms); in MakeA2DPSession()
114 session->set_media_timer_avg_millis(metrics.media_timer_avg_ms); in MakeA2DPSession()
115 session->set_buffer_overruns_max_count(metrics.buffer_overruns_max_count); in MakeA2DPSession()
116 session->set_buffer_overruns_total(metrics.buffer_overruns_total); in MakeA2DPSession()
117 session->set_buffer_underruns_average(metrics.buffer_underruns_average); in MakeA2DPSession()
118 session->set_buffer_underruns_count(metrics.buffer_underruns_count); in MakeA2DPSession()
119 session->set_audio_duration_millis(metrics.audio_duration_ms); in MakeA2DPSession()
120 session->set_source_codec(source_codec); in MakeA2DPSession()
[all …]
/system/core/trusty/storage/lib/
Dstorage.c104 static ssize_t send_reqv(storage_session_t session, in send_reqv() argument
110 rc = writev(session, tx_iovs, tx_iovcnt); in send_reqv()
117 rc = readv(session, rx_iovs, rx_iovcnt); in send_reqv()
137 void storage_close_session(storage_session_t session) in storage_close_session() argument
139 tipc_close(session); in storage_close_session()
143 int storage_open_file(storage_session_t session, file_handle_t *handle_p, const char *name, in storage_open_file() argument
152 ssize_t rc = send_reqv(session, tx, 3, rx, 2); in storage_open_file()
162 *handle_p = make_file_handle(session, rsp.handle); in storage_open_file()
180 int storage_delete_file(storage_session_t session, const char *name, uint32_t opflags) in storage_delete_file() argument
187 ssize_t rc = send_reqv(session, tx, 3, rx, 1); in storage_delete_file()
[all …]
/system/security/keystore2/src/
Dapc.rs183 session: Option<ApcSessionState>, field
190 Self { session: None, rate_limiting: Default::default(), confirmation_token_sender } in new()
219 let (callback, uid, start, client_aborted) = match state.session.take() { in result()
277 if state.session.is_some() { in present_prompt()
319 state.session = Some(ApcSessionState { in present_prompt()
331 let hal = match &mut state.session { in cancel_prompt()
336 Some(session) => { in cancel_prompt()
337 if session.cb != listener.as_binder() { in cancel_prompt()
343 session.client_aborted = true; in cancel_prompt()
344 session.hal.clone() in cancel_prompt()
/system/bt/gd/proto/bluetooth/metrics/
Dbluetooth.proto27 repeated BluetoothSession session = 1; field
96 // A metrics dump takes a snapshot of current Bluetooth session and thus
104 // Duration of the session.
116 // The information about the RFComm session.
119 // The information about the A2DP audio session.
143 // Session information that gets logged for A2DP session.
166 // Total audio time in this A2DP session
169 // Audio codec used in this A2DP session in A2DP source role
172 // Whether A2DP offload is enabled in this A2DP session
/system/bt/gd/common/
Dobserver_registry.h47 void callback_wrapper(int session, Callback<R(T...)> callback, T... t) { in callback_wrapper() argument
48 if (session == session_) { in callback_wrapper()
/system/security/keystore2/apc_compat/
Dapc_compat.cpp186 auto session = reinterpret_cast<sp<ConfuiCompatSession>*>(handle); in promptUserConfirmation() local
187 return (*session)->promptUserConfirmation(callback, prompt_text, extra_data, extra_data_size, in promptUserConfirmation()
192 auto session = reinterpret_cast<sp<ConfuiCompatSession>*>(handle); in abortUserConfirmation() local
193 (*session)->abort(); in abortUserConfirmation()
/system/media/audio/include/system/
Daudio.h207 static inline bool audio_is_global_session(audio_session_t session) { in audio_is_global_session() argument
208 return session <= AUDIO_SESSION_OUTPUT_MIX; in audio_is_global_session()
545 audio_session_t session; /* audio session */ member
597 struct audio_port_config_session_ext session; /* session specific info */ member
643 audio_session_t session; /* audio session */ member
663 struct audio_port_session_ext session; member
711 struct audio_port_session_ext session; member
868 if (lhs->ext.session.session != rhs->ext.session.session) return false; in audio_port_configs_are_equal()
963 if (lhs->ext.session.session != rhs->ext.session.session) { in audio_ports_base_are_equal()
/system/bt/binder/android/bluetooth/
DIBluetoothAvrcpController.aidl23 import android.media.session.PlaybackState;
/system/media/tests/
Dsystemaudio_tests.cpp381 port->ext.session.session = mSession; in fillFakeAudioPortBaseInfo()
417 lhs->ext.session.session = AUDIO_SESSION_NONE; in testAudioPortExtBaseEquivalent()
419 lhs->ext.session.session = rhs->ext.session.session; in testAudioPortExtBaseEquivalent()
517 config->ext.session.session = mSession; in fillFakeAudioPortConfigInfo()
/system/tools/aidl/
Dhiddenapi-greylist219 "android.media.session.IActiveSessionsListener",
220 "android.media.session.ICallback",
221 "android.media.session.IOnMediaKeyListener",
222 "android.media.session.IOnVolumeKeyLongPressListener",
223 "android.media.session.ISession",
224 "android.media.session.ISessionCallback",
225 "android.media.session.ISessionController",
226 "android.media.session.ISessionControllerCallback",
227 "android.media.session.ISessionManager",

12