LBRYCommunity/lbcd
1
0
Fork 0
Code Issues 17 Pull requests 4 Projects Releases 28 Packages Wiki Activity

WIP: Feature/6/jeffreypicard/dockerize for deployment #7

Closed
jeffreypicard wants to merge 80 commits from feature/6/jeffreypicard/dockerize-for-deployment into master
pull from: feature/6/jeffreypicard/dockerize-for-deployment
merge into: LBRYCommunity:master
Conversation 0 Commits 80 Files changed 358 +7 -7
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 8dc0b54ebf - Show all commits

14
addrmgr/addrmanager.go
View file

@ -30,7 +30,7 @@ import (
// AddrManager provides a concurrency safe address manager for caching potential // AddrManager provides a concurrency safe address manager for caching potential
// peers on the bitcoin network. // peers on the bitcoin network.
type AddrManager struct { type AddrManager struct {
mtx sync.Mutex mtx sync.RWMutex
peersFile string peersFile string
lookupFunc func(string) ([]net.IP, error) lookupFunc func(string) ([]net.IP, error)
rand *rand.Rand rand *rand.Rand
@ -645,8 +645,8 @@ func (a *AddrManager) numAddresses() int {
// NumAddresses returns the number of addresses known to the address manager. // NumAddresses returns the number of addresses known to the address manager.
func (a *AddrManager) NumAddresses() int { func (a *AddrManager) NumAddresses() int {
a.mtx.Lock() a.mtx.RLock()
defer a.mtx.Unlock() defer a.mtx.RUnlock()
return a.numAddresses() return a.numAddresses()
} }
@ -654,8 +654,8 @@ func (a *AddrManager) NumAddresses() int {
// NeedMoreAddresses returns whether or not the address manager needs more // NeedMoreAddresses returns whether or not the address manager needs more
// addresses. // addresses.
func (a *AddrManager) NeedMoreAddresses() bool { func (a *AddrManager) NeedMoreAddresses() bool {
a.mtx.Lock() a.mtx.RLock()
defer a.mtx.Unlock() defer a.mtx.RUnlock()
return a.numAddresses() < needAddressThreshold return a.numAddresses() < needAddressThreshold
} }
@ -685,8 +685,8 @@ func (a *AddrManager) AddressCache() []*wire.NetAddress {
// getAddresses returns all of the addresses currently found within the // getAddresses returns all of the addresses currently found within the
// manager's address cache. // manager's address cache.
func (a *AddrManager) getAddresses() []*wire.NetAddress { func (a *AddrManager) getAddresses() []*wire.NetAddress {
a.mtx.Lock() a.mtx.RLock()
defer a.mtx.Unlock() defer a.mtx.RUnlock()
addrIndexLen := len(a.addrIndex) addrIndexLen := len(a.addrIndex)
if addrIndexLen == 0 { if addrIndexLen == 0 {