Home
last modified time | relevance | path

Searched refs:io (Results 1 – 25 of 111) sorted by relevance

12345

/developtools/hdc/hdc_rust/src/host/
Dclient.rs24 use std::io::{self, Error, ErrorKind, Write};
29 use ylong_runtime::io::AsyncReadExt;
30 use ylong_runtime::io::AsyncWriteExt;
46 pub async fn run_client_mode(parsed_cmd: ParsedCommand) -> io::Result<()> { in run_client_mode()
82 pub async fn new(parsed_cmd: ParsedCommand) -> io::Result<Self> { in new()
103 async fn execute_command(&mut self) -> io::Result<()> { in execute_command()
129 pub async fn handshake(&mut self) -> io::Result<()> { in handshake()
154 async fn recv(&mut self) -> io::Result<Vec<u8>> { in recv()
159 async fn unity_task(&mut self) -> io::Result<()> { in unity_task()
164 async fn shell_task(&mut self) -> io::Result<()> { in shell_task()
[all …]
Dauth.rs25 use std::io::{self, Error, ErrorKind};
37 ) -> io::Result<(String, String)> { in handshake_with_daemon()
86 fn load_or_create_prikey() -> io::Result<Rsa<openssl::pkey::Private>> { in load_or_create_prikey()
104 pub fn create_prikey() -> io::Result<Rsa<openssl::pkey::Private>> { in create_prikey()
119 fn get_pubkey_pem(rsa: &Rsa<openssl::pkey::Private>) -> io::Result<String> { in get_pubkey_pem()
137 fn get_signature_b64(rsa: &Rsa<openssl::pkey::Private>, plain: String) -> io::Result<String> { in get_signature_b64()
176 fn get_hostname() -> io::Result<String> { in get_hostname()
Dtask.rs25 use std::io::{self, Error, ErrorKind};
40 pub async fn channel_task_dispatch(task_info: TaskInfo) -> io::Result<()> { in channel_task_dispatch()
93 async fn channel_hilog_task(task_info: TaskInfo) -> io::Result<()> { in channel_hilog_task()
113 async fn channel_bug_report_task(task_info: TaskInfo) -> io::Result<()> { in channel_bug_report_task()
128 async fn channel_file_task(task_info: TaskInfo) -> io::Result<()> { in channel_file_task()
185 async fn channel_unity_task(task_info: TaskInfo) -> io::Result<()> { in channel_unity_task()
208 async fn channel_shell_task(task_info: TaskInfo) -> io::Result<()> { in channel_shell_task()
258 async fn channel_connect_task(task_info: TaskInfo) -> io::Result<()> { in channel_connect_task()
331 async fn channel_list_targets_task(task_info: TaskInfo) -> io::Result<()> { in channel_list_targets_task()
348 ) -> io::Result<()> { in tcp_handle_deamon()
[all …]
/developtools/hapsigner/hapsigntool/hap_sign_tool_lib/src/main/java/com/ohos/hapsigntool/codesigning/utils/
DInputStreamUtils.java18 import java.io.ByteArrayOutputStream;
19 import java.io.IOException;
20 import java.io.InputStream;
21 import java.io.OutputStream;
/developtools/hdc/hdc_rust/src/daemon/
Dshell.rs24 use std::io::{self, Error, ErrorKind, Read as _, Write as _};
49 pub fn set_pts(&mut self, pts: &Pts) -> io::Result<()> { in set_pts()
59 pub fn spawn(&mut self) -> io::Result<std::process::Child> { in spawn()
69 pub fn new() -> io::Result<Self> { in new()
91 pub fn get_pts(&self) -> io::Result<Pts> { in get_pts()
108 impl io::Read for Pty {
109 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
114 impl io::Write for Pty {
115 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
119 fn flush(&mut self) -> io::Result<()> { in flush()
[all …]
Dmain.rs27 use std::io::{self, ErrorKind, Write};
59 async fn handle_message(res: io::Result<TaskMessage>, session_id: u32) -> io::Result<()> { in handle_message()
80 async fn tcp_handle_client(stream: TcpStream) -> io::Result<()> { in tcp_handle_client()
110 async fn tcp_daemon_start(port: u16) -> io::Result<()> { in tcp_daemon_start()
121 async fn uart_daemon_start() -> io::Result<()> { in uart_daemon_start()
134 ) -> io::Result<u32> { in uart_handshake()
160 async fn uart_handle_client(fd: i32) -> io::Result<()> { in uart_handle_client()
182 return Err(std::io::Error::new(ErrorKind::Other, "uart recv handshake error")); in uart_handle_client()
234 return Err(std::io::Error::new(ErrorKind::Other, "RecvError")); in uart_handle_client()
241 async fn usb_daemon_start() -> io::Result<()> { in usb_daemon_start()
[all …]
/developtools/hiperf/include/
Dreport_protobuf_file.h40 class ReportProtobufFileWriter : public google::protobuf::io::CopyingOutputStream {
55 std::unique_ptr<google::protobuf::io::CopyingOutputStreamAdaptor> protpbufOutputStream_;
56 std::unique_ptr<google::protobuf::io::CodedOutputStream> protpbufCodedOutputStream_;
77 class ReportProtobufFileReader : public google::protobuf::io::CopyingInputStream {
82 std::unique_ptr<google::protobuf::io::CopyingInputStreamAdaptor> protpbufInputStream_;
83 std::unique_ptr<google::protobuf::io::CodedInputStream> protpbufCodedInputStream_;
/developtools/hapsigner/hapsigntool/hap_sign_tool_lib/src/main/java/com/ohos/hapsigntool/utils/
DFileUtils.java25 import java.io.BufferedWriter;
26 import java.io.ByteArrayOutputStream;
27 import java.io.Closeable;
28 import java.io.DataOutputStream;
29 import java.io.File;
30 import java.io.FileInputStream;
31 import java.io.FileNotFoundException;
32 import java.io.FileOutputStream;
33 import java.io.IOException;
34 import java.io.InputStream;
[all …]
DHashUtils.java21 import java.io.File;
22 import java.io.FileInputStream;
23 import java.io.FileNotFoundException;
24 import java.io.IOException;
25 import java.io.InputStream;
DCertificateUtils.java20 import java.io.File;
21 import java.io.FileInputStream;
22 import java.io.IOException;
/developtools/hdc/hdc_rust/src/transfer/
Dtcp.rs23 use std::io::{self, Error, ErrorKind};
25 use ylong_runtime::io::AsyncReadExt;
28 async fn read_frame(rd: &mut SplitReadHalf, expected_size: usize) -> io::Result<Vec<u8>> { in read_frame()
54 pub async fn unpack_task_message(rd: &mut SplitReadHalf) -> io::Result<TaskMessage> { in unpack_task_message()
87 pub async fn recv_channel_message(rd: &mut SplitReadHalf) -> io::Result<Vec<u8>> { in recv_channel_message()
Dbase.rs27 use std::io::{self, Error, ErrorKind};
58 fn write_all(&self, data: Vec<u8>) -> io::Result<()>; in write_all()
62 fn read_frame(&self, expected_size: usize) -> io::Result<Vec<u8>>; in read_frame()
63 fn check_protocol_head(&mut self) -> io::Result<(u32, u32)> { in check_protocol_head()
73 ) -> io::Result<()> { in unpack_task_message_lock()
167 ) -> io::Result<()> { in unpack_task_message()
Dusb.rs31 use std::io::{self, Error, ErrorKind};
62 pub fn usb_init() -> io::Result<(i32, i32, i32)> { in usb_init()
118 fn read_frame(&self, _expected_size: usize) -> io::Result<Vec<u8>> { in read_frame()
128 fn check_protocol_head(&mut self) -> io::Result<(u32, u32)> { in check_protocol_head()
147 fn write_all(&self, data: Vec<u8>) -> io::Result<()> { in write_all()
Duart.rs32 use std::io::{self, Error, ErrorKind};
48 pub fn uart_init() -> io::Result<i32> { in uart_init()
90 fn read_frame(&self, expected_size: usize) -> io::Result<Vec<u8>> { in read_frame()
112 fn check_protocol_head(&mut self) -> io::Result<(u32, u32)> { in check_protocol_head()
145 fn write_all(&self, data: Vec<u8>) -> io::Result<()> { in write_all()
Dbuffer.rs30 use std::io::{self, Error, ErrorKind};
33 use ylong_runtime::io::AsyncWriteExt;
86 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> { in send_channel_message()
136 async fn put(session_id: u32, data: TaskMessage) -> io::Result<()> { in put()
175 pub async fn put(session_id: u32, data: Vec<u8>) -> io::Result<()> { in put()
224 pub async fn send_channel_msg(channel_id: u32, level: EchoLevel, msg: String) -> io::Result<()> { in send_channel_msg()
255 pub async fn recv() -> io::Result<Vec<u8>> { in recv()
/developtools/profiler/device/services/ipc/src/
Dipc_generator.cpp42 …std::unique_ptr<::google::protobuf::io::ZeroCopyOutputStream> header_output(context->Open(base_nam… in Generate()
43 …std::unique_ptr<::google::protobuf::io::ZeroCopyOutputStream> source_output(context->Open(base_nam… in Generate()
45 ::google::protobuf::io::CodedOutputStream header_out(header_output.get()); in Generate()
46 ::google::protobuf::io::CodedOutputStream source_out(source_output.get()); in Generate()
/developtools/packing_tool/adapter/ohos/
DScan.java19 import java.io.BufferedInputStream;
20 import java.io.BufferedReader;
21 import java.io.File;
22 import java.io.FileInputStream;
23 import java.io.FileNotFoundException;
24 import java.io.FileOutputStream;
25 import java.io.FileWriter;
26 import java.io.IOException;
27 import java.io.InputStreamReader;
DFileUtils.java18 import java.io.BufferedInputStream;
19 import java.io.BufferedOutputStream;
20 import java.io.BufferedReader;
21 import java.io.Closeable;
22 import java.io.File;
23 import java.io.FileInputStream;
24 import java.io.FileOutputStream;
25 import java.io.FileNotFoundException;
26 import java.io.InputStream;
27 import java.io.InputStreamReader;
[all …]
/developtools/hapsigner/hapsigntool/hap_sign_tool/src/main/java/com/ohos/hapsigntoolcmd/
DParamsTrustlist.java21 import java.io.BufferedReader;
22 import java.io.IOException;
23 import java.io.InputStream;
24 import java.io.InputStreamReader;
DHelpDocument.java24 import java.io.IOException;
25 import java.io.InputStream;
/developtools/hdc/hdc_rust/src/serializer/
Dpack_assemble.rs25 use std::io::{self, Error, ErrorKind};
31 pub fn unpack_payload_head(data: Vec<u8>) -> io::Result<native_struct::PayloadHead> { in unpack_payload_head()
44 pub fn unpack_payload_protect(data: Vec<u8>) -> io::Result<native_struct::PayloadProtect> { in unpack_payload_protect()
Dserialize.rs26 use std::io::{self, Error, ErrorKind};
81 fn parse(&mut self, _: Vec<u8>) -> io::Result<()> { in parse()
110 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse()
154 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse()
206 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse()
264 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse()
303 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse()
339 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse()
371 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse()
405 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse()
/developtools/hapsigner/hapsigntool/hap_sign_tool_lib/src/main/java/com/ohos/hapsigntool/zip/
DZipEntryData.java20 import java.io.File;
21 import java.io.FileInputStream;
22 import java.io.IOException;
/developtools/hapsigner/hapsigntool/hap_sign_tool_lib/src/main/java/com/ohos/hapsigntool/hap/verify/
DVerifyAndParseProvision.java24 import java.io.File;
25 import java.io.FileOutputStream;
26 import java.io.IOException;
/developtools/smartperf_host/ide/src/trace/database/ui-worker/
DProcedureWorkerEBPF.ts268 for (let io of array) {
270 startNS: io.startNS,
271 dur: io.endNS > totalNS ? totalNS - io.startNS : io.endNS - io.startNS,
272 size: io.dur,

12345