| 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/protocol/libjingle_transport_factory.h" | 5 #include "remoting/protocol/libjingle_transport_factory.h" |
| 6 | 6 |
| 7 #include "base/message_loop_proxy.h" | 7 #include "base/message_loop_proxy.h" |
| 8 #include "jingle/glue/channel_socket_adapter.h" | 8 #include "jingle/glue/channel_socket_adapter.h" |
| 9 #include "jingle/glue/pseudotcp_adapter.h" | 9 #include "jingle/glue/pseudotcp_adapter.h" |
| 10 #include "jingle/glue/utils.h" | 10 #include "jingle/glue/utils.h" |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 43 const TransportConfig& config, | 43 const TransportConfig& config, |
| 44 Transport::EventHandler* event_handler, | 44 Transport::EventHandler* event_handler, |
| 45 scoped_ptr<ChannelAuthenticator> authenticator) OVERRIDE; | 45 scoped_ptr<ChannelAuthenticator> authenticator) OVERRIDE; |
| 46 virtual void Connect( | 46 virtual void Connect( |
| 47 const StreamTransport::ConnectedCallback& callback) OVERRIDE; | 47 const StreamTransport::ConnectedCallback& callback) OVERRIDE; |
| 48 virtual void AddRemoteCandidate(const cricket::Candidate& candidate) OVERRIDE; | 48 virtual void AddRemoteCandidate(const cricket::Candidate& candidate) OVERRIDE; |
| 49 virtual const std::string& name() const OVERRIDE; | 49 virtual const std::string& name() const OVERRIDE; |
| 50 virtual bool is_connected() const OVERRIDE; | 50 virtual bool is_connected() const OVERRIDE; |
| 51 | 51 |
| 52 private: | 52 private: |
| 53 void OnRequestSignaling(); | 53 void OnRequestSignaling(cricket::TransportChannelImpl* channel); |
| 54 void OnCandidateReady(cricket::TransportChannelImpl* channel, | 54 void OnCandidateReady(cricket::TransportChannelImpl* channel, |
| 55 const cricket::Candidate& candidate); | 55 const cricket::Candidate& candidate); |
| 56 void OnRouteChange(cricket::TransportChannel* channel, | 56 void OnRouteChange(cricket::TransportChannel* channel, |
| 57 const cricket::Candidate& candidate); | 57 const cricket::Candidate& candidate); |
| 58 | 58 |
| 59 void OnTcpConnected(int result); | 59 void OnTcpConnected(int result); |
| 60 void OnAuthenticationDone(net::Error error, | 60 void OnAuthenticationDone(net::Error error, |
| 61 scoped_ptr<net::StreamSocket> socket); | 61 scoped_ptr<net::StreamSocket> socket); |
| 62 | 62 |
| 63 void OnChannelDestroyed(); | 63 void OnChannelDestroyed(); |
| (...skipping 136 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 200 const std::string& LibjingleStreamTransport::name() const { | 200 const std::string& LibjingleStreamTransport::name() const { |
| 201 DCHECK(CalledOnValidThread()); | 201 DCHECK(CalledOnValidThread()); |
| 202 return name_; | 202 return name_; |
| 203 } | 203 } |
| 204 | 204 |
| 205 bool LibjingleStreamTransport::is_connected() const { | 205 bool LibjingleStreamTransport::is_connected() const { |
| 206 DCHECK(CalledOnValidThread()); | 206 DCHECK(CalledOnValidThread()); |
| 207 return callback_.is_null(); | 207 return callback_.is_null(); |
| 208 } | 208 } |
| 209 | 209 |
| 210 void LibjingleStreamTransport::OnRequestSignaling() { | 210 void LibjingleStreamTransport::OnRequestSignaling( |
| 211 cricket::TransportChannelImpl* channel) { |
| 211 DCHECK(CalledOnValidThread()); | 212 DCHECK(CalledOnValidThread()); |
| 212 channel_->OnSignalingReady(); | 213 channel_->OnSignalingReady(); |
| 213 } | 214 } |
| 214 | 215 |
| 215 void LibjingleStreamTransport::OnCandidateReady( | 216 void LibjingleStreamTransport::OnCandidateReady( |
| 216 cricket::TransportChannelImpl* channel, | 217 cricket::TransportChannelImpl* channel, |
| 217 const cricket::Candidate& candidate) { | 218 const cricket::Candidate& candidate) { |
| 218 DCHECK(CalledOnValidThread()); | 219 DCHECK(CalledOnValidThread()); |
| 219 event_handler_->OnTransportCandidate(this, candidate); | 220 event_handler_->OnTransportCandidate(this, candidate); |
| 220 } | 221 } |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 337 | 338 |
| 338 scoped_ptr<DatagramTransport> | 339 scoped_ptr<DatagramTransport> |
| 339 LibjingleTransportFactory::CreateDatagramTransport() { | 340 LibjingleTransportFactory::CreateDatagramTransport() { |
| 340 NOTIMPLEMENTED(); | 341 NOTIMPLEMENTED(); |
| 341 return scoped_ptr<DatagramTransport>(NULL); | 342 return scoped_ptr<DatagramTransport>(NULL); |
| 342 } | 343 } |
| 343 | 344 |
| 344 | 345 |
| 345 } // namespace protocol | 346 } // namespace protocol |
| 346 } // namespace remoting | 347 } // namespace remoting |
| OLD | NEW |