unistack-org/micro-registry-cache
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix race in cache

Browse Source
This commit is contained in:
Asim Aslam 2019-10-04 16:40:21 +01:00 committed by Vasiliy Tolstov
parent 388ee7232c
commit dfd93346a9
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
cache.go
View File

@ -119,12 +119,10 @@ func (c *cache) get(service string) ([]*registry.Service, error) {
// make a copy // make a copy
cp := registry.Copy(services) cp := registry.Copy(services)
// unlock the read lock
c.RUnlock()
// got services && within ttl so return cache // got services && within ttl so return cache
if c.isValid(cp, ttl) { if c.isValid(cp, ttl) {
// return servics c.RUnlock()
// return services
return cp, nil return cp, nil
} }
@ -163,8 +161,11 @@ func (c *cache) get(service string) ([]*registry.Service, error) {
go c.run(service) go c.run(service)
} }
// unlock the read lock
c.RUnlock()
// get and return services // get and return services
return get(service, services) return get(service, cp)
} }
func (c *cache) set(service string, services []*registry.Service) { func (c *cache) set(service string, services []*registry.Service) {