Chromium Code Reviews| Index: net/spdy/spdy_session.cc |
| =================================================================== |
| --- net/spdy/spdy_session.cc (revision 105879) |
| +++ net/spdy/spdy_session.cc (working copy) |
| @@ -237,7 +237,7 @@ |
| int SpdySession::connection_at_risk_of_loss_ms_ = 0; |
| // static |
| -int SpdySession::trailing_ping_delay_time_ms_ = 1000; |
| +int SpdySession::trailing_ping_delay_time_ms_ = 200; |
|
jar (doing other things)
2011/10/17 22:09:28
Will argued for keeping this at 1000, and was pers
ramant (doing other things)
2011/10/17 23:40:57
Done.
|
| // static |
| int SpdySession::hung_interval_ms_ = 10000; |
| @@ -280,7 +280,7 @@ |
| received_data_time_(base::TimeTicks::Now()), |
| trailing_ping_pending_(false), |
| check_ping_status_pending_(false), |
| - last_sent_was_ping_(false), |
| + need_to_send_ping_(false), |
| initial_send_window_size_(spdy::kSpdyStreamInitialWindowSize), |
| initial_recv_window_size_(spdy::kSpdyStreamInitialWindowSize), |
| net_log_(BoundNetLog::Make(net_log, NetLog::SOURCE_SPDY_SESSION)), |
| @@ -528,7 +528,7 @@ |
| make_scoped_refptr( |
| new NetLogSpdySynParameter(headers, flags, stream_id, 0))); |
| } |
| - last_sent_was_ping_ = false; |
| + need_to_send_ping_ = true; |
|
jar (doing other things)
2011/10/17 22:09:28
Please add comment:
Some servers don't like too ma
ramant (doing other things)
2011/10/17 23:40:57
Done.
|
| return ERR_IO_PENDING; |
| } |
| @@ -584,7 +584,6 @@ |
| scoped_ptr<spdy::SpdyDataFrame> frame( |
| spdy_framer_.CreateDataFrame(stream_id, data->data(), len, flags)); |
| QueueFrame(frame.get(), stream->priority(), stream); |
| - last_sent_was_ping_ = false; |
| return ERR_IO_PENDING; |
| } |
| @@ -612,7 +611,6 @@ |
| priority = stream->priority(); |
| } |
| QueueFrame(rst_frame.get(), priority, NULL); |
| - last_sent_was_ping_ = false; |
| DeleteStream(stream_id, ERR_SPDY_PROTOCOL_ERROR); |
| } |
| @@ -1383,7 +1381,7 @@ |
| if (pings_in_flight_ > 0) |
| return; |
| - if (last_sent_was_ping_) |
| + if (!need_to_send_ping_) |
| return; |
| PlanToSendTrailingPing(); |
| @@ -1446,7 +1444,6 @@ |
| scoped_ptr<spdy::SpdyWindowUpdateControlFrame> window_update_frame( |
| spdy_framer_.CreateWindowUpdate(stream_id, delta_window_size)); |
| QueueFrame(window_update_frame.get(), stream->priority(), stream); |
| - last_sent_was_ping_ = false; |
| } |
| // Given a cwnd that we would have sent to the server, modify it based on the |
| @@ -1511,7 +1508,6 @@ |
| spdy_framer_.CreateSettings(settings)); |
| sent_settings_ = true; |
| QueueFrame(settings_frame.get(), 0, NULL); |
| - last_sent_was_ping_ = false; |
| } |
| void SpdySession::HandleSettings(const spdy::SpdySettings& settings) { |
| @@ -1546,7 +1542,8 @@ |
| } |
| void SpdySession::SendPrefacePing() { |
| - WritePingFrame(next_ping_id_); |
| + // TODO(rtenneti): Enable sending Preface-PING after server fix. |
|
jar (doing other things)
2011/10/17 22:40:05
Suggest:
TODO(rtenneti): Send preface pings when m
ramant (doing other things)
2011/10/17 23:40:57
Done.
|
| + // WritePingFrame(next_ping_id_); |
| } |
| void SpdySession::PlanToSendTrailingPing() { |
| @@ -1579,7 +1576,7 @@ |
| if (unique_id % 2 != 0) { |
| next_ping_id_ += 2; |
| ++pings_in_flight_; |
| - last_sent_was_ping_ = true; |
| + need_to_send_ping_ = false; |
| PlanToCheckPingStatus(); |
| } |
| } |