Commit d0f55a27 authored by Nicolás Peña Moreno's avatar Nicolás Peña Moreno Committed by Commit Bot

Convert CastRtpStream::ErrorCallback to base::RepeatingCallback

Bug: 1007641
Change-Id: I9b02fb01862b99d5f8fbf7bc0bf3fd75bf659c0d
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/2105755Reviewed-by: default avatarKaran Bhatia <karandeepb@chromium.org>
Reviewed-by: default avatarmark a. foltz <mfoltz@chromium.org>
Reviewed-by: default avatardanakj <danakj@chromium.org>
Commit-Queue: Nicolás Peña Moreno <npm@chromium.org>
Cr-Commit-Position: refs/heads/master@{#760963}
parent 9b52edeb
...@@ -590,9 +590,8 @@ void CastStreamingNativeHandler::StartCastRtpStream( ...@@ -590,9 +590,8 @@ void CastStreamingNativeHandler::StartCastRtpStream(
base::BindOnce(&CastStreamingNativeHandler::CallStopCallback, base::BindOnce(&CastStreamingNativeHandler::CallStopCallback,
weak_factory_.GetWeakPtr(), transport_id); weak_factory_.GetWeakPtr(), transport_id);
CastRtpStream::ErrorCallback error_callback = CastRtpStream::ErrorCallback error_callback =
base::Bind(&CastStreamingNativeHandler::CallErrorCallback, base::BindRepeating(&CastStreamingNativeHandler::CallErrorCallback,
weak_factory_.GetWeakPtr(), weak_factory_.GetWeakPtr(), transport_id);
transport_id);
// |transport_id| is a globally unique identifier for the RTP stream. // |transport_id| is a globally unique identifier for the RTP stream.
transport->Start(transport_id, config, std::move(start_callback), transport->Start(transport_id, config, std::move(start_callback),
......
...@@ -170,9 +170,9 @@ class CastVideoSink : public base::SupportsWeakPtr<CastVideoSink>, ...@@ -170,9 +170,9 @@ class CastVideoSink : public base::SupportsWeakPtr<CastVideoSink>,
// |track| provides data for this sink. // |track| provides data for this sink.
// |error_callback| is called if video formats don't match. // |error_callback| is called if video formats don't match.
CastVideoSink(const blink::WebMediaStreamTrack& track, CastVideoSink(const blink::WebMediaStreamTrack& track,
const CastRtpStream::ErrorCallback& error_callback) CastRtpStream::ErrorCallback error_callback)
: track_(track), : track_(track),
deliverer_(new Deliverer(error_callback)), deliverer_(base::MakeRefCounted<Deliverer>(std::move(error_callback))),
consecutive_refresh_count_(0), consecutive_refresh_count_(0),
expecting_a_refresh_frame_(false), expecting_a_refresh_frame_(false),
is_connected_to_track_(false) {} is_connected_to_track_(false) {}
...@@ -203,9 +203,9 @@ class CastVideoSink : public base::SupportsWeakPtr<CastVideoSink>, ...@@ -203,9 +203,9 @@ class CastVideoSink : public base::SupportsWeakPtr<CastVideoSink>,
private: private:
class Deliverer : public base::RefCountedThreadSafe<Deliverer> { class Deliverer : public base::RefCountedThreadSafe<Deliverer> {
public: public:
explicit Deliverer(const CastRtpStream::ErrorCallback& error_callback) explicit Deliverer(CastRtpStream::ErrorCallback error_callback)
: main_task_runner_(base::ThreadTaskRunnerHandle::Get()), : main_task_runner_(base::ThreadTaskRunnerHandle::Get()),
error_callback_(error_callback) {} error_callback_(std::move(error_callback)) {}
void WillConnectToTrack( void WillConnectToTrack(
base::WeakPtr<CastVideoSink> sink, base::WeakPtr<CastVideoSink> sink,
...@@ -495,14 +495,14 @@ void CastRtpStream::Start(int32_t stream_id, ...@@ -495,14 +495,14 @@ void CastRtpStream::Start(int32_t stream_id,
const FrameSenderConfig& config, const FrameSenderConfig& config,
base::OnceClosure start_callback, base::OnceClosure start_callback,
base::OnceClosure stop_callback, base::OnceClosure stop_callback,
const ErrorCallback& error_callback) { ErrorCallback error_callback) {
DCHECK(!start_callback.is_null()); DCHECK(!start_callback.is_null());
DCHECK(!stop_callback.is_null()); DCHECK(!stop_callback.is_null());
DCHECK(!error_callback.is_null()); DCHECK(!error_callback.is_null());
DVLOG(1) << "CastRtpStream::Start = " << (is_audio_ ? "audio" : "video"); DVLOG(1) << "CastRtpStream::Start = " << (is_audio_ ? "audio" : "video");
stop_callback_ = std::move(stop_callback); stop_callback_ = std::move(stop_callback);
error_callback_ = error_callback; error_callback_ = std::move(error_callback);
if (track_.IsNull()) { if (track_.IsNull()) {
cast_session_->StartRemotingStream( cast_session_->StartRemotingStream(
......
...@@ -33,7 +33,7 @@ class CastVideoSink; ...@@ -33,7 +33,7 @@ class CastVideoSink;
// stream. // stream.
class CastRtpStream { class CastRtpStream {
public: public:
typedef base::Callback<void(const std::string&)> ErrorCallback; using ErrorCallback = base::RepeatingCallback<void(const std::string&)>;
static bool IsHardwareVP8EncodingSupported(); static bool IsHardwareVP8EncodingSupported();
...@@ -57,7 +57,7 @@ class CastRtpStream { ...@@ -57,7 +57,7 @@ class CastRtpStream {
const media::cast::FrameSenderConfig& config, const media::cast::FrameSenderConfig& config,
base::OnceClosure start_callback, base::OnceClosure start_callback,
base::OnceClosure stop_callback, base::OnceClosure stop_callback,
const ErrorCallback& error_callback); ErrorCallback error_callback);
// Stop encoding. // Stop encoding.
void Stop(); void Stop();
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment