/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 poll_fill_buf()
|
H A D | async_seek.rs | 54 self.get_mut().as_mut().poll_seek(cx, pos) in poll_seek()
|
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(); 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 | 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_flush()
|
H A D | async_read.rs | 81 self.get_mut().as_mut().poll_read(cx, buf) in poll_read()
|
H A D | write_task.rs | 178 let me = self.get_mut(); in poll() 203 let me = self.get_mut(); in poll()
|
/commonlibrary/rust/ylong_json/src/value/object/ |
H A D | vec.rs | 194 /// assert_eq!(object.get_mut("null"), Some(&mut JsonValue::Null)); 195 /// assert_eq!(object.get_mut("no_such_key"), None); 197 pub fn get_mut(&mut self, key: &str) -> Option<&mut JsonValue> { in get_mut() functions 210 self.inner.get_mut(index).map(|(_, v)| v) 304 /// UT test for `Object::get_mut`. in fmt() 311 /// 2. Calls `Object::get_mut` on it. in fmt() 317 object.get_mut("key1"), in fmt() 320 assert_eq!(object.get_mut("key2"), None); in fmt()
|
H A D | btree.rs | 185 /// assert_eq!(object.get_mut("null"), Some(&mut JsonValue::Null)); 186 /// assert_eq!(object.get_mut("no_such_key"), None); 188 pub fn get_mut(&mut self, key: &str) -> Option<&mut JsonValue> { in get_mut() functions 189 self.inner.get_mut(key) in get_mut()
|
H A D | linked_list.rs | 191 /// assert_eq!(object.get_mut("null"), Some(&mut JsonValue::Null)); 192 /// assert_eq!(object.get_mut("no_such_key"), None); 194 pub fn get_mut(&mut self, key: &str) -> Option<&mut JsonValue> { in get_mut() functions 356 /// UT test for `Object::get_mut`. in fmt() 363 /// 2. Calls `Object::get_mut` on it. in fmt() 369 object.get_mut("key1"), in fmt() 372 assert_eq!(object.get_mut("key2"), None); in fmt()
|
/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()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
H A D | streams.rs | 274 if let Some(stream) = self.stream_map.get_mut(&id) { 375 if let Some(stream) = self.stream_map.get_mut(&id) { 404 if let Some(stream) = self.stream_map.get_mut(&id) { 420 match self.stream_map.get_mut(&id) { 439 match self.stream_map.get_mut(&id) { 471 let stream = if let Some(stream) = self.stream_map.get_mut(&id) { in poll_sized_data() 558 return match self.stream_map.get_mut(&id) { 583 match self.stream_map.get_mut(&id) { 626 match self.stream_map.get_mut(&id) { 655 return match self.stream_map.get_mut( [all...] |
H A D | input.rs | 73 let sender = self.get_mut(); in poll()
|
/commonlibrary/rust/ylong_json/src/value/array/ |
H A D | vec.rs | 165 /// assert_eq!(array.get_mut(0), Some(&mut JsonValue::Null)); 166 /// assert_eq!(array.get_mut(1), None); 168 pub fn get_mut(&mut self, index: usize) -> Option<&mut JsonValue> { in get_mut() functions 169 self.inner.get_mut(index) in get_mut()
|
/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()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
H A D | operator.rs | 103 let fut = self.get_mut(); in poll()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
H A D | streams.rs | 188 if let Some(stream) = self.bidirectional_stream.get_mut(&id) { 244 if let Some(stream) = self.bidirectional_stream.get_mut(&id) { 364 if let Some(stream) = self.bidirectional_stream.get_mut(&id) { 478 .get_mut(&id) 510 let Some(stream) = self.bidirectional_stream.get_mut(&id) else { 595 if let Some(stream) = self.bidirectional_stream.get_mut(&id) { 606 if let Some(stream) = self.bidirectional_stream.get_mut(&id) { 633 if let Some(stream) = self.bidirectional_stream.get_mut(&id) { 664 let Some(stream) = self.bidirectional_stream.get_mut(id) else {
|
H A D | io_manager.rs | 172 let this = self.get_mut(); in poll()
|
/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()
|
/commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
H A D | ylong_io_tcp_server.rs | 51 match connections.get_mut(&event.token()) { in main()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
H A D | stream.rs | 86 pub(crate) fn get_mut(&mut self) -> &mut S { 232 self.get_mut().flush() in flush()
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
H A D | async_buf_reader.rs | 115 /// let reader_ref = reader.get_mut(); 119 pub fn get_mut(&mut self) -> &mut R { in get_mut() functions
|
H A D | async_buf_writer.rs | 110 /// let writer_ref = writer.get_mut(); 114 pub fn get_mut(&mut self) -> &mut W { in get_mut() functions
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
H A D | alt_svc.rs | 47 let vec = lock.get_mut(key)?;
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
H A D | async_file.rs | 69 let state = self.get_mut(); in poll() 389 let file = self.inner.get_mut(); in fmt() 478 let file = self.get_mut(); in poll_seek() 479 let inner = file.inner.get_mut(); in poll_seek() 531 let file = self.get_mut(); in poll_read() 532 let inner = file.inner.get_mut(); in poll_read() 595 let file = self.get_mut(); in poll_write() 596 let inner = file.inner.get_mut(); in poll_write() 638 self.inner.get_mut().poll_flush(cx) in poll_flush()
|
/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()
|