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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
/**
* Any copyright is dedicated to the Public Domain.
* http://creativecommons.org/publicdomain/zero/1.0/
*/
/**
* This test is mainly to verify that the storage pressure event is fired when
* the eviction process is not able to free some space when a quota client
* attempts to write over the global limit or when the global limit is reduced
* below the global usage.
*/
const { TestUtils } = ChromeUtils.importESModule(
"resource://testing-common/TestUtils.sys.mjs"
);
loadScript("dom/quota/test/common/file.js");
async function awaitStoragePressure() {
const [subject] = await TestUtils.topicObserved(
"QuotaManager::StoragePressure"
);
const usage = subject.QueryInterface(Ci.nsISupportsPRUint64).data;
return usage;
}
async function testSteps() {
const globalLimitKB = 2;
const principal = getPrincipal("https://example.com");
info("Setting limits");
setGlobalLimit(globalLimitKB);
info("Initializing");
let request = init();
await requestFinished(request);
info("Initializing temporary storage");
request = initTemporaryStorage();
await requestFinished(request);
info("Persisting and filling an origin");
// We need to persist the origin first to omit the group limit checks.
// Otherwise, we would have to fill five separate origins.
request = persist(principal);
await requestFinished(request);
let database = getSimpleDatabase(principal);
request = database.open("data");
await requestFinished(request);
try {
request = database.write(getBuffer(globalLimitKB * 1024));
await requestFinished(request);
ok(true, "Should not have thrown");
} catch (ex) {
ok(false, "Should not have thrown");
}
info("Testing storage pressure by writing over the global limit");
info("Storing one more byte to get the storage pressure event while writing");
let promiseStoragePressure = awaitStoragePressure();
try {
request = database.write(getBuffer(1));
await requestFinished(request);
ok(false, "Should have thrown");
} catch (e) {
ok(true, "Should have thrown");
Assert.strictEqual(
e.resultCode,
NS_ERROR_FILE_NO_DEVICE_SPACE,
"Threw right result code"
);
}
info("Checking the storage pressure event");
let usage = await promiseStoragePressure;
Assert.equal(usage, globalLimitKB * 1024, "Got correct usage");
info("Testing storage pressure by reducing the global limit");
info(
"Reducing the global limit to get the storage pressuse event while the" +
" temporary storage is being initialized"
);
setGlobalLimit(globalLimitKB - 1);
request = reset();
await requestFinished(request);
info("Initializing");
request = init();
await requestFinished(request);
promiseStoragePressure = awaitStoragePressure();
info("Initializing temporary storage");
request = initTemporaryStorage();
await requestFinished(request);
info("Checking the storage pressure event");
usage = await promiseStoragePressure;
Assert.equal(usage, globalLimitKB * 1024, "Got correct usage");
info("Resetting limits");
resetGlobalLimit();
request = reset();
await requestFinished(request);
}
|
