| /developtools/hdc/hdc_rust/src/common/ |
| H A D | hdcfile.rs | 18 use crate::transfer;
52 pub transfer: HdcTransferBase,
58 transfer: HdcTransferBase::new(_session_id, _channel_id), in new()
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
[all...] |
| H A D | hdctransfer.rs | 35 use crate::transfer;
168 transfer: &mut HdcTransferBase, in check_local_path()
179 if transfer.is_local_dir_exsit.is_none() { in check_local_path()
180 transfer.is_local_dir_exsit = Some(true); in check_local_path()
182 transfer.is_dir = f.is_dir(); in check_local_path()
183 if f.is_dir() && !transfer.local_path.ends_with(Base::get_path_sep()) { in check_local_path()
184 transfer in check_local_path()
188 } else if transfer.is_local_dir_exsit.is_none() { in check_local_path()
189 transfer.is_local_dir_exsit = Some(false); in check_local_path()
194 if op.contains(Base::get_path_sep()) && !transfer in check_local_path()
[all...] |
| H A D | jdwp.rs | 22 use crate::{transfer, utils};
144 transfer::put(*session_id2, data).await;
|
| /developtools/hdc/hdc_rust/src/host/ |
| H A D | host_app.rs | 24 use hdc::transfer;
25 use hdc::transfer::EchoLevel;
36 pub transfer: HdcTransferBase,
44 transfer: HdcTransferBase::new(_session_id, _channel_id), in new()
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
[all...] |
| H A D | task.rs | 26 use hdc::transfer;
27 use hdc::transfer::send_channel_data;
86 transfer::TcpMap::end(task_info.channel_id).await;
149 task.transfer.server_or_daemon = true;
182 let _ = transfer::send_channel_msg(
184 transfer::EchoLevel::FAIL,
188 transfer::TcpMap::end(task_info.channel_id).await;
201 transfer::TcpMap::end(task_info.channel_id).await;
209 transfer::TcpMap::end(task_info.channel_id).await;
237 transfer
[all...] |
| H A D | server.rs | 26 use hdc::transfer;
270 let recv = match transfer::tcp::recv_channel_message(&mut rd).await {
325 transfer::TcpMap::start(channel_id, wr).await;
335 transfer::send_channel_data(channel_id, buf).await;
336 let recv = transfer::tcp::recv_channel_message(rd).await?;
|
| H A D | unittest.rs | 167 assert_eq!(task.transfer.local_path, "/home/1234.hap"); in if_init_install_works()
169 .transfer in if_init_install_works()
|
| H A D | client.rs | 21 use hdc::transfer;
105 transfer::ChannelMap::start(rd).await;
184 transfer::ChannelMap::recv().await
221 match transfer::ChannelMap::recv().await {
269 match transfer::ChannelMap::recv().await {
|
| H A D | auth.rs | 24 use hdc::transfer;
227 transfer::put(
|
| /developtools/hdc/hdc_rust/src/daemon_lib/ |
| H A D | mod.rs | 40 use crate::transfer;
42 use crate::transfer::base::Reader;
44 use crate::transfer::uart::UartReader;
46 use crate::transfer::uart_wrapper;
47 use crate::transfer::buffer::DiedSession;
138 transfer::put(session_id, send_msg).await;
141 transfer::put(
153 let ret = handle_message(transfer::tcp::unpack_task_message(&rd).await, session_id).await;
168 let msg = transfer::tcp::unpack_task_message(&mut rd).await?;
174 transfer
[all...] |
| H A D | daemon_app.rs | 27 use crate::transfer;
40 pub transfer: HdcTransferBase,
47 transfer: HdcTransferBase::new(_session_id, _channel_id), in new()
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
[all...] |
| H A D | task_manager.rs | 30 use crate::transfer::buffer;
31 use crate::transfer::TcpMap;
32 use crate::transfer::UsbMap;
33 use crate::transfer::ConnectTypeMap;
|
| H A D | auth.rs | 23 use crate::{transfer, utils};
210 transfer::put(
285 transfer::put(
400 transfer::put(session_id, message).await;
440 transfer::put(
466 transfer::put(
471 transfer::put(session_id, make_channel_close_message(channel_id).await).await;
492 transfer::put(
505 transfer::put(
521 transfer
[all...] |
| H A D | bridge.rs | 24 use crate::transfer::base;
25 use crate::transfer::base::Writer;
26 use crate::transfer::buffer::ConnectTypeMap;
|
| H A D | task.rs | 29 use crate::transfer;
118 transfer::put(session_id, message).await;
154 task.transfer.server_or_daemon = false;
170 task.transfer.server_or_daemon = false;
336 transfer::put(
|
| H A D | shell.rs | 24 use crate::transfer;
69 transfer::put(session_id, message).await;
200 transfer::put(session_id, message).await;
237 transfer::put(session_id, message).await;
310 transfer::put(session_id, message).await;
580 transfer::put(shell_task_id.session_id, message).await;
593 transfer::put(shell_task_id.session_id, message).await;
678 transfer::put(shell_task_id.session_id, message).await;
695 transfer::put(shell_task_id.session_id, message).await;
|
| /developtools/hdc/hdc_rust/src/cffi/host/ |
| H A D | host_usb.cpp | 389 libusb_cancel_transfer(hUSB->hostBulkIn.transfer);
in OpenDeviceMyNeed()
397 libusb_cancel_transfer(hUSB->hostBulkOut.transfer);
in OpenDeviceMyNeed()
412 void LIBUSB_CALL HostUsb::USBBulkCallback(struct libusb_transfer *transfer)
in OpenDeviceMyNeed() argument
414 auto *ep = reinterpret_cast<HostUSBEndpoint *>(transfer->user_data);
in OpenDeviceMyNeed()
419 if (transfer->status != LIBUSB_TRANSFER_COMPLETED) {
in OpenDeviceMyNeed()
422 if (!ep->bulkInOut && transfer->actual_length != transfer->length) {
in OpenDeviceMyNeed()
423 transfer->length -= transfer->actual_length;
in OpenDeviceMyNeed()
424 transfer in OpenDeviceMyNeed()
[all...] |
| H A D | host_usb.h | 69 transfer = libusb_alloc_transfer(0);
in HostUSBEndpoint()
78 libusb_free_transfer(transfer);
in ~HostUSBEndpoint()
90 libusb_transfer *transfer;
member
129 static void LIBUSB_CALL USBBulkCallback(struct libusb_transfer *transfer);
|
| /developtools/hdc/src/host/ |
| H A D | host_usb.cpp | 445 libusb_cancel_transfer(hUSB->hostBulkIn.transfer); in CancelUsbIo()
453 libusb_cancel_transfer(hUSB->hostBulkOut.transfer); in CancelUsbIo()
508 void LIBUSB_CALL HdcHostUSB::USBBulkCallback(struct libusb_transfer *transfer) in USBBulkCallback() argument
510 auto *ep = reinterpret_cast<HostUSBEndpoint *>(transfer->user_data); in USBBulkCallback()
515 if (transfer->status != LIBUSB_TRANSFER_COMPLETED) { in USBBulkCallback()
516 WRITE_LOG(LOG_FATAL, "USBBulkCallback1 failed, ret:%d", transfer->status); in USBBulkCallback()
519 if (!ep->bulkInOut && transfer->actual_length != transfer->length) { in USBBulkCallback()
520 transfer->length -= transfer in USBBulkCallback()
[all...] |
| H A D | host_usb.h | 42 static void LIBUSB_CALL USBBulkCallback(struct libusb_transfer *transfer);
|
| /developtools/hdc/hdc_rust/src/ |
| H A D | lib.rs | 27 pub mod transfer; modules
|
| /developtools/hdc/src/common/ |
| H A D | define_plus.h | 111 transfer = libusb_alloc_transfer(0); in HostUSBEndpoint()
120 libusb_free_transfer(transfer); in ~HostUSBEndpoint()
132 libusb_transfer *transfer; member
|
| /developtools/hdc/hdc_rust/src/host_transfer/ |
| H A D | host_usb.rs | 25 use crate::transfer::base;
32 use crate::transfer::base::Reader;
33 use crate::transfer::base::Writer;
34 use crate::transfer::buffer::ConnectTypeMap;
314 crate::debug!("transfer put data {:?}", body);
|
| /developtools/hdc/src/daemon/ |
| H A D | daemon_uart.cpp | 283 transfer.Wait();
in DeamonWriteThread()
|
| /developtools/hdc/test/unittest/common/ |
| H A D | host_uart_test.cpp | 634 mockHostUART.transfer.Request();
in HWTEST_F()
637 mockHostUART.transfer.Request();
in HWTEST_F()
|