Lines Matching defs:task
59 hdc::trace!("dispatch to runmode task");
69 hdc::trace!("dispatch to shell task");
73 hdc::trace!("dispatch to tconn task");
77 hdc::trace!("dispatch to list task");
85 hdc::trace!("dispatch to close task");
148 let mut task = HdcForward::new(session_id, task_info.channel_id, true);
149 task.transfer.server_or_daemon = true;
150 ForwardTaskMap::update(session_id, task_info.channel_id, task).await;
323 let mut task = HdcFile::new(session_id, task_info.channel_id);
324 task.transfer.server_or_daemon = true;
325 FileTaskMap::put(session_id, task_info.channel_id, task).await;
472 hdc::error!("dispatch task failed: {}", e.to_string());
476 hdc::warn!("unpack task failed: {}", e.to_string());
588 hdc::error!("dispatch task failed: {}", e.to_string());
592 hdc::warn!("unpack task failed: {}", e.to_string());
647 let mut task = HdcForward::new(session_id, task_message.channel_id, true);
648 task.transfer.server_or_daemon = true;
649 ForwardTaskMap::update(session_id, task_message.channel_id, task).await;
692 let mut task = HdcFile::new(session_id, task_message.channel_id);
693 task.transfer.server_or_daemon = true;
694 FileTaskMap::put(session_id, task_message.channel_id, task).await;
743 let mut task = HostAppTask::new(session_id, channel_id);
744 task.transfer.server_or_daemon = true;
745 e.insert(Arc::new(Mutex::new(task)));
748 let mut task = HdcFile::new(session_id, channel_id);
749 task.transfer.server_or_daemon = true;
750 e.insert(Arc::new(Mutex::new(task)));
757 let task = session.map_tasks.get(&channel_id).unwrap();
758 let task_ = &mut task.lock().await;
838 conn_status: crate::task::ConnectStatus,