chore: fix a large number of spelling issues (#4147)

Signed-off-by: changgesi <changgesi@outlook.com>

pkg/rtc/participant.go

@@ -2290,7 +2290,7 @@ func (p *ParticipantImpl) onReceivedDataMessage(kind livekit.DataPacket_Kind, da
 				return
 
 			case MigrationDataCacheStateDone:
-				// see the continous message, drop the cache
+				// see the continuous message, drop the cache
 				p.reliableDataInfo.migrateInPubDataCache.Store(nil)
 			}
 		}
@@ -3130,7 +3130,7 @@ func (p *ParticipantImpl) mediaTrackReceived(track sfu.TrackRemote, rtpReceiver
 
 		// if the addTrackRequest is sent before participant active then it means the client tries to publish
 		// before fully connected, in this case we only record the time when the participant is active since
-		// we want this metric to represent the time cost by pubilshing.
+		// we want this metric to represent the time cost by publishing.
 		if activeAt := p.lastActiveAt.Load(); activeAt != nil && createdAt.Before(*activeAt) {
 			createdAt = *activeAt
 		}

pkg/rtc/room.go

@@ -681,7 +681,7 @@ func (r *Room) onSyncState(participant types.LocalParticipant, state *livekit.Sy
 	}
 
 	// synthesize a track setting for each disabled track,
-	// can be set before addding subscriptions,
+	// can be set before adding subscriptions,
 	// in fact it is done before so that setting can be updated immediately upon subscription.
 	for _, trackSid := range state.TrackSidsDisabled {
 		participant.UpdateSubscribedTrackSettings(livekit.TrackID(trackSid), &livekit.UpdateTrackSettings{Disabled: true})

pkg/rtc/subscribedtrack.go

@@ -352,7 +352,7 @@ func (t *SubscribedTrack) applySettings() {
 
 	t.settingsLock.Lock()
 	if settingsVersion != t.settingsVersion {
-		// a newer settings has superceded this one
+		// a newer settings has superseded this one
 		t.settingsLock.Unlock()
 		return
 	}

pkg/rtc/subscriptionmanager.go

@@ -539,7 +539,7 @@ func (m *SubscriptionManager) reconcileSubscription(s *mediaTrackSubscription) {
 		// and the clean up path to handle removing subscription from the subscription map.
 		// It is possible that the track is re-published before subscribed track is closed.
 		// That could create a new subscription and a duplicate entry in SDP.
-		// Waiting for susbcribed track close would ensure that the track is removed from
+		// Waiting for subscribed track close would ensure that the track is removed from
 		// the peer connection before re-published track is re-subscribed and added back to the SDP.
 		return
 	}

pkg/rtc/transport.go

@@ -235,7 +235,7 @@ type PCTransport struct {
 	// transceivers (senders) waiting for SetRemoteDescription (offer) to happen before
 	// SetCodecPreferences can be invoked on them.
 	// Pion adapts codecs/payload types from remote description.
-	// If SetCodecPreferences are done before the remote desctiption is processed,
+	// If SetCodecPreferences are done before the remote description is processed,
 	// it is possible that the transceiver gets payload types from media engine.
 	// Subssequently if the peer sends an offer with different payload type for the
 	// same codec, there could be two payload types for the same codec and the wrong

pkg/rtc/wrappedreceiver.go

@@ -93,7 +93,7 @@ func (r *WrappedReceiver) StreamID() string {
 // isAvailable: returns true if given codec is a potential codec from publisher or if an existing published codec can be translated
 // needsPublish: indicates if the codec is needed from publisher, some combinations can be achieved via codec translation internally,
 //
-//	example: unecrypted opus -> RED translation and vice-versa can be done without the need for publisher to send the other codec.
+//	example: unencrypted opus -> RED translation and vice-versa can be done without the need for publisher to send the other codec.
 func (r *WrappedReceiver) DetermineReceiver(codec webrtc.RTPCodecCapability) (isAvailable bool, needsPublish bool) {
 	r.lock.Lock()
 

pkg/service/ingress.go

@@ -217,7 +217,7 @@ func (s *IngressService) LaunchPullIngress(ctx context.Context, info *livekit.In
 }
 
 func updateEnableTranscoding(info *livekit.IngressInfo) {
-	// Set BypassTranscoding as well for backward compatiblity
+	// Set BypassTranscoding as well for backward compatibility
 	if info.EnableTranscoding != nil {
 		info.BypassTranscoding = !*info.EnableTranscoding
 		return

pkg/service/roomallocator.go

@@ -208,7 +208,7 @@ func (r *StandardRoomAllocator) applyNamedRoomConfiguration(req *livekit.CreateR
 
 	conf, ok := r.config.Room.RoomConfigurations[req.RoomPreset]
 	if !ok {
-		return req, psrpc.NewErrorf(psrpc.InvalidArgument, "unknown room confguration in create room request")
+		return req, psrpc.NewErrorf(psrpc.InvalidArgument, "unknown room configuration in create room request")
 	}
 
 	clone := utils.CloneProto(req)

pkg/sfu/buffer/helpers.go

@@ -430,7 +430,7 @@ func IsH265KeyFrame(payload []byte) (kf bool) {
 	case naluType == 48: // AP
 		idx := 2
 		for idx < len(payload)-2 {
-			// TODO: check the DONL field (controled by sprop-max-don-diff)
+			// TODO: check the DONL field (controlled by sprop-max-don-diff)
 			size := binary.BigEndian.Uint16(payload[idx:])
 			idx += 2
 			if idx >= len(payload) {

pkg/sfu/bwe/sendsidebwe/congestion_detector.go

@@ -674,7 +674,7 @@ func (c *congestionDetector) HandleTWCCFeedback(report *rtcp.TransportLayerCC) {
 		}
 	}
 
-	// 1. go through the TWCC feedback report and record recive time as reported by remote
+	// 1. go through the TWCC feedback report and record receive time as reported by remote
 	// 2. process acknowledged packet and group them
 	//
 	// losses are not recorded if a feedback report is completely lost.
@@ -1149,7 +1149,7 @@ func (c *congestionDetector) updateCongestionState(state bwe.CongestionState) (b
 	// when in congested state, monitor changes in captured traffic ratio (CTR)
 	// to ensure allocations are in line with latest estimates, it is possible that
 	// the estimate is incorrect when congestion starts and the allocation may be
-	// sub-optimal and not enough to reduce/relieve congestion, by monitoing CTR
+	// sub-optimal and not enough to reduce/relieve congestion, by monitoring CTR
 	// on a continuous basis allocations can be adjusted in the direction of
 	// reducing/relieving congestion
 	if state == bwe.CongestionStateCongested && fromState != bwe.CongestionStateCongested {

pkg/sfu/forwarder.go

@@ -701,7 +701,7 @@ func (f *Forwarder) SetRefSenderReport(layer int32, srData *livekit.RTCPSenderRe
 		//
 		// It could happen like this
 		//   1. Normal operation: publisher sending sender reports and
-		//      suscribers use reports from publisher to calculate and send
+		//      subscribers use reports from publisher to calculate and send
 		//      RTCP sender report.
 		//   2. Publisher pauses: there are no more reports.
 		//   3. When paused, subscriber can still use the publisher side sender

pkg/sfu/rtpstats/rtpstats_receiver.go

@@ -224,7 +224,7 @@ func (r *RTPStatsReceiver) Update(
 		//  Very old time stamp, happens under the following conditions
 		//  - resume after long mute, big time stamp jump
 		//  - an out of order packet from before the mute arrives (unsure what causes this
-		//    very old packet to be trasmitted from remote), causing time stamp to jump back
+		//    very old packet to be transmitted from remote), causing time stamp to jump back
 		//    to before mute, but it appears like it has rolled over.
 		//  Use a threshold against expected to ignore these.
 		if gapSN < 0 && gapTS > 0 {

pkg/sfu/rtpstats/rtpstats_sender.go

@@ -645,7 +645,7 @@ func (r *RTPStatsSender) UpdateFromReceiverReport(rr rtcp.ReceptionReport) (rtt
 		// should not roll over for long time, for e. g. it will approximately take 100 days at 500 pps).
 		// So, there seems to be a remote reporter issue where the sequence number rollover is missed.
 		//
-		// catch up till diffrence between highest sent and highest received via receiver report is
+		// catch up till difference between highest sent and highest received via receiver report is
 		// less than full 16-bit range.
 		//
 		// in a different flavor, there are clients that do not report properly,

pkg/sfu/videolayerselector/framenumberwrapper_test.go

@@ -65,7 +65,7 @@ func TestFrameNumberWrapper(t *testing.T) {
 		// frame out of order
 		firstF = secondF
 		secondF = getFrame(firstF, false)
-		// it is possile that an out of order non-keyframe has been converted to in order frame number if the diff is 32768
+		// it is possible that an out of order non-keyframe has been converted to in order frame number if the diff is 32768
 		// that is ok because the client can't decode in such case and always need to wait for the key frame.
 		// so it is just a failure of test case and increase the frame number here.
 		if secondF-firstF == 0x8000 {