Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1870)

Unified Diff: webkit/browser/fileapi/quota/quota_reservation.cc

Issue 539143002: Migrate webkit/browser/ to storage/browser/ (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 6 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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

Powered by Google App Engine
This is Rietveld 408576698