Home
last modified time | relevance | path

Searched refs:u8 (Results 1 – 25 of 49) sorted by relevance

12

/developtools/hdc/hdc_rust/src/serializer/
Dnative_struct.rs21 pub auth_type: u8,
32 pub check_sum: u8,
33 pub v_code: u8,
38 pub flag: [u8; 2],
39 pub reserve: [u8; 2],
40 pub protocol_ver: u8,
48 pub flag: [u8; 2],
60 pub flag: [u8; 2],
61 pub option: u8,
75 pub compress_type: u8,
[all …]
Dpack_assemble.rs27 fn calc_check_sum(data: &[u8]) -> u8 { in calc_check_sum() argument
31 pub fn unpack_payload_head(data: Vec<u8>) -> io::Result<native_struct::PayloadHead> { in unpack_payload_head()
44 pub fn unpack_payload_protect(data: Vec<u8>) -> io::Result<native_struct::PayloadProtect> { in unpack_payload_protect()
56 pub fn concat_pack(task_message: TaskMessage) -> Vec<u8> { in concat_pack() argument
58 let check_sum: u8 = if ENABLE_IO_CHECK { in concat_pack()
74 protocol_ver: VER_PROTOCOL as u8, in concat_pack()
Dserialize.rs48 pub bytes: Vec<u8>,
80 fn serialize(&self) -> Vec<u8>; in serialize() argument
81 fn parse(&mut self, _: Vec<u8>) -> io::Result<()> { in parse()
87 fn serialize(&self) -> Vec<u8> { in serialize() argument
93 fn serialize(&self) -> Vec<u8> { in serialize() argument
110 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse()
143 fn serialize(&self) -> Vec<u8> { in serialize() argument
154 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse()
178 fn serialize(&self) -> Vec<u8> { in serialize() argument
193 update_if_new: self.update_if_new as u8, in serialize()
[all …]
/developtools/profiler/hiebpf/include/
Dvmlinux.h30 typedef __u8 u8; typedef
237 u8 locked;
238 u8 pending;
253 u8 wlocked;
254 u8 __lstate[3];
568 u8 state;
569 u8 is_rel;
570 u8 is_soft;
571 u8 is_hard;
637 u8 blocked;
[all …]
/developtools/hdc/hdc_rust/src/daemon/
Ddaemon_app.rs36 pub result_msg: Vec<u8>,
88 async fn do_app_check(session_id: u32, channel_id: u32, _payload: &[u8]) -> bool { in do_app_check()
119 payload: Vec::<u8>::new(), in put_file_begin()
127 mode: u8, in put_app_finish() argument
128 exit_status: u8, in put_app_finish() argument
129 result: &mut [u8], in put_app_finish() argument
131 let mut msg = Vec::<u8>::new(); in put_app_finish()
147 async fn app_uninstall(session_id: u32, channel_id: u32, _payload: &[u8]) { in app_uninstall() argument
167 result: Result<Vec<u8>, Error>, in handle_execute_result() argument
168 mode: u8, in handle_execute_result() argument
[all …]
Ddaemon_unity.rs43 async fn echo_device_mode_result(session_id: u32, channel_id: u32, result: bool, message: Vec<u8>) { in echo_device_mode_result() argument
56 async fn echo_reboot_result(session_id: u32, channel_id: u32, result: bool, message: Vec<u8>) { in echo_reboot_result() argument
70 message: Vec<u8>, in echo_root_run_mode_result() argument
99 async fn set_root_run(session_id: u32, channel_id: u32, _payload: &[u8]) { in set_root_run() argument
121 async fn reboot_device(session_id: u32, channel_id: u32, _payload: &[u8]) { in reboot_device() argument
154 async fn set_device_mode(session_id: u32, channel_id: u32, _payload: &[u8]) { in set_device_mode() argument
222 async fn do_jdwp_track(session_id: u32, channel_id: u32, payload: &[u8]) { in do_jdwp_track() argument
237 _payload: &[u8], in command_dispatch() argument
Dshell.rs109 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
115 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
159 pub tx: mpsc::BoundedSender<Vec<u8>>,
182 buf: &mut [u8], in pty_echo() argument
233 mut rx: mpsc::BoundedReceiver<Vec<u8>>, in subprocess_task() argument
295 let (tx, rx) = ylong_runtime::sync::mpsc::bounded_channel::<Vec<u8>>(16); in new()
Dsys_para.rs51 let mut out: [u8; HDC_PARAMETER_VALUE_MAX_LEN] = [0; HDC_PARAMETER_VALUE_MAX_LEN]; in get_dev_item()
57 out.as_mut_ptr() as *mut u8, in get_dev_item()
Dauth.rs127 auth_type: AuthType::Publickey as u8, in handshake_init()
146 auth_type: AuthType::Signature as u8, in make_sign_message()
163 auth_type: AuthType::OK as u8, in make_ok_message()
209 if recv.auth_type == AuthType::Publickey as u8 { in handshake_task()
294 } else if recv.auth_type == AuthType::Signature as u8 { in handshake_task()
472 auth_type: AuthType::Fail as u8, in handshake_fail()
/developtools/hdc/hdc_rust/src/common/
Duds.rs68 const fn as_char(slice: &[u8]) -> &[c_char] { in as_char()
69 unsafe { &*(slice as *const [u8] as *const [c_char]) } in as_char()
89 pub fn parse_abstract(name: &[u8]) -> io::Result<Self> { in parse_abstract()
150 pub fn wrap_recv(socket_fd: i32, buffer: &mut [u8]) -> isize { in wrap_recv()
155 pub fn wrap_read(socket_fd: i32, buffer: &mut [u8]) -> isize { in wrap_read()
160 pub fn wrap_write(socket_fd: i32, buffer: &[u8]) -> isize { in wrap_write()
189 pub fn wrap_send(socket_fd: i32, buffer: &[u8]) -> isize { in wrap_send()
274 pub fn wrap_recv(socket_fd: i32, buffer: &mut [u8]) -> isize { in wrap_recv()
279 pub fn wrap_read(socket_fd: i32, buffer: &mut [u8]) -> isize { in wrap_read()
284 pub fn wrap_write(socket_fd: i32, buffer: &[u8]) -> isize { in wrap_write()
[all …]
Dsendmsg.rs23 pub fn send_msg(socket_fd: i32, fd: i32, data: &[u8]) -> i32 { in send_msg()
24 unsafe { SendMsg(socket_fd, fd, data.as_ptr() as *mut u8, data.len() as i32) } in send_msg()
Dhdctransfer.rs167 let mut buf: [u8; FILE_PACKAGE_PAYLOAD_SIZE] = [0; FILE_PACKAGE_PAYLOAD_SIZE]; in spawn_handler()
168 let mut data_buf: [u8; FILE_PACKAGE_PAYLOAD_SIZE] = [0; FILE_PACKAGE_PAYLOAD_SIZE]; in spawn_handler()
187 header.compress_type = CompressType::Lz4 as u8; in spawn_handler()
199 header.compress_type = CompressType::None as u8; in spawn_handler()
205 header.compress_type = CompressType::None as u8; in spawn_handler()
282 pub fn recv_and_write_file(tbase: &mut HdcTransferBase, _data: &[u8]) -> bool { in recv_and_write_file()
295 let buf: [u8; FILE_PACKAGE_PAYLOAD_SIZE] = [0; FILE_PACKAGE_PAYLOAD_SIZE]; in recv_and_write_file()
359 pub fn transfer_data(tbase: &mut HdcTransferBase, _payload: &[u8]) -> bool { in transfer_data()
385 pub async fn echo_client(session_id: u32, channel_id: u32, payload: Vec<u8>) { in echo_client() argument
Dforward.rs124 async fn write(id: u32, data: Vec<u8>) { in write() argument
233 pub fn get_id(_payload: &[u8]) -> u32 { in get_id()
268 pub async fn check_command(session_id: u32, channel_id: u32, _payload: &[u8]) -> bool { in check_command()
399 let buf_string: Vec<u8> = value.as_bytes().to_vec(); in on_accept()
440 let mut buffer: [u8; SOCKET_BUFFER_SIZE] = [0; SOCKET_BUFFER_SIZE]; in deamon_read_socket_msg()
470 let vec_none = Vec::<u8>::new(); in free_context()
529 let name: Vec<u8> = path.as_bytes().to_vec(); in server_socket_bind_listen()
597 let mut buf: [u8; config::FILE_PACKAGE_PAYLOAD_SIZE] = in setup_device_point()
709 let vec_none = Vec::<u8>::new(); in setup_jdwp_point()
737 let name: Vec<u8> = path.as_bytes().to_vec(); in daemon_connect_pipe()
[all …]
Dtaskbase.rs24 _payload: &[u8], in command_dispatch() argument
Dhdcfile.rs109 file_task.transfer.transfer_config.compress_type = CompressType::Lz4 as u8; in check_local_path()
166 task.transfer.transfer_config.compress_type = CompressType::Lz4 as u8; in set_master_parameters()
252 pub async fn check_slaver(session_id: u32, channel_id: u32, _payload: &[u8]) -> bool { in check_slaver()
287 payload: Vec::<u8>::new(), in put_file_begin()
330 async fn do_file_finish(session_id: u32, channel_id: u32, _payload: &[u8]) { in do_file_finish() argument
356 let _payload: [u8; 1] = [1]; in put_file_finish()
371 _payload: &[u8], in command_dispatch() argument
/developtools/hdc/hdc_rust/src/
Dconfig.rs30 impl TryFrom<u8> for CompressType {
32 fn try_from(cmd: u8) -> Result<Self, ()> { in try_from()
68 pub payload: Vec<u8>,
250 impl TryFrom<u8> for AppModeType {
252 fn try_from(cmd: u8) -> Result<Self, ()> { in try_from()
261 pub const PACKET_FLAG: &[u8] = "HW".as_bytes();
264 pub const PAYLOAD_VCODE: u8 = 0x09;
289 pub const UART_EVENT: u8 = 78;
293 pub const USB_PACKET_FLAG: &[u8] = "UB".as_bytes();
Dutils.rs41 pub async fn print_msg(buf: Vec<u8>) -> io::Result<()> { in print_msg()
48 pub fn execute_cmd(cmd: String) -> Vec<u8> { in execute_cmd() argument
62 pub fn execute_shell_cmd(cmd: String) -> (bool, Vec<u8>) { in execute_shell_cmd() argument
93 pub fn bytes_to_string(message: Vec<u8>) -> String { in bytes_to_string()
/developtools/hdc/hdc_rust/src/transfer/
Duart_wrapper.rs32 #[repr(u8)]
41 impl TryFrom<u8> for UartOption {
43 fn try_from(cmd: u8) -> Result<Self, ()> { in try_from()
117 #[repr(u8)]
128 option: u8,
130 data: Vec<u8>,
149 stop_flag_map: HashMap<u32, Arc<Mutex<u8>>>,
224 async fn get_stop_flag(session_id: u32) -> Option<u8> { in get_stop_flag() argument
428 option: u8, in output_package() argument
430 data: Vec<u8>, in output_package() argument
[all …]
Dusb.rs39 pub fn buf_to_vec(buf: PersistBuffer) -> Vec<u8> { in buf_to_vec() argument
53 fn CloseEndPointEx(bulkIn: i32, bulkOut: i32, ctrlEp: i32, closeCtrlEp: u8); in CloseEndPointEx() argument
118 fn read_frame(&self, _expected_size: usize) -> io::Result<Vec<u8>> { in read_frame() argument
147 fn write_all(&self, data: Vec<u8>) -> io::Result<()> { in write_all()
160 pub fn build_header(session_id: u32, option: u8, length: usize) -> Vec<u8> { in build_header() argument
Duart.rs42 fn SetSerialExt(fd: i32, speed: i32, bits: i32, event: u8, stop: i32) -> i32; in SetSerialExt() argument
45 fn CloseSerialPortExt(fd: i32) -> u8; in CloseSerialPortExt() argument
90 fn read_frame(&self, expected_size: usize) -> io::Result<Vec<u8>> { in read_frame() argument
145 fn write_all(&self, data: Vec<u8>) -> io::Result<()> { in write_all()
161 pub fn build_header(session_id: u32, option: u16, length: usize, package_index: u32) -> Vec<u8> { in build_header() argument
Dtcp.rs28 async fn read_frame(rd: &mut SplitReadHalf, expected_size: usize) -> io::Result<Vec<u8>> { in read_frame() argument
87 pub async fn recv_channel_message(rd: &mut SplitReadHalf) -> io::Result<Vec<u8>> { in recv_channel_message() argument
Dbuffer.rs86 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> { in send_channel_message()
175 pub async fn put(session_id: u32, data: Vec<u8>) -> io::Result<()> { in put()
214 pub async fn send_channel_data(channel_id: u32, data: Vec<u8>) { in send_channel_data() argument
255 pub async fn recv() -> io::Result<Vec<u8>> { in recv()
/developtools/profiler/device/plugins/ftrace_plugin/test/unittest/resource/
Dtest_comm118 9573 kworker/u8:3
128 9984 kworker/u8:0
132 8863 kworker/u8:3
142 8236 kworker/u8:0
186 9956 kworker/u8:2
/developtools/hdc/hdc_rust/src/host/
Dauth.rs60 if recv.auth_type == config::AuthType::OK as u8 { in handshake_with_daemon()
62 } else if recv.auth_type == config::AuthType::Publickey as u8 { in handshake_with_daemon()
64 handshake.auth_type = config::AuthType::Publickey as u8; in handshake_with_daemon()
72 handshake.auth_type = config::AuthType::Signature as u8; in handshake_with_daemon()
75 } else if recv.auth_type == config::AuthType::Fail as u8 { in handshake_with_daemon()
Dhost_app.rs137 fn do_app_finish(&mut self, _payload: &Vec<u8>) -> bool { in do_app_finish()
146 fn do_app_uninstall(&mut self, _payload: &Vec<u8>) { in do_app_uninstall() argument
193 _payload: &[u8], in command_dispatch() argument

12