Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(244)

Unified Diff: webrtc/modules/rtp_rtcp/source/rtcp_sender.cc

Issue 1474693002: [Splitting] TMMBRHelp class simplifted (and disappear because become too simple) (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Created 4 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: webrtc/modules/rtp_rtcp/source/rtcp_sender.cc
diff --git a/webrtc/modules/rtp_rtcp/source/rtcp_sender.cc b/webrtc/modules/rtp_rtcp/source/rtcp_sender.cc
index 4a509b001ea0db5d438268b6011a163096f6abee..a206510fb4cd9d7ddb1b23e2f1b4cf420929b068 100644
--- a/webrtc/modules/rtp_rtcp/source/rtcp_sender.cc
+++ b/webrtc/modules/rtp_rtcp/source/rtcp_sender.cc
@@ -169,9 +169,6 @@ RTCPSender::RTCPSender(
remb_bitrate_(0),
- tmmbr_help_(),
- tmmbr_send_(0),
- packet_oh_send_(0),
max_payload_length_(IP_PACKET_SIZE - 28), // IPv4 + UDP by default.
app_sub_type_(0),
@@ -573,7 +570,7 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildREMB(
void RTCPSender::SetTargetBitrate(unsigned int target_bitrate) {
rtc::CritScope lock(&critical_section_rtcp_sender_);
- tmmbr_send_ = target_bitrate / 1000;
+ tmmbr_to_send_.set_bitrate_bps(target_bitrate);
}
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildTMMBR(
@@ -588,18 +585,18 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildTMMBR(
// get current bounding set from RTCP receiver
bool tmmbrOwner = false;
// store in candidateSet, allocates one extra slot
- TMMBRSet* candidateSet = tmmbr_help_.CandidateSet();
+ std::vector<rtcp::TmmbItem> candidates;
// holding critical_section_rtcp_sender_ while calling RTCPreceiver which
// will accuire criticalSectionRTCPReceiver_ is a potental deadlock but
// since RTCPreceiver is not doing the reverse we should be fine
int32_t lengthOfBoundingSet =
- ctx.feedback_state_.module->BoundingSet(&tmmbrOwner, candidateSet);
+ ctx.feedback_state_.module->BoundingSet(&tmmbrOwner, &candidates);
if (lengthOfBoundingSet > 0) {
for (int32_t i = 0; i < lengthOfBoundingSet; i++) {
- if (candidateSet->Tmmbr(i) == tmmbr_send_ &&
- candidateSet->PacketOH(i) == packet_oh_send_) {
+ if (candidates[i].bitrate_bps() == tmmbr_to_send_.bitrate_bps() &&
+ candidates[i].packet_overhead() == tmmbr_to_send_.packet_overhead()) {
// Do not send the same tuple.
return nullptr;
}
@@ -607,15 +604,17 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildTMMBR(
if (!tmmbrOwner) {
// use received bounding set as candidate set
// add current tuple
- candidateSet->SetEntry(lengthOfBoundingSet, tmmbr_send_, packet_oh_send_,
- ssrc_);
- int numCandidates = lengthOfBoundingSet + 1;
+ tmmbr_to_send_.set_ssrc(ssrc_);
+ candidates.push_back(tmmbr_to_send_);
// find bounding set
- TMMBRSet* boundingSet = nullptr;
- int numBoundingSet = tmmbr_help_.FindTMMBRBoundingSet(boundingSet);
- if (numBoundingSet > 0 || numBoundingSet <= numCandidates)
- tmmbrOwner = tmmbr_help_.IsOwner(ssrc_, numBoundingSet);
+ FindTMMBRBoundingSet(&candidates);
+ for (const rtcp::TmmbItem& entry : candidates) {
+ if (entry.ssrc() == ssrc_) {
+ tmmbrOwner = true;
+ break;
+ }
+ }
if (!tmmbrOwner) {
// Did not enter bounding set, no meaning to send this request.
return nullptr;
@@ -623,16 +622,13 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildTMMBR(
}
}
- if (!tmmbr_send_)
+ if (tmmbr_to_send_.bitrate_bps() == 0)
return nullptr;
rtcp::Tmmbr* tmmbr = new rtcp::Tmmbr();
tmmbr->From(ssrc_);
- rtcp::TmmbItem request;
- request.set_ssrc(remote_ssrc_);
- request.set_bitrate_bps(tmmbr_send_ * 1000);
- request.set_packet_overhead(packet_oh_send_);
- tmmbr->WithTmmbr(request);
+ tmmbr_to_send_.set_ssrc(remote_ssrc_);
+ tmmbr->WithTmmbr(tmmbr_to_send_);
return std::unique_ptr<rtcp::RtcpPacket>(tmmbr);
}
@@ -641,9 +637,9 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildTMMBN(
const RtcpContext& ctx) {
rtcp::Tmmbn* tmmbn = new rtcp::Tmmbn();
tmmbn->From(ssrc_);
- for (const rtcp::TmmbItem& tmmbr : tmmbn_to_send_) {
- if (tmmbr.bitrate_bps() > 0) {
- tmmbn->WithTmmbr(tmmbr);
+ for (const rtcp::TmmbItem& item : tmmbn_to_send_) {
+ if (item.bitrate_bps() > 0) {
+ tmmbn->WithTmmbr(item);
}
}
« no previous file with comments | « webrtc/modules/rtp_rtcp/source/rtcp_sender.h ('k') | webrtc/modules/rtp_rtcp/source/rtcp_sender_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698