summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--experiments.h9
-rw-r--r--video_engine/include/vie_network.h7
-rw-r--r--video_engine/vie_channel_group.cc54
-rw-r--r--video_engine/vie_channel_group.h1
-rw-r--r--video_engine/vie_channel_manager.cc11
-rw-r--r--video_engine/vie_channel_manager.h4
-rw-r--r--video_engine/vie_network_impl.cc9
-rw-r--r--video_engine/vie_network_impl.h5
8 files changed, 87 insertions, 13 deletions
diff --git a/experiments.h b/experiments.h
index 4b5661b4..b03d248c 100644
--- a/experiments.h
+++ b/experiments.h
@@ -39,5 +39,14 @@ struct SkipEncodingUnusedStreams {
const bool enabled;
};
+
+struct AimdRemoteRateControl {
+ AimdRemoteRateControl() : enabled(false) {}
+ explicit AimdRemoteRateControl(bool set_enabled)
+ : enabled(set_enabled) {}
+ virtual ~AimdRemoteRateControl() {}
+
+ const bool enabled;
+};
} // namespace webrtc
#endif // WEBRTC_EXPERIMENTS_H_
diff --git a/video_engine/include/vie_network.h b/video_engine/include/vie_network.h
index 0f2a10c6..bb368182 100644
--- a/video_engine/include/vie_network.h
+++ b/video_engine/include/vie_network.h
@@ -86,6 +86,13 @@ class WEBRTC_DLLEXPORT ViENetwork {
return 0;
}
+ // TODO(holmer): Remove the default implementation when this has been fixed
+ // in fakewebrtcvideoengine.cc.
+ virtual bool SetBandwidthEstimationConfig(int video_channel,
+ const webrtc::Config& config) {
+ return false;
+ }
+
protected:
ViENetwork() {}
virtual ~ViENetwork() {}
diff --git a/video_engine/vie_channel_group.cc b/video_engine/vie_channel_group.cc
index f4055e46..9ce52a22 100644
--- a/video_engine/vie_channel_group.cc
+++ b/video_engine/vie_channel_group.cc
@@ -17,6 +17,7 @@
#include "webrtc/modules/rtp_rtcp/interface/rtp_rtcp.h"
#include "webrtc/modules/utility/interface/process_thread.h"
#include "webrtc/system_wrappers/interface/critical_section_wrapper.h"
+#include "webrtc/system_wrappers/interface/thread_annotations.h"
#include "webrtc/system_wrappers/interface/trace.h"
#include "webrtc/video_engine/call_stats.h"
#include "webrtc/video_engine/encoder_state_feedback.h"
@@ -40,8 +41,10 @@ class WrappingBitrateEstimator : public RemoteBitrateEstimator {
crit_sect_(CriticalSectionWrapper::CreateCriticalSection()),
engine_id_(engine_id),
min_bitrate_bps_(config.Get<RemoteBitrateEstimatorMinRate>().min_rate),
- rbe_(RemoteBitrateEstimatorFactory().Create(observer_, clock_,
- kMimdControl,
+ rate_control_type_(kMimdControl),
+ rbe_(RemoteBitrateEstimatorFactory().Create(observer_,
+ clock_,
+ rate_control_type_,
min_bitrate_bps_)),
using_absolute_send_time_(false),
packets_since_absolute_send_time_(0) {
@@ -56,7 +59,7 @@ class WrappingBitrateEstimator : public RemoteBitrateEstimator {
int payload_size,
const RTPHeader& header) {
CriticalSectionScoped cs(crit_sect_.get());
- PickEstimator(header);
+ PickEstimatorFromHeader(header);
rbe_->IncomingPacket(arrival_time_ms, payload_size, header);
}
@@ -91,19 +94,27 @@ class WrappingBitrateEstimator : public RemoteBitrateEstimator {
return rbe_->GetStats(output);
}
+ void SetConfig(const webrtc::Config& config) {
+ CriticalSectionScoped cs(crit_sect_.get());
+ RateControlType new_control_type =
+ config.Get<AimdRemoteRateControl>().enabled ? kAimdControl :
+ kMimdControl;
+ if (new_control_type != rate_control_type_) {
+ rate_control_type_ = new_control_type;
+ PickEstimator();
+ }
+ }
+
private:
- // Instantiate RBE for Time Offset or Absolute Send Time extensions.
- void PickEstimator(const RTPHeader& header) {
+ void PickEstimatorFromHeader(const RTPHeader& header)
+ EXCLUSIVE_LOCKS_REQUIRED(crit_sect_.get()) {
if (header.extension.hasAbsoluteSendTime) {
// If we see AST in header, switch RBE strategy immediately.
if (!using_absolute_send_time_) {
- process_thread_->DeRegisterModule(rbe_.get());
WEBRTC_TRACE(kTraceStateInfo, kTraceVideo, ViEId(engine_id_),
"WrappingBitrateEstimator: Switching to absolute send time RBE.");
- rbe_.reset(AbsoluteSendTimeRemoteBitrateEstimatorFactory().Create(
- observer_, clock_, kMimdControl, min_bitrate_bps_));
- process_thread_->RegisterModule(rbe_.get());
using_absolute_send_time_ = true;
+ PickEstimator();
}
packets_since_absolute_send_time_ = 0;
} else {
@@ -111,25 +122,36 @@ class WrappingBitrateEstimator : public RemoteBitrateEstimator {
if (using_absolute_send_time_) {
++packets_since_absolute_send_time_;
if (packets_since_absolute_send_time_ >= kTimeOffsetSwitchThreshold) {
- process_thread_->DeRegisterModule(rbe_.get());
WEBRTC_TRACE(kTraceStateInfo, kTraceVideo, ViEId(engine_id_),
"WrappingBitrateEstimator: Switching to transmission time offset "
"RBE.");
- rbe_.reset(RemoteBitrateEstimatorFactory().Create(observer_, clock_,
- kMimdControl, min_bitrate_bps_));
- process_thread_->RegisterModule(rbe_.get());
using_absolute_send_time_ = false;
+ PickEstimator();
}
}
}
}
+ // Instantiate RBE for Time Offset or Absolute Send Time extensions.
+ void PickEstimator() EXCLUSIVE_LOCKS_REQUIRED(crit_sect_.get()) {
+ process_thread_->DeRegisterModule(rbe_.get());
+ if (using_absolute_send_time_) {
+ rbe_.reset(AbsoluteSendTimeRemoteBitrateEstimatorFactory().Create(
+ observer_, clock_, rate_control_type_, min_bitrate_bps_));
+ } else {
+ rbe_.reset(RemoteBitrateEstimatorFactory().Create(
+ observer_, clock_, rate_control_type_, min_bitrate_bps_));
+ }
+ process_thread_->RegisterModule(rbe_.get());
+ }
+
RemoteBitrateObserver* observer_;
Clock* clock_;
ProcessThread* process_thread_;
scoped_ptr<CriticalSectionWrapper> crit_sect_;
const int engine_id_;
const uint32_t min_bitrate_bps_;
+ RateControlType rate_control_type_;
scoped_ptr<RemoteBitrateEstimator> rbe_;
bool using_absolute_send_time_;
uint32_t packets_since_absolute_send_time_;
@@ -224,4 +246,10 @@ bool ChannelGroup::SetChannelRembStatus(int channel_id, bool sender,
}
return true;
}
+
+void ChannelGroup::SetBandwidthEstimationConfig(const webrtc::Config& config) {
+ WrappingBitrateEstimator* estimator =
+ static_cast<WrappingBitrateEstimator*>(remote_bitrate_estimator_.get());
+ estimator->SetConfig(config);
+}
} // namespace webrtc
diff --git a/video_engine/vie_channel_group.h b/video_engine/vie_channel_group.h
index 036967f2..40ce71ef 100644
--- a/video_engine/vie_channel_group.h
+++ b/video_engine/vie_channel_group.h
@@ -42,6 +42,7 @@ class ChannelGroup {
bool SetChannelRembStatus(int channel_id, bool sender, bool receiver,
ViEChannel* channel);
+ void SetBandwidthEstimationConfig(const webrtc::Config& config);
BitrateController* GetBitrateController();
CallStats* GetCallStats();
diff --git a/video_engine/vie_channel_manager.cc b/video_engine/vie_channel_manager.cc
index 37e46928..746cb258 100644
--- a/video_engine/vie_channel_manager.cc
+++ b/video_engine/vie_channel_manager.cc
@@ -389,6 +389,17 @@ void ViEChannelManager::UpdateSsrcs(int channel_id,
}
}
+bool ViEChannelManager::SetBandwidthEstimationConfig(
+ int channel_id, const webrtc::Config& config) {
+ CriticalSectionScoped cs(channel_id_critsect_);
+ ChannelGroup* group = FindGroup(channel_id);
+ if (!group) {
+ return false;
+ }
+ group->SetBandwidthEstimationConfig(config);
+ return true;
+}
+
bool ViEChannelManager::CreateChannelObject(
int channel_id,
ViEEncoder* vie_encoder,
diff --git a/video_engine/vie_channel_manager.h b/video_engine/vie_channel_manager.h
index 83250980..a979ab60 100644
--- a/video_engine/vie_channel_manager.h
+++ b/video_engine/vie_channel_manager.h
@@ -79,6 +79,10 @@ class ViEChannelManager: private ViEManagerBase {
// it will simply be ignored and no error is returned.
void UpdateSsrcs(int channel_id, const std::list<unsigned int>& ssrcs);
+ // Sets bandwidth estimation related configurations.
+ bool SetBandwidthEstimationConfig(int channel_id,
+ const webrtc::Config& config);
+
private:
// Creates a channel object connected to |vie_encoder|. Assumed to be called
// protected.
diff --git a/video_engine/vie_network_impl.cc b/video_engine/vie_network_impl.cc
index 8c3e1eb0..2b80159f 100644
--- a/video_engine/vie_network_impl.cc
+++ b/video_engine/vie_network_impl.cc
@@ -217,4 +217,13 @@ int ViENetworkImpl::ReceivedBWEPacket(const int video_channel,
vie_channel->ReceivedBWEPacket(arrival_time_ms, payload_size, header);
return 0;
}
+
+bool ViENetworkImpl::SetBandwidthEstimationConfig(
+ int video_channel, const webrtc::Config& config) {
+ WEBRTC_TRACE(kTraceApiCall, kTraceVideo,
+ ViEId(shared_data_->instance_id(), video_channel),
+ "%s(channel: %d)", __FUNCTION__, video_channel);
+ return shared_data_->channel_manager()->SetBandwidthEstimationConfig(
+ video_channel, config);
+}
} // namespace webrtc
diff --git a/video_engine/vie_network_impl.h b/video_engine/vie_network_impl.h
index 26d8a9f8..03547d88 100644
--- a/video_engine/vie_network_impl.h
+++ b/video_engine/vie_network_impl.h
@@ -38,8 +38,13 @@ class ViENetworkImpl
const void* data,
const int length);
virtual int SetMTU(int video_channel, unsigned int mtu);
+
virtual int ReceivedBWEPacket(const int video_channel,
int64_t arrival_time_ms, int payload_size, const RTPHeader& header);
+
+ virtual bool SetBandwidthEstimationConfig(int video_channel,
+ const webrtc::Config& config);
+
protected:
explicit ViENetworkImpl(ViESharedData* shared_data);
virtual ~ViENetworkImpl();
generated by cgit v1.2.3 (git 2.25.1) at 2024-07-26 10:35:51 +0000