From 8f276ef29583e363bb886170f2f424f2d2a0e244 Mon Sep 17 00:00:00 2001 From: Aleksandr Nogikh Date: Thu, 30 Jan 2025 15:25:31 +0100 Subject: pkg/vminfo: gracefully handle context abortion On context abortion, return a special error. On the pkg/rpcserver side, recognize and process it. --- pkg/fuzzer/queue/queue.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'pkg/fuzzer/queue') 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 } -- cgit mrf-deployment