123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 |
- #ifndef TEST_PC_E2E_STATS_POLLER_H_
- #define TEST_PC_E2E_STATS_POLLER_H_
- #include <map>
- #include <string>
- #include <utility>
- #include <vector>
- #include "api/peer_connection_interface.h"
- #include "api/stats/rtc_stats_collector_callback.h"
- #include "api/test/stats_observer_interface.h"
- #include "test/pc/e2e/test_peer.h"
- namespace webrtc {
- namespace webrtc_pc_e2e {
- class InternalStatsObserver : public RTCStatsCollectorCallback {
- public:
- InternalStatsObserver(std::string pc_label,
- TestPeer* peer,
- std::vector<StatsObserverInterface*> observers)
- : pc_label_(std::move(pc_label)),
- peer_(peer),
- observers_(std::move(observers)) {}
- void PollStats();
- void OnStatsDelivered(
- const rtc::scoped_refptr<const RTCStatsReport>& report) override;
- private:
- std::string pc_label_;
- TestPeer* peer_;
- std::vector<StatsObserverInterface*> observers_;
- };
- class StatsPoller {
- public:
- StatsPoller(std::vector<StatsObserverInterface*> observers,
- std::map<std::string, TestPeer*> peers_to_observe);
- void PollStatsAndNotifyObservers();
- private:
- std::vector<rtc::scoped_refptr<InternalStatsObserver>> pollers_;
- };
- }
- }
- #endif
|