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

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

Issue 2348623003: Unify rtcp packet setters (Closed)
Patch Set: +call/rtc_event_log_unittest Created 4 years, 3 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 7762e66bf28f7c23e5da2fb9461a007d297c1f8e..859ac0549b7e1cdd888c5c8227cdb1e52bfecc58 100644
--- a/webrtc/modules/rtp_rtcp/source/rtcp_sender.cc
+++ b/webrtc/modules/rtp_rtcp/source/rtcp_sender.cc
@@ -449,14 +449,14 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildSR(const RtcpContext& ctx) {
(ctx.feedback_state_.frequency_hz / 1000);
rtcp::SenderReport* report = new rtcp::SenderReport();
- report->From(ssrc_);
- report->WithNtp(NtpTime(ctx.ntp_sec_, ctx.ntp_frac_));
- report->WithRtpTimestamp(rtp_timestamp);
- report->WithPacketCount(ctx.feedback_state_.packets_sent);
- report->WithOctetCount(ctx.feedback_state_.media_bytes_sent);
+ report->SetSenderSsrc(ssrc_);
+ report->SetNtp(NtpTime(ctx.ntp_sec_, ctx.ntp_frac_));
+ report->SetRtpTimestamp(rtp_timestamp);
+ report->SetPacketCount(ctx.feedback_state_.packets_sent);
+ report->SetOctetCount(ctx.feedback_state_.media_bytes_sent);
for (auto it : report_blocks_)
- report->WithReportBlock(it.second);
+ report->AddReportBlock(it.second);
report_blocks_.clear();
@@ -469,19 +469,19 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildSDES(
RTC_CHECK_LT(length_cname, static_cast<size_t>(RTCP_CNAME_SIZE));
rtcp::Sdes* sdes = new rtcp::Sdes();
- sdes->WithCName(ssrc_, cname_);
+ sdes->AddCName(ssrc_, cname_);
for (const auto it : csrc_cnames_)
- sdes->WithCName(it.first, it.second);
+ sdes->AddCName(it.first, it.second);
return std::unique_ptr<rtcp::RtcpPacket>(sdes);
}
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildRR(const RtcpContext& ctx) {
rtcp::ReceiverReport* report = new rtcp::ReceiverReport();
- report->From(ssrc_);
+ report->SetSenderSsrc(ssrc_);
for (auto it : report_blocks_)
- report->WithReportBlock(it.second);
+ report->AddReportBlock(it.second);
report_blocks_.clear();
return std::unique_ptr<rtcp::RtcpPacket>(report);
@@ -489,8 +489,8 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildRR(const RtcpContext& ctx) {
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildPLI(const RtcpContext& ctx) {
rtcp::Pli* pli = new rtcp::Pli();
- pli->From(ssrc_);
- pli->To(remote_ssrc_);
+ pli->SetSenderSsrc(ssrc_);
+ pli->SetMediaSsrc(remote_ssrc_);
TRACE_EVENT_INSTANT0(TRACE_DISABLED_BY_DEFAULT("webrtc_rtp"),
"RTCPSender::PLI");
@@ -506,8 +506,8 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildFIR(const RtcpContext& ctx) {
++sequence_number_fir_; // Do not increase if repetition.
rtcp::Fir* fir = new rtcp::Fir();
- fir->From(ssrc_);
- fir->WithRequestTo(remote_ssrc_, sequence_number_fir_);
+ fir->SetSenderSsrc(ssrc_);
+ fir->AddRequestTo(remote_ssrc_, sequence_number_fir_);
TRACE_EVENT_INSTANT0(TRACE_DISABLED_BY_DEFAULT("webrtc_rtp"),
"RTCPSender::FIR");
@@ -527,10 +527,10 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildFIR(const RtcpContext& ctx) {
*/
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildSLI(const RtcpContext& ctx) {
rtcp::Sli* sli = new rtcp::Sli();
- sli->From(ssrc_);
- sli->To(remote_ssrc_);
+ sli->SetSenderSsrc(ssrc_);
+ sli->SetMediaSsrc(remote_ssrc_);
// Crop picture id to 6 least significant bits.
- sli->WithPictureId(ctx.picture_id_ & 0x3F);
+ sli->AddPictureId(ctx.picture_id_ & 0x3F);
return std::unique_ptr<rtcp::RtcpPacket>(sli);
}
@@ -553,10 +553,10 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildRPSI(
return nullptr;
rtcp::Rpsi* rpsi = new rtcp::Rpsi();
- rpsi->From(ssrc_);
- rpsi->To(remote_ssrc_);
- rpsi->WithPayloadType(ctx.feedback_state_.send_payload_type);
- rpsi->WithPictureId(ctx.picture_id_);
+ rpsi->SetSenderSsrc(ssrc_);
+ rpsi->SetMediaSsrc(remote_ssrc_);
+ rpsi->SetPayloadType(ctx.feedback_state_.send_payload_type);
+ rpsi->SetPictureId(ctx.picture_id_);
return std::unique_ptr<rtcp::RtcpPacket>(rpsi);
}
@@ -564,10 +564,9 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildRPSI(
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildREMB(
const RtcpContext& ctx) {
rtcp::Remb* remb = new rtcp::Remb();
- remb->From(ssrc_);
- for (uint32_t ssrc : remb_ssrcs_)
- remb->AppliesTo(ssrc);
- remb->WithBitrateBps(remb_bitrate_);
+ remb->SetSenderSsrc(ssrc_);
+ remb->SetBitrateBps(remb_bitrate_);
+ remb->SetSsrcs(remb_ssrcs_);
TRACE_EVENT_INSTANT0(TRACE_DISABLED_BY_DEFAULT("webrtc_rtp"),
"RTCPSender::REMB");
@@ -626,12 +625,12 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildTMMBR(
return nullptr;
rtcp::Tmmbr* tmmbr = new rtcp::Tmmbr();
- tmmbr->From(ssrc_);
+ tmmbr->SetSenderSsrc(ssrc_);
rtcp::TmmbItem request;
request.set_ssrc(remote_ssrc_);
request.set_bitrate_bps(tmmbr_send_bps_);
request.set_packet_overhead(packet_oh_send_);
- tmmbr->WithTmmbr(request);
+ tmmbr->AddTmmbr(request);
return std::unique_ptr<rtcp::RtcpPacket>(tmmbr);
}
@@ -639,10 +638,10 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildTMMBR(
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildTMMBN(
const RtcpContext& ctx) {
rtcp::Tmmbn* tmmbn = new rtcp::Tmmbn();
- tmmbn->From(ssrc_);
+ tmmbn->SetSenderSsrc(ssrc_);
for (const rtcp::TmmbItem& tmmbr : tmmbn_to_send_) {
if (tmmbr.bitrate_bps() > 0) {
- tmmbn->WithTmmbr(tmmbr);
+ tmmbn->AddTmmbr(tmmbr);
}
}
@@ -651,10 +650,10 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildTMMBN(
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildAPP(const RtcpContext& ctx) {
rtcp::App* app = new rtcp::App();
- app->From(ssrc_);
- app->WithSubType(app_sub_type_);
- app->WithName(app_name_);
- app->WithData(app_data_.get(), app_length_);
+ app->SetSsrc(ssrc_);
+ app->SetSubType(app_sub_type_);
+ app->SetName(app_name_);
+ app->SetData(app_data_.get(), app_length_);
return std::unique_ptr<rtcp::RtcpPacket>(app);
}
@@ -662,9 +661,9 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildAPP(const RtcpContext& ctx) {
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildNACK(
const RtcpContext& ctx) {
rtcp::Nack* nack = new rtcp::Nack();
- nack->From(ssrc_);
- nack->To(remote_ssrc_);
- nack->WithList(ctx.nack_list_, ctx.nack_size_);
+ nack->SetSenderSsrc(ssrc_);
+ nack->SetMediaSsrc(remote_ssrc_);
+ nack->SetPacketIds(ctx.nack_list_, ctx.nack_size_);
// Report stats.
NACKStringBuilder stringBuilder;
@@ -687,9 +686,8 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildNACK(
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildBYE(const RtcpContext& ctx) {
rtcp::Bye* bye = new rtcp::Bye();
- bye->From(ssrc_);
- for (uint32_t csrc : csrcs_)
- bye->WithCsrc(csrc);
+ bye->SetSenderSsrc(ssrc_);
+ bye->SetCsrcs(csrcs_);
return std::unique_ptr<rtcp::RtcpPacket>(bye);
}
@@ -698,12 +696,12 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildReceiverReferenceTime(
const RtcpContext& ctx) {
rtcp::ExtendedReports* xr = new rtcp::ExtendedReports();
- xr->From(ssrc_);
+ xr->SetSenderSsrc(ssrc_);
rtcp::Rrtr rrtr;
- rrtr.WithNtp(NtpTime(ctx.ntp_sec_, ctx.ntp_frac_));
+ rrtr.SetNtp(NtpTime(ctx.ntp_sec_, ctx.ntp_frac_));
- xr->WithRrtr(rrtr);
+ xr->AddRrtr(rrtr);
// TODO(sprang): Merge XR report sending to contain all of RRTR, DLRR, VOIP?
@@ -713,13 +711,13 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildReceiverReferenceTime(
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildDlrr(
const RtcpContext& ctx) {
rtcp::ExtendedReports* xr = new rtcp::ExtendedReports();
- xr->From(ssrc_);
+ xr->SetSenderSsrc(ssrc_);
rtcp::Dlrr dlrr;
const RtcpReceiveTimeInfo& info = ctx.feedback_state_.last_xr_rr;
- dlrr.WithDlrrItem(info.sourceSSRC, info.lastRR, info.delaySinceLastRR);
+ dlrr.AddDlrrItem(info.sourceSSRC, info.lastRR, info.delaySinceLastRR);
- xr->WithDlrr(dlrr);
+ xr->AddDlrr(dlrr);
return std::unique_ptr<rtcp::RtcpPacket>(xr);
}
@@ -728,13 +726,13 @@ std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildDlrr(
std::unique_ptr<rtcp::RtcpPacket> RTCPSender::BuildVoIPMetric(
const RtcpContext& context) {
rtcp::ExtendedReports* xr = new rtcp::ExtendedReports();
- xr->From(ssrc_);
+ xr->SetSenderSsrc(ssrc_);
rtcp::VoipMetric voip;
- voip.To(remote_ssrc_);
- voip.WithVoipMetric(xr_voip_metric_);
+ voip.SetMediaSsrc(remote_ssrc_);
+ voip.SetVoipMetric(xr_voip_metric_);
- xr->WithVoipMetric(voip);
+ xr->AddVoipMetric(voip);
return std::unique_ptr<rtcp::RtcpPacket>(xr);
}
@@ -905,16 +903,16 @@ bool RTCPSender::AddReportBlock(const FeedbackState& feedback_state,
}
RTC_DCHECK(report_blocks_.find(ssrc) == report_blocks_.end());
rtcp::ReportBlock* block = &report_blocks_[ssrc];
- block->To(ssrc);
- block->WithFractionLost(stats.fraction_lost);
- if (!block->WithCumulativeLost(stats.cumulative_lost)) {
+ block->SetMediaSsrc(ssrc);
+ block->SetFractionLost(stats.fraction_lost);
+ if (!block->SetCumulativeLost(stats.cumulative_lost)) {
report_blocks_.erase(ssrc);
LOG(LS_WARNING) << "Cumulative lost is oversized.";
return false;
}
- block->WithExtHighestSeqNum(stats.extended_max_sequence_number);
- block->WithJitter(stats.jitter);
- block->WithLastSr(feedback_state.remote_sr);
+ block->SetExtHighestSeqNum(stats.extended_max_sequence_number);
+ block->SetJitter(stats.jitter);
+ block->SetLastSr(feedback_state.remote_sr);
// TODO(sprang): Do we really need separate time stamps for each report?
// Get our NTP as late as possible to avoid a race.
@@ -934,7 +932,7 @@ bool RTCPSender::AddReportBlock(const FeedbackState& feedback_state,
receiveTime <<= 16;
receiveTime += (feedback_state.last_rr_ntp_frac & 0xffff0000) >> 16;
- block->WithDelayLastSr(now - receiveTime);
+ block->SetDelayLastSr(now - receiveTime);
}
return true;
}
« no previous file with comments | « webrtc/modules/rtp_rtcp/source/rtcp_receiver_unittest.cc ('k') | webrtc/modules/rtp_rtcp/source/rtp_rtcp_impl_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698