Searched refs:as_ref (Results 1 – 14 of 14) sorted by relevance
70 FRAMEWORKS.as_ref() in get_instance()101 match self.ipc_client.as_ref() { in alloc_socket_pair()115 match self.ipc_client.as_ref() { in start_drag()130 match self.ipc_client.as_ref() { in register_coordination_listener()144 match self.ipc_client.as_ref() { in unregister_coordination_listener()158 match self.ipc_client.as_ref() { in enable_coordination()172 match self.ipc_client.as_ref() { in disable_coordination()187 match self.ipc_client.as_ref() { in start_coordination()204 match self.ipc_client.as_ref() { in stop_coordination()219 match self.ipc_client.as_ref() { in get_coordination_state()
62 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferData()77 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferSize()125 if let Some(buffer) = StreamBuffer::as_ref(buf) { in StreamBufferWrite()143 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferRead()161 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferChkRWError()176 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferGetErrorStatusRemark()283 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferReadBuf()297 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferGetRcount()311 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferGetWcount()325 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferGetWpos()[all …]
84 fn as_ref<'a>(object: *const Self) -> Option<&'a Self> { in as_ref() method87 object.as_ref() in as_ref()
110 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetUid()125 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetPid()141 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetFd()172 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetTokenType()187 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetModuleType()219 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionSendMsg()
53 fn as_ref<'a>(object: *const Self) -> Option<&'a Self> { in as_ref() method56 object.as_ref() in as_ref()
85 fn as_ref<'a>(object: *const Self) -> Option<&'a Self> { in as_ref() method88 object.as_ref() in as_ref()
65 if let Some(obj) = EpollManager::as_ref(object) { in StreamSocketGetFd()
319 let callback = (callback as *const F).as_ref().unwrap(); in on_query_callback()335 let callback = (callback as *const F).as_ref().unwrap(); in on_complete_callback()471 let callback = (callback as *const F).as_ref().unwrap(); in on_event()486 let callback = (callback as *const F).as_ref().unwrap(); in on_service_died()
76 FUSION_SERVICE_PROXY.as_ref() in get_instance()
149 let front_task = task_manager.global_front_task.as_ref(); in dump_all_task_info()216 self.event_cb.as_ref().unwrap()(event, notify_data); in front_notify()227 } else if uid != *self.front_app_uid.as_ref().unwrap() { in is_front_app()705 if let Some(front_task) = self.global_front_task.as_ref() { in query_one_task()723 if let Some(front_task) = self.global_front_task.as_ref() { in query_all_task()785 task_manager.info_cb.as_ref().unwrap()(&task_info); in remove_task_from_map()862 if uid as u64 != task_manager.global_front_task.as_ref().unwrap().uid { in update_app_state()
559 file.as_ref().write(HELP_MSG.as_bytes()); in dump()564 file.as_ref().write("invalid args".as_bytes()); in dump()576 Err(_) => { file.as_ref().write("-t accept a number".as_bytes()); } in dump()580 file.as_ref().write("too many args, -t accept no arg or one arg".as_bytes()); in dump()
500 let mut file = file.as_ref(); in dump_all_task_info()515 let mut file = file.as_ref(); in dump_one_task_info()
1123 let response = task.client.as_ref().unwrap().request(request).await; in download_inner()1237 let response = task.client.as_ref().unwrap().request(request.unwrap()).await; in upload_one_file()