Home
last modified time | relevance | path

Searched refs:as_ref (Results 1 – 25 of 75) sorted by relevance

123

/ohos5.0/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/stream_buffer/
H A Dffi.rs64 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferData()
79 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferSize()
145 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferRead()
163 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferChkRWError()
178 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferGetErrorStatusRemark()
285 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferReadBuf()
299 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferGetRcount()
313 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferGetWcount()
327 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferGetWpos()
341 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferGetRpos()
[all …]
H A Dnet_packet.rs84 fn as_ref<'a>(object: *const Self) -> Option<&'a Self> { in as_ref() method
87 object.as_ref() in as_ref()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/
H A Dasync_dir.rs60 let path = path.as_ref().to_owned(); in create_dir()
89 let path = path.as_ref().to_owned(); in create_dir_all()
119 let path = path.as_ref().to_owned(); in remove_dir()
145 let path = path.as_ref().to_owned(); in remove_dir_all()
172 let path = path.as_ref().to_owned(); in read_dir()
207 let path = path.as_ref().to_owned(); in remove_file()
238 let from = from.as_ref().to_owned(); in rename()
239 let to = to.as_ref().to_owned(); in rename()
274 let from = from.as_ref().to_owned(); in copy()
275 let to = to.as_ref().to_owned(); in copy()
[all …]
/ohos5.0/base/msdp/device_status/rust/frameworks/client/src/
H A Dframeworks.rs68 match self.ipc_client.as_ref() { in alloc_socket_pair()
82 match self.ipc_client.as_ref() { in start_drag()
97 match self.ipc_client.as_ref() { in register_coordination_listener()
111 match self.ipc_client.as_ref() { in unregister_coordination_listener()
125 match self.ipc_client.as_ref() { in enable_coordination()
139 match self.ipc_client.as_ref() { in disable_coordination()
155 match self.ipc_client.as_ref() { in start_coordination()
171 match self.ipc_client.as_ref() { in stop_coordination()
185 match self.ipc_client.as_ref() { in get_coordination_state()
211 FRAMEWORKS.as_ref() in get_instance()
/ohos5.0/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/stream_session/
H A Dffi.rs112 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetUid()
127 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetPid()
143 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetFd()
174 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetTokenType()
189 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetModuleType()
221 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionSendMsg()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Dencoder.rs157 match self.encode_frame(self.current_frame.as_ref(), buf) { in encode()
166 if let Some(frame) = self.current_frame.as_ref() { in encode()
199 match self.encode_frame(self.current_frame.as_ref(), buf) { in encode()
208 if let Some(frame) = self.current_frame.as_ref() { in encode()
237 match self.encode_frame(self.current_frame.as_ref(), buf) { in encode()
246 if let Some(frame) = self.current_frame.as_ref() { in encode()
263 match self.encode_frame(self.current_frame.as_ref(), buf) { in encode()
272 if let Some(frame) = self.current_frame.as_ref() { in encode()
316 match self.encode_frame(self.current_frame.as_ref(), buf) { in encode()
337 if let Some(frame) = self.current_frame.as_ref() { in encode()
[all …]
H A Doctets.rs55 let bytes: [u8; len] = <[u8; len]>::try_from(self.buf[..len].as_ref()).unwrap(); in into_u8()
71 let bytes: [u8; len] = <[u8; len]>::try_from(self.buf[..len].as_ref()).unwrap(); in into_u16()
87 let bytes: [u8; len] = <[u8; len]>::try_from(self.buf[..len].as_ref()).unwrap(); in into_u32()
103 let bytes: [u8; len] = <[u8; len]>::try_from(self.buf[..len].as_ref()).unwrap(); in into_u64()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/
H A Ddatabase.rs114 .as_ref() in generate_ids()
155 .as_ref() in insert()
202 .as_ref() in update()
245 .as_ref() in delete()
296 .as_ref() in query_values()
323 .as_ref() in lock()
350 .as_ref() in unlock()
374 .as_ref() in heartbeat()
H A Dasset.rs230 .as_ref() in download()
282 .as_ref() in upload()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dtask_handle.rs46 unsafe { self.task.as_ref().header() } in header()
50 unsafe { self.task.as_ref().inner() } in inner()
137 .as_ref() in set_waker()
305 let ffrt_task = unsafe { (*self.inner().task.get()).as_ref().unwrap() }; in ffrt_run()
334 let ffrt_task = unsafe { (*self.inner().task.get()).as_ref().unwrap() }; in ffrt_wake_by_ref()
348 let ffrt_task = unsafe { (*self.inner().task.get()).as_ref().unwrap() }; in ffrt_set_canceled()
H A Dwaker.rs44 let vir_tble = header.as_ref().vtable; in wake()
50 let vir_tble = header.as_ref().vtable; in wake_by_ref()
56 let vir_tble = header.as_ref().vtable; in drop()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
H A Dlinked_list.rs43 let prev = T::node(node).as_ref().prev; in remove_node()
44 let next = T::node(node).as_ref().next; in remove_node()
138 unsafe { L::node(self.head).as_ref().next == Some(self.head) } in is_empty()
149 let head = L::node(self.head).as_ref(); in drain_filtered()
154 let next = L::node(node).as_ref().next; in drain_filtered()
207 unsafe { ptr.as_ref().val } in get_val()
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/
H A Dmultipart.rs112 if let Some(name) = part.name.as_ref() { in total_bytes()
117 if let Some(name) = part.file_name.as_ref() { in total_bytes()
125 if let Some(mime) = part.mime.as_ref() { in total_bytes()
350 let body = body.as_ref().to_vec(); in body()
383 fn as_ref(&self) -> &MultiPart { in as_ref() method
/ohos5.0/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/
H A Depoll_manager.rs51 fn as_ref<'a>(object: *const Self) -> Option<&'a Self> { in as_ref() method
54 object.as_ref() in as_ref()
H A Dstream_session.rs53 fn as_ref<'a>(object: *const Self) -> Option<&'a Self> { in as_ref() method
56 object.as_ref() in as_ref()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Dasync_source.rs186 self.io.as_ref().unwrap().read(slice)
209 self.io.as_ref().unwrap().write(buf)
223 self.io.as_ref().unwrap().write_vectored(bufs)
240 self.io.as_ref().unwrap() in deref()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
H A Dwheel.rs221 let expiration = unsafe { clock_entry.as_ref().expiration() }; in insert()
240 let level = unsafe { clock_entry.as_ref().level() }; in cancel()
259 let expected_expiration = unsafe { item.as_ref().expiration() }; in process_expiration()
342 let duration = unsafe { clock_entry.as_ref().expiration() }; in insert()
357 let duration = unsafe { clock_entry.as_ref().duration() }; in cancel()
/ohos5.0/commonlibrary/rust/ylong_json/src/reader/
H A Dslice_reader.rs112 self.cache.as_ref().map(|c| self.index - c.0) in cached_len()
117 self.cache.as_ref().map(|c| &self.slice[c.0..self.index]) in cached_slice()
123 .as_ref() in cached_data()
338 assert_eq!(slice_reader.cache.as_ref().unwrap().0, 0); in ut_slice_reader_start_caching()
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/
H A Drequest.rs203 let value = format!("multipart/form-data; boundary={}", body.as_ref().boundary()); in multipart()
212 if let Some(size) = body.as_ref().total_bytes() { in multipart()
/ohos5.0/base/hiviewdfx/hisysevent/interfaces/rust/innerkits/src/
H A Dsys_event_manager.rs319 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()
/ohos5.0/foundation/multimodalinput/input/service/rust/src/
H A Dlib.rs170 unsafe { GLOBAL_CURVES.as_ref().unwrap() } in get_instance()
240 unsafe { GLOBAL_CURVES.as_ref().unwrap() } in get_instance()
310 unsafe { GLOBAL_CURVES.as_ref().unwrap() } in get_instance()
380 unsafe { GLOBAL_CURVES.as_ref().unwrap() } in get_instance()
450 unsafe { GLOBAL_CURVES.as_ref().unwrap() } in get_instance()
520 unsafe { GLOBAL_CURVES.as_ref().unwrap() } in get_instance()
545 unsafe { GLOBAL_CURVES.as_ref().unwrap() } in get_instance()
615 unsafe { GLOBAL_CURVES.as_ref().unwrap() } in get_instance()
/ohos5.0/base/msdp/device_status/rust/subsystem/dsoftbus/sys/src/
H A Ddsoftbus.rs118 let raw_ptr = self.as_ref() as *const dyn IDSoftbufCallback; in hash()
125 let self_data_ptr = self.as_ref() as *const dyn IDSoftbufCallback as *const (); in eq()
126 let other_data_ptr = other.as_ref() as *const dyn IDSoftbufCallback as *const (); in eq()
825 G_DSOFTBUS.as_ref() in get_instance()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/
H A Dsimple.rs112 if let Some(name) = part.name.as_ref() { in total_bytes()
117 if let Some(name) = part.file_name.as_ref() { in total_bytes()
125 if let Some(mime) = part.mime.as_ref() { in total_bytes()
380 let body = body.as_ref().to_vec(); in body()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/request/uri/
H A Dmod.rs131 self.scheme.as_ref() in scheme()
149 self.authority.as_ref() in authority()
165 self.authority.as_ref().map(|auth| auth.host()) in host()
181 self.authority.as_ref().and_then(|auth| auth.port()) in port()
197 self.path.as_ref() in path()
213 self.query.as_ref() in query()
688 self.port.as_ref() in port()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dmod.rs111 let runtime = match initialize_async_spawner(global_builder.as_ref().unwrap_unchecked()) in global_default_async()
142 match initialize_blocking_spawner(&global_builder.as_ref().unwrap_unchecked().common) { in global_default_blocking()

123