fix race with rcache
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
parent
8d21dd456c
commit
58775249c5
@ -34,7 +34,9 @@ func (m *gossipWatcher) Next() (*registry.Result, error) {
|
|||||||
if len(m.wo.Service) > 0 && r.Service.Name != m.wo.Service {
|
if len(m.wo.Service) > 0 && r.Service.Name != m.wo.Service {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
return r, nil
|
nr := ®istry.Result{}
|
||||||
|
*nr = *r
|
||||||
|
return nr, nil
|
||||||
case <-m.stop:
|
case <-m.stop:
|
||||||
return nil, registry.ErrWatcherStopped
|
return nil, registry.ErrWatcherStopped
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user