Commit 3cd49143 authored by vyzo's avatar vyzo

read/write metadata lock

parent 0ddad15b
...@@ -16,7 +16,7 @@ type memoryPeerMetadata struct { ...@@ -16,7 +16,7 @@ type memoryPeerMetadata struct {
// store other data, like versions // store other data, like versions
//ds ds.ThreadSafeDatastore //ds ds.ThreadSafeDatastore
ds map[metakey]interface{} ds map[metakey]interface{}
dslock sync.Mutex dslock sync.RWMutex
} }
var _ pstore.PeerMetadata = (*memoryPeerMetadata)(nil) var _ pstore.PeerMetadata = (*memoryPeerMetadata)(nil)
...@@ -35,8 +35,8 @@ func (ps *memoryPeerMetadata) Put(p peer.ID, key string, val interface{}) error ...@@ -35,8 +35,8 @@ func (ps *memoryPeerMetadata) Put(p peer.ID, key string, val interface{}) error
} }
func (ps *memoryPeerMetadata) Get(p peer.ID, key string) (interface{}, error) { func (ps *memoryPeerMetadata) Get(p peer.ID, key string) (interface{}, error) {
ps.dslock.Lock() ps.dslock.RLock()
defer ps.dslock.Unlock() defer ps.dslock.RUnlock()
i, ok := ps.ds[metakey{p, key}] i, ok := ps.ds[metakey{p, key}]
if !ok { if !ok {
return nil, pstore.ErrNotFound return nil, pstore.ErrNotFound
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment