| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 "storage/browser/blob/blob_storage_registry.h" | 5 #include "storage/browser/blob/blob_storage_registry.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 | 8 |
| 9 #include <memory> | 9 #include <memory> |
| 10 | 10 |
| (...skipping 20 matching lines...) Expand all Loading... |
| 31 | 31 |
| 32 GURL ClearBlobUrlRef(const GURL& url) { | 32 GURL ClearBlobUrlRef(const GURL& url) { |
| 33 size_t hash_pos = url.spec().find('#'); | 33 size_t hash_pos = url.spec().find('#'); |
| 34 if (hash_pos == std::string::npos) | 34 if (hash_pos == std::string::npos) |
| 35 return url; | 35 return url; |
| 36 return GURL(url.spec().substr(0, hash_pos)); | 36 return GURL(url.spec().substr(0, hash_pos)); |
| 37 } | 37 } |
| 38 | 38 |
| 39 } // namespace | 39 } // namespace |
| 40 | 40 |
| 41 BlobStorageRegistry::Entry::Entry(int refcount, BlobState state) | 41 BlobStorageRegistry::ItemCopyEntry::ItemCopyEntry( |
| 42 : refcount(refcount), state(state) {} | 42 scoped_refptr<ShareableBlobDataItem> source_item, |
| 43 size_t source_item_offset, |
| 44 scoped_refptr<ShareableBlobDataItem> dest_item) |
| 45 : source_item(std::move(source_item)), |
| 46 source_item_offset(source_item_offset), |
| 47 dest_item(std::move(dest_item)) {} |
| 48 |
| 49 BlobStorageRegistry::ItemCopyEntry::ItemCopyEntry(const ItemCopyEntry&) = |
| 50 default; |
| 51 |
| 52 BlobStorageRegistry::ItemCopyEntry::~ItemCopyEntry() {} |
| 53 |
| 54 BlobStorageRegistry::Entry::Entry() {} |
| 43 | 55 |
| 44 BlobStorageRegistry::Entry::~Entry() {} | 56 BlobStorageRegistry::Entry::~Entry() {} |
| 45 | 57 |
| 46 bool BlobStorageRegistry::Entry::TestAndSetState(BlobState expected, | |
| 47 BlobState set) { | |
| 48 if (state != expected) | |
| 49 return false; | |
| 50 state = set; | |
| 51 return true; | |
| 52 } | |
| 53 | |
| 54 BlobStorageRegistry::BlobStorageRegistry() {} | 58 BlobStorageRegistry::BlobStorageRegistry() {} |
| 55 | 59 |
| 56 BlobStorageRegistry::~BlobStorageRegistry() { | 60 BlobStorageRegistry::~BlobStorageRegistry() { |
| 57 // Note: We don't bother calling the construction complete callbacks, as we | 61 // Note: We don't bother calling the construction complete callbacks, as we |
| 58 // are only being destructed at the end of the life of the browser process. | 62 // are only being destructed at the end of the life of the browser process. |
| 59 // So it shouldn't matter. | 63 // So it shouldn't matter. |
| 60 } | 64 } |
| 61 | 65 |
| 62 BlobStorageRegistry::Entry* BlobStorageRegistry::CreateEntry( | 66 BlobStorageRegistry::Entry* BlobStorageRegistry::CreateEntry( |
| 63 const std::string& uuid, | 67 const std::string& uuid, |
| 64 const std::string& content_type, | 68 const std::string& content_type, |
| 65 const std::string& content_disposition) { | 69 const std::string& content_disposition) { |
| 66 DCHECK(!ContainsKey(blob_map_, uuid)); | 70 DCHECK(!ContainsKey(blob_map_, uuid)); |
| 67 std::unique_ptr<Entry> entry(new Entry(1, BlobState::PENDING)); | 71 std::unique_ptr<Entry> entry(new Entry()); |
| 68 entry->content_type = content_type; | 72 entry->content_type = content_type; |
| 69 entry->content_disposition = content_disposition; | 73 entry->content_disposition = content_disposition; |
| 70 Entry* entry_ptr = entry.get(); | 74 Entry* entry_ptr = entry.get(); |
| 71 blob_map_.add(uuid, std::move(entry)); | 75 blob_map_.add(uuid, std::move(entry)); |
| 72 return entry_ptr; | 76 return entry_ptr; |
| 73 } | 77 } |
| 74 | 78 |
| 75 bool BlobStorageRegistry::DeleteEntry(const std::string& uuid) { | 79 bool BlobStorageRegistry::DeleteEntry(const std::string& uuid) { |
| 76 return blob_map_.erase(uuid) == 1; | 80 return blob_map_.erase(uuid) == 1; |
| 77 } | 81 } |
| (...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 125 url_to_uuid_.find(BlobUrlHasRef(url) ? ClearBlobUrlRef(url) : url); | 129 url_to_uuid_.find(BlobUrlHasRef(url) ? ClearBlobUrlRef(url) : url); |
| 126 if (found == url_to_uuid_.end()) | 130 if (found == url_to_uuid_.end()) |
| 127 return nullptr; | 131 return nullptr; |
| 128 Entry* entry = GetEntry(found->second); | 132 Entry* entry = GetEntry(found->second); |
| 129 if (entry && uuid) | 133 if (entry && uuid) |
| 130 uuid->assign(found->second); | 134 uuid->assign(found->second); |
| 131 return entry; | 135 return entry; |
| 132 } | 136 } |
| 133 | 137 |
| 134 } // namespace storage | 138 } // namespace storage |
| OLD | NEW |