1
0

feat: parameter to write per-run logs to directory

This commit is contained in:
dump_stack() 2024-10-08 12:01:53 +00:00
parent 287ef19530
commit 4e3313b6db
Signed by: dump_stack
GPG Key ID: C9905BA72B5E02BB

View File

@ -12,6 +12,7 @@ import (
"math/rand" "math/rand"
"os" "os"
"os/exec" "os/exec"
"path/filepath"
"strings" "strings"
"time" "time"
@ -90,6 +91,8 @@ type PewCmd struct {
OutputOnSuccess bool `help:"show output on success"` OutputOnSuccess bool `help:"show output on success"`
RealtimeOutput bool `help:"show realtime output"` RealtimeOutput bool `help:"show realtime output"`
LogDir string `help:"write logs to directory"`
Endless bool `help:"endless tests"` Endless bool `help:"endless tests"`
EndlessTimeout time.Duration `help:"timeout between tests" default:"1m"` EndlessTimeout time.Duration `help:"timeout between tests" default:"1m"`
EndlessStress string `help:"endless stress script" type:"existingfile"` EndlessStress string `help:"endless stress script" type:"existingfile"`
@ -403,39 +406,54 @@ func (cmd PewCmd) testArtifact(swg *sizedwaitgroup.SizedWaitGroup,
defer swg.Done() defer swg.Done()
logdir := "logs/" + cmd.Tag var logDirWriter *zerolog.ConsoleWriter
err := os.MkdirAll(logdir, os.ModePerm) if cmd.LogDir != "" {
if err != nil { logdir := filepath.Join(cmd.LogDir, cmd.Tag)
log.Error().Err(err).Msgf("mkdir %s", logdir) err := os.MkdirAll(logdir, os.ModePerm)
return if err != nil {
} log.Error().Err(err).Msgf("mkdir %s", logdir)
return
}
logfile := fmt.Sprintf("logs/%s/%s-%s-%s.log", logfile := fmt.Sprintf("logs/%s/%s-%s-%s.log",
cmd.Tag, cmd.Tag,
ki.Distro.ID.String(), ki.Distro.ID.String(),
ki.Distro.Release, ki.Distro.Release,
ki.KernelRelease, ki.KernelRelease,
) )
f, err := os.Create(logfile) f, err := os.Create(logfile)
if err != nil { if err != nil {
log.Error().Err(err).Msgf("create %s", logfile) log.Error().Err(err).Msgf("create %s", logfile)
return return
} }
defer f.Close() defer f.Close()
slog := zerolog.New(zerolog.MultiLevelWriter( logDirWriter = &zerolog.ConsoleWriter{
&ConsoleWriter,
&FileWriter,
&zerolog.ConsoleWriter{
Out: f, Out: f,
FieldsExclude: []string{ FieldsExclude: []string{
"distro_release", "distro_release",
"distro_type", "distro_type",
"kernel", "kernel",
"command",
"workdir",
}, },
NoColor: true, NoColor: true,
}, }
)) }
var slog zerolog.Logger
if logDirWriter != nil {
slog = zerolog.New(zerolog.MultiLevelWriter(
&ConsoleWriter,
&FileWriter,
logDirWriter,
))
} else {
slog = zerolog.New(zerolog.MultiLevelWriter(
&ConsoleWriter,
&FileWriter,
))
}
switch LogLevel { switch LogLevel {
case zerolog.TraceLevel, zerolog.DebugLevel: case zerolog.TraceLevel, zerolog.DebugLevel: