fluencelabs/go-libp2p-kad-dht
1
0
Fork 0
mirror of https://github.com/fluencelabs/go-libp2p-kad-dht synced 2025-04-24 22:32:13 +00:00
Code Issues Projects Releases Wiki Activity

Load providers from datastore on cache miss

Browse Source 
Cache miss might mean that provider records where offloaded to
datastore and need to be brough back up in order to have a consistent
cache entry.
This commit is contained in:
Vasily Kolobkov 2016-11-10 18:01:48 +02:00
parent df7a822619
commit bd6e9b1d2f
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
providers/providers.go
View File

@ -160,7 +160,11 @@ func readTimeValue(i interface{}) (time.Time, error) {
func (pm *ProviderManager) addProv(k *cid.Cid, p peer.ID) error {
iprovs, ok := pm.providers.Get(k.KeyString())
if !ok {
iprovs = newProviderSet()
stored, err := loadProvSet(pm.dstore, k)
if err != nil {
return err
}
iprovs = stored
pm.providers.Add(k.KeyString(), iprovs)
}
provs := iprovs.(*providerSet)