diff --git a/proxy/lib/snowflake.go b/proxy/lib/snowflake.go index 243b49d..53a502d 100644 --- a/proxy/lib/snowflake.go +++ b/proxy/lib/snowflake.go @@ -438,7 +438,6 @@ func (sf *SnowflakeProxy) makePeerConnectionFromOffer(sdp *webrtc.SessionDescrip conn.lock.Lock() defer conn.lock.Unlock() log.Printf("Data Channel %s-%d close\n", dc.Label(), dc.ID()) - log.Println(conn.bytesLogger.ThroughputSummary()) in, out := conn.bytesLogger.GetStat() conn.eventLogger.OnNewSnowflakeEvent(event.EventOnProxyConnectionOver{ InboundTraffic: in, diff --git a/proxy/lib/util.go b/proxy/lib/util.go index dd8681e..bb678d8 100644 --- a/proxy/lib/util.go +++ b/proxy/lib/util.go @@ -1,7 +1,6 @@ package snowflake_proxy import ( - "fmt" "time" ) @@ -10,7 +9,6 @@ import ( type bytesLogger interface { AddOutbound(int64) AddInbound(int64) - ThroughputSummary() string GetStat() (in int64, out int64) } @@ -23,9 +21,6 @@ func (b bytesNullLogger) AddOutbound(amount int64) {} // AddInbound in bytesNullLogger does nothing func (b bytesNullLogger) AddInbound(amount int64) {} -// ThroughputSummary in bytesNullLogger does nothing -func (b bytesNullLogger) ThroughputSummary() string { return "" } - func (b bytesNullLogger) GetStat() (in int64, out int64) { return -1, -1 } // bytesSyncLogger uses channels to safely log from multiple sources with output @@ -71,18 +66,6 @@ func (b *bytesSyncLogger) AddInbound(amount int64) { b.inboundChan <- amount } -// ThroughputSummary view a formatted summary of the throughput totals -func (b *bytesSyncLogger) ThroughputSummary() string { - inbound := b.inbound - outbound := b.outbound - - inbound, inUnit := formatTraffic(inbound) - outbound, outUnit := formatTraffic(outbound) - - t := time.Now() - return fmt.Sprintf("Traffic throughput (down|up): %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 int64, out int64) { return b.inbound, b.outbound } func formatTraffic(amount int64) (value int64, unit string) { return amount / 1000, "KB" }