diff options
| author | Martin Polden <mpolden@mpolden.no> | 2023-04-14 15:52:02 +0200 |
|---|---|---|
| committer | Martin Polden <mpolden@mpolden.no> | 2023-04-17 10:31:40 +0200 |
| commit | bb273b823216308a1b33ce2ef6dc7b0a4639494b (patch) | |
| tree | 69949b5c931993f424c12ff5a6bd6d9f629e1ddc /client/go/internal/vespa/document/dispatcher.go | |
| parent | 58fb99d57e3b81f9c1c4567355355ef4a97e989f (diff) | |
Create key once
Diffstat (limited to 'client/go/internal/vespa/document/dispatcher.go')
| -rw-r--r-- | client/go/internal/vespa/document/dispatcher.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/client/go/internal/vespa/document/dispatcher.go b/client/go/internal/vespa/document/dispatcher.go index 798a888d677..dc6045ac791 100644 --- a/client/go/internal/vespa/document/dispatcher.go +++ b/client/go/internal/vespa/document/dispatcher.go @@ -184,10 +184,11 @@ func (d *Dispatcher) enqueue(op documentOp) error { if !d.started { return fmt.Errorf("dispatcher is closed") } - group, ok := d.inflight[op.document.Id.String()] + key := op.document.Id.String() + group, ok := d.inflight[key] if !ok { group = &documentGroup{} - d.inflight[op.document.Id.String()] = group + d.inflight[key] = group } d.mu.Unlock() group.add(op, op.attempts > 0) |