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

Side by Side Diff: net/spdy/spdy_session.cc

Issue 10821086: Fix bug in SpdySession (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix sleevi comments. Created 8 years, 4 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 unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « no previous file | net/spdy/spdy_session_spdy2_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 <map> 7 #include <map>
8 8
9 #include "base/basictypes.h" 9 #include "base/basictypes.h"
10 #include "base/bind.h" 10 #include "base/bind.h"
(...skipping 998 matching lines...) Expand 10 before | Expand all | Expand 10 after
1009 1009
1010 while (!active_streams_.empty()) { 1010 while (!active_streams_.empty()) {
1011 ActiveStreamMap::iterator it = active_streams_.begin(); 1011 ActiveStreamMap::iterator it = active_streams_.begin();
1012 const scoped_refptr<SpdyStream>& stream = it->second; 1012 const scoped_refptr<SpdyStream>& stream = it->second;
1013 LogAbandonedStream(stream, status); 1013 LogAbandonedStream(stream, status);
1014 DeleteStream(stream->stream_id(), status); 1014 DeleteStream(stream->stream_id(), status);
1015 } 1015 }
1016 1016
1017 while (!created_streams_.empty()) { 1017 while (!created_streams_.empty()) {
1018 CreatedStreamSet::iterator it = created_streams_.begin(); 1018 CreatedStreamSet::iterator it = created_streams_.begin();
1019 const scoped_refptr<SpdyStream>& stream = *it; 1019 const scoped_refptr<SpdyStream> stream = *it;
1020 created_streams_.erase(it);
1020 LogAbandonedStream(stream, status); 1021 LogAbandonedStream(stream, status);
1021 stream->OnClose(status); 1022 stream->OnClose(status);
1022 created_streams_.erase(it);
1023 } 1023 }
1024 1024
1025 // We also need to drain the queue. 1025 // We also need to drain the queue.
1026 while (!write_queue_.empty()) { 1026 while (!write_queue_.empty()) {
1027 scoped_ptr<SpdyIOBufferProducer> producer(write_queue_.top()); 1027 scoped_ptr<SpdyIOBufferProducer> producer(write_queue_.top());
1028 write_queue_.pop(); 1028 write_queue_.pop();
1029 stream_producers_.erase(producer.get()); 1029 stream_producers_.erase(producer.get());
1030 } 1030 }
1031 } 1031 }
1032 1032
(...skipping 937 matching lines...) Expand 10 before | Expand all | Expand 10 after
1970 SSLClientSocket* SpdySession::GetSSLClientSocket() const { 1970 SSLClientSocket* SpdySession::GetSSLClientSocket() const {
1971 if (!is_secure_) 1971 if (!is_secure_)
1972 return NULL; 1972 return NULL;
1973 SSLClientSocket* ssl_socket = 1973 SSLClientSocket* ssl_socket =
1974 reinterpret_cast<SSLClientSocket*>(connection_->socket()); 1974 reinterpret_cast<SSLClientSocket*>(connection_->socket());
1975 DCHECK(ssl_socket); 1975 DCHECK(ssl_socket);
1976 return ssl_socket; 1976 return ssl_socket;
1977 } 1977 }
1978 1978
1979 } // namespace net 1979 } // namespace net
OLDNEW
« no previous file with comments | « no previous file | net/spdy/spdy_session_spdy2_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698