mirror of
https://github.com/fluencelabs/go-libp2p-kad-dht
synced 2025-06-01 07:21:19 +00:00
use NewKey over RawKey as it doesnt exist yet
This commit is contained in:
parent
1b4f407655
commit
b152b1ed87
@ -176,7 +176,7 @@ func writeProviderEntry(dstore ds.Datastore, k *cid.Cid, p peer.ID, t time.Time)
|
|||||||
buf := make([]byte, 16)
|
buf := make([]byte, 16)
|
||||||
n := binary.PutVarint(buf, t.UnixNano())
|
n := binary.PutVarint(buf, t.UnixNano())
|
||||||
|
|
||||||
return dstore.Put(ds.RawKey(dsk), buf[:n])
|
return dstore.Put(ds.NewKey(dsk), buf[:n])
|
||||||
}
|
}
|
||||||
|
|
||||||
func (pm *ProviderManager) deleteProvSet(k *cid.Cid) error {
|
func (pm *ProviderManager) deleteProvSet(k *cid.Cid) error {
|
||||||
@ -193,7 +193,7 @@ func (pm *ProviderManager) deleteProvSet(k *cid.Cid) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for _, e := range entries {
|
for _, e := range entries {
|
||||||
err := pm.dstore.Delete(ds.RawKey(e.Key))
|
err := pm.dstore.Delete(ds.NewKey(e.Key))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error("deleting provider set: ", err)
|
log.Error("deleting provider set: ", err)
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user