Lines Matching refs:transfer
27 use crate::transfer;
40 pub transfer: HdcTransferBase,
47 transfer: HdcTransferBase::new(_session_id, _channel_id),
106 task.transfer.stop_run = true;
116 let command = task.transfer.command_str.clone();
159 task.transfer.transfer_config.options = transconfig.options.clone();
160 task.transfer.transfer_config.function_name = transconfig.function_name.clone();
163 task.transfer.command_str = format!(
167 task.transfer.is_master = false;
168 task.transfer.local_path = local_path;
169 task.transfer.file_size = transconfig.file_size;
170 task.transfer.index = 0;
174 return File::create(task.transfer.local_path.clone()).is_ok();
179 return File::create(task.transfer.local_path.clone()).is_ok();
190 transfer::put(session_id, file_begin_message).await;
220 transfer::put(session_id, app_finish_message).await;
306 let options = task.transfer.transfer_config.options.clone();
307 let mut local_path = task.transfer.local_path.clone();
362 let function_name = task.transfer.transfer_config.function_name.clone();
409 if task.transfer.stop_run {
410 crate::error!("stop_run {}", task.transfer.stop_run);
413 if hdctransfer::transfer_data(&mut task.transfer, _payload) {