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
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
/**
* Any copyright is dedicated to the Public Domain.
* http://creativecommons.org/publicdomain/zero/1.0/
*/
/* exported testGenerator, disableWorkerTest */
var disableWorkerTest = "Need a way to set temporary prefs from a worker";
var testGenerator = testSteps();
function* testSteps() {
const spec = "http://foo.com";
const name = this.window
? window.location.pathname
: "test_quotaExceeded_recovery";
const objectStoreName = "foo";
// We want 32 MB database, but there's the group limit so we need to
// multiply by 5.
const tempStorageLimitKB = 32 * 1024 * 5;
// Store in 1 MB chunks.
const dataSize = 1024 * 1024;
for (let blobs of [false, true]) {
setTemporaryStorageLimit(tempStorageLimitKB);
clearAllDatabases(continueToNextStepSync);
yield undefined;
info("Opening database");
let request = indexedDB.openForPrincipal(getPrincipal(spec), name);
request.onerror = errorHandler;
request.onupgradeneeded = grabEventAndContinueHandler;
request.onsuccess = unexpectedSuccessHandler;
yield undefined;
// upgradeneeded
request.onupgradeneeded = unexpectedSuccessHandler;
request.onsuccess = grabEventAndContinueHandler;
info("Creating objectStore");
request.result.createObjectStore(objectStoreName);
yield undefined;
// success
let db = request.result;
db.onerror = errorHandler;
ok(true, "Adding data until quota is reached");
let obj = {
name: "foo",
};
if (!blobs) {
obj.data = getRandomView(dataSize);
}
let i = 1;
let j = 1;
while (true) {
if (blobs) {
obj.data = getBlob(getView(dataSize));
}
let trans = db.transaction(objectStoreName, "readwrite");
request = trans.objectStore(objectStoreName).add(obj, i);
request.onerror = function (event) {
event.stopPropagation();
};
trans.oncomplete = function (event) {
i++;
j++;
testGenerator.next(true);
};
trans.onabort = function (event) {
is(trans.error.name, "QuotaExceededError", "Reached quota limit");
testGenerator.next(false);
};
let completeFired = yield undefined;
if (completeFired) {
ok(true, "Got complete event");
} else {
ok(true, "Got abort event");
if (j == 1) {
// Plain cleanup transaction (just vacuuming and checkpointing)
// couldn't shrink database any further.
break;
}
j = 1;
trans = db.transaction(objectStoreName, "cleanup");
trans.onabort = unexpectedSuccessHandler;
trans.oncomplete = grabEventAndContinueHandler;
yield undefined;
}
}
info("Reopening database");
db.close();
request = indexedDB.openForPrincipal(getPrincipal(spec), name);
request.onerror = errorHandler;
request.onsuccess = grabEventAndContinueHandler;
yield undefined;
db = request.result;
db.onerror = errorHandler;
info("Deleting some data");
let trans = db.transaction(objectStoreName, "cleanup");
trans.objectStore(objectStoreName).delete(1);
trans.onabort = unexpectedSuccessHandler;
trans.oncomplete = grabEventAndContinueHandler;
yield undefined;
info("Adding data again");
trans = db.transaction(objectStoreName, "readwrite");
trans.objectStore(objectStoreName).add(obj, 1);
trans.onabort = unexpectedSuccessHandler;
trans.oncomplete = grabEventAndContinueHandler;
yield undefined;
info("Deleting database");
db.close();
request = indexedDB.deleteForPrincipal(getPrincipal(spec), name);
request.onerror = errorHandler;
request.onsuccess = grabEventAndContinueHandler;
yield undefined;
}
finishTest();
yield undefined;
}
|
