summaryrefslogtreecommitdiffstats
path: root/net/disk_cache/entry_impl.cc
diff options
context:
space:
mode:
Diffstat (limited to 'net/disk_cache/entry_impl.cc')
-rw-r--r--net/disk_cache/entry_impl.cc40
1 files changed, 36 insertions, 4 deletions
diff --git a/net/disk_cache/entry_impl.cc b/net/disk_cache/entry_impl.cc
index ea20b3c..c9bab9a 100644
--- a/net/disk_cache/entry_impl.cc
+++ b/net/disk_cache/entry_impl.cc
@@ -1,4 +1,4 @@
-// Copyright (c) 2006-2008 The Chromium Authors. All rights reserved.
+// Copyright (c) 2006-2009 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.
@@ -10,8 +10,10 @@
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"
#include "net/disk_cache/backend_impl.h"
+#include "net/disk_cache/bitmap.h"
#include "net/disk_cache/cache_util.h"
#include "net/disk_cache/histogram_macros.h"
+#include "net/disk_cache/sparse_control.h"
using base::Time;
using base::TimeDelta;
@@ -91,6 +93,9 @@ EntryImpl::EntryImpl(BackendImpl* backend, Addr address)
// data related to a previous cache entry because the range was not fully
// written before).
EntryImpl::~EntryImpl() {
+ // Save the sparse info to disk before deleting this entry.
+ sparse_.reset();
+
if (doomed_) {
DeleteEntryData(true);
} else {
@@ -353,16 +358,32 @@ int EntryImpl::WriteData(int index, int offset, net::IOBuffer* buf, int buf_len,
int EntryImpl::ReadSparseData(int64 offset, net::IOBuffer* buf, int buf_len,
net::CompletionCallback* completion_callback) {
- return net::ERR_CACHE_OPERATION_NOT_SUPPORTED;
+ DCHECK(node_.Data()->dirty);
+ int result = InitSparseData();
+ if (net::OK != result)
+ return result;
+
+ return sparse_->StartIO(SparseControl::kReadOperation, offset, buf, buf_len,
+ completion_callback);
}
int EntryImpl::WriteSparseData(int64 offset, net::IOBuffer* buf, int buf_len,
net::CompletionCallback* completion_callback) {
- return net::ERR_CACHE_OPERATION_NOT_SUPPORTED;
+ DCHECK(node_.Data()->dirty);
+ int result = InitSparseData();
+ if (net::OK != result)
+ return result;
+
+ return sparse_->StartIO(SparseControl::kWriteOperation, offset, buf, buf_len,
+ completion_callback);
}
int EntryImpl::GetAvailableRange(int64 offset, int len, int64* start) {
- return net::ERR_CACHE_OPERATION_NOT_SUPPORTED;
+ int result = InitSparseData();
+ if (net::OK != result)
+ return result;
+
+ return sparse_->GetAvailableRange(offset, len, start);
}
uint32 EntryImpl::GetHash() {
@@ -813,6 +834,17 @@ bool EntryImpl::Flush(int index, int size, bool async) {
return true;
}
+int EntryImpl::InitSparseData() {
+ if (sparse_.get())
+ return net::OK;
+
+ sparse_.reset(new SparseControl(this));
+ int result = sparse_->Init();
+ if (net::OK != result)
+ sparse_.reset();
+ return result;
+}
+
void EntryImpl::Log(const char* msg) {
void* pointer = NULL;
int dirty = 0;