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
|
/**
* 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";
const android = mozinfo.os == "android";
// We want 512 KB database on Android and 4 MB database on other platforms.
const groupLimitKB = android ? 512 : 4096;
// The group limit is calculated as 20% of the global temporary storage limit.
const tempStorageLimitKB = groupLimitKB * 5;
// We want 64 KB chunks on Android and 512 KB chunks on other platforms.
const dataSizeKB = android ? 64 : 512;
const dataSize = dataSizeKB * 1024;
const maxIter = 5;
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, { autoIncrement: true });
yield undefined;
// success
let db = request.result;
db.onerror = errorHandler;
ok(true, "Filling database");
let obj = {
name: "foo",
};
if (!blobs) {
obj.data = getRandomView(dataSize);
}
let iter = 1;
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);
request.onerror = function (event) {
event.stopPropagation();
};
trans.oncomplete = function (event) {
if (iter == 1) {
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");
continue;
}
ok(true, "Got abort event");
if (iter++ == maxIter) {
break;
}
if (iter > 1) {
ok(i == j, "Recycled entire database");
j = 1;
}
trans = db.transaction(objectStoreName, "readwrite");
// Don't use a cursor for deleting stored blobs (Cursors prolong live
// of stored files since each record must be fetched from the database
// first which creates a memory reference to the stored blob.)
if (blobs) {
request = trans.objectStore(objectStoreName).clear();
} else {
request = trans.objectStore(objectStoreName).openCursor();
request.onsuccess = function (event) {
let cursor = event.target.result;
if (cursor) {
cursor.delete();
cursor.continue();
}
};
}
trans.onabort = unexpectedSuccessHandler;
trans.oncomplete = grabEventAndContinueHandler;
yield undefined;
}
}
finishTest();
yield undefined;
}
|
