libp2p/go-libp2p-peerstore
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p-peerstore.git synced 2025-03-22 12:50:07 +08:00
Code Issues Projects Releases Wiki Activity

Merge pull request #185 from libp2p/remove-interning

Browse Source 
remove metadata interning
This commit is contained in:
Marten Seemann 2021-12-02 16:10:45 +04:00 committed by GitHub
commit c07b052352
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pstoremem/metadata.go
View File

@ -9,18 +9,15 @@ import (
type memoryPeerMetadata struct {
// store other data, like versions
// ds ds.ThreadSafeDatastore
ds map[peer.ID]map[string]interface{}
dslock sync.RWMutex
interned map[string]interface{}
ds map[peer.ID]map[string]interface{}
dslock sync.RWMutex
}
var _ pstore.PeerMetadata = (*memoryPeerMetadata)(nil)
func NewPeerMetadata() *memoryPeerMetadata {
return &memoryPeerMetadata{
ds: make(map[peer.ID]map[string]interface{}),
interned: make(map[string]interface{}),
ds: make(map[peer.ID]map[string]interface{}),
}
}
@ -30,13 +27,6 @@ func (ps *memoryPeerMetadata) Put(p peer.ID, key string, val interface{}) error
}
ps.dslock.Lock()
defer ps.dslock.Unlock()
if vals, ok := val.(string); ok && (key == "AgentVersion" || key == "ProtocolVersion") {
if interned, ok := ps.interned[vals]; ok {
val = interned
} else {
ps.interned[vals] = val
}
}
m, ok := ps.ds[p]
if !ok {
m = make(map[string]interface{})