Home
last modified time | relevance | path

Searched refs:transfer (Results 1 – 25 of 108) sorted by relevance

12345

/developtools/hdc/hdc_rust/src/common/
Dhdcfile.rs18 use crate::transfer;
45 pub transfer: HdcTransferBase, field
51 transfer: HdcTransferBase::new(_session_id, _channel_id), in new()
98 let local_path = file_task.transfer.local_path.clone(); in check_local_path()
102 file_task.transfer.transfer_config.file_size = file_manager.file_size(); in check_local_path()
103 file_task.transfer.file_size = file_task.transfer.transfer_config.file_size; in check_local_path()
104 file_task.file_size = file_task.transfer.transfer_config.file_size; in check_local_path()
105 file_task.transfer.transfer_config.optional_name = file_task.transfer.local_name.clone(); in check_local_path()
106 if transfer::base::CheckCompressVersion::get().await in check_local_path()
107 && (file_task.transfer.transfer_config.file_size > (MAX_SIZE_IOBUF as u64)) in check_local_path()
[all …]
Dhdctransfer.rs27 use crate::transfer;
108 transfer: &mut HdcTransferBase, in check_local_path()
115 transfer.is_dir = f.is_dir(); in check_local_path()
116 if f.is_dir() && !transfer.local_path.ends_with(Base::get_path_sep()) { in check_local_path()
117 transfer in check_local_path()
125 if op.contains(Base::get_path_sep()) && !transfer.local_path.ends_with(Base::get_path_sep()) { in check_local_path()
126 transfer in check_local_path()
131 if transfer.local_path.ends_with(Base::get_path_sep()) { in check_local_path()
132 transfer.local_path.push_str(op.as_str()); in check_local_path()
134 if transfer.local_path.ends_with(Base::get_path_sep()) { in check_local_path()
[all …]
/developtools/hdc/hdc_rust/src/host/
Dhost_app.rs24 use hdc::transfer;
25 use hdc::transfer::EchoLevel;
30 pub transfer: HdcTransferBase, field
36 transfer: HdcTransferBase::new(_session_id, _channel_id), in new()
67 self.transfer.transfer_config.client_cwd = argv[i + 1].clone(); in init_install()
78 &self.transfer.transfer_config.client_cwd, in init_install()
82 self.transfer.task_queue.push(path.clone()); in init_install()
85 self.transfer.task_queue.append(&mut queue); in init_install()
91 if self.transfer.task_queue.is_empty() { in init_install()
95 self.transfer.transfer_config.options = options.clone(); in init_install()
[all …]
Dtask.rs21 use hdc::transfer;
65 transfer::TcpMap::end(task_info.channel_id).await; in channel_task_dispatch()
101 transfer::put( in channel_hilog_task()
116 transfer::put( in channel_bug_report_task()
151 task.transfer.server_or_daemon = true; in channel_file_task()
156 task.transfer.server_or_daemon = true; in channel_file_task()
196 transfer::put( in channel_unity_task()
219 transfer::put( in channel_shell_task()
230 transfer::put( in channel_shell_task()
242 transfer::put( in channel_shell_task()
[all …]
/developtools/smartperf_host/ide/src/trace/database/data-trafic/
DFrameDynamicEffectReceiver.ts87 let transfer = data.params.trafic !== TraficEnum.SharedArrayBuffer;
88 let frameAnimation = new FrameAnimation(data, res, transfer);
128 postFrameAnimationMessage(data, transfer, frameAnimation, res.length);
130 function postFrameAnimationMessage(data: any, transfer: boolean, frameAnimation: FrameAnimation, le…
135 results: transfer
146 transfer: transfer,
148 transfer
168 constructor(data: any, res: any[], transfer: boolean) {
169 …this.animationId = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.animatio…
170 this.status = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.status);
[all …]
DEnergySysEventReceiver.ts141 function systemBufferHandler(data: any, res: any[], transfer: boolean) {
142 let hiSysEnergy = new HiSysEnergy(data, res, transfer);
176 postMessage(data, transfer, hiSysEnergy, res.length);
279 function postMessage(data: any, transfer: boolean, hiSysEnergy: HiSysEnergy, len: number): void {
284 results: transfer
295 transfer: transfer,
297 transfer
318 constructor(data: any, res: any[], transfer: boolean) {
319 this.id = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.id);
320 this.startNs = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startNs);
[all …]
DHiSysEventDataReceiver.ts48 function arrayBufferHandler(data: any, res: any[], transfer: boolean) {
49 let id = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.id);
50 let ts = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.ts);
51 let pid = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.pid);
52 let tid = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.tid);
53 let seq = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.seq);
54 let uid = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.uid);
55 let dur = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.dur);
56 let depth = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.depth);
72 results: transfer
[all …]
DLogDataReceiver.ts61 function arrayBufferHandler(data: any, res: any[], transfer: boolean) {
62 let id = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.id);
63 let startTs = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startTs);
64 let pid = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.pid);
65 let tid = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.tid);
66 let dur = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.dur);
67 let depth = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.depth);
82 results: transfer
93 transfer: transfer,
95 transfer ? [id.buffer, startTs.buffer, pid.buffer, tid.buffer, dur.buffer, depth.buffer] : []
DFrameJanksReceiver.ts126 function frameJanksReceiver(data: any, res: any[], type: string, transfer: boolean): void {
127 let frameJanks = new FrameJanks(data, transfer, res.length);
171 postFrameJanksMessage(data, transfer, frameJanks, res.length);
190 function setResults(transfer: boolean, frameJanks: FrameJanks): any {
191 return transfer
211 function postFrameJanksMessage(data: any, transfer: boolean, frameJanks: FrameJanks, len: number) {
212 let results = setResults(transfer, frameJanks);
219 transfer: transfer,
221 transfer
258 constructor(data: any, transfer: boolean, len: number) {
[all …]
DCpuDataReceiver.ts93 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
94 …let startTime = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startTime);
95 let dur = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.dur);
96 let tid = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.tid);
97 let id = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.id);
98 let processId = new Int16Array(transfer ? res.length : data.params.sharedArrayBuffers.processId);
99 let cpu = new Uint8Array(transfer ? res.length : data.params.sharedArrayBuffers.cpu);
100 let argSetId = new Int8Array(transfer ? res.length : data.params.sharedArrayBuffers.argSetId);
101 let nofinish = new Uint8Array(transfer ? res.length : data.params.sharedArrayBuffers.nofinish);
117 results: transfer
[all …]
DIrqDataReceiver.ts93 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
94 let startNS = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startNS);
95 let dur = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.dur);
96 let depth = new Uint32Array(transfer ? res.length : data.params.sharedArrayBuffers.depth);
97 let argSetId = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.argSetId);
98 let id = new Uint32Array(transfer ? res.length : data.params.sharedArrayBuffers.id);
111 results: transfer
121 transfer: transfer,
123 transfer ? [startNS.buffer, dur.buffer, depth.buffer, argSetId.buffer, id.buffer] : []
DVirtualMemoryDataReceiver.ts61 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
62 …let startTime = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startTime);
63 let value = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.value);
64 let filterID = new Uint8Array(transfer ? res.length : data.params.sharedArrayBuffers.filterID);
75 results: transfer
83 transfer: transfer,
85 transfer ? [startTime.buffer, value.buffer, filterID.buffer] : []
/developtools/smartperf_host/ide/src/trace/database/data-trafic/process/
DProcessDeliverInputEventDataReceiver.ts51 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
52 let processDeliverInputEvent = new ProcessDeliverInputEvent(data, transfer, res.length);
67 postMessage(data, transfer, processDeliverInputEvent, res.length);
69 function postMessage(data: any, transfer: boolean, processDeliverInputEvent: ProcessDeliverInputEve…
72 transfer: transfer,
75 results: transfer
92 transfer
121 constructor(data: any, transfer: boolean, len: number) {
122 this.tid = new Int32Array(transfer ? len : data.params.sharedArrayBuffers.tid);
123 this.pid = new Int32Array(transfer ? len : data.params.sharedArrayBuffers.pid);
[all …]
DProcessActualDataReceiver.ts76 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
77 let processActual = new ProcessActual(data, transfer, res.length);
94 postProcessActualMessage(data, transfer, processActual, res.length);
96 function postProcessActualMessage(data: any, transfer: boolean, processActual: ProcessActual, len: …
101 results: transfer
115 transfer: transfer,
117 transfer
142 constructor(data: any, transfer: boolean, len: number) {
143 this.ts = new Float64Array(transfer ? len : data.params.sharedArrayBuffers.ts);
144 this.dur = new Float64Array(transfer ? len : data.params.sharedArrayBuffers.dur);
[all …]
DProcessSoInitDataReceiver.ts39 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
40 let startTs = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startTs);
41 let dur = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.dur);
42 let pid = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.pid);
43 let tid = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.tid);
44 let itid = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.itid);
45 let depth = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.depth);
46 let id = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.id);
59 transfer: transfer,
62 results: transfer
[all …]
DProcessStartupDataReceiver.ts39 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
40 let startTs = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startTime);
41 let dur = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.dur);
42 let pid = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.pid);
43 let tid = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.tid);
44 let itid = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.itid);
45 let startName = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.startName);
59 results: transfer
70 transfer: transfer,
72 transfer ? [dur.buffer, startTs.buffer, pid.buffer, tid.buffer, itid.buffer] : []
DProcessDataReceiver.ts61 let transfer = data.params.trafic !== TraficEnum.SharedArrayBuffer;
64 arrayBufferHandler(data, res, transfer);
68 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
69 …let startTime = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startTime);
70 let dur = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.dur);
71 let cpu = new Uint8Array(transfer ? res.length : data.params.sharedArrayBuffers.cpu);
82 results: transfer
90 transfer: transfer,
92 transfer ? [startTime.buffer, dur.buffer, cpu.buffer] : []
DProcessExpectedDataReceiver.ts70 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
71 let ts = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.ts);
72 let dur = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.dur);
73 let pid = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.pid);
74 let id = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.id);
75 let name = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.name);
76 let type = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.type);
77 let depth = new Uint16Array(transfer ? res.length : data.params.sharedArrayBuffers.depth);
93 results: transfer
105 transfer: transfer,
[all …]
DProcessMemDataReceiver.ts42 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
43 …let startTime = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startTime);
44 let ts = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.ts);
45 let value = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.value);
46 let track_id = new Uint8Array(transfer ? res.length : data.params.sharedArrayBuffers.track_id);
58 results: transfer
67 transfer: transfer,
69 transfer ? [ts.buffer, startTime.buffer, value.buffer, track_id.buffer] : []
DThreadDataReceiver.ts77 function arrayBufferHandler(data: any, res: any[], transfer: boolean, isEmpty: boolean): void {
78 …let startTime = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startTime);
79 let dur = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.dur);
80 let cpu = new Int8Array(transfer ? res.length : data.params.sharedArrayBuffers.cpu);
81 let id = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.id);
82 let tid = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.tid);
83 let state = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.state);
84 let pid = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.pid);
85 let argSetID = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.argSetID);
101 results: transfer
[all …]
DFuncDataReceiver.ts91 function arrayBufferHandler(data: any, res: any[], transfer: boolean,isEmpty:boolean): void {
92 let startTs = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.startTs);
93 let dur = new Float64Array(transfer ? res.length : data.params.sharedArrayBuffers.dur);
94 let argsetid = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.argsetid);
95 let depth = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.depth);
96 let id = new Int32Array(transfer ? res.length : data.params.sharedArrayBuffers.id);
109 results: transfer
119 transfer: transfer,
122 transfer ? [startTs.buffer, dur.buffer, argsetid.buffer, depth.buffer, id.buffer] : []
/developtools/smartperf_host/ide/src/trace/database/data-trafic/hiperf/
DHiperfThreadDataReceiver.ts64 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
68 let perfThread = new PerfThread(data, transfer, res.length);
90 postPerfThreadMessage(data, transfer, perfThread, res.length);
92 function postPerfThreadMessage(data: any, transfer: boolean, perfThread: PerfThread, len: number) {
97 results: transfer
108 transfer: transfer,
110 transfer
129 constructor(data: any, transfer: boolean, len: number) {
130 this.startNS = new Float64Array(transfer ? len : data.params.sharedArrayBuffers.startNS);
131 this.eventCount = new Int32Array(transfer ? len : data.params.sharedArrayBuffers.eventCount);
[all …]
DHiperfProcessDataReceiver.ts71 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
75 let perfProcess = new PerfProcess(data, transfer, res.length);
99 postPerfProcessMessage(data, transfer, perfProcess, res.length);
101 function postPerfProcessMessage(data: any, transfer: boolean, perfProcess: PerfProcess, len: number…
106 results: transfer
117 transfer: transfer,
119 transfer
138 constructor(data: any, transfer: boolean, len: number) {
139 this.startNS = new Float64Array(transfer ? len : data.params.sharedArrayBuffers.startNS);
140 this.eventCount = new Int32Array(transfer ? len : data.params.sharedArrayBuffers.eventCount);
[all …]
DHiperfCpuDataReceiver.ts69 function arrayBufferHandler(data: any, res: any[], transfer: boolean): void {
73 let perfCpu = new PerfCpu(data, transfer, res.length);
97 postPerfCpuMessage(data, transfer, perfCpu, res.length);
99 function postPerfCpuMessage(data: any, transfer: boolean, perfCpu: PerfCpu, len: number) {
102 transfer: transfer,
105 results: transfer
117 transfer
136 constructor(data: any, transfer: boolean, len: number) {
137 this.startNS = new Float64Array(transfer ? len : data.params.sharedArrayBuffers.startNS);
138 this.eventCount = new Int32Array(transfer ? len : data.params.sharedArrayBuffers.eventCount);
[all …]
/developtools/hdc/hdc_rust/src/daemon/
Dmain.rs36 use hdc::transfer;
37 use hdc::transfer::uart::UartReader;
38 use hdc::transfer::base::Reader;
39 use hdc::transfer::uart_wrapper;
82 let recv_msg = transfer::tcp::unpack_task_message(&mut rd).await?; in tcp_handle_client()
87 transfer::TcpMap::start(session_id, wr).await; in tcp_handle_client()
88 transfer::put(session_id, send_msg).await; in tcp_handle_client()
90 transfer::put( in tcp_handle_client()
103 transfer::tcp::unpack_task_message(&mut rd).await, in tcp_handle_client()
123 let fd = transfer::uart::uart_init()?; in uart_daemon_start()
[all …]

12345