xmengnet/mihomo
1
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Improve: use atomic for connection statistic (#938)

Browse source
This commit is contained in:
Kr328 2020-09-02 16:34:12 +08:00 committed by GitHub
parent a32ee13fc9
commit 7631bcc99e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 23 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
tunnel/manager.go
View file

@ -2,23 +2,19 @@ package tunnel
import ( import (
"sync" "sync"
"sync/atomic"
"time" "time"
) )
var DefaultManager *Manager var DefaultManager *Manager
func init() { func init() {
DefaultManager = &Manager{ DefaultManager = &Manager{}
upload: make(chan int64),
download: make(chan int64),
}
DefaultManager.handle() DefaultManager.handle()
} }
type Manager struct { type Manager struct {
connections sync.Map connections sync.Map
upload chan int64
download chan int64
uploadTemp int64 uploadTemp int64
downloadTemp int64 downloadTemp int64
uploadBlip int64 uploadBlip int64
@ -35,16 +31,18 @@ func (m *Manager) Leave(c tracker) {
m.connections.Delete(c.ID()) m.connections.Delete(c.ID())
} }
func (m *Manager) Upload() chan<- int64 { func (m *Manager) PushUploaded(size int64) {
return m.upload atomic.AddInt64(&m.uploadTemp, size)
atomic.AddInt64(&m.uploadTotal, size)
} }
func (m *Manager) Download() chan<- int64 { func (m *Manager) PushDownloaded(size int64) {
return m.download atomic.AddInt64(&m.downloadTemp, size)
atomic.AddInt64(&m.downloadTotal, size)
} }
func (m *Manager) Now() (up int64, down int64) { func (m *Manager) Now() (up int64, down int64) {
return m.uploadBlip, m.downloadBlip return atomic.LoadInt64(&m.uploadBlip), atomic.LoadInt64(&m.downloadBlip)
} }
func (m *Manager) Snapshot() *Snapshot { func (m *Manager) Snapshot() *Snapshot {
@ -55,8 +53,8 @@ func (m *Manager) Snapshot() *Snapshot {
}) })
return &Snapshot{ return &Snapshot{
UploadTotal: m.uploadTotal, UploadTotal: atomic.LoadInt64(&m.uploadTotal),
DownloadTotal: m.downloadTotal, DownloadTotal: atomic.LoadInt64(&m.downloadTotal),
Connections: connections, Connections: connections,
} }
} }
@ -71,21 +69,18 @@ func (m *Manager) ResetStatistic() {
} }
func (m *Manager) handle() { func (m *Manager) handle() {
go m.handleCh(m.upload, &m.uploadTemp, &m.uploadBlip, &m.uploadTotal) go m.handleCh(&m.uploadTemp, &m.uploadBlip)
go m.handleCh(m.download, &m.downloadTemp, &m.downloadBlip, &m.downloadTotal) go m.handleCh(&m.downloadTemp, &m.downloadBlip)
} }
func (m *Manager) handleCh(ch <-chan int64, temp *int64, blip *int64, total *int64) { func (m *Manager) handleCh(temp *int64, blip *int64) {
ticker := time.NewTicker(time.Second) ticker := time.NewTicker(time.Second)
for { for {
select { <-ticker.C
case n := <-ch:
*temp += n atomic.StoreInt64(blip, atomic.LoadInt64(temp))
*total += n atomic.StoreInt64(temp, 0)
case <-ticker.C:
*blip = *temp
*temp = 0
}
} }
} }

8
tunnel/tracker.go
View file

@ -37,7 +37,7 @@ func (tt *tcpTracker) ID() string {
func (tt *tcpTracker) Read(b []byte) (int, error) { func (tt *tcpTracker) Read(b []byte) (int, error) {
n, err := tt.Conn.Read(b) n, err := tt.Conn.Read(b)
download := int64(n) download := int64(n)
tt.manager.Download() <- download tt.manager.PushDownloaded(download)
tt.DownloadTotal += download tt.DownloadTotal += download
return n, err return n, err
} }
@ -45,7 +45,7 @@ func (tt *tcpTracker) Read(b []byte) (int, error) {
func (tt *tcpTracker) Write(b []byte) (int, error) { func (tt *tcpTracker) Write(b []byte) (int, error) {
n, err := tt.Conn.Write(b) n, err := tt.Conn.Write(b)
upload := int64(n) upload := int64(n)
tt.manager.Upload() <- upload tt.manager.PushUploaded(upload)
tt.UploadTotal += upload tt.UploadTotal += upload
return n, err return n, err
} }
@ -92,7 +92,7 @@ func (ut *udpTracker) ID() string {
func (ut *udpTracker) ReadFrom(b []byte) (int, net.Addr, error) { func (ut *udpTracker) ReadFrom(b []byte) (int, net.Addr, error) {
n, addr, err := ut.PacketConn.ReadFrom(b) n, addr, err := ut.PacketConn.ReadFrom(b)
download := int64(n) download := int64(n)
ut.manager.Download() <- download ut.manager.PushDownloaded(download)
ut.DownloadTotal += download ut.DownloadTotal += download
return n, addr, err return n, addr, err
} }
@ -100,7 +100,7 @@ func (ut *udpTracker) ReadFrom(b []byte) (int, net.Addr, error) {
func (ut *udpTracker) WriteTo(b []byte, addr net.Addr) (int, error) { func (ut *udpTracker) WriteTo(b []byte, addr net.Addr) (int, error) {
n, err := ut.PacketConn.WriteTo(b, addr) n, err := ut.PacketConn.WriteTo(b, addr)
upload := int64(n) upload := int64(n)
ut.manager.Upload() <- upload ut.manager.PushUploaded(upload)
ut.UploadTotal += upload ut.UploadTotal += upload
return n, err return n, err
} }