aboutsummaryrefslogtreecommitdiffstats
path: root/cache/resolvers.go
diff options
context:
space:
mode:
authorMichael Muré <batolettre@gmail.com>2021-04-08 16:25:22 +0200
committerGitHub <noreply@github.com>2021-04-08 16:25:22 +0200
commitbc5f618eba812859bf87ce2c31b278bd518d4555 (patch)
tree6429e6c47de93660b16debfa244427e79e7aed85 /cache/resolvers.go
parenta3e098d76314fbb197a6fbd85d2e1df02c9e00fe (diff)
parent554992523574684ecce36d38bf5310bff52c8c03 (diff)
downloadgit-bug-bc5f618eba812859bf87ce2c31b278bd518d4555.tar.gz
Merge pull request #628 from MichaelMure/entity-fix
cache: many fixes following the dag entity migration
Diffstat (limited to 'cache/resolvers.go')
-rw-r--r--cache/resolvers.go29
1 files changed, 29 insertions, 0 deletions
diff --git a/cache/resolvers.go b/cache/resolvers.go
index 36b70d3b..e53c3660 100644
--- a/cache/resolvers.go
+++ b/cache/resolvers.go
@@ -20,3 +20,32 @@ func newIdentityCacheResolver(cache *RepoCache) *identityCacheResolver {
func (i *identityCacheResolver) ResolveIdentity(id entity.Id) (identity.Interface, error) {
return i.cache.ResolveIdentity(id)
}
+
+var _ identity.Resolver = &identityCacheResolverNoLock{}
+
+// identityCacheResolverNoLock is an identity Resolver that retrieve identities from
+// the cache, without locking it.
+type identityCacheResolverNoLock struct {
+ cache *RepoCache
+}
+
+func newIdentityCacheResolverNoLock(cache *RepoCache) *identityCacheResolverNoLock {
+ return &identityCacheResolverNoLock{cache: cache}
+}
+
+func (ir *identityCacheResolverNoLock) ResolveIdentity(id entity.Id) (identity.Interface, error) {
+ cached, ok := ir.cache.identities[id]
+ if ok {
+ return cached, nil
+ }
+
+ i, err := identity.ReadLocal(ir.cache.repo, id)
+ if err != nil {
+ return nil, err
+ }
+
+ cached = NewIdentityCache(ir.cache, i)
+ ir.cache.identities[id] = cached
+
+ return cached, nil
+}