| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/hpack_header_table.h" | 5 #include "net/spdy/hpack_header_table.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/logging.h" | 9 #include "base/logging.h" |
| 10 #include "net/spdy/hpack_constants.h" | 10 #include "net/spdy/hpack_constants.h" |
| 11 #include "net/spdy/hpack_static_table.h" |
| 11 #include "net/spdy/hpack_string_util.h" | 12 #include "net/spdy/hpack_string_util.h" |
| 12 | 13 |
| 13 namespace net { | 14 namespace net { |
| 14 | 15 |
| 15 using base::StringPiece; | 16 using base::StringPiece; |
| 16 | 17 |
| 17 namespace { | |
| 18 | |
| 19 // An entry in the static table. Must be a POD in order to avoid | |
| 20 // static initializers, i.e. no user-defined constructors or | |
| 21 // destructors. | |
| 22 struct StaticEntry { | |
| 23 const char* const name; | |
| 24 const size_t name_len; | |
| 25 const char* const value; | |
| 26 const size_t value_len; | |
| 27 }; | |
| 28 | |
| 29 // The "constructor" for a StaticEntry that computes the lengths at | |
| 30 // compile time. | |
| 31 #define STATIC_ENTRY(name, value) \ | |
| 32 { name, arraysize(name) - 1, value, arraysize(value) - 1 } | |
| 33 | |
| 34 const StaticEntry kStaticTable[] = { | |
| 35 STATIC_ENTRY(":authority" , ""), // 1 | |
| 36 STATIC_ENTRY(":method" , "GET"), // 2 | |
| 37 STATIC_ENTRY(":method" , "POST"), // 3 | |
| 38 STATIC_ENTRY(":path" , "/"), // 4 | |
| 39 STATIC_ENTRY(":path" , "/index.html"), // 5 | |
| 40 STATIC_ENTRY(":scheme" , "http"), // 6 | |
| 41 STATIC_ENTRY(":scheme" , "https"), // 7 | |
| 42 STATIC_ENTRY(":status" , "200"), // 8 | |
| 43 STATIC_ENTRY(":status" , "204"), // 9 | |
| 44 STATIC_ENTRY(":status" , "206"), // 10 | |
| 45 STATIC_ENTRY(":status" , "304"), // 11 | |
| 46 STATIC_ENTRY(":status" , "400"), // 12 | |
| 47 STATIC_ENTRY(":status" , "404"), // 13 | |
| 48 STATIC_ENTRY(":status" , "500"), // 14 | |
| 49 STATIC_ENTRY("accept-charset" , ""), // 15 | |
| 50 STATIC_ENTRY("accept-encoding" , "gzip, deflate"), // 16 | |
| 51 STATIC_ENTRY("accept-language" , ""), // 17 | |
| 52 STATIC_ENTRY("accept-ranges" , ""), // 18 | |
| 53 STATIC_ENTRY("accept" , ""), // 19 | |
| 54 STATIC_ENTRY("access-control-allow-origin", ""), // 20 | |
| 55 STATIC_ENTRY("age" , ""), // 21 | |
| 56 STATIC_ENTRY("allow" , ""), // 22 | |
| 57 STATIC_ENTRY("authorization" , ""), // 23 | |
| 58 STATIC_ENTRY("cache-control" , ""), // 24 | |
| 59 STATIC_ENTRY("content-disposition" , ""), // 25 | |
| 60 STATIC_ENTRY("content-encoding" , ""), // 26 | |
| 61 STATIC_ENTRY("content-language" , ""), // 27 | |
| 62 STATIC_ENTRY("content-length" , ""), // 28 | |
| 63 STATIC_ENTRY("content-location" , ""), // 29 | |
| 64 STATIC_ENTRY("content-range" , ""), // 30 | |
| 65 STATIC_ENTRY("content-type" , ""), // 31 | |
| 66 STATIC_ENTRY("cookie" , ""), // 32 | |
| 67 STATIC_ENTRY("date" , ""), // 33 | |
| 68 STATIC_ENTRY("etag" , ""), // 34 | |
| 69 STATIC_ENTRY("expect" , ""), // 35 | |
| 70 STATIC_ENTRY("expires" , ""), // 36 | |
| 71 STATIC_ENTRY("from" , ""), // 37 | |
| 72 STATIC_ENTRY("host" , ""), // 38 | |
| 73 STATIC_ENTRY("if-match" , ""), // 39 | |
| 74 STATIC_ENTRY("if-modified-since" , ""), // 40 | |
| 75 STATIC_ENTRY("if-none-match" , ""), // 41 | |
| 76 STATIC_ENTRY("if-range" , ""), // 42 | |
| 77 STATIC_ENTRY("if-unmodified-since" , ""), // 43 | |
| 78 STATIC_ENTRY("last-modified" , ""), // 44 | |
| 79 STATIC_ENTRY("link" , ""), // 45 | |
| 80 STATIC_ENTRY("location" , ""), // 46 | |
| 81 STATIC_ENTRY("max-forwards" , ""), // 47 | |
| 82 STATIC_ENTRY("proxy-authenticate" , ""), // 48 | |
| 83 STATIC_ENTRY("proxy-authorization" , ""), // 49 | |
| 84 STATIC_ENTRY("range" , ""), // 50 | |
| 85 STATIC_ENTRY("referer" , ""), // 51 | |
| 86 STATIC_ENTRY("refresh" , ""), // 52 | |
| 87 STATIC_ENTRY("retry-after" , ""), // 53 | |
| 88 STATIC_ENTRY("server" , ""), // 54 | |
| 89 STATIC_ENTRY("set-cookie" , ""), // 55 | |
| 90 STATIC_ENTRY("strict-transport-security" , ""), // 56 | |
| 91 STATIC_ENTRY("transfer-encoding" , ""), // 57 | |
| 92 STATIC_ENTRY("user-agent" , ""), // 58 | |
| 93 STATIC_ENTRY("vary" , ""), // 59 | |
| 94 STATIC_ENTRY("via" , ""), // 60 | |
| 95 STATIC_ENTRY("www-authenticate" , ""), // 61 | |
| 96 }; | |
| 97 | |
| 98 #undef STATIC_ENTRY | |
| 99 | |
| 100 } // namespace | |
| 101 | |
| 102 bool HpackHeaderTable::EntryComparator::operator() ( | 18 bool HpackHeaderTable::EntryComparator::operator() ( |
| 103 const HpackEntry* lhs, const HpackEntry* rhs) const { | 19 const HpackEntry* lhs, const HpackEntry* rhs) const { |
| 104 int result = lhs->name().compare(rhs->name()); | 20 int result = lhs->name().compare(rhs->name()); |
| 105 if (result != 0) | 21 if (result != 0) |
| 106 return result < 0; | 22 return result < 0; |
| 107 result = lhs->value().compare(rhs->value()); | 23 result = lhs->value().compare(rhs->value()); |
| 108 if (result != 0) | 24 if (result != 0) |
| 109 return result < 0; | 25 return result < 0; |
| 110 const size_t lhs_index = table_->IndexOf(lhs); | 26 const size_t lhs_index = lhs->IsLookup() ? 0 : 1 + lhs->InsertionIndex(); |
| 111 const size_t rhs_index = table_->IndexOf(rhs); | 27 const size_t rhs_index = rhs->IsLookup() ? 0 : 1 + rhs->InsertionIndex(); |
| 112 DCHECK(lhs == rhs || lhs_index != rhs_index) | 28 DCHECK(lhs == rhs || lhs_index != rhs_index) |
| 113 << "lhs: (" << lhs->name() << ", " << rhs->value() << ") rhs: (" | 29 << "lhs: (" << lhs->name() << ", " << rhs->value() << ") rhs: (" |
| 114 << rhs->name() << ", " << rhs->value() << ")" | 30 << rhs->name() << ", " << rhs->value() << ")" |
| 115 << " lhs index: " << lhs_index << " rhs index: " << rhs_index; | 31 << " lhs index: " << lhs_index << " rhs index: " << rhs_index; |
| 116 return lhs_index < rhs_index; | 32 return lhs_index < rhs_index; |
| 117 } | 33 } |
| 118 | 34 |
| 119 HpackHeaderTable::HpackHeaderTable() | 35 HpackHeaderTable::HpackHeaderTable() |
| 120 : index_(EntryComparator(this)), | 36 : static_entries_(ObtainHpackStaticTable().GetStaticEntries()), |
| 37 static_index_(ObtainHpackStaticTable().GetStaticIndex()), |
| 121 settings_size_bound_(kDefaultHeaderTableSizeSetting), | 38 settings_size_bound_(kDefaultHeaderTableSizeSetting), |
| 122 size_(0), | 39 size_(0), |
| 123 max_size_(kDefaultHeaderTableSizeSetting), | 40 max_size_(kDefaultHeaderTableSizeSetting), |
| 124 total_insertions_(0) { | 41 total_insertions_(static_entries_.size()) {} |
| 125 for (const StaticEntry* it = kStaticTable; | |
| 126 it != kStaticTable + arraysize(kStaticTable); ++it) { | |
| 127 static_entries_.push_back( | |
| 128 HpackEntry(StringPiece(it->name, it->name_len), | |
| 129 StringPiece(it->value, it->value_len), | |
| 130 true, // is_static | |
| 131 total_insertions_)); | |
| 132 CHECK(index_.insert(&static_entries_.back()).second); | |
| 133 | |
| 134 ++total_insertions_; | |
| 135 } | |
| 136 } | |
| 137 | 42 |
| 138 HpackHeaderTable::~HpackHeaderTable() {} | 43 HpackHeaderTable::~HpackHeaderTable() {} |
| 139 | 44 |
| 140 HpackEntry* HpackHeaderTable::GetByIndex(size_t index) { | 45 const HpackEntry* HpackHeaderTable::GetByIndex(size_t index) { |
| 141 if (index == 0) { | 46 if (index == 0) { |
| 142 return NULL; | 47 return NULL; |
| 143 } | 48 } |
| 144 index -= 1; | 49 index -= 1; |
| 145 if (index < static_entries_.size()) { | 50 if (index < static_entries_.size()) { |
| 146 return &static_entries_[index]; | 51 return &static_entries_[index]; |
| 147 } | 52 } |
| 148 index -= static_entries_.size(); | 53 index -= static_entries_.size(); |
| 149 if (index < dynamic_entries_.size()) { | 54 if (index < dynamic_entries_.size()) { |
| 150 return &dynamic_entries_[index]; | 55 return &dynamic_entries_[index]; |
| 151 } | 56 } |
| 152 return NULL; | 57 return NULL; |
| 153 } | 58 } |
| 154 | 59 |
| 155 HpackEntry* HpackHeaderTable::GetByName(StringPiece name) { | 60 const HpackEntry* HpackHeaderTable::GetByName(StringPiece name) { |
| 156 HpackEntry query(name, ""); | 61 HpackEntry query(name, ""); |
| 157 OrderedEntrySet::const_iterator it = index_.lower_bound(&query); | 62 { |
| 158 if (it != index_.end() && (*it)->name() == name) { | 63 OrderedEntrySet::const_iterator it = static_index_.lower_bound(&query); |
| 159 return *it; | 64 if (it != static_index_.end() && (*it)->name() == name) { |
| 65 return *it; |
| 66 } |
| 67 } |
| 68 { |
| 69 OrderedEntrySet::const_iterator it = dynamic_index_.lower_bound(&query); |
| 70 if (it != dynamic_index_.end() && (*it)->name() == name) { |
| 71 return *it; |
| 72 } |
| 160 } | 73 } |
| 161 return NULL; | 74 return NULL; |
| 162 } | 75 } |
| 163 | 76 |
| 164 HpackEntry* HpackHeaderTable::GetByNameAndValue(StringPiece name, | 77 const HpackEntry* HpackHeaderTable::GetByNameAndValue(StringPiece name, |
| 165 StringPiece value) { | 78 StringPiece value) { |
| 166 HpackEntry query(name, value); | 79 HpackEntry query(name, value); |
| 167 OrderedEntrySet::const_iterator it = index_.lower_bound(&query); | 80 { |
| 168 if (it != index_.end() && (*it)->name() == name && (*it)->value() == value) { | 81 OrderedEntrySet::const_iterator it = static_index_.lower_bound(&query); |
| 169 return *it; | 82 if (it != static_index_.end() && |
| 83 (*it)->name() == name && |
| 84 (*it)->value() == value) { |
| 85 return *it; |
| 86 } |
| 87 } |
| 88 { |
| 89 OrderedEntrySet::const_iterator it = dynamic_index_.lower_bound(&query); |
| 90 if (it != dynamic_index_.end() && |
| 91 (*it)->name() == name && |
| 92 (*it)->value() == value) { |
| 93 return *it; |
| 94 } |
| 170 } | 95 } |
| 171 return NULL; | 96 return NULL; |
| 172 } | 97 } |
| 173 | 98 |
| 174 size_t HpackHeaderTable::IndexOf(const HpackEntry* entry) const { | 99 size_t HpackHeaderTable::IndexOf(const HpackEntry* entry) const { |
| 175 if (entry->IsLookup()) { | 100 if (entry->IsLookup()) { |
| 176 return 0; | 101 return 0; |
| 177 } else if (entry->IsStatic()) { | 102 } else if (entry->IsStatic()) { |
| 178 return 1 + entry->InsertionIndex(); | 103 return 1 + entry->InsertionIndex(); |
| 179 } else { | 104 } else { |
| (...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 227 } | 152 } |
| 228 return count; | 153 return count; |
| 229 } | 154 } |
| 230 | 155 |
| 231 void HpackHeaderTable::Evict(size_t count) { | 156 void HpackHeaderTable::Evict(size_t count) { |
| 232 for (size_t i = 0; i != count; ++i) { | 157 for (size_t i = 0; i != count; ++i) { |
| 233 CHECK(!dynamic_entries_.empty()); | 158 CHECK(!dynamic_entries_.empty()); |
| 234 HpackEntry* entry = &dynamic_entries_.back(); | 159 HpackEntry* entry = &dynamic_entries_.back(); |
| 235 | 160 |
| 236 size_ -= entry->Size(); | 161 size_ -= entry->Size(); |
| 237 CHECK_EQ(1u, index_.erase(entry)); | 162 CHECK_EQ(1u, dynamic_index_.erase(entry)); |
| 238 dynamic_entries_.pop_back(); | 163 dynamic_entries_.pop_back(); |
| 239 } | 164 } |
| 240 } | 165 } |
| 241 | 166 |
| 242 HpackEntry* HpackHeaderTable::TryAddEntry(StringPiece name, StringPiece value) { | 167 const HpackEntry* HpackHeaderTable::TryAddEntry(StringPiece name, |
| 168 StringPiece value) { |
| 243 Evict(EvictionCountForEntry(name, value)); | 169 Evict(EvictionCountForEntry(name, value)); |
| 244 | 170 |
| 245 size_t entry_size = HpackEntry::Size(name, value); | 171 size_t entry_size = HpackEntry::Size(name, value); |
| 246 if (entry_size > (max_size_ - size_)) { | 172 if (entry_size > (max_size_ - size_)) { |
| 247 // Entire table has been emptied, but there's still insufficient room. | 173 // Entire table has been emptied, but there's still insufficient room. |
| 248 DCHECK(dynamic_entries_.empty()); | 174 DCHECK(dynamic_entries_.empty()); |
| 249 DCHECK_EQ(0u, size_); | 175 DCHECK_EQ(0u, size_); |
| 250 return NULL; | 176 return NULL; |
| 251 } | 177 } |
| 252 dynamic_entries_.push_front(HpackEntry(name, | 178 dynamic_entries_.push_front(HpackEntry(name, |
| 253 value, | 179 value, |
| 254 false, // is_static | 180 false, // is_static |
| 255 total_insertions_)); | 181 total_insertions_)); |
| 256 CHECK(index_.insert(&dynamic_entries_.front()).second); | 182 CHECK(dynamic_index_.insert(&dynamic_entries_.front()).second); |
| 257 | 183 |
| 258 size_ += entry_size; | 184 size_ += entry_size; |
| 259 ++total_insertions_; | 185 ++total_insertions_; |
| 260 | 186 |
| 261 return &dynamic_entries_.front(); | 187 return &dynamic_entries_.front(); |
| 262 } | 188 } |
| 263 | 189 |
| 264 void HpackHeaderTable::DebugLogTableState() const { | 190 void HpackHeaderTable::DebugLogTableState() const { |
| 265 DVLOG(2) << "Dynamic table:"; | 191 DVLOG(2) << "Dynamic table:"; |
| 266 for (EntryTable::const_iterator it = dynamic_entries_.begin(); | 192 for (EntryTable::const_iterator it = dynamic_entries_.begin(); |
| 267 it != dynamic_entries_.end(); ++it) { | 193 it != dynamic_entries_.end(); ++it) { |
| 268 DVLOG(2) << " " << it->GetDebugString(); | 194 DVLOG(2) << " " << it->GetDebugString(); |
| 269 } | 195 } |
| 270 DVLOG(2) << "Full Index:"; | 196 DVLOG(2) << "Full Static Index:"; |
| 271 for (OrderedEntrySet::const_iterator it = index_.begin(); | 197 for (OrderedEntrySet::const_iterator it = static_index_.begin(); |
| 272 it != index_.end(); ++it) { | 198 it != static_index_.end(); ++it) { |
| 199 DVLOG(2) << " " << (*it)->GetDebugString(); |
| 200 } |
| 201 DVLOG(2) << "Full Dynamic Index:"; |
| 202 for (OrderedEntrySet::const_iterator it = dynamic_index_.begin(); |
| 203 it != dynamic_index_.end(); ++it) { |
| 273 DVLOG(2) << " " << (*it)->GetDebugString(); | 204 DVLOG(2) << " " << (*it)->GetDebugString(); |
| 274 } | 205 } |
| 275 } | 206 } |
| 276 | 207 |
| 277 } // namespace net | 208 } // namespace net |
| OLD | NEW |