feat: add timeout for first threads
This commit is contained in:
parent
2f9b5d615b
commit
916acc9895
7
pew.go
7
pew.go
@ -839,6 +839,8 @@ func (cmd PewCmd) performCI(ka config.Artifact) (err error) {
|
|||||||
found := false
|
found := false
|
||||||
max := cmd.Max
|
max := cmd.Max
|
||||||
|
|
||||||
|
qemuCounter := 0
|
||||||
|
|
||||||
swg := sizedwaitgroup.New(cmd.Threads)
|
swg := sizedwaitgroup.New(cmd.Threads)
|
||||||
if cmd.Shuffle {
|
if cmd.Shuffle {
|
||||||
cmd.kcfg.Kernels = shuffleKernels(cmd.kcfg.Kernels)
|
cmd.kcfg.Kernels = shuffleKernels(cmd.kcfg.Kernels)
|
||||||
@ -864,6 +866,11 @@ func (cmd PewCmd) performCI(ka config.Artifact) (err error) {
|
|||||||
break
|
break
|
||||||
}
|
}
|
||||||
swg.Add()
|
swg.Add()
|
||||||
|
if qemuCounter < cmd.Threads {
|
||||||
|
duration := time.Second * time.Duration(qemuCounter)
|
||||||
|
time.Sleep(duration)
|
||||||
|
qemuCounter++
|
||||||
|
}
|
||||||
go cmd.testArtifact(&swg, ka, kernel)
|
go cmd.testArtifact(&swg, ka, kernel)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user