| 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_chromium_client_session.h" | 5 #include "net/quic/quic_chromium_client_session.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/callback_helpers.h" | 9 #include "base/callback_helpers.h" |
| 10 #include "base/location.h" | 10 #include "base/location.h" |
| (...skipping 872 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 883 observer->OnSessionClosed(net_error); | 883 observer->OnSessionClosed(net_error); |
| 884 } | 884 } |
| 885 } | 885 } |
| 886 | 886 |
| 887 scoped_ptr<base::Value> QuicChromiumClientSession::GetInfoAsValue( | 887 scoped_ptr<base::Value> QuicChromiumClientSession::GetInfoAsValue( |
| 888 const std::set<HostPortPair>& aliases) { | 888 const std::set<HostPortPair>& aliases) { |
| 889 scoped_ptr<base::DictionaryValue> dict(new base::DictionaryValue()); | 889 scoped_ptr<base::DictionaryValue> dict(new base::DictionaryValue()); |
| 890 dict->SetString("version", QuicVersionToString(connection()->version())); | 890 dict->SetString("version", QuicVersionToString(connection()->version())); |
| 891 dict->SetInteger("open_streams", GetNumOpenOutgoingStreams()); | 891 dict->SetInteger("open_streams", GetNumOpenOutgoingStreams()); |
| 892 scoped_ptr<base::ListValue> stream_list(new base::ListValue()); | 892 scoped_ptr<base::ListValue> stream_list(new base::ListValue()); |
| 893 for (base::hash_map<QuicStreamId, ReliableQuicStream*>::const_iterator it = | 893 for (StreamMap::const_iterator it = dynamic_streams().begin(); |
| 894 dynamic_streams().begin(); | |
| 895 it != dynamic_streams().end(); ++it) { | 894 it != dynamic_streams().end(); ++it) { |
| 896 stream_list->Append( | 895 stream_list->Append( |
| 897 new base::StringValue(base::UintToString(it->second->id()))); | 896 new base::StringValue(base::UintToString(it->second->id()))); |
| 898 } | 897 } |
| 899 dict->Set("active_streams", std::move(stream_list)); | 898 dict->Set("active_streams", std::move(stream_list)); |
| 900 | 899 |
| 901 dict->SetInteger("total_streams", num_total_streams_); | 900 dict->SetInteger("total_streams", num_total_streams_); |
| 902 dict->SetString("peer_address", peer_address().ToString()); | 901 dict->SetString("peer_address", peer_address().ToString()); |
| 903 dict->SetString("connection_id", base::Uint64ToString(connection_id())); | 902 dict->SetString("connection_id", base::Uint64ToString(connection_id())); |
| 904 dict->SetBoolean("connected", connection()->connected()); | 903 dict->SetBoolean("connected", connection()->connected()); |
| (...skipping 114 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1019 } | 1018 } |
| 1020 | 1019 |
| 1021 const DatagramClientSocket* QuicChromiumClientSession::GetDefaultSocket() | 1020 const DatagramClientSocket* QuicChromiumClientSession::GetDefaultSocket() |
| 1022 const { | 1021 const { |
| 1023 DCHECK(sockets_.back().get() != nullptr); | 1022 DCHECK(sockets_.back().get() != nullptr); |
| 1024 // The most recently added socket is the currently active one. | 1023 // The most recently added socket is the currently active one. |
| 1025 return sockets_.back().get(); | 1024 return sockets_.back().get(); |
| 1026 } | 1025 } |
| 1027 | 1026 |
| 1028 } // namespace net | 1027 } // namespace net |
| OLD | NEW |