third_party/blink/public/web/modules/peerconnection/webrtc_stats_report_obtainer.h

// Copyright (c) 2017 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#ifndef THIRD_PARTY_BLINK_PUBLIC_WEB_MODULES_PEERCONNECTION_WEBRTC_STATS_REPORT_OBTAINER_H_
#define THIRD_PARTY_BLINK_PUBLIC_WEB_MODULES_PEERCONNECTION_WEBRTC_STATS_REPORT_OBTAINER_H_

#include <memory>

#include "base/memory/ref_counted.h"
#include "base/run_loop.h"
#include "third_party/blink/public/platform/web_rtc_stats.h"

namespace blink {

// The obtainer is a test-only helper class capable of waiting for a GetStats()
// callback to be called. It takes ownership of and exposes the resulting
// blink::WebRTCStatsReport.
// While WaitForReport() is waiting for the report, tasks posted on the current
// thread are executed (see base::RunLoop::Run()) making it safe to wait on the
// same thread that the stats report callback occurs on without blocking the
// callback.
//
// TODO(crbug.com/787254): Move this class out of the Blink API
// when all its clients get Onion souped.
class WebRTCStatsReportObtainer
    : public base::RefCountedThreadSafe<WebRTCStatsReportObtainer> {
 public:
  WebRTCStatsReportObtainer();

  blink::WebRTCStatsReportCallback GetStatsCallbackWrapper();

  blink::WebRTCStatsReport* report() const;
  blink::WebRTCStatsReport* WaitForReport();

 private:
  friend class base::RefCountedThreadSafe<WebRTCStatsReportObtainer>;
  friend class CallbackWrapper;
  virtual ~WebRTCStatsReportObtainer();

  void OnStatsDelivered(std::unique_ptr<blink::WebRTCStatsReport> report);

  base::RunLoop run_loop_;
  std::unique_ptr<blink::WebRTCStatsReport> report_;
};

}  // namespace blink

#endif  // THIRD_PARTY_BLINK_PUBLIC_WEB_MODULES_PEERCONNECTION_WEBRTC_STATS_REPORT_OBTAINER_H_