-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Allow passing in existing StatsTracker
- Loading branch information
Showing
5 changed files
with
140 additions
and
100 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,124 @@ | ||
| package gonat | ||
|
|
||
| import ( | ||
| "sync" | ||
| "sync/atomic" | ||
| "syscall" | ||
| "time" | ||
|
|
||
| "github.com/getlantern/ops" | ||
| ) | ||
|
|
||
| // StatsTracker tracks statistics for one or more gonat servers. | ||
| type StatsTracker struct { | ||
| acceptedPackets int64 | ||
| invalidPackets int64 | ||
| droppedPackets int64 | ||
| numTCPConns int64 | ||
| numUDPConns int64 | ||
| statsInterval time.Duration | ||
| startOnce sync.Once | ||
| stop chan interface{} | ||
| stopped chan interface{} | ||
| } | ||
|
|
||
| // NewStatsTracker creates a new StatsTracker that will log stats at the given statsInterval. | ||
| // Logging only begins once a Server using this StatsTracker is started, and continues until | ||
| // Stop is called | ||
| func NewStatsTracker(statsInterval time.Duration) *StatsTracker { | ||
| return &StatsTracker{ | ||
| statsInterval: statsInterval, | ||
| stop: make(chan interface{}), | ||
| stopped: make(chan interface{}), | ||
| } | ||
| } | ||
|
|
||
| // Stop stops the StatsTracker | ||
| func (s *StatsTracker) Close() error { | ||
| select { | ||
| case <-s.stop: | ||
| // already stopped | ||
| default: | ||
| close(s.stop) | ||
| } | ||
| <-s.stopped | ||
| return nil | ||
| } | ||
|
|
||
| func (s *StatsTracker) start() { | ||
| s.startOnce.Do(func() { | ||
| ops.Go(s.trackStats) | ||
| }) | ||
| } | ||
|
|
||
| func (s *StatsTracker) trackStats() { | ||
| defer close(s.stopped) | ||
| ticker := time.NewTicker(s.statsInterval) | ||
| defer ticker.Stop() | ||
|
|
||
| for { | ||
| select { | ||
| case <-s.stop: | ||
| return | ||
| case <-ticker.C: | ||
| log.Debugf("TCP Conns: %v UDP Conns: %v", s.NumTCPConns(), s.NumUDPConns()) | ||
| log.Debugf("Invalid Packets: %d Accepted Packets: %d Dropped Packets: %d", s.InvalidPackets(), s.AcceptedPackets(), s.DroppedPackets()) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| func (s *StatsTracker) acceptedPacket() { | ||
| atomic.AddInt64(&s.acceptedPackets, 1) | ||
| } | ||
|
|
||
| // AcceptedPackets gives a count of accepted packets | ||
| func (s *StatsTracker) AcceptedPackets() int { | ||
| return int(atomic.LoadInt64(&s.acceptedPackets)) | ||
| } | ||
|
|
||
| func (s *StatsTracker) invalidPacket() { | ||
| atomic.AddInt64(&s.invalidPackets, 1) | ||
| } | ||
|
|
||
| // InvalidPackets gives a count of invalid packets (unknown destination, wrong IP version, etc.) | ||
| func (s *StatsTracker) InvalidPackets() int { | ||
| return int(atomic.LoadInt64(&s.invalidPackets)) | ||
| } | ||
|
|
||
| func (s *StatsTracker) droppedPacket() { | ||
| atomic.AddInt64(&s.droppedPackets, 1) | ||
| } | ||
|
|
||
| // DroppedPackets gives a count of packets dropped due to being stalled writing down or upstream, | ||
| // being unable to assign a port open a connection, etc. | ||
| func (s *StatsTracker) DroppedPackets() int { | ||
| return int(atomic.LoadInt64(&s.droppedPackets)) | ||
| } | ||
|
|
||
| func (s *StatsTracker) addConn(proto uint8) { | ||
| switch proto { | ||
| case syscall.IPPROTO_TCP: | ||
| atomic.AddInt64(&s.numTCPConns, 1) | ||
| case syscall.IPPROTO_UDP: | ||
| atomic.AddInt64(&s.numUDPConns, 1) | ||
| } | ||
| } | ||
|
|
||
| func (s *StatsTracker) removeConn(proto uint8) { | ||
| switch proto { | ||
| case syscall.IPPROTO_TCP: | ||
| atomic.AddInt64(&s.numTCPConns, -1) | ||
| case syscall.IPPROTO_UDP: | ||
| atomic.AddInt64(&s.numUDPConns, -1) | ||
| } | ||
| } | ||
|
|
||
| // NumTCPConns gives a count of the number of TCP connections being tracked | ||
| func (s *StatsTracker) NumTCPConns() int { | ||
| return int(atomic.LoadInt64(&s.numTCPConns)) | ||
| } | ||
|
|
||
| // NumUDPConns gives a count of the number of UDP connections being tracked | ||
| func (s *StatsTracker) NumUDPConns() int { | ||
| return int(atomic.LoadInt64(&s.numUDPConns)) | ||
| } |
This file was deleted.
Oops, something went wrong.