| Index: webkit/browser/fileapi/quota/quota_reservation.cc
|
| diff --git a/webkit/browser/fileapi/quota/quota_reservation.cc b/webkit/browser/fileapi/quota/quota_reservation.cc
|
| deleted file mode 100644
|
| index 5139d0b4ae9a51e63d61c1896654302a5d5ee44f..0000000000000000000000000000000000000000
|
| --- a/webkit/browser/fileapi/quota/quota_reservation.cc
|
| +++ /dev/null
|
| @@ -1,127 +0,0 @@
|
| -// Copyright 2013 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 "webkit/browser/fileapi/quota/quota_reservation.h"
|
| -
|
| -#include "base/bind.h"
|
| -#include "webkit/browser/fileapi/quota/open_file_handle.h"
|
| -#include "webkit/browser/fileapi/quota/quota_reservation_buffer.h"
|
| -
|
| -namespace storage {
|
| -
|
| -void QuotaReservation::RefreshReservation(
|
| - int64 size,
|
| - const StatusCallback& callback) {
|
| - DCHECK(sequence_checker_.CalledOnValidSequencedThread());
|
| - DCHECK(!running_refresh_request_);
|
| - DCHECK(!client_crashed_);
|
| - if (!reservation_manager())
|
| - return;
|
| -
|
| - running_refresh_request_ = true;
|
| -
|
| - reservation_manager()->ReserveQuota(
|
| - origin(), type(), size - remaining_quota_,
|
| - base::Bind(&QuotaReservation::AdaptDidUpdateReservedQuota,
|
| - weak_ptr_factory_.GetWeakPtr(),
|
| - remaining_quota_, callback));
|
| -
|
| - if (running_refresh_request_)
|
| - remaining_quota_ = 0;
|
| -}
|
| -
|
| -scoped_ptr<OpenFileHandle> QuotaReservation::GetOpenFileHandle(
|
| - const base::FilePath& platform_path) {
|
| - DCHECK(sequence_checker_.CalledOnValidSequencedThread());
|
| - DCHECK(!client_crashed_);
|
| - return reservation_buffer_->GetOpenFileHandle(this, platform_path);
|
| -}
|
| -
|
| -void QuotaReservation::OnClientCrash() {
|
| - DCHECK(sequence_checker_.CalledOnValidSequencedThread());
|
| - client_crashed_ = true;
|
| -
|
| - if (remaining_quota_) {
|
| - reservation_buffer_->PutReservationToBuffer(remaining_quota_);
|
| - remaining_quota_ = 0;
|
| - }
|
| -}
|
| -
|
| -void QuotaReservation::ConsumeReservation(int64 size) {
|
| - DCHECK(sequence_checker_.CalledOnValidSequencedThread());
|
| - DCHECK_LT(0, size);
|
| - DCHECK_LE(size, remaining_quota_);
|
| - if (client_crashed_)
|
| - return;
|
| -
|
| - remaining_quota_ -= size;
|
| - reservation_buffer_->PutReservationToBuffer(size);
|
| -}
|
| -
|
| -QuotaReservationManager* QuotaReservation::reservation_manager() {
|
| - return reservation_buffer_->reservation_manager();
|
| -}
|
| -
|
| -const GURL& QuotaReservation::origin() const {
|
| - return reservation_buffer_->origin();
|
| -}
|
| -
|
| -FileSystemType QuotaReservation::type() const {
|
| - return reservation_buffer_->type();
|
| -}
|
| -
|
| -QuotaReservation::QuotaReservation(
|
| - QuotaReservationBuffer* reservation_buffer)
|
| - : client_crashed_(false),
|
| - running_refresh_request_(false),
|
| - remaining_quota_(0),
|
| - reservation_buffer_(reservation_buffer),
|
| - weak_ptr_factory_(this) {
|
| - DCHECK(sequence_checker_.CalledOnValidSequencedThread());
|
| -}
|
| -
|
| -QuotaReservation::~QuotaReservation() {
|
| - DCHECK(sequence_checker_.CalledOnValidSequencedThread());
|
| -
|
| - if (remaining_quota_ && reservation_manager()) {
|
| - reservation_manager()->ReleaseReservedQuota(
|
| - origin(), type(), remaining_quota_);
|
| - }
|
| -}
|
| -
|
| -// static
|
| -bool QuotaReservation::AdaptDidUpdateReservedQuota(
|
| - const base::WeakPtr<QuotaReservation>& reservation,
|
| - int64 previous_size,
|
| - const StatusCallback& callback,
|
| - base::File::Error error,
|
| - int64 delta) {
|
| - if (!reservation)
|
| - return false;
|
| -
|
| - return reservation->DidUpdateReservedQuota(
|
| - previous_size, callback, error, delta);
|
| -}
|
| -
|
| -bool QuotaReservation::DidUpdateReservedQuota(
|
| - int64 previous_size,
|
| - const StatusCallback& callback,
|
| - base::File::Error error,
|
| - int64 delta) {
|
| - DCHECK(sequence_checker_.CalledOnValidSequencedThread());
|
| - DCHECK(running_refresh_request_);
|
| - running_refresh_request_ = false;
|
| -
|
| - if (client_crashed_) {
|
| - callback.Run(base::File::FILE_ERROR_ABORT);
|
| - return false;
|
| - }
|
| -
|
| - if (error == base::File::FILE_OK)
|
| - remaining_quota_ = previous_size + delta;
|
| - callback.Run(error);
|
| - return true;
|
| -}
|
| -
|
| -} // namespace storage
|
|
|