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

Add Raw Data Output for bytesLogger

Browse source
This commit is contained in:
Shelikhoo 2021-12-20 12:29:23 +00:00
parent 6cb82618a0
commit 91379a42f3
No known key found for this signature in database
GPG key ID: C4D5E79D22B25316
1 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

5
proxy/lib/util.go
View file

@ -11,6 +11,7 @@ type bytesLogger interface {
AddOutbound(int) AddOutbound(int)
AddInbound(int) AddInbound(int)
ThroughputSummary() string ThroughputSummary() string
GetStat() (in int, out int)
} }
// bytesNullLogger Default bytesLogger does nothing. // bytesNullLogger Default bytesLogger does nothing.
@ -25,6 +26,8 @@ func (b bytesNullLogger) AddInbound(amount int) {}
// ThroughputSummary in bytesNullLogger does nothing // ThroughputSummary in bytesNullLogger does nothing
func (b bytesNullLogger) ThroughputSummary() string { return "" } func (b bytesNullLogger) ThroughputSummary() string { return "" }
func (b bytesNullLogger) GetStat() (in int, out int) { return -1, -1 }
// bytesSyncLogger uses channels to safely log from multiple sources with output // bytesSyncLogger uses channels to safely log from multiple sources with output
// occuring at reasonable intervals. // occuring at reasonable intervals.
type bytesSyncLogger struct { type bytesSyncLogger struct {
@ -92,3 +95,5 @@ func (b *bytesSyncLogger) ThroughputSummary() string {
t := time.Now() t := time.Now()
return fmt.Sprintf("Traffic throughput (up|down): %d %s|%d %s -- (%d OnMessages, %d Sends, over %d seconds)", inbound, inUnit, outbound, outUnit, b.outEvents, b.inEvents, int(t.Sub(b.start).Seconds())) return fmt.Sprintf("Traffic throughput (up|down): %d %s|%d %s -- (%d OnMessages, %d Sends, over %d seconds)", inbound, inUnit, outbound, outUnit, b.outEvents, b.inEvents, int(t.Sub(b.start).Seconds()))
} }
func (b *bytesSyncLogger) GetStat() (in int, out int) { return b.inbound, b.outbound }