From 7468aec8a38d851d0189970dad8542a66a2dbf21 Mon Sep 17 00:00:00 2001 From: 9seconds Date: Mon, 9 Jul 2018 11:55:45 +0300 Subject: [PATCH] Do not use atomic if not necessary --- stats/channels.go | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/stats/channels.go b/stats/channels.go index 1ece855..7387b6d 100644 --- a/stats/channels.go +++ b/stats/channels.go @@ -2,7 +2,6 @@ package stats import ( "net" - "sync/atomic" "time" "github.com/9seconds/mtg/mtproto" @@ -54,26 +53,26 @@ func connectionManager() { switch event.connectionType { case mtproto.ConnectionTypeAbridged: if isIPv4 { - atomic.AddUint32(&instance.ActiveConnections.Abridged.IPv4, inc) + instance.ActiveConnections.Abridged.IPv4 += inc if event.connected { - atomic.AddUint32(&instance.AllConnections.Abridged.IPv4, inc) + instance.AllConnections.Abridged.IPv4 += inc } } else { - atomic.AddUint32(&instance.ActiveConnections.Abridged.IPv6, inc) + instance.ActiveConnections.Abridged.IPv6 += inc if event.connected { - atomic.AddUint32(&instance.AllConnections.Abridged.IPv6, inc) + instance.AllConnections.Abridged.IPv6 += inc } } default: if isIPv4 { - atomic.AddUint32(&instance.ActiveConnections.Intermediate.IPv4, inc) + instance.ActiveConnections.Intermediate.IPv4 += inc if event.connected { - atomic.AddUint32(&instance.AllConnections.Intermediate.IPv4, inc) + instance.AllConnections.Intermediate.IPv4 += inc } } else { - atomic.AddUint32(&instance.ActiveConnections.Intermediate.IPv6, inc) + instance.ActiveConnections.Intermediate.IPv6 += inc if event.connected { - atomic.AddUint32(&instance.AllConnections.Intermediate.IPv6, inc) + instance.AllConnections.Intermediate.IPv6 += inc } } }