This source file includes following definitions.
- Backend
- Init
- InitWithStore
- Get
- Set
- Remove
- CurrentlyOn
- RunCallback
- Init
- Get
- Set
- Remove
#include "extensions/browser/value_store/value_store_frontend.h"
#include "base/bind.h"
#include "base/debug/trace_event.h"
#include "base/files/file_path.h"
#include "base/logging.h"
#include "content/public/browser/browser_thread.h"
#include "extensions/browser/value_store/leveldb_value_store.h"
using content::BrowserThread;
class ValueStoreFrontend::Backend : public base::RefCountedThreadSafe<Backend> {
public:
Backend() : storage_(NULL) {}
void Init(const base::FilePath& db_path) {
DCHECK_CURRENTLY_ON(BrowserThread::FILE);
DCHECK(!storage_);
TRACE_EVENT0("ValueStoreFrontend::Backend", "Init");
db_path_ = db_path;
storage_ = new LeveldbValueStore(db_path);
}
void InitWithStore(scoped_ptr<ValueStore> storage) {
DCHECK_CURRENTLY_ON(BrowserThread::FILE);
DCHECK(!storage_);
storage_ = storage.release();
}
void Get(const std::string& key,
const ValueStoreFrontend::ReadCallback& callback) {
DCHECK_CURRENTLY_ON(BrowserThread::FILE);
ValueStore::ReadResult result = storage_->Get(key);
scoped_ptr<base::Value> value;
if (!result->HasError()) {
result->settings().RemoveWithoutPathExpansion(key, &value);
} else {
LOG(WARNING) << "Reading " << key << " from " << db_path_.value()
<< " failed: " << result->error().message;
}
BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
base::Bind(&ValueStoreFrontend::Backend::RunCallback,
this, callback, base::Passed(&value)));
}
void Set(const std::string& key, scoped_ptr<base::Value> value) {
DCHECK_CURRENTLY_ON(BrowserThread::FILE);
storage_->Set(ValueStore::IGNORE_QUOTA | ValueStore::NO_GENERATE_CHANGES,
key, *value.get());
}
void Remove(const std::string& key) {
DCHECK_CURRENTLY_ON(BrowserThread::FILE);
storage_->Remove(key);
}
private:
friend class base::RefCountedThreadSafe<Backend>;
virtual ~Backend() {
if (BrowserThread::CurrentlyOn(BrowserThread::FILE)) {
delete storage_;
} else {
BrowserThread::DeleteSoon(BrowserThread::FILE, FROM_HERE, storage_);
}
}
void RunCallback(const ValueStoreFrontend::ReadCallback& callback,
scoped_ptr<base::Value> value) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
callback.Run(value.Pass());
}
ValueStore* storage_;
base::FilePath db_path_;
DISALLOW_COPY_AND_ASSIGN(Backend);
};
ValueStoreFrontend::ValueStoreFrontend()
: backend_(new Backend()) {
}
ValueStoreFrontend::ValueStoreFrontend(const base::FilePath& db_path)
: backend_(new Backend()) {
Init(db_path);
}
ValueStoreFrontend::ValueStoreFrontend(scoped_ptr<ValueStore> value_store)
: backend_(new Backend()) {
BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE,
base::Bind(&ValueStoreFrontend::Backend::InitWithStore,
backend_, base::Passed(&value_store)));
}
ValueStoreFrontend::~ValueStoreFrontend() {
DCHECK(CalledOnValidThread());
}
void ValueStoreFrontend::Init(const base::FilePath& db_path) {
BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE,
base::Bind(&ValueStoreFrontend::Backend::Init,
backend_, db_path));
}
void ValueStoreFrontend::Get(const std::string& key,
const ReadCallback& callback) {
DCHECK(CalledOnValidThread());
BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE,
base::Bind(&ValueStoreFrontend::Backend::Get,
backend_, key, callback));
}
void ValueStoreFrontend::Set(const std::string& key,
scoped_ptr<base::Value> value) {
DCHECK(CalledOnValidThread());
BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE,
base::Bind(&ValueStoreFrontend::Backend::Set,
backend_, key, base::Passed(&value)));
}
void ValueStoreFrontend::Remove(const std::string& key) {
DCHECK(CalledOnValidThread());
BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE,
base::Bind(&ValueStoreFrontend::Backend::Remove,
backend_, key));
}