2015-02-17 00:40:34 +01:00
|
|
|
#include "datanodestore/DataLeafNode.h"
|
|
|
|
#include "datanodestore/DataNodeStore.h"
|
2015-02-25 22:48:39 +01:00
|
|
|
#include "datatreestore/DataTreeStore.h"
|
|
|
|
#include "datatreestore/DataTree.h"
|
2014-12-09 17:56:48 +01:00
|
|
|
#include "BlobStoreOnBlocks.h"
|
2015-03-19 11:16:50 +01:00
|
|
|
#include <messmer/blockstore/implementations/synchronized/SynchronizedBlockStore.h>
|
2014-12-09 17:56:48 +01:00
|
|
|
|
|
|
|
#include "BlobOnBlocks.h"
|
2015-03-06 02:21:20 +01:00
|
|
|
#include <messmer/cpp-utils/pointer.h>
|
2014-12-09 17:56:48 +01:00
|
|
|
|
|
|
|
using std::unique_ptr;
|
|
|
|
using std::make_unique;
|
|
|
|
|
|
|
|
using blockstore::BlockStore;
|
2015-03-19 11:16:50 +01:00
|
|
|
using blockstore::synchronized::SynchronizedBlockStore;
|
2014-12-13 19:17:08 +01:00
|
|
|
using blockstore::Key;
|
2015-03-06 02:21:20 +01:00
|
|
|
using cpputils::dynamic_pointer_move;
|
2014-12-09 17:45:33 +01:00
|
|
|
|
|
|
|
namespace blobstore {
|
|
|
|
namespace onblocks {
|
|
|
|
|
2014-12-13 19:17:08 +01:00
|
|
|
using datanodestore::DataNodeStore;
|
2015-02-25 22:48:39 +01:00
|
|
|
using datatreestore::DataTreeStore;
|
2014-12-13 19:17:08 +01:00
|
|
|
|
2015-03-05 22:21:59 +01:00
|
|
|
BlobStoreOnBlocks::BlobStoreOnBlocks(unique_ptr<BlockStore> blockStore, uint32_t blocksizeBytes)
|
2015-03-19 11:16:50 +01:00
|
|
|
: _dataTreeStore(make_unique<DataTreeStore>(make_unique<DataNodeStore>(make_unique<SynchronizedBlockStore>(std::move(blockStore)), blocksizeBytes))) {
|
2014-12-09 17:45:33 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
BlobStoreOnBlocks::~BlobStoreOnBlocks() {
|
|
|
|
}
|
|
|
|
|
2014-12-13 19:17:08 +01:00
|
|
|
unique_ptr<Blob> BlobStoreOnBlocks::create() {
|
2015-02-25 22:48:39 +01:00
|
|
|
return make_unique<BlobOnBlocks>(_dataTreeStore->createNewTree());
|
2014-12-09 17:56:48 +01:00
|
|
|
}
|
|
|
|
|
2014-12-09 20:36:32 +01:00
|
|
|
unique_ptr<Blob> BlobStoreOnBlocks::load(const Key &key) {
|
2015-03-06 02:21:20 +01:00
|
|
|
auto tree = _dataTreeStore->load(key);
|
|
|
|
if (tree == nullptr) {
|
|
|
|
return nullptr;
|
|
|
|
}
|
|
|
|
return make_unique<BlobOnBlocks>(std::move(tree));
|
|
|
|
}
|
|
|
|
|
|
|
|
void BlobStoreOnBlocks::remove(unique_ptr<Blob> blob) {
|
|
|
|
auto _blob = dynamic_pointer_move<BlobOnBlocks>(blob);
|
|
|
|
_dataTreeStore->remove(_blob->releaseTree());
|
2014-12-09 17:56:48 +01:00
|
|
|
}
|
|
|
|
|
2014-12-09 17:45:33 +01:00
|
|
|
}
|
|
|
|
}
|