aboutsummaryrefslogtreecommitdiffstats
path: root/pkg/fuzzer
diff options
context:
space:
mode:
authorAleksandr Nogikh <nogikh@google.com>2025-01-30 15:25:31 +0100
committerAleksandr Nogikh <nogikh@google.com>2025-02-03 16:09:45 +0000
commit8f276ef29583e363bb886170f2f424f2d2a0e244 (patch)
treed37104b5067213b6058b7e588a3fc61b049b8c7f /pkg/fuzzer
parent52e7ad470cd3623478252840dce6484603ef1cf4 (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')
-rw-r--r--pkg/fuzzer/queue/queue.go4
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
}