71 lines
1.2 KiB
Go
71 lines
1.2 KiB
Go
|
package server
|
||
|
|
|
||
|
|
import (
|
||
|
|
"sync"
|
||
|
|
"time"
|
||
|
|
)
|
||
|
|
|
||
|
|
type counter struct {
|
||
|
|
duration time.Duration
|
||
|
|
zeroTimer *time.Timer
|
||
|
|
wg sync.WaitGroup
|
||
|
|
connections int
|
||
|
|
mutex sync.Mutex
|
||
|
|
}
|
||
|
|
|
||
|
|
func newCounter(duration time.Duration) *counter {
|
||
|
|
zeroTimer := time.NewTimer(duration)
|
||
|
|
|
||
|
|
// when duration is 0, drain the expire event here
|
||
|
|
// so that user will never get the event.
|
||
|
|
if duration == 0 {
|
||
|
|
<-zeroTimer.C
|
||
|
|
}
|
||
|
|
|
||
|
|
return &counter{
|
||
|
|
duration: duration,
|
||
|
|
zeroTimer: zeroTimer,
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (counter *counter) add(n int) int {
|
||
|
|
counter.mutex.Lock()
|
||
|
|
defer counter.mutex.Unlock()
|
||
|
|
|
||
|
|
if counter.duration > 0 {
|
||
|
|
counter.zeroTimer.Stop()
|
||
|
|
}
|
||
|
|
counter.wg.Add(n)
|
||
|
|
counter.connections += n
|
||
|
|
|
||
|
|
return counter.connections
|
||
|
|
}
|
||
|
|
|
||
|
|
func (counter *counter) done() int {
|
||
|
|
counter.mutex.Lock()
|
||
|
|
defer counter.mutex.Unlock()
|
||
|
|
|
||
|
|
counter.connections--
|
||
|
|
counter.wg.Done()
|
||
|
|
if counter.connections == 0 && counter.duration > 0 {
|
||
|
|
counter.zeroTimer.Reset(counter.duration)
|
||
|
|
}
|
||
|
|
|
||
|
|
return counter.connections
|
||
|
|
}
|
||
|
|
|
||
|
|
func (counter *counter) count() int {
|
||
|
|
counter.mutex.Lock()
|
||
|
|
defer counter.mutex.Unlock()
|
||
|
|
|
||
|
|
return counter.connections
|
||
|
|
}
|
||
|
|
|
||
|
|
func (counter *counter) wait() {
|
||
|
|
counter.wg.Wait()
|
||
|
|
}
|
||
|
|
|
||
|
|
func (counter *counter) timer() *time.Timer {
|
||
|
|
return counter.zeroTimer
|
||
|
|
}
|