tor-browser

The Tor Browser
git clone https://git.dasho.dev/tor-browser.git
Log | Files | Refs | README | LICENSE

transport_feedback_demuxer.h (2274B)

      1 /*
      2 *  Copyright (c) 2019 The WebRTC project authors. All Rights Reserved.
      3 *
      4 *  Use of this source code is governed by a BSD-style license
      5 *  that can be found in the LICENSE file in the root of the source
      6 *  tree. An additional intellectual property rights grant can be found
      7 *  in the file PATENTS.  All contributing project authors may
      8 *  be found in the AUTHORS file in the root of the source tree.
      9 */
     10 #ifndef MODULES_CONGESTION_CONTROLLER_RTP_TRANSPORT_FEEDBACK_DEMUXER_H_
     11 #define MODULES_CONGESTION_CONTROLLER_RTP_TRANSPORT_FEEDBACK_DEMUXER_H_
     12 
     13 #include <cstdint>
     14 #include <utility>
     15 #include <vector>
     16 
     17 #include "api/sequence_checker.h"
     18 #include "api/transport/network_types.h"
     19 #include "modules/rtp_rtcp/include/rtp_rtcp_defines.h"
     20 #include "rtc_base/system/no_unique_address.h"
     21 #include "rtc_base/thread_annotations.h"
     22 
     23 namespace webrtc {
     24 
     25 // Implementation of StreamFeedbackProvider that provides a way for
     26 // implementations of StreamFeedbackObserver to register for feedback callbacks
     27 // for a given set of SSRCs.
     28 // Registration methods need to be called from the same execution context
     29 // (thread or task queue) and callbacks to
     30 // StreamFeedbackObserver::OnPacketFeedbackVector will be made in that same
     31 // context.
     32 // TODO(tommi): This appears to be the only implementation of this interface.
     33 // Do we need the interface?
     34 class TransportFeedbackDemuxer final : public StreamFeedbackProvider {
     35 public:
     36  TransportFeedbackDemuxer();
     37 
     38  // Implements StreamFeedbackProvider interface
     39  void RegisterStreamFeedbackObserver(
     40      std::vector<uint32_t> ssrcs,
     41      StreamFeedbackObserver* observer) override;
     42  void DeRegisterStreamFeedbackObserver(
     43      StreamFeedbackObserver* observer) override;
     44  void OnTransportFeedback(const TransportPacketsFeedback& feedback);
     45 
     46 private:
     47  RTC_NO_UNIQUE_ADDRESS SequenceChecker observer_checker_;
     48  // Maps a set of ssrcs to corresponding observer. Vectors are used rather than
     49  // set/map to ensure that the processing order is consistent independently of
     50  // the randomized ssrcs.
     51  std::vector<std::pair<std::vector<uint32_t>, StreamFeedbackObserver*>>
     52      observers_ RTC_GUARDED_BY(&observer_checker_);
     53 };
     54 }  // namespace webrtc
     55 
     56 #endif  // MODULES_CONGESTION_CONTROLLER_RTP_TRANSPORT_FEEDBACK_DEMUXER_H_