diff options
| author | Aleksandr Nogikh <nogikh@google.com> | 2025-01-24 15:14:16 +0100 |
|---|---|---|
| committer | Aleksandr Nogikh <nogikh@google.com> | 2025-01-24 14:45:07 +0000 |
| commit | 2d19ddde3e0e272bddc8220c8752c3d649459a26 (patch) | |
| tree | d439ea46af7120b83582d6b056ee861c50b00abf /pkg | |
| parent | 1293872ddc4eb3b11697a1d21008f7e99fcbba1f (diff) | |
pkg/fuzzer/queue: remove unnecessary Context usage
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/fuzzer/queue/queue.go | 4 | ||||
| -rw-r--r-- | pkg/vminfo/vminfo.go | 2 |
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), } } |
