| 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/quic/quic_session.h" | 5 #include "net/quic/quic_session.h" |
| 6 | 6 |
| 7 #include "net/quic/quic_connection.h" | 7 #include "net/quic/quic_connection.h" |
| 8 | 8 |
| 9 using base::StringPiece; | 9 using base::StringPiece; |
| 10 using base::hash_map; | 10 using base::hash_map; |
| (...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 91 DLOG(INFO) << "Closing stream " << stream_id; | 91 DLOG(INFO) << "Closing stream " << stream_id; |
| 92 | 92 |
| 93 ReliableStreamMap::iterator it = stream_map_.find(stream_id); | 93 ReliableStreamMap::iterator it = stream_map_.find(stream_id); |
| 94 if (it == stream_map_.end()) { | 94 if (it == stream_map_.end()) { |
| 95 DLOG(INFO) << "Stream is already closed: " << stream_id; | 95 DLOG(INFO) << "Stream is already closed: " << stream_id; |
| 96 return; | 96 return; |
| 97 } | 97 } |
| 98 stream_map_.erase(it); | 98 stream_map_.erase(it); |
| 99 } | 99 } |
| 100 | 100 |
| 101 bool QuicSession::IsHandshakeComplete() { | 101 bool QuicSession::IsCryptoHandshakeComplete() { |
| 102 return GetCryptoStream()->handshake_complete(); | 102 return GetCryptoStream()->handshake_complete(); |
| 103 } | 103 } |
| 104 | 104 |
| 105 void QuicSession::OnCryptoHandshakeComplete(QuicErrorCode error) { |
| 106 // TODO(rch): tear down the connection if error != QUIC_NO_ERROR. |
| 107 } |
| 108 |
| 105 void QuicSession::ActivateStream(ReliableQuicStream* stream) { | 109 void QuicSession::ActivateStream(ReliableQuicStream* stream) { |
| 106 LOG(INFO) << "num_streams: " << stream_map_.size() | 110 LOG(INFO) << "num_streams: " << stream_map_.size() |
| 107 << ". activating " << stream->id(); | 111 << ". activating " << stream->id(); |
| 108 DCHECK(stream_map_.count(stream->id()) == 0); | 112 DCHECK(stream_map_.count(stream->id()) == 0); |
| 109 stream_map_[stream->id()] = stream; | 113 stream_map_[stream->id()] = stream; |
| 110 } | 114 } |
| 111 | 115 |
| 112 QuicStreamId QuicSession::GetNextStreamId() { | 116 QuicStreamId QuicSession::GetNextStreamId() { |
| 113 QuicStreamId id = next_stream_id_; | 117 QuicStreamId id = next_stream_id_; |
| 114 next_stream_id_ += 2; | 118 next_stream_id_ += 2; |
| (...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 183 // streams. | 187 // streams. |
| 184 return id <= largest_peer_created_stream_id_ && | 188 return id <= largest_peer_created_stream_id_ && |
| 185 implicitly_created_streams_.count(id) == 0; | 189 implicitly_created_streams_.count(id) == 0; |
| 186 } | 190 } |
| 187 | 191 |
| 188 size_t QuicSession::GetNumOpenStreams() { | 192 size_t QuicSession::GetNumOpenStreams() { |
| 189 return stream_map_.size() + implicitly_created_streams_.size(); | 193 return stream_map_.size() + implicitly_created_streams_.size(); |
| 190 } | 194 } |
| 191 | 195 |
| 192 } // namespace net | 196 } // namespace net |
| OLD | NEW |