/developtools/integration_verification/tools/fotff/utils/ |
D | ssh.go | 41 …aSSHContext(ctx context.Context, addr string, user string, passwd string, cmd string) (err error) { 44 if err := RunCmdViaSSHContextNoRetry(ctx, addr, user, passwd, cmd); err != nil { 45 if errors.Is(err, context.Canceled) { 46 return err 48 logrus.Errorf("exec cmd via SSH at %s failed: %v, try again...", addr, err) 54 …textNoRetry(ctx context.Context, addr string, user string, passwd string, cmd string) (err error) { 56 client, err := newSSHClient(addr, user, passwd) 57 if err != nil { 58 logrus.Errorf("new SSH client to %s err: %v", addr, err) 59 return err [all …]
|
D | exec.go | 32 if err := execContext(ctx, name, args...); err != nil { 33 if errors.Is(err, context.Canceled) { 34 return err 36 logrus.Errorf("exec failed: %v, try again...", err) 46 stdout, err := cmd.StdoutPipe() 47 if err != nil { 48 return err 50 stderr, err := cmd.StderrPipe() 51 if err != nil { 52 return err [all …]
|
D | log.go | 32 if err := os.MkdirAll("logs", 0750); err != nil { 33 logrus.Errorf("can not make logs dir: %v", err) 66 var err error 67 if _, err = os.Stat(file); err == nil { 68 f, err = os.OpenFile(file, os.O_RDWR|os.O_APPEND, 0666) 70 f, err = os.Create(file) 72 if err != nil { 73 logrus.Errorf("failed to open new log file %s: %v", file, err) 83 if _, err = os.Stat(stdout); err == nil { 84 f, err = os.OpenFile(stdout, os.O_RDWR|os.O_APPEND, 0666) [all …]
|
D | http.go | 27 …d string, url string, body []byte, header map[string]string) (response *http.Response, err error) { 33 if response, err = doSimpleHttpReqImpl(method, url, body, header); err == nil { 41 …HttpReq(method string, url string, body []byte, header map[string]string) (ret []byte, err error) { 48 if resp, err = doSimpleHttpReqImpl(method, url, body, header); err == nil { 49 ret, err = io.ReadAll(resp.Body) 58 …d string, url string, body []byte, header map[string]string) (response *http.Response, err error) { 60 req, err := http.NewRequest(method, url, bytes.NewReader(body)) 61 if err != nil { 62 return nil, err 67 resp, err := proxyClient.Do(req) [all …]
|
/developtools/integration_verification/tools/fotff/pkg/dayu200/ |
D | flash.go | 36 if err := utils.TryRebootToLoader(device, ctx); err != nil { 37 return err 39 if err := m.flashImages(device, pkg, ctx); err != nil { 40 return err 65 …if err := utils.ExecContext(ctx, m.FlashTool, "-s", locationID, "UL", filepath.Join(m.Workspace, p… 66 if errors.Is(err, context.Canceled) { 67 return err 69 logrus.Errorf("flash MiniLoaderAll.bin fail: %v", err) 71 …if err := utils.ExecContext(ctx, m.FlashTool, "-s", locationID, "UL", filepath.Join(m.Workspace, p… 72 if errors.Is(err, context.Canceled) { [all …]
|
/developtools/integration_verification/tools/fotff/pkg/gitee_common/ |
D | steps_ci.go | 55 func (m *Manager) stepsFromCI(from, to string) (pkgs []string, err error) { 56 startTime, err := parseTime(from) 57 if err != nil { 58 return nil, err 60 endTime, err := parseTime(to) 61 if err != nil { 62 return nil, err 67 func (m *Manager) getAllStepsFromTags(from, to time.Time) (pkgs []string, err error) { 68 tags, err := m.getAllTags(from, to) 69 if err != nil { [all …]
|
D | steps_gitee.go | 52 func (m *Manager) stepsFromGitee(from, to string) (pkgs []string, err error) { 53 updates, err := m.getRepoUpdates(from, to) 54 if err != nil { 55 return nil, err 57 startTime, err := parseTime(from) 58 if err != nil { 59 return nil, err 61 endTime, err := parseTime(to) 62 if err != nil { 63 return nil, err [all …]
|
D | build.go | 40 err := m.BuildNoRetry(config, false, ctx) 41 if err == nil { 44 logrus.Errorf("build pkg %s err: %v", config.Pkg, err) 46 err = m.BuildNoRetry(config, true, ctx) 47 if err == nil { 50 logrus.Errorf("build pkg %s err: %v", config.Pkg, err) 51 return err 58 if _, err := os.Stat(filepath.Join(m.Workspace, config.Pkg, imgName)); err != nil { 72 …if err := utils.RunCmdViaSSHContext(ctx, server.Addr, server.User, server.Passwd, cmd); err != nil… 73 return fmt.Errorf("remote: mkdir error: %w", err) [all …]
|
D | get_newer_or_fail.go | 36 if _, err := os.Stat(dir); err == nil { 40 if err := ex.Extract(filepath.Join(m.ArchiveDir, newFile), dir); err != nil { 41 return dirName, err 61 lastSuccessTime, err := parseTime(cur) 62 if err != nil { 66 nowFailTime, err := parseTime(db.BuildStartTime) 67 if err != nil { 83 tags, err := m.getAllTags(lastSuccessTime, failedBuildStartTime) 84 if err != nil { 85 logrus.Errorf("can not get latest tag from ci, err: %v", err) [all …]
|
D | get_newer_ci.go | 60 data, err := json.Marshal(param) 61 if err != nil { 62 logrus.Errorf("can not marshal query param: %v", err) 65 …resp, err := utils.DoSimpleHttpReq(http.MethodPost, "http://ci.openharmony.cn/api/ci-backend/ci-po… 66 if err != nil { 67 logrus.Errorf("can not query builds: %v", err) 71 if err := json.Unmarshal(resp, &dailyBuildsResp); err != nil { 72 logrus.Errorf("can not unmarshal resp [%s]: %v", string(resp), err) 110 file, err := m.downloadToWorkspace(p) 111 if err != nil { [all …]
|
D | common.go | 56 es, err := os.ReadDir(m.Workspace) 57 if err != nil { 58 logrus.Errorf("can not read %s: %v", m.Workspace, err) 66 info, err := e.Info() 67 if err != nil { 68 logrus.Errorf("can not read %s info: %v", path, err) 80 es, err := os.ReadDir(path) 81 if err != nil { 82 logrus.Errorf("can not read %s: %v", path, err) 89 if err := os.RemoveAll(filepath.Join(path, e.Name())); err != nil { [all …]
|
D | steps_gitee_test.go | 69 ret, err := m.Steps(tt.from, tt.to) 70 if err != nil { 71 t.Fatalf("err: expcect: <nil>, actual: %v", err) 79 …mLast, err := vcs.ParseManifestFile(filepath.Join(m.Workspace, ret[len(ret)-1], "manifest_tag.xml"… 80 if err != nil { 81 t.Fatalf("err: expcect: <nil>, actual: %v", err) 83 mLastMD5, err := mLast.Standardize() 84 if err != nil { 85 t.Fatalf("err: expcect: <nil>, actual: %v", err) 87 expected, err := vcs.ParseManifestFile(filepath.Join(m.Workspace, tt.to, "manifest_tag.xml")) [all …]
|
/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) { 63 if err := os.MkdirAll(filepath.Join(t.SavePath, reportDir), 0755); err != nil { 64 return nil, err 70 if err := utils.ExecContext(ctx, "python", args...); err != nil { 71 if errors.Is(err, context.Canceled) { 72 return nil, err 74 logrus.Errorf("do test suite fail: %v", err) 75 return nil, err 80 func (t *Tester) DoTestCase(deviceSN, testCase string, ctx context.Context) (ret tester.Result, err… 82 if err := os.MkdirAll(filepath.Join(t.SavePath, reportDir), 0755); err != nil { [all …]
|
/developtools/integration_verification/tools/fotff/tester/xdevice/ |
D | xdevice.go | 67 func (t *Tester) Prepare(pkgDir string, device string, ctx context.Context) (err error) { 69 if err := utils.HdcShell(enableTestModeScript, device, ctx); err != nil { 70 return err 82 func (t *Tester) DoTestTask(deviceSN string, ctx context.Context) (ret []tester.Result, err error) { 88 if err := utils.ExecContext(ctx, "python", args...); err != nil { 89 if errors.Is(err, context.Canceled) { 90 return nil, err 92 logrus.Errorf("do test suite fail: %v", err) 93 return nil, err 98 func (t *Tester) DoTestCase(deviceSN, testCase string, ctx context.Context) (ret tester.Result, err… [all …]
|
/developtools/integration_verification/tools/fotff/tester/common/ |
D | common.go | 61 if err := utils.ExecContext(ctx, t.Tool, args...); err != nil { 62 if errors.Is(err, context.Canceled) { 63 return nil, err 65 logrus.Errorf("Failed to do test task on device %s, error: %s", device, err.Error()) 66 return nil, err 82 if err := utils.ExecContext(ctx, t.Tool, args...); err != nil { 83 if errors.Is(err, context.Canceled) { 84 return defaultResult, err 86 logrus.Errorf("Failed to do test case %s on device %s, error: %s", testCase, device, err.Error()) 87 return defaultResult, err [all …]
|
/developtools/integration_verification/tools/fotff/vcs/gitee/ |
D | compare.go | 63 func GetLatestMRBefore(owner, repo, branch string, before string) (ret *Commit, err error) { 64 branchResp, err := GetBranch(owner, repo, branch) 65 if err != nil { 66 return nil, err 72 if head, err = GetCommit(owner, repo, head.Parents[0].SHA); err != nil { 73 return nil, err 79 func GetBetweenTimeMRs(owner, repo, branch string, from, to time.Time) (ret []*Commit, err error) { 80 branchResp, err := GetBranch(owner, repo, branch) 81 if err != nil { 82 return nil, err [all …]
|
D | commit.go | 31 var err error 32 resp, err = utils.DoSimpleHttpReq(http.MethodGet, url, nil, nil) 33 if err != nil { 34 return nil, err 39 if err := json.Unmarshal(resp, &commitResp); err != nil { 40 return nil, err
|
D | issue.go | 35 var err error 36 resp, err = utils.DoSimpleHttpReq(http.MethodGet, url, nil, nil) 37 if err != nil { 38 return nil, err 43 if err := json.Unmarshal(resp, &prIssues); err != nil { 44 return nil, err
|
/developtools/integration_verification/tools/fotff/rec/ |
D | flashandtest.go | 23 if err := opt.M.Flash(opt.Device, opt.Version, ctx); err != nil { 24 …logrus.Errorf("Failed to flash version %s to device %s, error: %s", opt.Version, opt.Device, err.E… 25 return err 29 if err := opt.T.Prepare(opt.M.PkgDir(opt.Version), opt.Device, ctx); err != nil { 30 logrus.Errorf("Failed to prepare test, error: %s", err.Error()) 31 return err 36 results, err := opt.T.DoTestTask(opt.Device, ctx) 37 if err != nil { 38 logrus.Errorf("Failed to run all test cases on device %s, error: %s", opt.Device, err.Error()) 39 return err [all …]
|
D | record.go | 31 data, err := utils.ReadRuntimeData("records.json") 32 if err != nil { 35 if err := json.Unmarshal(data, &Records); err != nil { 36 logrus.Errorf("unmarshal records err: %v", err) 41 data, err := json.MarshalIndent(Records, "", "\t") 42 if err != nil { 43 logrus.Errorf("marshal records err: %v", err) 46 if err := utils.WriteRuntimeData("records.json", data); err != nil { 47 logrus.Errorf("save records err: %v", err) 89 r, err := t.DoTestCase(dev, result.TestCaseName, context.TODO()) [all …]
|
D | fotff.go | 42 steps, err := m.Steps(successPkg, failPkg) 43 if err != nil { 44 return "", err 110 var err error 111 pass, fellows, err = flashAndTest(m, t, steps[index], testcase, ctx, fellows...) 112 if err != nil { 113 if errors.Is(err, context.Canceled) { 114 logrus.Warnf("abort to flash %s and test %s: %v", steps[index], testcase, err) 116 logrus.Errorf("flash %s and test %s fail: %v", steps[index], testcase, err) 148 if err := m.Flash(device, pkg, ctx); err != nil && !errors.Is(err, context.Canceled) { [all …]
|
/developtools/smartperf_host/ide/server/ |
D | main.go | 75 _, err := os.Stat(path) 76 if err != nil { 77 if os.IsExist(err) { 154 err := ser.ListenAndServeTLS("cert/certFile.pem", "cert/keyFile.key") 155 CheckErr(err) 163 err := ser.ListenAndServe() 164 CheckErr(err) 182 pid, err := strconv.Atoi(strings.TrimSpace(findStr[0])) 183 if err != nil { 201 …dst, err := os.OpenFile(exPath+"/logger/"+fileName, os.O_WRONLY|os.O_CREATE|os.O_APPEND|os.O_SYNC,… [all …]
|
/developtools/integration_verification/tools/fotff/ |
D | main.go | 131 if err := rootCmd.Execute(); err != nil { 132 logrus.Errorf("failed to execute: %v", err) 142 if err := utils.WriteRuntimeData("last_handled.rec", []byte(curPkg)); err != nil { 143 logrus.Errorf("failed to write last_handled.rec: %v", err) 146 var err error 147 curPkg, err = m.GetNewer(curPkg) 148 if err != nil { 149 logrus.Infof("get newer package err: %v", err) 155 if err := m.Flash(device, curPkg, context.TODO()); err != nil { 156 logrus.Errorf("flash package dir %s err: %v", curPkg, err) [all …]
|
/developtools/integration_verification/tools/fotff/vcs/ |
D | manifest.go | 87 data, err := os.ReadFile(file) 88 if err != nil { 89 return nil, err 92 err = xml.Unmarshal(data, &m) 93 return &m, err 97 data, err := xml.MarshalIndent(m, "", " ") 98 if err != nil { 99 return err 105 func GetRepoUpdates(m1, m2 *Manifest) (updates []ProjectUpdate, err error) { 106 if _, err := m1.Standardize(); err != nil { [all …]
|
/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… 65 if _, err := fmt.Scanln(&answer); err != nil { 66 logrus.Errorf("failed to scan result: %v", err) 79 …tCases(deviceSN string, testcases []string, ctx context.Context) (ret []tester.Result, err error) { 81 r, err := t.DoTestCase(deviceSN, testcase, ctx) 82 if err != nil { 83 return nil, err
|