| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "remoting/host/client_session.h" | 5 #include "remoting/host/client_session.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/message_loop/message_loop_proxy.h" | 9 #include "base/message_loop/message_loop_proxy.h" |
| 10 #include "remoting/base/capabilities.h" | 10 #include "remoting/base/capabilities.h" |
| (...skipping 406 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 417 event_handler_->OnSessionClosed(this); | 417 event_handler_->OnSessionClosed(this); |
| 418 } | 418 } |
| 419 | 419 |
| 420 void ClientSession::OnSequenceNumberUpdated( | 420 void ClientSession::OnSequenceNumberUpdated( |
| 421 protocol::ConnectionToClient* connection, int64 sequence_number) { | 421 protocol::ConnectionToClient* connection, int64 sequence_number) { |
| 422 DCHECK(CalledOnValidThread()); | 422 DCHECK(CalledOnValidThread()); |
| 423 DCHECK_EQ(connection_.get(), connection); | 423 DCHECK_EQ(connection_.get(), connection); |
| 424 | 424 |
| 425 if (video_scheduler_.get()) | 425 if (video_scheduler_.get()) |
| 426 video_scheduler_->UpdateSequenceNumber(sequence_number); | 426 video_scheduler_->UpdateSequenceNumber(sequence_number); |
| 427 | |
| 428 event_handler_->OnSessionSequenceNumber(this, sequence_number); | |
| 429 } | 427 } |
| 430 | 428 |
| 431 void ClientSession::OnRouteChange( | 429 void ClientSession::OnRouteChange( |
| 432 protocol::ConnectionToClient* connection, | 430 protocol::ConnectionToClient* connection, |
| 433 const std::string& channel_name, | 431 const std::string& channel_name, |
| 434 const protocol::TransportRoute& route) { | 432 const protocol::TransportRoute& route) { |
| 435 DCHECK(CalledOnValidThread()); | 433 DCHECK(CalledOnValidThread()); |
| 436 DCHECK_EQ(connection_.get(), connection); | 434 DCHECK_EQ(connection_.get(), connection); |
| 437 event_handler_->OnSessionRouteChange(this, channel_name, route); | 435 event_handler_->OnSessionRouteChange(this, channel_name, route); |
| 438 } | 436 } |
| (...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 506 return scoped_ptr<AudioEncoder>(new AudioEncoderVerbatim()); | 504 return scoped_ptr<AudioEncoder>(new AudioEncoderVerbatim()); |
| 507 } else if (audio_config.codec == protocol::ChannelConfig::CODEC_OPUS) { | 505 } else if (audio_config.codec == protocol::ChannelConfig::CODEC_OPUS) { |
| 508 return scoped_ptr<AudioEncoder>(new AudioEncoderOpus()); | 506 return scoped_ptr<AudioEncoder>(new AudioEncoderOpus()); |
| 509 } | 507 } |
| 510 | 508 |
| 511 NOTREACHED(); | 509 NOTREACHED(); |
| 512 return scoped_ptr<AudioEncoder>(); | 510 return scoped_ptr<AudioEncoder>(); |
| 513 } | 511 } |
| 514 | 512 |
| 515 } // namespace remoting | 513 } // namespace remoting |
| OLD | NEW |