| 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 |