Index: media/cast/cast_sender_impl.cc |
diff --git a/media/cast/cast_sender_impl.cc b/media/cast/cast_sender_impl.cc |
index 83048d7c9c55e6fc30e518dbf4e5af1a34e23312..b47ae9c30220e13096a290fd600a50a55ee34848 100644 |
--- a/media/cast/cast_sender_impl.cc |
+++ b/media/cast/cast_sender_impl.cc |
@@ -107,7 +107,7 @@ CastSenderImpl::CastSenderImpl( |
void CastSenderImpl::InitializeAudio( |
const AudioSenderConfig& audio_config, |
- const CastInitializationCallback& cast_initialization_cb) { |
+ const StatusChangeCallback& status_change_cb) { |
DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
CHECK(audio_config.use_external_encoder || |
cast_environment_->HasAudioThread()); |
@@ -115,14 +115,12 @@ void CastSenderImpl::InitializeAudio( |
VLOG(1) << "CastSenderImpl@" << this << "::InitializeAudio()"; |
audio_sender_.reset( |
- new AudioSender(cast_environment_, audio_config, transport_sender_)); |
- |
- const CastInitializationStatus status = audio_sender_->InitializationResult(); |
- if (status == STATUS_AUDIO_INITIALIZED) { |
- audio_frame_input_ = |
- new LocalAudioFrameInput(cast_environment_, audio_sender_->AsWeakPtr()); |
- } |
- cast_initialization_cb.Run(status); |
+ new AudioSender(cast_environment_, |
+ audio_config, |
+ base::Bind(&CastSenderImpl::OnAudioStatusChange, |
+ weak_factory_.GetWeakPtr(), |
+ status_change_cb), |
+ transport_sender_)); |
if (video_sender_) { |
DCHECK(audio_sender_->GetTargetPlayoutDelay() == |
video_sender_->GetTargetPlayoutDelay()); |
@@ -131,7 +129,7 @@ void CastSenderImpl::InitializeAudio( |
void CastSenderImpl::InitializeVideo( |
const VideoSenderConfig& video_config, |
- const CastInitializationCallback& cast_initialization_cb, |
+ const StatusChangeCallback& status_change_cb, |
const CreateVideoEncodeAcceleratorCallback& create_vea_cb, |
const CreateVideoEncodeMemoryCallback& create_video_encode_mem_cb) { |
DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
@@ -141,8 +139,9 @@ void CastSenderImpl::InitializeVideo( |
video_sender_.reset(new VideoSender( |
cast_environment_, |
video_config, |
- base::Bind(&CastSenderImpl::OnVideoInitialized, |
- weak_factory_.GetWeakPtr(), cast_initialization_cb), |
+ base::Bind(&CastSenderImpl::OnVideoStatusChange, |
+ weak_factory_.GetWeakPtr(), |
+ status_change_cb), |
create_vea_cb, |
create_video_encode_mem_cb, |
transport_sender_, |
@@ -178,16 +177,27 @@ void CastSenderImpl::SetTargetPlayoutDelay( |
} |
} |
-void CastSenderImpl::OnVideoInitialized( |
- const CastInitializationCallback& initialization_cb, |
- media::cast::CastInitializationStatus result) { |
+void CastSenderImpl::OnAudioStatusChange( |
+ const StatusChangeCallback& status_change_cb, |
+ OperationalStatus status) { |
+ DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
+ if (status == STATUS_INITIALIZED && !audio_frame_input_) { |
+ audio_frame_input_ = |
+ new LocalAudioFrameInput(cast_environment_, audio_sender_->AsWeakPtr()); |
+ } |
+ status_change_cb.Run(status); |
+} |
+ |
+void CastSenderImpl::OnVideoStatusChange( |
+ const StatusChangeCallback& status_change_cb, |
+ OperationalStatus status) { |
DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
- if (result == STATUS_VIDEO_INITIALIZED) { |
+ if (status == STATUS_INITIALIZED && !video_frame_input_) { |
video_frame_input_ = |
new LocalVideoFrameInput(cast_environment_, video_sender_->AsWeakPtr(), |
video_sender_->CreateVideoFrameFactory()); |
} |
- initialization_cb.Run(result); |
+ status_change_cb.Run(status); |
} |
} // namespace cast |