1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
// Copyright 2013 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CONTENT_BROWSER_RENDERER_HOST_PEPPER_QUOTA_RESERVATION_H_
#define CONTENT_BROWSER_RENDERER_HOST_PEPPER_QUOTA_RESERVATION_H_
#include <map>
#include "base/functional/callback.h"
#include "base/memory/raw_ptr.h"
#include "content/common/content_export.h"
#include "ppapi/c/pp_stdint.h" // For int64_t on Windows.
#include "ppapi/shared_impl/file_growth.h"
#include "storage/browser/file_system/file_system_context.h"
#include "url/gurl.h"
namespace storage {
class FileSystemURL;
class OpenFileHandle;
class QuotaReservation;
}
namespace content {
struct QuotaReservationDeleter;
// This class holds a QuotaReservation and manages OpenFileHandles for checking
// quota. It should be created, used, and destroyed on a FileSystemContext's
// default_file_task_runner() instance. This is a RefCountedThreadSafe object
// because it needs to be passed to the file thread and kept alive during
// potentially long-running quota operations.
class CONTENT_EXPORT QuotaReservation
: public base::RefCountedThreadSafe<QuotaReservation,
QuotaReservationDeleter> {
public:
// Static method to facilitate construction on the file task runner.
static scoped_refptr<QuotaReservation> Create(
scoped_refptr<storage::FileSystemContext> file_system_context,
const GURL& origin_url,
storage::FileSystemType file_system_type);
QuotaReservation(const QuotaReservation&) = delete;
QuotaReservation& operator=(const QuotaReservation&) = delete;
// Opens a file with the given id and path and returns its current size.
int64_t OpenFile(int32_t id, const storage::FileSystemURL& url);
// Closes the file opened by OpenFile with the given id.
void CloseFile(int32_t id, const ppapi::FileGrowth& file_growth);
// Refreshes the quota reservation to a new amount. A map that associates file
// ids with maximum written offsets is provided as input. The callback will
// receive a similar map with the updated file sizes.
using ReserveQuotaCallback =
base::OnceCallback<void(int64_t, const ppapi::FileSizeMap&)>;
void ReserveQuota(int64_t amount,
const ppapi::FileGrowthMap& file_growth,
ReserveQuotaCallback callback);
// Notifies underlying QuotaReservation that the associated client crashed,
// and that the reserved quota is no longer traceable.
void OnClientCrash();
private:
friend class base::RefCountedThreadSafe<QuotaReservation,
QuotaReservationDeleter>;
friend class base::DeleteHelper<QuotaReservation>;
friend struct QuotaReservationDeleter;
friend class QuotaReservationTest;
QuotaReservation(
scoped_refptr<storage::FileSystemContext> file_system_context,
const GURL& origin_url,
storage::FileSystemType file_system_type);
// For unit testing only. A QuotaReservation intended for unit testing will
// have file_system_context_ == NULL.
QuotaReservation(scoped_refptr<storage::QuotaReservation> quota_reservation,
const GURL& origin_url,
storage::FileSystemType file_system_type);
~QuotaReservation();
void GotReservedQuota(ReserveQuotaCallback callback, base::File::Error error);
void DeleteOnCorrectThread() const;
scoped_refptr<storage::FileSystemContext> file_system_context_;
scoped_refptr<storage::QuotaReservation> quota_reservation_;
typedef std::map<int32_t, raw_ptr<storage::OpenFileHandle, CtnExperimental>>
FileMap;
FileMap files_;
};
struct QuotaReservationDeleter {
static void Destruct(const QuotaReservation* quota_reservation) {
quota_reservation->DeleteOnCorrectThread();
}
};
} // namespace content
#endif // CONTENT_BROWSER_RENDERER_HOST_PEPPER_QUOTA_RESERVATION_H_
|
