OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/jingle_stream_connector.h" | 5 #include "remoting/protocol/jingle_stream_connector.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.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 "net/base/cert_status_flags.h" | 10 #include "net/base/cert_status_flags.h" |
(...skipping 23 matching lines...) Expand all Loading... |
34 | 34 |
35 } // namespace | 35 } // namespace |
36 | 36 |
37 JingleStreamConnector::JingleStreamConnector( | 37 JingleStreamConnector::JingleStreamConnector( |
38 JingleSession* session, | 38 JingleSession* session, |
39 const std::string& name, | 39 const std::string& name, |
40 const Session::StreamChannelCallback& callback) | 40 const Session::StreamChannelCallback& callback) |
41 : session_(session), | 41 : session_(session), |
42 name_(name), | 42 name_(name), |
43 callback_(callback), | 43 callback_(callback), |
44 raw_channel_(NULL), | 44 raw_channel_(NULL) { |
45 ALLOW_THIS_IN_INITIALIZER_LIST(tcp_connect_callback_( | |
46 this, &JingleStreamConnector::OnTCPConnect)) { | |
47 } | 45 } |
48 | 46 |
49 JingleStreamConnector::~JingleStreamConnector() { | 47 JingleStreamConnector::~JingleStreamConnector() { |
50 } | 48 } |
51 | 49 |
52 void JingleStreamConnector::Connect(ChannelAuthenticator* authenticator, | 50 void JingleStreamConnector::Connect(ChannelAuthenticator* authenticator, |
53 cricket::TransportChannel* raw_channel) { | 51 cricket::TransportChannel* raw_channel) { |
54 DCHECK(CalledOnValidThread()); | 52 DCHECK(CalledOnValidThread()); |
55 DCHECK(!raw_channel_); | 53 DCHECK(!raw_channel_); |
56 | 54 |
(...skipping 19 matching lines...) Expand all Loading... |
76 | 74 |
77 // Set options for the TCP layer. | 75 // Set options for the TCP layer. |
78 jingle_glue::PseudoTcpAdapter* adapter = | 76 jingle_glue::PseudoTcpAdapter* adapter = |
79 new jingle_glue::PseudoTcpAdapter(socket); | 77 new jingle_glue::PseudoTcpAdapter(socket); |
80 adapter->SetAckDelay(kTcpAckDelayMilliseconds); | 78 adapter->SetAckDelay(kTcpAckDelayMilliseconds); |
81 adapter->SetNoDelay(true); | 79 adapter->SetNoDelay(true); |
82 adapter->SetReceiveBufferSize(kTcpReceiveBufferSize); | 80 adapter->SetReceiveBufferSize(kTcpReceiveBufferSize); |
83 adapter->SetSendBufferSize(kTcpSendBufferSize); | 81 adapter->SetSendBufferSize(kTcpSendBufferSize); |
84 | 82 |
85 tcp_socket_.reset(adapter); | 83 tcp_socket_.reset(adapter); |
86 int result = tcp_socket_->Connect(&tcp_connect_callback_); | 84 int result = tcp_socket_->Connect( |
| 85 base::Bind(&JingleStreamConnector::OnTCPConnect, |
| 86 base::Unretained(this))); |
87 if (result == net::ERR_IO_PENDING) { | 87 if (result == net::ERR_IO_PENDING) { |
88 return true; | 88 return true; |
89 } else if (result == net::OK) { | 89 } else if (result == net::OK) { |
90 tcp_connect_callback_.Run(result); | 90 OnTCPConnect(result); |
91 return true; | 91 return true; |
92 } | 92 } |
93 | 93 |
94 return false; | 94 return false; |
95 } | 95 } |
96 | 96 |
97 void JingleStreamConnector::OnTCPConnect(int result) { | 97 void JingleStreamConnector::OnTCPConnect(int result) { |
98 DCHECK(CalledOnValidThread()); | 98 DCHECK(CalledOnValidThread()); |
99 | 99 |
100 if (result != net::OK) { | 100 if (result != net::OK) { |
(...skipping 20 matching lines...) Expand all Loading... |
121 callback_.Run(socket); | 121 callback_.Run(socket); |
122 delete this; | 122 delete this; |
123 } | 123 } |
124 | 124 |
125 void JingleStreamConnector::NotifyError() { | 125 void JingleStreamConnector::NotifyError() { |
126 NotifyDone(NULL); | 126 NotifyDone(NULL); |
127 } | 127 } |
128 | 128 |
129 } // namespace protocol | 129 } // namespace protocol |
130 } // namespace remoting | 130 } // namespace remoting |
OLD | NEW |