aboutsummaryrefslogtreecommitdiffstats
path: root/pkg
diff options
context:
space:
mode:
authorAleksandr Nogikh <nogikh@google.com>2025-01-24 15:14:16 +0100
committerAleksandr Nogikh <nogikh@google.com>2025-01-24 14:45:07 +0000
commit2d19ddde3e0e272bddc8220c8752c3d649459a26 (patch)
treed439ea46af7120b83582d6b056ee861c50b00abf /pkg
parent1293872ddc4eb3b11697a1d21008f7e99fcbba1f (diff)
pkg/fuzzer/queue: remove unnecessary Context usage
Diffstat (limited to 'pkg')
-rw-r--r--pkg/fuzzer/queue/queue.go4
-rw-r--r--pkg/vminfo/vminfo.go2
2 files changed, 2 insertions, 4 deletions
diff --git a/pkg/fuzzer/queue/queue.go b/pkg/fuzzer/queue/queue.go
index 05d9cfbed..58c9f1561 100644
--- a/pkg/fuzzer/queue/queue.go
+++ b/pkg/fuzzer/queue/queue.go
@@ -422,7 +422,6 @@ func (ds *DynamicSourceCtl) Next() *Request {
// Deduplicator() keeps track of the previously run requests to avoid re-running them.
type Deduplicator struct {
mu sync.Mutex
- ctx context.Context
source Source
mm map[hash.Sig]*duplicateState
}
@@ -432,9 +431,8 @@ type duplicateState struct {
queued []*Request // duplicate requests waiting for the result.
}
-func Deduplicate(ctx context.Context, source Source) Source {
+func Deduplicate(source Source) Source {
return &Deduplicator{
- ctx: ctx,
source: source,
mm: map[hash.Sig]*duplicateState{},
}
diff --git a/pkg/vminfo/vminfo.go b/pkg/vminfo/vminfo.go
index dee1924b5..c1171bddb 100644
--- a/pkg/vminfo/vminfo.go
+++ b/pkg/vminfo/vminfo.go
@@ -69,7 +69,7 @@ func New(ctx context.Context, cfg *Config) *Checker {
executor := queue.Plain()
return &Checker{
checker: impl,
- source: queue.Deduplicate(ctx, executor),
+ source: queue.Deduplicate(executor),
checkContext: newCheckContext(ctx, cfg, impl, executor),
}
}