diff options
| author | Aleksandr Nogikh <nogikh@google.com> | 2024-06-28 13:46:53 +0200 |
|---|---|---|
| committer | Aleksandr Nogikh <nogikh@google.com> | 2024-07-01 09:13:47 +0000 |
| commit | a7b22031cdbe8555ef6d4a086bd11dbc9feea4fd (patch) | |
| tree | b678f59c9f269de3f5330a1d8ddf38c6afbb7656 /vm/vmimpl | |
| parent | ce1ad06980f78675067a2519a76601cb6cdc692b (diff) | |
vmimpl: add a delay after an error from the tracked process
It usually means a kernel crash, in which case we want to give the
kernel some more time to print the whole coverage report to the console.
Diffstat (limited to 'vm/vmimpl')
| -rw-r--r-- | vm/vmimpl/vmimpl.go | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/vm/vmimpl/vmimpl.go b/vm/vmimpl/vmimpl.go index be7186889..00a815314 100644 --- a/vm/vmimpl/vmimpl.go +++ b/vm/vmimpl/vmimpl.go @@ -146,6 +146,8 @@ var ( Types = make(map[string]Type) ) +var WaitForOutputTimeout = 10 * time.Second + func Multiplex(cmd *exec.Cmd, merger *OutputMerger, console io.Closer, timeout time.Duration, stop, closed <-chan bool, debug bool) (<-chan []byte, <-chan error, error) { errc := make(chan error, 1) @@ -168,6 +170,9 @@ func Multiplex(cmd *exec.Cmd, merger *OutputMerger, console io.Closer, timeout t signal(fmt.Errorf("instance closed")) case err := <-merger.Err: cmd.Process.Kill() + // Once the command has exited, we might want to let the full console + // output accumulate before we abort the console connection too. + time.Sleep(WaitForOutputTimeout) if console != nil { // Only wait for the merger if we're able to control the console stream. console.Close() |
