VPLAY-12213: ABR Refactoring part 3 - encapsulate remaining abr logic inside abr.cpp

Reason for change: To encapsulate all ABR related logic inside abr.cpp and abr.h.
This will help in future to add/remove different bandwidth estimation algorithms without
affecting other parts of the code.
Risks: Low
Test Procedure: Test with Linear and VOD
Priority: P1

Signed-off-by: Nandakishor U M <nu641001@gmail.com>

Author: nu641001

AampConfig.cpp

@@ -31,6 +31,7 @@
 #include "PlayerRfc.h"
 #include "PlayerExternalsInterface.h"
 #include "PlayerSecInterface.h"
+#include "abr.h"
 #include <time.h>
 #include <map>
 //////////////// CAUTION !!!! STOP !!! Read this before you proceed !!!!!!! /////////////
@@ -84,6 +85,7 @@ typedef enum
 	eCONFIG_RANGE_MONITOR_AVSYNC_THRESHOLD_POSITIVE, //1ms to 10000ms
 	eCONFIG_RANGE_MONITOR_AVSYNC_THRESHOLD_NEGATIVE, //-1 to -10000ms
 	eCONFIG_RANGE_MONITOR_AVSYNC_JUMP_THRESHOLD,//1ms to 10000
+	eCONFIG_RANGE_ABR_BANDWIDTH_ESTIMATOR, // BandwidthEstimatorType enum range
 	eCONFIG_RANGE_MAX_VALUE,
 } ConfigValidRange;
 #define CONFIG_RANGE_ENUM_COUNT (eCONFIG_RANGE_MAX_VALUE)
@@ -127,6 +129,7 @@ static const struct
 	{ MIN_MONITOR_AVSYNC_POSITIVE_DELTA_MS, MAX_MONITOR_AVSYNC_POSITIVE_DELTA_MS, eCONFIG_RANGE_MONITOR_AVSYNC_THRESHOLD_POSITIVE},
 	{ MIN_MONITOR_AVSYNC_NEGATIVE_DELTA_MS, MAX_MONITOR_AVSYNC_NEGATIVE_DELTA_MS, eCONFIG_RANGE_MONITOR_AVSYNC_THRESHOLD_NEGATIVE},
 	{ MIN_MONITOR_AV_JUMP_THRESHOLD_MS, MAX_MONITOR_AV_JUMP_THRESHOLD_MS, eCONFIG_RANGE_MONITOR_AVSYNC_JUMP_THRESHOLD},
+	{ BANDWIDTH_ESTIMATOR_TYPE_ROLLING_MEDIAN_OUTLIER, BANDWIDTH_ESTIMATOR_TYPE_MAX, eCONFIG_RANGE_ABR_BANDWIDTH_ESTIMATOR},
 };
 
 static ConfigPriority customOwner;
@@ -470,7 +473,7 @@ static const ConfigLookupEntryInt mConfigLookupTableInt[AAMPCONFIG_INT_COUNT+CON
 	{DEFAULT_PROGRESS_LOGGING_DIVISOR,"progressLoggingDivisor",eAAMPConfig_ProgressLoggingDivisor,false},
 	{DEFAULT_MONITOR_AV_REPORTING_INTERVAL, "monitorAVReportingInterval", eAAMPConfig_MonitorAVReportingInterval, false},
 	{DEFAULT_UTC_SYNC_MIN_INTERVAL_SEC,"utcSyncMinIntervalSec",eAAMPConfig_UTCSyncMinIntervalSec,true },
-
+	{BANDWIDTH_ESTIMATOR_TYPE_ROLLING_MEDIAN_OUTLIER, "abrBandwidthEstimator", eAAMPConfig_ABRBandwidthEstimator, false, eCONFIG_RANGE_ABR_BANDWIDTH_ESTIMATOR},
 	// Add new integer config entries above this line, before the aliases section.
 	//
 	// Aliases, kept for backwards compatibility

AampConfig.h

@@ -313,6 +313,7 @@ typedef enum
 	eAAMPConfig_ProgressLoggingDivisor,				/**<  Divisor to avoid printing the progress report too frequently in the log */
 	eAAMPConfig_MonitorAVReportingInterval,			/**< Timeout in milliseconds for reporting MonitorAV events */
 	eAAMPConfig_UTCSyncMinIntervalSec,				/**< Minimum interval between sync attempts */
+	eAAMPConfig_ABRBandwidthEstimator,				/**< Select ABR bandwidth estimator */
 	eAAMPConfig_IntMaxValue							/**< Max value of int config always last element*/
 } AAMPConfigSettingInt;
 #define AAMPCONFIG_INT_COUNT (eAAMPConfig_IntMaxValue)

AampDefine.h

@@ -361,5 +361,12 @@ enum EOSInjectionModeCode
 	EOS_INJECTION_MODE_STOP_ONLY,
 };
 
+enum BandwidthEstimatorType
+{
+	BANDWIDTH_ESTIMATOR_TYPE_ROLLING_MEDIAN_OUTLIER,
+	BANDWIDTH_ESTIMATOR_TYPE_HARMONIC_EWMA,
+	BANDWIDTH_ESTIMATOR_TYPE_MAX
+};
+
 #endif
 

CMakeLists.txt

@@ -389,7 +389,9 @@ set(LIBAAMP_SOURCES
 	AampCMCDCollector.cpp AampCMCDCollector.h
 	downloader/AampCurlDownloader.cpp downloader/AampCurlDownloader.h
 	ID3Metadata.cpp ID3Metadata.hpp
-	abr/abr.cpp abr/abr.h abr/NetworkBandwidthEstimator.cpp abr/NetworkBandwidthEstimator.h
+	abr/abr.cpp abr/abr.h
+	abr/RMOBandwidthEstimator.cpp abr/RMOBandwidthEstimator.h
+	abr/HarmonicEWMAEstimator.cpp abr/HarmonicEWMAEstimator.h
 	dash/xml/DomDocument.cpp
 	dash/xml/DomElement.cpp
 	dash/xml/DomNode.cpp
@@ -586,6 +588,9 @@ install(FILES
 	LangCodePreference.h StreamOutputFormat.h VideoZoomMode.h StreamSink.h TimedMetadata.h
 	AampDemuxDataTypes.h
 	abr/abr.h
+	abr/RMOBandwidthEstimator.h
+	abr/HarmonicEWMAEstimator.h
+	abr/BandwidthEstimatorBase.h
 	DESTINATION include
 )
 

abr/BandwidthEstimatorBase.h

@@ -0,0 +1,153 @@
+/*
+ * If not stated otherwise in this file or this component's license file the
+ * following copyright and licenses apply:
+ *
+ * Copyright 2026 RDK Management
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef AAMP_ABR_BANDWIDTH_ESTIMATOR_BASE_H
+#define AAMP_ABR_BANDWIDTH_ESTIMATOR_BASE_H
+
+#include <cstddef>
+
+#include "AampMediaType.h"
+
+/**
+ * @brief Plain Old Data (POD) structure for profiling information from a
+ * given CURL instance.
+ */
+struct DownloadMetrics
+{
+	std::size_t m_size_download_bytes; // CURLINFO_SIZE_DOWNLOAD
+	double m_total_time_seconds; // CURLINFO_TOTAL_TIME
+	double m_time_to_first_byte_seconds; // CURLINFO_STARTTRANSFER_TIME
+};
+
+/**
+ * @brief POD structure for in-flight progress updates (xferinfo-style).
+ */
+struct DownloadProgressInfo
+{
+	double m_now_seconds;
+	std::size_t m_total_bytes;
+	std::size_t m_now_bytes;
+};
+
+/**
+ * @brief Optional configuration for bandwidth estimators.
+ *
+ * Not all estimators use every field. Estimators that do not support
+ * configuration should ignore it.
+ */
+struct BandwidthEstimatorConfig
+{
+	int mAbrCacheLife;
+	int mAbrCacheLength;
+	int mAbrCacheOutlier;
+	std::size_t mLowLatencyCacheLength;
+
+	BandwidthEstimatorConfig()
+		: mAbrCacheLife(0),
+		  mAbrCacheLength(0),
+		  mAbrCacheOutlier(0),
+		  mLowLatencyCacheLength(0)
+	{
+	}
+
+	BandwidthEstimatorConfig(
+		int abrCacheLife,
+		int abrCacheLength,
+		int abrCacheOutlier,
+		std::size_t lowLatencyCacheLength)
+		: mAbrCacheLife(abrCacheLife),
+		  mAbrCacheLength(abrCacheLength),
+		  mAbrCacheOutlier(abrCacheOutlier),
+		  mLowLatencyCacheLength(lowLatencyCacheLength)
+	{
+	}
+};
+
+/**
+ * @brief Base interface for bandwidth estimation algorithms.
+ */
+class BandwidthEstimatorBase
+{
+public:
+	virtual ~BandwidthEstimatorBase() {}
+
+	/**
+	 * @brief Human-readable algorithm name.
+	 */
+	virtual const char* GetNetworkEstimatorName() const = 0;
+
+	/**
+	 * @brief Reset all internal state.
+	 */
+	virtual void Reset() = 0;
+
+	/**
+	 * @brief Add a bandwidth sample (bits per second).
+	 */
+	virtual void AddBandwidthSample(
+		BitsPerSecond downloadbps, bool lowLatencyMode) = 0;
+
+	/**
+	 * @brief Add download metrics derived from curl (optional).
+	 */
+	virtual void UpdateDownloadMetrics( const DownloadMetrics &metrics ) = 0;
+
+	/**
+	 * @brief Provide in-flight download progress updates (optional).
+	 */
+	virtual void UpdateDownloadProgress(
+		const DownloadProgressInfo &progressInfo)
+	{
+		(void)progressInfo;
+	}
+
+	/**
+	 * @brief Update estimator configuration (optional).
+	 *
+	 * Default implementation is a no-op.
+	 */
+	virtual void SetConfig(const BandwidthEstimatorConfig &config)
+	{
+		(void)config;
+	}
+
+	/**
+	 * @brief Return current bandwidth estimate (bits per second).
+	 *
+	 * @return Estimated bandwidth in bits per second, or -1 if unavailable.
+	 */
+	virtual BitsPerSecond GetBandwidthBitsPerSecond() = 0;
+
+	/**
+	 * @brief Return current robust throughput estimate (bytes/s).
+	 */
+	virtual double GetThroughputBytesPerSecond() = 0;
+
+	/**
+	 * @brief Return current overhead (TTFB) estimate (seconds).
+	 */
+	virtual double GetTimeToFirstByteSeconds() = 0;
+
+	/**
+	 * @brief Predict completion time for a new segment.
+	 */
+	virtual double GetPredictedDownloadTimeSeconds(
+		std::size_t segment_size_bytes) = 0;
+};
+
+#endif