archives/snowflake
2
0
Fork 0
mirror of https://gitlab.torproject.org/tpo/anti-censorship/pluggable-transports/snowflake.git synced 2025-10-14 05:11:19 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

use const LogTimeInterval

Browse source
This commit is contained in:
Serene Han 2016-02-28 13:16:12 -08:00
parent 5aae41c901
commit 8a8273e972
1 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
client/util.go
View file

@ -5,6 +5,10 @@ import (
"time" "time"
) )
const (
LogTimeInterval = 5
)
type BytesInfo struct { type BytesInfo struct {
outboundChan chan int outboundChan chan int
inboundChan chan int inboundChan chan int
@ -33,18 +37,18 @@ func (b *BytesInfo) Log() {
b.outbound += amount b.outbound += amount
b.outEvents++ b.outEvents++
last := time.Now() last := time.Now()
if time.Since(last) > time.Second*5 { if time.Since(last) > time.Second*LogTimeInterval {
last = time.Now() last = time.Now()
output() output()
} }
case amount = <-b.inboundChan: case amount = <-b.inboundChan:
b.inbound += amount b.inbound += amount
b.inEvents++ b.inEvents++
if time.Since(last) > time.Second*5 { if time.Since(last) > time.Second*LogTimeInterval {
last = time.Now() last = time.Now()
output() output()
} }
case <-time.After(time.Second * 5): case <-time.After(time.Second * LogTimeInterval):
if b.inEvents > 0 || b.outEvents > 0 { if b.inEvents > 0 || b.outEvents > 0 {
output() output()
} }