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 |