| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| H A D | table.rs | 311 4 => Some(( in field()
330 30 => Some(( in field()
334 31 => Some(( in field()
338 32 => Some(( in field()
342 33 => Some(( in field()
346 34 => Some(( in field()
350 35 => Some(( in field()
354 36 => Some(( in field()
358 37 => Some(( in field()
362 38 => Some(( in field()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| H A D | table.rs | 52 (x @ Some(TableIndex::Header(_)), _) => x, in index()
53 (_, Some(TableIndex::Header(i))) => Some(TableIndex::Header(i + 62)), in index()
54 (x @ Some(TableIndex::HeaderName(_)), _) => x, in index()
55 (_, Some(TableIndex::HeaderName(i))) => Some(TableIndex::Header(i + 62)), in index()
243 1 => Some(Header::Authority), in header_name()
244 2..=3 => Some(Header::Method), in header_name()
245 4..=5 => Some(Header::Path), in header_name()
246 6..=7 => Some(Header::Scheme), in header_name()
247 8..=14 => Some(Header::Status), in header_name()
315 16 => Some(( in header()
[all …]
|
| H A D | decoder.rs | 64 Some(repr) => updater.update(repr)?, in decode()
350 { None, Some("GET"), None, None, None }, in ut_hpack_decoder()
361 { Some("www.example.com"), Some("GET"), Some("/"), Some("http"), None }, in ut_hpack_decoder()
369 { Some("www.example.com"), Some("GET"), Some("/"), Some("http"), None }, in ut_hpack_decoder()
378 … { Some("www.example.com"), Some("GET"), Some("/index.html"), Some("https"), None }, in ut_hpack_decoder()
391 { Some("www.example.com"), Some("GET"), Some("/"), Some("http"), None }, in ut_hpack_decoder()
399 { Some("www.example.com"), Some("GET"), Some("/"), Some("http"), None }, in ut_hpack_decoder()
408 … { Some("www.example.com"), Some("GET"), Some("/index.html"), Some("https"), None }, in ut_hpack_decoder()
425 { None, None, None, None, Some("302") }, in ut_hpack_decoder()
444 { None, None, None, None, Some("307") }, in ut_hpack_decoder()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | pseudo.rs | 259 pseudo.method = Some(String::from("method")); in ut_pseudo_headers_contains_method()
276 assert_eq!(pseudo.method(), Some("method")); in ut_pseudo_headers_method()
291 assert_eq!(pseudo.method(), Some("method")); in ut_pseudo_headers_set_method()
325 pseudo.path = Some(String::from("path")); in ut_pseudo_headers_contains_path()
341 pseudo.path = Some(String::from("path")); in ut_pseudo_headers_path()
342 assert_eq!(pseudo.path(), Some("path")); in ut_pseudo_headers_path()
356 pseudo.set_path(Some(String::from("path"))); in ut_pseudo_headers_set_path()
357 assert_eq!(pseudo.path(), Some("path")); in ut_pseudo_headers_set_path()
375 pseudo.path = Some(String::from("path")); in ut_pseudo_headers_take_path()
409 assert_eq!(pseudo.scheme(), Some("scheme")); in ut_pseudo_headers_scheme()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | pseudo.rs | 258 pseudo.method = Some(String::from("method")); in ut_pseudo_headers_contains_method()
275 assert_eq!(pseudo.method(), Some("method")); in ut_pseudo_headers_method()
290 assert_eq!(pseudo.method(), Some("method")); in ut_pseudo_headers_set_method()
324 pseudo.path = Some(String::from("path")); in ut_pseudo_headers_contains_path()
340 pseudo.path = Some(String::from("path")); in ut_pseudo_headers_path()
341 assert_eq!(pseudo.path(), Some("path")); in ut_pseudo_headers_path()
355 pseudo.set_path(Some(String::from("path"))); in ut_pseudo_headers_set_path()
356 assert_eq!(pseudo.path(), Some("path")); in ut_pseudo_headers_set_path()
374 pseudo.path = Some(String::from("path")); in ut_pseudo_headers_take_path()
408 assert_eq!(pseudo.scheme(), Some("scheme")); in ut_pseudo_headers_scheme()
[all …]
|
| /ohos5.0/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/stream_buffer/ |
| H A D | ffi.rs | 64 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferData()
79 if let Some(obj) = StreamBuffer::as_ref(object) { in StreamBufferSize()
94 if let Some(obj) = StreamBuffer::as_mut(object) { in StreamBufferReset()
110 if let Some(obj) = StreamBuffer::as_mut(object) { in StreamBufferClean()
126 if let Some(obj) = StreamBuffer::as_mut(object) { in StreamBufferWrite()
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()
193 if let Some(obj) = StreamBuffer::as_mut(object) { in StreamBufferWriteChar()
208 if let Some(obj) = StreamBuffer::as_mut(object) { in StreamBufferCheckWrite()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/request/uri/ |
| H A D | mod.rs | 274 Some(builder) in path_and_query()
991 Some((index, _)) in scheme_token()
1172 (None, Some(_), Some(_), _) => Err(InvalidUri::UriMissScheme), in validity_check()
1173 (None, Some(_), _, Some(_)) => Err(InvalidUri::UriMissScheme), in validity_check()
1516 Some("/"), in ut_uri_from_bytes()
1526 Some("80"), in ut_uri_from_bytes()
1567 Ok((Some("https"), Some("www.example.com"), None, None, None)), in ut_uri_from_bytes()
1583 Ok((Some("https"), Some("www.example.com"), None, None, None)), in ut_uri_from_bytes()
1588 Ok((Some("https"), Some("www.example.com"), None, None, None)), in ut_uri_from_bytes()
1598 Ok((None, None, None, Some("/foo"), Some("a=1"))), in ut_uri_from_bytes()
[all …]
|
| H A D | percent_encoding.rs | 71 while let Some(char) = origin.next() { in parse_scheme()
111 while let Some(ch) = chars.next() { in parse_userinfo()
126 Some((0, remaining)) => { in parse_userinfo()
132 Some(at) => at, in parse_userinfo()
138 if let Some(ch) = origin.next_u8() { in parse_userinfo()
154 let c = if let Some(ch) = origin.next() { in parse_authority()
202 Some('?') => { in parse_query_and_fragment()
207 Some('#') => { in parse_query_and_fragment()
233 while let Some(utf8) = origin.next_u8() { in parse_fragment()
398 Some(InvalidUri::InvalidScheme.into()) in url_percent_encode_failure()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| H A D | encoder.rs | 90 while let Some((h, v)) = iter.next() { in encode()
313 Some(TableIndex::Field(x)) => { in should_index()
319 Some(TableIndex::FieldName(x)) => { in should_index()
629 if let Some(i) = $item.take() {
633 $item = Some(e);
767 *ins_state = Some(state); in decode()
935 Some(value) => return Some((Field::Method, value)), in next()
939 Some(value) => return Some((Field::Status, value)), in next()
943 Some(value) => return Some((Field::Scheme, value)), in next()
947 Some(value) => return Some((Field::Path, value)), in next()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_json/src/ |
| H A D | states.rs | 26 Ok(Some(ch)) => {
114 Some(T_LOWER) => { in parse_value()
119 Some(F_LOWER) => { in parse_value()
124 Some(N_LOWER) => { in parse_value()
234 Some(ch) => { in parse_string_inner()
373 Some(ZERO) => { in parse_number()
379 Some(ONE..=NINE) => { in parse_number()
411 Some(_) => {} in parse_number()
500 Some(x) => x, in read_error_char()
510 Some(y) => y, in read_error_char()
[all …]
|
| H A D | linked_list.rs | 88 Some(node.into_element()) in pop_back()
200 Some(node) in back_node_mut()
341 Some(&node.element) in next()
348 (self.len, Some(self.len)) in size_hint()
366 Some(&node.element) in next_back()
390 Some(&mut node.element) in next()
397 (self.len, Some(self.len)) in size_hint()
416 Some(&mut node.element) in next_back()
437 Some(self.index) in index()
505 Some(self.index) in index()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
| H A D | error.rs | 44 Some(InternalError::Io(e)) => Ok(e), in into_io_error()
51 Some(InternalError::Io(ref e)) => Some(e), in get_io_error()
60 Some(InternalError::Io(ref e)) => Some(e), in source()
61 Some(InternalError::Ssl(ref e)) => Some(e), in source()
62 Some(InternalError::User(ref e)) => Some(e), in source()
160 HandshakeError::SetupFailure(ref e) => Some(e), in source()
213 internal: Some(InternalError::Io(io::Error::from( in ut_ssl_error_into_io_error()
236 internal: Some(InternalError::Io(io::Error::from( in ut_ssl_error_source()
270 internal: Some(InternalError::Io(io::Error::from( in ut_ssl_error_fmt()
278 internal: Some(InternalError::Io(io::Error::from( in ut_ssl_error_fmt()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_json/src/reader/ |
| H A D | io_reader.rs | 92 if let Some(ref mut cacher) = self.cache { in load()
106 if let Some(ref mut cacher) = self.cache { in update_cache()
140 Ok(Some(ch)) in next()
152 Ok(Some(self.buf[self.cur])) in peek()
189 if let Some(ref mut cacher) = self.cache { in start_caching()
195 self.cache = Some(cache); in start_caching()
488 assert_eq!(io_reader.cached_len(), Some(0)); in ut_io_reader_start_caching()
491 assert_eq!(io_reader.cached_len(), Some(1)); in ut_io_reader_start_caching()
493 assert_eq!(io_reader.cached_len(), Some(0)); in ut_io_reader_start_caching()
513 assert_eq!(io_reader.cached_len(), Some(0)); in ut_io_reader_cached_len()
[all …]
|
| H A D | slice_reader.rs | 60 Ok(Some(ch)) in next()
68 Ok(Some(self.slice[self.index])) in peek()
107 self.cache = Some(Cache(self.index)); in start_caching()
164 Ok(Some(result)) in next_n()
171 Ok(Some(&self.slice[self.index..self.index + n])) in peek_n()
219 assert_eq!(slice_reader.next(), Ok(Some(b'A'))); in ut_slice_reader_next()
238 assert_eq!(slice_reader.peek(), Ok(Some(b'A'))); in ut_slice_reader_peek()
239 assert_eq!(slice_reader.peek(), Ok(Some(b'A'))); in ut_slice_reader_peek()
240 assert_eq!(slice_reader.next(), Ok(Some(b'A'))); in ut_slice_reader_peek()
301 assert_eq!(slice_reader.next(), Ok(Some(b'A'))); in ut_slice_reader_position()
[all …]
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
| H A D | multipart.rs | 112 if let Some(name) = part.name.as_ref() { in total_bytes()
125 if let Some(mime) = part.mime.as_ref() { in total_bytes()
134 Some(size) in total_bytes()
147 if let Some(ref name) = part.name { in build_status()
161 if let Some(ref mime) = part.mime { in build_status()
169 if let Some(body) = part.body.take() { in build_status()
286 self.name = Some(String::from(name)); in name()
318 self.mime = Some(String::from(mime)); in mime()
351 self.length = Some(body.len() as u64); in body()
405 if let Some(mut state) = self.curr.take() { in poll_read_curr()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| H A D | encoder.rs | 75 if let Some(state) = self.state.take() { in encode()
80 self.state = Some(state); in encode()
114 self.iter = Some(iter); in encode()
185 Some(value) => return Some((Header::Method, value)), in next()
189 Some(value) => return Some((Header::Status, value)), in next()
193 Some(value) => return Some((Header::Scheme, value)), in next()
197 Some(value) => return Some((Header::Path, value)), in next()
201 Some(value) => return Some((Header::Authority, value)), in next()
401 if let Some(i) = $item.take() {
405 $item = Some(e);
[all …]
|
| /ohos5.0/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/stream_session/ |
| H A D | ffi.rs | 64 if let Some(obj) = StreamSession::as_mut(object) { in StreamSessionSetUid()
80 if let Some(obj) = StreamSession::as_mut(object) { in StreamSessionSetFd()
96 if let Some(obj) = StreamSession::as_mut(object) { in StreamSessionSetPid()
112 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()
158 if let Some(obj) = StreamSession::as_mut(object) { in StreamSessionSetTokenType()
174 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetTokenType()
189 if let Some(obj) = StreamSession::as_ref(object) { in StreamSessionGetModuleType()
204 if let Some(obj) = StreamSession::as_mut(object) { in StreamSessionClose()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h1/response/ |
| H A D | decoder.rs | 138 Some(unparsed) => $buffer = unparsed,
150 return Ok(Some($buffer));
262 self.status_code = Some( in status_code_phase()
302 self.headers = Some(headers); in header_phase_with_init()
333 Some(unparsed) => { in blank_line_phase()
349 Ok(Some(unparsed)) in decode_status_crlf()
468 Ok(Some(unparsed)) in decode_key()
506 Ok(Some(unparsed)) in decode_value()
524 Ok(Some(unparsed)) in decode_crlf()
550 return Ok(Some(&buffer[i..])); in decode_reason()
[all …]
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/state/ |
| H A D | recorder.rs | 48 if let Some(top_uid) = top_uid { in init()
63 Some(RssCapacity::new(rss_level)) in update_rss_level()
74 Some(sql_list) in update_network()
90 Some(sql_list) in update_accounts()
97 self.top_uid = Some(uid); in update_top_uid()
98 Some(sql_list) in update_top_uid()
102 if let Some(uid) = self.top_uid { in update_background()
109 if self.top_uid == Some(uid) { in update_background_timeout()
115 Some(sql_list) in update_background_timeout()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/ |
| H A D | common_builder.rs | 102 self.common.worker_name = Some(name);
123 self.common.after_start = Some(Arc::new(f));
132 self.common.before_stop = Some(Arc::new(f));
151 self.common.max_blocking_pool_size = Some(1);
153 self.common.max_blocking_pool_size = Some(64);
155 self.common.max_blocking_pool_size = Some(max_blocking_pool_size);
163 self.common.keep_alive_time = Some(keep_alive_time);
171 self.common.stack_size = Some(1);
173 self.common.stack_size = Some(stack_size);
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| H A D | slots.rs | 34 data: Some(val), in new()
101 self.entries[key].data = Some(val); in push_back()
108 Some(entry) => { in push_back()
141 Some(head) => { in pop_front()
180 Some(slot) => { in remove()
190 Some(slot) => { in remove()
248 Some(entry) => match entry.data { in index()
249 Some(ref val) => val, in index()
261 Some(ref mut val) => val, in index_mut()
298 return Some((head, val)); in next()
[all …]
|
| H A D | linked_list.rs | 47 Some(prev) => T::node(prev).as_mut().next = next, in remove_node()
55 Some(node) in remove_node()
88 node.prev = Some(head_ptr); in new()
89 node.next = Some(head_ptr); in new()
98 L::node(val).as_mut().prev = Some(self.head); in push_front()
100 let node = Some(val); in push_front()
101 if let Some(first) = head.next { in push_front()
112 if head.prev != Some(self.head) { in pop_back()
116 Some(node) in pop_back()
151 while p != Some(self.head) { in drain_filtered()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| H A D | simple.rs | 134 Some(size) in total_bytes()
147 if let Some(ref name) = part.name { in build_status()
161 if let Some(ref mime) = part.mime { in build_status()
316 self.name = Some(String::from(name)); in name()
348 self.mime = Some(String::from(mime)); in mime()
381 self.length = Some(body.len() as u64); in body()
446 Some(state) => state, in poll_read_curr()
657 assert_eq!(part.length, Some(4)); in ut_part_set()
660 assert_eq!(part.length, Some(8)); in ut_part_set()
697 Some( in ut_multipart_set()
[all …]
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/ |
| H A D | config.rs | 57 Self(Some(Duration::from_secs(secs))) in from_secs()
240 .map_err(|e| HttpClientError::new_with_cause(ErrorKind::Build, Some(e))), in http()
257 .map_err(|e| HttpClientError::new_with_cause(ErrorKind::Build, Some(e))), in https()
274 .map_err(|e| HttpClientError::new_with_cause(ErrorKind::Build, Some(e))), in all()
325 Ok(Proxy(Some(self.0?))) in build()
367 HttpClientError::new_with_cause(ErrorKind::Build, Some(InvalidCertificate)) in from_pem()
372 Some(size) => size, in from_pem()
377 Some(size) => size, in from_pem()
383 .map_err(|e| HttpClientError::new_with_cause(ErrorKind::Build, Some(e)))?; in from_pem()
391 Some(InvalidCertificate), in from_pem()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http2.rs | 165 if let Some(te_ref) = headers.get("te") { in remove_connection_specific_headers()
177 Some(scheme) => { in build_pseudo_headers()
187 .or_else(|| Some(String::from("/"))), in build_pseudo_headers()
247 text_io.remain = Some(frame); in match_channel_message()
249 Some(Poll::Ready(Ok(()))) in match_channel_message()
260 Some(Poll::Ready(Ok(()))) in match_channel_message()
269 Some(Poll::Ready(Ok(()))) in match_channel_message()
282 Poll::Pending => Some(Poll::Pending), in match_channel_message()
295 Some(Poll::Ready(Ok(()))) in end_read()
300 Some(Poll::Ready(Ok(()))) in end_read()
[all …]
|