| 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 "net/tools/quic/quic_client.h" | 5 #include "net/tools/quic/quic_client.h" |
| 6 | 6 |
| 7 #include <errno.h> | 7 #include <errno.h> |
| 8 #include <netinet/in.h> | 8 #include <netinet/in.h> |
| 9 #include <string.h> | 9 #include <string.h> |
| 10 #include <sys/socket.h> | 10 #include <sys/socket.h> |
| (...skipping 183 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 194 void QuicClient::StartConnect() { | 194 void QuicClient::StartConnect() { |
| 195 DCHECK(initialized_); | 195 DCHECK(initialized_); |
| 196 DCHECK(!connected()); | 196 DCHECK(!connected()); |
| 197 | 197 |
| 198 QuicPacketWriter* writer = CreateQuicPacketWriter(); | 198 QuicPacketWriter* writer = CreateQuicPacketWriter(); |
| 199 | 199 |
| 200 DummyPacketWriterFactory factory(writer); | 200 DummyPacketWriterFactory factory(writer); |
| 201 | 201 |
| 202 session_.reset(new QuicClientSession( | 202 session_.reset(new QuicClientSession( |
| 203 config_, | 203 config_, |
| 204 new QuicConnection(GenerateConnectionId(), | 204 new QuicConnection(GenerateConnectionId(), server_address_, helper_.get(), |
| 205 server_address_, | |
| 206 helper_.get(), | |
| 207 factory, | 205 factory, |
| 208 /* owns_writer= */ false, | 206 /* owns_writer= */ false, Perspective::IS_CLIENT, |
| 209 /* is_server= */ false, | 207 server_id_.is_https(), supported_versions_))); |
| 210 server_id_.is_https(), | |
| 211 supported_versions_))); | |
| 212 | 208 |
| 213 // Reset |writer_| after |session_| so that the old writer outlives the old | 209 // Reset |writer_| after |session_| so that the old writer outlives the old |
| 214 // session. | 210 // session. |
| 215 if (writer_.get() != writer) { | 211 if (writer_.get() != writer) { |
| 216 writer_.reset(writer); | 212 writer_.reset(writer); |
| 217 } | 213 } |
| 218 session_->InitializeSession(server_id_, &crypto_config_); | 214 session_->InitializeSession(server_id_, &crypto_config_); |
| 219 session_->CryptoConnect(); | 215 session_->CryptoConnect(); |
| 220 } | 216 } |
| 221 | 217 |
| (...skipping 178 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 400 QuicEncryptedPacket packet(buf, bytes_read, false); | 396 QuicEncryptedPacket packet(buf, bytes_read, false); |
| 401 | 397 |
| 402 IPEndPoint client_address(client_ip, client_address_.port()); | 398 IPEndPoint client_address(client_ip, client_address_.port()); |
| 403 session_->connection()->ProcessUdpPacket( | 399 session_->connection()->ProcessUdpPacket( |
| 404 client_address, server_address, packet); | 400 client_address, server_address, packet); |
| 405 return true; | 401 return true; |
| 406 } | 402 } |
| 407 | 403 |
| 408 } // namespace tools | 404 } // namespace tools |
| 409 } // namespace net | 405 } // namespace net |
| OLD | NEW |