OLD | NEW |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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 "content/browser/indexed_db/indexed_db_backing_store.h" | 5 #include "content/browser/indexed_db/indexed_db_backing_store.h" |
6 | 6 |
7 #include <string> | |
8 | |
9 #include "base/file_util.h" | 7 #include "base/file_util.h" |
10 #include "base/logging.h" | 8 #include "base/logging.h" |
11 #include "base/metrics/histogram.h" | 9 #include "base/metrics/histogram.h" |
12 #include "base/strings/string_piece.h" | 10 #include "base/strings/string_piece.h" |
13 #include "base/strings/utf_string_conversions.h" | 11 #include "base/strings/utf_string_conversions.h" |
14 #include "content/browser/indexed_db/indexed_db_leveldb_coding.h" | 12 #include "content/browser/indexed_db/indexed_db_leveldb_coding.h" |
15 #include "content/browser/indexed_db/indexed_db_metadata.h" | 13 #include "content/browser/indexed_db/indexed_db_metadata.h" |
16 #include "content/browser/indexed_db/indexed_db_tracing.h" | 14 #include "content/browser/indexed_db/indexed_db_tracing.h" |
17 #include "content/browser/indexed_db/leveldb/leveldb_comparator.h" | 15 #include "content/browser/indexed_db/leveldb/leveldb_comparator.h" |
18 #include "content/browser/indexed_db/leveldb/leveldb_database.h" | 16 #include "content/browser/indexed_db/leveldb/leveldb_database.h" |
19 #include "content/browser/indexed_db/leveldb/leveldb_iterator.h" | 17 #include "content/browser/indexed_db/leveldb/leveldb_iterator.h" |
20 #include "content/browser/indexed_db/leveldb/leveldb_slice.h" | |
21 #include "content/browser/indexed_db/leveldb/leveldb_transaction.h" | 18 #include "content/browser/indexed_db/leveldb/leveldb_transaction.h" |
22 #include "content/common/indexed_db/indexed_db_key.h" | 19 #include "content/common/indexed_db/indexed_db_key.h" |
23 #include "content/common/indexed_db/indexed_db_key_path.h" | 20 #include "content/common/indexed_db/indexed_db_key_path.h" |
24 #include "content/common/indexed_db/indexed_db_key_range.h" | 21 #include "content/common/indexed_db/indexed_db_key_range.h" |
25 #include "third_party/WebKit/public/platform/WebIDBKey.h" | 22 #include "third_party/WebKit/public/platform/WebIDBKey.h" |
26 #include "third_party/WebKit/public/platform/WebIDBKeyPath.h" | 23 #include "third_party/WebKit/public/platform/WebIDBKeyPath.h" |
27 | 24 |
28 using base::StringPiece; | 25 using base::StringPiece; |
29 | 26 |
30 // TODO(jsbell): Make blink push the version during the open() call. | 27 // TODO(jsbell): Make blink push the version during the open() call. |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
81 NOTREACHED(); \ | 78 NOTREACHED(); \ |
82 RecordInternalError(type, location); \ | 79 RecordInternalError(type, location); \ |
83 } while (0) | 80 } while (0) |
84 | 81 |
85 #define INTERNAL_READ_ERROR(location) REPORT_ERROR("Read", location) | 82 #define INTERNAL_READ_ERROR(location) REPORT_ERROR("Read", location) |
86 #define INTERNAL_CONSISTENCY_ERROR(location) \ | 83 #define INTERNAL_CONSISTENCY_ERROR(location) \ |
87 REPORT_ERROR("Consistency", location) | 84 REPORT_ERROR("Consistency", location) |
88 #define INTERNAL_WRITE_ERROR(location) REPORT_ERROR("Write", location) | 85 #define INTERNAL_WRITE_ERROR(location) REPORT_ERROR("Write", location) |
89 | 86 |
90 static void PutBool(LevelDBTransaction* transaction, | 87 static void PutBool(LevelDBTransaction* transaction, |
91 const LevelDBSlice& key, | 88 const StringPiece& key, |
92 bool value) { | 89 bool value) { |
93 std::vector<char> buffer; | 90 std::string buffer; |
94 EncodeBool(value, &buffer); | 91 EncodeBool(value, &buffer); |
95 transaction->Put(key, &buffer); | 92 transaction->Put(key, &buffer); |
96 } | 93 } |
97 | 94 |
98 template <typename DBOrTransaction> | 95 template <typename DBOrTransaction> |
99 static bool GetInt(DBOrTransaction* db, | 96 static bool GetInt(DBOrTransaction* db, |
100 const LevelDBSlice& key, | 97 const StringPiece& key, |
101 int64* found_int, | 98 int64* found_int, |
102 bool* found) { | 99 bool* found) { |
103 std::string result; | 100 std::string result; |
104 bool ok = db->Get(key, &result, found); | 101 bool ok = db->Get(key, &result, found); |
105 if (!ok) | 102 if (!ok) |
106 return false; | 103 return false; |
107 if (!*found) | 104 if (!*found) |
108 return true; | 105 return true; |
109 StringPiece slice(result); | 106 StringPiece slice(result); |
110 return DecodeInt(&slice, found_int) && slice.empty(); | 107 return DecodeInt(&slice, found_int) && slice.empty(); |
111 } | 108 } |
112 | 109 |
113 static void PutInt(LevelDBTransaction* transaction, | 110 static void PutInt(LevelDBTransaction* transaction, |
114 const LevelDBSlice& key, | 111 const StringPiece& key, |
115 int64 value) { | 112 int64 value) { |
116 DCHECK_GE(value, 0); | 113 DCHECK_GE(value, 0); |
117 std::vector<char> buffer; | 114 std::string buffer; |
118 EncodeInt(value, &buffer); | 115 EncodeInt(value, &buffer); |
119 transaction->Put(key, &buffer); | 116 transaction->Put(key, &buffer); |
120 } | 117 } |
121 | 118 |
122 template <typename DBOrTransaction> | 119 template <typename DBOrTransaction> |
123 WARN_UNUSED_RESULT static bool GetVarInt(DBOrTransaction* db, | 120 WARN_UNUSED_RESULT static bool GetVarInt(DBOrTransaction* db, |
124 const LevelDBSlice& key, | 121 const StringPiece& key, |
125 int64* found_int, | 122 int64* found_int, |
126 bool* found) { | 123 bool* found) { |
127 std::string result; | 124 std::string result; |
128 bool ok = db->Get(key, &result, found); | 125 bool ok = db->Get(key, &result, found); |
129 if (!ok) | 126 if (!ok) |
130 return false; | 127 return false; |
131 if (!*found) | 128 if (!*found) |
132 return true; | 129 return true; |
133 StringPiece slice(result); | 130 StringPiece slice(result); |
134 return DecodeVarInt(&slice, found_int) && slice.empty(); | 131 return DecodeVarInt(&slice, found_int) && slice.empty(); |
135 } | 132 } |
136 | 133 |
137 static void PutVarInt(LevelDBTransaction* transaction, | 134 static void PutVarInt(LevelDBTransaction* transaction, |
138 const LevelDBSlice& key, | 135 const StringPiece& key, |
139 int64 value) { | 136 int64 value) { |
140 std::vector<char> buffer; | 137 std::string buffer; |
141 EncodeVarInt(value, &buffer); | 138 EncodeVarInt(value, &buffer); |
142 transaction->Put(key, &buffer); | 139 transaction->Put(key, &buffer); |
143 } | 140 } |
144 | 141 |
145 template <typename DBOrTransaction> | 142 template <typename DBOrTransaction> |
146 WARN_UNUSED_RESULT static bool GetString(DBOrTransaction* db, | 143 WARN_UNUSED_RESULT static bool GetString(DBOrTransaction* db, |
147 const LevelDBSlice& key, | 144 const StringPiece& key, |
148 string16* found_string, | 145 string16* found_string, |
149 bool* found) { | 146 bool* found) { |
150 std::string result; | 147 std::string result; |
151 *found = false; | 148 *found = false; |
152 bool ok = db->Get(key, &result, found); | 149 bool ok = db->Get(key, &result, found); |
153 if (!ok) | 150 if (!ok) |
154 return false; | 151 return false; |
155 if (!*found) | 152 if (!*found) |
156 return true; | 153 return true; |
157 StringPiece slice(result); | 154 StringPiece slice(result); |
158 return DecodeString(&slice, found_string) && slice.empty(); | 155 return DecodeString(&slice, found_string) && slice.empty(); |
159 } | 156 } |
160 | 157 |
161 static void PutString(LevelDBTransaction* transaction, | 158 static void PutString(LevelDBTransaction* transaction, |
162 const LevelDBSlice& key, | 159 const StringPiece& key, |
163 const string16& value) { | 160 const string16& value) { |
164 std::vector<char> buffer; | 161 std::string buffer; |
165 EncodeString(value, &buffer); | 162 EncodeString(value, &buffer); |
166 transaction->Put(key, &buffer); | 163 transaction->Put(key, &buffer); |
167 } | 164 } |
168 | 165 |
169 static void PutIDBKeyPath(LevelDBTransaction* transaction, | 166 static void PutIDBKeyPath(LevelDBTransaction* transaction, |
170 const LevelDBSlice& key, | 167 const StringPiece& key, |
171 const IndexedDBKeyPath& value) { | 168 const IndexedDBKeyPath& value) { |
172 std::vector<char> buffer; | 169 std::string buffer; |
173 EncodeIDBKeyPath(value, &buffer); | 170 EncodeIDBKeyPath(value, &buffer); |
174 transaction->Put(key, &buffer); | 171 transaction->Put(key, &buffer); |
175 } | 172 } |
176 | 173 |
177 static int CompareKeys(const LevelDBSlice& a, const LevelDBSlice& b) { | 174 static int CompareKeys(const StringPiece& a, const StringPiece& b) { |
178 return Compare(a, b, false /*index_keys*/); | 175 return Compare(a, b, false /*index_keys*/); |
179 } | 176 } |
180 | 177 |
181 static int CompareIndexKeys(const LevelDBSlice& a, const LevelDBSlice& b) { | 178 static int CompareIndexKeys(const StringPiece& a, const StringPiece& b) { |
182 return Compare(a, b, true /*index_keys*/); | 179 return Compare(a, b, true /*index_keys*/); |
183 } | 180 } |
184 | 181 |
185 class Comparator : public LevelDBComparator { | 182 class Comparator : public LevelDBComparator { |
186 public: | 183 public: |
187 virtual int Compare(const LevelDBSlice& a, const LevelDBSlice& b) const | 184 virtual int Compare(const StringPiece& a, const StringPiece& b) const |
188 OVERRIDE { | 185 OVERRIDE { |
189 return content::Compare(a, b, false /*index_keys*/); | 186 return content::Compare(a, b, false /*index_keys*/); |
190 } | 187 } |
191 virtual const char* Name() const OVERRIDE { return "idb_cmp1"; } | 188 virtual const char* Name() const OVERRIDE { return "idb_cmp1"; } |
192 }; | 189 }; |
193 | 190 |
194 // 0 - Initial version. | 191 // 0 - Initial version. |
195 // 1 - Adds UserIntVersion to DatabaseMetaData. | 192 // 1 - Adds UserIntVersion to DatabaseMetaData. |
196 // 2 - Adds DataVersion to to global metadata. | 193 // 2 - Adds DataVersion to to global metadata. |
197 static const int64 kLatestKnownSchemaVersion = 2; | 194 static const int64 kLatestKnownSchemaVersion = 2; |
198 WARN_UNUSED_RESULT static bool IsSchemaKnown(LevelDBDatabase* db, bool* known) { | 195 WARN_UNUSED_RESULT static bool IsSchemaKnown(LevelDBDatabase* db, bool* known) { |
199 int64 db_schema_version = 0; | 196 int64 db_schema_version = 0; |
200 bool found = false; | 197 bool found = false; |
201 bool ok = GetInt( | 198 bool ok = GetInt(db, SchemaVersionKey::Encode(), &db_schema_version, &found); |
202 db, LevelDBSlice(SchemaVersionKey::Encode()), &db_schema_version, &found); | |
203 if (!ok) | 199 if (!ok) |
204 return false; | 200 return false; |
205 if (!found) { | 201 if (!found) { |
206 *known = true; | 202 *known = true; |
207 return true; | 203 return true; |
208 } | 204 } |
209 if (db_schema_version > kLatestKnownSchemaVersion) { | 205 if (db_schema_version > kLatestKnownSchemaVersion) { |
210 *known = false; | 206 *known = false; |
211 return true; | 207 return true; |
212 } | 208 } |
213 | 209 |
214 const uint32 latest_known_data_version = kWireVersion; | 210 const uint32 latest_known_data_version = kWireVersion; |
215 int64 db_data_version = 0; | 211 int64 db_data_version = 0; |
216 ok = GetInt( | 212 ok = GetInt(db, DataVersionKey::Encode(), &db_data_version, &found); |
217 db, LevelDBSlice(DataVersionKey::Encode()), &db_data_version, &found); | |
218 if (!ok) | 213 if (!ok) |
219 return false; | 214 return false; |
220 if (!found) { | 215 if (!found) { |
221 *known = true; | 216 *known = true; |
222 return true; | 217 return true; |
223 } | 218 } |
224 | 219 |
225 if (db_data_version > latest_known_data_version) { | 220 if (db_data_version > latest_known_data_version) { |
226 *known = false; | 221 *known = false; |
227 return true; | 222 return true; |
228 } | 223 } |
229 | 224 |
230 *known = true; | 225 *known = true; |
231 return true; | 226 return true; |
232 } | 227 } |
233 | 228 |
234 WARN_UNUSED_RESULT static bool SetUpMetadata( | 229 WARN_UNUSED_RESULT static bool SetUpMetadata( |
235 LevelDBDatabase* db, | 230 LevelDBDatabase* db, |
236 const std::string& origin_identifier) { | 231 const std::string& origin_identifier) { |
237 const uint32 latest_known_data_version = kWireVersion; | 232 const uint32 latest_known_data_version = kWireVersion; |
238 const std::vector<char> schema_version_key = SchemaVersionKey::Encode(); | 233 const std::string schema_version_key = SchemaVersionKey::Encode(); |
239 const std::vector<char> data_version_key = DataVersionKey::Encode(); | 234 const std::string data_version_key = DataVersionKey::Encode(); |
240 | 235 |
241 scoped_refptr<LevelDBTransaction> transaction = | 236 scoped_refptr<LevelDBTransaction> transaction = |
242 LevelDBTransaction::Create(db); | 237 LevelDBTransaction::Create(db); |
243 | 238 |
244 int64 db_schema_version = 0; | 239 int64 db_schema_version = 0; |
245 int64 db_data_version = 0; | 240 int64 db_data_version = 0; |
246 bool found = false; | 241 bool found = false; |
247 bool ok = GetInt(transaction.get(), | 242 bool ok = |
248 LevelDBSlice(schema_version_key), | 243 GetInt(transaction.get(), schema_version_key, &db_schema_version, &found); |
249 &db_schema_version, | |
250 &found); | |
251 if (!ok) { | 244 if (!ok) { |
252 INTERNAL_READ_ERROR(SET_UP_METADATA); | 245 INTERNAL_READ_ERROR(SET_UP_METADATA); |
253 return false; | 246 return false; |
254 } | 247 } |
255 if (!found) { | 248 if (!found) { |
256 // Initialize new backing store. | 249 // Initialize new backing store. |
257 db_schema_version = kLatestKnownSchemaVersion; | 250 db_schema_version = kLatestKnownSchemaVersion; |
258 PutInt( | 251 PutInt(transaction.get(), schema_version_key, db_schema_version); |
259 transaction.get(), LevelDBSlice(schema_version_key), db_schema_version); | |
260 db_data_version = latest_known_data_version; | 252 db_data_version = latest_known_data_version; |
261 PutInt(transaction.get(), LevelDBSlice(data_version_key), db_data_version); | 253 PutInt(transaction.get(), data_version_key, db_data_version); |
262 } else { | 254 } else { |
263 // Upgrade old backing store. | 255 // Upgrade old backing store. |
264 DCHECK_LE(db_schema_version, kLatestKnownSchemaVersion); | 256 DCHECK_LE(db_schema_version, kLatestKnownSchemaVersion); |
265 if (db_schema_version < 1) { | 257 if (db_schema_version < 1) { |
266 db_schema_version = 1; | 258 db_schema_version = 1; |
267 PutInt(transaction.get(), | 259 PutInt(transaction.get(), schema_version_key, db_schema_version); |
268 LevelDBSlice(schema_version_key), | 260 const std::string start_key = |
269 db_schema_version); | |
270 const std::vector<char> start_key = | |
271 DatabaseNameKey::EncodeMinKeyForOrigin(origin_identifier); | 261 DatabaseNameKey::EncodeMinKeyForOrigin(origin_identifier); |
272 const std::vector<char> stop_key = | 262 const std::string stop_key = |
273 DatabaseNameKey::EncodeStopKeyForOrigin(origin_identifier); | 263 DatabaseNameKey::EncodeStopKeyForOrigin(origin_identifier); |
274 scoped_ptr<LevelDBIterator> it = db->CreateIterator(); | 264 scoped_ptr<LevelDBIterator> it = db->CreateIterator(); |
275 for (it->Seek(LevelDBSlice(start_key)); | 265 for (it->Seek(start_key); |
276 it->IsValid() && CompareKeys(it->Key(), LevelDBSlice(stop_key)) < 0; | 266 it->IsValid() && CompareKeys(it->Key(), stop_key) < 0; |
277 it->Next()) { | 267 it->Next()) { |
278 int64 database_id = 0; | 268 int64 database_id = 0; |
279 found = false; | 269 found = false; |
280 bool ok = GetInt(transaction.get(), it->Key(), &database_id, &found); | 270 bool ok = GetInt(transaction.get(), it->Key(), &database_id, &found); |
281 if (!ok) { | 271 if (!ok) { |
282 INTERNAL_READ_ERROR(SET_UP_METADATA); | 272 INTERNAL_READ_ERROR(SET_UP_METADATA); |
283 return false; | 273 return false; |
284 } | 274 } |
285 if (!found) { | 275 if (!found) { |
286 INTERNAL_CONSISTENCY_ERROR(SET_UP_METADATA); | 276 INTERNAL_CONSISTENCY_ERROR(SET_UP_METADATA); |
287 return false; | 277 return false; |
288 } | 278 } |
289 std::vector<char> int_version_key = DatabaseMetaDataKey::Encode( | 279 std::string int_version_key = DatabaseMetaDataKey::Encode( |
290 database_id, DatabaseMetaDataKey::USER_INT_VERSION); | 280 database_id, DatabaseMetaDataKey::USER_INT_VERSION); |
291 PutVarInt(transaction.get(), | 281 PutVarInt(transaction.get(), |
292 LevelDBSlice(int_version_key), | 282 int_version_key, |
293 IndexedDBDatabaseMetadata::DEFAULT_INT_VERSION); | 283 IndexedDBDatabaseMetadata::DEFAULT_INT_VERSION); |
294 } | 284 } |
295 } | 285 } |
296 if (db_schema_version < 2) { | 286 if (db_schema_version < 2) { |
297 db_schema_version = 2; | 287 db_schema_version = 2; |
298 PutInt(transaction.get(), | 288 PutInt(transaction.get(), schema_version_key, db_schema_version); |
299 LevelDBSlice(schema_version_key), | |
300 db_schema_version); | |
301 db_data_version = kWireVersion; | 289 db_data_version = kWireVersion; |
302 PutInt( | 290 PutInt(transaction.get(), data_version_key, db_data_version); |
303 transaction.get(), LevelDBSlice(data_version_key), db_data_version); | |
304 } | 291 } |
305 } | 292 } |
306 | 293 |
307 // All new values will be written using this serialization version. | 294 // All new values will be written using this serialization version. |
308 found = false; | 295 found = false; |
309 ok = GetInt(transaction.get(), | 296 ok = GetInt(transaction.get(), data_version_key, &db_data_version, &found); |
310 LevelDBSlice(data_version_key), | |
311 &db_data_version, | |
312 &found); | |
313 if (!ok) { | 297 if (!ok) { |
314 INTERNAL_READ_ERROR(SET_UP_METADATA); | 298 INTERNAL_READ_ERROR(SET_UP_METADATA); |
315 return false; | 299 return false; |
316 } | 300 } |
317 if (!found) { | 301 if (!found) { |
318 INTERNAL_CONSISTENCY_ERROR(SET_UP_METADATA); | 302 INTERNAL_CONSISTENCY_ERROR(SET_UP_METADATA); |
319 return false; | 303 return false; |
320 } | 304 } |
321 if (db_data_version < latest_known_data_version) { | 305 if (db_data_version < latest_known_data_version) { |
322 db_data_version = latest_known_data_version; | 306 db_data_version = latest_known_data_version; |
323 PutInt(transaction.get(), LevelDBSlice(data_version_key), db_data_version); | 307 PutInt(transaction.get(), data_version_key, db_data_version); |
324 } | 308 } |
325 | 309 |
326 DCHECK_EQ(db_schema_version, kLatestKnownSchemaVersion); | 310 DCHECK_EQ(db_schema_version, kLatestKnownSchemaVersion); |
327 DCHECK_EQ(db_data_version, latest_known_data_version); | 311 DCHECK_EQ(db_data_version, latest_known_data_version); |
328 | 312 |
329 if (!transaction->Commit()) { | 313 if (!transaction->Commit()) { |
330 INTERNAL_WRITE_ERROR(SET_UP_METADATA); | 314 INTERNAL_WRITE_ERROR(SET_UP_METADATA); |
331 return false; | 315 return false; |
332 } | 316 } |
333 return true; | 317 return true; |
334 } | 318 } |
335 | 319 |
336 template <typename DBOrTransaction> | 320 template <typename DBOrTransaction> |
337 WARN_UNUSED_RESULT static bool GetMaxObjectStoreId(DBOrTransaction* db, | 321 WARN_UNUSED_RESULT static bool GetMaxObjectStoreId(DBOrTransaction* db, |
338 int64 database_id, | 322 int64 database_id, |
339 int64* max_object_store_id) { | 323 int64* max_object_store_id) { |
340 const std::vector<char> max_object_store_id_key = DatabaseMetaDataKey::Encode( | 324 const std::string max_object_store_id_key = DatabaseMetaDataKey::Encode( |
341 database_id, DatabaseMetaDataKey::MAX_OBJECT_STORE_ID); | 325 database_id, DatabaseMetaDataKey::MAX_OBJECT_STORE_ID); |
342 bool ok = | 326 bool ok = |
343 GetMaxObjectStoreId(db, max_object_store_id_key, max_object_store_id); | 327 GetMaxObjectStoreId(db, max_object_store_id_key, max_object_store_id); |
344 return ok; | 328 return ok; |
345 } | 329 } |
346 | 330 |
347 template <typename DBOrTransaction> | 331 template <typename DBOrTransaction> |
348 WARN_UNUSED_RESULT static bool GetMaxObjectStoreId( | 332 WARN_UNUSED_RESULT static bool GetMaxObjectStoreId( |
349 DBOrTransaction* db, | 333 DBOrTransaction* db, |
350 const std::vector<char>& max_object_store_id_key, | 334 const std::string& max_object_store_id_key, |
351 int64* max_object_store_id) { | 335 int64* max_object_store_id) { |
352 *max_object_store_id = -1; | 336 *max_object_store_id = -1; |
353 bool found = false; | 337 bool found = false; |
354 bool ok = GetInt( | 338 bool ok = GetInt(db, max_object_store_id_key, max_object_store_id, &found); |
355 db, LevelDBSlice(max_object_store_id_key), max_object_store_id, &found); | |
356 if (!ok) | 339 if (!ok) |
357 return false; | 340 return false; |
358 if (!found) | 341 if (!found) |
359 *max_object_store_id = 0; | 342 *max_object_store_id = 0; |
360 | 343 |
361 DCHECK_GE(*max_object_store_id, 0); | 344 DCHECK_GE(*max_object_store_id, 0); |
362 return true; | 345 return true; |
363 } | 346 } |
364 | 347 |
365 class DefaultLevelDBFactory : public LevelDBFactory { | 348 class DefaultLevelDBFactory : public LevelDBFactory { |
(...skipping 18 matching lines...) Expand all Loading... |
384 comparator_(comparator.Pass()), | 367 comparator_(comparator.Pass()), |
385 weak_factory_(this) {} | 368 weak_factory_(this) {} |
386 | 369 |
387 IndexedDBBackingStore::~IndexedDBBackingStore() { | 370 IndexedDBBackingStore::~IndexedDBBackingStore() { |
388 // db_'s destructor uses comparator_. The order of destruction is important. | 371 // db_'s destructor uses comparator_. The order of destruction is important. |
389 db_.reset(); | 372 db_.reset(); |
390 comparator_.reset(); | 373 comparator_.reset(); |
391 } | 374 } |
392 | 375 |
393 IndexedDBBackingStore::RecordIdentifier::RecordIdentifier( | 376 IndexedDBBackingStore::RecordIdentifier::RecordIdentifier( |
394 const std::vector<char>& primary_key, | 377 const std::string& primary_key, |
395 int64 version) | 378 int64 version) |
396 : primary_key_(primary_key), version_(version) { | 379 : primary_key_(primary_key), version_(version) { |
397 DCHECK(!primary_key.empty()); | 380 DCHECK(!primary_key.empty()); |
398 } | 381 } |
399 IndexedDBBackingStore::RecordIdentifier::RecordIdentifier() | 382 IndexedDBBackingStore::RecordIdentifier::RecordIdentifier() |
400 : primary_key_(), version_(-1) {} | 383 : primary_key_(), version_(-1) {} |
401 IndexedDBBackingStore::RecordIdentifier::~RecordIdentifier() {} | 384 IndexedDBBackingStore::RecordIdentifier::~RecordIdentifier() {} |
402 | 385 |
403 IndexedDBBackingStore::Cursor::CursorOptions::CursorOptions() {} | 386 IndexedDBBackingStore::Cursor::CursorOptions::CursorOptions() {} |
404 IndexedDBBackingStore::Cursor::CursorOptions::~CursorOptions() {} | 387 IndexedDBBackingStore::Cursor::CursorOptions::~CursorOptions() {} |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
461 base::Histogram::FactoryGet("WebCore.IndexedDB.BackingStore.OpenStatus", | 444 base::Histogram::FactoryGet("WebCore.IndexedDB.BackingStore.OpenStatus", |
462 1, | 445 1, |
463 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX, | 446 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX, |
464 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX + 1, | 447 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX + 1, |
465 base::HistogramBase::kUmaTargetedHistogramFlag) | 448 base::HistogramBase::kUmaTargetedHistogramFlag) |
466 ->Add(INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_FAILED_DIRECTORY); | 449 ->Add(INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_FAILED_DIRECTORY); |
467 return scoped_refptr<IndexedDBBackingStore>(); | 450 return scoped_refptr<IndexedDBBackingStore>(); |
468 } | 451 } |
469 | 452 |
470 base::FilePath identifier_path = | 453 base::FilePath identifier_path = |
471 base::FilePath().AppendASCII(origin_identifier). | 454 base::FilePath().AppendASCII(origin_identifier) |
472 AddExtension(FILE_PATH_LITERAL(".indexeddb.leveldb")); | 455 .AddExtension(FILE_PATH_LITERAL(".indexeddb.leveldb")); |
473 | 456 |
474 int limit = file_util::GetMaximumPathComponentLength(path_base); | 457 int limit = file_util::GetMaximumPathComponentLength(path_base); |
475 if (limit == -1) { | 458 if (limit == -1) { |
476 DLOG(WARNING) << "GetMaximumPathComponentLength returned -1"; | 459 DLOG(WARNING) << "GetMaximumPathComponentLength returned -1"; |
477 // In limited testing, ChromeOS returns 143, other OSes 255. | 460 // In limited testing, ChromeOS returns 143, other OSes 255. |
478 #if defined(OS_CHROMEOS) | 461 #if defined(OS_CHROMEOS) |
479 limit = 143; | 462 limit = 143; |
480 #else | 463 #else |
481 limit = 255; | 464 limit = 255; |
482 #endif | 465 #endif |
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
542 | 525 |
543 if (db) { | 526 if (db) { |
544 base::Histogram::FactoryGet("WebCore.IndexedDB.BackingStore.OpenStatus", | 527 base::Histogram::FactoryGet("WebCore.IndexedDB.BackingStore.OpenStatus", |
545 1, | 528 1, |
546 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX, | 529 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX, |
547 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX + 1, | 530 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX + 1, |
548 base::HistogramBase::kUmaTargetedHistogramFlag) | 531 base::HistogramBase::kUmaTargetedHistogramFlag) |
549 ->Add(INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_SUCCESS); | 532 ->Add(INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_SUCCESS); |
550 } else if (is_disk_full) { | 533 } else if (is_disk_full) { |
551 LOG(ERROR) << "Unable to open backing store - disk is full."; | 534 LOG(ERROR) << "Unable to open backing store - disk is full."; |
552 base::Histogram::FactoryGet( | 535 base::Histogram::FactoryGet("WebCore.IndexedDB.BackingStore.OpenStatus", |
553 "WebCore.IndexedDB.BackingStore.OpenStatus", | 536 1, |
554 1, | 537 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX, |
555 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX, | 538 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX + 1, |
556 INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_MAX + 1, | 539 base::HistogramBase::kUmaTargetedHistogramFlag) |
557 base::HistogramBase::kUmaTargetedHistogramFlag) | |
558 ->Add(INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_DISK_FULL); | 540 ->Add(INDEXED_DB_LEVEL_DB_BACKING_STORE_OPEN_DISK_FULL); |
559 return scoped_refptr<IndexedDBBackingStore>(); | 541 return scoped_refptr<IndexedDBBackingStore>(); |
560 } else { | 542 } else { |
561 LOG(ERROR) << "IndexedDB backing store open failed, attempting cleanup"; | 543 LOG(ERROR) << "IndexedDB backing store open failed, attempting cleanup"; |
562 *data_loss = WebKit::WebIDBCallbacks::DataLossTotal; | 544 *data_loss = WebKit::WebIDBCallbacks::DataLossTotal; |
563 bool success = leveldb_factory->DestroyLevelDB(file_path); | 545 bool success = leveldb_factory->DestroyLevelDB(file_path); |
564 if (!success) { | 546 if (!success) { |
565 LOG(ERROR) << "IndexedDB backing store cleanup failed"; | 547 LOG(ERROR) << "IndexedDB backing store cleanup failed"; |
566 base::Histogram::FactoryGet( | 548 base::Histogram::FactoryGet( |
567 "WebCore.IndexedDB.BackingStore.OpenStatus", | 549 "WebCore.IndexedDB.BackingStore.OpenStatus", |
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
651 new IndexedDBBackingStore(identifier, db.Pass(), comparator.Pass())); | 633 new IndexedDBBackingStore(identifier, db.Pass(), comparator.Pass())); |
652 | 634 |
653 if (!SetUpMetadata(backing_store->db_.get(), identifier)) | 635 if (!SetUpMetadata(backing_store->db_.get(), identifier)) |
654 return scoped_refptr<IndexedDBBackingStore>(); | 636 return scoped_refptr<IndexedDBBackingStore>(); |
655 | 637 |
656 return backing_store; | 638 return backing_store; |
657 } | 639 } |
658 | 640 |
659 std::vector<string16> IndexedDBBackingStore::GetDatabaseNames() { | 641 std::vector<string16> IndexedDBBackingStore::GetDatabaseNames() { |
660 std::vector<string16> found_names; | 642 std::vector<string16> found_names; |
661 const std::vector<char> start_key = | 643 const std::string start_key = |
662 DatabaseNameKey::EncodeMinKeyForOrigin(identifier_); | 644 DatabaseNameKey::EncodeMinKeyForOrigin(identifier_); |
663 const std::vector<char> stop_key = | 645 const std::string stop_key = |
664 DatabaseNameKey::EncodeStopKeyForOrigin(identifier_); | 646 DatabaseNameKey::EncodeStopKeyForOrigin(identifier_); |
665 | 647 |
666 DCHECK(found_names.empty()); | 648 DCHECK(found_names.empty()); |
667 | 649 |
668 scoped_ptr<LevelDBIterator> it = db_->CreateIterator(); | 650 scoped_ptr<LevelDBIterator> it = db_->CreateIterator(); |
669 for (it->Seek(LevelDBSlice(start_key)); | 651 for (it->Seek(start_key); |
670 it->IsValid() && CompareKeys(it->Key(), LevelDBSlice(stop_key)) < 0; | 652 it->IsValid() && CompareKeys(it->Key(), stop_key) < 0; |
671 it->Next()) { | 653 it->Next()) { |
672 const char* p = it->Key().begin(); | 654 const char* p = it->Key().begin(); |
673 const char* limit = it->Key().end(); | 655 const char* limit = it->Key().end(); |
674 | 656 |
675 DatabaseNameKey database_name_key; | 657 DatabaseNameKey database_name_key; |
676 p = DatabaseNameKey::Decode(p, limit, &database_name_key); | 658 p = DatabaseNameKey::Decode(p, limit, &database_name_key); |
677 DCHECK(p); | 659 DCHECK(p); |
678 | 660 |
679 found_names.push_back(database_name_key.database_name()); | 661 found_names.push_back(database_name_key.database_name()); |
680 } | 662 } |
681 return found_names; | 663 return found_names; |
682 } | 664 } |
683 | 665 |
684 bool IndexedDBBackingStore::GetIDBDatabaseMetaData( | 666 bool IndexedDBBackingStore::GetIDBDatabaseMetaData( |
685 const string16& name, | 667 const string16& name, |
686 IndexedDBDatabaseMetadata* metadata, | 668 IndexedDBDatabaseMetadata* metadata, |
687 bool* found) { | 669 bool* found) { |
688 const std::vector<char> key = DatabaseNameKey::Encode(identifier_, name); | 670 const std::string key = DatabaseNameKey::Encode(identifier_, name); |
689 *found = false; | 671 *found = false; |
690 | 672 |
691 bool ok = GetInt(db_.get(), LevelDBSlice(key), &metadata->id, found); | 673 bool ok = GetInt(db_.get(), key, &metadata->id, found); |
692 if (!ok) { | 674 if (!ok) { |
693 INTERNAL_READ_ERROR(GET_IDBDATABASE_METADATA); | 675 INTERNAL_READ_ERROR(GET_IDBDATABASE_METADATA); |
694 return false; | 676 return false; |
695 } | 677 } |
696 if (!*found) | 678 if (!*found) |
697 return true; | 679 return true; |
698 | 680 |
699 ok = GetString(db_.get(), | 681 ok = GetString(db_.get(), |
700 LevelDBSlice(DatabaseMetaDataKey::Encode( | 682 DatabaseMetaDataKey::Encode(metadata->id, |
701 metadata->id, DatabaseMetaDataKey::USER_VERSION)), | 683 DatabaseMetaDataKey::USER_VERSION), |
702 &metadata->version, | 684 &metadata->version, |
703 found); | 685 found); |
704 if (!ok) { | 686 if (!ok) { |
705 INTERNAL_READ_ERROR(GET_IDBDATABASE_METADATA); | 687 INTERNAL_READ_ERROR(GET_IDBDATABASE_METADATA); |
706 return false; | 688 return false; |
707 } | 689 } |
708 if (!*found) { | 690 if (!*found) { |
709 INTERNAL_CONSISTENCY_ERROR(GET_IDBDATABASE_METADATA); | 691 INTERNAL_CONSISTENCY_ERROR(GET_IDBDATABASE_METADATA); |
710 return false; | 692 return false; |
711 } | 693 } |
712 | 694 |
713 ok = GetVarInt(db_.get(), | 695 ok = GetVarInt(db_.get(), |
714 LevelDBSlice(DatabaseMetaDataKey::Encode( | 696 DatabaseMetaDataKey::Encode( |
715 metadata->id, DatabaseMetaDataKey::USER_INT_VERSION)), | 697 metadata->id, DatabaseMetaDataKey::USER_INT_VERSION), |
716 &metadata->int_version, | 698 &metadata->int_version, |
717 found); | 699 found); |
718 if (!ok) { | 700 if (!ok) { |
719 INTERNAL_READ_ERROR(GET_IDBDATABASE_METADATA); | 701 INTERNAL_READ_ERROR(GET_IDBDATABASE_METADATA); |
720 return false; | 702 return false; |
721 } | 703 } |
722 if (!*found) { | 704 if (!*found) { |
723 INTERNAL_CONSISTENCY_ERROR(GET_IDBDATABASE_METADATA); | 705 INTERNAL_CONSISTENCY_ERROR(GET_IDBDATABASE_METADATA); |
724 return false; | 706 return false; |
725 } | 707 } |
(...skipping 12 matching lines...) Expand all Loading... |
738 } | 720 } |
739 | 721 |
740 WARN_UNUSED_RESULT static bool GetNewDatabaseId(LevelDBDatabase* db, | 722 WARN_UNUSED_RESULT static bool GetNewDatabaseId(LevelDBDatabase* db, |
741 int64* new_id) { | 723 int64* new_id) { |
742 scoped_refptr<LevelDBTransaction> transaction = | 724 scoped_refptr<LevelDBTransaction> transaction = |
743 LevelDBTransaction::Create(db); | 725 LevelDBTransaction::Create(db); |
744 | 726 |
745 *new_id = -1; | 727 *new_id = -1; |
746 int64 max_database_id = -1; | 728 int64 max_database_id = -1; |
747 bool found = false; | 729 bool found = false; |
748 bool ok = GetInt(transaction.get(), | 730 bool ok = GetInt( |
749 LevelDBSlice(MaxDatabaseIdKey::Encode()), | 731 transaction.get(), MaxDatabaseIdKey::Encode(), &max_database_id, &found); |
750 &max_database_id, | |
751 &found); | |
752 if (!ok) { | 732 if (!ok) { |
753 INTERNAL_READ_ERROR(GET_NEW_DATABASE_ID); | 733 INTERNAL_READ_ERROR(GET_NEW_DATABASE_ID); |
754 return false; | 734 return false; |
755 } | 735 } |
756 if (!found) | 736 if (!found) |
757 max_database_id = 0; | 737 max_database_id = 0; |
758 | 738 |
759 DCHECK_GE(max_database_id, 0); | 739 DCHECK_GE(max_database_id, 0); |
760 | 740 |
761 int64 database_id = max_database_id + 1; | 741 int64 database_id = max_database_id + 1; |
762 PutInt( | 742 PutInt(transaction.get(), MaxDatabaseIdKey::Encode(), database_id); |
763 transaction.get(), LevelDBSlice(MaxDatabaseIdKey::Encode()), database_id); | |
764 if (!transaction->Commit()) { | 743 if (!transaction->Commit()) { |
765 INTERNAL_WRITE_ERROR(GET_NEW_DATABASE_ID); | 744 INTERNAL_WRITE_ERROR(GET_NEW_DATABASE_ID); |
766 return false; | 745 return false; |
767 } | 746 } |
768 *new_id = database_id; | 747 *new_id = database_id; |
769 return true; | 748 return true; |
770 } | 749 } |
771 | 750 |
772 bool IndexedDBBackingStore::CreateIDBDatabaseMetaData(const string16& name, | 751 bool IndexedDBBackingStore::CreateIDBDatabaseMetaData(const string16& name, |
773 const string16& version, | 752 const string16& version, |
774 int64 int_version, | 753 int64 int_version, |
775 int64* row_id) { | 754 int64* row_id) { |
776 bool ok = GetNewDatabaseId(db_.get(), row_id); | 755 bool ok = GetNewDatabaseId(db_.get(), row_id); |
777 if (!ok) | 756 if (!ok) |
778 return false; | 757 return false; |
779 DCHECK_GE(*row_id, 0); | 758 DCHECK_GE(*row_id, 0); |
780 | 759 |
781 if (int_version == IndexedDBDatabaseMetadata::NO_INT_VERSION) | 760 if (int_version == IndexedDBDatabaseMetadata::NO_INT_VERSION) |
782 int_version = IndexedDBDatabaseMetadata::DEFAULT_INT_VERSION; | 761 int_version = IndexedDBDatabaseMetadata::DEFAULT_INT_VERSION; |
783 | 762 |
784 scoped_refptr<LevelDBTransaction> transaction = | 763 scoped_refptr<LevelDBTransaction> transaction = |
785 LevelDBTransaction::Create(db_.get()); | 764 LevelDBTransaction::Create(db_.get()); |
786 PutInt(transaction.get(), | 765 PutInt( |
787 LevelDBSlice(DatabaseNameKey::Encode(identifier_, name)), | 766 transaction.get(), DatabaseNameKey::Encode(identifier_, name), *row_id); |
788 *row_id); | 767 PutString( |
789 PutString(transaction.get(), | 768 transaction.get(), |
790 LevelDBSlice(DatabaseMetaDataKey::Encode( | 769 DatabaseMetaDataKey::Encode(*row_id, DatabaseMetaDataKey::USER_VERSION), |
791 *row_id, DatabaseMetaDataKey::USER_VERSION)), | 770 version); |
792 version); | |
793 PutVarInt(transaction.get(), | 771 PutVarInt(transaction.get(), |
794 LevelDBSlice(DatabaseMetaDataKey::Encode( | 772 DatabaseMetaDataKey::Encode(*row_id, |
795 *row_id, DatabaseMetaDataKey::USER_INT_VERSION)), | 773 DatabaseMetaDataKey::USER_INT_VERSION), |
796 int_version); | 774 int_version); |
797 if (!transaction->Commit()) { | 775 if (!transaction->Commit()) { |
798 INTERNAL_WRITE_ERROR(CREATE_IDBDATABASE_METADATA); | 776 INTERNAL_WRITE_ERROR(CREATE_IDBDATABASE_METADATA); |
799 return false; | 777 return false; |
800 } | 778 } |
801 return true; | 779 return true; |
802 } | 780 } |
803 | 781 |
804 bool IndexedDBBackingStore::UpdateIDBDatabaseIntVersion( | 782 bool IndexedDBBackingStore::UpdateIDBDatabaseIntVersion( |
805 IndexedDBBackingStore::Transaction* transaction, | 783 IndexedDBBackingStore::Transaction* transaction, |
806 int64 row_id, | 784 int64 row_id, |
807 int64 int_version) { | 785 int64 int_version) { |
808 if (int_version == IndexedDBDatabaseMetadata::NO_INT_VERSION) | 786 if (int_version == IndexedDBDatabaseMetadata::NO_INT_VERSION) |
809 int_version = IndexedDBDatabaseMetadata::DEFAULT_INT_VERSION; | 787 int_version = IndexedDBDatabaseMetadata::DEFAULT_INT_VERSION; |
810 DCHECK_GE(int_version, 0) << "int_version was " << int_version; | 788 DCHECK_GE(int_version, 0) << "int_version was " << int_version; |
811 PutVarInt(Transaction::LevelDBTransactionFrom(transaction), | 789 PutVarInt(Transaction::LevelDBTransactionFrom(transaction), |
812 LevelDBSlice(DatabaseMetaDataKey::Encode( | 790 DatabaseMetaDataKey::Encode(row_id, |
813 row_id, DatabaseMetaDataKey::USER_INT_VERSION)), | 791 DatabaseMetaDataKey::USER_INT_VERSION), |
814 int_version); | 792 int_version); |
815 return true; | 793 return true; |
816 } | 794 } |
817 | 795 |
818 bool IndexedDBBackingStore::UpdateIDBDatabaseMetaData( | 796 bool IndexedDBBackingStore::UpdateIDBDatabaseMetaData( |
819 IndexedDBBackingStore::Transaction* transaction, | 797 IndexedDBBackingStore::Transaction* transaction, |
820 int64 row_id, | 798 int64 row_id, |
821 const string16& version) { | 799 const string16& version) { |
822 PutString(Transaction::LevelDBTransactionFrom(transaction), | 800 PutString( |
823 LevelDBSlice(DatabaseMetaDataKey::Encode( | 801 Transaction::LevelDBTransactionFrom(transaction), |
824 row_id, DatabaseMetaDataKey::USER_VERSION)), | 802 DatabaseMetaDataKey::Encode(row_id, DatabaseMetaDataKey::USER_VERSION), |
825 version); | 803 version); |
826 return true; | 804 return true; |
827 } | 805 } |
828 | 806 |
829 static void DeleteRange(LevelDBTransaction* transaction, | 807 static void DeleteRange(LevelDBTransaction* transaction, |
830 const std::vector<char>& begin, | 808 const std::string& begin, |
831 const std::vector<char>& end) { | 809 const std::string& end) { |
832 scoped_ptr<LevelDBIterator> it = transaction->CreateIterator(); | 810 scoped_ptr<LevelDBIterator> it = transaction->CreateIterator(); |
833 for (it->Seek(LevelDBSlice(begin)); | 811 for (it->Seek(begin); it->IsValid() && CompareKeys(it->Key(), end) < 0; |
834 it->IsValid() && CompareKeys(it->Key(), LevelDBSlice(end)) < 0; | |
835 it->Next()) | 812 it->Next()) |
836 transaction->Remove(it->Key()); | 813 transaction->Remove(it->Key()); |
837 } | 814 } |
838 | 815 |
839 bool IndexedDBBackingStore::DeleteDatabase(const string16& name) { | 816 bool IndexedDBBackingStore::DeleteDatabase(const string16& name) { |
840 IDB_TRACE("IndexedDBBackingStore::DeleteDatabase"); | 817 IDB_TRACE("IndexedDBBackingStore::DeleteDatabase"); |
841 scoped_ptr<LevelDBWriteOnlyTransaction> transaction = | 818 scoped_ptr<LevelDBWriteOnlyTransaction> transaction = |
842 LevelDBWriteOnlyTransaction::Create(db_.get()); | 819 LevelDBWriteOnlyTransaction::Create(db_.get()); |
843 | 820 |
844 IndexedDBDatabaseMetadata metadata; | 821 IndexedDBDatabaseMetadata metadata; |
845 bool success = false; | 822 bool success = false; |
846 bool ok = GetIDBDatabaseMetaData(name, &metadata, &success); | 823 bool ok = GetIDBDatabaseMetaData(name, &metadata, &success); |
847 if (!ok) | 824 if (!ok) |
848 return false; | 825 return false; |
849 if (!success) | 826 if (!success) |
850 return true; | 827 return true; |
851 | 828 |
852 const std::vector<char> start_key = DatabaseMetaDataKey::Encode( | 829 const std::string start_key = DatabaseMetaDataKey::Encode( |
853 metadata.id, DatabaseMetaDataKey::ORIGIN_NAME); | 830 metadata.id, DatabaseMetaDataKey::ORIGIN_NAME); |
854 const std::vector<char> stop_key = DatabaseMetaDataKey::Encode( | 831 const std::string stop_key = DatabaseMetaDataKey::Encode( |
855 metadata.id + 1, DatabaseMetaDataKey::ORIGIN_NAME); | 832 metadata.id + 1, DatabaseMetaDataKey::ORIGIN_NAME); |
856 scoped_ptr<LevelDBIterator> it = db_->CreateIterator(); | 833 scoped_ptr<LevelDBIterator> it = db_->CreateIterator(); |
857 for (it->Seek(LevelDBSlice(start_key)); | 834 for (it->Seek(start_key); |
858 it->IsValid() && CompareKeys(it->Key(), LevelDBSlice(stop_key)) < 0; | 835 it->IsValid() && CompareKeys(it->Key(), stop_key) < 0; |
859 it->Next()) | 836 it->Next()) |
860 transaction->Remove(it->Key()); | 837 transaction->Remove(it->Key()); |
861 | 838 |
862 const std::vector<char> key = DatabaseNameKey::Encode(identifier_, name); | 839 const std::string key = DatabaseNameKey::Encode(identifier_, name); |
863 transaction->Remove(LevelDBSlice(key)); | 840 transaction->Remove(key); |
864 | 841 |
865 if (!transaction->Commit()) { | 842 if (!transaction->Commit()) { |
866 INTERNAL_WRITE_ERROR(DELETE_DATABASE); | 843 INTERNAL_WRITE_ERROR(DELETE_DATABASE); |
867 return false; | 844 return false; |
868 } | 845 } |
869 return true; | 846 return true; |
870 } | 847 } |
871 | 848 |
872 static bool CheckObjectStoreAndMetaDataType(const LevelDBIterator* it, | 849 static bool CheckObjectStoreAndMetaDataType(const LevelDBIterator* it, |
873 const std::vector<char>& stop_key, | 850 const std::string& stop_key, |
874 int64 object_store_id, | 851 int64 object_store_id, |
875 int64 meta_data_type) { | 852 int64 meta_data_type) { |
876 if (!it->IsValid() || CompareKeys(it->Key(), LevelDBSlice(stop_key)) >= 0) | 853 if (!it->IsValid() || CompareKeys(it->Key(), stop_key) >= 0) |
877 return false; | 854 return false; |
878 | 855 |
879 ObjectStoreMetaDataKey meta_data_key; | 856 ObjectStoreMetaDataKey meta_data_key; |
880 const char* p = ObjectStoreMetaDataKey::Decode( | 857 const char* p = ObjectStoreMetaDataKey::Decode( |
881 it->Key().begin(), it->Key().end(), &meta_data_key); | 858 it->Key().begin(), it->Key().end(), &meta_data_key); |
882 DCHECK(p); | 859 DCHECK(p); |
883 if (meta_data_key.ObjectStoreId() != object_store_id) | 860 if (meta_data_key.ObjectStoreId() != object_store_id) |
884 return false; | 861 return false; |
885 if (meta_data_key.MetaDataType() != meta_data_type) | 862 if (meta_data_key.MetaDataType() != meta_data_type) |
886 return false; | 863 return false; |
887 return true; | 864 return true; |
888 } | 865 } |
889 | 866 |
890 // TODO(jsbell): This should do some error handling rather than | 867 // TODO(jsbell): This should do some error handling rather than |
891 // plowing ahead when bad data is encountered. | 868 // plowing ahead when bad data is encountered. |
892 bool IndexedDBBackingStore::GetObjectStores( | 869 bool IndexedDBBackingStore::GetObjectStores( |
893 int64 database_id, | 870 int64 database_id, |
894 IndexedDBDatabaseMetadata::ObjectStoreMap* object_stores) { | 871 IndexedDBDatabaseMetadata::ObjectStoreMap* object_stores) { |
895 IDB_TRACE("IndexedDBBackingStore::GetObjectStores"); | 872 IDB_TRACE("IndexedDBBackingStore::GetObjectStores"); |
896 if (!KeyPrefix::IsValidDatabaseId(database_id)) | 873 if (!KeyPrefix::IsValidDatabaseId(database_id)) |
897 return false; | 874 return false; |
898 const std::vector<char> start_key = | 875 const std::string start_key = |
899 ObjectStoreMetaDataKey::Encode(database_id, 1, 0); | 876 ObjectStoreMetaDataKey::Encode(database_id, 1, 0); |
900 const std::vector<char> stop_key = | 877 const std::string stop_key = |
901 ObjectStoreMetaDataKey::EncodeMaxKey(database_id); | 878 ObjectStoreMetaDataKey::EncodeMaxKey(database_id); |
902 | 879 |
903 DCHECK(object_stores->empty()); | 880 DCHECK(object_stores->empty()); |
904 | 881 |
905 scoped_ptr<LevelDBIterator> it = db_->CreateIterator(); | 882 scoped_ptr<LevelDBIterator> it = db_->CreateIterator(); |
906 it->Seek(LevelDBSlice(start_key)); | 883 it->Seek(start_key); |
907 while (it->IsValid() && CompareKeys(it->Key(), LevelDBSlice(stop_key)) < 0) { | 884 while (it->IsValid() && CompareKeys(it->Key(), stop_key) < 0) { |
908 const char* p = it->Key().begin(); | 885 const char* p = it->Key().begin(); |
909 const char* limit = it->Key().end(); | 886 const char* limit = it->Key().end(); |
910 | 887 |
911 ObjectStoreMetaDataKey meta_data_key; | 888 ObjectStoreMetaDataKey meta_data_key; |
912 p = ObjectStoreMetaDataKey::Decode(p, limit, &meta_data_key); | 889 p = ObjectStoreMetaDataKey::Decode(p, limit, &meta_data_key); |
913 DCHECK(p); | 890 DCHECK(p); |
914 if (meta_data_key.MetaDataType() != ObjectStoreMetaDataKey::NAME) { | 891 if (meta_data_key.MetaDataType() != ObjectStoreMetaDataKey::NAME) { |
915 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 892 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
916 // Possible stale metadata, but don't fail the load. | 893 // Possible stale metadata, but don't fail the load. |
917 it->Next(); | 894 it->Next(); |
918 continue; | 895 continue; |
919 } | 896 } |
920 | 897 |
921 int64 object_store_id = meta_data_key.ObjectStoreId(); | 898 int64 object_store_id = meta_data_key.ObjectStoreId(); |
922 | 899 |
923 // TODO(jsbell): Do this by direct key lookup rather than iteration, to | 900 // TODO(jsbell): Do this by direct key lookup rather than iteration, to |
924 // simplify. | 901 // simplify. |
925 string16 object_store_name; | 902 string16 object_store_name; |
926 { | 903 { |
927 StringPiece slice(it->Value().AsStringPiece()); | 904 StringPiece slice(it->Value()); |
928 if (!DecodeString(&slice, &object_store_name) || !slice.empty()) | 905 if (!DecodeString(&slice, &object_store_name) || !slice.empty()) |
929 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 906 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
930 } | 907 } |
931 | 908 |
932 it->Next(); | 909 it->Next(); |
933 if (!CheckObjectStoreAndMetaDataType(it.get(), | 910 if (!CheckObjectStoreAndMetaDataType(it.get(), |
934 stop_key, | 911 stop_key, |
935 object_store_id, | 912 object_store_id, |
936 ObjectStoreMetaDataKey::KEY_PATH)) { | 913 ObjectStoreMetaDataKey::KEY_PATH)) { |
937 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 914 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
938 break; | 915 break; |
939 } | 916 } |
940 IndexedDBKeyPath key_path; | 917 IndexedDBKeyPath key_path; |
941 { | 918 { |
942 StringPiece slice(it->Value().AsStringPiece()); | 919 StringPiece slice(it->Value()); |
943 if (!DecodeIDBKeyPath(&slice, &key_path) || !slice.empty()) | 920 if (!DecodeIDBKeyPath(&slice, &key_path) || !slice.empty()) |
944 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 921 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
945 } | 922 } |
946 | 923 |
947 it->Next(); | 924 it->Next(); |
948 if (!CheckObjectStoreAndMetaDataType( | 925 if (!CheckObjectStoreAndMetaDataType( |
949 it.get(), | 926 it.get(), |
950 stop_key, | 927 stop_key, |
951 object_store_id, | 928 object_store_id, |
952 ObjectStoreMetaDataKey::AUTO_INCREMENT)) { | 929 ObjectStoreMetaDataKey::AUTO_INCREMENT)) { |
953 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 930 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
954 break; | 931 break; |
955 } | 932 } |
956 bool auto_increment; | 933 bool auto_increment; |
957 { | 934 { |
958 StringPiece slice(it->Value().AsStringPiece()); | 935 StringPiece slice(it->Value()); |
959 if (!DecodeBool(&slice, &auto_increment) || !slice.empty()) | 936 if (!DecodeBool(&slice, &auto_increment) || !slice.empty()) |
960 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 937 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
961 } | 938 } |
962 | 939 |
963 it->Next(); // Is evicatble. | 940 it->Next(); // Is evicatble. |
964 if (!CheckObjectStoreAndMetaDataType(it.get(), | 941 if (!CheckObjectStoreAndMetaDataType(it.get(), |
965 stop_key, | 942 stop_key, |
966 object_store_id, | 943 object_store_id, |
967 ObjectStoreMetaDataKey::EVICTABLE)) { | 944 ObjectStoreMetaDataKey::EVICTABLE)) { |
968 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 945 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
(...skipping 14 matching lines...) Expand all Loading... |
983 if (!CheckObjectStoreAndMetaDataType( | 960 if (!CheckObjectStoreAndMetaDataType( |
984 it.get(), | 961 it.get(), |
985 stop_key, | 962 stop_key, |
986 object_store_id, | 963 object_store_id, |
987 ObjectStoreMetaDataKey::MAX_INDEX_ID)) { | 964 ObjectStoreMetaDataKey::MAX_INDEX_ID)) { |
988 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 965 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
989 break; | 966 break; |
990 } | 967 } |
991 int64 max_index_id; | 968 int64 max_index_id; |
992 { | 969 { |
993 StringPiece slice(it->Value().AsStringPiece()); | 970 StringPiece slice(it->Value()); |
994 if (!DecodeInt(&slice, &max_index_id) || !slice.empty()) | 971 if (!DecodeInt(&slice, &max_index_id) || !slice.empty()) |
995 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 972 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
996 } | 973 } |
997 | 974 |
998 it->Next(); // [optional] has key path (is not null) | 975 it->Next(); // [optional] has key path (is not null) |
999 if (CheckObjectStoreAndMetaDataType(it.get(), | 976 if (CheckObjectStoreAndMetaDataType(it.get(), |
1000 stop_key, | 977 stop_key, |
1001 object_store_id, | 978 object_store_id, |
1002 ObjectStoreMetaDataKey::HAS_KEY_PATH)) { | 979 ObjectStoreMetaDataKey::HAS_KEY_PATH)) { |
1003 bool has_key_path; | 980 bool has_key_path; |
1004 { | 981 { |
1005 StringPiece slice(it->Value().AsStringPiece()); | 982 StringPiece slice(it->Value()); |
1006 if (!DecodeBool(&slice, &has_key_path)) | 983 if (!DecodeBool(&slice, &has_key_path)) |
1007 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 984 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
1008 } | 985 } |
1009 // This check accounts for two layers of legacy coding: | 986 // This check accounts for two layers of legacy coding: |
1010 // (1) Initially, has_key_path was added to distinguish null vs. string. | 987 // (1) Initially, has_key_path was added to distinguish null vs. string. |
1011 // (2) Later, null vs. string vs. array was stored in the key_path itself. | 988 // (2) Later, null vs. string vs. array was stored in the key_path itself. |
1012 // So this check is only relevant for string-type key_paths. | 989 // So this check is only relevant for string-type key_paths. |
1013 if (!has_key_path && | 990 if (!has_key_path && |
1014 (key_path.type() == WebKit::WebIDBKeyPath::StringType && | 991 (key_path.type() == WebKit::WebIDBKeyPath::StringType && |
1015 !key_path.string().empty())) { | 992 !key_path.string().empty())) { |
1016 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 993 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
1017 break; | 994 break; |
1018 } | 995 } |
1019 if (!has_key_path) | 996 if (!has_key_path) |
1020 key_path = IndexedDBKeyPath(); | 997 key_path = IndexedDBKeyPath(); |
1021 it->Next(); | 998 it->Next(); |
1022 } | 999 } |
1023 | 1000 |
1024 int64 key_generator_current_number = -1; | 1001 int64 key_generator_current_number = -1; |
1025 if (CheckObjectStoreAndMetaDataType( | 1002 if (CheckObjectStoreAndMetaDataType( |
1026 it.get(), | 1003 it.get(), |
1027 stop_key, | 1004 stop_key, |
1028 object_store_id, | 1005 object_store_id, |
1029 ObjectStoreMetaDataKey::KEY_GENERATOR_CURRENT_NUMBER)) { | 1006 ObjectStoreMetaDataKey::KEY_GENERATOR_CURRENT_NUMBER)) { |
1030 StringPiece slice(it->Value().AsStringPiece()); | 1007 StringPiece slice(it->Value()); |
1031 if (!DecodeInt(&slice, &key_generator_current_number) || !slice.empty()) | 1008 if (!DecodeInt(&slice, &key_generator_current_number) || !slice.empty()) |
1032 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); | 1009 INTERNAL_CONSISTENCY_ERROR(GET_OBJECT_STORES); |
1033 | 1010 |
1034 // TODO(jsbell): Return key_generator_current_number, cache in | 1011 // TODO(jsbell): Return key_generator_current_number, cache in |
1035 // object store, and write lazily to backing store. For now, | 1012 // object store, and write lazily to backing store. For now, |
1036 // just assert that if it was written it was valid. | 1013 // just assert that if it was written it was valid. |
1037 DCHECK_GE(key_generator_current_number, kKeyGeneratorInitialNumber); | 1014 DCHECK_GE(key_generator_current_number, kKeyGeneratorInitialNumber); |
1038 it->Next(); | 1015 it->Next(); |
1039 } | 1016 } |
1040 | 1017 |
1041 IndexedDBObjectStoreMetadata metadata(object_store_name, | 1018 IndexedDBObjectStoreMetadata metadata(object_store_name, |
1042 object_store_id, | 1019 object_store_id, |
1043 key_path, | 1020 key_path, |
1044 auto_increment, | 1021 auto_increment, |
1045 max_index_id); | 1022 max_index_id); |
1046 if (!GetIndexes(database_id, object_store_id, &metadata.indexes)) | 1023 if (!GetIndexes(database_id, object_store_id, &metadata.indexes)) |
1047 return false; | 1024 return false; |
1048 (*object_stores)[object_store_id] = metadata; | 1025 (*object_stores)[object_store_id] = metadata; |
1049 } | 1026 } |
1050 return true; | 1027 return true; |
1051 } | 1028 } |
1052 | 1029 |
1053 WARN_UNUSED_RESULT static bool SetMaxObjectStoreId( | 1030 WARN_UNUSED_RESULT static bool SetMaxObjectStoreId( |
1054 LevelDBTransaction* transaction, | 1031 LevelDBTransaction* transaction, |
1055 int64 database_id, | 1032 int64 database_id, |
1056 int64 object_store_id) { | 1033 int64 object_store_id) { |
1057 const std::vector<char> max_object_store_id_key = DatabaseMetaDataKey::Encode( | 1034 const std::string max_object_store_id_key = DatabaseMetaDataKey::Encode( |
1058 database_id, DatabaseMetaDataKey::MAX_OBJECT_STORE_ID); | 1035 database_id, DatabaseMetaDataKey::MAX_OBJECT_STORE_ID); |
1059 int64 max_object_store_id = -1; | 1036 int64 max_object_store_id = -1; |
1060 bool ok = GetMaxObjectStoreId( | 1037 bool ok = GetMaxObjectStoreId( |
1061 transaction, max_object_store_id_key, &max_object_store_id); | 1038 transaction, max_object_store_id_key, &max_object_store_id); |
1062 if (!ok) { | 1039 if (!ok) { |
1063 INTERNAL_READ_ERROR(SET_MAX_OBJECT_STORE_ID); | 1040 INTERNAL_READ_ERROR(SET_MAX_OBJECT_STORE_ID); |
1064 return false; | 1041 return false; |
1065 } | 1042 } |
1066 | 1043 |
1067 if (object_store_id <= max_object_store_id) { | 1044 if (object_store_id <= max_object_store_id) { |
1068 INTERNAL_CONSISTENCY_ERROR(SET_MAX_OBJECT_STORE_ID); | 1045 INTERNAL_CONSISTENCY_ERROR(SET_MAX_OBJECT_STORE_ID); |
1069 return false; | 1046 return false; |
1070 } | 1047 } |
1071 PutInt(transaction, LevelDBSlice(max_object_store_id_key), object_store_id); | 1048 PutInt(transaction, max_object_store_id_key, object_store_id); |
1072 return true; | 1049 return true; |
1073 } | 1050 } |
1074 | 1051 |
1075 bool IndexedDBBackingStore::CreateObjectStore( | 1052 bool IndexedDBBackingStore::CreateObjectStore( |
1076 IndexedDBBackingStore::Transaction* transaction, | 1053 IndexedDBBackingStore::Transaction* transaction, |
1077 int64 database_id, | 1054 int64 database_id, |
1078 int64 object_store_id, | 1055 int64 object_store_id, |
1079 const string16& name, | 1056 const string16& name, |
1080 const IndexedDBKeyPath& key_path, | 1057 const IndexedDBKeyPath& key_path, |
1081 bool auto_increment) { | 1058 bool auto_increment) { |
1082 IDB_TRACE("IndexedDBBackingStore::CreateObjectStore"); | 1059 IDB_TRACE("IndexedDBBackingStore::CreateObjectStore"); |
1083 if (!KeyPrefix::ValidIds(database_id, object_store_id)) | 1060 if (!KeyPrefix::ValidIds(database_id, object_store_id)) |
1084 return false; | 1061 return false; |
1085 LevelDBTransaction* leveldb_transaction = | 1062 LevelDBTransaction* leveldb_transaction = |
1086 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1063 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1087 if (!SetMaxObjectStoreId(leveldb_transaction, database_id, object_store_id)) | 1064 if (!SetMaxObjectStoreId(leveldb_transaction, database_id, object_store_id)) |
1088 return false; | 1065 return false; |
1089 | 1066 |
1090 const std::vector<char> name_key = ObjectStoreMetaDataKey::Encode( | 1067 const std::string name_key = ObjectStoreMetaDataKey::Encode( |
1091 database_id, object_store_id, ObjectStoreMetaDataKey::NAME); | 1068 database_id, object_store_id, ObjectStoreMetaDataKey::NAME); |
1092 const std::vector<char> key_path_key = ObjectStoreMetaDataKey::Encode( | 1069 const std::string key_path_key = ObjectStoreMetaDataKey::Encode( |
1093 database_id, object_store_id, ObjectStoreMetaDataKey::KEY_PATH); | 1070 database_id, object_store_id, ObjectStoreMetaDataKey::KEY_PATH); |
1094 const std::vector<char> auto_increment_key = ObjectStoreMetaDataKey::Encode( | 1071 const std::string auto_increment_key = ObjectStoreMetaDataKey::Encode( |
1095 database_id, object_store_id, ObjectStoreMetaDataKey::AUTO_INCREMENT); | 1072 database_id, object_store_id, ObjectStoreMetaDataKey::AUTO_INCREMENT); |
1096 const std::vector<char> evictable_key = ObjectStoreMetaDataKey::Encode( | 1073 const std::string evictable_key = ObjectStoreMetaDataKey::Encode( |
1097 database_id, object_store_id, ObjectStoreMetaDataKey::EVICTABLE); | 1074 database_id, object_store_id, ObjectStoreMetaDataKey::EVICTABLE); |
1098 const std::vector<char> last_version_key = ObjectStoreMetaDataKey::Encode( | 1075 const std::string last_version_key = ObjectStoreMetaDataKey::Encode( |
1099 database_id, object_store_id, ObjectStoreMetaDataKey::LAST_VERSION); | 1076 database_id, object_store_id, ObjectStoreMetaDataKey::LAST_VERSION); |
1100 const std::vector<char> max_index_id_key = ObjectStoreMetaDataKey::Encode( | 1077 const std::string max_index_id_key = ObjectStoreMetaDataKey::Encode( |
1101 database_id, object_store_id, ObjectStoreMetaDataKey::MAX_INDEX_ID); | 1078 database_id, object_store_id, ObjectStoreMetaDataKey::MAX_INDEX_ID); |
1102 const std::vector<char> has_key_path_key = ObjectStoreMetaDataKey::Encode( | 1079 const std::string has_key_path_key = ObjectStoreMetaDataKey::Encode( |
1103 database_id, object_store_id, ObjectStoreMetaDataKey::HAS_KEY_PATH); | 1080 database_id, object_store_id, ObjectStoreMetaDataKey::HAS_KEY_PATH); |
1104 const std::vector<char> key_generator_current_number_key = | 1081 const std::string key_generator_current_number_key = |
1105 ObjectStoreMetaDataKey::Encode( | 1082 ObjectStoreMetaDataKey::Encode( |
1106 database_id, | 1083 database_id, |
1107 object_store_id, | 1084 object_store_id, |
1108 ObjectStoreMetaDataKey::KEY_GENERATOR_CURRENT_NUMBER); | 1085 ObjectStoreMetaDataKey::KEY_GENERATOR_CURRENT_NUMBER); |
1109 const std::vector<char> names_key = | 1086 const std::string names_key = ObjectStoreNamesKey::Encode(database_id, name); |
1110 ObjectStoreNamesKey::Encode(database_id, name); | |
1111 | 1087 |
1112 PutString(leveldb_transaction, LevelDBSlice(name_key), name); | 1088 PutString(leveldb_transaction, name_key, name); |
1113 PutIDBKeyPath(leveldb_transaction, LevelDBSlice(key_path_key), key_path); | 1089 PutIDBKeyPath(leveldb_transaction, key_path_key, key_path); |
1114 PutInt(leveldb_transaction, LevelDBSlice(auto_increment_key), auto_increment); | 1090 PutInt(leveldb_transaction, auto_increment_key, auto_increment); |
1115 PutInt(leveldb_transaction, LevelDBSlice(evictable_key), false); | 1091 PutInt(leveldb_transaction, evictable_key, false); |
1116 PutInt(leveldb_transaction, LevelDBSlice(last_version_key), 1); | 1092 PutInt(leveldb_transaction, last_version_key, 1); |
1117 PutInt(leveldb_transaction, LevelDBSlice(max_index_id_key), kMinimumIndexId); | 1093 PutInt(leveldb_transaction, max_index_id_key, kMinimumIndexId); |
1118 PutBool( | 1094 PutBool(leveldb_transaction, has_key_path_key, !key_path.IsNull()); |
1119 leveldb_transaction, LevelDBSlice(has_key_path_key), !key_path.IsNull()); | |
1120 PutInt(leveldb_transaction, | 1095 PutInt(leveldb_transaction, |
1121 LevelDBSlice(key_generator_current_number_key), | 1096 key_generator_current_number_key, |
1122 kKeyGeneratorInitialNumber); | 1097 kKeyGeneratorInitialNumber); |
1123 PutInt(leveldb_transaction, LevelDBSlice(names_key), object_store_id); | 1098 PutInt(leveldb_transaction, names_key, object_store_id); |
1124 return true; | 1099 return true; |
1125 } | 1100 } |
1126 | 1101 |
1127 bool IndexedDBBackingStore::DeleteObjectStore( | 1102 bool IndexedDBBackingStore::DeleteObjectStore( |
1128 IndexedDBBackingStore::Transaction* transaction, | 1103 IndexedDBBackingStore::Transaction* transaction, |
1129 int64 database_id, | 1104 int64 database_id, |
1130 int64 object_store_id) { | 1105 int64 object_store_id) { |
1131 IDB_TRACE("IndexedDBBackingStore::DeleteObjectStore"); | 1106 IDB_TRACE("IndexedDBBackingStore::DeleteObjectStore"); |
1132 if (!KeyPrefix::ValidIds(database_id, object_store_id)) | 1107 if (!KeyPrefix::ValidIds(database_id, object_store_id)) |
1133 return false; | 1108 return false; |
1134 LevelDBTransaction* leveldb_transaction = | 1109 LevelDBTransaction* leveldb_transaction = |
1135 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1110 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1136 | 1111 |
1137 string16 object_store_name; | 1112 string16 object_store_name; |
1138 bool found = false; | 1113 bool found = false; |
1139 bool ok = GetString( | 1114 bool ok = GetString( |
1140 leveldb_transaction, | 1115 leveldb_transaction, |
1141 LevelDBSlice(ObjectStoreMetaDataKey::Encode( | 1116 ObjectStoreMetaDataKey::Encode( |
1142 database_id, object_store_id, ObjectStoreMetaDataKey::NAME)), | 1117 database_id, object_store_id, ObjectStoreMetaDataKey::NAME), |
1143 &object_store_name, | 1118 &object_store_name, |
1144 &found); | 1119 &found); |
1145 if (!ok) { | 1120 if (!ok) { |
1146 INTERNAL_READ_ERROR(DELETE_OBJECT_STORE); | 1121 INTERNAL_READ_ERROR(DELETE_OBJECT_STORE); |
1147 return false; | 1122 return false; |
1148 } | 1123 } |
1149 if (!found) { | 1124 if (!found) { |
1150 INTERNAL_CONSISTENCY_ERROR(DELETE_OBJECT_STORE); | 1125 INTERNAL_CONSISTENCY_ERROR(DELETE_OBJECT_STORE); |
1151 return false; | 1126 return false; |
1152 } | 1127 } |
1153 | 1128 |
1154 DeleteRange( | 1129 DeleteRange( |
1155 leveldb_transaction, | 1130 leveldb_transaction, |
1156 ObjectStoreMetaDataKey::Encode(database_id, object_store_id, 0), | 1131 ObjectStoreMetaDataKey::Encode(database_id, object_store_id, 0), |
1157 ObjectStoreMetaDataKey::EncodeMaxKey(database_id, object_store_id)); | 1132 ObjectStoreMetaDataKey::EncodeMaxKey(database_id, object_store_id)); |
1158 | 1133 |
1159 leveldb_transaction->Remove(LevelDBSlice( | 1134 leveldb_transaction->Remove( |
1160 ObjectStoreNamesKey::Encode(database_id, object_store_name))); | 1135 ObjectStoreNamesKey::Encode(database_id, object_store_name)); |
1161 | 1136 |
1162 DeleteRange(leveldb_transaction, | 1137 DeleteRange(leveldb_transaction, |
1163 IndexFreeListKey::Encode(database_id, object_store_id, 0), | 1138 IndexFreeListKey::Encode(database_id, object_store_id, 0), |
1164 IndexFreeListKey::EncodeMaxKey(database_id, object_store_id)); | 1139 IndexFreeListKey::EncodeMaxKey(database_id, object_store_id)); |
1165 DeleteRange(leveldb_transaction, | 1140 DeleteRange(leveldb_transaction, |
1166 IndexMetaDataKey::Encode(database_id, object_store_id, 0, 0), | 1141 IndexMetaDataKey::Encode(database_id, object_store_id, 0, 0), |
1167 IndexMetaDataKey::EncodeMaxKey(database_id, object_store_id)); | 1142 IndexMetaDataKey::EncodeMaxKey(database_id, object_store_id)); |
1168 | 1143 |
1169 return ClearObjectStore(transaction, database_id, object_store_id); | 1144 return ClearObjectStore(transaction, database_id, object_store_id); |
1170 } | 1145 } |
1171 | 1146 |
1172 bool IndexedDBBackingStore::GetRecord( | 1147 bool IndexedDBBackingStore::GetRecord( |
1173 IndexedDBBackingStore::Transaction* transaction, | 1148 IndexedDBBackingStore::Transaction* transaction, |
1174 int64 database_id, | 1149 int64 database_id, |
1175 int64 object_store_id, | 1150 int64 object_store_id, |
1176 const IndexedDBKey& key, | 1151 const IndexedDBKey& key, |
1177 std::vector<char>* record) { | 1152 std::string* record) { |
1178 IDB_TRACE("IndexedDBBackingStore::GetRecord"); | 1153 IDB_TRACE("IndexedDBBackingStore::GetRecord"); |
1179 if (!KeyPrefix::ValidIds(database_id, object_store_id)) | 1154 if (!KeyPrefix::ValidIds(database_id, object_store_id)) |
1180 return false; | 1155 return false; |
1181 LevelDBTransaction* leveldb_transaction = | 1156 LevelDBTransaction* leveldb_transaction = |
1182 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1157 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1183 | 1158 |
1184 const std::vector<char> leveldb_key = | 1159 const std::string leveldb_key = |
1185 ObjectStoreDataKey::Encode(database_id, object_store_id, key); | 1160 ObjectStoreDataKey::Encode(database_id, object_store_id, key); |
1186 std::string data; | 1161 std::string data; |
1187 | 1162 |
1188 record->clear(); | 1163 record->clear(); |
1189 | 1164 |
1190 bool found = false; | 1165 bool found = false; |
1191 bool ok = leveldb_transaction->Get(LevelDBSlice(leveldb_key), &data, &found); | 1166 bool ok = leveldb_transaction->Get(leveldb_key, &data, &found); |
1192 if (!ok) { | 1167 if (!ok) { |
1193 INTERNAL_READ_ERROR(GET_RECORD); | 1168 INTERNAL_READ_ERROR(GET_RECORD); |
1194 return false; | 1169 return false; |
1195 } | 1170 } |
1196 if (!found) | 1171 if (!found) |
1197 return true; | 1172 return true; |
1198 if (data.empty()) { | 1173 if (data.empty()) { |
1199 INTERNAL_READ_ERROR(GET_RECORD); | 1174 INTERNAL_READ_ERROR(GET_RECORD); |
1200 return false; | 1175 return false; |
1201 } | 1176 } |
1202 | 1177 |
1203 int64 version; | 1178 int64 version; |
1204 StringPiece slice(data); | 1179 StringPiece slice(data); |
1205 if (!DecodeVarInt(&slice, &version)) { | 1180 if (!DecodeVarInt(&slice, &version)) { |
1206 INTERNAL_READ_ERROR(GET_RECORD); | 1181 INTERNAL_READ_ERROR(GET_RECORD); |
1207 return false; | 1182 return false; |
1208 } | 1183 } |
1209 | 1184 |
1210 record->insert(record->end(), slice.begin(), slice.end()); | 1185 *record = slice.as_string(); |
1211 return true; | 1186 return true; |
1212 } | 1187 } |
1213 | 1188 |
1214 WARN_UNUSED_RESULT static bool GetNewVersionNumber( | 1189 WARN_UNUSED_RESULT static bool GetNewVersionNumber( |
1215 LevelDBTransaction* transaction, | 1190 LevelDBTransaction* transaction, |
1216 int64 database_id, | 1191 int64 database_id, |
1217 int64 object_store_id, | 1192 int64 object_store_id, |
1218 int64* new_version_number) { | 1193 int64* new_version_number) { |
1219 const std::vector<char> last_version_key = ObjectStoreMetaDataKey::Encode( | 1194 const std::string last_version_key = ObjectStoreMetaDataKey::Encode( |
1220 database_id, object_store_id, ObjectStoreMetaDataKey::LAST_VERSION); | 1195 database_id, object_store_id, ObjectStoreMetaDataKey::LAST_VERSION); |
1221 | 1196 |
1222 *new_version_number = -1; | 1197 *new_version_number = -1; |
1223 int64 last_version = -1; | 1198 int64 last_version = -1; |
1224 bool found = false; | 1199 bool found = false; |
1225 bool ok = GetInt( | 1200 bool ok = GetInt(transaction, last_version_key, &last_version, &found); |
1226 transaction, LevelDBSlice(last_version_key), &last_version, &found); | |
1227 if (!ok) { | 1201 if (!ok) { |
1228 INTERNAL_READ_ERROR(GET_NEW_VERSION_NUMBER); | 1202 INTERNAL_READ_ERROR(GET_NEW_VERSION_NUMBER); |
1229 return false; | 1203 return false; |
1230 } | 1204 } |
1231 if (!found) | 1205 if (!found) |
1232 last_version = 0; | 1206 last_version = 0; |
1233 | 1207 |
1234 DCHECK_GE(last_version, 0); | 1208 DCHECK_GE(last_version, 0); |
1235 | 1209 |
1236 int64 version = last_version + 1; | 1210 int64 version = last_version + 1; |
1237 PutInt(transaction, LevelDBSlice(last_version_key), version); | 1211 PutInt(transaction, last_version_key, version); |
1238 | 1212 |
1239 // TODO(jsbell): Think about how we want to handle the overflow scenario. | 1213 // TODO(jsbell): Think about how we want to handle the overflow scenario. |
1240 DCHECK(version > last_version); | 1214 DCHECK(version > last_version); |
1241 | 1215 |
1242 *new_version_number = version; | 1216 *new_version_number = version; |
1243 return true; | 1217 return true; |
1244 } | 1218 } |
1245 | 1219 |
1246 bool IndexedDBBackingStore::PutRecord( | 1220 bool IndexedDBBackingStore::PutRecord( |
1247 IndexedDBBackingStore::Transaction* transaction, | 1221 IndexedDBBackingStore::Transaction* transaction, |
1248 int64 database_id, | 1222 int64 database_id, |
1249 int64 object_store_id, | 1223 int64 object_store_id, |
1250 const IndexedDBKey& key, | 1224 const IndexedDBKey& key, |
1251 const std::vector<char>& value, | 1225 const std::string& value, |
1252 RecordIdentifier* record_identifier) { | 1226 RecordIdentifier* record_identifier) { |
1253 IDB_TRACE("IndexedDBBackingStore::PutRecord"); | 1227 IDB_TRACE("IndexedDBBackingStore::PutRecord"); |
1254 if (!KeyPrefix::ValidIds(database_id, object_store_id)) | 1228 if (!KeyPrefix::ValidIds(database_id, object_store_id)) |
1255 return false; | 1229 return false; |
1256 DCHECK(key.IsValid()); | 1230 DCHECK(key.IsValid()); |
1257 | 1231 |
1258 LevelDBTransaction* leveldb_transaction = | 1232 LevelDBTransaction* leveldb_transaction = |
1259 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1233 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1260 int64 version = -1; | 1234 int64 version = -1; |
1261 bool ok = GetNewVersionNumber( | 1235 bool ok = GetNewVersionNumber( |
1262 leveldb_transaction, database_id, object_store_id, &version); | 1236 leveldb_transaction, database_id, object_store_id, &version); |
1263 if (!ok) | 1237 if (!ok) |
1264 return false; | 1238 return false; |
1265 DCHECK_GE(version, 0); | 1239 DCHECK_GE(version, 0); |
1266 const std::vector<char> object_storedata_key = | 1240 const std::string object_storedata_key = |
1267 ObjectStoreDataKey::Encode(database_id, object_store_id, key); | 1241 ObjectStoreDataKey::Encode(database_id, object_store_id, key); |
1268 | 1242 |
1269 std::vector<char> v; | 1243 std::string v; |
1270 EncodeVarInt(version, &v); | 1244 EncodeVarInt(version, &v); |
1271 v.insert(v.end(), value.begin(), value.end()); | 1245 v.append(value); |
1272 | 1246 |
1273 leveldb_transaction->Put(LevelDBSlice(object_storedata_key), &v); | 1247 leveldb_transaction->Put(object_storedata_key, &v); |
1274 | 1248 |
1275 const std::vector<char> exists_entry_key = | 1249 const std::string exists_entry_key = |
1276 ExistsEntryKey::Encode(database_id, object_store_id, key); | 1250 ExistsEntryKey::Encode(database_id, object_store_id, key); |
1277 std::vector<char> version_encoded; | 1251 std::string version_encoded; |
1278 EncodeInt(version, &version_encoded); | 1252 EncodeInt(version, &version_encoded); |
1279 leveldb_transaction->Put(LevelDBSlice(exists_entry_key), &version_encoded); | 1253 leveldb_transaction->Put(exists_entry_key, &version_encoded); |
1280 | 1254 |
1281 std::vector<char> key_encoded; | 1255 std::string key_encoded; |
1282 EncodeIDBKey(key, &key_encoded); | 1256 EncodeIDBKey(key, &key_encoded); |
1283 record_identifier->Reset(key_encoded, version); | 1257 record_identifier->Reset(key_encoded, version); |
1284 return true; | 1258 return true; |
1285 } | 1259 } |
1286 | 1260 |
1287 bool IndexedDBBackingStore::ClearObjectStore( | 1261 bool IndexedDBBackingStore::ClearObjectStore( |
1288 IndexedDBBackingStore::Transaction* transaction, | 1262 IndexedDBBackingStore::Transaction* transaction, |
1289 int64 database_id, | 1263 int64 database_id, |
1290 int64 object_store_id) { | 1264 int64 object_store_id) { |
1291 IDB_TRACE("IndexedDBBackingStore::ClearObjectStore"); | 1265 IDB_TRACE("IndexedDBBackingStore::ClearObjectStore"); |
1292 if (!KeyPrefix::ValidIds(database_id, object_store_id)) | 1266 if (!KeyPrefix::ValidIds(database_id, object_store_id)) |
1293 return false; | 1267 return false; |
1294 LevelDBTransaction* leveldb_transaction = | 1268 LevelDBTransaction* leveldb_transaction = |
1295 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1269 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1296 const std::vector<char> start_key = | 1270 const std::string start_key = |
1297 KeyPrefix(database_id, object_store_id).Encode(); | 1271 KeyPrefix(database_id, object_store_id).Encode(); |
1298 const std::vector<char> stop_key = | 1272 const std::string stop_key = |
1299 KeyPrefix(database_id, object_store_id + 1).Encode(); | 1273 KeyPrefix(database_id, object_store_id + 1).Encode(); |
1300 | 1274 |
1301 DeleteRange(leveldb_transaction, start_key, stop_key); | 1275 DeleteRange(leveldb_transaction, start_key, stop_key); |
1302 return true; | 1276 return true; |
1303 } | 1277 } |
1304 | 1278 |
1305 bool IndexedDBBackingStore::DeleteRecord( | 1279 bool IndexedDBBackingStore::DeleteRecord( |
1306 IndexedDBBackingStore::Transaction* transaction, | 1280 IndexedDBBackingStore::Transaction* transaction, |
1307 int64 database_id, | 1281 int64 database_id, |
1308 int64 object_store_id, | 1282 int64 object_store_id, |
1309 const RecordIdentifier& record_identifier) { | 1283 const RecordIdentifier& record_identifier) { |
1310 IDB_TRACE("IndexedDBBackingStore::DeleteRecord"); | 1284 IDB_TRACE("IndexedDBBackingStore::DeleteRecord"); |
1311 if (!KeyPrefix::ValidIds(database_id, object_store_id)) | 1285 if (!KeyPrefix::ValidIds(database_id, object_store_id)) |
1312 return false; | 1286 return false; |
1313 LevelDBTransaction* leveldb_transaction = | 1287 LevelDBTransaction* leveldb_transaction = |
1314 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1288 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1315 | 1289 |
1316 const std::vector<char> object_store_data_key = ObjectStoreDataKey::Encode( | 1290 const std::string object_store_data_key = ObjectStoreDataKey::Encode( |
1317 database_id, object_store_id, record_identifier.primary_key()); | 1291 database_id, object_store_id, record_identifier.primary_key()); |
1318 leveldb_transaction->Remove(LevelDBSlice(object_store_data_key)); | 1292 leveldb_transaction->Remove(object_store_data_key); |
1319 | 1293 |
1320 const std::vector<char> exists_entry_key = ExistsEntryKey::Encode( | 1294 const std::string exists_entry_key = ExistsEntryKey::Encode( |
1321 database_id, object_store_id, record_identifier.primary_key()); | 1295 database_id, object_store_id, record_identifier.primary_key()); |
1322 leveldb_transaction->Remove(LevelDBSlice(exists_entry_key)); | 1296 leveldb_transaction->Remove(exists_entry_key); |
1323 return true; | 1297 return true; |
1324 } | 1298 } |
1325 | 1299 |
1326 bool IndexedDBBackingStore::GetKeyGeneratorCurrentNumber( | 1300 bool IndexedDBBackingStore::GetKeyGeneratorCurrentNumber( |
1327 IndexedDBBackingStore::Transaction* transaction, | 1301 IndexedDBBackingStore::Transaction* transaction, |
1328 int64 database_id, | 1302 int64 database_id, |
1329 int64 object_store_id, | 1303 int64 object_store_id, |
1330 int64* key_generator_current_number) { | 1304 int64* key_generator_current_number) { |
1331 if (!KeyPrefix::ValidIds(database_id, object_store_id)) | 1305 if (!KeyPrefix::ValidIds(database_id, object_store_id)) |
1332 return false; | 1306 return false; |
1333 LevelDBTransaction* leveldb_transaction = | 1307 LevelDBTransaction* leveldb_transaction = |
1334 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1308 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1335 | 1309 |
1336 const std::vector<char> key_generator_current_number_key = | 1310 const std::string key_generator_current_number_key = |
1337 ObjectStoreMetaDataKey::Encode( | 1311 ObjectStoreMetaDataKey::Encode( |
1338 database_id, | 1312 database_id, |
1339 object_store_id, | 1313 object_store_id, |
1340 ObjectStoreMetaDataKey::KEY_GENERATOR_CURRENT_NUMBER); | 1314 ObjectStoreMetaDataKey::KEY_GENERATOR_CURRENT_NUMBER); |
1341 | 1315 |
1342 *key_generator_current_number = -1; | 1316 *key_generator_current_number = -1; |
1343 std::string data; | 1317 std::string data; |
1344 | 1318 |
1345 bool found = false; | 1319 bool found = false; |
1346 bool ok = leveldb_transaction->Get( | 1320 bool ok = |
1347 LevelDBSlice(key_generator_current_number_key), &data, &found); | 1321 leveldb_transaction->Get(key_generator_current_number_key, &data, &found); |
1348 if (!ok) { | 1322 if (!ok) { |
1349 INTERNAL_READ_ERROR(GET_KEY_GENERATOR_CURRENT_NUMBER); | 1323 INTERNAL_READ_ERROR(GET_KEY_GENERATOR_CURRENT_NUMBER); |
1350 return false; | 1324 return false; |
1351 } | 1325 } |
1352 if (found && !data.empty()) { | 1326 if (found && !data.empty()) { |
1353 StringPiece slice(data); | 1327 StringPiece slice(data); |
1354 if (!DecodeInt(&slice, key_generator_current_number) || !slice.empty()) { | 1328 if (!DecodeInt(&slice, key_generator_current_number) || !slice.empty()) { |
1355 INTERNAL_READ_ERROR(GET_KEY_GENERATOR_CURRENT_NUMBER); | 1329 INTERNAL_READ_ERROR(GET_KEY_GENERATOR_CURRENT_NUMBER); |
1356 return false; | 1330 return false; |
1357 } | 1331 } |
1358 return true; | 1332 return true; |
1359 } | 1333 } |
1360 | 1334 |
1361 // Previously, the key generator state was not stored explicitly | 1335 // Previously, the key generator state was not stored explicitly |
1362 // but derived from the maximum numeric key present in existing | 1336 // but derived from the maximum numeric key present in existing |
1363 // data. This violates the spec as the data may be cleared but the | 1337 // data. This violates the spec as the data may be cleared but the |
1364 // key generator state must be preserved. | 1338 // key generator state must be preserved. |
1365 // TODO(jsbell): Fix this for all stores on database open? | 1339 // TODO(jsbell): Fix this for all stores on database open? |
1366 const std::vector<char> start_key = | 1340 const std::string start_key = |
1367 ObjectStoreDataKey::Encode(database_id, object_store_id, MinIDBKey()); | 1341 ObjectStoreDataKey::Encode(database_id, object_store_id, MinIDBKey()); |
1368 const std::vector<char> stop_key = | 1342 const std::string stop_key = |
1369 ObjectStoreDataKey::Encode(database_id, object_store_id, MaxIDBKey()); | 1343 ObjectStoreDataKey::Encode(database_id, object_store_id, MaxIDBKey()); |
1370 | 1344 |
1371 scoped_ptr<LevelDBIterator> it = leveldb_transaction->CreateIterator(); | 1345 scoped_ptr<LevelDBIterator> it = leveldb_transaction->CreateIterator(); |
1372 int64 max_numeric_key = 0; | 1346 int64 max_numeric_key = 0; |
1373 | 1347 |
1374 for (it->Seek(LevelDBSlice(start_key)); | 1348 for (it->Seek(start_key); |
1375 it->IsValid() && CompareKeys(it->Key(), LevelDBSlice(stop_key)) < 0; | 1349 it->IsValid() && CompareKeys(it->Key(), stop_key) < 0; |
1376 it->Next()) { | 1350 it->Next()) { |
1377 const char* p = it->Key().begin(); | 1351 const char* p = it->Key().begin(); |
1378 const char* limit = it->Key().end(); | 1352 const char* limit = it->Key().end(); |
1379 | 1353 |
1380 ObjectStoreDataKey data_key; | 1354 ObjectStoreDataKey data_key; |
1381 p = ObjectStoreDataKey::Decode(p, limit, &data_key); | 1355 p = ObjectStoreDataKey::Decode(p, limit, &data_key); |
1382 DCHECK(p); | 1356 DCHECK(p); |
1383 | 1357 |
1384 scoped_ptr<IndexedDBKey> user_key = data_key.user_key(); | 1358 scoped_ptr<IndexedDBKey> user_key = data_key.user_key(); |
1385 if (user_key->type() == WebKit::WebIDBKey::NumberType) { | 1359 if (user_key->type() == WebKit::WebIDBKey::NumberType) { |
(...skipping 21 matching lines...) Expand all Loading... |
1407 if (check_current) { | 1381 if (check_current) { |
1408 int64 current_number; | 1382 int64 current_number; |
1409 bool ok = GetKeyGeneratorCurrentNumber( | 1383 bool ok = GetKeyGeneratorCurrentNumber( |
1410 transaction, database_id, object_store_id, ¤t_number); | 1384 transaction, database_id, object_store_id, ¤t_number); |
1411 if (!ok) | 1385 if (!ok) |
1412 return false; | 1386 return false; |
1413 if (new_number <= current_number) | 1387 if (new_number <= current_number) |
1414 return true; | 1388 return true; |
1415 } | 1389 } |
1416 | 1390 |
1417 const std::vector<char> key_generator_current_number_key = | 1391 const std::string key_generator_current_number_key = |
1418 ObjectStoreMetaDataKey::Encode( | 1392 ObjectStoreMetaDataKey::Encode( |
1419 database_id, | 1393 database_id, |
1420 object_store_id, | 1394 object_store_id, |
1421 ObjectStoreMetaDataKey::KEY_GENERATOR_CURRENT_NUMBER); | 1395 ObjectStoreMetaDataKey::KEY_GENERATOR_CURRENT_NUMBER); |
1422 PutInt(leveldb_transaction, | 1396 PutInt(leveldb_transaction, key_generator_current_number_key, new_number); |
1423 LevelDBSlice(key_generator_current_number_key), | |
1424 new_number); | |
1425 return true; | 1397 return true; |
1426 } | 1398 } |
1427 | 1399 |
1428 bool IndexedDBBackingStore::KeyExistsInObjectStore( | 1400 bool IndexedDBBackingStore::KeyExistsInObjectStore( |
1429 IndexedDBBackingStore::Transaction* transaction, | 1401 IndexedDBBackingStore::Transaction* transaction, |
1430 int64 database_id, | 1402 int64 database_id, |
1431 int64 object_store_id, | 1403 int64 object_store_id, |
1432 const IndexedDBKey& key, | 1404 const IndexedDBKey& key, |
1433 RecordIdentifier* found_record_identifier, | 1405 RecordIdentifier* found_record_identifier, |
1434 bool* found) { | 1406 bool* found) { |
1435 IDB_TRACE("IndexedDBBackingStore::KeyExistsInObjectStore"); | 1407 IDB_TRACE("IndexedDBBackingStore::KeyExistsInObjectStore"); |
1436 if (!KeyPrefix::ValidIds(database_id, object_store_id)) | 1408 if (!KeyPrefix::ValidIds(database_id, object_store_id)) |
1437 return false; | 1409 return false; |
1438 *found = false; | 1410 *found = false; |
1439 LevelDBTransaction* leveldb_transaction = | 1411 LevelDBTransaction* leveldb_transaction = |
1440 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1412 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1441 const std::vector<char> leveldb_key = | 1413 const std::string leveldb_key = |
1442 ObjectStoreDataKey::Encode(database_id, object_store_id, key); | 1414 ObjectStoreDataKey::Encode(database_id, object_store_id, key); |
1443 std::string data; | 1415 std::string data; |
1444 | 1416 |
1445 bool ok = leveldb_transaction->Get(LevelDBSlice(leveldb_key), &data, found); | 1417 bool ok = leveldb_transaction->Get(leveldb_key, &data, found); |
1446 if (!ok) { | 1418 if (!ok) { |
1447 INTERNAL_READ_ERROR(KEY_EXISTS_IN_OBJECT_STORE); | 1419 INTERNAL_READ_ERROR(KEY_EXISTS_IN_OBJECT_STORE); |
1448 return false; | 1420 return false; |
1449 } | 1421 } |
1450 if (!*found) | 1422 if (!*found) |
1451 return true; | 1423 return true; |
1452 if (!data.size()) { | 1424 if (!data.size()) { |
1453 INTERNAL_READ_ERROR(KEY_EXISTS_IN_OBJECT_STORE); | 1425 INTERNAL_READ_ERROR(KEY_EXISTS_IN_OBJECT_STORE); |
1454 return false; | 1426 return false; |
1455 } | 1427 } |
1456 | 1428 |
1457 int64 version; | 1429 int64 version; |
1458 StringPiece slice(data); | 1430 StringPiece slice(data); |
1459 if (!DecodeVarInt(&slice, &version)) | 1431 if (!DecodeVarInt(&slice, &version)) |
1460 return false; | 1432 return false; |
1461 | 1433 |
1462 std::vector<char> encoded_key; | 1434 std::string encoded_key; |
1463 EncodeIDBKey(key, &encoded_key); | 1435 EncodeIDBKey(key, &encoded_key); |
1464 found_record_identifier->Reset(encoded_key, version); | 1436 found_record_identifier->Reset(encoded_key, version); |
1465 return true; | 1437 return true; |
1466 } | 1438 } |
1467 | 1439 |
1468 static bool CheckIndexAndMetaDataKey(const LevelDBIterator* it, | 1440 static bool CheckIndexAndMetaDataKey(const LevelDBIterator* it, |
1469 const std::vector<char>& stop_key, | 1441 const std::string& stop_key, |
1470 int64 index_id, | 1442 int64 index_id, |
1471 unsigned char meta_data_type) { | 1443 unsigned char meta_data_type) { |
1472 if (!it->IsValid() || CompareKeys(it->Key(), LevelDBSlice(stop_key)) >= 0) | 1444 if (!it->IsValid() || CompareKeys(it->Key(), stop_key) >= 0) |
1473 return false; | 1445 return false; |
1474 | 1446 |
1475 IndexMetaDataKey meta_data_key; | 1447 IndexMetaDataKey meta_data_key; |
1476 const char* p = IndexMetaDataKey::Decode( | 1448 const char* p = IndexMetaDataKey::Decode( |
1477 it->Key().begin(), it->Key().end(), &meta_data_key); | 1449 it->Key().begin(), it->Key().end(), &meta_data_key); |
1478 DCHECK(p); | 1450 DCHECK(p); |
1479 if (meta_data_key.IndexId() != index_id) | 1451 if (meta_data_key.IndexId() != index_id) |
1480 return false; | 1452 return false; |
1481 if (meta_data_key.meta_data_type() != meta_data_type) | 1453 if (meta_data_key.meta_data_type() != meta_data_type) |
1482 return false; | 1454 return false; |
1483 return true; | 1455 return true; |
1484 } | 1456 } |
1485 | 1457 |
1486 // TODO(jsbell): This should do some error handling rather than plowing ahead | 1458 // TODO(jsbell): This should do some error handling rather than plowing ahead |
1487 // when bad data is encountered. | 1459 // when bad data is encountered. |
1488 bool IndexedDBBackingStore::GetIndexes( | 1460 bool IndexedDBBackingStore::GetIndexes( |
1489 int64 database_id, | 1461 int64 database_id, |
1490 int64 object_store_id, | 1462 int64 object_store_id, |
1491 IndexedDBObjectStoreMetadata::IndexMap* indexes) { | 1463 IndexedDBObjectStoreMetadata::IndexMap* indexes) { |
1492 IDB_TRACE("IndexedDBBackingStore::GetIndexes"); | 1464 IDB_TRACE("IndexedDBBackingStore::GetIndexes"); |
1493 if (!KeyPrefix::ValidIds(database_id, object_store_id)) | 1465 if (!KeyPrefix::ValidIds(database_id, object_store_id)) |
1494 return false; | 1466 return false; |
1495 const std::vector<char> start_key = | 1467 const std::string start_key = |
1496 IndexMetaDataKey::Encode(database_id, object_store_id, 0, 0); | 1468 IndexMetaDataKey::Encode(database_id, object_store_id, 0, 0); |
1497 const std::vector<char> stop_key = | 1469 const std::string stop_key = |
1498 IndexMetaDataKey::Encode(database_id, object_store_id + 1, 0, 0); | 1470 IndexMetaDataKey::Encode(database_id, object_store_id + 1, 0, 0); |
1499 | 1471 |
1500 DCHECK(indexes->empty()); | 1472 DCHECK(indexes->empty()); |
1501 | 1473 |
1502 scoped_ptr<LevelDBIterator> it = db_->CreateIterator(); | 1474 scoped_ptr<LevelDBIterator> it = db_->CreateIterator(); |
1503 it->Seek(LevelDBSlice(start_key)); | 1475 it->Seek(start_key); |
1504 while (it->IsValid() && | 1476 while (it->IsValid() && CompareKeys(it->Key(), stop_key) < 0) { |
1505 CompareKeys(LevelDBSlice(it->Key()), LevelDBSlice(stop_key)) < 0) { | |
1506 const char* p = it->Key().begin(); | 1477 const char* p = it->Key().begin(); |
1507 const char* limit = it->Key().end(); | 1478 const char* limit = it->Key().end(); |
1508 | 1479 |
1509 IndexMetaDataKey meta_data_key; | 1480 IndexMetaDataKey meta_data_key; |
1510 p = IndexMetaDataKey::Decode(p, limit, &meta_data_key); | 1481 p = IndexMetaDataKey::Decode(p, limit, &meta_data_key); |
1511 DCHECK(p); | 1482 DCHECK(p); |
1512 if (meta_data_key.meta_data_type() != IndexMetaDataKey::NAME) { | 1483 if (meta_data_key.meta_data_type() != IndexMetaDataKey::NAME) { |
1513 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); | 1484 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); |
1514 // Possible stale metadata due to http://webkit.org/b/85557 but don't fail | 1485 // Possible stale metadata due to http://webkit.org/b/85557 but don't fail |
1515 // the load. | 1486 // the load. |
1516 it->Next(); | 1487 it->Next(); |
1517 continue; | 1488 continue; |
1518 } | 1489 } |
1519 | 1490 |
1520 // TODO(jsbell): Do this by direct key lookup rather than iteration, to | 1491 // TODO(jsbell): Do this by direct key lookup rather than iteration, to |
1521 // simplify. | 1492 // simplify. |
1522 int64 index_id = meta_data_key.IndexId(); | 1493 int64 index_id = meta_data_key.IndexId(); |
1523 string16 index_name; | 1494 string16 index_name; |
1524 { | 1495 { |
1525 StringPiece slice(it->Value().AsStringPiece()); | 1496 StringPiece slice(it->Value()); |
1526 if (!DecodeString(&slice, &index_name) || !slice.empty()) | 1497 if (!DecodeString(&slice, &index_name) || !slice.empty()) |
1527 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); | 1498 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); |
1528 } | 1499 } |
1529 | 1500 |
1530 it->Next(); // unique flag | 1501 it->Next(); // unique flag |
1531 if (!CheckIndexAndMetaDataKey( | 1502 if (!CheckIndexAndMetaDataKey( |
1532 it.get(), stop_key, index_id, IndexMetaDataKey::UNIQUE)) { | 1503 it.get(), stop_key, index_id, IndexMetaDataKey::UNIQUE)) { |
1533 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); | 1504 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); |
1534 break; | 1505 break; |
1535 } | 1506 } |
1536 bool index_unique; | 1507 bool index_unique; |
1537 { | 1508 { |
1538 StringPiece slice(it->Value().AsStringPiece()); | 1509 StringPiece slice(it->Value()); |
1539 if (!DecodeBool(&slice, &index_unique) || !slice.empty()) | 1510 if (!DecodeBool(&slice, &index_unique) || !slice.empty()) |
1540 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); | 1511 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); |
1541 } | 1512 } |
1542 | 1513 |
1543 it->Next(); // key_path | 1514 it->Next(); // key_path |
1544 if (!CheckIndexAndMetaDataKey( | 1515 if (!CheckIndexAndMetaDataKey( |
1545 it.get(), stop_key, index_id, IndexMetaDataKey::KEY_PATH)) { | 1516 it.get(), stop_key, index_id, IndexMetaDataKey::KEY_PATH)) { |
1546 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); | 1517 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); |
1547 break; | 1518 break; |
1548 } | 1519 } |
1549 IndexedDBKeyPath key_path; | 1520 IndexedDBKeyPath key_path; |
1550 { | 1521 { |
1551 StringPiece slice(it->Value().AsStringPiece()); | 1522 StringPiece slice(it->Value()); |
1552 if (!DecodeIDBKeyPath(&slice, &key_path) || !slice.empty()) | 1523 if (!DecodeIDBKeyPath(&slice, &key_path) || !slice.empty()) |
1553 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); | 1524 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); |
1554 } | 1525 } |
1555 | 1526 |
1556 it->Next(); // [optional] multi_entry flag | 1527 it->Next(); // [optional] multi_entry flag |
1557 bool index_multi_entry = false; | 1528 bool index_multi_entry = false; |
1558 if (CheckIndexAndMetaDataKey( | 1529 if (CheckIndexAndMetaDataKey( |
1559 it.get(), stop_key, index_id, IndexMetaDataKey::MULTI_ENTRY)) { | 1530 it.get(), stop_key, index_id, IndexMetaDataKey::MULTI_ENTRY)) { |
1560 StringPiece slice(it->Value().AsStringPiece()); | 1531 StringPiece slice(it->Value()); |
1561 if (!DecodeBool(&slice, &index_multi_entry) || !slice.empty()) | 1532 if (!DecodeBool(&slice, &index_multi_entry) || !slice.empty()) |
1562 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); | 1533 INTERNAL_CONSISTENCY_ERROR(GET_INDEXES); |
1563 | 1534 |
1564 it->Next(); | 1535 it->Next(); |
1565 } | 1536 } |
1566 | 1537 |
1567 (*indexes)[index_id] = IndexedDBIndexMetadata( | 1538 (*indexes)[index_id] = IndexedDBIndexMetadata( |
1568 index_name, index_id, key_path, index_unique, index_multi_entry); | 1539 index_name, index_id, key_path, index_unique, index_multi_entry); |
1569 } | 1540 } |
1570 return true; | 1541 return true; |
1571 } | 1542 } |
1572 | 1543 |
1573 WARN_UNUSED_RESULT static bool SetMaxIndexId(LevelDBTransaction* transaction, | 1544 WARN_UNUSED_RESULT static bool SetMaxIndexId(LevelDBTransaction* transaction, |
1574 int64 database_id, | 1545 int64 database_id, |
1575 int64 object_store_id, | 1546 int64 object_store_id, |
1576 int64 index_id) { | 1547 int64 index_id) { |
1577 int64 max_index_id = -1; | 1548 int64 max_index_id = -1; |
1578 const std::vector<char> max_index_id_key = ObjectStoreMetaDataKey::Encode( | 1549 const std::string max_index_id_key = ObjectStoreMetaDataKey::Encode( |
1579 database_id, object_store_id, ObjectStoreMetaDataKey::MAX_INDEX_ID); | 1550 database_id, object_store_id, ObjectStoreMetaDataKey::MAX_INDEX_ID); |
1580 bool found = false; | 1551 bool found = false; |
1581 bool ok = GetInt( | 1552 bool ok = GetInt(transaction, max_index_id_key, &max_index_id, &found); |
1582 transaction, LevelDBSlice(max_index_id_key), &max_index_id, &found); | |
1583 if (!ok) { | 1553 if (!ok) { |
1584 INTERNAL_READ_ERROR(SET_MAX_INDEX_ID); | 1554 INTERNAL_READ_ERROR(SET_MAX_INDEX_ID); |
1585 return false; | 1555 return false; |
1586 } | 1556 } |
1587 if (!found) | 1557 if (!found) |
1588 max_index_id = kMinimumIndexId; | 1558 max_index_id = kMinimumIndexId; |
1589 | 1559 |
1590 if (index_id <= max_index_id) { | 1560 if (index_id <= max_index_id) { |
1591 INTERNAL_CONSISTENCY_ERROR(SET_MAX_INDEX_ID); | 1561 INTERNAL_CONSISTENCY_ERROR(SET_MAX_INDEX_ID); |
1592 return false; | 1562 return false; |
1593 } | 1563 } |
1594 | 1564 |
1595 PutInt(transaction, LevelDBSlice(max_index_id_key), index_id); | 1565 PutInt(transaction, max_index_id_key, index_id); |
1596 return true; | 1566 return true; |
1597 } | 1567 } |
1598 | 1568 |
1599 bool IndexedDBBackingStore::CreateIndex( | 1569 bool IndexedDBBackingStore::CreateIndex( |
1600 IndexedDBBackingStore::Transaction* transaction, | 1570 IndexedDBBackingStore::Transaction* transaction, |
1601 int64 database_id, | 1571 int64 database_id, |
1602 int64 object_store_id, | 1572 int64 object_store_id, |
1603 int64 index_id, | 1573 int64 index_id, |
1604 const string16& name, | 1574 const string16& name, |
1605 const IndexedDBKeyPath& key_path, | 1575 const IndexedDBKeyPath& key_path, |
1606 bool is_unique, | 1576 bool is_unique, |
1607 bool is_multi_entry) { | 1577 bool is_multi_entry) { |
1608 IDB_TRACE("IndexedDBBackingStore::CreateIndex"); | 1578 IDB_TRACE("IndexedDBBackingStore::CreateIndex"); |
1609 if (!KeyPrefix::ValidIds(database_id, object_store_id, index_id)) | 1579 if (!KeyPrefix::ValidIds(database_id, object_store_id, index_id)) |
1610 return false; | 1580 return false; |
1611 LevelDBTransaction* leveldb_transaction = | 1581 LevelDBTransaction* leveldb_transaction = |
1612 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1582 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1613 if (!SetMaxIndexId( | 1583 if (!SetMaxIndexId( |
1614 leveldb_transaction, database_id, object_store_id, index_id)) | 1584 leveldb_transaction, database_id, object_store_id, index_id)) |
1615 return false; | 1585 return false; |
1616 | 1586 |
1617 const std::vector<char> name_key = IndexMetaDataKey::Encode( | 1587 const std::string name_key = IndexMetaDataKey::Encode( |
1618 database_id, object_store_id, index_id, IndexMetaDataKey::NAME); | 1588 database_id, object_store_id, index_id, IndexMetaDataKey::NAME); |
1619 const std::vector<char> unique_key = IndexMetaDataKey::Encode( | 1589 const std::string unique_key = IndexMetaDataKey::Encode( |
1620 database_id, object_store_id, index_id, IndexMetaDataKey::UNIQUE); | 1590 database_id, object_store_id, index_id, IndexMetaDataKey::UNIQUE); |
1621 const std::vector<char> key_path_key = IndexMetaDataKey::Encode( | 1591 const std::string key_path_key = IndexMetaDataKey::Encode( |
1622 database_id, object_store_id, index_id, IndexMetaDataKey::KEY_PATH); | 1592 database_id, object_store_id, index_id, IndexMetaDataKey::KEY_PATH); |
1623 const std::vector<char> multi_entry_key = IndexMetaDataKey::Encode( | 1593 const std::string multi_entry_key = IndexMetaDataKey::Encode( |
1624 database_id, object_store_id, index_id, IndexMetaDataKey::MULTI_ENTRY); | 1594 database_id, object_store_id, index_id, IndexMetaDataKey::MULTI_ENTRY); |
1625 | 1595 |
1626 PutString(leveldb_transaction, LevelDBSlice(name_key), name); | 1596 PutString(leveldb_transaction, name_key, name); |
1627 PutBool(leveldb_transaction, LevelDBSlice(unique_key), is_unique); | 1597 PutBool(leveldb_transaction, unique_key, is_unique); |
1628 PutIDBKeyPath(leveldb_transaction, LevelDBSlice(key_path_key), key_path); | 1598 PutIDBKeyPath(leveldb_transaction, key_path_key, key_path); |
1629 PutBool(leveldb_transaction, LevelDBSlice(multi_entry_key), is_multi_entry); | 1599 PutBool(leveldb_transaction, multi_entry_key, is_multi_entry); |
1630 return true; | 1600 return true; |
1631 } | 1601 } |
1632 | 1602 |
1633 bool IndexedDBBackingStore::DeleteIndex( | 1603 bool IndexedDBBackingStore::DeleteIndex( |
1634 IndexedDBBackingStore::Transaction* transaction, | 1604 IndexedDBBackingStore::Transaction* transaction, |
1635 int64 database_id, | 1605 int64 database_id, |
1636 int64 object_store_id, | 1606 int64 object_store_id, |
1637 int64 index_id) { | 1607 int64 index_id) { |
1638 IDB_TRACE("IndexedDBBackingStore::DeleteIndex"); | 1608 IDB_TRACE("IndexedDBBackingStore::DeleteIndex"); |
1639 if (!KeyPrefix::ValidIds(database_id, object_store_id, index_id)) | 1609 if (!KeyPrefix::ValidIds(database_id, object_store_id, index_id)) |
1640 return false; | 1610 return false; |
1641 LevelDBTransaction* leveldb_transaction = | 1611 LevelDBTransaction* leveldb_transaction = |
1642 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1612 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1643 | 1613 |
1644 const std::vector<char> index_meta_data_start = | 1614 const std::string index_meta_data_start = |
1645 IndexMetaDataKey::Encode(database_id, object_store_id, index_id, 0); | 1615 IndexMetaDataKey::Encode(database_id, object_store_id, index_id, 0); |
1646 const std::vector<char> index_meta_data_end = | 1616 const std::string index_meta_data_end = |
1647 IndexMetaDataKey::EncodeMaxKey(database_id, object_store_id, index_id); | 1617 IndexMetaDataKey::EncodeMaxKey(database_id, object_store_id, index_id); |
1648 DeleteRange(leveldb_transaction, index_meta_data_start, index_meta_data_end); | 1618 DeleteRange(leveldb_transaction, index_meta_data_start, index_meta_data_end); |
1649 | 1619 |
1650 const std::vector<char> index_data_start = | 1620 const std::string index_data_start = |
1651 IndexDataKey::EncodeMinKey(database_id, object_store_id, index_id); | 1621 IndexDataKey::EncodeMinKey(database_id, object_store_id, index_id); |
1652 const std::vector<char> index_data_end = | 1622 const std::string index_data_end = |
1653 IndexDataKey::EncodeMaxKey(database_id, object_store_id, index_id); | 1623 IndexDataKey::EncodeMaxKey(database_id, object_store_id, index_id); |
1654 DeleteRange(leveldb_transaction, index_data_start, index_data_end); | 1624 DeleteRange(leveldb_transaction, index_data_start, index_data_end); |
1655 return true; | 1625 return true; |
1656 } | 1626 } |
1657 | 1627 |
1658 bool IndexedDBBackingStore::PutIndexDataForRecord( | 1628 bool IndexedDBBackingStore::PutIndexDataForRecord( |
1659 IndexedDBBackingStore::Transaction* transaction, | 1629 IndexedDBBackingStore::Transaction* transaction, |
1660 int64 database_id, | 1630 int64 database_id, |
1661 int64 object_store_id, | 1631 int64 object_store_id, |
1662 int64 index_id, | 1632 int64 index_id, |
1663 const IndexedDBKey& key, | 1633 const IndexedDBKey& key, |
1664 const RecordIdentifier& record_identifier) { | 1634 const RecordIdentifier& record_identifier) { |
1665 IDB_TRACE("IndexedDBBackingStore::PutIndexDataForRecord"); | 1635 IDB_TRACE("IndexedDBBackingStore::PutIndexDataForRecord"); |
1666 DCHECK(key.IsValid()); | 1636 DCHECK(key.IsValid()); |
1667 if (!KeyPrefix::ValidIds(database_id, object_store_id, index_id)) | 1637 if (!KeyPrefix::ValidIds(database_id, object_store_id, index_id)) |
1668 return false; | 1638 return false; |
1669 | 1639 |
1670 LevelDBTransaction* leveldb_transaction = | 1640 LevelDBTransaction* leveldb_transaction = |
1671 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1641 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1672 | 1642 |
1673 std::vector<char> encoded_key; | 1643 std::string encoded_key; |
1674 EncodeIDBKey(key, &encoded_key); | 1644 EncodeIDBKey(key, &encoded_key); |
1675 | 1645 |
1676 const std::vector<char> index_data_key = | 1646 const std::string index_data_key = |
1677 IndexDataKey::Encode(database_id, | 1647 IndexDataKey::Encode(database_id, |
1678 object_store_id, | 1648 object_store_id, |
1679 index_id, | 1649 index_id, |
1680 encoded_key, | 1650 encoded_key, |
1681 record_identifier.primary_key(), | 1651 record_identifier.primary_key(), |
1682 0); | 1652 0); |
1683 | 1653 |
1684 std::vector<char> data; | 1654 std::string data; |
1685 EncodeVarInt(record_identifier.version(), &data); | 1655 EncodeVarInt(record_identifier.version(), &data); |
1686 const std::vector<char>& primary_key = record_identifier.primary_key(); | 1656 data.append(record_identifier.primary_key()); |
1687 data.insert(data.end(), primary_key.begin(), primary_key.end()); | |
1688 | 1657 |
1689 leveldb_transaction->Put(LevelDBSlice(index_data_key), &data); | 1658 leveldb_transaction->Put(index_data_key, &data); |
1690 return true; | 1659 return true; |
1691 } | 1660 } |
1692 | 1661 |
1693 static bool FindGreatestKeyLessThanOrEqual(LevelDBTransaction* transaction, | 1662 static bool FindGreatestKeyLessThanOrEqual(LevelDBTransaction* transaction, |
1694 const std::vector<char>& target, | 1663 const std::string& target, |
1695 std::vector<char>* found_key) { | 1664 std::string* found_key) { |
1696 scoped_ptr<LevelDBIterator> it = transaction->CreateIterator(); | 1665 scoped_ptr<LevelDBIterator> it = transaction->CreateIterator(); |
1697 it->Seek(LevelDBSlice(target)); | 1666 it->Seek(target); |
1698 | 1667 |
1699 if (!it->IsValid()) { | 1668 if (!it->IsValid()) { |
1700 it->SeekToLast(); | 1669 it->SeekToLast(); |
1701 if (!it->IsValid()) | 1670 if (!it->IsValid()) |
1702 return false; | 1671 return false; |
1703 } | 1672 } |
1704 | 1673 |
1705 while (CompareIndexKeys(LevelDBSlice(it->Key()), LevelDBSlice(target)) > 0) { | 1674 while (CompareIndexKeys(it->Key(), target) > 0) { |
1706 it->Prev(); | 1675 it->Prev(); |
1707 if (!it->IsValid()) | 1676 if (!it->IsValid()) |
1708 return false; | 1677 return false; |
1709 } | 1678 } |
1710 | 1679 |
1711 do { | 1680 do { |
1712 found_key->assign(it->Key().begin(), it->Key().end()); | 1681 *found_key = it->Key().as_string(); |
1713 | 1682 |
1714 // There can be several index keys that compare equal. We want the last one. | 1683 // There can be several index keys that compare equal. We want the last one. |
1715 it->Next(); | 1684 it->Next(); |
1716 } while (it->IsValid() && !CompareIndexKeys(it->Key(), LevelDBSlice(target))); | 1685 } while (it->IsValid() && !CompareIndexKeys(it->Key(), target)); |
1717 | 1686 |
1718 return true; | 1687 return true; |
1719 } | 1688 } |
1720 | 1689 |
1721 static bool VersionExists(LevelDBTransaction* transaction, | 1690 static bool VersionExists(LevelDBTransaction* transaction, |
1722 int64 database_id, | 1691 int64 database_id, |
1723 int64 object_store_id, | 1692 int64 object_store_id, |
1724 int64 version, | 1693 int64 version, |
1725 const std::vector<char>& encoded_primary_key, | 1694 const std::string& encoded_primary_key, |
1726 bool* exists) { | 1695 bool* exists) { |
1727 const std::vector<char> key = | 1696 const std::string key = |
1728 ExistsEntryKey::Encode(database_id, object_store_id, encoded_primary_key); | 1697 ExistsEntryKey::Encode(database_id, object_store_id, encoded_primary_key); |
1729 std::string data; | 1698 std::string data; |
1730 | 1699 |
1731 bool ok = transaction->Get(LevelDBSlice(key), &data, exists); | 1700 bool ok = transaction->Get(key, &data, exists); |
1732 if (!ok) { | 1701 if (!ok) { |
1733 INTERNAL_READ_ERROR(VERSION_EXISTS); | 1702 INTERNAL_READ_ERROR(VERSION_EXISTS); |
1734 return false; | 1703 return false; |
1735 } | 1704 } |
1736 if (!*exists) | 1705 if (!*exists) |
1737 return true; | 1706 return true; |
1738 | 1707 |
1739 StringPiece slice(data); | 1708 StringPiece slice(data); |
1740 int64 decoded; | 1709 int64 decoded; |
1741 if (!DecodeInt(&slice, &decoded) || !slice.empty()) | 1710 if (!DecodeInt(&slice, &decoded) || !slice.empty()) |
1742 return false; | 1711 return false; |
1743 *exists = (decoded == version); | 1712 *exists = (decoded == version); |
1744 return true; | 1713 return true; |
1745 } | 1714 } |
1746 | 1715 |
1747 bool IndexedDBBackingStore::FindKeyInIndex( | 1716 bool IndexedDBBackingStore::FindKeyInIndex( |
1748 IndexedDBBackingStore::Transaction* transaction, | 1717 IndexedDBBackingStore::Transaction* transaction, |
1749 int64 database_id, | 1718 int64 database_id, |
1750 int64 object_store_id, | 1719 int64 object_store_id, |
1751 int64 index_id, | 1720 int64 index_id, |
1752 const IndexedDBKey& key, | 1721 const IndexedDBKey& key, |
1753 std::vector<char>* found_encoded_primary_key, | 1722 std::string* found_encoded_primary_key, |
1754 bool* found) { | 1723 bool* found) { |
1755 IDB_TRACE("IndexedDBBackingStore::FindKeyInIndex"); | 1724 IDB_TRACE("IndexedDBBackingStore::FindKeyInIndex"); |
1756 DCHECK(KeyPrefix::ValidIds(database_id, object_store_id, index_id)); | 1725 DCHECK(KeyPrefix::ValidIds(database_id, object_store_id, index_id)); |
1757 | 1726 |
1758 DCHECK(found_encoded_primary_key->empty()); | 1727 DCHECK(found_encoded_primary_key->empty()); |
1759 *found = false; | 1728 *found = false; |
1760 | 1729 |
1761 LevelDBTransaction* leveldb_transaction = | 1730 LevelDBTransaction* leveldb_transaction = |
1762 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); | 1731 IndexedDBBackingStore::Transaction::LevelDBTransactionFrom(transaction); |
1763 const std::vector<char> leveldb_key = | 1732 const std::string leveldb_key = |
1764 IndexDataKey::Encode(database_id, object_store_id, index_id, key); | 1733 IndexDataKey::Encode(database_id, object_store_id, index_id, key); |
1765 scoped_ptr<LevelDBIterator> it = leveldb_transaction->CreateIterator(); | 1734 scoped_ptr<LevelDBIterator> it = leveldb_transaction->CreateIterator(); |
1766 it->Seek(LevelDBSlice(leveldb_key)); | 1735 it->Seek(leveldb_key); |
1767 | 1736 |
1768 for (;;) { | 1737 for (;;) { |
1769 if (!it->IsValid()) | 1738 if (!it->IsValid()) |
1770 return true; | 1739 return true; |
1771 if (CompareIndexKeys(it->Key(), LevelDBSlice(leveldb_key)) > 0) | 1740 if (CompareIndexKeys(it->Key(), leveldb_key) > 0) |
1772 return true; | 1741 return true; |
1773 | 1742 |
1774 StringPiece slice(it->Value().AsStringPiece()); | 1743 StringPiece slice(it->Value()); |
1775 | 1744 |
1776 int64 version; | 1745 int64 version; |
1777 if (!DecodeVarInt(&slice, &version)) { | 1746 if (!DecodeVarInt(&slice, &version)) { |
1778 INTERNAL_READ_ERROR(FIND_KEY_IN_INDEX); | 1747 INTERNAL_READ_ERROR(FIND_KEY_IN_INDEX); |
1779 return false; | 1748 return false; |
1780 } | 1749 } |
1781 found_encoded_primary_key->insert( | 1750 *found_encoded_primary_key = slice.as_string(); |
1782 found_encoded_primary_key->end(), slice.begin(), slice.end()); | |
1783 | 1751 |
1784 bool exists = false; | 1752 bool exists = false; |
1785 bool ok = VersionExists(leveldb_transaction, | 1753 bool ok = VersionExists(leveldb_transaction, |
1786 database_id, | 1754 database_id, |
1787 object_store_id, | 1755 object_store_id, |
1788 version, | 1756 version, |
1789 *found_encoded_primary_key, | 1757 *found_encoded_primary_key, |
1790 &exists); | 1758 &exists); |
1791 if (!ok) | 1759 if (!ok) |
1792 return false; | 1760 return false; |
(...skipping 13 matching lines...) Expand all Loading... |
1806 int64 database_id, | 1774 int64 database_id, |
1807 int64 object_store_id, | 1775 int64 object_store_id, |
1808 int64 index_id, | 1776 int64 index_id, |
1809 const IndexedDBKey& key, | 1777 const IndexedDBKey& key, |
1810 scoped_ptr<IndexedDBKey>* primary_key) { | 1778 scoped_ptr<IndexedDBKey>* primary_key) { |
1811 IDB_TRACE("IndexedDBBackingStore::GetPrimaryKeyViaIndex"); | 1779 IDB_TRACE("IndexedDBBackingStore::GetPrimaryKeyViaIndex"); |
1812 if (!KeyPrefix::ValidIds(database_id, object_store_id, index_id)) | 1780 if (!KeyPrefix::ValidIds(database_id, object_store_id, index_id)) |
1813 return false; | 1781 return false; |
1814 | 1782 |
1815 bool found = false; | 1783 bool found = false; |
1816 std::vector<char> found_encoded_primary_key; | 1784 std::string found_encoded_primary_key; |
1817 bool ok = FindKeyInIndex(transaction, | 1785 bool ok = FindKeyInIndex(transaction, |
1818 database_id, | 1786 database_id, |
1819 object_store_id, | 1787 object_store_id, |
1820 index_id, | 1788 index_id, |
1821 key, | 1789 key, |
1822 &found_encoded_primary_key, | 1790 &found_encoded_primary_key, |
1823 &found); | 1791 &found); |
1824 if (!ok) { | 1792 if (!ok) { |
1825 INTERNAL_READ_ERROR(GET_PRIMARY_KEY_VIA_INDEX); | 1793 INTERNAL_READ_ERROR(GET_PRIMARY_KEY_VIA_INDEX); |
1826 return false; | 1794 return false; |
1827 } | 1795 } |
1828 if (!found) | 1796 if (!found) |
1829 return true; | 1797 return true; |
1830 if (!found_encoded_primary_key.size()) { | 1798 if (!found_encoded_primary_key.size()) { |
1831 INTERNAL_READ_ERROR(GET_PRIMARY_KEY_VIA_INDEX); | 1799 INTERNAL_READ_ERROR(GET_PRIMARY_KEY_VIA_INDEX); |
1832 return false; | 1800 return false; |
1833 } | 1801 } |
1834 | 1802 |
1835 StringPiece slice(&*found_encoded_primary_key.begin(), | 1803 StringPiece slice(found_encoded_primary_key); |
1836 found_encoded_primary_key.size()); | |
1837 return DecodeIDBKey(&slice, primary_key) && slice.empty(); | 1804 return DecodeIDBKey(&slice, primary_key) && slice.empty(); |
1838 } | 1805 } |
1839 | 1806 |
1840 bool IndexedDBBackingStore::KeyExistsInIndex( | 1807 bool IndexedDBBackingStore::KeyExistsInIndex( |
1841 IndexedDBBackingStore::Transaction* transaction, | 1808 IndexedDBBackingStore::Transaction* transaction, |
1842 int64 database_id, | 1809 int64 database_id, |
1843 int64 object_store_id, | 1810 int64 object_store_id, |
1844 int64 index_id, | 1811 int64 index_id, |
1845 const IndexedDBKey& index_key, | 1812 const IndexedDBKey& index_key, |
1846 scoped_ptr<IndexedDBKey>* found_primary_key, | 1813 scoped_ptr<IndexedDBKey>* found_primary_key, |
1847 bool* exists) { | 1814 bool* exists) { |
1848 IDB_TRACE("IndexedDBBackingStore::KeyExistsInIndex"); | 1815 IDB_TRACE("IndexedDBBackingStore::KeyExistsInIndex"); |
1849 if (!KeyPrefix::ValidIds(database_id, object_store_id, index_id)) | 1816 if (!KeyPrefix::ValidIds(database_id, object_store_id, index_id)) |
1850 return false; | 1817 return false; |
1851 | 1818 |
1852 *exists = false; | 1819 *exists = false; |
1853 std::vector<char> found_encoded_primary_key; | 1820 std::string found_encoded_primary_key; |
1854 bool ok = FindKeyInIndex(transaction, | 1821 bool ok = FindKeyInIndex(transaction, |
1855 database_id, | 1822 database_id, |
1856 object_store_id, | 1823 object_store_id, |
1857 index_id, | 1824 index_id, |
1858 index_key, | 1825 index_key, |
1859 &found_encoded_primary_key, | 1826 &found_encoded_primary_key, |
1860 exists); | 1827 exists); |
1861 if (!ok) { | 1828 if (!ok) { |
1862 INTERNAL_READ_ERROR(KEY_EXISTS_IN_INDEX); | 1829 INTERNAL_READ_ERROR(KEY_EXISTS_IN_INDEX); |
1863 return false; | 1830 return false; |
1864 } | 1831 } |
1865 if (!*exists) | 1832 if (!*exists) |
1866 return true; | 1833 return true; |
1867 if (found_encoded_primary_key.empty()) { | 1834 if (found_encoded_primary_key.empty()) { |
1868 INTERNAL_READ_ERROR(KEY_EXISTS_IN_INDEX); | 1835 INTERNAL_READ_ERROR(KEY_EXISTS_IN_INDEX); |
1869 return false; | 1836 return false; |
1870 } | 1837 } |
1871 | 1838 |
1872 StringPiece slice(&*found_encoded_primary_key.begin(), | 1839 StringPiece slice(found_encoded_primary_key); |
1873 found_encoded_primary_key.size()); | |
1874 return DecodeIDBKey(&slice, found_primary_key) && slice.empty(); | 1840 return DecodeIDBKey(&slice, found_primary_key) && slice.empty(); |
1875 } | 1841 } |
1876 | 1842 |
1877 IndexedDBBackingStore::Cursor::Cursor( | 1843 IndexedDBBackingStore::Cursor::Cursor( |
1878 const IndexedDBBackingStore::Cursor* other) | 1844 const IndexedDBBackingStore::Cursor* other) |
1879 : transaction_(other->transaction_), | 1845 : transaction_(other->transaction_), |
1880 cursor_options_(other->cursor_options_), | 1846 cursor_options_(other->cursor_options_), |
1881 current_key_(new IndexedDBKey(*other->current_key_)) { | 1847 current_key_(new IndexedDBKey(*other->current_key_)) { |
1882 if (other->iterator_) { | 1848 if (other->iterator_) { |
1883 iterator_ = transaction_->CreateIterator(); | 1849 iterator_ = transaction_->CreateIterator(); |
1884 | 1850 |
1885 if (other->iterator_->IsValid()) { | 1851 if (other->iterator_->IsValid()) { |
1886 iterator_->Seek(other->iterator_->Key()); | 1852 iterator_->Seek(other->iterator_->Key()); |
1887 DCHECK(iterator_->IsValid()); | 1853 DCHECK(iterator_->IsValid()); |
1888 } | 1854 } |
1889 } | 1855 } |
1890 } | 1856 } |
1891 | 1857 |
1892 IndexedDBBackingStore::Cursor::Cursor(LevelDBTransaction* transaction, | 1858 IndexedDBBackingStore::Cursor::Cursor(LevelDBTransaction* transaction, |
1893 const CursorOptions& cursor_options) | 1859 const CursorOptions& cursor_options) |
1894 : transaction_(transaction), cursor_options_(cursor_options) {} | 1860 : transaction_(transaction), cursor_options_(cursor_options) {} |
1895 IndexedDBBackingStore::Cursor::~Cursor() {} | 1861 IndexedDBBackingStore::Cursor::~Cursor() {} |
1896 | 1862 |
1897 bool IndexedDBBackingStore::Cursor::FirstSeek() { | 1863 bool IndexedDBBackingStore::Cursor::FirstSeek() { |
1898 iterator_ = transaction_->CreateIterator(); | 1864 iterator_ = transaction_->CreateIterator(); |
1899 if (cursor_options_.forward) | 1865 if (cursor_options_.forward) |
1900 iterator_->Seek(LevelDBSlice(cursor_options_.low_key)); | 1866 iterator_->Seek(cursor_options_.low_key); |
1901 else | 1867 else |
1902 iterator_->Seek(LevelDBSlice(cursor_options_.high_key)); | 1868 iterator_->Seek(cursor_options_.high_key); |
1903 | 1869 |
1904 return ContinueFunction(0, READY); | 1870 return ContinueFunction(0, READY); |
1905 } | 1871 } |
1906 | 1872 |
1907 bool IndexedDBBackingStore::Cursor::Advance(uint32 count) { | 1873 bool IndexedDBBackingStore::Cursor::Advance(uint32 count) { |
1908 while (count--) { | 1874 while (count--) { |
1909 if (!ContinueFunction()) | 1875 if (!ContinueFunction()) |
1910 return false; | 1876 return false; |
1911 } | 1877 } |
1912 return true; | 1878 return true; |
(...skipping 10 matching lines...) Expand all Loading... |
1923 // value we yield for each key is the first duplicate in forwards | 1889 // value we yield for each key is the first duplicate in forwards |
1924 // order. | 1890 // order. |
1925 IndexedDBKey last_duplicate_key; | 1891 IndexedDBKey last_duplicate_key; |
1926 | 1892 |
1927 bool forward = cursor_options_.forward; | 1893 bool forward = cursor_options_.forward; |
1928 | 1894 |
1929 for (;;) { | 1895 for (;;) { |
1930 if (next_state == SEEK) { | 1896 if (next_state == SEEK) { |
1931 // TODO(jsbell): Optimize seeking for reverse cursors as well. | 1897 // TODO(jsbell): Optimize seeking for reverse cursors as well. |
1932 if (first_iteration && key && key->IsValid() && forward) { | 1898 if (first_iteration && key && key->IsValid() && forward) { |
1933 iterator_->Seek(LevelDBSlice(EncodeKey(*key))); | 1899 iterator_->Seek(EncodeKey(*key)); |
1934 first_iteration = false; | 1900 first_iteration = false; |
1935 } else if (forward) { | 1901 } else if (forward) { |
1936 iterator_->Next(); | 1902 iterator_->Next(); |
1937 } else { | 1903 } else { |
1938 iterator_->Prev(); | 1904 iterator_->Prev(); |
1939 } | 1905 } |
1940 } else { | 1906 } else { |
1941 next_state = SEEK; // for subsequent iterations | 1907 next_state = SEEK; // for subsequent iterations |
1942 } | 1908 } |
1943 | 1909 |
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2008 break; | 1974 break; |
2009 } | 1975 } |
2010 | 1976 |
2011 DCHECK(!last_duplicate_key.IsValid() || | 1977 DCHECK(!last_duplicate_key.IsValid() || |
2012 (forward && last_duplicate_key.IsEqual(*current_key_))); | 1978 (forward && last_duplicate_key.IsEqual(*current_key_))); |
2013 return true; | 1979 return true; |
2014 } | 1980 } |
2015 | 1981 |
2016 bool IndexedDBBackingStore::Cursor::HaveEnteredRange() const { | 1982 bool IndexedDBBackingStore::Cursor::HaveEnteredRange() const { |
2017 if (cursor_options_.forward) { | 1983 if (cursor_options_.forward) { |
2018 int compare = CompareIndexKeys(iterator_->Key(), | 1984 int compare = CompareIndexKeys(iterator_->Key(), cursor_options_.low_key); |
2019 LevelDBSlice(cursor_options_.low_key)); | |
2020 if (cursor_options_.low_open) { | 1985 if (cursor_options_.low_open) { |
2021 return compare > 0; | 1986 return compare > 0; |
2022 } | 1987 } |
2023 return compare >= 0; | 1988 return compare >= 0; |
2024 } | 1989 } |
2025 int compare = CompareIndexKeys(iterator_->Key(), | 1990 int compare = CompareIndexKeys(iterator_->Key(), cursor_options_.high_key); |
2026 LevelDBSlice(cursor_options_.high_key)); | |
2027 if (cursor_options_.high_open) { | 1991 if (cursor_options_.high_open) { |
2028 return compare < 0; | 1992 return compare < 0; |
2029 } | 1993 } |
2030 return compare <= 0; | 1994 return compare <= 0; |
2031 } | 1995 } |
2032 | 1996 |
2033 bool IndexedDBBackingStore::Cursor::IsPastBounds() const { | 1997 bool IndexedDBBackingStore::Cursor::IsPastBounds() const { |
2034 if (cursor_options_.forward) { | 1998 if (cursor_options_.forward) { |
2035 int compare = CompareIndexKeys(iterator_->Key(), | 1999 int compare = CompareIndexKeys(iterator_->Key(), cursor_options_.high_key); |
2036 LevelDBSlice(cursor_options_.high_key)); | |
2037 if (cursor_options_.high_open) { | 2000 if (cursor_options_.high_open) { |
2038 return compare >= 0; | 2001 return compare >= 0; |
2039 } | 2002 } |
2040 return compare > 0; | 2003 return compare > 0; |
2041 } | 2004 } |
2042 int compare = | 2005 int compare = CompareIndexKeys(iterator_->Key(), cursor_options_.low_key); |
2043 CompareIndexKeys(iterator_->Key(), LevelDBSlice(cursor_options_.low_key)); | |
2044 if (cursor_options_.low_open) { | 2006 if (cursor_options_.low_open) { |
2045 return compare <= 0; | 2007 return compare <= 0; |
2046 } | 2008 } |
2047 return compare < 0; | 2009 return compare < 0; |
2048 } | 2010 } |
2049 | 2011 |
2050 const IndexedDBKey& IndexedDBBackingStore::Cursor::primary_key() const { | 2012 const IndexedDBKey& IndexedDBBackingStore::Cursor::primary_key() const { |
2051 return *current_key_; | 2013 return *current_key_; |
2052 } | 2014 } |
2053 | 2015 |
2054 const IndexedDBBackingStore::RecordIdentifier& | 2016 const IndexedDBBackingStore::RecordIdentifier& |
2055 IndexedDBBackingStore::Cursor::record_identifier() const { | 2017 IndexedDBBackingStore::Cursor::record_identifier() const { |
2056 return record_identifier_; | 2018 return record_identifier_; |
2057 } | 2019 } |
2058 | 2020 |
2059 class ObjectStoreKeyCursorImpl : public IndexedDBBackingStore::Cursor { | 2021 class ObjectStoreKeyCursorImpl : public IndexedDBBackingStore::Cursor { |
2060 public: | 2022 public: |
2061 ObjectStoreKeyCursorImpl( | 2023 ObjectStoreKeyCursorImpl( |
2062 LevelDBTransaction* transaction, | 2024 LevelDBTransaction* transaction, |
2063 const IndexedDBBackingStore::Cursor::CursorOptions& cursor_options) | 2025 const IndexedDBBackingStore::Cursor::CursorOptions& cursor_options) |
2064 : IndexedDBBackingStore::Cursor(transaction, cursor_options) {} | 2026 : IndexedDBBackingStore::Cursor(transaction, cursor_options) {} |
2065 | 2027 |
2066 virtual Cursor* Clone() OVERRIDE { | 2028 virtual Cursor* Clone() OVERRIDE { |
2067 return new ObjectStoreKeyCursorImpl(this); | 2029 return new ObjectStoreKeyCursorImpl(this); |
2068 } | 2030 } |
2069 | 2031 |
2070 // IndexedDBBackingStore::Cursor | 2032 // IndexedDBBackingStore::Cursor |
2071 virtual std::vector<char>* Value() OVERRIDE { | 2033 virtual std::string* Value() OVERRIDE { |
2072 NOTREACHED(); | 2034 NOTREACHED(); |
2073 return NULL; | 2035 return NULL; |
2074 } | 2036 } |
2075 virtual bool LoadCurrentRow() OVERRIDE; | 2037 virtual bool LoadCurrentRow() OVERRIDE; |
2076 | 2038 |
2077 protected: | 2039 protected: |
2078 virtual std::vector<char> EncodeKey(const IndexedDBKey& key) OVERRIDE { | 2040 virtual std::string EncodeKey(const IndexedDBKey& key) OVERRIDE { |
2079 return ObjectStoreDataKey::Encode( | 2041 return ObjectStoreDataKey::Encode( |
2080 cursor_options_.database_id, cursor_options_.object_store_id, key); | 2042 cursor_options_.database_id, cursor_options_.object_store_id, key); |
2081 } | 2043 } |
2082 | 2044 |
2083 private: | 2045 private: |
2084 explicit ObjectStoreKeyCursorImpl(const ObjectStoreKeyCursorImpl* other) | 2046 explicit ObjectStoreKeyCursorImpl(const ObjectStoreKeyCursorImpl* other) |
2085 : IndexedDBBackingStore::Cursor(other) {} | 2047 : IndexedDBBackingStore::Cursor(other) {} |
2086 }; | 2048 }; |
2087 | 2049 |
2088 bool ObjectStoreKeyCursorImpl::LoadCurrentRow() { | 2050 bool ObjectStoreKeyCursorImpl::LoadCurrentRow() { |
2089 const char* key_position = iterator_->Key().begin(); | 2051 const char* key_position = iterator_->Key().begin(); |
2090 const char* key_limit = iterator_->Key().end(); | 2052 const char* key_limit = iterator_->Key().end(); |
2091 | 2053 |
2092 ObjectStoreDataKey object_store_data_key; | 2054 ObjectStoreDataKey object_store_data_key; |
2093 key_position = ObjectStoreDataKey::Decode( | 2055 key_position = ObjectStoreDataKey::Decode( |
2094 key_position, key_limit, &object_store_data_key); | 2056 key_position, key_limit, &object_store_data_key); |
2095 if (!key_position) { | 2057 if (!key_position) { |
2096 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2058 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2097 return false; | 2059 return false; |
2098 } | 2060 } |
2099 | 2061 |
2100 current_key_ = object_store_data_key.user_key(); | 2062 current_key_ = object_store_data_key.user_key(); |
2101 | 2063 |
2102 int64 version; | 2064 int64 version; |
2103 StringPiece slice(iterator_->Value().AsStringPiece()); | 2065 StringPiece slice(iterator_->Value()); |
2104 if (!DecodeVarInt(&slice, &version)) { | 2066 if (!DecodeVarInt(&slice, &version)) { |
2105 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2067 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2106 return false; | 2068 return false; |
2107 } | 2069 } |
2108 | 2070 |
2109 // TODO(jsbell): This re-encodes what was just decoded; try and optimize. | 2071 // TODO(jsbell): This re-encodes what was just decoded; try and optimize. |
2110 std::vector<char> encoded_key; | 2072 std::string encoded_key; |
2111 EncodeIDBKey(*current_key_, &encoded_key); | 2073 EncodeIDBKey(*current_key_, &encoded_key); |
2112 record_identifier_.Reset(encoded_key, version); | 2074 record_identifier_.Reset(encoded_key, version); |
2113 | 2075 |
2114 return true; | 2076 return true; |
2115 } | 2077 } |
2116 | 2078 |
2117 class ObjectStoreCursorImpl : public IndexedDBBackingStore::Cursor { | 2079 class ObjectStoreCursorImpl : public IndexedDBBackingStore::Cursor { |
2118 public: | 2080 public: |
2119 ObjectStoreCursorImpl( | 2081 ObjectStoreCursorImpl( |
2120 LevelDBTransaction* transaction, | 2082 LevelDBTransaction* transaction, |
2121 const IndexedDBBackingStore::Cursor::CursorOptions& cursor_options) | 2083 const IndexedDBBackingStore::Cursor::CursorOptions& cursor_options) |
2122 : IndexedDBBackingStore::Cursor(transaction, cursor_options) {} | 2084 : IndexedDBBackingStore::Cursor(transaction, cursor_options) {} |
2123 | 2085 |
2124 virtual Cursor* Clone() OVERRIDE { return new ObjectStoreCursorImpl(this); } | 2086 virtual Cursor* Clone() OVERRIDE { return new ObjectStoreCursorImpl(this); } |
2125 | 2087 |
2126 // IndexedDBBackingStore::Cursor | 2088 // IndexedDBBackingStore::Cursor |
2127 virtual std::vector<char>* Value() OVERRIDE { return ¤t_value_; } | 2089 virtual std::string* Value() OVERRIDE { return ¤t_value_; } |
2128 virtual bool LoadCurrentRow() OVERRIDE; | 2090 virtual bool LoadCurrentRow() OVERRIDE; |
2129 | 2091 |
2130 protected: | 2092 protected: |
2131 virtual std::vector<char> EncodeKey(const IndexedDBKey& key) OVERRIDE { | 2093 virtual std::string EncodeKey(const IndexedDBKey& key) OVERRIDE { |
2132 return ObjectStoreDataKey::Encode( | 2094 return ObjectStoreDataKey::Encode( |
2133 cursor_options_.database_id, cursor_options_.object_store_id, key); | 2095 cursor_options_.database_id, cursor_options_.object_store_id, key); |
2134 } | 2096 } |
2135 | 2097 |
2136 private: | 2098 private: |
2137 explicit ObjectStoreCursorImpl(const ObjectStoreCursorImpl* other) | 2099 explicit ObjectStoreCursorImpl(const ObjectStoreCursorImpl* other) |
2138 : IndexedDBBackingStore::Cursor(other), | 2100 : IndexedDBBackingStore::Cursor(other), |
2139 current_value_(other->current_value_) {} | 2101 current_value_(other->current_value_) {} |
2140 | 2102 |
2141 std::vector<char> current_value_; | 2103 std::string current_value_; |
2142 }; | 2104 }; |
2143 | 2105 |
2144 bool ObjectStoreCursorImpl::LoadCurrentRow() { | 2106 bool ObjectStoreCursorImpl::LoadCurrentRow() { |
2145 const char* key_position = iterator_->Key().begin(); | 2107 const char* key_position = iterator_->Key().begin(); |
2146 const char* key_limit = iterator_->Key().end(); | 2108 const char* key_limit = iterator_->Key().end(); |
2147 | 2109 |
2148 ObjectStoreDataKey object_store_data_key; | 2110 ObjectStoreDataKey object_store_data_key; |
2149 key_position = ObjectStoreDataKey::Decode( | 2111 key_position = ObjectStoreDataKey::Decode( |
2150 key_position, key_limit, &object_store_data_key); | 2112 key_position, key_limit, &object_store_data_key); |
2151 if (!key_position) { | 2113 if (!key_position) { |
2152 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2114 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2153 return false; | 2115 return false; |
2154 } | 2116 } |
2155 | 2117 |
2156 current_key_ = object_store_data_key.user_key(); | 2118 current_key_ = object_store_data_key.user_key(); |
2157 | 2119 |
2158 int64 version; | 2120 int64 version; |
2159 StringPiece slice(iterator_->Value().AsStringPiece()); | 2121 StringPiece slice(iterator_->Value()); |
2160 if (!DecodeVarInt(&slice, &version)) { | 2122 if (!DecodeVarInt(&slice, &version)) { |
2161 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2123 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2162 return false; | 2124 return false; |
2163 } | 2125 } |
2164 | 2126 |
2165 // TODO(jsbell): This re-encodes what was just decoded; try and optimize. | 2127 // TODO(jsbell): This re-encodes what was just decoded; try and optimize. |
2166 std::vector<char> encoded_key; | 2128 std::string encoded_key; |
2167 EncodeIDBKey(*current_key_, &encoded_key); | 2129 EncodeIDBKey(*current_key_, &encoded_key); |
2168 record_identifier_.Reset(encoded_key, version); | 2130 record_identifier_.Reset(encoded_key, version); |
2169 | 2131 |
2170 std::vector<char> value; | 2132 current_value_ = slice.as_string(); |
2171 value.insert(value.end(), slice.begin(), slice.end()); | |
2172 current_value_.swap(value); | |
2173 return true; | 2133 return true; |
2174 } | 2134 } |
2175 | 2135 |
2176 class IndexKeyCursorImpl : public IndexedDBBackingStore::Cursor { | 2136 class IndexKeyCursorImpl : public IndexedDBBackingStore::Cursor { |
2177 public: | 2137 public: |
2178 IndexKeyCursorImpl( | 2138 IndexKeyCursorImpl( |
2179 LevelDBTransaction* transaction, | 2139 LevelDBTransaction* transaction, |
2180 const IndexedDBBackingStore::Cursor::CursorOptions& cursor_options) | 2140 const IndexedDBBackingStore::Cursor::CursorOptions& cursor_options) |
2181 : IndexedDBBackingStore::Cursor(transaction, cursor_options) {} | 2141 : IndexedDBBackingStore::Cursor(transaction, cursor_options) {} |
2182 | 2142 |
2183 virtual Cursor* Clone() OVERRIDE { return new IndexKeyCursorImpl(this); } | 2143 virtual Cursor* Clone() OVERRIDE { return new IndexKeyCursorImpl(this); } |
2184 | 2144 |
2185 // IndexedDBBackingStore::Cursor | 2145 // IndexedDBBackingStore::Cursor |
2186 virtual std::vector<char>* Value() OVERRIDE { | 2146 virtual std::string* Value() OVERRIDE { |
2187 NOTREACHED(); | 2147 NOTREACHED(); |
2188 return NULL; | 2148 return NULL; |
2189 } | 2149 } |
2190 virtual const IndexedDBKey& primary_key() const OVERRIDE { | 2150 virtual const IndexedDBKey& primary_key() const OVERRIDE { |
2191 return *primary_key_; | 2151 return *primary_key_; |
2192 } | 2152 } |
2193 virtual const IndexedDBBackingStore::RecordIdentifier& RecordIdentifier() | 2153 virtual const IndexedDBBackingStore::RecordIdentifier& RecordIdentifier() |
2194 const { | 2154 const { |
2195 NOTREACHED(); | 2155 NOTREACHED(); |
2196 return record_identifier_; | 2156 return record_identifier_; |
2197 } | 2157 } |
2198 virtual bool LoadCurrentRow() OVERRIDE; | 2158 virtual bool LoadCurrentRow() OVERRIDE; |
2199 | 2159 |
2200 protected: | 2160 protected: |
2201 virtual std::vector<char> EncodeKey(const IndexedDBKey& key) OVERRIDE { | 2161 virtual std::string EncodeKey(const IndexedDBKey& key) OVERRIDE { |
2202 return IndexDataKey::Encode(cursor_options_.database_id, | 2162 return IndexDataKey::Encode(cursor_options_.database_id, |
2203 cursor_options_.object_store_id, | 2163 cursor_options_.object_store_id, |
2204 cursor_options_.index_id, | 2164 cursor_options_.index_id, |
2205 key); | 2165 key); |
2206 } | 2166 } |
2207 | 2167 |
2208 private: | 2168 private: |
2209 explicit IndexKeyCursorImpl(const IndexKeyCursorImpl* other) | 2169 explicit IndexKeyCursorImpl(const IndexKeyCursorImpl* other) |
2210 : IndexedDBBackingStore::Cursor(other), | 2170 : IndexedDBBackingStore::Cursor(other), |
2211 primary_key_(new IndexedDBKey(*other->primary_key_)) {} | 2171 primary_key_(new IndexedDBKey(*other->primary_key_)) {} |
2212 | 2172 |
2213 scoped_ptr<IndexedDBKey> primary_key_; | 2173 scoped_ptr<IndexedDBKey> primary_key_; |
2214 }; | 2174 }; |
2215 | 2175 |
2216 bool IndexKeyCursorImpl::LoadCurrentRow() { | 2176 bool IndexKeyCursorImpl::LoadCurrentRow() { |
2217 const char* key_position = iterator_->Key().begin(); | 2177 const char* key_position = iterator_->Key().begin(); |
2218 const char* key_limit = iterator_->Key().end(); | 2178 const char* key_limit = iterator_->Key().end(); |
2219 | 2179 |
2220 IndexDataKey index_data_key; | 2180 IndexDataKey index_data_key; |
2221 key_position = IndexDataKey::Decode(key_position, key_limit, &index_data_key); | 2181 key_position = IndexDataKey::Decode(key_position, key_limit, &index_data_key); |
2222 | 2182 |
2223 current_key_ = index_data_key.user_key(); | 2183 current_key_ = index_data_key.user_key(); |
2224 DCHECK(current_key_); | 2184 DCHECK(current_key_); |
2225 | 2185 |
2226 StringPiece slice(iterator_->Value().AsStringPiece()); | 2186 StringPiece slice(iterator_->Value()); |
2227 int64 index_data_version; | 2187 int64 index_data_version; |
2228 if (!DecodeVarInt(&slice, &index_data_version)) { | 2188 if (!DecodeVarInt(&slice, &index_data_version)) { |
2229 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2189 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2230 return false; | 2190 return false; |
2231 } | 2191 } |
2232 | 2192 |
2233 if (!DecodeIDBKey(&slice, &primary_key_) || !slice.empty()) { | 2193 if (!DecodeIDBKey(&slice, &primary_key_) || !slice.empty()) { |
2234 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2194 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2235 return false; | 2195 return false; |
2236 } | 2196 } |
2237 | 2197 |
2238 std::vector<char> primary_leveldb_key = | 2198 std::string primary_leveldb_key = |
2239 ObjectStoreDataKey::Encode(index_data_key.DatabaseId(), | 2199 ObjectStoreDataKey::Encode(index_data_key.DatabaseId(), |
2240 index_data_key.ObjectStoreId(), | 2200 index_data_key.ObjectStoreId(), |
2241 *primary_key_); | 2201 *primary_key_); |
2242 | 2202 |
2243 std::string result; | 2203 std::string result; |
2244 bool found = false; | 2204 bool found = false; |
2245 bool ok = | 2205 bool ok = transaction_->Get(primary_leveldb_key, &result, &found); |
2246 transaction_->Get(LevelDBSlice(primary_leveldb_key), &result, &found); | |
2247 if (!ok) { | 2206 if (!ok) { |
2248 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2207 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2249 return false; | 2208 return false; |
2250 } | 2209 } |
2251 if (!found) { | 2210 if (!found) { |
2252 transaction_->Remove(iterator_->Key()); | 2211 transaction_->Remove(iterator_->Key()); |
2253 return false; | 2212 return false; |
2254 } | 2213 } |
2255 if (!result.size()) { | 2214 if (!result.size()) { |
2256 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2215 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
(...skipping 18 matching lines...) Expand all Loading... |
2275 class IndexCursorImpl : public IndexedDBBackingStore::Cursor { | 2234 class IndexCursorImpl : public IndexedDBBackingStore::Cursor { |
2276 public: | 2235 public: |
2277 IndexCursorImpl( | 2236 IndexCursorImpl( |
2278 LevelDBTransaction* transaction, | 2237 LevelDBTransaction* transaction, |
2279 const IndexedDBBackingStore::Cursor::CursorOptions& cursor_options) | 2238 const IndexedDBBackingStore::Cursor::CursorOptions& cursor_options) |
2280 : IndexedDBBackingStore::Cursor(transaction, cursor_options) {} | 2239 : IndexedDBBackingStore::Cursor(transaction, cursor_options) {} |
2281 | 2240 |
2282 virtual Cursor* Clone() OVERRIDE { return new IndexCursorImpl(this); } | 2241 virtual Cursor* Clone() OVERRIDE { return new IndexCursorImpl(this); } |
2283 | 2242 |
2284 // IndexedDBBackingStore::Cursor | 2243 // IndexedDBBackingStore::Cursor |
2285 virtual std::vector<char>* Value() OVERRIDE { return ¤t_value_; } | 2244 virtual std::string* Value() OVERRIDE { return ¤t_value_; } |
2286 virtual const IndexedDBKey& primary_key() const OVERRIDE { | 2245 virtual const IndexedDBKey& primary_key() const OVERRIDE { |
2287 return *primary_key_; | 2246 return *primary_key_; |
2288 } | 2247 } |
2289 virtual const IndexedDBBackingStore::RecordIdentifier& RecordIdentifier() | 2248 virtual const IndexedDBBackingStore::RecordIdentifier& RecordIdentifier() |
2290 const { | 2249 const { |
2291 NOTREACHED(); | 2250 NOTREACHED(); |
2292 return record_identifier_; | 2251 return record_identifier_; |
2293 } | 2252 } |
2294 virtual bool LoadCurrentRow() OVERRIDE; | 2253 virtual bool LoadCurrentRow() OVERRIDE; |
2295 | 2254 |
2296 protected: | 2255 protected: |
2297 virtual std::vector<char> EncodeKey(const IndexedDBKey& key) OVERRIDE { | 2256 virtual std::string EncodeKey(const IndexedDBKey& key) OVERRIDE { |
2298 return IndexDataKey::Encode(cursor_options_.database_id, | 2257 return IndexDataKey::Encode(cursor_options_.database_id, |
2299 cursor_options_.object_store_id, | 2258 cursor_options_.object_store_id, |
2300 cursor_options_.index_id, | 2259 cursor_options_.index_id, |
2301 key); | 2260 key); |
2302 } | 2261 } |
2303 | 2262 |
2304 private: | 2263 private: |
2305 explicit IndexCursorImpl(const IndexCursorImpl* other) | 2264 explicit IndexCursorImpl(const IndexCursorImpl* other) |
2306 : IndexedDBBackingStore::Cursor(other), | 2265 : IndexedDBBackingStore::Cursor(other), |
2307 primary_key_(new IndexedDBKey(*other->primary_key_)), | 2266 primary_key_(new IndexedDBKey(*other->primary_key_)), |
2308 current_value_(other->current_value_), | 2267 current_value_(other->current_value_), |
2309 primary_leveldb_key_(other->primary_leveldb_key_) {} | 2268 primary_leveldb_key_(other->primary_leveldb_key_) {} |
2310 | 2269 |
2311 scoped_ptr<IndexedDBKey> primary_key_; | 2270 scoped_ptr<IndexedDBKey> primary_key_; |
2312 std::vector<char> current_value_; | 2271 std::string current_value_; |
2313 std::vector<char> primary_leveldb_key_; | 2272 std::string primary_leveldb_key_; |
2314 }; | 2273 }; |
2315 | 2274 |
2316 bool IndexCursorImpl::LoadCurrentRow() { | 2275 bool IndexCursorImpl::LoadCurrentRow() { |
2317 const char* key_position = iterator_->Key().begin(); | 2276 const char* key_position = iterator_->Key().begin(); |
2318 const char* key_limit = iterator_->Key().end(); | 2277 const char* key_limit = iterator_->Key().end(); |
2319 | 2278 |
2320 IndexDataKey index_data_key; | 2279 IndexDataKey index_data_key; |
2321 key_position = IndexDataKey::Decode(key_position, key_limit, &index_data_key); | 2280 key_position = IndexDataKey::Decode(key_position, key_limit, &index_data_key); |
2322 | 2281 |
2323 current_key_ = index_data_key.user_key(); | 2282 current_key_ = index_data_key.user_key(); |
2324 DCHECK(current_key_); | 2283 DCHECK(current_key_); |
2325 | 2284 |
2326 StringPiece slice(iterator_->Value().AsStringPiece()); | 2285 StringPiece slice(iterator_->Value()); |
2327 int64 index_data_version; | 2286 int64 index_data_version; |
2328 if (!DecodeVarInt(&slice, &index_data_version)) { | 2287 if (!DecodeVarInt(&slice, &index_data_version)) { |
2329 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2288 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2330 return false; | 2289 return false; |
2331 } | 2290 } |
2332 if (!DecodeIDBKey(&slice, &primary_key_)) { | 2291 if (!DecodeIDBKey(&slice, &primary_key_)) { |
2333 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2292 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2334 return false; | 2293 return false; |
2335 } | 2294 } |
2336 | 2295 |
2337 primary_leveldb_key_ = | 2296 primary_leveldb_key_ = |
2338 ObjectStoreDataKey::Encode(index_data_key.DatabaseId(), | 2297 ObjectStoreDataKey::Encode(index_data_key.DatabaseId(), |
2339 index_data_key.ObjectStoreId(), | 2298 index_data_key.ObjectStoreId(), |
2340 *primary_key_); | 2299 *primary_key_); |
2341 | 2300 |
2342 std::string result; | 2301 std::string result; |
2343 bool found = false; | 2302 bool found = false; |
2344 bool ok = | 2303 bool ok = transaction_->Get(primary_leveldb_key_, &result, &found); |
2345 transaction_->Get(LevelDBSlice(primary_leveldb_key_), &result, &found); | |
2346 if (!ok) { | 2304 if (!ok) { |
2347 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2305 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2348 return false; | 2306 return false; |
2349 } | 2307 } |
2350 if (!found) { | 2308 if (!found) { |
2351 transaction_->Remove(iterator_->Key()); | 2309 transaction_->Remove(iterator_->Key()); |
2352 return false; | 2310 return false; |
2353 } | 2311 } |
2354 if (!result.size()) { | 2312 if (!result.size()) { |
2355 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2313 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2356 return false; | 2314 return false; |
2357 } | 2315 } |
2358 | 2316 |
2359 int64 object_store_data_version; | 2317 int64 object_store_data_version; |
2360 slice = StringPiece(result); | 2318 slice = StringPiece(result); |
2361 if (!DecodeVarInt(&slice, &object_store_data_version)) { | 2319 if (!DecodeVarInt(&slice, &object_store_data_version)) { |
2362 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); | 2320 INTERNAL_READ_ERROR(LOAD_CURRENT_ROW); |
2363 return false; | 2321 return false; |
2364 } | 2322 } |
2365 | 2323 |
2366 if (object_store_data_version != index_data_version) { | 2324 if (object_store_data_version != index_data_version) { |
2367 transaction_->Remove(iterator_->Key()); | 2325 transaction_->Remove(iterator_->Key()); |
2368 return false; | 2326 return false; |
2369 } | 2327 } |
2370 | 2328 |
2371 current_value_.clear(); | 2329 current_value_ = slice.as_string(); |
2372 current_value_.insert(current_value_.end(), slice.begin(), slice.end()); | |
2373 return true; | 2330 return true; |
2374 } | 2331 } |
2375 | 2332 |
2376 bool ObjectStoreCursorOptions( | 2333 bool ObjectStoreCursorOptions( |
2377 LevelDBTransaction* transaction, | 2334 LevelDBTransaction* transaction, |
2378 int64 database_id, | 2335 int64 database_id, |
2379 int64 object_store_id, | 2336 int64 object_store_id, |
2380 const IndexedDBKeyRange& range, | 2337 const IndexedDBKeyRange& range, |
2381 indexed_db::CursorDirection direction, | 2338 indexed_db::CursorDirection direction, |
2382 IndexedDBBackingStore::Cursor::CursorOptions* cursor_options) { | 2339 IndexedDBBackingStore::Cursor::CursorOptions* cursor_options) { |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2414 return false; | 2371 return false; |
2415 cursor_options->high_open = false; | 2372 cursor_options->high_open = false; |
2416 } | 2373 } |
2417 } else { | 2374 } else { |
2418 cursor_options->high_key = | 2375 cursor_options->high_key = |
2419 ObjectStoreDataKey::Encode(database_id, object_store_id, range.upper()); | 2376 ObjectStoreDataKey::Encode(database_id, object_store_id, range.upper()); |
2420 cursor_options->high_open = range.upperOpen(); | 2377 cursor_options->high_open = range.upperOpen(); |
2421 | 2378 |
2422 if (!cursor_options->forward) { | 2379 if (!cursor_options->forward) { |
2423 // For reverse cursors, we need a key that exists. | 2380 // For reverse cursors, we need a key that exists. |
2424 std::vector<char> found_high_key; | 2381 std::string found_high_key; |
2425 if (!FindGreatestKeyLessThanOrEqual( | 2382 if (!FindGreatestKeyLessThanOrEqual( |
2426 transaction, cursor_options->high_key, &found_high_key)) | 2383 transaction, cursor_options->high_key, &found_high_key)) |
2427 return false; | 2384 return false; |
2428 | 2385 |
2429 // If the target key should not be included, but we end up with a smaller | 2386 // If the target key should not be included, but we end up with a smaller |
2430 // key, we should include that. | 2387 // key, we should include that. |
2431 if (cursor_options->high_open && | 2388 if (cursor_options->high_open && |
2432 CompareIndexKeys(LevelDBSlice(found_high_key), | 2389 CompareIndexKeys(found_high_key, cursor_options->high_key) < 0) |
2433 LevelDBSlice(cursor_options->high_key)) < | |
2434 0) | |
2435 cursor_options->high_open = false; | 2390 cursor_options->high_open = false; |
2436 | 2391 |
2437 cursor_options->high_key = found_high_key; | 2392 cursor_options->high_key = found_high_key; |
2438 } | 2393 } |
2439 } | 2394 } |
2440 | 2395 |
2441 return true; | 2396 return true; |
2442 } | 2397 } |
2443 | 2398 |
2444 bool IndexCursorOptions( | 2399 bool IndexCursorOptions( |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2484 if (!FindGreatestKeyLessThanOrEqual( | 2439 if (!FindGreatestKeyLessThanOrEqual( |
2485 transaction, cursor_options->high_key, &cursor_options->high_key)) | 2440 transaction, cursor_options->high_key, &cursor_options->high_key)) |
2486 return false; | 2441 return false; |
2487 cursor_options->high_open = false; | 2442 cursor_options->high_open = false; |
2488 } | 2443 } |
2489 } else { | 2444 } else { |
2490 cursor_options->high_key = IndexDataKey::Encode( | 2445 cursor_options->high_key = IndexDataKey::Encode( |
2491 database_id, object_store_id, index_id, range.upper()); | 2446 database_id, object_store_id, index_id, range.upper()); |
2492 cursor_options->high_open = range.upperOpen(); | 2447 cursor_options->high_open = range.upperOpen(); |
2493 | 2448 |
2494 std::vector<char> found_high_key; | 2449 std::string found_high_key; |
2495 // Seek to the *last* key in the set of non-unique keys | 2450 // Seek to the *last* key in the set of non-unique keys |
2496 if (!FindGreatestKeyLessThanOrEqual( | 2451 if (!FindGreatestKeyLessThanOrEqual( |
2497 transaction, cursor_options->high_key, &found_high_key)) | 2452 transaction, cursor_options->high_key, &found_high_key)) |
2498 return false; | 2453 return false; |
2499 | 2454 |
2500 // If the target key should not be included, but we end up with a smaller | 2455 // If the target key should not be included, but we end up with a smaller |
2501 // key, we should include that. | 2456 // key, we should include that. |
2502 if (cursor_options->high_open && | 2457 if (cursor_options->high_open && |
2503 CompareIndexKeys(LevelDBSlice(found_high_key), | 2458 CompareIndexKeys(found_high_key, cursor_options->high_key) < 0) |
2504 LevelDBSlice(cursor_options->high_key)) < | |
2505 0) | |
2506 cursor_options->high_open = false; | 2459 cursor_options->high_open = false; |
2507 | 2460 |
2508 cursor_options->high_key = found_high_key; | 2461 cursor_options->high_key = found_high_key; |
2509 } | 2462 } |
2510 | 2463 |
2511 return true; | 2464 return true; |
2512 } | 2465 } |
2513 | 2466 |
2514 scoped_ptr<IndexedDBBackingStore::Cursor> | 2467 scoped_ptr<IndexedDBBackingStore::Cursor> |
2515 IndexedDBBackingStore::OpenObjectStoreCursor( | 2468 IndexedDBBackingStore::OpenObjectStoreCursor( |
(...skipping 126 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2642 } | 2595 } |
2643 | 2596 |
2644 void IndexedDBBackingStore::Transaction::Rollback() { | 2597 void IndexedDBBackingStore::Transaction::Rollback() { |
2645 IDB_TRACE("IndexedDBBackingStore::Transaction::Rollback"); | 2598 IDB_TRACE("IndexedDBBackingStore::Transaction::Rollback"); |
2646 DCHECK(transaction_.get()); | 2599 DCHECK(transaction_.get()); |
2647 transaction_->Rollback(); | 2600 transaction_->Rollback(); |
2648 transaction_ = NULL; | 2601 transaction_ = NULL; |
2649 } | 2602 } |
2650 | 2603 |
2651 } // namespace content | 2604 } // namespace content |
OLD | NEW |