Chromium Code Reviews| Index: remoting/protocol/connection_to_client.cc |
| diff --git a/remoting/protocol/connection_to_client.cc b/remoting/protocol/connection_to_client.cc |
| index 03ee1fec34bf4da5915c2a05a5a0451352f64e6e..0bf2903e86df40dd9a00822908841f3768165595 100644 |
| --- a/remoting/protocol/connection_to_client.cc |
| +++ b/remoting/protocol/connection_to_client.cc |
| @@ -68,6 +68,11 @@ VideoStub* ConnectionToClient::video_stub() { |
| return video_writer_.get(); |
| } |
| +AudioStub* ConnectionToClient::audio_stub() { |
| + DCHECK(CalledOnValidThread()); |
| + return audio_writer_.get(); |
| +} |
| + |
| // Return pointer to ClientStub. |
| ClientStub* ConnectionToClient::client_stub() { |
| DCHECK(CalledOnValidThread()); |
| @@ -120,6 +125,10 @@ void ConnectionToClient::OnSessionStateChange(Session::State state) { |
| video_writer_->Init(session_.get(), base::Bind( |
| &ConnectionToClient::OnChannelInitialized, base::Unretained(this))); |
| + audio_writer_ = AudioWriter::Create(session_->config()); |
| + audio_writer_->Init(session_.get(), base::Bind( |
| + &ConnectionToClient::OnChannelInitialized, base::Unretained(this))); |
| + |
| // Notify the handler after initializing the channels, so that |
| // ClientSession can get a client clipboard stub. |
| handler_->OnConnectionAuthenticated(this); |
| @@ -158,7 +167,8 @@ void ConnectionToClient::NotifyIfChannelsReady() { |
| if (control_dispatcher_.get() && control_dispatcher_->is_connected() && |
| event_dispatcher_.get() && event_dispatcher_->is_connected() && |
| - video_writer_.get() && video_writer_->is_connected()) { |
| + video_writer_.get() && video_writer_->is_connected() && |
| + audio_writer_.get() && audio_writer_->is_connected()) { |
|
Wez
2012/06/19 03:29:31
This assumes that the remote party also wants an a
kxing
2012/06/20 22:30:06
Done.
|
| handler_->OnConnectionChannelsConnected(this); |
| } |
| } |
| @@ -172,6 +182,7 @@ void ConnectionToClient::CloseChannels() { |
| control_dispatcher_.reset(); |
| event_dispatcher_.reset(); |
| video_writer_.reset(); |
| + audio_writer_.reset(); |
| } |
| } // namespace protocol |