diff options
Diffstat (limited to 'chromium/net/disk_cache/flash/internal_entry.cc')
-rw-r--r-- | chromium/net/disk_cache/flash/internal_entry.cc | 86 |
1 files changed, 86 insertions, 0 deletions
diff --git a/chromium/net/disk_cache/flash/internal_entry.cc b/chromium/net/disk_cache/flash/internal_entry.cc new file mode 100644 index 00000000000..c6bae8926aa --- /dev/null +++ b/chromium/net/disk_cache/flash/internal_entry.cc @@ -0,0 +1,86 @@ +// Copyright (c) 2012 The Chromium Authors. All rights reserved. +// Use of this source code is governed by a BSD-style license that can be +// found in the LICENSE file. + +#include "net/disk_cache/flash/internal_entry.h" + +#include "base/memory/ref_counted.h" +#include "net/base/completion_callback.h" +#include "net/base/io_buffer.h" +#include "net/base/net_errors.h" +#include "net/disk_cache/flash/log_store.h" +#include "net/disk_cache/flash/log_store_entry.h" + +using net::IOBuffer; +using net::StringIOBuffer; +using net::CompletionCallback; + +namespace disk_cache { + +KeyAndStreamSizes::KeyAndStreamSizes() { +} + +InternalEntry::InternalEntry(const std::string& key, LogStore* store) + : store_(store), + entry_(new LogStoreEntry(store_)) { + entry_->Init(); + WriteKey(entry_.get(), key); +} + +InternalEntry::InternalEntry(int32 id, LogStore* store) + : store_(store), + entry_(new LogStoreEntry(store_, id)) { +} + +InternalEntry::~InternalEntry() { +} + +scoped_ptr<KeyAndStreamSizes> InternalEntry::Init() { + scoped_ptr<KeyAndStreamSizes> null; + if (entry_->IsNew()) + return null.Pass(); + if (!entry_->Init()) + return null.Pass(); + + scoped_ptr<KeyAndStreamSizes> rv(new KeyAndStreamSizes); + if (!ReadKey(entry_.get(), &rv->key)) + return null.Pass(); + for (int i = 0; i < kFlashLogStoreEntryNumStreams; ++i) + rv->stream_sizes[i] = entry_->GetDataSize(i+1); + return rv.Pass(); +} + +int32 InternalEntry::GetDataSize(int index) const { + return entry_->GetDataSize(++index); +} + +int InternalEntry::ReadData(int index, int offset, IOBuffer* buf, int buf_len, + const CompletionCallback& callback) { + return entry_->ReadData(++index, offset, buf, buf_len); +} + +int InternalEntry::WriteData(int index, int offset, IOBuffer* buf, int buf_len, + const CompletionCallback& callback) { + return entry_->WriteData(++index, offset, buf, buf_len); +} + +void InternalEntry::Close() { + entry_->Close(); +} + +bool InternalEntry::WriteKey(LogStoreEntry* entry, const std::string& key) { + int key_size = static_cast<int>(key.size()); + scoped_refptr<IOBuffer> key_buf(new StringIOBuffer(key)); + return entry->WriteData(0, 0, key_buf.get(), key_size) == key_size; +} + +bool InternalEntry::ReadKey(LogStoreEntry* entry, std::string* key) { + int key_size = entry->GetDataSize(0); + scoped_refptr<net::IOBuffer> key_buf(new net::IOBuffer(key_size)); + if (entry->ReadData(0, 0, key_buf.get(), key_size) != key_size) + return false; + key->assign(key_buf->data(), key_size); + return true; +} + +} // namespace disk_cache |