| /developtools/hdc/hdc_rust/src/common/ |
| D | hdcfile.rs | 82 let task = map.get(&(session_id, channel_id)); in exsit() localVariable
83 task.is_some() in exsit()
95 let task = map.get(&(session_id, channel_id)); in get() localVariable
96 task.cloned() in get()
108 let mut task = _iter.1.lock().await; in stop_task() localVariable
109 task.transfer.stop_run = true; in stop_task()
123 let task = _iter.1.lock().await; in dump_task() localVariable
124 let command = task.transfer.command_str.clone(); in dump_task()
136 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in check_local_path()
142 let mut file_task = task.lock().await; in check_local_path()
[all …]
|
| D | forward.rs | 53 use ylong_runtime::task::JoinHandle;
344 let task = map.get(&(session_id, channel_id)); in get() localVariable
345 match task { in get()
346 Some(task) => Some(task.clone()), in get()
541 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in check_command()
545 let task = &mut task.clone(); in check_command() localVariable
554 let map_info = String::from(if task.transfer.server_or_daemon { in check_command()
558 }) + &task.task_command; in check_command()
597 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in detech_forward_type()
601 let task = &mut task.clone(); in detech_forward_type() localVariable
[all …]
|
| /developtools/hdc/hdc_rust/src/daemon/ |
| D | daemon_app.rs | 71 let task = map.get(&(session_id, channel_id)); in exsit() localVariable
72 task.is_some() in exsit()
84 let Some(task) = map.get(&(session_id, channel_id)) else { in get()
92 Some(task.clone()) in get()
103 let mut task = _iter.1.lock().await; in stop_task() localVariable
104 task.transfer.stop_run = true; in stop_task()
113 let task = _iter.1.lock().await; in dump_task() localVariable
114 let command = task.transfer.command_str.clone(); in dump_task()
134 let mut task = arc.lock().await; in do_app_check() localVariable
139 task.transfer.transfer_config.options = transconfig.options.clone(); in do_app_check()
[all …]
|
| D | task.rs | 123 let task = DaemonAppTask::new(session_id, task_message.channel_id); in daemon_file_task() localVariable
124 AppTaskMap::put(session_id, task_message.channel_id, task).await; in daemon_file_task()
149 let mut task = HdcFile::new(session_id, task_message.channel_id); in daemon_file_task() localVariable
150 task.transfer.server_or_daemon = false; in daemon_file_task()
151 FileTaskMap::put(session_id, task_message.channel_id, task).await; in daemon_file_task()
165 let mut task = HdcForward::new(session_id, task_message.channel_id); in daemon_file_task() localVariable
166 task.transfer.server_or_daemon = false; in daemon_file_task()
167 ForwardTaskMap::update(session_id, task_message.channel_id, task).await; in daemon_file_task()
|
| D | main.rs | 24 mod task; module
77 if let Err(e) = task::dispatch_task(msg, session_id).await { in handle_message()
335 if let Err(e) = task::dispatch_task(message, real_session_id).await { in uart_handle_client()
391 if let Err(e) = task::dispatch_task(msg, cur_session_id).await { in usb_handle_client()
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | host_app.rs | 112 let mut task = arc_task.lock().await; in check_install_continue() localVariable
113 let msg = str[task.printed_msg_len..].to_owned(); in check_install_continue()
117 task.transfer.local_path.clone(), in check_install_continue()
118 task.transfer.task_queue.len(), in check_install_continue()
121 task.printed_msg_len = str.len(); in check_install_continue()
123 if task.transfer.task_queue.is_empty() { in check_install_continue()
129 drop(task); in check_install_continue()
210 let task = arc_task.lock().await; in put_app_check() localVariable
214 payload: task.transfer.transfer_config.serialize(), in put_app_check()
221 let mut task = arc_task.lock().await; in install_single() localVariable
[all …]
|
| D | unittest.rs | 164 let mut task = HostAppTask::new(0, 0); in if_init_install_works() localVariable
165 task.init_install(&String::from("-cwd \"/home/\" 1234.hap")); in if_init_install_works()
167 assert_eq!(task.transfer.local_path, "/home/1234.hap"); in if_init_install_works()
168 let ret = task in if_init_install_works()
|
| D | server.rs | 16 use crate::task;
29 use crate::task::ConnectMap;
76 task::start_usb_device_loop(ptr, sn.to_string()).await; in start_usb_server()
272 if let Err(e) = task::channel_task_dispatch(task::TaskInfo { in handle_client()
|
| D | task.rs | 148 let mut task = HdcForward::new(session_id, task_info.channel_id); in channel_forward_task() localVariable
149 task.transfer.server_or_daemon = true; in channel_forward_task()
150 ForwardTaskMap::update(session_id, task_info.channel_id, task).await; in channel_forward_task()
321 let mut task = HdcFile::new(session_id, task_info.channel_id); in channel_file_task() localVariable
322 task.transfer.server_or_daemon = true; in channel_file_task()
323 FileTaskMap::put(session_id, task_info.channel_id, task).await; in channel_file_task()
691 let mut task = HdcForward::new(session_id, task_message.channel_id); in session_task_dispatch() localVariable
692 task.transfer.server_or_daemon = true; in session_task_dispatch()
693 ForwardTaskMap::update(session_id, task_message.channel_id, task).await; in session_task_dispatch()
737 let mut task = HdcFile::new(session_id, task_message.channel_id); in session_file_task() localVariable
[all …]
|
| D | main.rs | 23 mod task; module
|
| /developtools/smartperf_host/trace_streamer/src/protos/types/plugins/ftrace_data/ |
| D | task.proto | 20 // category: task
21 // /sys/kernel/debug/tracing/events/task/task_newtask/format
29 // /sys/kernel/debug/tracing/events/task/task_rename/format
|
| D | autogenerated.gni | 42 "task.proto",
|
| /developtools/smartperf_host/trace_streamer/src/protos/types/plugins/ftrace_data/default/ |
| D | task.proto | 20 // category: task
21 // /sys/kernel/debug/tracing/events/task/task_newtask/format
29 // /sys/kernel/debug/tracing/events/task/task_rename/format
|
| D | autogenerated.gni | 46 "task.proto",
|
| /developtools/profiler/protos/types/plugins/ftrace_data/default/ |
| D | task.proto | 20 // category: task
21 // /sys/kernel/debug/tracing/events/task/task_newtask/format
29 // /sys/kernel/debug/tracing/events/task/task_rename/format
|
| D | autogenerated.gni | 46 "task.proto",
|
| /developtools/smartperf_host/ide/src/trace/component/trace/sheet/task/ |
| D | TabPaneTaskFrames.ts | 135 let task: TaskTabStruct = new TaskTabStruct(); variable
136 task.executeId = relationId;
137 task.taskPriority = Priority[priorityId];
138 task.taskST = this.getMsTime(sTime);
139 task.taskET = this.getMsTime(eTime);
140 task.taskRT = rTime > 0 ? this.getMsTime(rTime) : '-';
141 this.taskFramesSource = [task];
142 this.taskFramesGroupSource = [[task]];
|
| /developtools/profiler/device/services/profiler_service/include/ |
| D | profiler_service.h | 113 void StartSessionExpireTask(ScheduleTaskManager& task);
114 void StopSessionExpireTask(ScheduleTaskManager& task);
|
| /developtools/profiler/host/smartperf/client/client_command/include/ |
| D | sp_task.h | 128 ftrace_events: "task/task_newtask"
129 ftrace_events: "task/task_rename"
|
| /developtools/ace_ets2bundle/compiler/sample/pages/ |
| D | willdo.ets | 121 // Add ID for each task
139 Button("Next task")
144 Button("Prev task")
|
| /developtools/smartperf_host/trace_streamer/src/parser/ptreader_parser/ |
| D | ptreader_parser.cpp | 311 seg.bufLine.task = StrTrim(matcheLine.prefix()); in GetDataSegAttr()
312 if (seg.bufLine.task == "<...>") { in GetDataSegAttr()
313 seg.bufLine.task = ""; in GetDataSegAttr()
|
| /developtools/integration_verification/tools/fotff/ |
| D | fotff.ini | 48 task = acts key
|
| /developtools/hdc/src/daemon/ |
| D | jdwp.h | 97 void ProcessListUpdated(HTaskInfo task = nullptr);
|
| /developtools/hapsigner/hapsigntool/hap_sign_tool_lib/src/main/java/com/ohos/hapsigntool/codesigning/fsverity/ |
| D | MerkleTreeBuilder.java | 180 Runnable task = () -> { in runHashTask() local
198 this.mPools.execute(task); in runHashTask()
|
| /developtools/profiler/protos/services/ |
| D | profiler_service.proto | 42 // keep tracing session alive, call this interface will restart session expire count down task.
|