| 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/pepper_transport_factory.h" | 5 #include "remoting/protocol/pepper_transport_factory.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "crypto/hmac.h" | 8 #include "crypto/hmac.h" |
| 9 #include "jingle/glue/utils.h" | 9 #include "jingle/glue/utils.h" |
| 10 #include "net/base/cert_status_flags.h" | 10 #include "net/base/cert_status_flags.h" |
| (...skipping 20 matching lines...) Expand all Loading... |
| 31 const int kTcpAckDelayMilliseconds = 10; | 31 const int kTcpAckDelayMilliseconds = 10; |
| 32 | 32 |
| 33 // Values for the TCP send and receive buffer size. This should be tuned to | 33 // Values for the TCP send and receive buffer size. This should be tuned to |
| 34 // accomodate high latency network but not backlog the decoding pipeline. | 34 // accomodate high latency network but not backlog the decoding pipeline. |
| 35 const int kTcpReceiveBufferSize = 256 * 1024; | 35 const int kTcpReceiveBufferSize = 256 * 1024; |
| 36 const int kTcpSendBufferSize = kTcpReceiveBufferSize + 30 * 1024; | 36 const int kTcpSendBufferSize = kTcpReceiveBufferSize + 30 * 1024; |
| 37 | 37 |
| 38 class PepperStreamTransport : public StreamTransport, | 38 class PepperStreamTransport : public StreamTransport, |
| 39 public PepperTransportSocketAdapter::Observer { | 39 public PepperTransportSocketAdapter::Observer { |
| 40 public: | 40 public: |
| 41 PepperStreamTransport(pp::Instance* pp_instance); | 41 PepperStreamTransport(pp::Instance* pp_instance, |
| 42 const TransportConfig& config); |
| 42 virtual ~PepperStreamTransport(); | 43 virtual ~PepperStreamTransport(); |
| 43 | 44 |
| 44 // StreamTransport interface. | 45 // StreamTransport interface. |
| 45 virtual void Initialize( | 46 virtual void Initialize( |
| 46 const std::string& name, | 47 const std::string& name, |
| 47 const TransportConfig& config, | |
| 48 Transport::EventHandler* event_handler, | 48 Transport::EventHandler* event_handler, |
| 49 scoped_ptr<ChannelAuthenticator> authenticator) OVERRIDE; | 49 scoped_ptr<ChannelAuthenticator> authenticator) OVERRIDE; |
| 50 virtual void Connect( | 50 virtual void Connect( |
| 51 const StreamTransport::ConnectedCallback& callback) OVERRIDE; | 51 const StreamTransport::ConnectedCallback& callback) OVERRIDE; |
| 52 virtual void AddRemoteCandidate(const cricket::Candidate& candidate) OVERRIDE; | 52 virtual void AddRemoteCandidate(const cricket::Candidate& candidate) OVERRIDE; |
| 53 virtual const std::string& name() const OVERRIDE; | 53 virtual const std::string& name() const OVERRIDE; |
| 54 virtual bool is_connected() const OVERRIDE; | 54 virtual bool is_connected() const OVERRIDE; |
| 55 | 55 |
| 56 // PepperTransportSocketAdapter::Observer interface. | 56 // PepperTransportSocketAdapter::Observer interface. |
| 57 virtual void OnChannelDeleted() OVERRIDE; | 57 virtual void OnChannelDeleted() OVERRIDE; |
| 58 virtual void OnChannelNewLocalCandidate( | 58 virtual void OnChannelNewLocalCandidate( |
| 59 const std::string& candidate) OVERRIDE; | 59 const std::string& candidate) OVERRIDE; |
| 60 | 60 |
| 61 private: | 61 private: |
| 62 void OnP2PConnect(int result); | 62 void OnP2PConnect(int result); |
| 63 void OnAuthenticationDone(net::Error error, | 63 void OnAuthenticationDone(net::Error error, |
| 64 scoped_ptr<net::StreamSocket> socket); | 64 scoped_ptr<net::StreamSocket> socket); |
| 65 | 65 |
| 66 void NotifyConnected(scoped_ptr<net::StreamSocket> socket); | 66 void NotifyConnected(scoped_ptr<net::StreamSocket> socket); |
| 67 void NotifyConnectFailed(); | 67 void NotifyConnectFailed(); |
| 68 | 68 |
| 69 pp::Instance* pp_instance_; | 69 pp::Instance* pp_instance_; |
| 70 TransportConfig config_; |
| 70 std::string name_; | 71 std::string name_; |
| 71 TransportConfig config_; | |
| 72 EventHandler* event_handler_; | 72 EventHandler* event_handler_; |
| 73 StreamTransport::ConnectedCallback callback_; | 73 StreamTransport::ConnectedCallback callback_; |
| 74 scoped_ptr<ChannelAuthenticator> authenticator_; | 74 scoped_ptr<ChannelAuthenticator> authenticator_; |
| 75 | 75 |
| 76 // We own |channel_| until it is connected. After that | 76 // We own |channel_| until it is connected. After that |
| 77 // |authenticator_| owns it. | 77 // |authenticator_| owns it. |
| 78 scoped_ptr<PepperTransportSocketAdapter> owned_channel_; | 78 scoped_ptr<PepperTransportSocketAdapter> owned_channel_; |
| 79 PepperTransportSocketAdapter* channel_; | 79 PepperTransportSocketAdapter* channel_; |
| 80 | 80 |
| 81 // Indicates that we've finished connecting. | 81 // Indicates that we've finished connecting. |
| 82 bool connected_; | 82 bool connected_; |
| 83 | 83 |
| 84 DISALLOW_COPY_AND_ASSIGN(PepperStreamTransport); | 84 DISALLOW_COPY_AND_ASSIGN(PepperStreamTransport); |
| 85 }; | 85 }; |
| 86 | 86 |
| 87 PepperStreamTransport::PepperStreamTransport(pp::Instance* pp_instance) | 87 PepperStreamTransport::PepperStreamTransport(pp::Instance* pp_instance, |
| 88 const TransportConfig& config) |
| 88 : pp_instance_(pp_instance), | 89 : pp_instance_(pp_instance), |
| 90 config_(config), |
| 89 event_handler_(NULL), | 91 event_handler_(NULL), |
| 90 channel_(NULL), | 92 channel_(NULL), |
| 91 connected_(false) { | 93 connected_(false) { |
| 92 } | 94 } |
| 93 | 95 |
| 94 PepperStreamTransport::~PepperStreamTransport() { | 96 PepperStreamTransport::~PepperStreamTransport() { |
| 95 DCHECK(event_handler_); | 97 DCHECK(event_handler_); |
| 96 event_handler_->OnTransportDeleted(this); | 98 event_handler_->OnTransportDeleted(this); |
| 97 // Channel should be already destroyed if we were connected. | 99 // Channel should be already destroyed if we were connected. |
| 98 DCHECK(!connected_ || channel_ == NULL); | 100 DCHECK(!connected_ || channel_ == NULL); |
| 99 } | 101 } |
| 100 | 102 |
| 101 void PepperStreamTransport::Initialize( | 103 void PepperStreamTransport::Initialize( |
| 102 const std::string& name, | 104 const std::string& name, |
| 103 const TransportConfig& config, | |
| 104 Transport::EventHandler* event_handler, | 105 Transport::EventHandler* event_handler, |
| 105 scoped_ptr<ChannelAuthenticator> authenticator) { | 106 scoped_ptr<ChannelAuthenticator> authenticator) { |
| 106 DCHECK(CalledOnValidThread()); | 107 DCHECK(CalledOnValidThread()); |
| 107 | 108 |
| 108 DCHECK(!name.empty()); | 109 DCHECK(!name.empty()); |
| 109 DCHECK(event_handler); | 110 DCHECK(event_handler); |
| 110 | 111 |
| 111 // Can be initialized only once. | 112 // Can be initialized only once. |
| 112 DCHECK(name_.empty()); | 113 DCHECK(name_.empty()); |
| 113 | 114 |
| 114 name_ = name; | 115 name_ = name; |
| 115 config_ = config; | |
| 116 event_handler_ = event_handler; | 116 event_handler_ = event_handler; |
| 117 authenticator_ = authenticator.Pass(); | 117 authenticator_ = authenticator.Pass(); |
| 118 } | 118 } |
| 119 | 119 |
| 120 void PepperStreamTransport::Connect( | 120 void PepperStreamTransport::Connect( |
| 121 const StreamTransport::ConnectedCallback& callback) { | 121 const StreamTransport::ConnectedCallback& callback) { |
| 122 DCHECK(CalledOnValidThread()); | 122 DCHECK(CalledOnValidThread()); |
| 123 | 123 |
| 124 // Initialize() must be called first. | 124 // Initialize() must be called first. |
| 125 DCHECK(!name_.empty()); | 125 DCHECK(!name_.empty()); |
| (...skipping 147 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 273 } // namespace | 273 } // namespace |
| 274 | 274 |
| 275 PepperTransportFactory::PepperTransportFactory( | 275 PepperTransportFactory::PepperTransportFactory( |
| 276 pp::Instance* pp_instance) | 276 pp::Instance* pp_instance) |
| 277 : pp_instance_(pp_instance) { | 277 : pp_instance_(pp_instance) { |
| 278 } | 278 } |
| 279 | 279 |
| 280 PepperTransportFactory::~PepperTransportFactory() { | 280 PepperTransportFactory::~PepperTransportFactory() { |
| 281 } | 281 } |
| 282 | 282 |
| 283 void PepperTransportFactory::SetConfig(const TransportConfig& config) { |
| 284 config_ = config; |
| 285 } |
| 286 |
| 283 scoped_ptr<StreamTransport> PepperTransportFactory::CreateStreamTransport() { | 287 scoped_ptr<StreamTransport> PepperTransportFactory::CreateStreamTransport() { |
| 284 return scoped_ptr<StreamTransport>(new PepperStreamTransport(pp_instance_)); | 288 return scoped_ptr<StreamTransport>( |
| 289 new PepperStreamTransport(pp_instance_, config_)); |
| 285 } | 290 } |
| 286 | 291 |
| 287 scoped_ptr<DatagramTransport> | 292 scoped_ptr<DatagramTransport> |
| 288 PepperTransportFactory::CreateDatagramTransport() { | 293 PepperTransportFactory::CreateDatagramTransport() { |
| 289 NOTIMPLEMENTED(); | 294 NOTIMPLEMENTED(); |
| 290 return scoped_ptr<DatagramTransport>(NULL); | 295 return scoped_ptr<DatagramTransport>(NULL); |
| 291 } | 296 } |
| 292 | 297 |
| 293 } // namespace protocol | 298 } // namespace protocol |
| 294 } // namespace remoting | 299 } // namespace remoting |
| OLD | NEW |