diff options
| author | Aleksandr Nogikh <nogikh@google.com> | 2025-01-30 15:25:31 +0100 |
|---|---|---|
| committer | Aleksandr Nogikh <nogikh@google.com> | 2025-02-03 16:09:45 +0000 |
| commit | 8f276ef29583e363bb886170f2f424f2d2a0e244 (patch) | |
| tree | d37104b5067213b6058b7e588a3fc61b049b8c7f /pkg/fuzzer/queue | |
| parent | 52e7ad470cd3623478252840dce6484603ef1cf4 (diff) | |
pkg/vminfo: gracefully handle context abortion
On context abortion, return a special error.
On the pkg/rpcserver side, recognize and process it.
Diffstat (limited to 'pkg/fuzzer/queue')
| -rw-r--r-- | pkg/fuzzer/queue/queue.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/fuzzer/queue/queue.go b/pkg/fuzzer/queue/queue.go index 6e17225e2..1b98d768e 100644 --- a/pkg/fuzzer/queue/queue.go +++ b/pkg/fuzzer/queue/queue.go @@ -100,14 +100,14 @@ func (r *Request) Done(res *Result) { close(r.done) } -var errContextAborted = errors.New("context closed while waiting the result") +var ErrRequestAborted = errors.New("context closed while waiting the result") // Wait() blocks until we have the result. func (r *Request) Wait(ctx context.Context) *Result { r.initChannel() select { case <-ctx.Done(): - return &Result{Status: ExecFailure, Err: errContextAborted} + return &Result{Status: ExecFailure, Err: ErrRequestAborted} case <-r.done: return r.result } |
