/ohos5.0/base/request/request/services/src/utils/ |
H A D | mod.rs | 106 let token_id = ipc::Skeleton::calling_full_token_id(); in query_calling_bundle() localVariable 107 ffi::GetCallingBundle(token_id) in query_calling_bundle() 112 let token_id = ipc::Skeleton::calling_full_token_id(); in is_system_api() localVariable 113 ffi::IsSystemAPI(token_id) in is_system_api() 118 let token_id = ipc::Skeleton::calling_full_token_id(); in check_permission() localVariable 119 ffi::CheckPermission(token_id, permission) in check_permission() 156 fn GetCallingBundle(token_id: u64) -> String; in GetCallingBundle() 157 fn IsSystemAPI(token_id: u64) -> bool; in IsSystemAPI() 158 fn CheckPermission(token_id: u64, permission: &str) -> bool; in CheckPermission()
|
/ohos5.0/foundation/systemabilitymgr/safwk/interfaces/innerkits/safwk/rust/tests/ |
H A D | entry.rs | 32 fn SetSelfTokenID(token_id: u64) -> i32; in SetSelfTokenID() 52 let token_id = GetAccessTokenId(&mut param as *mut TokenInfoParams); in init_access_token() localVariable 53 SetSelfTokenID(token_id); in init_access_token()
|
/ohos5.0/foundation/systemabilitymgr/samgr/services/samgr/native/test/unittest/rust/service/src/ |
H A D | access_token.rs | 33 fn SetSelfTokenID(token_id: u64) -> i32; in SetSelfTokenID() 54 let token_id = GetAccessTokenId(&mut param as *mut TokenInfoParams); in init_access_token() localVariable 55 SetSelfTokenID(token_id); in init_access_token()
|
/ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/tests/ |
H A D | entry.rs | 36 fn SetSelfTokenID(token_id: u64) -> i32; in SetSelfTokenID() 55 let token_id = GetAccessTokenId(&mut param as *mut TokenInfoParams); in init_access_token() localVariable 56 SetSelfTokenID(token_id); in init_access_token()
|
/ohos5.0/foundation/systemabilitymgr/samgr/interfaces/innerkits/rust/tests/ |
H A D | entry.rs | 34 fn SetSelfTokenID(token_id: u64) -> i32; in SetSelfTokenID() 54 let token_id = GetAccessTokenId(&mut param as *mut TokenInfoParams); in init_access_token() localVariable 55 SetSelfTokenID(token_id); in init_access_token()
|
/ohos5.0/base/request/request/services/src/service/command/ |
H A D | subscribe.rs | 39 let token_id = ipc::Skeleton::calling_full_token_id(); in subscribe() localVariable 41 let (event, rx) = TaskManagerEvent::subscribe(task_id, token_id); in subscribe() 68 let ret = self.client_manager.subscribe(task_id, pid, uid, token_id); in subscribe()
|
H A D | get_task.rs | 52 let token_id = ipc::Skeleton::calling_full_token_id(); in get_task() localVariable 55 let ret = self.client_manager.subscribe(task_id, pid, uid, token_id); in get_task()
|
H A D | construct.rs | 98 let token_id = ipc::Skeleton::calling_full_token_id(); in construct() localVariable 222 token_id, in construct() 266 let ret = self.client_manager.subscribe(task_id, pid, uid, token_id); in construct()
|
/ohos5.0/foundation/communication/ipc/example/rust_test/service/src/ |
H A D | access_token.rs | 55 let token_id = GetAccessTokenId(&mut param as *mut TokenInfoParams); in init_access_token() localVariable 56 SetSelfTokenID(token_id); in init_access_token()
|
/ohos5.0/base/security/asset/test/unittest/module_test/src/crypto_manager/ |
H A D | lib.rs | 39 fn SetSelfTokenID(token_id: u64) -> i32; in SetSelfTokenID() 59 let token_id = GetAccessTokenId(&mut param as *mut TokenInfoParams); in grant_self_permission() localVariable 60 SetSelfTokenID(token_id) in grant_self_permission()
|
/ohos5.0/base/request/request/services/src/task/ |
H A D | ffi.rs | 61 pub(crate) token_id: u64, 289 token_id: self.common_data.token_id, in to_c_struct() 348 token_id: c_struct.common_data.token_id, in from_c_struct()
|
H A D | config.rs | 80 pub(crate) token_id: u64, 272 token_id: 0, in default()
|
/ohos5.0/foundation/ability/idl_tool/test/rust/moduletest/client/src/ |
H A D | main.rs | 75 let token_id = GetAccessTokenId(&mut param as *mut TokenInfoParams); in init_access_token() localVariable 76 SetSelfTokenID(token_id); in init_access_token()
|
/ohos5.0/foundation/ability/idl_tool/test/rust/moduletest/server/src/ |
H A D | main.rs | 58 let token_id = GetAccessTokenId(&mut param as *mut TokenInfoParams); in init_access_token() localVariable 59 SetSelfTokenID(token_id); in init_access_token()
|
/ohos5.0/base/request/request/services/src/manage/ |
H A D | task_manager.rs | 254 TaskEvent::Subscribe(task_id, token_id, tx) => { in handle_task_event() 255 let _ = tx.send(self.check_subscriber(task_id, token_id)); in handle_task_event() 297 fn check_subscriber(&self, task_id: u32, token_id: u64) -> ErrorCode { in check_subscriber() 299 Ok(id) if id == token_id => ErrorCode::ErrOk, in check_subscriber()
|
H A D | database.rs | 225 config.common_data.token_id, in insert_task() 426 token_id: 0, in get_task_config() 695 let token_id = 123456789; in ut_database_query_task_token_id() localVariable 699 task_id, token_id in ut_database_query_task_token_id() 703 assert_eq!(db.query_task_token_id(task_id).unwrap(), token_id); in ut_database_query_task_token_id()
|
/ohos5.0/base/request/request/services/src/service/client/ |
H A D | manager.rs | 84 ClientEvent::Subscribe(tid, pid, uid, token_id, tx) => { in run() 85 self.handle_subscribe(tid, pid, uid, token_id, tx) in run()
|
H A D | mod.rs | 68 pub(crate) fn subscribe(&self, tid: u32, pid: u64, uid: u64, token_id: u64) -> ErrorCode { in subscribe() 70 let event = ClientEvent::Subscribe(tid, pid, uid, token_id, tx); in subscribe()
|
/ohos5.0/base/request/request/services/src/manage/events/ |
H A D | mod.rs | 116 pub(crate) fn subscribe(task_id: u32, token_id: u64) -> (Self, Recv<ErrorCode>) { in subscribe() 119 Self::Task(TaskEvent::Subscribe(task_id, token_id, tx)), in subscribe()
|