| 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/quic/quic_client_session.h" | 5 #include "net/quic/quic_client_session.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
| 10 #include "net/base/test_completion_callback.h" | 10 #include "net/base/test_completion_callback.h" |
| 11 #include "net/quic/crypto/crypto_protocol.h" | 11 #include "net/quic/crypto/crypto_protocol.h" |
| 12 #include "net/quic/test_tools/quic_test_utils.h" | 12 #include "net/quic/test_tools/quic_test_utils.h" |
| 13 | 13 |
| 14 using testing::_; | 14 using testing::_; |
| 15 | 15 |
| 16 namespace net { | 16 namespace net { |
| 17 namespace test { | 17 namespace test { |
| 18 namespace { | 18 namespace { |
| 19 | 19 |
| 20 class QuicClientSessionTest : public ::testing::Test { | 20 class QuicClientSessionTest : public ::testing::Test { |
| 21 protected: | 21 protected: |
| 22 QuicClientSessionTest() | 22 QuicClientSessionTest() |
| 23 : guid_(1), | 23 : guid_(1), |
| 24 connection_(new PacketSavingConnection(guid_, IPEndPoint())), | 24 connection_(new PacketSavingConnection(guid_, IPEndPoint())), |
| 25 session_(connection_, NULL, NULL) { | 25 session_(connection_, NULL, NULL) { |
| 26 } | 26 } |
| 27 | 27 |
| 28 protected: | |
| 29 QuicGuid guid_; | 28 QuicGuid guid_; |
| 30 PacketSavingConnection* connection_; | 29 PacketSavingConnection* connection_; |
| 31 QuicClientSession session_; | 30 QuicClientSession session_; |
| 32 QuicConnectionVisitorInterface* visitor_; | 31 QuicConnectionVisitorInterface* visitor_; |
| 33 TestCompletionCallback callback_; | 32 TestCompletionCallback callback_; |
| 34 }; | 33 }; |
| 35 | 34 |
| 36 TEST_F(QuicClientSessionTest, CryptoConnectSendsCorrectData) { | 35 TEST_F(QuicClientSessionTest, CryptoConnectSendsCorrectData) { |
| 37 EXPECT_EQ(ERR_IO_PENDING, session_.CryptoConnect(callback_.callback())); | 36 EXPECT_EQ(ERR_IO_PENDING, session_.CryptoConnect(callback_.callback())); |
| 38 ASSERT_EQ(1u, connection_->packets_.size()); | 37 ASSERT_EQ(1u, connection_->packets_.size()); |
| 39 scoped_ptr<QuicPacket> chlo(ConstructHandshakePacket(guid_, kCHLO)); | 38 scoped_ptr<QuicPacket> chlo(ConstructClientHelloPacket( |
| 39 guid_, connection_->clock(), connection_->random_generator())); |
| 40 CompareQuicDataWithHexError("CHLO", connection_->packets_[0], chlo.get()); | 40 CompareQuicDataWithHexError("CHLO", connection_->packets_[0], chlo.get()); |
| 41 } | 41 } |
| 42 | 42 |
| 43 TEST_F(QuicClientSessionTest, CryptoConnectSendsCompletesAfterSHLO) { | 43 TEST_F(QuicClientSessionTest, CryptoConnectSendsCompletesAfterSHLO) { |
| 44 ASSERT_EQ(ERR_IO_PENDING, session_.CryptoConnect(callback_.callback())); | 44 ASSERT_EQ(ERR_IO_PENDING, session_.CryptoConnect(callback_.callback())); |
| 45 // Send the SHLO message. | 45 // Send the SHLO message. |
| 46 CryptoHandshakeMessage server_message; | 46 CryptoHandshakeMessage server_message; |
| 47 server_message.tag = kSHLO; | 47 server_message.tag = kSHLO; |
| 48 session_.GetCryptoStream()->OnHandshakeMessage(server_message); | 48 session_.GetCryptoStream()->OnHandshakeMessage(server_message); |
| 49 EXPECT_EQ(OK, callback_.WaitForResult()); | 49 EXPECT_EQ(OK, callback_.WaitForResult()); |
| 50 } | 50 } |
| 51 | 51 |
| 52 TEST_F(QuicClientSessionTest, MaxNumConnections) { | 52 TEST_F(QuicClientSessionTest, MaxNumConnections) { |
| 53 // Initialize crypto before the client session will create a stream. | 53 // Initialize crypto before the client session will create a stream. |
| 54 ASSERT_EQ(ERR_IO_PENDING, session_.CryptoConnect(callback_.callback())); | 54 ASSERT_EQ(ERR_IO_PENDING, session_.CryptoConnect(callback_.callback())); |
| 55 // Simulate the server crypto handshake. |
| 55 CryptoHandshakeMessage server_message; | 56 CryptoHandshakeMessage server_message; |
| 56 server_message.tag = kSHLO; | 57 server_message.tag = kSHLO; |
| 57 session_.GetCryptoStream()->OnHandshakeMessage(server_message); | 58 session_.GetCryptoStream()->OnHandshakeMessage(server_message); |
| 58 callback_.WaitForResult(); | 59 callback_.WaitForResult(); |
| 59 | 60 |
| 60 std::vector<QuicReliableClientStream*> streams; | 61 std::vector<QuicReliableClientStream*> streams; |
| 61 for (size_t i = 0; i < kDefaultMaxStreamsPerConnection; i++) { | 62 for (size_t i = 0; i < kDefaultMaxStreamsPerConnection; i++) { |
| 62 QuicReliableClientStream* stream = session_.CreateOutgoingReliableStream(); | 63 QuicReliableClientStream* stream = session_.CreateOutgoingReliableStream(); |
| 63 EXPECT_TRUE(stream); | 64 EXPECT_TRUE(stream); |
| 64 streams.push_back(stream); | 65 streams.push_back(stream); |
| 65 } | 66 } |
| 66 EXPECT_FALSE(session_.CreateOutgoingReliableStream()); | 67 EXPECT_FALSE(session_.CreateOutgoingReliableStream()); |
| 67 | 68 |
| 68 // Close a stream and ensure I can now open a new one. | 69 // Close a stream and ensure I can now open a new one. |
| 69 session_.CloseStream(streams[0]->id()); | 70 session_.CloseStream(streams[0]->id()); |
| 70 EXPECT_TRUE(session_.CreateOutgoingReliableStream()); | 71 EXPECT_TRUE(session_.CreateOutgoingReliableStream()); |
| 71 } | 72 } |
| 72 | 73 |
| 73 } // namespace | 74 } // namespace |
| 74 } // namespace test | 75 } // namespace test |
| 75 } // namespace net | 76 } // namespace net |
| OLD | NEW |