aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--syz-fuzzer/testing.go26
1 files changed, 14 insertions, 12 deletions
diff --git a/syz-fuzzer/testing.go b/syz-fuzzer/testing.go
index 68dbb1e55..0ef837801 100644
--- a/syz-fuzzer/testing.go
+++ b/syz-fuzzer/testing.go
@@ -101,24 +101,26 @@ func convertTestReq(target *prog.Target, req *rpctype.RunTestPollRes) *runtest.R
return test
}
+func checkMachineHeartbeats(done chan bool) {
+ ticker := time.NewTicker(3 * time.Second)
+ defer ticker.Stop()
+ for {
+ select {
+ case <-done:
+ return
+ case <-ticker.C:
+ fmt.Printf("executing program\n")
+ }
+ }
+}
+
func checkMachine(args *checkArgs) (*rpctype.CheckArgs, error) {
log.Logf(0, "checking machine...")
// Machine checking can be very slow on some machines (qemu without kvm, KMEMLEAK linux, etc),
// so print periodic heartbeats for vm.MonitorExecution so that it does not decide that we are dead.
done := make(chan bool)
defer close(done)
- go func() {
- ticker := time.NewTicker(3 * time.Second)
- defer ticker.Stop()
- for {
- select {
- case <-done:
- return
- case <-ticker.C:
- fmt.Printf("executing program\n")
- }
- }
- }()
+ go checkMachineHeartbeats(done)
if err := checkRevisions(args); err != nil {
return nil, err
}