| /developtools/hiperf/include/ |
| D | perf_record_format.h | 32 u32 pid;
33 u32 tid; /* if PERF_SAMPLE_TID set */
37 u32 cpu, res; /* if PERF_SAMPLE_CPU set */
63 u32 pid, tid;
97 u32 pid;
98 u32 tid;
102 u32 maj;
103 u32 min;
106 u32 prot;
107 u32 flags;
[all …]
|
| D | perf_event_record.h | 177 PerfRecordMmap(bool inKernel, u32 pid, u32 tid, u64 addr, u64 len, u64 pgoff,
191 PerfRecordMmap2(bool inKernel, u32 pid, u32 tid, u64 addr, u64 len, u64 pgoff, u32 maj, u32 min,
192 u64 ino, u32 prot, u32 flags, const std::string &filename);
194 PerfRecordMmap2(bool inKernel, u32 pid, u32 tid, std::shared_ptr<DfxMap> item);
227 PerfRecordComm(bool inKernel, u32 pid, u32 tid, const std::string &comm);
263 PerfRecordSample(bool inKernel, u32 pid, u32 tid, u64 period = 0, u64 time = 0, u64 id = 0)
|
| /developtools/hdc/hdc_rust/src/serializer/ |
| D | native_struct.rs | 22 pub session_id: u32,
30 pub channel_id: u32,
31 pub command_flag: u32,
42 pub data_size: u32,
50 pub session_id: u32,
51 pub data_size: u32,
52 pub package_index: u32,
53 pub data_checksum: u32,
54 pub head_checksum: u32,
62 pub session_id: u32,
[all …]
|
| D | pack_assemble.rs | 65 command_flag: task_message.command as u32, in concat_pack()
76 data_size: (task_message.payload.len() as u32).to_be(), in concat_pack()
|
| /developtools/hdc/hdc_rust/src/daemon/ |
| D | daemon_unity.rs | 34 async fn echo_client(session_id: u32, channel_id: u32, message: &str) { in echo_client() argument
43 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
67 session_id: u32, in echo_root_run_mode_result() argument
68 channel_id: u32, in echo_root_run_mode_result() argument
84 async fn set_root_run_enable(session_id: u32, channel_id: u32, force: bool) { in set_root_run_enable() 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
144 async fn remount_device(session_id: u32, channel_id: u32) { in remount_device() argument
154 async fn set_device_mode(session_id: u32, channel_id: u32, _payload: &[u8]) { in set_device_mode() argument
[all …]
|
| D | daemon_app.rs | 41 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() argument
50 type AppTaskMap_ = Arc<Mutex<HashMap<(u32, u32), DaemonAppTask_>>>;
61 pub async fn put(session_id: u32, channel_id: u32, value: DaemonAppTask) { in put() argument
67 pub async fn exsit(session_id: u32, channel_id: u32) -> bool { in exsit() argument
74 pub async fn remove(session_id: u32, channel_id: u32) -> Option<DaemonAppTask_> { in remove() argument
80 pub async fn get(session_id: u32, channel_id: u32) -> DaemonAppTask_ { in get() argument
88 async fn do_app_check(session_id: u32, channel_id: u32, _payload: &[u8]) -> bool { in do_app_check() argument
115 async fn put_file_begin(session_id: u32, channel_id: u32) { in put_file_begin() argument
125 session_id: u32, in put_app_finish() argument
126 channel_id: u32, in put_app_finish() argument
[all …]
|
| D | task.rs | 46 async fn daemon_shell_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_shell_task()
85 async fn remove_task(session_id: u32, channel_id: u32) { in remove_task() argument
95 async fn daemon_channel_close(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_channel_close()
110 async fn daemon_file_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_file_task()
219 async fn daemon_hilog_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_hilog_task()
238 async fn daemon_bug_report_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_bug_report_task()
302 pub async fn dispatch_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in dispatch_task()
308 hdc::error!("auth status is nok, cannt accept cmd: {}", cmd as u32); in dispatch_task()
320 format!("auth status is nok, cannt accept cmd: {}", cmd as u32), in dispatch_task()
329 task_message.command as u32 in dispatch_task()
[all …]
|
| D | shell.rs | 166 channel_id: u32,
170 fn new(pty: Pty, child: Child, channel_id: u32) -> Self { in new()
203 fn init_pty_process(cmd: Option<String>, channel_id: u32) -> io::Result<PtyProcess> { in init_pty_process()
230 session_id: u32, in subprocess_task() argument
231 channel_id: u32, in subprocess_task() argument
290 session_id: u32, in new() argument
291 channel_id: u32, in new() argument
307 type PtyMap_ = Arc<Mutex<HashMap<u32, Arc<PtyTask>>>>;
319 pub async fn get(channel_id: u32) -> Option<Arc<PtyTask>> { in get()
328 pub async fn put(channel_id: u32, pty_task: PtyTask) { in put() argument
[all …]
|
| D | auth.rs | 51 type AuthStatusMap_ = Arc<RwLock<HashMap<u32, AuthStatus>>>;
64 pub async fn get(session_id: u32) -> AuthStatus { in get()
70 async fn put(session_id: u32, auth_status: AuthStatus) { in put() argument
77 pub async fn handshake_init(task_message: TaskMessage) -> io::Result<(u32, TaskMessage)> { in handshake_init() argument
140 async fn make_sign_message(session_id: u32, token: String, channel_id: u32) -> TaskMessage { in make_sign_message() argument
156 async fn make_ok_message(session_id: u32, channel_id: u32) -> TaskMessage { in make_ok_message() argument
185 pub async fn get_new_session_id(task_message: &TaskMessage) -> io::Result<u32> { in get_new_session_id() argument
191 pub async fn handshake_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in handshake_task()
326 async fn validate_signature(signature: String, session_id: u32) -> io::Result<()> { in validate_signature()
467 async fn handshake_fail(session_id: u32, channel_id: u32, msg: String) { in handshake_fail() argument
|
| /developtools/hdc/hdc_rust/src/common/ |
| D | forward.rs | 40 pub const ARG_COUNT2: u32 = 2;
47 type TcpReadMap_ = Arc<RwLock<HashMap<u32, TcpRead>>>;
59 async fn put(id: u32, rd: SplitReadHalf) { in put() argument
66 async fn read(session_id: u32, channel_id: u32, cid: u32) { in read() argument
105 type TcpWriterMap_ = Arc<RwLock<HashMap<u32, TcpWriter>>>;
117 async fn put(id: u32, wr: SplitWriteHalf) { in put() argument
124 async fn write(id: u32, data: Vec<u8>) { in write() argument
135 pub async fn end(id: u32) { in end() argument
159 session_id: u32,
160 channel_id: u32,
[all …]
|
| D | hdcfile.rs | 40 pub file_cnt: u32,
49 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() argument
57 type FileTaskMap_ = Arc<Mutex<HashMap<(u32, u32), HdcFile_>>>;
68 pub async fn put(session_id: u32, channel_id: u32, value: HdcFile) { in put() argument
74 pub async fn exsit(session_id: u32, channel_id: u32) -> bool { in exsit() argument
81 pub async fn remove(session_id: u32, channel_id: u32) -> Option<HdcFile_> { in remove() argument
87 pub async fn get(session_id: u32, channel_id: u32) -> HdcFile_ { in get() argument
95 async fn check_local_path(session_id: u32, channel_id: u32) -> bool { in check_local_path() argument
120 async fn echo_finish(session_id: u32, channel_id: u32, msg: String) { in echo_finish() argument
125 pub async fn begin_transfer(session_id: u32, channel_id: u32, command: &String) -> bool { in begin_transfer() argument
[all …]
|
| D | hdctransfer.rs | 56 pub last_error: u32,
68 pub session_id: u32,
69 pub channel_id: u32,
71 pub file_cnt: u32,
80 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() argument
156 _channel_id_: u32, in spawn_handler() argument
181 header.uncompress_size = read_len as u32; in spawn_handler()
197 header.compress_size = compress_size as u32; in spawn_handler()
200 header.compress_size = read_len as u32; in spawn_handler()
206 header.compress_size = read_len as u32; in spawn_handler()
[all …]
|
| D | jdwp.rs | 33 type Trackers = Arc<Mutex<Vec<(u32, u32, bool)>>>;
74 pub async fn send_fd_to_target(&self, target_pid: u32, fd: i32, parameter: &str) -> bool { in send_fd_to_target() argument
116 pub async fn add_tracker(&self, channel_id: u32, session_id: u32, debug_or_release: bool) { in add_tracker() argument
165 let u32_size = std::mem::size_of::<u32>(); in handle_client()
167 let _pid = u32::from_le_bytes(buffer[0..u32_size].try_into().unwrap()); in handle_client()
169 let len = u32::from_le_bytes(buffer[0..u32_size].try_into().unwrap()); in handle_client()
170 let pid = u32::from_le_bytes(buffer[u32_size..2 * u32_size].try_into().unwrap()); in handle_client()
173 u32::from_le_bytes(buffer[u32_size * 2..3 * u32_size].try_into().unwrap()) == 1; in handle_client()
|
| /developtools/profiler/hiebpf/include/ |
| D | vmlinux.h | 38 typedef __u32 u32; typedef
77 typedef u32 __kernel_dev_t;
103 typedef u32 uint32_t;
440 u32 *uaddr;
441 u32 val;
442 u32 flags;
443 u32 bitset;
445 u32 *uaddr2;
472 u32 count;
473 u32 need_resched;
[all …]
|
| D | bpf_log_writer.h | 23 u32 bpf_log_level_index = BPF_LOG_LEVEL_INDEX; \
24 u32* bpf_log_level_ptr = bpf_map_lookup_elem(&config_var_map, &bpf_log_level_index); \
26 u32 bpf_log_level = BPF_LOG_NONE; \
27 bpf_probe_read_kernel(&bpf_log_level, sizeof(u32), bpf_log_level_ptr); \
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| D | uart_wrapper.rs | 57 response_waiters: HashMap<u32, Waiter>,
59 empty_waiters: HashMap<u32, Waiter>,
73 async fn start_session(session_id: u32) { in start_session() argument
80 async fn wait_response(session_id: u32) { in wait_response() argument
89 async fn wakeup_response_wait(session_id: u32) { in wakeup_response_wait() argument
98 async fn wait_empty(session_id: u32) { in wait_empty() argument
107 async fn wakeup_empty_wait(session_id: u32) { in wakeup_empty_wait() argument
126 session_id: u32,
129 package_index: u32,
132 retry_count: u32,
[all …]
|
| D | buffer.rs | 37 type ConnectTypeMap_ = Arc<RwLock<HashMap<u32, ConnectType>>>;
50 async fn put(session_id: u32, conn_type: ConnectType) { in put() argument
56 async fn get(session_id: u32) -> ConnectType { in get()
64 type TcpMap_ = Arc<RwLock<HashMap<u32, TcpWriter_>>>;
77 async fn put(session_id: u32, data: TaskMessage) { in put() argument
86 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> { in send_channel_message() argument
89 u32::to_be_bytes(buf.len() as u32).as_slice(), in send_channel_message()
103 pub async fn start(id: u32, wr: SplitWriteHalf) { in start() argument
111 pub async fn end(id: u32) { in end() argument
122 type UsbMap_ = Arc<RwLock<HashMap<u32, UsbWriter_>>>;
[all …]
|
| D | uart.rs | 112 fn check_protocol_head(&mut self) -> io::Result<(u32, u32)> { in check_protocol_head() argument
161 pub fn build_header(session_id: u32, option: u16, length: usize, package_index: u32) -> Vec<u8> { in build_header() argument
163 session_id: u32::to_le(session_id), in build_header()
166 data_size: u32::to_le(length as u32), in build_header()
175 session_id: u32, in build_header_obj() argument
178 package_index: u32, in build_header_obj() argument
181 session_id: u32::to_le(session_id), in build_header_obj()
184 data_size: u32::to_le(length as u32), in build_header_obj()
|
| D | usb.rs | 128 fn check_protocol_head(&mut self) -> io::Result<(u32, u32)> { in check_protocol_head() argument
142 Ok((u32::from_be(head.data_size), 0)) in check_protocol_head()
160 pub fn build_header(session_id: u32, option: u8, length: usize) -> Vec<u8> { in build_header() argument
162 session_id: u32::to_be(session_id), in build_header()
165 data_size: u32::to_be(length as u32), in build_header()
|
| D | base.rs | 63 fn check_protocol_head(&mut self) -> io::Result<(u32, u32)> { in check_protocol_head() argument
71 pack_size: u32, in unpack_task_message_lock() argument
80 let expected_data_size = u32::from_be(payload_head.data_size) as usize; in unpack_task_message_lock()
166 tx: BoundedSender<(TaskMessage, u32)>, in unpack_task_message() argument
179 let expected_data_size = u32::from_be(payload_head.data_size) as usize; in unpack_task_message()
|
| /developtools/profiler/hiebpf/src/ |
| D | hiebpf.bpf.c | 53 __uint(key_size, sizeof(u32));
54 __uint(value_size, sizeof(u32));
63 __uint(key_size, sizeof(u32));
64 __uint(value_size, sizeof(u32));
85 __uint(key_size, sizeof(u32));
102 u32 index = UNWIND_FLAG_INDEX; in unwind_stack()
103 const u32 *unwind_ptr = bpf_map_lookup_elem(&config_var_map, &index); in unwind_stack()
104 u32 unwind = 0; in unwind_stack()
105 int err = bpf_probe_read_kernel(&unwind, sizeof(u32), unwind_ptr); in unwind_stack()
142 cmplt_event->pid = (u32) pid_tgid; in emit_fstrace_event()
[all …]
|
| /developtools/hdc/hdc_rust/src/ |
| D | config.rs | 66 pub channel_id: u32,
72 #[repr(u32)]
155 impl TryFrom<u32> for HdcCommand {
157 fn try_from(cmd: u32) -> Result<Self, ()> { in try_from()
281 pub const MAX_PORT_NUM: u32 = 65535;
290 pub const MAX_UART_SIZE_IOBUF: u32 = 4096;
336 const HDC_VERSION_NUMBER: u32 = 0x10400000;
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | server.rs | 43 pub async fn get_process_pids() -> Vec<u32> { in get_process_pids()
44 let mut pids: Vec<u32> = Vec::new(); in get_process_pids()
51 pids.push(u32::from_str(token).unwrap()); in get_process_pids()
62 pids.push(u32::from_str(pid).unwrap()); in get_process_pids()
188 ) -> io::Result<(String, u32)> { in handshake_with_client() argument
195 u32::to_le_bytes(channel_id).as_slice(), in handshake_with_client()
196 vec![0_u8; config::KEY_MAX_SIZE - std::mem::size_of::<u32>()].as_slice(), in handshake_with_client()
|
| D | task.rs | 36 pub channel_id: u32,
346 session_id: u32, in tcp_handle_deamon() argument
370 async fn session_task_dispatch(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_task_dispatch()
393 async fn session_file_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_file_task()
435 async fn session_channel_close(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_channel_close()
462 pub session_id: u32,
544 pub async fn get_session_id(connect_key: String) -> Option<u32> { in get_session_id() argument
551 async fn get_valid_session_id(connect_key: String, channel_id: u32) -> io::Result<u32> { in get_valid_session_id() argument
|
| D | auth.rs | 34 session_id: u32, in handshake_with_daemon() argument
35 channel_id: u32, in handshake_with_daemon() argument
105 let prikey = Rsa::generate(config::RSA_BIT_NUM as u32).unwrap(); in create_prikey()
145 async fn send_handshake_to_daemon(handshake: &SessionHandShake, channel_id: u32) { in send_handshake_to_daemon() argument
|