ScuroNeko/mtg
1
0
Fork 0
mirror of https://github.com/ScuroNeko/mtg.git synced 2026-09-01 14:44:01 +03:00
Code Issues Packages Projects Releases Wiki Activity

Unpublic stats chans

Browse Source
This commit is contained in:
9seconds
2018-07-09 11:57:23 +03:00
parent 7468aec8a3
commit 2a6cc7e195
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
stats/channels.go
+11 -11
View File
@@ -14,9 +14,9 @@ const (
) )
var ( var (
CrashesChan = make(chan struct{}, crashesChanLength) crashesChan = make(chan struct{}, crashesChanLength)
ConnectionsChan = make(chan *connectionData, connectionsChanLength) connectionsChan = make(chan *connectionData, connectionsChanLength)
TrafficChan = make(chan *trafficData, trafficChanLength) trafficChan = make(chan *trafficData, trafficChanLength)
) )
type connectionData struct { type connectionData struct {
@@ -31,7 +31,7 @@ type trafficData struct {
} }
func crashManager() { func crashManager() {
for range CrashesChan { for range crashesChan {
instance.mutex.RLock() instance.mutex.RLock()
instance.Crashes++ instance.Crashes++
@@ -41,7 +41,7 @@ func crashManager() {
} }
func connectionManager() { func connectionManager() {
for event := range ConnectionsChan { for event := range connectionsChan {
instance.mutex.RLock() instance.mutex.RLock()
isIPv4 := event.addr.IP.To4() != nil isIPv4 := event.addr.IP.To4() != nil
@@ -86,7 +86,7 @@ func trafficManager() {
for { for {
select { select {
case event := <-TrafficChan: case event := <-trafficChan:
instance.mutex.RLock() instance.mutex.RLock()
if event.ingress { if event.ingress {
@@ -112,11 +112,11 @@ func trafficManager() {
} }
func NewCrash() { func NewCrash() {
CrashesChan <- struct{}{} crashesChan <- struct{}{}
} }
func ClientConnected(connectionType mtproto.ConnectionType, addr *net.TCPAddr) { func ClientConnected(connectionType mtproto.ConnectionType, addr *net.TCPAddr) {
ConnectionsChan <- &connectionData{ connectionsChan <- &connectionData{
connectionType: connectionType, connectionType: connectionType,
addr: addr, addr: addr,
connected: true, connected: true,
@@ -124,7 +124,7 @@ func ClientConnected(connectionType mtproto.ConnectionType, addr *net.TCPAddr) {
} }
func ClientDisconnected(connectionType mtproto.ConnectionType, addr *net.TCPAddr) { func ClientDisconnected(connectionType mtproto.ConnectionType, addr *net.TCPAddr) {
ConnectionsChan <- &connectionData{ connectionsChan <- &connectionData{
connectionType: connectionType, connectionType: connectionType,
addr: addr, addr: addr,
connected: false, connected: false,
@@ -132,14 +132,14 @@ func ClientDisconnected(connectionType mtproto.ConnectionType, addr *net.TCPAddr
} }
func IngressTraffic(traffic int) { func IngressTraffic(traffic int) {
TrafficChan <- &trafficData{ trafficChan <- &trafficData{
traffic: traffic, traffic: traffic,
ingress: true, ingress: true,
} }
} }
func EgressTraffic(traffic int) { func EgressTraffic(traffic int) {
TrafficChan <- &trafficData{ trafficChan <- &trafficData{
traffic: traffic, traffic: traffic,
ingress: false, ingress: false,
} }