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
|
/* Any copyright is dedicated to the Public Domain.
* http://creativecommons.org/publicdomain/zero/1.0
*/
function BinaryComparer(file, callback) {
var fstream = Cc["@mozilla.org/network/file-input-stream;1"].createInstance(
Ci.nsIFileInputStream
);
fstream.init(file, -1, 0, 0);
this.length = file.fileSize;
this.fileStream = Cc["@mozilla.org/binaryinputstream;1"].createInstance(
Ci.nsIBinaryInputStream
);
this.fileStream.setInputStream(fstream);
this.offset = 0;
this.callback = callback;
}
BinaryComparer.prototype = {
fileStream: null,
offset: null,
length: null,
callback: null,
onStartRequest(aRequest) {},
onStopRequest(aRequest, aStatusCode) {
this.fileStream.close();
Assert.equal(aStatusCode, Cr.NS_OK);
Assert.equal(this.offset, this.length);
this.callback();
},
onDataAvailable(aRequest, aInputStream, aOffset, aCount) {
var stream = Cc["@mozilla.org/binaryinputstream;1"].createInstance(
Ci.nsIBinaryInputStream
);
stream.setInputStream(aInputStream);
var source, actual;
for (var i = 0; i < aCount; i++) {
try {
source = this.fileStream.read8();
} catch (e) {
do_throw("Unable to read from file at offset " + this.offset + " " + e);
}
try {
actual = stream.read8();
} catch (e) {
do_throw(
"Unable to read from converted stream at offset " +
this.offset +
" " +
e
);
}
// The byte at offset 9 is the OS byte (see RFC 1952, section 2.3), which
// can legitimately differ when the source is compressed on different
// operating systems. The actual .gz for this test was created on a Unix
// system, but we want the test to work correctly everywhere. So ignore
// the byte at offset 9.
if (this.offset != 9 && source != actual) {
do_throw(
"Invalid value " +
actual +
" at offset " +
this.offset +
", should have been " +
source
);
}
this.offset++;
}
},
};
function comparer_callback() {
do_test_finished();
}
function run_test() {
var source = do_get_file(DATA_DIR + "test_bug717061.html");
var comparer = new BinaryComparer(
do_get_file(DATA_DIR + "test_bug717061.gz"),
comparer_callback
);
// Prepare the stream converter
var scs = Cc["@mozilla.org/streamConverters;1"].getService(
Ci.nsIStreamConverterService
);
var converter = scs.asyncConvertData("uncompressed", "gzip", comparer, null);
// Open the expected output file
var fstream = Cc["@mozilla.org/network/file-input-stream;1"].createInstance(
Ci.nsIFileInputStream
);
fstream.init(source, -1, 0, 0);
// Set up a pump to push data from the file to the stream converter
var pump = Cc["@mozilla.org/network/input-stream-pump;1"].createInstance(
Ci.nsIInputStreamPump
);
pump.init(fstream, 0, 0, true);
pump.asyncRead(converter);
do_test_pending();
}
|
