OLD | NEW |
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 Loading... |
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 Loading... |
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 |
OLD | NEW |