Home | History | Annotate | Download | only in blockfile
      1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
      2 // Use of this source code is governed by a BSD-style license that can be
      3 // found in the LICENSE file.
      4 
      5 #ifndef NET_DISK_CACHE_BLOCKFILE_STORAGE_BLOCK_INL_H_
      6 #define NET_DISK_CACHE_BLOCKFILE_STORAGE_BLOCK_INL_H_
      7 
      8 #include "net/disk_cache/blockfile/storage_block.h"
      9 
     10 #include "base/hash.h"
     11 #include "base/logging.h"
     12 #include "net/disk_cache/blockfile/trace.h"
     13 
     14 namespace disk_cache {
     15 
     16 template<typename T> StorageBlock<T>::StorageBlock(MappedFile* file,
     17                                                    Addr address)
     18     : data_(NULL), file_(file), address_(address), modified_(false),
     19       own_data_(false), extended_(false) {
     20   if (address.num_blocks() > 1)
     21     extended_ = true;
     22   DCHECK(!address.is_initialized() || sizeof(*data_) == address.BlockSize());
     23 }
     24 
     25 template<typename T> StorageBlock<T>::~StorageBlock() {
     26   if (modified_)
     27     Store();
     28   DeleteData();
     29 }
     30 
     31 template<typename T> void* StorageBlock<T>::buffer() const {
     32   return data_;
     33 }
     34 
     35 template<typename T> size_t StorageBlock<T>::size() const {
     36   if (!extended_)
     37     return sizeof(*data_);
     38   return address_.num_blocks() * sizeof(*data_);
     39 }
     40 
     41 template<typename T> int StorageBlock<T>::offset() const {
     42   return address_.start_block() * address_.BlockSize();
     43 }
     44 
     45 template<typename T> bool StorageBlock<T>::LazyInit(MappedFile* file,
     46                                                     Addr address) {
     47   if (file_ || address_.is_initialized()) {
     48     NOTREACHED();
     49     return false;
     50   }
     51   file_ = file;
     52   address_.set_value(address.value());
     53   if (address.num_blocks() > 1)
     54     extended_ = true;
     55 
     56   DCHECK(sizeof(*data_) == address.BlockSize());
     57   return true;
     58 }
     59 
     60 template<typename T> void StorageBlock<T>::SetData(T* other) {
     61   DCHECK(!modified_);
     62   DeleteData();
     63   data_ = other;
     64 }
     65 
     66 template<typename T> void  StorageBlock<T>::Discard() {
     67   if (!data_)
     68     return;
     69   if (!own_data_) {
     70     NOTREACHED();
     71     return;
     72   }
     73   DeleteData();
     74   data_ = NULL;
     75   modified_ = false;
     76   extended_ = false;
     77 }
     78 
     79 template<typename T> void  StorageBlock<T>::StopSharingData() {
     80   if (!data_ || own_data_)
     81     return;
     82   DCHECK(!modified_);
     83   data_ = NULL;
     84 }
     85 
     86 template<typename T> void StorageBlock<T>::set_modified() {
     87   DCHECK(data_);
     88   modified_ = true;
     89 }
     90 
     91 template<typename T> void StorageBlock<T>::clear_modified() {
     92   modified_ = false;
     93 }
     94 
     95 template<typename T> T* StorageBlock<T>::Data() {
     96   if (!data_)
     97     AllocateData();
     98   return data_;
     99 }
    100 
    101 template<typename T> bool StorageBlock<T>::HasData() const {
    102   return (NULL != data_);
    103 }
    104 
    105 template<typename T> bool StorageBlock<T>::VerifyHash() const {
    106   uint32 hash = CalculateHash();
    107   return (!data_->self_hash || data_->self_hash == hash);
    108 }
    109 
    110 template<typename T> bool StorageBlock<T>::own_data() const {
    111   return own_data_;
    112 }
    113 
    114 template<typename T> const Addr StorageBlock<T>::address() const {
    115   return address_;
    116 }
    117 
    118 template<typename T> bool StorageBlock<T>::Load() {
    119   if (file_) {
    120     if (!data_)
    121       AllocateData();
    122 
    123     if (file_->Load(this)) {
    124       modified_ = false;
    125       return true;
    126     }
    127   }
    128   LOG(WARNING) << "Failed data load.";
    129   Trace("Failed data load.");
    130   return false;
    131 }
    132 
    133 template<typename T> bool StorageBlock<T>::Store() {
    134   if (file_ && data_) {
    135     data_->self_hash = CalculateHash();
    136     if (file_->Store(this)) {
    137       modified_ = false;
    138       return true;
    139     }
    140   }
    141   LOG(ERROR) << "Failed data store.";
    142   Trace("Failed data store.");
    143   return false;
    144 }
    145 
    146 template<typename T> bool StorageBlock<T>::Load(FileIOCallback* callback,
    147                                                 bool* completed) {
    148   if (file_) {
    149     if (!data_)
    150       AllocateData();
    151 
    152     if (file_->Load(this, callback, completed)) {
    153       modified_ = false;
    154       return true;
    155     }
    156   }
    157   LOG(WARNING) << "Failed data load.";
    158   Trace("Failed data load.");
    159   return false;
    160 }
    161 
    162 template<typename T> bool StorageBlock<T>::Store(FileIOCallback* callback,
    163                                                  bool* completed) {
    164   if (file_ && data_) {
    165     data_->self_hash = CalculateHash();
    166     if (file_->Store(this, callback, completed)) {
    167       modified_ = false;
    168       return true;
    169     }
    170   }
    171   LOG(ERROR) << "Failed data store.";
    172   Trace("Failed data store.");
    173   return false;
    174 }
    175 
    176 template<typename T> void StorageBlock<T>::AllocateData() {
    177   DCHECK(!data_);
    178   if (!extended_) {
    179     data_ = new T;
    180   } else {
    181     void* buffer = new char[address_.num_blocks() * sizeof(*data_)];
    182     data_ = new(buffer) T;
    183   }
    184   own_data_ = true;
    185 }
    186 
    187 template<typename T> void StorageBlock<T>::DeleteData() {
    188   if (own_data_) {
    189     if (!extended_) {
    190       delete data_;
    191     } else {
    192       data_->~T();
    193       delete[] reinterpret_cast<char*>(data_);
    194     }
    195     own_data_ = false;
    196   }
    197 }
    198 
    199 template<typename T> uint32 StorageBlock<T>::CalculateHash() const {
    200   return base::Hash(reinterpret_cast<char*>(data_), offsetof(T, self_hash));
    201 }
    202 
    203 }  // namespace disk_cache
    204 
    205 #endif  // NET_DISK_CACHE_BLOCKFILE_STORAGE_BLOCK_INL_H_
    206