VPAAMP-28: Merge MonitorLatency and RateCorrectionWorkerThread

Reason for change: Merged the new flow
Test Procedure: Refer jira ticket VPAAMP-28
Priority: P2

Signed-off-by: srikanthreddybijjam-comcast <srikanthreddybijjam.2000@gmail.com>

Author: srikanthreddybijjam-comcast

AampConfig.cpp

@@ -457,7 +457,6 @@ static const ConfigLookupEntryInt mConfigLookupTableInt[AAMPCONFIG_INT_COUNT+CON
 	{0,"timeBasedBufferSeconds",eAAMPConfig_TimeBasedBufferSeconds,true,eCONFIG_RANGE_PLAYBACK_OFFSET},
 	{DEFAULT_MAX_DOWNLOAD_BUFFER,"maxDownloadBuffer",eAAMPConfig_MaxDownloadBuffer,true,eCONFIG_RANGE_PLAYBACK_OFFSET},
 	{DEFAULT_TELEMETRY_REPORT_INTERVAL,"telemetryInterval",eAAMPConfig_TelemetryInterval,true},
-	{0,"rateCorrectionDelay", eAAMPConfig_RateCorrectionDelay,true},
 	{-1,"harvestDuration",eAAMPConfig_HarvestDuration,false,eCONFIG_RANGE_HARVEST_DURATION},
 	{DEFAULT_SUBTITLE_CLOCK_SYNC_INTERVAL_S,"subtitleClockSyncInterval",eAAMPConfig_SubtitleClockSyncInterval,true},
 	{eABSOLUTE_PROGRESS_WITHOUT_AVAILABILITY_START,"preferredAbsoluteReporting",eAAMPConfig_PreferredAbsoluteProgressReporting,true, eCONFIG_RANGE_ABSOLUTE_REPORTING},

AampConfig.h

@@ -308,7 +308,6 @@ typedef enum
 	eAAMPConfig_TimeBasedBufferSeconds,
 	eAAMPConfig_MaxDownloadBuffer,					/**< Max download buffer in seconds, this can be used to limit player download job scheduling for DASH*/
 	eAAMPConfig_TelemetryInterval,						/**< time interval for the telemetry reporting*/
-	eAAMPConfig_RateCorrectionDelay,			/**< Delay Rate Correction upon discontinuity in seconds */
 	eAAMPConfig_HarvestDuration,						/**< Harvest  duration time */
 	eAAMPConfig_SubtitleClockSyncInterval,			/**< time interval for synchronizing subtitle clock */
 	eAAMPConfig_PreferredAbsoluteProgressReporting, /**< Preferred settings for absolute progress reporting**/

AampLatencyMonitor.cpp

@@ -196,7 +196,12 @@ void AampLatencyMonitor::EnableRateCorrection(bool enabled)
 	}
 
 	mCorrectionEnabled.store(enabled);
-	// Wake the worker so it can immediately reset the rate if needed.
+	if (!enabled)
+	{
+		// Synchronously reset the pipeline rate to normal so mCurrentRate stays in sync
+		// with the GStreamer seek that follows (e.g. FlushTrack), before the worker wakes.
+		ResetToNormalRate();
+	}
 	{
 		std::lock_guard<std::mutex> lock(mSleepMutex);
 		mWakeupSignalled = true;

AampLatencyMonitor.h

@@ -185,6 +185,12 @@ class AampLatencyMonitor
 	 */
 	void EnableRateCorrection(bool enabled);
 
+	/**
+	 * @brief Returns true if rate correction is currently enabled.
+	 * Thread-safe (atomic load).
+	 */
+	bool IsRateCorrectionEnabled() const { return mCorrectionEnabled.load(); }
+
 	/**
 	 * @brief Returns the playback rate most recently applied by this monitor.
 	 *

aampgstplayer.cpp

@@ -950,12 +950,6 @@ void AAMPGstPlayer::FlushTrack(AampMediaType type,double pos)
 	double audioDelta = aamp->mAudioDelta;
 	double subDelta = aamp->mSubtitleDelta;
 	double rate = playerInstance->FlushTrack(mediaType, pos, audioDelta, subDelta);
-
-	if(aamp->mCorrectionRate != rate)
-	{
-		AAMPLOG_MIL("Reset Rate Correction to 1");
-		aamp->mCorrectionRate = rate;
-	}
 }
 
 /**
@@ -1076,8 +1070,6 @@ void AAMPGstPlayer::Flush(double position, int rate, bool shouldTearDown)
 			//reset buffer control states prior to gstreamer flush so that the first needs_data event is caught
 			privateContext->mBufferControl[i].flush();
 		}
-
-		aamp->mCorrectionRate = (double)AAMP_NORMAL_PLAY_RATE;
 	}
 }
 

fragmentcollector_hls.cpp

@@ -4023,7 +4023,8 @@ AAMPStatusType StreamAbstractionAAMP_HLS::Init(TuneType tuneType)
 			video->playTarget = 0;
 			subtitle->playTarget = 0;
 			aamp->NotifyOnEnteringLive();
-			aamp->mDisableRateCorrection = false;
+			// Re-enable latency rate correction after seeking to live edge.
+			aamp->EnableLatencyMonitor(true);
 		}
 		else if (((eTUNETYPE_SEEK == tuneType) || (eTUNETYPE_RETUNE == tuneType) || (eTUNETYPE_NEW_SEEK == tuneType)) && (this->rate > 0))
 		{
@@ -4049,7 +4050,8 @@ AAMPStatusType StreamAbstractionAAMP_HLS::Init(TuneType tuneType)
 						aamp->NotifyOnEnteringLive();
 					}
 					AAMPLOG_INFO("StreamAbstractionAAMP_HLS: Live latency correction is enabled due to the seek (rate=%f) to live window!!", this->rate);
-					aamp->mDisableRateCorrection = false;
+					// Re-enable latency rate correction; StartLatencyMonitor() is protected.
+					aamp->EnableLatencyMonitor(true);
 				}
 				else
 				{
@@ -7020,7 +7022,7 @@ void StreamAbstractionAAMP_HLS::RefreshTrack(AampMediaType type)
 		}
 		track->AbortWaitForCachedAndFreeFragment(true);
 		aamp->StopTrackInjection(type);
-		aamp->mDisableRateCorrection = true;
+		aamp->EnableLatencyMonitor(false);
 		if(aamp->IsLive() && !track->seamlessAudioSwitchInProgress)
 		{
 			// Abort ongoing wait for playlist refresh, so the track change can be processed immediately.

fragmentcollector_mpd.cpp

@@ -3659,7 +3659,7 @@ AAMPStatusType StreamAbstractionAAMP_MPD::Init(TuneType tuneType)
 						notifyEnteringLive = true;
 					}
 					AAMPLOG_INFO("StreamAbstractionAAMP_MPD: Live latency correction is enabled due to the seek (rate=%f) to live window!!", currentRate);
-					aamp->mDisableRateCorrection = false;
+					aamp->EnableLatencyMonitor(true);
 				}
 
 				if (mLowLatencyMode && !liveAdjust)
@@ -6495,7 +6495,7 @@ void StreamAbstractionAAMP_MPD::RefreshTrack(AampMediaType type)
 		}
 		track->AbortWaitForCachedAndFreeFragment(true);
 		aamp->StopTrackInjection(type);
-		aamp->mDisableRateCorrection = true;
+		aamp->EnableLatencyMonitor(false);
 	}
 }
 

main_aamp.cpp

@@ -949,14 +949,8 @@ void PlayerInstanceAAMP::SetRateInternal(float rate,int overshootcorrection)
 					}
 					aamp->mSinkPaused = true;
 
-					if(aamp->GetLLDashServiceData()->lowLatencyMode)
-					{
-						// PAUSED to PLAY without tune, LLD rate correction is disabled to keep position
-						AAMPLOG_INFO("LL-Dash speed correction disabled after Pause");
-						aamp->EnableLatencyMonitor(false);
-					}
-					AAMPLOG_INFO("StreamAbstractionAAMP_MPD: Live latency correction is disabled due to the Pause operation!!");
-					aamp->mDisableRateCorrection = true;
+					AAMPLOG_INFO("Latency correction is disabled due to the Pause operation!!");
+					aamp->EnableLatencyMonitor(false);
 				}
 			}
 			else