Merge pull request #10348 from hashicorp/dnephin/fix-submatview-store-bug
submatview: fix a bug with Store.Get
This commit is contained in:
commit
1766aa8a84
|
@ -118,8 +118,11 @@ func (s *Store) Get(ctx context.Context, req Request) (Result, error) {
|
||||||
}
|
}
|
||||||
defer s.releaseEntry(key)
|
defer s.releaseEntry(key)
|
||||||
|
|
||||||
ctx, cancel := context.WithTimeout(ctx, info.Timeout)
|
if info.Timeout > 0 {
|
||||||
defer cancel()
|
var cancel context.CancelFunc
|
||||||
|
ctx, cancel = context.WithTimeout(ctx, info.Timeout)
|
||||||
|
defer cancel()
|
||||||
|
}
|
||||||
|
|
||||||
result, err := materializer.getFromView(ctx, info.MinIndex)
|
result, err := materializer.getFromView(ctx, info.MinIndex)
|
||||||
// context.DeadlineExceeded is translated to nil to match the timeout
|
// context.DeadlineExceeded is translated to nil to match the timeout
|
||||||
|
|
|
@ -160,7 +160,6 @@ func (r *fakeRequest) CacheInfo() cache.RequestInfo {
|
||||||
Key: key,
|
Key: key,
|
||||||
Token: "abcd",
|
Token: "abcd",
|
||||||
Datacenter: "dc1",
|
Datacenter: "dc1",
|
||||||
Timeout: 4 * time.Second,
|
|
||||||
MinIndex: r.index,
|
MinIndex: r.index,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue