Home
last modified time | relevance | path

Searched refs:send (Results 1 – 25 of 37) sorted by relevance

12

/developtools/hdc/hdc_rust/src/serializer/
Dunittest.rs25 let send = native_struct::SessionHandShake { in if_session_hand_shake_works() localVariable
34 let serialized = send.serialize(); in if_session_hand_shake_works()
40 assert_eq!(recv, send); in if_session_hand_shake_works()
45 let send = native_struct::TransferPayload { in if_session_transfer_payload_works() localVariable
52 let serialized = send.serialize(); in if_session_transfer_payload_works()
58 assert_eq!(recv, send); in if_session_transfer_payload_works()
63 let send = native_struct::TransferConfig { in if_transfer_config_works() localVariable
79 let serialized = send.serialize(); in if_transfer_config_works()
87 assert_eq!(recv, send); in if_transfer_config_works()
92 let send = native_struct::PayloadHead { in if_session_payload_head_works() localVariable
[all …]
/developtools/profiler/host/smartperf/client/client_ui/entry/src/main/ets/workers/
Dworker.js68 udp.send({
77 udp.send({
86 udp.send({
95 udp.send({
103 udp.send({
110 udp.send({
118 udp.send({
126 udp.send({
/developtools/hdc/hdc_rust/src/host/
Dclient.rs173 self.send(buf.as_slice()).await; in handshake()
178 async fn send(&mut self, buf: &[u8]) { in send() method
190 self.send(self.params.join(" ").as_bytes()).await; in unity_task()
195 self.send(self.params.join(" ").as_bytes()).await; in wait_task()
203 self.send(self.params.join(" ").as_bytes()).await; in unity_root_run_task()
207 self.send(self.params.join(" ").as_bytes()).await; in jdwp_task()
217 self.send(cmd.as_bytes()).await; in shell_task()
247 self.send(&buf[..bytes]).await; in shell_task()
256 self.send([c as u8].as_slice()).await; in shell_task()
268 self.send(self.params.join(" ").as_bytes()).await; in forward_task()
[all …]
/developtools/profiler/device/services/ipc/src/
Dsocket_context.cpp164 …CHECK_TRUE(send(sockfd, reinterpret_cast<int8_t*>(&phead), sizeof(struct ProtocolHead), 0) != -1, … in SendRaw()
167 CHECK_TRUE(send(sockfd, data, size, 0) != -1, false, "SendRaw Send Data ERR : %d", errno); in SendRaw()
184 send(socketHandle_, reinterpret_cast<int8_t*>(&phead), sizeof(struct ProtocolHead), 0); in SendProtobuf()
185 send(socketHandle_, data, size, 0); in SendProtobuf()
201 send(socketHandle_, reinterpret_cast<int8_t*>(&phead), sizeof(struct ProtocolHead), 0); in SendHookConfig()
202 send(socketHandle_, config, len, 0); in SendHookConfig()
212 …if (send(socketHandle_, reinterpret_cast<int8_t*>(&phead), sizeof(struct ProtocolHead), 0) == -1) { in SendHeartBeat()
216 if (send(socketHandle_, &HEARTBEAT_MSG, sizeof(HEARTBEAT_MSG), 0) == -1) { in SendHeartBeat()
/developtools/ace_ets2bundle/compiler/src/fast_build/ark_compiler/common/
Dgen_abc.ts43 process.send({ data: e.toString() });
69 process.send({ data: e.toString() });
81 process.send({
101 process.send({
/developtools/integration_verification/DeployDevice/src/aw/poweronoff/
Dserial_power_on_off.py43 def send(self, msg): member in SocketCon
73 if self.send(msg):
145 if serialPort.send(sendMsg):
192 if usbpower.send(sendMsg):
241 if usbpower.send(sendMsg):
/developtools/hdc/hdc_rust/src/daemon/
Dauth.rs136 let send = native_struct::SessionHandShake { in handshake_init() localVariable
145 hdc::info!("send handshake: {:?}", send); in handshake_init()
149 payload: send.serialize(), in handshake_init()
155 let send = native_struct::SessionHandShake { in make_sign_message() localVariable
166 payload: send.serialize(), in make_sign_message()
179 let send = native_struct::SessionHandShake { in make_bypass_message() localVariable
190 payload: send.serialize(), in make_bypass_message()
223 let send = native_struct::SessionHandShake { in make_emg_message() localVariable
234 payload: send.serialize(), in make_emg_message()
253 let send = native_struct::SessionHandShake { in make_reject_message() localVariable
[all …]
/developtools/profiler/host/smartperf/client/client_command/
Dclient_control.cpp35 send(clientSocket, messageInit.c_str(), strlen(messageInit.c_str()), 0); in SocketStart()
37 send(clientSocket, message1, strlen(message1), 0); in SocketStart()
59 send(clientSocket, message2, strlen(message2), 0); in SocketStop()
/developtools/hdc/hdc_rust/src/transfer/
Dbase.rs113 .send(TaskMessage { in unpack_task_message_lock()
135 .send(TaskMessage { in unpack_task_message_lock()
152 .send(TaskMessage { in unpack_task_message_lock()
210 .send(( in unpack_task_message()
Duart_wrapper.rs522 let send = serializer::concat_pack(data); in wrap_put() localVariable
523 crate::info!("wrap_put send len:{}, send:{:#?}", send.len(), send); in wrap_put()
527 let len = send.len(); in wrap_put()
543 let data = send[index..index + size].to_vec().clone(); in wrap_put()
554 let total = [header, send[index..index + size].to_vec().clone()].concat(); in wrap_put()
Dbuffer.rs105 let send = serializer::concat_pack(data); in put() localVariable
113 let _ = wr.write_all(send.as_slice()).await; in put()
124 let send = [ in send_channel_message() localVariable
133 let _ = wr.write_all(send.as_slice()).await; in send_channel_message()
/developtools/hdc/hdc_rust/src/daemon_lib/
Dbridge.rs150 let send = serializer::concat_pack(data); in put() localVariable
157 let _ = wr.write_all(send); in put()
168 let send = [ in send_channel_message() localVariable
177 let _ = wr.write_all(send); in send_channel_message()
/developtools/profiler/hiebpf/src/
Dipc_unix_socket.cpp86 CHECK_TRUE(send(clientFd_, buf, size, 0) != -1, false, in SendMessage()
169 if (send(sockFd_, buf, size, 0) != -1) { in SendMessage()
/developtools/smartperf_host/ide/test/statistics/util/
DSpStatisticsHttpUtil.test.ts29 send: jest.fn(),
/developtools/hdc/hdc_rust/src/common/
Duds.rs25 use libc::{eventfd, fcntl, pipe, read, send, socketpair, write, MSG_EOR};
219 unsafe { send(socket_fd, ptr, buffer.len(), flags) } in wrap_send()
319 unsafe { send(socket_fd, ptr, buffer.len(), flags) } in wrap_send()
/developtools/hiperf/test/fuzztest/resource/
Dsend_to_device.bat18 hdc_std file send %%f /data/test/resource/testdata/
/developtools/hiperf/test/unittest/resource/
Dsend_to_device.bat18 hdc_std file send %%f /data/test/resource/testdata/
Dsend_dwarf_to_device.bat18 hdc_std file send %%f /data/test/resource/testdata/dwarf/
Dsend_report_to_device.bat18 hdc_std file send %%f /data/test/resource/testdata/report/
/developtools/profiler/device/plugins/native_daemon/test/unittest/resource/
Dsend_to_device.bat18 hdc_std file send %%f /data/test/resource/testdata/
Dsend_dwarf_to_device.bat18 hdc_std file send %%f /data/test/resource/testdata/dwarf/
/developtools/hdc/hdc_rust/src/host_transfer/
Dhost_usb.rs252 .send(( in unpack_task_message()
332 let send = [ in send_channel_message() localVariable
341 let _ = wr.write_all(send); in send_channel_message()
/developtools/smartperf_host/ide/src/hdc/hdcclient/
DHdcClient.ts65 let sendResult = await this.readDataProcessing.send(
/developtools/smartperf_host/ide/src/statistics/util/
DSpStatisticsHttpUtil.ts55 req.send(null);
/developtools/smartperf_host/ide/src/hdc/transmission/
DDataProcessing.ts81 public async send( method in DataProcessing

12