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 |