Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(65)

Unified Diff: net/quic/core/quic_session.cc

Issue 2631613002: Revert of Add quic_logging (Closed)
Patch Set: Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/quic/core/quic_server_session_base.cc ('k') | net/quic/core/quic_spdy_session.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/quic/core/quic_session.cc
diff --git a/net/quic/core/quic_session.cc b/net/quic/core/quic_session.cc
index 02252bece2fae89187cd8d3a16ad36b6b94ca72c..effc342477a2b5603a27a9b0224f08f6447511a8 100644
--- a/net/quic/core/quic_session.cc
+++ b/net/quic/core/quic_session.cc
@@ -11,7 +11,6 @@
#include "net/quic/core/quic_flags.h"
#include "net/quic/core/quic_flow_controller.h"
#include "net/quic/platform/api/quic_bug_tracker.h"
-#include "net/quic/platform/api/quic_logging.h"
#include "net/quic/platform/api/quic_str_cat.h"
using base::StringPiece;
@@ -54,13 +53,13 @@
}
QuicSession::~QuicSession() {
- QUIC_LOG_IF(WARNING, num_locally_closed_incoming_streams_highest_offset() >
- max_open_incoming_streams_)
+ DLOG_IF(WARNING, num_locally_closed_incoming_streams_highest_offset() >
+ max_open_incoming_streams_)
<< "Surprisingly high number of locally closed peer initiated streams"
"still waiting for final byte offset: "
<< num_locally_closed_incoming_streams_highest_offset();
- QUIC_LOG_IF(WARNING, GetNumLocallyClosedOutgoingStreamsHighestOffset() >
- max_open_outgoing_streams_)
+ DLOG_IF(WARNING, GetNumLocallyClosedOutgoingStreamsHighestOffset() >
+ max_open_outgoing_streams_)
<< "Surprisingly high number of locally closed self initiated streams"
"still waiting for final byte offset: "
<< GetNumLocallyClosedOutgoingStreamsHighestOffset();
@@ -147,10 +146,9 @@
if (stream_id == kConnectionLevelId) {
// This is a window update that applies to the connection, rather than an
// individual stream.
- QUIC_DLOG(INFO) << ENDPOINT
- << "Received connection level flow control window "
- "update with byte offset: "
- << frame.byte_offset;
+ DVLOG(1) << ENDPOINT << "Received connection level flow control window "
+ "update with byte offset: "
+ << frame.byte_offset;
flow_controller_.UpdateSendWindowOffset(frame.byte_offset);
return;
}
@@ -164,8 +162,8 @@
// TODO(rjshade): Compare our flow control receive windows for specified
// streams: if we have a large window then maybe something
// had gone wrong with the flow control accounting.
- QUIC_DLOG(INFO) << ENDPOINT << "Received BLOCKED frame with stream id: "
- << frame.stream_id;
+ DVLOG(1) << ENDPOINT
+ << "Received BLOCKED frame with stream id: " << frame.stream_id;
}
bool QuicSession::CheckStreamNotBusyLooping(QuicStream* stream,
@@ -179,18 +177,17 @@
previous_bytes_written == stream->stream_bytes_written() &&
previous_fin_sent == stream->fin_sent()) {
stream->set_busy_counter(stream->busy_counter() + 1);
- QUIC_DVLOG(1) << "Suspected busy loop on stream id " << stream->id()
- << " stream_bytes_written " << stream->stream_bytes_written()
- << " fin " << stream->fin_sent() << " count "
- << stream->busy_counter();
+ DVLOG(1) << "Suspected busy loop on stream id " << stream->id()
+ << " stream_bytes_written " << stream->stream_bytes_written()
+ << " fin " << stream->fin_sent() << " count "
+ << stream->busy_counter();
// Wait a few iterations before firing, the exact count is
// arbitrary, more than a few to cover a few test-only false
// positives.
if (stream->busy_counter() > 20) {
- QUIC_LOG(ERROR) << "Detected busy loop on stream id " << stream->id()
- << " stream_bytes_written "
- << stream->stream_bytes_written() << " fin "
- << stream->fin_sent();
+ LOG(ERROR) << "Detected busy loop on stream id " << stream->id()
+ << " stream_bytes_written " << stream->stream_bytes_written()
+ << " fin " << stream->fin_sent();
return false;
}
} else {
@@ -243,8 +240,8 @@
// list.
uint64_t previous_bytes_written = stream->stream_bytes_written();
bool previous_fin_sent = stream->fin_sent();
- QUIC_DVLOG(1) << "stream " << stream->id() << " bytes_written "
- << previous_bytes_written << " fin " << previous_fin_sent;
+ DVLOG(1) << "stream " << stream->id() << " bytes_written "
+ << previous_bytes_written << " fin " << previous_fin_sent;
stream->OnCanWrite();
DCHECK(CheckStreamNotBusyLooping(stream, previous_bytes_written,
previous_fin_sent));
@@ -346,14 +343,14 @@
}
void QuicSession::CloseStreamInner(QuicStreamId stream_id, bool locally_reset) {
- QUIC_DLOG(INFO) << ENDPOINT << "Closing stream " << stream_id;
+ DVLOG(1) << ENDPOINT << "Closing stream " << stream_id;
DynamicStreamMap::iterator it = dynamic_stream_map_.find(stream_id);
if (it == dynamic_stream_map_.end()) {
// When CloseStreamInner has been called recursively (via
// QuicStream::OnClose), the stream will already have been deleted
// from stream_map_, so return immediately.
- QUIC_DLOG(INFO) << ENDPOINT << "Stream is already closed: " << stream_id;
+ DVLOG(1) << ENDPOINT << "Stream is already closed: " << stream_id;
return;
}
QuicStream* stream = it->second.get();
@@ -398,8 +395,8 @@
return;
}
- QUIC_DVLOG(1) << ENDPOINT << "Received final byte offset "
- << final_byte_offset << " for stream " << stream_id;
+ DVLOG(1) << ENDPOINT << "Received final byte offset " << final_byte_offset
+ << " for stream " << stream_id;
QuicByteCount offset_diff = final_byte_offset - it->second;
if (flow_controller_.UpdateHighestReceivedOffset(
flow_controller_.highest_received_byte_offset() + offset_diff)) {
@@ -503,12 +500,11 @@
config_.GetInitialStreamFlowControlWindowToSend()
: 1.5;
- QUIC_DVLOG(1) << ENDPOINT << "Set stream receive window to " << stream_window;
+ DVLOG(1) << ENDPOINT << "Set stream receive window to " << stream_window;
config_.SetInitialStreamFlowControlWindowToSend(stream_window);
size_t session_window = session_window_multiplier * stream_window;
- QUIC_DVLOG(1) << ENDPOINT << "Set session receive window to "
- << session_window;
+ DVLOG(1) << ENDPOINT << "Set session receive window to " << session_window;
config_.SetInitialSessionFlowControlWindowToSend(session_window);
flow_controller_.UpdateReceiveWindowSize(session_window);
// Inform all existing streams about the new window.
@@ -545,9 +541,9 @@
void QuicSession::OnNewStreamFlowControlWindow(QuicStreamOffset new_window) {
if (new_window < kMinimumFlowControlSendWindow) {
- QUIC_LOG_FIRST_N(ERROR, 1)
- << "Peer sent us an invalid stream flow control send window: "
- << new_window << ", below default: " << kMinimumFlowControlSendWindow;
+ LOG(ERROR) << "Peer sent us an invalid stream flow control send window: "
+ << new_window
+ << ", below default: " << kMinimumFlowControlSendWindow;
if (connection_->connected()) {
connection_->CloseConnection(
QUIC_FLOW_CONTROL_INVALID_WINDOW, "New stream window too low",
@@ -567,9 +563,9 @@
void QuicSession::OnNewSessionFlowControlWindow(QuicStreamOffset new_window) {
if (new_window < kMinimumFlowControlSendWindow) {
- QUIC_LOG_FIRST_N(ERROR, 1)
- << "Peer sent us an invalid session flow control send window: "
- << new_window << ", below default: " << kMinimumFlowControlSendWindow;
+ LOG(ERROR) << "Peer sent us an invalid session flow control send window: "
+ << new_window
+ << ", below default: " << kMinimumFlowControlSendWindow;
if (connection_->connected()) {
connection_->CloseConnection(
QUIC_FLOW_CONTROL_INVALID_WINDOW, "New connection window too low",
@@ -607,7 +603,7 @@
break;
default:
- QUIC_LOG(ERROR) << ENDPOINT << "Got unknown handshake event: " << event;
+ LOG(ERROR) << ENDPOINT << "Got unknown handshake event: " << event;
}
}
@@ -623,8 +619,8 @@
void QuicSession::ActivateStream(std::unique_ptr<QuicStream> stream) {
QuicStreamId stream_id = stream->id();
- QUIC_DLOG(INFO) << ENDPOINT << "num_streams: " << dynamic_stream_map_.size()
- << ". activating " << stream_id;
+ DVLOG(1) << ENDPOINT << "num_streams: " << dynamic_stream_map_.size()
+ << ". activating " << stream_id;
DCHECK(!base::ContainsKey(dynamic_stream_map_, stream_id));
DCHECK(!base::ContainsKey(static_stream_map_, stream_id));
dynamic_stream_map_[stream_id] = std::move(stream);
@@ -673,13 +669,12 @@
size_t new_num_available_streams =
GetNumAvailableStreams() + additional_available_streams;
if (new_num_available_streams > MaxAvailableStreams()) {
- QUIC_DLOG(INFO) << ENDPOINT
- << "Failed to create a new incoming stream with id:"
- << stream_id << ". There are already "
- << GetNumAvailableStreams()
- << " streams available, which would become "
- << new_num_available_streams << ", which exceeds the limit "
- << MaxAvailableStreams() << ".";
+ DVLOG(1) << ENDPOINT
+ << "Failed to create a new incoming stream with id:" << stream_id
+ << ". There are already " << GetNumAvailableStreams()
+ << " streams available, which would become "
+ << new_num_available_streams << ", which exceeds the limit "
+ << MaxAvailableStreams() << ".";
connection()->CloseConnection(
QUIC_TOO_MANY_AVAILABLE_STREAMS,
QuicStrCat(new_num_available_streams, " above ", MaxAvailableStreams()),
@@ -739,16 +734,16 @@
void QuicSession::set_max_open_incoming_streams(
size_t max_open_incoming_streams) {
- QUIC_DVLOG(1) << "Setting max_open_incoming_streams_ to "
- << max_open_incoming_streams;
+ DVLOG(1) << "Setting max_open_incoming_streams_ to "
+ << max_open_incoming_streams;
max_open_incoming_streams_ = max_open_incoming_streams;
- QUIC_DVLOG(1) << "MaxAvailableStreams() became " << MaxAvailableStreams();
+ DVLOG(1) << "MaxAvailableStreams() became " << MaxAvailableStreams();
}
void QuicSession::set_max_open_outgoing_streams(
size_t max_open_outgoing_streams) {
- QUIC_DVLOG(1) << "Setting max_open_outgoing_streams_ to "
- << max_open_outgoing_streams;
+ DVLOG(1) << "Setting max_open_outgoing_streams_ to "
+ << max_open_outgoing_streams;
max_open_outgoing_streams_ = max_open_outgoing_streams;
}
« no previous file with comments | « net/quic/core/quic_server_session_base.cc ('k') | net/quic/core/quic_spdy_session.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698