[Feature] Extend Throughput Logging

Extends throughput logging to continue even after saturation has been reached by the algorithm.

3 files changed, 9 insertions, 9 deletions

diff --git a/extendedstats/darwin.go b/extendedstats/darwin.go
index 0f52be5..17298c9 100644
--- a/extendedstats/darwin.go
+++ b/extendedstats/darwin.go
@@ -12,7 +12,7 @@ import (
 	"golang.org/x/sys/unix"
 )
 
-type ExtendedStats struct {
+type AggregateExtendedStats struct {
 	Maxseg               uint64
 	MaxSendMss           uint64
 	MaxRecvMss           uint64
@@ -38,7 +38,7 @@ type TCPInfo struct {
 	Snd_cwnd          uint32
 }
 
-func (es *ExtendedStats) IncorporateConnectionStats(basicConn net.Conn) error {
+func (es *AggregateExtendedStats) IncorporateConnectionStats(basicConn net.Conn) error {
 	if info, err := GetTCPInfo(basicConn); err != nil {
 		return fmt.Errorf("OOPS: Could not get the TCP info for the connection: %v", err)
 	} else {
@@ -54,7 +54,7 @@ func (es *ExtendedStats) IncorporateConnectionStats(basicConn net.Conn) error {
 	return nil
 }
 
-func (es *ExtendedStats) Repr() string {
+func (es *AggregateExtendedStats) Repr() string {
 	return fmt.Sprintf(`Extended Statistics:
 	Maximum Segment Size: %v
 	Total Bytes Retransmitted: %v
diff --git a/extendedstats/unix.go b/extendedstats/unix.go
index 3db94fc..270a956 100644
--- a/extendedstats/unix.go
+++ b/extendedstats/unix.go
@@ -12,7 +12,7 @@ import (
 	"golang.org/x/sys/unix"
 )
 
-type ExtendedStats struct {
+type AggregateExtendedStats struct {
 	MaxPathMtu           uint64
 	MaxSendMss           uint64
 	MaxRecvMss           uint64
@@ -27,7 +27,7 @@ func ExtendedStatsAvailable() bool {
 	return true
 }
 
-func (es *ExtendedStats) IncorporateConnectionStats(basicConn net.Conn) error {
+func (es *AggregateExtendedStats) IncorporateConnectionStats(basicConn net.Conn) error {
 	if info, err := GetTCPInfo(basicConn); err != nil {
 		return fmt.Errorf("OOPS: Could not get the TCP info for the connection: %v", err)
 	} else {
@@ -44,7 +44,7 @@ func (es *ExtendedStats) IncorporateConnectionStats(basicConn net.Conn) error {
 	return nil
 }
 
-func (es *ExtendedStats) Repr() string {
+func (es *AggregateExtendedStats) Repr() string {
 	return fmt.Sprintf(`Extended Statistics:
 	Maximum Path MTU: %v
 	Maximum Send MSS: %v
diff --git a/extendedstats/windows.go b/extendedstats/windows.go
index 5c0fbd9..f38ffbd 100644
--- a/extendedstats/windows.go
+++ b/extendedstats/windows.go
@@ -13,7 +13,7 @@ import (
 	"golang.org/x/sys/windows"
 )
 
-type ExtendedStats struct {
+type AggregateExtendedStats struct {
 	MaxMss                  uint64
 	TotalBytesSent          uint64
 	TotalBytesReceived      uint64
@@ -106,7 +106,7 @@ func ExtendedStatsAvailable() bool {
 	return true
 }
 
-func (es *ExtendedStats) IncorporateConnectionStats(basicConn net.Conn) error {
+func (es *AggregateExtendedStats) IncorporateConnectionStats(basicConn net.Conn) error {
 	if info, err := getTCPInfoRaw(basicConn); err != nil {
 		return fmt.Errorf("OOPS: Could not get the TCP info for the connection: %v", err)
 	} else {
@@ -124,7 +124,7 @@ func (es *ExtendedStats) IncorporateConnectionStats(basicConn net.Conn) error {
 	return nil
 }
 
-func (es *ExtendedStats) Repr() string {
+func (es *AggregateExtendedStats) Repr() string {
 	return fmt.Sprintf(`Extended Statistics:
 	Maximum Segment Size: %v
 	Total Bytes Retransmitted: %v