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

Unified Diff: net/spdy/spdy_session.cc

Issue 10185007: [net] Change order of RequestPriority to natural: higher > lower (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Use MINIMUM_PRIORITY instead of 0. Created 8 years, 8 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
Index: net/spdy/spdy_session.cc
diff --git a/net/spdy/spdy_session.cc b/net/spdy/spdy_session.cc
index be67c993506402d5d4d75a53da3d3898c25f495c..612e3a4233bee63b9df58482e12c43ad36c768ea 100644
--- a/net/spdy/spdy_session.cc
+++ b/net/spdy/spdy_session.cc
@@ -535,7 +535,7 @@ void SpdySession::ProcessPendingCreateStreams() {
while (!max_concurrent_streams_ ||
active_streams_.size() < max_concurrent_streams_) {
bool no_pending_create_streams = true;
- for (int i = 0;i < NUM_PRIORITIES;++i) {
+ for (int i = NUM_PRIORITIES - 1; i >= MINIMUM_PRIORITY; --i) {
if (!create_stream_queues_[i].empty()) {
PendingCreateStream pending_create = create_stream_queues_[i].front();
create_stream_queues_[i].pop();
@@ -568,7 +568,7 @@ void SpdySession::CancelPendingCreateStreams(
return;
}
- for (int i = 0;i < NUM_PRIORITIES;++i) {
+ for (int i = 0; i < NUM_PRIORITIES; ++i) {
Ryan Hamilton 2012/04/23 22:51:05 Should this loop be reversed too, like the previou
szym 2012/04/24 00:19:31 This loop is order-agnostic. It goes through all e
PendingCreateStreamQueue tmp;
// Make a copy removing this trans
while (!create_stream_queues_[i].empty()) {
@@ -590,6 +590,9 @@ int SpdySession::CreateStreamImpl(
RequestPriority priority,
scoped_refptr<SpdyStream>* spdy_stream,
const BoundNetLog& stream_net_log) {
+ DCHECK_GE(priority, net::MINIMUM_PRIORITY);
Ryan Hamilton 2012/04/23 22:51:05 nit: no need for net:: prefix
szym 2012/04/24 00:19:31 Agreed.
+ DCHECK_LT(priority, net::NUM_PRIORITIES);
+
// Make sure that we don't try to send https/wss over an unauthenticated, but
// encrypted SSL socket.
if (is_secure_ && certificate_error_code_ != OK &&
@@ -622,7 +625,6 @@ int SpdySession::CreateStreamImpl(
static_cast<int>(priority), 0, 10, 11);
// TODO(mbelshe): Optimize memory allocations
- DCHECK(priority >= net::HIGHEST && priority < net::NUM_PRIORITIES);
DCHECK_EQ(active_streams_[stream_id].get(), stream.get());
return OK;
@@ -834,7 +836,7 @@ void SpdySession::ResetStream(SpdyStreamId stream_id,
buffered_spdy_framer_->CreateRstStream(stream_id, status));
// Default to lowest priority unless we know otherwise.
- int priority = 3;
+ RequestPriority priority = net::IDLE;
Ryan Hamilton 2012/04/23 22:51:05 nit: no need for net::
szym 2012/04/24 00:19:31 net::IDLE is shadowed by enum SpdySession::State I
Ryan Hamilton 2012/04/24 00:42:11 I see. *shakes fist at C++* I'm looking fwd to c
Ryan Hamilton 2012/04/24 00:42:11 I see. *shakes fist at C++* I'm looking fwd to c
if(IsStreamActive(stream_id)) {
scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
priority = stream->priority();
@@ -1092,7 +1094,7 @@ void SpdySession::CloseAllStreams(net::Error status) {
unclaimed_pushed_streams_.clear();
}
- for (int i = 0;i < NUM_PRIORITIES;++i) {
+ for (int i = 0; i < NUM_PRIORITIES; ++i) {
Ryan Hamilton 2012/04/23 22:51:05 Same question about reversing the loop
szym 2012/04/24 00:19:31 Same answer. Order-agnostic, unless the order of c
Ryan Hamilton 2012/04/24 00:42:11 Gotcha. That makes sense.
while (!create_stream_queues_[i].empty()) {
PendingCreateStream pending_create = create_stream_queues_[i].front();
create_stream_queues_[i].pop();
@@ -1124,7 +1126,7 @@ int SpdySession::GetNewStreamId() {
}
void SpdySession::QueueFrame(SpdyFrame* frame,
- SpdyPriority priority,
+ RequestPriority priority,
SpdyStream* stream) {
int length = SpdyFrame::kHeaderSize + frame->length();
IOBuffer* buffer = new IOBuffer(length);
@@ -1739,7 +1741,7 @@ void SpdySession::SendSettings() {
scoped_ptr<SpdySettingsControlFrame> settings_frame(
buffered_spdy_framer_->CreateSettings(settings_map_new));
sent_settings_ = true;
- QueueFrame(settings_frame.get(), 0, NULL);
+ QueueFrame(settings_frame.get(), HIGHEST, NULL);
}
void SpdySession::HandleSetting(uint32 id, uint32 value) {
@@ -1816,8 +1818,7 @@ void SpdySession::WritePingFrame(uint32 unique_id) {
DCHECK(buffered_spdy_framer_.get());
scoped_ptr<SpdyPingControlFrame> ping_frame(
buffered_spdy_framer_->CreatePingFrame(next_ping_id_));
- QueueFrame(
- ping_frame.get(), buffered_spdy_framer_->GetHighestPriority(), NULL);
+ QueueFrame(ping_frame.get(), HIGHEST, NULL);
if (net_log().IsLoggingAllEvents()) {
net_log().AddEvent(

Powered by Google App Engine
This is Rietveld 408576698