1 files changed, 13 insertions, 0 deletions
diff --git a/call/rtp_demuxer.cc b/call/rtp_demuxer.cc
index 0b74f2ac0a..841d7e3b94 100644
--- a/call/rtp_demuxer.cc
+++ b/call/rtp_demuxer.cc
@@ -255,6 +255,19 @@ bool RtpDemuxer::RemoveSink(const RtpPacketSinkInterface* sink) {
   return num_removed > 0;
 }
 
+flat_set<uint32_t> RtpDemuxer::GetSsrcsForSink(
+    const RtpPacketSinkInterface* sink) const {
+  flat_set<uint32_t> ssrcs;
+  if (sink) {
+    for (const auto& it : sink_by_ssrc_) {
+      if (it.second == sink) {
+        ssrcs.insert(it.first);
+      }
+    }
+  }
+  return ssrcs;
+}
+
 bool RtpDemuxer::OnRtpPacket(const RtpPacketReceived& packet) {
   RtpPacketSinkInterface* sink = ResolveSink(packet);
   if (sink != nullptr) {