2015-04-08 16:57:04 +02:00
|
|
|
#include "CachedBlockRef.h"
|
|
|
|
#include "CachingBlockStore.h"
|
2015-03-31 14:02:24 +02:00
|
|
|
#include <cassert>
|
2015-03-19 11:16:20 +01:00
|
|
|
|
2015-04-02 18:19:05 +02:00
|
|
|
#include "CachingBlockStoreAdapter.h"
|
|
|
|
|
2015-03-19 11:16:20 +01:00
|
|
|
using std::unique_ptr;
|
|
|
|
using std::make_unique;
|
|
|
|
using std::string;
|
2015-03-31 14:02:24 +02:00
|
|
|
using std::mutex;
|
|
|
|
using std::lock_guard;
|
|
|
|
using std::promise;
|
2015-03-19 11:16:20 +01:00
|
|
|
|
|
|
|
namespace blockstore {
|
2015-04-02 08:59:43 +02:00
|
|
|
namespace caching {
|
2015-03-19 11:16:20 +01:00
|
|
|
|
2015-04-02 08:59:43 +02:00
|
|
|
CachingBlockStore::CachingBlockStore(unique_ptr<BlockStore> baseBlockStore)
|
2015-04-02 18:19:05 +02:00
|
|
|
: _baseBlockStore(std::move(baseBlockStore)), _cachingStore(make_unique<CachingBlockStoreAdapter>(_baseBlockStore.get())) {
|
2015-03-28 18:44:22 +01:00
|
|
|
}
|
2015-03-19 11:16:20 +01:00
|
|
|
|
2015-04-02 08:59:43 +02:00
|
|
|
unique_ptr<Block> CachingBlockStore::create(size_t size) {
|
2015-03-31 14:02:24 +02:00
|
|
|
auto block = _baseBlockStore->create(size);
|
2015-04-02 13:21:52 +02:00
|
|
|
Key key = block->key();
|
2015-04-02 18:19:05 +02:00
|
|
|
return _cachingStore.add(key, std::move(block));
|
2015-03-19 11:16:20 +01:00
|
|
|
}
|
|
|
|
|
2015-04-02 08:59:43 +02:00
|
|
|
unique_ptr<Block> CachingBlockStore::load(const Key &key) {
|
2015-04-02 18:19:05 +02:00
|
|
|
return _cachingStore.load(key);
|
2015-03-31 14:02:24 +02:00
|
|
|
}
|
|
|
|
|
2015-03-19 11:16:20 +01:00
|
|
|
|
2015-04-02 08:59:43 +02:00
|
|
|
void CachingBlockStore::remove(unique_ptr<Block> block) {
|
2015-04-02 13:21:52 +02:00
|
|
|
Key key = block->key();
|
2015-04-02 18:19:05 +02:00
|
|
|
return _cachingStore.remove(key, std::move(block));
|
2015-03-19 11:16:20 +01:00
|
|
|
}
|
|
|
|
|
2015-04-02 08:59:43 +02:00
|
|
|
uint64_t CachingBlockStore::numBlocks() const {
|
2015-03-19 11:16:20 +01:00
|
|
|
return _baseBlockStore->numBlocks();
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|