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 "jingle/notifier/base/chrome_async_socket.h" | 5 #include "jingle/notifier/base/chrome_async_socket.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <cstring> | 8 #include <cstring> |
9 #include <cstdlib> | 9 #include <cstdlib> |
10 | 10 |
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
98 } | 98 } |
99 | 99 |
100 DCHECK_EQ(state_, buzz::AsyncSocket::STATE_CLOSED); | 100 DCHECK_EQ(state_, buzz::AsyncSocket::STATE_CLOSED); |
101 DCHECK_EQ(read_state_, IDLE); | 101 DCHECK_EQ(read_state_, IDLE); |
102 DCHECK_EQ(write_state_, IDLE); | 102 DCHECK_EQ(write_state_, IDLE); |
103 | 103 |
104 state_ = STATE_CONNECTING; | 104 state_ = STATE_CONNECTING; |
105 | 105 |
106 DCHECK_EQ(false, weak_factory_.HasWeakPtrs()); | 106 DCHECK_EQ(false, weak_factory_.HasWeakPtrs()); |
107 | 107 |
108 net::HostPortPair dest_host_port_pair(address.IPAsString(), address.port()); | 108 net::HostPortPair dest_host_port_pair( |
109 address.HostAsURIString(), address.port()); | |
Sergey Ulanov
2012/05/09 18:58:00
same here: ipaddr().ToString()
HostPortPair doesn'
Mallinath (Gone from Chromium)
2012/05/09 22:04:22
Done.
| |
109 | 110 |
110 transport_socket_.reset( | 111 transport_socket_.reset( |
111 client_socket_factory_->CreateTransportClientSocket( | 112 client_socket_factory_->CreateTransportClientSocket( |
112 dest_host_port_pair)); | 113 dest_host_port_pair)); |
113 int status = transport_socket_->Connect( | 114 int status = transport_socket_->Connect( |
114 base::Bind(&ChromeAsyncSocket::ProcessConnectDone, | 115 base::Bind(&ChromeAsyncSocket::ProcessConnectDone, |
115 base::Unretained(this))); | 116 base::Unretained(this))); |
116 if (status != net::ERR_IO_PENDING) { | 117 if (status != net::ERR_IO_PENDING) { |
117 // We defer execution of ProcessConnectDone instead of calling it | 118 // We defer execution of ProcessConnectDone instead of calling it |
118 // directly here as the caller may not expect an error/close to | 119 // directly here as the caller may not expect an error/close to |
(...skipping 318 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
437 } | 438 } |
438 state_ = STATE_TLS_OPEN; | 439 state_ = STATE_TLS_OPEN; |
439 PostDoRead(); | 440 PostDoRead(); |
440 if (write_end_ > 0U) { | 441 if (write_end_ > 0U) { |
441 PostDoWrite(); | 442 PostDoWrite(); |
442 } | 443 } |
443 SignalSSLConnected(); | 444 SignalSSLConnected(); |
444 } | 445 } |
445 | 446 |
446 } // namespace notifier | 447 } // namespace notifier |
OLD | NEW |