Lines Matching refs:transfer
18 use crate::transfer;
52 pub transfer: HdcTransferBase,
58 transfer: HdcTransferBase::new(_session_id, _channel_id),
110 task.transfer.stop_run = true;
125 let command = task.transfer.command_str.clone();
144 let local_path = file_task.transfer.local_path.clone();
148 file_task.transfer.transfer_config.file_size = file_manager.file_size();
149 file_task.transfer.file_size = file_task.transfer.transfer_config.file_size;
150 file_task.file_size = file_task.transfer.transfer_config.file_size;
151 file_task.transfer.transfer_config.optional_name = file_task.transfer.local_name.clone();
152 if transfer::base::CheckCompressVersion::get().await
153 && (file_task.transfer.transfer_config.file_size > (MAX_SIZE_IOBUF as u64))
155 file_task.transfer.transfer_config.compress_type = CompressType::Lz4 as u8;
157 file_task.transfer.transfer_config.path = file_task.transfer.remote_path.clone();
160 file_task.transfer.local_path.clone(),
161 file_task.transfer.transfer_config.optional_name
164 .transfer
217 task.transfer.is_master = true;
246 if task.transfer.server_or_daemon {
252 task.transfer.transfer_config.compress_type = CompressType::Lz4 as u8;
256 task.transfer.transfer_config.hold_timestamp = true;
260 task.transfer.transfer_config.update_if_new = true;
271 task.transfer.transfer_config.client_cwd = argv.get(i + 1).unwrap().clone();
281 task.transfer.remote_path = argv.last().unwrap().clone();
282 task.transfer.local_path = argv.get(argv.len() - 2).unwrap().clone();
283 if task.transfer.server_or_daemon {
288 let cwd = task.transfer.transfer_config.client_cwd.clone();
289 task.transfer.local_path = Base::extract_relative_path(&cwd, &task.transfer.local_path);
291 task.transfer.remote_path = String::from(".");
292 task.transfer.local_path = argv.get((argc - 1) as usize).unwrap().clone();
294 task.transfer.local_name = Base::get_file_name(&mut task.transfer.local_path).unwrap();
295 match metadata(task.transfer.local_path.clone()) {
298 task.transfer.is_dir = false;
301 task.transfer.is_dir = true;
302 task.transfer.task_queue = get_sub_files_resurively(&task.transfer.local_path.clone());
303 task.transfer.base_local_path = get_base_path(task.transfer.local_path.clone());
305 if !task.transfer.task_queue.is_empty() {
306 task.transfer.local_path = task.transfer.task_queue.pop().unwrap();
307 task.transfer.local_name =
308 match Base::get_relative_path(&task.transfer.base_local_path, &task.transfer.local_path) {
310 None => task.transfer.local_path.clone()
313 crate::error!("task transfer task_queue is empty");
318 let err_msg = format!("Error opening file: {}, path: {}", error, task.transfer.local_path);
344 payload: task.transfer.transfer_config.serialize(),
346 transfer::put(task.transfer.session_id, file_check_message).await;
361 task.transfer.file_size = transconfig.file_size;
363 task.transfer.local_path = transconfig.path;
364 task.transfer.is_master = false;
365 task.transfer.index = 0;
368 task.transfer.local_path.clone(),
371 task.transfer.command_str.push_str(command_str.as_str());
372 let local_path = task.transfer.local_path.clone();
374 task.transfer.transfer_config.compress_type = transconfig.compress_type;
375 match hdctransfer::check_local_path(&mut task.transfer, &local_path, &optional_name) {
382 if task.transfer.transfer_config.update_if_new {
383 crate::error!("task.transfer.transfer_config.update_if_new is true");
399 transfer::put(session_id, wake_up_message).await;
408 transfer::put(session_id, file_begin_message).await;
419 let Some(local_path) = task.transfer.task_queue.pop() else {
425 task.transfer.local_path = local_path;
426 task.transfer.local_name =
427 match Base::get_relative_path(&task.transfer.base_local_path, &task.transfer.local_path) {
429 None => task.transfer.local_path.clone()
443 let last_error = task.transfer.last_error;
464 task.transfer.local_path,
471 transfer::EchoLevel::OK
473 transfer::EchoLevel::FAIL
476 transfer::send_channel_msg(task.transfer.channel_id, level, message)
489 task.transfer.session_id,
490 task.transfer.channel_id,
507 task.transfer.task_queue.is_empty()
526 transfer::put(session_id, _finish_message).await;
550 transfer::put(session_id, task_finish_message).await;
593 hdctransfer::transfer_begin(&task.transfer, HdcCommand::FileData).await;
603 if hdctransfer::transfer_data(&mut task.transfer, _payload) {
628 transfer::put(session_id, task_message).await;
648 format!("Error opening file: {}, path: {}", error, task.transfer.local_path)