Home
last modified time | relevance | path

Searched refs:io (Results 1 - 25 of 120) sorted by relevance

12345

/developtools/hdc/hdc_rust/src/tar/
H A Dentry.rs19 io::{self, Write},
72 pub fn create_from_raw_data(data: &[u8; 512]) -> Result<Self, std::io::Error> { in create_from_raw_data()
76 return Err(std::io::Error::new(
77 std::io::ErrorKind::Other,
137 pub fn write_to_file(&self, path: &Path) -> Result<(), std::io::Error> { in write_to_file()
139 return Err(io::Error::new( in write_to_file()
140 io::ErrorKind::Other, in write_to_file()
160 return Err(io::Error::new( in write_to_file()
161 io::ErrorKind::Other, in write_to_file()
171 pub fn read_data_to_file(&mut self, _file: &mut fs::File) -> Result<(), std::io
[all...]
H A Dcompress.rs19 io::{self, Error},
57 fn add_path_recursion(&mut self, path: &Path) -> io::Result<()> { in add_path_recursion()
75 pub fn add_path(&mut self, path: &Path) -> io::Result<()> { in add_path()
79 fn add_entry(&mut self, file: &str) -> io::Result<()> { in add_entry()
82 io::ErrorKind::Other, in add_entry()
104 pub fn compress(&mut self, file_path: PathBuf) -> io::Result<()> { in compress()
106 return Err(io::Error::new( in compress()
107 io::ErrorKind::InvalidInput, in compress()
H A Ddecompress.rs19 io::{self, Read},
35 pub fn file(path: &str) -> Result<Decompress, io::Error> { in file()
40 return Err(io::Error::new( in file()
41 io::ErrorKind::InvalidInput, in file()
87 pub fn decompress(&self, prefix: &str) -> io::Result<()> { in decompress()
94 return Err(io::Error::new( in decompress()
95 io::ErrorKind::InvalidInput, in decompress()
/developtools/hdc/hdc_rust/src/host/
H A Dclient.rs29 use std::io::{self, Error, ErrorKind, Write};
36 use ylong_runtime::io::AsyncReadExt;
37 use ylong_runtime::io::AsyncWriteExt;
57 pub async fn run_client_mode(parsed_cmd: ParsedCommand) -> io::Result<()> {
92 pub async fn new(parsed_cmd: ParsedCommand) -> io::Result<Self> {
115 async fn execute_command(&mut self) -> io::Result<()> {
152 pub async fn handshake(&mut self) -> io::Result<()> {
182 async fn recv(&mut self) -> io::Result<Vec<u8>> {
187 async fn unity_task(&mut self) -> io::Result<()> {
192 async fn wait_task(&mut self) -> io
[all...]
H A Dauth.rs26 use std::io::{self, Error, ErrorKind};
65 async fn handshake_deal_daemon_auth_result(daemon: SessionHandShake, connect_key: String) -> io::Result<()> {
121 pub async fn handshake_task(msg: TaskMessage, session_id: u32, connect_key: String) -> io::Result<()> {
173 fn load_or_create_prikey() -> io::Result<Rsa<openssl::pkey::Private>> { in load_or_create_prikey()
189 pub fn create_prikey() -> io::Result<Rsa<openssl::pkey::Private>> { in create_prikey()
205 fn get_pubkey_pem(rsa: &Rsa<openssl::pkey::Private>) -> io::Result<String> { in get_pubkey_pem()
217 fn get_signature_b64(rsa: &Rsa<openssl::pkey::Private>, plain: String) -> io::Result<String> { in get_signature_b64()
251 fn get_hostname() -> io::Result<String> { in get_hostname()
H A Dtask.rs32 use std::io::{self, Error, ErrorKind};
51 pub async fn channel_task_dispatch(task_info: TaskInfo) -> io::Result<()> {
142 async fn channel_forward_task(task_info: TaskInfo) -> io::Result<()> {
168 async fn channel_forward_remove(task_info: TaskInfo, forward_or_reverse: bool) -> io::Result<()> {
205 async fn channel_forward_list(task_info: TaskInfo, forward_or_reverse: bool) -> io::Result<()> {
241 async fn channel_jdwp_task(task_info: TaskInfo) -> io::Result<()> {
260 async fn channel_hilog_task(task_info: TaskInfo) -> io::Result<()> {
280 async fn channel_bug_report_task(task_info: TaskInfo) -> io::Result<()> {
295 async fn channel_file_task(task_info: TaskInfo) -> io::Result<()> {
312 return Err(io
[all...]
/developtools/hapsigner/hapsigntool/hap_sign_tool_lib/src/main/java/com/ohos/hapsigntool/codesigning/utils/
H A DInputStreamUtils.java18 import java.io.ByteArrayOutputStream;
19 import java.io.IOException;
20 import java.io.InputStream;
21 import java.io.OutputStream;
37 * @throws IOException io error
/developtools/hapsigner/hapsigntool/hap_sign_tool_lib/src/main/java/com/ohos/hapsigntool/utils/
H A 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
[all...]
H A 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;
/developtools/hiperf/include/
H A Dreport_protobuf_file.h23 #include "google/protobuf/io/coded_stream.h"
24 #include "google/protobuf/io/zero_copy_stream_impl_lite.h"
40 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/hdc/hdc_rust/src/daemon_lib/
H A Dmod.rs30 use std::io::{self, ErrorKind};
69 pub async fn handle_message(res: io::Result<TaskMessage>, session_id: u32) -> io::Result<()> {
94 pub async fn bridge_daemon_start() -> io::Result<()> {
102 return Err(std::io::Error::new(
130 pub async fn bridge_handle_client(ptr: u64, fd: i32, client_fd: i32) -> io::Result<()> {
166 pub async fn tcp_handle_client(stream: TcpStream) -> io::Result<()> {
196 pub async fn tcp_daemon_start(port: u16) -> io::Result<()> {
222 pub async fn uart_daemon_start() -> io::Result<()> {
238 ) -> io
[all...]
H A Dbridge.rs32 use std::io::{self, Error, ErrorKind};
105 fn read_frame(&self, _expected_size: usize) -> io::Result<Vec<u8>> { in read_frame()
115 fn check_protocol_head(&mut self) -> io::Result<(u32, u32, u32)> { in check_protocol_head()
121 fn write_all(&self, data: Vec<u8>) -> io::Result<i32> { in write_all()
160 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> {
/developtools/hdc/hdc_rust/src/
H A Dutils.rs21 use std::io::{self, Error, ErrorKind};
27 use ylong_runtime::io::AsyncWriteExt;
44 pub async fn print_msg(buf: Vec<u8>) -> io::Result<()> {
45 let mut stdout = ylong_runtime::io::stdout();
/developtools/profiler/device/services/ipc/src/
H A Dipc_generator.cpp42 std::unique_ptr<::google::protobuf::io::ZeroCopyOutputStream> header_output(context->Open(base_name + ".ipc.h")); in Generate()
43 std::unique_ptr<::google::protobuf::io::ZeroCopyOutputStream> source_output(context->Open(base_name + ".ipc.cc")); 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/hdc/hdc_rust/src/transfer/
H A Dtcp.rs23 use std::io::{self, Error, ErrorKind};
27 use ylong_runtime::io::AsyncReadExt;
30 async fn read_frame(rd: &mut SplitReadHalf, expected_size: usize) -> io::Result<Vec<u8>> {
56 pub async fn unpack_task_message(rd: &mut SplitReadHalf) -> io::Result<TaskMessage> {
89 pub async fn recv_channel_message(rd: &mut SplitReadHalf) -> io::Result<Vec<u8>> {
H A Dusb.rs32 use std::io::{self, Error, ErrorKind};
68 pub fn usb_init() -> io::Result<(i32, i32, i32)> { in usb_init()
134 fn read_frame(&self, expect: usize) -> io::Result<Vec<u8>> { in read_frame()
157 fn read_frame(&self, _expected_size: usize) -> io::Result<Vec<u8>> { in read_frame()
161 fn check_protocol_head(&mut self) -> io::Result<(u32, u32, u32)> { in check_protocol_head()
180 pub fn usb_write_all(fd: i32, data: Vec<u8>) -> io::Result<i32> { in usb_write_all()
196 fn write_all(&self, data: Vec<u8>) -> io::Result<i32> { in write_all()
211 fn write_all(&self, _data: Vec<u8>) -> io::Result<i32> { in write_all()
H A Duart.rs33 use std::io::{self, Error, ErrorKind};
56 pub fn uart_init() -> io::Result<i32> { in uart_init()
101 fn read_frame(&self, expected_size: usize) -> io::Result<Vec<u8>> { in read_frame()
123 fn check_protocol_head(&mut self) -> io::Result<(u32, u32, u32)> { in check_protocol_head()
158 fn write_all(&self, data: Vec<u8>) -> io::Result<i32> { in write_all()
/developtools/packing_tool/adapter/ohos/
H A 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;
H A 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
[all...]
/developtools/hapsigner/hapsigntool/hap_sign_tool/src/main/java/com/ohos/hapsigntoolcmd/
H A DParamsTrustlist.java21 import java.io.BufferedReader;
22 import java.io.IOException;
23 import java.io.InputStream;
24 import java.io.InputStreamReader;
H A DHelpDocument.java23 import java.io.IOException;
24 import java.io.InputStream;
/developtools/hapsigner/hapsigntool/hap_sign_tool_lib/src/main/java/com/ohos/hapsigntool/hap/verify/
H A DVerifyAndParseProvision.java24 import java.io.File;
25 import java.io.FileOutputStream;
26 import java.io.IOException;
/developtools/hdc/hdc_rust/src/serializer/
H A 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()
50 pub fn unpack_payload_protect(data: Vec<u8>) -> io::Result<native_struct::PayloadProtect> { in unpack_payload_protect()
H A Dserialize.rs26 use std::io::{self, Error, ErrorKind};
31 // use tokio::io::Result;
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
[all...]
/developtools/smartperf_host/trace_streamer/src/proto_reader/protoc_plugin/
H A Dproto_reader_plugin.h22 #include <google/protobuf/io/printer.h>
23 #include <google/protobuf/io/zero_copy_stream.h>
32 using google::protobuf::io::Printer;
33 using google::protobuf::io::ZeroCopyOutputStream;

Completed in 9 milliseconds

12345