| /ohos5.0/base/request/request/services/src/task/ |
| H A D | reason.rs | 19 #[repr(u8)]
122 assert_eq!(Reason::Default.repr, 0); in ut_enum_reason()
125 assert_eq!(Reason::UserOperation.repr, 5); in ut_enum_reason()
132 assert_eq!(Reason::RequestError.repr, 14); in ut_enum_reason()
136 assert_eq!(Reason::IoError.repr, 18); in ut_enum_reason()
138 assert_eq!(Reason::OthersError.repr, 20); in ut_enum_reason()
140 assert_eq!(Reason::Dns.repr, 23); in ut_enum_reason()
141 assert_eq!(Reason::Tcp.repr, 24); in ut_enum_reason()
142 assert_eq!(Reason::Ssl.repr, 25); in ut_enum_reason()
144 assert_eq!(Reason::NetworkApp.repr, 27); in ut_enum_reason()
[all …]
|
| H A D | info.rs | 60 #[repr(C)]
89 #[repr(u8)]
199 assert_eq!(State::Waiting.repr, 16); in ut_enum_state()
200 assert_eq!(State::Running.repr, 32); in ut_enum_state()
201 assert_eq!(State::Retrying.repr, 33); in ut_enum_state()
202 assert_eq!(State::Paused.repr, 48); in ut_enum_state()
203 assert_eq!(State::Stopped.repr, 49); in ut_enum_state()
204 assert_eq!(State::Completed.repr, 64); in ut_enum_state()
205 assert_eq!(State::Failed.repr, 65); in ut_enum_state()
206 assert_eq!(State::Removed.repr, 80); in ut_enum_state()
[all …]
|
| H A D | config.rs | 33 #[repr(u8)]
45 #[repr(u8)]
57 #[repr(u8)]
65 #[repr(u8)]
75 #[repr(C)]
477 assert_eq!(Action::Download.repr, 0); in ut_enum_action()
478 assert_eq!(Action::Upload.repr, 1); in ut_enum_action()
479 assert_eq!(Action::Any.repr, 2); in ut_enum_action()
484 assert_eq!(Mode::BackGround.repr, 0); in ut_enum_mode()
485 assert_eq!(Mode::FrontEnd.repr, 1); in ut_enum_mode()
[all …]
|
| H A D | ffi.rs | 30 #[repr(C)]
57 #[repr(C)]
79 #[repr(C)]
90 reason: self.reason.repr, in to_c_struct()
104 #[repr(C)]
136 #[repr(C)]
184 || (c_struct.progress.common_data.state != State::Completed.repr in from_c_struct()
185 && c_struct.progress.common_data.state != State::Failed.repr) in from_c_struct()
230 #[repr(C)]
290 action: self.common_data.action.repr, in to_c_struct()
[all …]
|
| H A D | notify.rs | 43 #[repr(C)]
60 #[repr(C)]
72 state: State::Initialized.repr, in new()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/ |
| H A D | sql.rs | 21 State::Waiting.repr, in start_task()
25 State::Paused.repr, in start_task()
27 State::Failed.repr, in start_task()
28 State::Stopped.repr, in start_task()
35 State::Paused.repr, in pause_task()
38 State::Running.repr, in pause_task()
40 State::Waiting.repr, in pause_task()
47 State::Stopped.repr, in stop_task()
50 State::Running.repr, in stop_task()
52 State::Waiting.repr, in stop_task()
[all …]
|
| H A D | mod.rs | 126 if (is_resume && info.progress.common_data.state != State::Paused.repr) in start_inner()
127 || (!is_resume && info.progress.common_data.state == State::Paused.repr) in start_inner()
207 if info.state != State::Running.repr && info.state != State::Waiting.repr { in task_completed()
290 if info.state != State::Running.repr && info.state != State::Waiting.repr { in task_failed()
333 reason.repr as i32 in sys_event()
445 if info.progress.common_data.state == state.repr { in change_status()
468 if info.progress.common_data.state != state.repr { in change_status()
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | query.rs | 205 State::Removed.repr, in ut_search_user()
207 Action::Upload.repr, in ut_search_user()
208 Mode::BackGround.repr in ut_search_user()
216 mode: Mode::Any.repr, in ut_search_user()
226 mode: Mode::Any.repr, in ut_search_user()
256 mode: Mode::Any.repr, in ut_search_user()
283 State::Removed.repr, in ut_search_system()
285 Action::Download.repr, in ut_search_system()
286 Mode::BackGround.repr in ut_search_system()
294 mode: Mode::Any.repr, in ut_search_system()
[all …]
|
| H A D | mod.rs | 103 State::Waiting.repr in ut_manager_task_state_and_reason()
113 State::Paused.repr in ut_manager_task_state_and_reason()
123 State::Waiting.repr in ut_manager_task_state_and_reason()
133 State::Paused.repr in ut_manager_task_state_and_reason()
143 State::Waiting.repr in ut_manager_task_state_and_reason()
153 State::Stopped.repr in ut_manager_task_state_and_reason()
163 State::Waiting.repr in ut_manager_task_state_and_reason()
222 State::Removed.repr in ut_manager_state_change_error()
233 State::Removed.repr in ut_manager_state_change_error()
246 State::Removed.repr in ut_manager_state_change_error()
[all …]
|
| H A D | database.rs | 253 Reason::Default.repr, in insert_task()
291 State::Failed.repr, in clear_invalid_records()
292 State::Waiting.repr, in clear_invalid_records()
293 Reason::Default.repr, in clear_invalid_records()
319 state.repr, in update_task_state()
321 reason.repr, in update_task_state()
549 State::Waiting.repr, in get_app_task_qos_infos()
551 State::Running.repr, in get_app_task_qos_infos()
552 State::Retrying.repr, in get_app_task_qos_infos()
716 Action::Download.repr, in ut_database_app_task_qos_info()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| H A D | decoder.rs | 67 DecResult::Decoded(repr) => Ok(Some(repr)), in decode()
181 DecResult::Decoded((repr, 0)) => NameString::new(repr).decode(buf), in decode()
193 repr: PrefixBit, field
221 repr: PrefixBit, field
317 repr: PrefixBit, field
520 repr: PrefixBit, field
789 DecResult::Decoded(repr) => match repr { in ut_finish_decode()
801 DecResult::Decoded(repr) => match repr { in ut_finish_decode()
813 DecResult::Decoded(repr) => match repr { in ut_finish_decode()
825 DecResult::Decoded(repr) => match repr { in ut_finish_decode()
[all …]
|
| H A D | encoder.rs | 592 let repr = ReprEncodeState::Indexed(Indexed::new(42)); in ut_repr_encode_state_encode() localVariable
593 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
597 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
600 let repr = ReprEncodeState::IndexingWithName(IndexingWithName::new( in ut_repr_encode_state_encode() localVariable
605 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
608 let repr = ReprEncodeState::WithoutIndexing(WithoutIndexing::new( in ut_repr_encode_state_encode() localVariable
613 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
621 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
624 let repr = in ut_repr_encode_state_encode() localVariable
626 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | winapi.rs | 195 #[repr(C)]
204 #[repr(C)]
211 #[repr(C)]
218 #[repr(C)]
227 #[repr(C)]
235 #[repr(C)]
246 #[repr(C)]
253 #[repr(C)]
260 #[repr(C)]
267 #[repr(C)]
[all …]
|
| /ohos5.0/base/request/request/services/src/service/command/ |
| H A D | dump.rs | 89 info.task_id, info.action.repr, info.state.repr, info.reason.repr in dump_all_task_info()
124 task.action.repr, in dump_one_task_info()
125 task.state.repr, in dump_one_task_info()
126 task.reason.repr in dump_one_task_info()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/state/ |
| H A D | sql.rs | 22 const RUNNING: u8 = State::Running.repr;
23 const RETRYING: u8 = State::Retrying.repr;
24 const WAITING: u8 = State::Waiting.repr;
25 const PAUSED: u8 = State::Paused.repr;
26 const STOPPED: u8 = State::Stopped.repr;
27 const FAILED: u8 = State::Failed.repr;
39 const DOWNLOAD: u8 = Action::Download.repr;
40 const UPLOAD: u8 = Action::Upload.repr;
42 const BACKGROUND: u8 = Mode::BackGround.repr;
43 const FRONTEND: u8 = Mode::FrontEnd.repr;
[all …]
|
| /ohos5.0/base/msdp/device_status/rust/subsystem/input/sys/src/ |
| H A D | input_binding.rs | 21 #[repr(C)]
28 #[repr(C)]
35 #[repr(C)]
42 #[repr(C)]
53 #[repr(C)]
|
| /ohos5.0/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/stream_buffer/ |
| H A D | net_packet.rs | 27 #[repr(packed(1))]
28 #[repr(C)]
35 #[repr(C)]
61 #[repr(C)]
68 #[repr(C)]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| H A D | error.rs | 21 repr: Repr, field
26 std::fmt::Debug::fmt(&self.repr, f) in fmt()
32 match self.repr { in fmt()
106 repr: Repr::Simple(kind), in from()
134 repr: Repr::Custom(Box::new(Custom { kind, error })), in _new()
158 match self.repr { in into_inner()
181 match self.repr { in kind()
|
| /ohos5.0/base/security/asset/services/crypto_manager/src/ |
| H A D | lib.rs | 24 #[repr(C)]
30 #[repr(C)]
36 #[repr(C)]
|
| /ohos5.0/base/msdp/device_status/rust/subsystem/dsoftbus/sys/src/ |
| H A D | binding.rs | 45 #[repr(C)]
56 #[repr(C)]
73 #[repr(C)]
82 #[repr(C)]
120 #[repr(C)]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_ffrt/src/ |
| H A D | lib.rs | 26 #[repr(C)]
46 #[repr(C)]
53 #[repr(C)]
|
| /ohos5.0/base/request/request/services/src/manage/events/ |
| H A D | stop.rs | 24 if info.state == State::Running.repr in stop()
25 || info.state == State::Retrying.repr in stop()
26 || info.state == State::Waiting.repr in stop()
|
| H A D | remove.rs | 24 if info.state != State::Failed.repr in remove()
25 && info.state != State::Completed.repr in remove()
26 && info.state != State::Removed.repr in remove()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| H A D | decoder.rs | 65 DecResult::Decoded((buf_index, repr)) => Ok(Some((buf_index, repr))), in decode()
105 DecResult::Decoded((buf_index, repr)) => { in decode()
107 return Ok(Some((buf_index, repr))); in decode()
110 Ok(Some((buf_index, repr))) in decode()
119 if let DecResult::Decoded((cnt, repr)) = $res {
120 return DecResult::Decoded((cnt + $buf_index, repr));
786 repr: ReprPrefixBit, field
793 fn new(repr: ReprPrefixBit, mid_bit: MidBit, name: Name) -> Self { in new()
794 Self::from_inner(repr, mid_bit, name, LengthFirstByte.into()) in new()
799 repr, in from_inner()
[all …]
|
| /ohos5.0/base/msdp/device_status/rust/subsystem/distributed_hardware/sys/src/ |
| H A D | dm_binding.rs | 35 #[repr(C)]
49 #[repr(C)]
66 #[repr(C)]
|