Lines Matching refs:transfer
24 use hdc::transfer;
25 use hdc::transfer::EchoLevel;
36 pub transfer: HdcTransferBase,
44 transfer: HdcTransferBase::new(_session_id, _channel_id),
111 let local_path = if !task.transfer.local_tar_raw_path.is_empty() {
112 &task.transfer.local_tar_raw_path
114 &task.transfer.local_path
117 format!("{} path:{}, queuesize:{}, msg:{}", mode_desc, local_path, task.transfer.task_queue.len(), msg);
120 let _ = transfer::send_channel_msg(channel_id, EchoLevel::INFO, message).await;
121 if task.transfer.task_queue.is_empty() {
122 let _ = transfer::send_channel_msg(channel_id, EchoLevel::INFO, String::from("AppMod finish")).await;
129 let _ = transfer::send_channel_msg(channel_id, EchoLevel::FAIL, err_msg).await;
140 transfer::put(session_id, app_uninstall_message).await;
189 payload: task.transfer.transfer_config.serialize(),
191 transfer::put(session_id, file_check_message).await
200 match task.transfer.task_queue.pop() {
204 task.transfer.local_path = loc_path;
205 task.transfer.local_tar_raw_path = String::new();
210 task.transfer.local_path = tar_file;
211 task.transfer.local_tar_raw_path = loc_path;
227 let local_path = task.transfer.local_path.clone();
232 task.transfer.transfer_config.file_size = file_size;
233 task.transfer.file_size = file_size;
234 task.transfer.transfer_config.optional_name = utils::get_pseudo_random_u32().to_string();
237 task.transfer
242 task.transfer.transfer_config.path = task.transfer.remote_path.clone();
267 task.transfer.transfer_config.client_cwd = argv[i + 1].clone();
278 &task.transfer.transfer_config.client_cwd,
282 task.transfer.task_queue.push(path);
286 task.transfer.task_queue.push(path);
293 if task.transfer.task_queue.is_empty() {
297 task.transfer.transfer_config.options = options.clone();
298 task.transfer.transfer_config.function_name = TRANSFER_FUNC_NAME.to_string();
299 task.transfer.is_master = true;
355 let _ = transfer::send_channel_msg(channel_id, EchoLevel::FAIL, err_msg).await;
356 transfer::TcpMap::end(channel_id).await;
365 let _ = transfer::send_channel_msg(channel_id, EchoLevel::FAIL, err_msg).await;
366 transfer::TcpMap::end(channel_id).await;
372 hdctransfer::transfer_begin(&task.transfer, HdcCommand::AppData).await;
376 let _ = transfer::send_channel_msg(channel_id, EchoLevel::FAIL, err_msg).await;
377 transfer::TcpMap::end(channel_id).await;