X-Git-Url: https://ruderich.org/simon/gitweb/?a=blobdiff_plain;f=cmd%2Fsafcm-remote%2Fsync%2Fsync_test.go;h=0953c0490e2fd17dda565b8d357615a1d8117758;hb=e0d1ceb383e5672de1a414f192eb2849a1887934;hp=52d7435eadcea20abff6fbbc2f9e33639878692d;hpb=6d78cccd689fd81a08851b95a03fea608f497e16;p=safcm%2Fsafcm.git diff --git a/cmd/safcm-remote/sync/sync_test.go b/cmd/safcm-remote/sync/sync_test.go index 52d7435..0953c04 100644 --- a/cmd/safcm-remote/sync/sync_test.go +++ b/cmd/safcm-remote/sync/sync_test.go @@ -54,6 +54,8 @@ func (r *testRunner) Run(cmd *exec.Cmd) error { return resErr } func (r *testRunner) CombinedOutput(cmd *exec.Cmd) ([]byte, error) { + r.t.Helper() + stdout, stderr, err := r.check("combinedOutput", cmd) if stderr != nil { // stdout also contains stderr @@ -63,6 +65,7 @@ func (r *testRunner) CombinedOutput(cmd *exec.Cmd) ([]byte, error) { } func (r *testRunner) check(method string, cmd *exec.Cmd) ( []byte, []byte, error) { + r.t.Helper() if len(r.expCmds) == 0 { r.t.Fatalf("%s: empty expCmds", method) @@ -120,11 +123,9 @@ func prepareSync(req safcm.MsgSyncReq, runner *testRunner) ( res.wg.Done() }() - logger := log.NewLogger(logPrefix, - func(level safcm.LogLevel, format string, a ...interface{}) { - res.ch <- fmt.Sprintf("%d: %s", level, - fmt.Sprintf(format, a...)) - }) + logger := log.NewLogger(func(level safcm.LogLevel, msg string) { + res.ch <- fmt.Sprintf("%d: %s", level, msg) + }) return &Sync{ req: req, cmd: run.NewCmd(runner, logger), @@ -133,6 +134,8 @@ func prepareSync(req safcm.MsgSyncReq, runner *testRunner) ( } func (s *syncTestResult) Wait() []string { + s.runner.t.Helper() + close(s.ch) s.wg.Wait()