| /developtools/hdc/hdc_rust/src/common/ |
| D | hdcfile.rs | 77 let task = map.get(&(session_id, channel_id)); in exsit() localVariable
78 task.is_some() in exsit()
90 let task = map.get(&(session_id, channel_id)).unwrap(); in get() localVariable
91 task.clone() in get()
96 let task = FileTaskMap::get(session_id, channel_id).await; in check_local_path() localVariable
97 let mut file_task = task.lock().await; in check_local_path()
137 let task = FileTaskMap::get(session_id, channel_id).await; in begin_transfer() localVariable
138 let mut task = task.lock().await; in begin_transfer() localVariable
139 task.transfer.is_master = true; in begin_transfer()
140 drop(task); in begin_transfer()
[all …]
|
| D | forward.rs | 190 let task = map.get(&(session_id, channel_id)); in get() localVariable
191 if task.is_none() { in get()
196 Some(task.unwrap().clone()) in get()
269 let task = ForwardTaskMap::get(session_id, channel_id).await; in check_command() localVariable
270 if task.is_none() { in check_command()
273 let task = &mut task.unwrap().clone(); in check_command() localVariable
276 let map_info = String::from(if task.transfer.server_or_daemon { in check_command()
280 }) + &task.task_command; in check_command()
307 let task = ForwardTaskMap::get(session_id, channel_id).await; in detech_forward_type() localVariable
308 if task.is_none() { in detech_forward_type()
[all …]
|
| /developtools/hdc/hdc_rust/src/daemon/ |
| D | daemon_app.rs | 70 let task = map.get(&(session_id, channel_id)); in exsit() localVariable
71 task.is_some() in exsit()
83 let task = map.get(&(session_id, channel_id)).unwrap(); in get() localVariable
84 task.clone() in get()
90 let mut task = arc.lock().await; in do_app_check() localVariable
95 task.transfer.transfer_config.options = transconfig.options.clone(); in do_app_check()
96 task.transfer.transfer_config.function_name = transconfig.function_name.clone(); in do_app_check()
99 task.transfer.is_master = false; in do_app_check()
100 task.transfer.local_path = local_path; in do_app_check()
101 task.transfer.file_size = transconfig.file_size; in do_app_check()
[all …]
|
| D | task.rs | 114 let task = DaemonAppTask::new(session_id, task_message.channel_id); in daemon_file_task() localVariable
115 AppTaskMap::put(session_id, task_message.channel_id, task).await; in daemon_file_task()
140 let mut task = HdcFile::new(session_id, task_message.channel_id); in daemon_file_task() localVariable
141 task.transfer.server_or_daemon = false; in daemon_file_task()
142 FileTaskMap::put(session_id, task_message.channel_id, task).await; in daemon_file_task()
156 let mut task = HdcForward::new(session_id, task_message.channel_id); in daemon_file_task() localVariable
157 task.transfer.server_or_daemon = false; in daemon_file_task()
158 ForwardTaskMap::update(session_id, task_message.channel_id, task).await; in daemon_file_task()
|
| D | main.rs | 23 mod task; module
62 if let Err(e) = task::dispatch_task(msg, session_id).await { in handle_message()
226 if let Err(e) = task::dispatch_task(message, real_session_id).await { in uart_handle_client()
317 if let Err(e) = task::dispatch_task(msg, real_session_id).await { in usb_handle_client()
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | task.rs | 150 let mut task = HostAppTask::new(session_id, task_info.channel_id); in channel_file_task() localVariable
151 task.transfer.server_or_daemon = true; in channel_file_task()
152 e.insert(Arc::new(Mutex::new(task))); in channel_file_task()
155 let mut task = HdcFile::new(session_id, task_info.channel_id); in channel_file_task() localVariable
156 task.transfer.server_or_daemon = true; in channel_file_task()
157 e.insert(Arc::new(Mutex::new(task))); in channel_file_task()
164 let task = session.map_tasks.get(&task_info.channel_id).unwrap(); in channel_file_task() localVariable
165 let task_ = &mut task.lock().await; in channel_file_task()
413 let mut task = HostAppTask::new(session_id, channel_id); in session_file_task() localVariable
414 task.transfer.server_or_daemon = true; in session_file_task()
[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;
123 let session_id = match task::ConnectMap::get_session_id(connect_key.clone()).await { in handle_client()
169 if let Err(e) = task::channel_task_dispatch(task::TaskInfo { in handle_client()
|
| D | main.rs | 21 mod task; module
|
| /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/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/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 | 134 let task: TaskTabStruct = new TaskTabStruct(); variable
135 task.executeId = executeId;
136 task.taskPriority = Priority[priorityId];
137 task.taskST = this.getMsTime(sTime);
138 task.taskET = this.getMsTime(eTime);
139 task.taskRT = this.getMsTime(rTime);
140 this.taskFramesSource = [task];
141 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/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/bytrace_parser/ |
| D | bytrace_parser.cpp | 283 seg.bufLine.task = StrTrim(matcheLine.prefix()); in GetDataSegAttr()
284 if (seg.bufLine.task == "<...>") { in GetDataSegAttr()
285 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);
|
| D | jdwp.cpp | 535 void HdcJdwp::ProcessListUpdated(HTaskInfo task) in ProcessListUpdated() argument
546 if (task != nullptr) { in ProcessListUpdated()
548 size_t len = JdwpProcessListMsg(&data[0], data.size(), task->debugRelease); in ProcessListUpdated()
551 SendProcessList(task, data); in ProcessListUpdated()
|
| /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.
|
| /developtools/smartperf_host/trace_streamer/src/protos/services/ |
| D | profiler_service.proto | 42 // keep tracing session alive, call this interface will restart session expire count down task.
|