Lines Matching refs:transfer
35 use crate::transfer;
168 transfer: &mut HdcTransferBase,
179 if transfer.is_local_dir_exsit.is_none() {
180 transfer.is_local_dir_exsit = Some(true);
182 transfer.is_dir = f.is_dir();
183 if f.is_dir() && !transfer.local_path.ends_with(Base::get_path_sep()) {
184 transfer
188 } else if transfer.is_local_dir_exsit.is_none() {
189 transfer.is_local_dir_exsit = Some(false);
194 if op.contains(Base::get_path_sep()) && !transfer.local_path.ends_with(Base::get_path_sep()) {
195 transfer
200 if transfer.local_path.ends_with(Base::get_path_sep()) {
201 let local_dir = transfer
206 if let Some(false) = transfer.is_local_dir_exsit {
218 transfer.local_path = Base::combine(local_dir, op);
221 "check_local_path, final transfer.local_path:{}",
222 transfer.local_path
224 if transfer.local_path.ends_with(Base::get_path_sep()) {
225 match create_dir_all_with_permission(transfer.local_path.clone(), 0o750) {
233 let last = transfer.local_path.rfind(Base::get_path_sep());
236 match create_dir_all_with_permission((transfer.local_path[0..index]).to_string(), 0o750) {
238 match File::create(transfer.local_path.clone()) {
241 set_file_permission(transfer.local_path.clone(), 0o644)?;
257 match File::create(transfer.local_path.clone()) {
260 set_file_permission(transfer.local_path.clone(), 0o644)?;
451 transfer::put(session_id, task_message).await;
527 "transfer file [{}] index {} / {}",
552 task.transfer.last_error = errno;
596 pub async fn transfer_begin(transfer: &HdcTransferBase, _command_data: HdcCommand) {
597 let local_path_ = transfer.local_path.clone();
601 transfer.session_id,
602 transfer.channel_id,
603 transfer.file_size,
605 &transfer.transfer_config,
620 transfer::put(_session_id, task_message).await;
629 transfer::put(_session_id, task_message).await;
633 transfer::TcpMap::end(channel_id).await;
640 MessageLevel::Ok => transfer::EchoLevel::OK,
641 MessageLevel::Fail => transfer::EchoLevel::FAIL,
642 MessageLevel::Info => transfer::EchoLevel::INFO,
645 transfer::send_channel_msg(channel_id, echo_level, message.to_string())
658 transfer::put(_session_id, echo_message).await;