Home
last modified time | relevance | path

Searched refs:recv (Results 1 - 20 of 20) sorted by relevance

/developtools/hdc/hdc_rust/src/serializer/
H A Dunittest.rs35 let mut recv = native_struct::SessionHandShake::default(); in if_session_hand_shake_works() variables
36 let suc = recv.parse(serialized); in if_session_hand_shake_works()
38 println!("{:#?}", recv); in if_session_hand_shake_works()
40 assert_eq!(recv, send); in if_session_hand_shake_works()
53 let mut recv = native_struct::TransferPayload::default(); in if_session_transfer_payload_works() variables
54 let suc = recv.parse(serialized); in if_session_transfer_payload_works()
56 println!("{:#?}", recv); in if_session_transfer_payload_works()
58 assert_eq!(recv, send); in if_session_transfer_payload_works()
80 let mut recv = native_struct::TransferConfig { in if_transfer_config_works() variables
83 let suc = recv in if_transfer_config_works()
100 let mut recv = native_struct::PayloadHead::default(); if_session_payload_head_works() variables
[all...]
/developtools/integration_verification/DeployDevice/src/aw/poweronoff/
H A Dserial_power_on_off.py74 recv = self.receive()
75 if recv == "认证错误!":
77 elif recv == "Error":
98 ret = self.recv(size)
100 recv = ret.decode(self.encoding)
101 return recv
146 recv = serialPort.receive()
149 if recv == recvMsg:
193 recv = usbpower.receive()
196 logger.info(recv)
[all...]
/developtools/hdc/hdc_rust/src/host/
H A Dclient.rs153 let recv = self.recv().await?;
154 let msg = match std::str::from_utf8(&recv[..config::HANDSHAKE_MESSAGE.len()]) {
182 async fn recv(&mut self) -> io::Result<Vec<u8>> {
183 hdc::debug!("channel recv buf");
184 transfer::ChannelMap::recv().await
221 match transfer::ChannelMap::recv().await {
222 Ok(recv) => {
223 let _ = utils::print_msg(recv).await;
269 match transfer::ChannelMap::recv()
[all...]
H A Dauth.rs123 let mut recv = SessionHandShake::default(); variables
125 recv.parse(msg.payload)?;
126 hdc::info!("recv handshake: {:#?}", recv);
128 if recv.banner != config::HANDSHAKE_MESSAGE {
129 hdc::info!("invalid banner {}", recv.banner);
133 if recv.auth_type == config::AuthType::OK as u8 {
134 handshake_deal_daemon_auth_result(recv.clone(), connect_key.clone()).await
135 } else if recv.auth_type == config::AuthType::Publickey as u8 {
151 } else if recv
[all...]
H A Dserver.rs270 let recv = match transfer::tcp::recv_channel_message(&mut rd).await {
271 Ok(recv) => recv,
277 hdc::debug!("recv hex: {}", recv.iter().map(|c| format!("{c:02x}")).collect::<Vec<_>>().join(" "));
279 let recv_str = String::from_utf8_lossy(&recv.clone()).into_owned();
280 hdc::debug!("recv str: {}", recv_str.clone());
282 String::from_utf8_lossy(&recv)
336 let recv = transfer::tcp::recv_channel_message(rd).await?;
337 let connect_key = unpack_channel_handshake(recv)
[all...]
H A Dtask.rs464 match rx.recv().await {
467 "in usb_handle_deamon, recv cmd: {:#?}, payload len: {}",
479 return Err(Error::new(ErrorKind::Other, "recv error"));
583 // "in tcp_handle_deamon, recv cmd: {:#?}, payload len: {}",
774 hdc::info!("recv channel close {}", task_message.channel_id);
/developtools/hdc/hdc_rust/src/daemon_lib/
H A Dauth.rs103 let mut recv = native_struct::SessionHandShake::default(); variables
104 recv.parse(task_message.payload)?;
106 crate::info!("recv handshake: {:#?}", recv);
107 if recv.banner != HANDSHAKE_MESSAGE {
111 let session_id = recv.session_id;
113 let host_ver = recv.version.as_str();
122 recv.session_id
126 recv.session_id,
133 recv
375 let mut recv = native_struct::SessionHandShake::default(); global() variables
562 let mut recv = native_struct::SessionHandShake::default(); global() variables
[all...]
H A Dmod.rs283 match rx.recv().await {
285 let _ = rx.recv().await;
293 format!("uart recv handshake error, {e:?}"),
327 match rx.recv().await {
347 let error_msg = format!("uart recv error: {e:?}");
379 match rx.recv().await {
H A Dshell.rs208 recv_res = rx.recv() => {
248 crate::debug!("rx recv failed: {e:?}");
562 crate::debug!("pipe recv {:?}", val);
/developtools/hdc/hdc_rust/src/transfer/
H A Duart.rs110 let recv = ReadUartDevExt(self.fd, (expected_size - index) as i32); in read_frame()
112 recv.ptr as *const libc::c_uchar, in read_frame()
113 recv.size as usize, in read_frame()
115 index += recv.size as usize; in read_frame()
H A Dbuffer.rs405 // client recv and print msg
427 pub async fn recv() -> io::Result<Vec<u8>> {
/developtools/hdc/src/test/jdwp/
H A DHdcJdwpSimulator.cpp101 std::unique_ptr<char[]> recv = std::make_unique<char[]>(nread + 1); in ProcessIncoming() local
102 if (memset_s(recv.get(), nread, 0, nread) != EOK) { in ProcessIncoming()
106 if (memcpy_s(recv.get(), nread, buf->base, nread) != EOK) { in ProcessIncoming()
111 HiLog::Info(LABEL, "ProcessIncoming recv2[%{public}d] :%{public}c", i, recv[i]); in ProcessIncoming()
/developtools/profiler/hiebpf/src/
H A Dipc_unix_socket.cpp113 int recvSize = recv(clientFd_, buf, UNIX_SOCKET_BUFFER_SIZE, 0); in HandleThreadLoop()
120 HHLOGE(true, "recv failed, peer has closed"); in HandleThreadLoop()
122 HHLOGE(true, "recv failed, Unix Socket(%d), %d: %s", clientFd_, errno, strerror(errno)); in HandleThreadLoop()
189 int recvSize = recv(sockFd_, buf, size, 0); in RecvMessage()
194 HHLOGE(true, "recv failed, peer has closed"); in RecvMessage()
196 HHLOGE(true, "recv failed, Unix Socket(%d), %d: %s", sockFd_, errno, strerror(errno)); in RecvMessage()
/developtools/hdc/hdc_rust/src/common/
H A Duds.rs23 use libc::{c_char, listen, poll, recv, socket, MSG_NOSIGNAL};
153 unsafe { recv(socket_fd, ptr, buffer.len(), MSG_NOSIGNAL) } in wrap_recv()
303 unsafe { recv(socket_fd, ptr, buffer.len(), MSG_NOSIGNAL) } in wrap_recv()
H A Dforward.rs787 "recv tcp msg read failed session_id={session_id},channel_id={channel_id}"
1590 crate::info!("command_dispatch command recv: {:?}", command);
/developtools/profiler/device/services/ipc/src/
H A Dsocket_context.cpp85 int ret = recv(sock, &databuf[p], size - p, 0); in ReceiveData()
236 ssize_t recv_bytes = recv(socketHandle_, buf, sizeof(buf), MSG_DONTWAIT); in IsConnected()
/developtools/profiler/host/smartperf/client/client_command/
H A Dsp_server_socket.cpp119 int l = recv(connFd, rbuf, sizeof(rbuf) - 1, 0); in Recv()
123 LOGE("SpServerSocket::recv Error(%d) fd(%d)", l, connFd); in Recv()
/developtools/hdc/scripts/
H A Ddev_hdc_test.py422 cmd = f"file recv {remote_path} {local_path}"
509 cmd = f"file recv {remote_soft} {local_recv}"
699 print("generating recv test dir ...")
717 print("generating recv test dir ...")
779 cmd_recv = f"file recv {get_remote_path(f'it_{size}_mix_{i}')} {get_local_path(f'recv_{size}_mix_{i}')}"
790 for recv in list_recv:
792 recv.start()
794 for recv in list_recv:
795 recv.join()
829 elif mode == "recv"
[all...]
/developtools/hdc/test/scripts/
H A Dhdc_recv_all_test.py82 recv_cmd = f"hdc file recv {device_tmp_dir}/{file_id} {local}"
117 recv_cmd = f"hdc file recv {remote} {local_real}"
175 if action == 'recv':
211 def merge_file(tmp_dir, file_num, input_name, action='recv'):
222 if action == 'recv':
223 header = "file_id,ls result,recv result,full path,save dir,ls output,recv output\n"
225 header = "file_id,ls result,recv result,full path,dave dir,ls output,copy output,copied ls output,\
226 recv output,remove output\n"
282 "请输入数字选择测试内容：\n1. [recv]use
[all...]
/developtools/profiler/hiebpf/include/
H A Dvmlinux.h52449 int (*recv)(struct tpm_chip *, u8 *, size_t); global() member
[all...]

Completed in 444 milliseconds