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

connmgr: unexport the DynamicBanScore mutex.

Browse source
This commit is contained in:
David Hill 2016-11-01 15:12:27 -04:00 committed by Dave Collins
parent 83432785f3
commit 6951d8e235
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
connmgr/dynamicbanscore.go
View file

@ -64,15 +64,15 @@ type DynamicBanScore struct {
lastUnix int64 lastUnix int64
transient float64 transient float64
persistent uint32 persistent uint32
sync.Mutex mtx sync.Mutex
} }
// String returns the ban score as a human-readable string. // String returns the ban score as a human-readable string.
func (s *DynamicBanScore) String() string { func (s *DynamicBanScore) String() string {
s.Lock() s.mtx.Lock()
r := fmt.Sprintf("persistent %v + transient %v at %v = %v as of now", r := fmt.Sprintf("persistent %v + transient %v at %v = %v as of now",
s.persistent, s.transient, s.lastUnix, s.Int()) s.persistent, s.transient, s.lastUnix, s.Int())
s.Unlock() s.mtx.Unlock()
return r return r
} }
@ -81,9 +81,9 @@ func (s *DynamicBanScore) String() string {
// //
// This function is safe for concurrent access. // This function is safe for concurrent access.
func (s *DynamicBanScore) Int() uint32 { func (s *DynamicBanScore) Int() uint32 {
s.Lock() s.mtx.Lock()
r := s.int(time.Now()) r := s.int(time.Now())
s.Unlock() s.mtx.Unlock()
return r return r
} }
@ -92,9 +92,9 @@ func (s *DynamicBanScore) Int() uint32 {
// //
// This function is safe for concurrent access. // This function is safe for concurrent access.
func (s *DynamicBanScore) Increase(persistent, transient uint32) uint32 { func (s *DynamicBanScore) Increase(persistent, transient uint32) uint32 {
s.Lock() s.mtx.Lock()
r := s.increase(persistent, transient, time.Now()) r := s.increase(persistent, transient, time.Now())
s.Unlock() s.mtx.Unlock()
return r return r
} }
@ -102,11 +102,11 @@ func (s *DynamicBanScore) Increase(persistent, transient uint32) uint32 {
// //
// This function is safe for concurrent access. // This function is safe for concurrent access.
func (s *DynamicBanScore) Reset() { func (s *DynamicBanScore) Reset() {
s.Lock() s.mtx.Lock()
s.persistent = 0 s.persistent = 0
s.transient = 0 s.transient = 0
s.lastUnix = 0 s.lastUnix = 0
s.Unlock() s.mtx.Unlock()
} }
// int returns the ban score, the sum of the persistent and decaying scores at a // int returns the ban score, the sum of the persistent and decaying scores at a