| Index: net/spdy/spdy_session.cc
|
| diff --git a/net/spdy/spdy_session.cc b/net/spdy/spdy_session.cc
|
| index d07e16da7cf8e92ab5f22c5162fc54f50aa818a3..67fd0e17f0d44619b87df907943f6cf566204fa7 100644
|
| --- a/net/spdy/spdy_session.cc
|
| +++ b/net/spdy/spdy_session.cc
|
| @@ -38,6 +38,8 @@
|
| #include "net/http/http_util.h"
|
| #include "net/http/transport_security_state.h"
|
| #include "net/log/net_log.h"
|
| +#include "net/log/net_log_event_type.h"
|
| +#include "net/log/net_log_source_type.h"
|
| #include "net/proxy/proxy_server.h"
|
| #include "net/socket/ssl_client_socket.h"
|
| #include "net/spdy/spdy_buffer_producer.h"
|
| @@ -670,7 +672,7 @@ SpdySession::SpdySession(const SpdySessionKey& spdy_session_key,
|
| session_unacked_recv_window_bytes_(0),
|
| stream_initial_send_window_size_(kDefaultInitialWindowSize),
|
| stream_max_recv_window_size_(stream_max_recv_window_size),
|
| - net_log_(BoundNetLog::Make(net_log, NetLog::SOURCE_HTTP2_SESSION)),
|
| + net_log_(BoundNetLog::Make(net_log, NetLogSourceType::HTTP2_SESSION)),
|
| verify_domain_authentication_(verify_domain_authentication),
|
| enable_sending_initial_data_(enable_sending_initial_data),
|
| enable_ping_based_connection_checking_(
|
| @@ -682,7 +684,7 @@ SpdySession::SpdySession(const SpdySessionKey& spdy_session_key,
|
| time_func_(time_func),
|
| weak_factory_(this) {
|
| net_log_.BeginEvent(
|
| - NetLog::TYPE_HTTP2_SESSION,
|
| + NetLogEventType::HTTP2_SESSION,
|
| base::Bind(&NetLogSpdySessionCallback, &host_port_proxy_pair()));
|
| next_unclaimed_push_stream_sweep_time_ = time_func_() +
|
| base::TimeDelta::FromSeconds(kMinPushedStreamLifetimeSeconds);
|
| @@ -701,7 +703,7 @@ SpdySession::~SpdySession() {
|
|
|
| RecordHistograms();
|
|
|
| - net_log_.EndEvent(NetLog::TYPE_HTTP2_SESSION);
|
| + net_log_.EndEvent(NetLogEventType::HTTP2_SESSION);
|
| }
|
|
|
| void SpdySession::InitializeWithSocket(
|
| @@ -733,7 +735,7 @@ void SpdySession::InitializeWithSocket(
|
| buffered_spdy_framer_->set_debug_visitor(this);
|
| buffered_spdy_framer_->UpdateHeaderDecoderTableSize(kMaxHeaderTableSize);
|
|
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_SESSION_INITIALIZED,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_SESSION_INITIALIZED,
|
| base::Bind(&NetLogSpdyInitializedCallback,
|
| connection_->socket()->NetLog().source()));
|
|
|
| @@ -827,7 +829,7 @@ int SpdySession::TryCreateStream(
|
| }
|
|
|
| stalled_streams_++;
|
| - net_log().AddEvent(NetLog::TYPE_HTTP2_SESSION_STALLED_MAX_STREAMS);
|
| + net_log().AddEvent(NetLogEventType::HTTP2_SESSION_STALLED_MAX_STREAMS);
|
| RequestPriority priority = request->priority();
|
| CHECK_GE(priority, MINIMUM_PRIORITY);
|
| CHECK_LE(priority, MAXIMUM_PRIORITY);
|
| @@ -1016,7 +1018,7 @@ std::unique_ptr<SpdySerializedFrame> SpdySession::CreateHeaders(
|
|
|
| if (net_log().IsCapturing()) {
|
| net_log().AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_SEND_HEADERS,
|
| + NetLogEventType::HTTP2_SESSION_SEND_HEADERS,
|
| base::Bind(&NetLogSpdyHeadersSentCallback, &block,
|
| (flags & CONTROL_FLAG_FIN) != 0, stream_id, has_priority,
|
| weight, dependent_stream_id, exclusive));
|
| @@ -1090,7 +1092,7 @@ std::unique_ptr<SpdyBuffer> SpdySession::CreateDataBuffer(
|
| // might end up being stalled by the session also.
|
| QueueSendStalledStream(*stream);
|
| net_log().AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_STREAM_STALLED_BY_STREAM_SEND_WINDOW,
|
| + NetLogEventType::HTTP2_SESSION_STREAM_STALLED_BY_STREAM_SEND_WINDOW,
|
| NetLog::IntCallback("stream_id", stream_id));
|
| return std::unique_ptr<SpdyBuffer>();
|
| }
|
| @@ -1102,7 +1104,7 @@ std::unique_ptr<SpdyBuffer> SpdySession::CreateDataBuffer(
|
| stream->set_send_stalled_by_flow_control(true);
|
| QueueSendStalledStream(*stream);
|
| net_log().AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_STREAM_STALLED_BY_SESSION_SEND_WINDOW,
|
| + NetLogEventType::HTTP2_SESSION_STREAM_STALLED_BY_SESSION_SEND_WINDOW,
|
| NetLog::IntCallback("stream_id", stream_id));
|
| return std::unique_ptr<SpdyBuffer>();
|
| }
|
| @@ -1117,7 +1119,7 @@ std::unique_ptr<SpdyBuffer> SpdySession::CreateDataBuffer(
|
| flags = static_cast<SpdyDataFlags>(flags & ~DATA_FLAG_FIN);
|
|
|
| if (net_log().IsCapturing()) {
|
| - net_log().AddEvent(NetLog::TYPE_HTTP2_SESSION_SEND_DATA,
|
| + net_log().AddEvent(NetLogEventType::HTTP2_SESSION_SEND_DATA,
|
| base::Bind(&NetLogSpdyDataCallback, stream_id,
|
| effective_len, (flags & DATA_FLAG_FIN) != 0));
|
| }
|
| @@ -1258,7 +1260,7 @@ void SpdySession::EnqueueResetStreamFrame(SpdyStreamId stream_id,
|
| DCHECK_NE(stream_id, 0u);
|
|
|
| net_log().AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_SEND_RST_STREAM,
|
| + NetLogEventType::HTTP2_SESSION_SEND_RST_STREAM,
|
| base::Bind(&NetLogSpdyRstCallback, stream_id, status, &description));
|
|
|
| DCHECK(buffered_spdy_framer_.get());
|
| @@ -1671,7 +1673,7 @@ void SpdySession::DoDrainSession(Error err, const std::string& description) {
|
| error_on_close_ = err;
|
|
|
| net_log_.AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_CLOSE,
|
| + NetLogEventType::HTTP2_SESSION_CLOSE,
|
| base::Bind(&NetLogSpdySessionCloseCallback, err, &description));
|
|
|
| UMA_HISTOGRAM_SPARSE_SLOWLY("Net.SpdySession.ClosedOnError", -err);
|
| @@ -1916,7 +1918,7 @@ base::WeakPtr<SpdyStream> SpdySession::GetActivePushStream(const GURL& url) {
|
| return base::WeakPtr<SpdyStream>();
|
| }
|
|
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_STREAM_ADOPTED_PUSH_STREAM,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_STREAM_ADOPTED_PUSH_STREAM,
|
| base::Bind(&NetLogSpdyAdoptedPushStreamCallback,
|
| active_it->second.stream->stream_id(), &url));
|
| return active_it->second.stream->GetWeakPtr();
|
| @@ -2003,7 +2005,7 @@ void SpdySession::OnStreamFrameData(SpdyStreamId stream_id,
|
| DCHECK_LT(len, 1u << 24);
|
| if (net_log().IsCapturing()) {
|
| net_log().AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_RECV_DATA,
|
| + NetLogEventType::HTTP2_SESSION_RECV_DATA,
|
| base::Bind(&NetLogSpdyDataCallback, stream_id, len, false));
|
| }
|
|
|
| @@ -2049,7 +2051,7 @@ void SpdySession::OnStreamFrameData(SpdyStreamId stream_id,
|
| void SpdySession::OnStreamEnd(SpdyStreamId stream_id) {
|
| CHECK(in_io_loop_);
|
| if (net_log().IsCapturing()) {
|
| - net_log().AddEvent(NetLog::TYPE_HTTP2_SESSION_RECV_DATA,
|
| + net_log().AddEvent(NetLogEventType::HTTP2_SESSION_RECV_DATA,
|
| base::Bind(&NetLogSpdyDataCallback, stream_id, 0, true));
|
| }
|
|
|
| @@ -2102,7 +2104,7 @@ void SpdySession::OnSettings(bool clear_persisted) {
|
| http_server_properties_->ClearSpdySettings(GetServer());
|
|
|
| if (net_log_.IsCapturing()) {
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_SESSION_RECV_SETTINGS,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_SESSION_RECV_SETTINGS,
|
| base::Bind(&NetLogSpdySettingsCallback, host_port_pair(),
|
| clear_persisted));
|
| }
|
| @@ -2125,7 +2127,7 @@ void SpdySession::OnSetting(SpdySettingsIds id, uint8_t flags, uint32_t value) {
|
| received_settings_ = true;
|
|
|
| // Log the setting.
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_SESSION_RECV_SETTING,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_SESSION_RECV_SETTING,
|
| base::Bind(&NetLogSpdySettingCallback, id,
|
| static_cast<SpdySettingsFlags>(flags), value));
|
| }
|
| @@ -2239,7 +2241,7 @@ void SpdySession::OnHeaders(SpdyStreamId stream_id,
|
| CHECK(in_io_loop_);
|
|
|
| if (net_log().IsCapturing()) {
|
| - net_log().AddEvent(NetLog::TYPE_HTTP2_SESSION_RECV_HEADERS,
|
| + net_log().AddEvent(NetLogEventType::HTTP2_SESSION_RECV_HEADERS,
|
| base::Bind(&NetLogSpdyHeadersReceivedCallback, &headers,
|
| fin, stream_id));
|
| }
|
| @@ -2347,7 +2349,7 @@ void SpdySession::OnRstStream(SpdyStreamId stream_id,
|
|
|
| std::string description;
|
| net_log().AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_RST_STREAM,
|
| + NetLogEventType::HTTP2_SESSION_RST_STREAM,
|
| base::Bind(&NetLogSpdyRstCallback, stream_id, status, &description));
|
|
|
| ActiveStreamMap::iterator it = active_streams_.find(stream_id);
|
| @@ -2390,7 +2392,7 @@ void SpdySession::OnGoAway(SpdyStreamId last_accepted_stream_id,
|
| // TODO(jgraettinger): UMA histogram on |status|.
|
|
|
| net_log_.AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_GOAWAY,
|
| + NetLogEventType::HTTP2_SESSION_GOAWAY,
|
| base::Bind(&NetLogSpdyGoAwayCallback, last_accepted_stream_id,
|
| active_streams_.size(), unclaimed_pushed_streams_.size(),
|
| status, debug_data));
|
| @@ -2412,7 +2414,7 @@ void SpdySession::OnPing(SpdyPingId unique_id, bool is_ack) {
|
| CHECK(in_io_loop_);
|
|
|
| net_log_.AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_PING,
|
| + NetLogEventType::HTTP2_SESSION_PING,
|
| base::Bind(&NetLogSpdyPingCallback, unique_id, is_ack, "received"));
|
|
|
| // Send response to a PING from server.
|
| @@ -2441,7 +2443,7 @@ void SpdySession::OnWindowUpdate(SpdyStreamId stream_id,
|
| int delta_window_size) {
|
| CHECK(in_io_loop_);
|
|
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_SESSION_RECEIVED_WINDOW_UPDATE_FRAME,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_SESSION_RECEIVED_WINDOW_UPDATE_FRAME,
|
| base::Bind(&NetLogSpdyWindowUpdateFrameCallback, stream_id,
|
| delta_window_size));
|
|
|
| @@ -2674,7 +2676,7 @@ void SpdySession::OnPushPromise(SpdyStreamId stream_id,
|
| CHECK(in_io_loop_);
|
|
|
| if (net_log_.IsCapturing()) {
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_SESSION_RECV_PUSH_PROMISE,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_SESSION_RECV_PUSH_PROMISE,
|
| base::Bind(&NetLogSpdyPushPromiseReceivedCallback,
|
| &headers, stream_id, promised_stream_id));
|
| }
|
| @@ -2734,7 +2736,7 @@ void SpdySession::SendInitialData() {
|
| }
|
|
|
| void SpdySession::SendSettings(const SettingsMap& settings) {
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_SESSION_SEND_SETTINGS,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_SESSION_SEND_SETTINGS,
|
| base::Bind(&NetLogSpdySendSettingsCallback, &settings));
|
| // Create the SETTINGS frame and send it.
|
| DCHECK(buffered_spdy_framer_.get());
|
| @@ -2754,7 +2756,7 @@ void SpdySession::HandleSetting(uint32_t id, uint32_t value) {
|
| case SETTINGS_INITIAL_WINDOW_SIZE: {
|
| if (value > static_cast<uint32_t>(std::numeric_limits<int32_t>::max())) {
|
| net_log().AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_INITIAL_WINDOW_SIZE_OUT_OF_RANGE,
|
| + NetLogEventType::HTTP2_SESSION_INITIAL_WINDOW_SIZE_OUT_OF_RANGE,
|
| NetLog::IntCallback("initial_window_size", value));
|
| return;
|
| }
|
| @@ -2765,7 +2767,7 @@ void SpdySession::HandleSetting(uint32_t id, uint32_t value) {
|
| stream_initial_send_window_size_ = static_cast<int32_t>(value);
|
| UpdateStreamsSendWindowSize(delta_window_size);
|
| net_log().AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_UPDATE_STREAMS_SEND_WINDOW_SIZE,
|
| + NetLogEventType::HTTP2_SESSION_UPDATE_STREAMS_SEND_WINDOW_SIZE,
|
| NetLog::IntCallback("delta_window_size", delta_window_size));
|
| break;
|
| }
|
| @@ -2808,7 +2810,7 @@ void SpdySession::SendWindowUpdateFrame(SpdyStreamId stream_id,
|
| CHECK_EQ(stream_id, kSessionFlowControlStreamId);
|
| }
|
|
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_SESSION_SENT_WINDOW_UPDATE_FRAME,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_SESSION_SENT_WINDOW_UPDATE_FRAME,
|
| base::Bind(&NetLogSpdyWindowUpdateFrameCallback, stream_id,
|
| delta_window_size));
|
|
|
| @@ -2826,7 +2828,7 @@ void SpdySession::WritePingFrame(SpdyPingId unique_id, bool is_ack) {
|
|
|
| if (net_log().IsCapturing()) {
|
| net_log().AddEvent(
|
| - NetLog::TYPE_HTTP2_SESSION_PING,
|
| + NetLogEventType::HTTP2_SESSION_PING,
|
| base::Bind(&NetLogSpdyPingCallback, unique_id, is_ack, "sent"));
|
| }
|
| if (!is_ack) {
|
| @@ -3017,7 +3019,7 @@ void SpdySession::IncreaseSendWindowSize(int delta_window_size) {
|
|
|
| session_send_window_size_ += delta_window_size;
|
|
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_SESSION_UPDATE_SEND_WINDOW,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_SESSION_UPDATE_SEND_WINDOW,
|
| base::Bind(&NetLogSpdySessionWindowUpdateCallback,
|
| delta_window_size, session_send_window_size_));
|
|
|
| @@ -3037,7 +3039,7 @@ void SpdySession::DecreaseSendWindowSize(int32_t delta_window_size) {
|
|
|
| session_send_window_size_ -= delta_window_size;
|
|
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_SESSION_UPDATE_SEND_WINDOW,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_SESSION_UPDATE_SEND_WINDOW,
|
| base::Bind(&NetLogSpdySessionWindowUpdateCallback,
|
| -delta_window_size, session_send_window_size_));
|
| }
|
| @@ -3063,7 +3065,7 @@ void SpdySession::IncreaseRecvWindowSize(int32_t delta_window_size) {
|
| std::numeric_limits<int32_t>::max() - session_recv_window_size_);
|
|
|
| session_recv_window_size_ += delta_window_size;
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_STREAM_UPDATE_RECV_WINDOW,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_STREAM_UPDATE_RECV_WINDOW,
|
| base::Bind(&NetLogSpdySessionWindowUpdateCallback,
|
| delta_window_size, session_recv_window_size_));
|
|
|
| @@ -3096,7 +3098,7 @@ void SpdySession::DecreaseRecvWindowSize(int32_t delta_window_size) {
|
| }
|
|
|
| session_recv_window_size_ -= delta_window_size;
|
| - net_log_.AddEvent(NetLog::TYPE_HTTP2_SESSION_UPDATE_RECV_WINDOW,
|
| + net_log_.AddEvent(NetLogEventType::HTTP2_SESSION_UPDATE_RECV_WINDOW,
|
| base::Bind(&NetLogSpdySessionWindowUpdateCallback,
|
| -delta_window_size, session_recv_window_size_));
|
| }
|
|
|