| /developtools/integration_verification/tools/fotff/tester/mock/ |
| D | mock.go | 38 func (t *Tester) DoTestTask(device string, ctx context.Context) ([]tester.Result, error) { 42 return []tester.Result{ 49 func (t *Tester) DoTestCase(device string, testCase string, ctx context.Context) (tester.Result, er… 51 return tester.Result{TestCaseName: testCase, Status: tester.ResultPass}, nil 54 …ter) DoTestCases(device string, testcases []string, ctx context.Context) ([]tester.Result, error) { 55 var ret []tester.Result
|
| /developtools/integration_verification/tools/fotff/tester/common/ |
| D | common.go | 36 Result string `json:"result"` member 54 func (t *Tester) DoTestTask(device string, ctx context.Context) ([]tester.Result, error) { 73 func (t *Tester) DoTestCase(device string, testCase string, ctx context.Context) (tester.Result, er… 81 defaultResult := tester.Result{} 106 …ter) DoTestCases(device string, testCases []string, ctx context.Context) ([]tester.Result, error) { 127 func (t *Tester) processResult() ([]tester.Result, error) { 141 var ret []tester.Result 143 if r.Result == testResultPass { 144 ret = append(ret, tester.Result{TestCaseName: r.TestCase, Status: tester.ResultPass}) 146 ret = append(ret, tester.Result{TestCaseName: r.TestCase, Status: tester.ResultFail})
|
| /developtools/integration_verification/tools/fotff/tester/pkg_available/ |
| D | pkg_available.go | 51 func (t *Tester) DoTestTask(deviceSN string, ctx context.Context) (ret []tester.Result, err error) { 55 func (t *Tester) DoTestCase(deviceSN, testCase string, ctx context.Context) (ret tester.Result, err… 60 return tester.Result{TestCaseName: testCase, Status: tester.ResultFail}, nil 65 return tester.Result{TestCaseName: testCase, Status: tester.ResultPass}, nil 69 return tester.Result{TestCaseName: testCase, Status: tester.ResultFail}, nil 72 …tCases(deviceSN string, testcases []string, ctx context.Context) (ret []tester.Result, err error) {
|
| /developtools/integration_verification/tools/fotff/tester/ |
| D | tester.go | 28 type Result struct { struct 39 DoTestTask(device string, ctx context.Context) ([]Result, error) 41 DoTestCase(device string, testCase string, ctx context.Context) (Result, error) 43 DoTestCases(device string, testcases []string, ctx context.Context) ([]Result, error)
|
| /developtools/integration_verification/tools/fotff/tester/manual/ |
| D | manual.go | 52 func (t *Tester) DoTestTask(deviceSN string, ctx context.Context) (ret []tester.Result, err error) { 56 func (t *Tester) DoTestCase(deviceSN, testCase string, ctx context.Context) (ret tester.Result, err… 71 return tester.Result{TestCaseName: testCase, Status: tester.ResultPass}, nil 73 return tester.Result{TestCaseName: testCase, Status: tester.ResultFail}, nil 79 …tCases(deviceSN string, testcases []string, ctx context.Context) (ret []tester.Result, err error) {
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | client.rs | 46 pub async fn run_client_mode(parsed_cmd: ParsedCommand) -> io::Result<()> { in run_client_mode() argument 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() argument 129 pub async fn handshake(&mut self) -> io::Result<()> { in handshake() argument 154 async fn recv(&mut self) -> io::Result<Vec<u8>> { in recv() 159 async fn unity_task(&mut self) -> io::Result<()> { in unity_task() argument 164 async fn shell_task(&mut self) -> io::Result<()> { in shell_task() argument 225 async fn general_task(&mut self) -> io::Result<()> { in general_task() argument 240 async fn bug_report_task(&mut self) -> io::Result<()> { in bug_report_task() argument 252 async fn file_send_task(&mut self) -> io::Result<()> { in file_send_task() argument [all …]
|
| D | auth.rs | 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()
|
| D | task.rs | 40 pub async fn channel_task_dispatch(task_info: TaskInfo) -> io::Result<()> { in channel_task_dispatch() argument 93 async fn channel_hilog_task(task_info: TaskInfo) -> io::Result<()> { in channel_hilog_task() argument 113 async fn channel_bug_report_task(task_info: TaskInfo) -> io::Result<()> { in channel_bug_report_task() argument 128 async fn channel_file_task(task_info: TaskInfo) -> io::Result<()> { in channel_file_task() argument 185 async fn channel_unity_task(task_info: TaskInfo) -> io::Result<()> { in channel_unity_task() argument 208 async fn channel_shell_task(task_info: TaskInfo) -> io::Result<()> { in channel_shell_task() argument 258 async fn channel_connect_task(task_info: TaskInfo) -> io::Result<()> { in channel_connect_task() argument 331 async fn channel_list_targets_task(task_info: TaskInfo) -> io::Result<()> { in channel_list_targets_task() argument 348 ) -> io::Result<()> { in tcp_handle_deamon() argument 370 async fn session_task_dispatch(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_task_dispatch() argument [all …]
|
| D | server.rs | 31 pub async fn run_server_mode(addr_str: String) -> io::Result<()> { in run_server_mode() argument 115 async fn handle_client(stream: TcpStream) -> io::Result<()> { in handle_client() argument 188 ) -> io::Result<(String, u32)> { in handshake_with_client() 206 fn unpack_channel_handshake(recv: Vec<u8>) -> io::Result<String> { in unpack_channel_handshake()
|
| /developtools/integration_verification/tools/fotff/rec/ |
| D | fotff.go | 134 …sult %s from cache done, result is %s", result.(tester.Result).TestCaseName, result.(tester.Result… 137 …rom cache done, result is %s", fellowResult.(tester.Result).TestCaseName, fellowResult.(tester.Res… 138 if fellowResult.(tester.Result).Status == result.(tester.Result).Status { 143 return result.(tester.Result).Status == tester.ResultPass, newFellows, nil 145 var results []tester.Result
|
| D | fotff_test.go | 72 func (f *FotffMocker) DoTestTask(device string, ctx context.Context) ([]tester.Result, error) { 79 return []tester.Result{{TestCaseName: f.TestCaseName(), Status: tester.ResultFail}}, nil 82 …tffMocker) DoTestCase(device string, testcase string, ctx context.Context) (tester.Result, error) { 86 return tester.Result{}, context.Canceled 95 return tester.Result{TestCaseName: testcase, Status: tester.ResultFail}, nil 98 return tester.Result{TestCaseName: testcase, Status: tester.ResultPass}, nil 101 …ker) DoTestCases(device string, testcases []string, ctx context.Context) ([]tester.Result, error) { 102 var ret []tester.Result
|
| D | record.go | 53 func HandleResults(t tester.Tester, dev string, pkgName string, results []tester.Result) []string { argument 54 var passes, fails []tester.Result 67 func handlePassResults(pkgName string, results []tester.Result) { argument 80 func handleFailResults(t tester.Tester, dev string, pkgName string, results []tester.Result) []stri… argument
|
| /developtools/hdc/hdc_rust/src/daemon/ |
| D | shell.rs | 49 pub fn set_pts(&mut self, pts: &Pts) -> io::Result<()> { in set_pts() argument 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() 109 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read() 115 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write() 119 fn flush(&mut self) -> io::Result<()> { in flush() argument 135 pub fn setup_pipes(&self) -> io::Result<Pipes> { in setup_pipes() 143 pub fn session_leader(&self) -> impl FnMut() -> io::Result<()> { in session_leader() argument 184 ) -> io::Result<TaskMessage> { in pty_echo() [all …]
|
| D | main.rs | 59 async fn handle_message(res: io::Result<TaskMessage>, session_id: u32) -> io::Result<()> { in handle_message() argument 80 async fn tcp_handle_client(stream: TcpStream) -> io::Result<()> { in tcp_handle_client() argument 110 async fn tcp_daemon_start(port: u16) -> io::Result<()> { in tcp_daemon_start() argument 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() argument 241 async fn usb_daemon_start() -> io::Result<()> { in usb_daemon_start() 257 async fn usb_handle_client(_config_fd: i32, bulkin_fd: i32, bulkout_fd: i32) -> io::Result<()> { in usb_handle_client() argument
|
| /developtools/integration_verification/tools/fotff/tester/xdevice/ |
| D | xdevice.go | 48 Result string `xml:"result,attr"` 82 func (t *Tester) DoTestTask(deviceSN string, ctx context.Context) (ret []tester.Result, err error) { 98 func (t *Tester) DoTestCase(deviceSN, testCase string, ctx context.Context) (ret tester.Result, err… 122 …tCases(deviceSN string, testcases []string, ctx context.Context) (ret []tester.Result, err error) { 138 func (t *Tester) readReport(reportDir string) (ret []tester.Result, err error) { 153 if c.Result == "true" { 158 ret = append(ret, tester.Result{TestCaseName: c.Name, Status: status})
|
| /developtools/integration_verification/tools/fotff/tester/smoke/ |
| D | smoke.go | 61 func (t *Tester) DoTestTask(deviceSN string, ctx context.Context) (ret []tester.Result, err error) { 80 func (t *Tester) DoTestCase(deviceSN, testCase string, ctx context.Context) (ret tester.Result, err… 107 …tCases(deviceSN string, testcases []string, ctx context.Context) (ret []tester.Result, err error) { 126 func (t *Tester) readReport(reportDir string) (ret []tester.Result, err error) { 143 …ret = append(ret, tester.Result{TestCaseName: strconv.Itoa(r.TestCaseName), Status: tester.ResultP… 145 …ret = append(ret, tester.Result{TestCaseName: strconv.Itoa(r.TestCaseName), Status: tester.ResultF…
|
| /developtools/integration_verification/tools/fotff/pkg/gitee_common/ |
| D | get_newer_ci.go | 42 Result struct { member 75 if len(dailyBuildsResp.Result.DailyBuildVos) == 0 { 78 if dailyBuildsResp.Result.DailyBuildVos[0].CurrentStatus != "end" { 81 return getFn(cur, dailyBuildsResp.Result.DailyBuildVos[0])
|
| D | steps_ci.go | 41 Result struct { member 107 for _, tag := range tagResp.Result.TagList { 120 if len(deDup) == tagResp.Result.Total {
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| D | base.rs | 58 fn write_all(&self, data: Vec<u8>) -> io::Result<()>; in write_all() argument 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() argument 167 ) -> io::Result<()> { in unpack_task_message() argument
|
| D | tcp.rs | 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()
|
| D | usb.rs | 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() argument
|
| D | uart.rs | 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() argument
|
| /developtools/hdc/hdc_rust/src/common/ |
| D | uds.rs | 18 use std::io::{self, ErrorKind, Result}; 89 pub fn parse_abstract(name: &[u8]) -> io::Result<Self> { in parse_abstract() 119 pub fn wrap_bind(socket_fd: i32, addr: &UdsAddr) -> Result<()> { in wrap_bind() argument 201 pub fn wrap_socketpair(socket_type: c_int) -> Result<(i32, i32)> { in wrap_socketpair() 212 pub fn wrap_pipe() -> Result<(i32, i32)> { in wrap_pipe() 234 pub fn wrap_bind(socket_fd: i32, addr: &UdsAddr) -> Result<()> { in wrap_bind() argument 255 pub fn wrap_connect(socket_fd: i32, addr: &UdsAddr) -> Result<()> { in wrap_connect() argument
|
| /developtools/hdc/hdc_rust/src/serializer/ |
| D | serialize.rs | 81 fn parse(&mut self, _: Vec<u8>) -> io::Result<()> { in parse() argument 110 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse() argument 154 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse() argument 206 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse() argument 264 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse() argument 303 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse() argument 339 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse() argument 371 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse() argument 405 fn parse(&mut self, input: Vec<u8>) -> io::Result<()> { in parse() argument
|
| D | pack_assemble.rs | 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()
|