| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | async_buf_read.rs | 53 Pin::new(&mut **self.get_mut()).poll_fill_buf(cx) in poll_fill_buf()
64 Pin::new(&mut **self.get_mut()).poll_fill_buf(cx) in poll_fill_buf()
79 self.get_mut().as_mut().poll_fill_buf(cx) in poll_fill_buf()
83 self.get_mut().as_mut().consume(amt) in consume()
|
| H A D | async_write.rs | 156 Pin::as_mut(self.get_mut()).poll_write(cx, buf) in poll_write()
164 Pin::as_mut(self.get_mut()).poll_write_vectored(cx, bufs) in poll_write_vectored()
172 Pin::as_mut(self.get_mut()).poll_flush(cx) in poll_flush()
176 Pin::as_mut(self.get_mut()).poll_shutdown(cx) in poll_shutdown()
|
| H A D | read_task.rs | 140 let me = self.get_mut(); in poll()
212 let me = self.get_mut(); in poll()
248 let this = self.get_mut(); in poll()
331 let me = self.get_mut(); in poll()
367 let me = self.get_mut(); in poll()
402 let me = self.get_mut(); in poll_next()
454 let me = self.get_mut(); in poll_next_line()
|
| H A D | write_task.rs | 178 let me = self.get_mut(); in poll()
203 let me = self.get_mut(); in poll()
|
| H A D | async_seek.rs | 54 self.get_mut().as_mut().poll_seek(cx, pos) in poll_seek()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | streams.rs | 265 if let Some(stream) = self.stream_map.get_mut(&id) { in release_stream_recv_window()
363 if let Some(stream) = self.stream_map.get_mut(&id) { in reassign_stream_send_window()
392 if let Some(stream) = self.stream_map.get_mut(&id) { in window_update_streams()
408 match self.stream_map.get_mut(&id) { in headers()
427 match self.stream_map.get_mut(&id) { in poll_read_body()
545 return match self.stream_map.get_mut(&id) { in send_local_reset()
570 match self.stream_map.get_mut(&id) { in send_headers_frame()
613 match self.stream_map.get_mut(&id) { in send_data_frame()
642 return match self.stream_map.get_mut(&id) { in recv_remote_reset()
662 match self.stream_map.get_mut(&id) { in recv_headers()
[all …]
|
| /ohos5.0/base/request/request/services/src/service/client/ |
| H A D | manager.rs | 92 if let Some((tx, _fd)) = self.clients.get_mut(&pid) { in run()
111 if let Some((tx, _fd)) = self.clients.get_mut(&pid) { in run()
157 if let Some(_client) = self.clients.get_mut(&pid) { in handle_subscribe()
169 if let Some(_client) = self.clients.get_mut(&pid) { in handle_unsubscribe()
191 if let Some((tx, _)) = self.clients.get_mut(&pid) { in handle_process_terminated()
|
| /ohos5.0/commonlibrary/rust/ylong_json/src/value/object/ |
| H A D | vec.rs | 197 pub fn get_mut(&mut self, key: &str) -> Option<&mut JsonValue> { in get_mut() method
210 self.inner.get_mut(index).map(|(_, v)| v) in get_mut_by_position()
317 object.get_mut("key1"), in ut_object_get_mut()
320 assert_eq!(object.get_mut("key2"), None); in ut_object_get_mut()
|
| H A D | linked_list.rs | 194 pub fn get_mut(&mut self, key: &str) -> Option<&mut JsonValue> { in get_mut() method
369 object.get_mut("key1"), in ut_object_get_mut()
372 assert_eq!(object.get_mut("key2"), None); in ut_object_get_mut()
|
| H A D | btree.rs | 188 pub fn get_mut(&mut self, key: &str) -> Option<&mut JsonValue> { in get_mut() method
189 self.inner.get_mut(key) in get_mut()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| H A D | slots.rs | 104 match self.entries.get_mut(tail) { in push_back()
131 if let Some(entry) = self.entries.get_mut(curr) { in pop_front()
137 match self.entries.get_mut(self.head) { in pop_front()
167 let entry = self.entries.get_mut(key).ok_or(SlotsError)?; in remove()
176 match self.entries.get_mut(prev) { in remove()
186 match self.entries.get_mut(next) { in remove()
259 match self.entries.get_mut(index) { in index_mut()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | async_file.rs | 68 let state = self.get_mut(); in poll()
381 let file = self.get_mut(); in poll_seek()
382 let inner = file.inner.get_mut(); in poll_seek()
434 let file = self.get_mut(); in poll_read()
435 let inner = file.inner.get_mut(); in poll_read()
498 let file = self.get_mut(); in poll_write()
499 let inner = file.inner.get_mut(); in poll_write()
541 self.inner.get_mut().poll_flush(cx) in poll_flush()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | c_ssl_stream.rs | 38 this.0.get_mut().context = ctx as *mut _ as *mut (); in with_context()
40 this.0.get_mut().context = ptr::null_mut(); in with_context()
47 unsafe { Pin::new_unchecked(&mut self.get_unchecked_mut().0.get_mut().stream) } in get_pin_mut()
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/ |
| H A D | operator.rs | 140 let fut = self.get_mut(); in poll()
159 let fut = self.get_mut(); in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_json/src/value/array/ |
| H A D | vec.rs | 168 pub fn get_mut(&mut self, index: usize) -> Option<&mut JsonValue> { in get_mut() method
169 self.inner.get_mut(index) in get_mut()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | operator.rs | 110 let fut = self.get_mut(); in poll()
128 let fut = self.get_mut(); in poll()
|
| /ohos5.0/base/request/request/services/src/task/ |
| H A D | files.rs | 207 pub(crate) fn get_mut(&self, index: usize) -> Option<&mut AsyncFile> { in get_mut() method
208 unsafe { &mut *self.0.get() }.get_mut(index) in get_mut()
|
| /ohos5.0/base/request/request/services/src/manage/events/ |
| H A D | stop.rs | 28 if let Some(count) = self.task_count.get_mut(&uid) { in stop()
|
| H A D | remove.rs | 28 if let Some(count) = self.task_count.get_mut(&uid) { in remove()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/tests/ |
| H A D | sdv_http_headers.rs | 47 let mut_value = headers.get_mut("key"); in sdv_client_send_request_repeatedly()
|
| /ohos5.0/commonlibrary/rust/ylong_json/src/value/ |
| H A D | index.rs | 110 array.get_mut(*self).unwrap() in index_into_mut()
235 return object.get_mut(self).unwrap(); in index_into_mut()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | mod.rs | 373 let fut = self.get_mut(); in poll()
399 let fut = self.get_mut(); in poll()
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
| H A D | operator.rs | 105 let fut = self.get_mut(); in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | task_cancel.rs | 75 let this = self.get_mut(); in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| H A D | operator.rs | 103 let fut = self.get_mut(); in poll()
|