| 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 "net/spdy/spdy_session.h" | 5 #include "net/spdy/spdy_session.h" |
| 6 | 6 |
| 7 #include "net/base/ip_endpoint.h" | 7 #include "net/base/ip_endpoint.h" |
| 8 #include "net/spdy/spdy_io_buffer.h" | 8 #include "net/spdy/spdy_io_buffer.h" |
| 9 #include "net/spdy/spdy_session_pool.h" | 9 #include "net/spdy/spdy_session_pool.h" |
| 10 #include "net/spdy/spdy_stream.h" | 10 #include "net/spdy/spdy_stream.h" |
| (...skipping 221 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 232 BoundNetLog(), | 232 BoundNetLog(), |
| 233 &callback1)); | 233 &callback1)); |
| 234 scoped_ptr<TestSpdyStreamDelegate> delegate( | 234 scoped_ptr<TestSpdyStreamDelegate> delegate( |
| 235 new TestSpdyStreamDelegate(&callback1)); | 235 new TestSpdyStreamDelegate(&callback1)); |
| 236 spdy_stream1->SetDelegate(delegate.get()); | 236 spdy_stream1->SetDelegate(delegate.get()); |
| 237 | 237 |
| 238 base::TimeTicks before_ping_time = base::TimeTicks::Now(); | 238 base::TimeTicks before_ping_time = base::TimeTicks::Now(); |
| 239 | 239 |
| 240 // Enable sending of PING. | 240 // Enable sending of PING. |
| 241 SpdySession::set_enable_ping_based_connection_checking(true); | 241 SpdySession::set_enable_ping_based_connection_checking(true); |
| 242 SpdySession::set_connection_at_risk_of_loss_ms(0); | 242 SpdySession::set_connection_at_risk_of_loss_seconds(0); |
| 243 SpdySession::set_trailing_ping_delay_time_ms(0); | 243 SpdySession::set_trailing_ping_delay_time_ms(0); |
| 244 SpdySession::set_hung_interval_ms(50); | 244 SpdySession::set_hung_interval_ms(50); |
| 245 | 245 |
| 246 session->SendPrefacePingIfNoneInFlight(); | 246 session->SendPrefacePingIfNoneInFlight(); |
| 247 | 247 |
| 248 EXPECT_EQ(OK, callback1.WaitForResult()); | 248 EXPECT_EQ(OK, callback1.WaitForResult()); |
| 249 | 249 |
| 250 session->CheckPingStatus(before_ping_time); | 250 session->CheckPingStatus(before_ping_time); |
| 251 | 251 |
| 252 EXPECT_EQ(0, session->pings_in_flight()); | 252 EXPECT_EQ(0, session->pings_in_flight()); |
| (...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 322 MEDIUM, | 322 MEDIUM, |
| 323 &spdy_stream1, | 323 &spdy_stream1, |
| 324 BoundNetLog(), | 324 BoundNetLog(), |
| 325 &callback1)); | 325 &callback1)); |
| 326 scoped_ptr<TestSpdyStreamDelegate> delegate( | 326 scoped_ptr<TestSpdyStreamDelegate> delegate( |
| 327 new TestSpdyStreamDelegate(&callback1)); | 327 new TestSpdyStreamDelegate(&callback1)); |
| 328 spdy_stream1->SetDelegate(delegate.get()); | 328 spdy_stream1->SetDelegate(delegate.get()); |
| 329 | 329 |
| 330 // Enable sending of PING. | 330 // Enable sending of PING. |
| 331 SpdySession::set_enable_ping_based_connection_checking(true); | 331 SpdySession::set_enable_ping_based_connection_checking(true); |
| 332 SpdySession::set_connection_at_risk_of_loss_ms(0); | 332 SpdySession::set_connection_at_risk_of_loss_seconds(0); |
| 333 SpdySession::set_trailing_ping_delay_time_ms(0); | 333 SpdySession::set_trailing_ping_delay_time_ms(0); |
| 334 SpdySession::set_hung_interval_ms(0); | 334 SpdySession::set_hung_interval_ms(0); |
| 335 | 335 |
| 336 // Send a PING frame. | 336 // Send a PING frame. |
| 337 session->WritePingFrame(1); | 337 session->WritePingFrame(1); |
| 338 EXPECT_LT(0, session->pings_in_flight()); | 338 EXPECT_LT(0, session->pings_in_flight()); |
| 339 EXPECT_GT(session->next_ping_id(), static_cast<uint32>(1)); | 339 EXPECT_GT(session->next_ping_id(), static_cast<uint32>(1)); |
| 340 EXPECT_TRUE(session->check_ping_status_pending()); | 340 EXPECT_TRUE(session->check_ping_status_pending()); |
| 341 | 341 |
| 342 // Assert session is not closed. | 342 // Assert session is not closed. |
| (...skipping 571 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 914 spdy::SpdySettings test_settings; | 914 spdy::SpdySettings test_settings; |
| 915 test_settings.push_back(spdy::SpdySetting(id, max_concurrent_streams)); | 915 test_settings.push_back(spdy::SpdySetting(id, max_concurrent_streams)); |
| 916 | 916 |
| 917 test_settings_storage->Set(test_host_port_pair, test_settings); | 917 test_settings_storage->Set(test_host_port_pair, test_settings); |
| 918 EXPECT_NE(0u, test_settings_storage->Get(test_host_port_pair).size()); | 918 EXPECT_NE(0u, test_settings_storage->Get(test_host_port_pair).size()); |
| 919 spdy_session_pool->OnIPAddressChanged(); | 919 spdy_session_pool->OnIPAddressChanged(); |
| 920 EXPECT_EQ(0u, test_settings_storage->Get(test_host_port_pair).size()); | 920 EXPECT_EQ(0u, test_settings_storage->Get(test_host_port_pair).size()); |
| 921 } | 921 } |
| 922 | 922 |
| 923 } // namespace net | 923 } // namespace net |
| OLD | NEW |