From aa2ce22655574d2babe324af67ff4e0f63f44b72 Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Sat, 16 Nov 2024 10:14:37 +0530 Subject: [PATCH] Stringer interface (#3181) --- pkg/sfu/bwe/remotebwe/channel_observer.go | 4 ++-- pkg/sfu/bwe/remotebwe/nack_tracker.go | 4 ++-- pkg/sfu/bwe/remotebwe/remote_bwe.go | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/pkg/sfu/bwe/remotebwe/channel_observer.go b/pkg/sfu/bwe/remotebwe/channel_observer.go index 50f01a25f..adf4daba2 100644 --- a/pkg/sfu/bwe/remotebwe/channel_observer.go +++ b/pkg/sfu/bwe/remotebwe/channel_observer.go @@ -154,11 +154,11 @@ func (c *channelObserver) GetTrend() (bwe.ChannelTrend, channelCongestionReason) switch { case estimateDirection == ccutils.TrendDirectionDownward: - c.logger.Debugw("stream allocator: channel observer: estimate is trending downward", "channel", c) + c.logger.Debugw("remote bwe: channel observer: estimate is trending downward", "channel", c) return bwe.ChannelTrendCongesting, channelCongestionReasonEstimate case c.nackTracker.IsTriggered(): - c.logger.Debugw("stream allocator: channel observer: high rate of repeated NACKs", "channel", c) + c.logger.Debugw("remote bwe: channel observer: high rate of repeated NACKs", "channel", c) return bwe.ChannelTrendCongesting, channelCongestionReasonLoss case estimateDirection == ccutils.TrendDirectionUpward: diff --git a/pkg/sfu/bwe/remotebwe/nack_tracker.go b/pkg/sfu/bwe/remotebwe/nack_tracker.go index 750788e0b..c536ad7e3 100644 --- a/pkg/sfu/bwe/remotebwe/nack_tracker.go +++ b/pkg/sfu/bwe/remotebwe/nack_tracker.go @@ -116,7 +116,7 @@ func (n *nackTracker) IsTriggered() bool { return false } -func (n *nackTracker) ToString() string { +func (n *nackTracker) String() string { window := "" if !n.windowStartTime.IsZero() { now := time.Now() @@ -136,7 +136,7 @@ func (n *nackTracker) updateHistory() { n.history = n.history[1:] } - n.history = append(n.history, n.ToString()) + n.history = append(n.history, n.String()) } */ diff --git a/pkg/sfu/bwe/remotebwe/remote_bwe.go b/pkg/sfu/bwe/remotebwe/remote_bwe.go index 0edfdaffe..e47dec4ad 100644 --- a/pkg/sfu/bwe/remotebwe/remote_bwe.go +++ b/pkg/sfu/bwe/remotebwe/remote_bwe.go @@ -263,7 +263,7 @@ func (r *RemoteBWE) ProbingStart(expectedBandwidthUsage int64) { r.lastExpectedBandwidthUsage = expectedBandwidthUsage r.params.Logger.Debugw( - "stream allocator: starting probe", + "remote bwe: starting probe", "lastReceived", r.lastReceivedEstimate, "expectedBandwidthUsage", expectedBandwidthUsage, "channel", r.channelObserver,