libp2p/go-libp2p-peerstore
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p-peerstore.git synced 2025-01-01 00:20:11 +08:00
Code Issues Projects Releases Wiki Activity

Don't export ttl manager functions

Browse Source
This commit is contained in:
Cole Brown 2018-06-11 19:59:50 -04:00
parent 2d0ebcedd7
commit 7e46530328
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
addr_manager_ds.go
View File

@ -28,7 +28,7 @@ func NewDatastoreAddrManager(ctx context.Context, ds ds.Datastore, ttlInterval t
} }
func (mgr *DatastoreAddrManager) Stop() { func (mgr *DatastoreAddrManager) Stop() {
mgr.ttlManager.Stop() mgr.ttlManager.stop()
} }
func peerAddressKey(p *peer.ID, addr *ma.Multiaddr) (ds.Key, error) { func peerAddressKey(p *peer.ID, addr *ma.Multiaddr) (ds.Key, error) {
@ -77,12 +77,12 @@ func (mgr *DatastoreAddrManager) SetAddrs(p peer.ID, addrs []ma.Multiaddr, ttl t
} }
} }
} }
mgr.ttlManager.SetTTLs(keys, ttl) mgr.ttlManager.setTTLs(keys, ttl)
} }
func (mgr *DatastoreAddrManager) UpdateAddrs(p peer.ID, oldTTL time.Duration, newTTL time.Duration) { func (mgr *DatastoreAddrManager) UpdateAddrs(p peer.ID, oldTTL time.Duration, newTTL time.Duration) {
prefix := ds.NewKey(p.Pretty()) prefix := ds.NewKey(p.Pretty())
mgr.ttlManager.UpdateTTLs(prefix, oldTTL, newTTL) mgr.ttlManager.updateTTLs(prefix, oldTTL, newTTL)
} }
func (mgr *DatastoreAddrManager) Addrs(p peer.ID) []ma.Multiaddr { func (mgr *DatastoreAddrManager) Addrs(p peer.ID) []ma.Multiaddr {
@ -125,7 +125,7 @@ func (mgr *DatastoreAddrManager) ClearAddrs(p peer.ID) {
for result := range results.Next() { for result := range results.Next() {
mgr.ds.Delete(ds.NewKey(result.Key)) mgr.ds.Delete(ds.NewKey(result.Key))
} }
mgr.ttlManager.Clear(ds.NewKey(p.Pretty())) mgr.ttlManager.clear(ds.NewKey(p.Pretty()))
} }
// ttlmanager // ttlmanager
@ -173,7 +173,7 @@ func newTTLManager(parent context.Context, d ds.Datastore, tick time.Duration) *
return mgr return mgr
} }
func (mgr *ttlmanager) Stop() { func (mgr *ttlmanager) stop() {
mgr.cancel() mgr.cancel()
<-mgr.done <-mgr.done
} }
@ -194,7 +194,7 @@ func (mgr *ttlmanager) tick() {
} }
} }
func (mgr *ttlmanager) SetTTLs(keys []ds.Key, ttl time.Duration) { func (mgr *ttlmanager) setTTLs(keys []ds.Key, ttl time.Duration) {
mgr.Lock() mgr.Lock()
defer mgr.Unlock() defer mgr.Unlock()
@ -208,7 +208,7 @@ func (mgr *ttlmanager) SetTTLs(keys []ds.Key, ttl time.Duration) {
} }
} }
func (mgr *ttlmanager) UpdateTTLs(prefix ds.Key, oldTTL, newTTL time.Duration) { func (mgr *ttlmanager) updateTTLs(prefix ds.Key, oldTTL, newTTL time.Duration) {
mgr.Lock() mgr.Lock()
defer mgr.Unlock() defer mgr.Unlock()
@ -223,7 +223,7 @@ func (mgr *ttlmanager) UpdateTTLs(prefix ds.Key, oldTTL, newTTL time.Duration) {
} }
} }
func (mgr *ttlmanager) Clear(prefix ds.Key) { func (mgr *ttlmanager) clear(prefix ds.Key) {
mgr.Lock() mgr.Lock()
defer mgr.Unlock() defer mgr.Unlock()