Chromium Code Reviews| Index: net/quic/quic_chromium_client_session.h |
| diff --git a/net/quic/quic_chromium_client_session.h b/net/quic/quic_chromium_client_session.h |
| index feb071042f26df69280ab0b8371ef09a502be281..6767afd630d22580d97ab368591252c5541d3a37 100644 |
| --- a/net/quic/quic_chromium_client_session.h |
| +++ b/net/quic/quic_chromium_client_session.h |
| @@ -177,7 +177,7 @@ class NET_EXPORT_PRIVATE QuicChromiumClientSession |
| // Resumes a crypto handshake with the server after a timeout. |
| int ResumeCryptoConnect(const CompletionCallback& callback); |
| - // Causes the QuicConnectionHelper to start reading from the socket |
| + // Causes the QuicConnectionHelper to start reading from all sockets |
| // and passing the data along to the QuicConnection. |
| void StartReading(); |
| @@ -210,6 +210,13 @@ class NET_EXPORT_PRIVATE QuicChromiumClientSession |
| QuicDisabledReason disabled_reason() const { return disabled_reason_; } |
| + // Call to add a new socket to the session. Takes ownership of |socket|. |
| + void AddSocket(scoped_ptr<DatagramClientSocket> socket); |
|
Ryan Hamilton
2015/09/08 04:09:38
Do we ever remove sockets? How shall we handle rea
Jana
2015/11/17 01:50:08
We don't remove sockets at this point. This is why
|
| + |
| + // Call to add a new PacketReader to the session. Returns true if reader was |
| + // successfully added to the session. Takes ownership of |reader|. |
| + bool AddPacketReader(QuicPacketReader* reader); |
|
Ryan Hamilton
2015/09/08 04:09:37
Should this be a scoped_ptr?
Jana
2015/11/17 01:50:08
Done.
|
| + |
|
Ryan Hamilton
2015/09/08 04:09:38
It's a bit odd that we need a socket, reader and w
Jana
2015/11/17 01:50:08
Fixed in the new version, PTAL.
|
| protected: |
| // QuicSession methods: |
| QuicDataStream* CreateIncomingDynamicStream(QuicStreamId id) override; |
| @@ -259,7 +266,7 @@ class NET_EXPORT_PRIVATE QuicChromiumClientSession |
| bool require_confirmation_; |
| scoped_ptr<QuicCryptoClientStream> crypto_stream_; |
| QuicStreamFactory* stream_factory_; |
| - scoped_ptr<DatagramClientSocket> socket_; |
| + std::vector<scoped_ptr<DatagramClientSocket>> sockets_; |
| TransportSecurityState* transport_security_state_; |
| scoped_ptr<QuicServerInfo> server_info_; |
| scoped_ptr<CertVerifyResult> cert_verify_result_; |
| @@ -270,7 +277,7 @@ class NET_EXPORT_PRIVATE QuicChromiumClientSession |
| size_t num_total_streams_; |
| base::TaskRunner* task_runner_; |
| BoundNetLog net_log_; |
| - QuicPacketReader packet_reader_; |
| + std::vector<scoped_ptr<QuicPacketReader>> packet_readers_; |
| base::TimeTicks dns_resolution_end_time_; |
| base::TimeTicks handshake_start_; // Time the handshake was started. |
| scoped_ptr<QuicConnectionLogger> logger_; |