modules/libjar/test/unit/test_jarchannel.js@6474c204b198
modules/libjar/test/unit/test_jarchannel.js
Wed, 31 Dec 2014 06:09:35 +0100
- author
- Michael Schloh von Bennewitz <michael@schloh.com>
- date
- Wed, 31 Dec 2014 06:09:35 +0100
- changeset 0
- 6474c204b198
- permissions
- -rw-r--r--
Cloned upstream origin tor-browser at tor-browser-31.3.0esr-4.5-1-build1
revision ID fc1c9ff7c1b2defdbc039f12214767608f46423f for hacking purpose.
1 /* Any copyright is dedicated to the Public Domain.
2 * http://creativecommons.org/publicdomain/zero/1.0/
3 */
5 /**
6 * Tests some basic jar channel functionality
7 */
10 const {classes: Cc,
11 interfaces: Ci,
12 results: Cr,
13 Constructor: ctor
14 } = Components;
16 const ios = Cc["@mozilla.org/network/io-service;1"].
17 getService(Ci.nsIIOService);
18 const dirSvc = Cc["@mozilla.org/file/directory_service;1"].
19 getService(Ci.nsIProperties);
20 const obs = Cc["@mozilla.org/observer-service;1"].
21 getService(Ci.nsIObserverService);
23 const nsIBinaryInputStream = ctor("@mozilla.org/binaryinputstream;1",
24 "nsIBinaryInputStream",
25 "setInputStream"
26 );
28 const fileBase = "test_bug637286.zip";
29 const file = do_get_file("data/" + fileBase);
30 // on child we'll test with jar:remoteopenfile:// instead of jar:file://
31 const jarBase = "jar:" + filePrefix + ios.newFileURI(file).spec + "!";
32 const tmpDir = dirSvc.get("TmpD", Ci.nsIFile);
34 function Listener(callback) {
35 this._callback = callback;
36 }
37 Listener.prototype = {
38 gotStartRequest: false,
39 available: -1,
40 gotStopRequest: false,
41 QueryInterface: function(iid) {
42 if (iid.equals(Ci.nsISupports) ||
43 iid.equals(Ci.nsIRequestObserver))
44 return this;
45 throw Cr.NS_ERROR_NO_INTERFACE;
46 },
47 onDataAvailable: function(request, ctx, stream, offset, count) {
48 try {
49 this.available = stream.available();
50 do_check_eq(this.available, count);
51 // Need to consume stream to avoid assertion
52 new nsIBinaryInputStream(stream).readBytes(count);
53 }
54 catch (ex) {
55 do_throw(ex);
56 }
57 },
58 onStartRequest: function(request, ctx) {
59 this.gotStartRequest = true;
60 },
61 onStopRequest: function(request, ctx) {
62 this.gotStopRequest = true;
63 if (this._callback) {
64 this._callback.call(null, this);
65 }
66 }
67 };
69 /**
70 * Basic reading test for asynchronously opened jar channel
71 */
72 function testAsync() {
73 var uri = jarBase + "/inner40.zip";
74 var chan = ios.newChannel(uri, null, null);
75 do_check_true(chan.contentLength < 0);
76 chan.asyncOpen(new Listener(function(l) {
77 do_check_true(chan.contentLength > 0);
78 do_check_true(l.gotStartRequest);
79 do_check_true(l.gotStopRequest);
80 do_check_eq(l.available, chan.contentLength);
82 run_next_test();
83 }), null);
84 }
86 add_test(testAsync);
87 // Run same test again so we test the codepath for a zipcache hit
88 add_test(testAsync);
91 // In e10s child processes we don't currently support
92 // 1) synchronously opening jar files on parent
93 // 2) nested jar channels in e10s: (app:// doesn't use them).
94 // 3) we can't do file lock checks on android, so skip those tests too.
95 if (!inChild) {
97 /**
98 * Basic reading test for synchronously opened jar channels
99 */
100 add_test(function testSync() {
101 var uri = jarBase + "/inner40.zip";
102 var chan = ios.newChannel(uri, null, null);
103 var stream = chan.open();
104 do_check_true(chan.contentLength > 0);
105 do_check_eq(stream.available(), chan.contentLength);
106 stream.close();
107 stream.close(); // should still not throw
109 run_next_test();
110 });
113 /**
114 * Basic reading test for synchronously opened, nested jar channels
115 */
116 add_test(function testSyncNested() {
117 var uri = "jar:" + jarBase + "/inner40.zip!/foo";
118 var chan = ios.newChannel(uri, null, null);
119 var stream = chan.open();
120 do_check_true(chan.contentLength > 0);
121 do_check_eq(stream.available(), chan.contentLength);
122 stream.close();
123 stream.close(); // should still not throw
125 run_next_test();
126 });
128 /**
129 * Basic reading test for asynchronously opened, nested jar channels
130 */
131 add_test(function testAsyncNested(next) {
132 var uri = "jar:" + jarBase + "/inner40.zip!/foo";
133 var chan = ios.newChannel(uri, null, null);
134 chan.asyncOpen(new Listener(function(l) {
135 do_check_true(chan.contentLength > 0);
136 do_check_true(l.gotStartRequest);
137 do_check_true(l.gotStopRequest);
138 do_check_eq(l.available, chan.contentLength);
140 run_next_test();
141 }), null);
142 });
144 /**
145 * Verify that file locks are released when closing a synchronously
146 * opened jar channel stream
147 */
148 add_test(function testSyncCloseUnlocks() {
149 var copy = tmpDir.clone();
150 copy.append(fileBase);
151 file.copyTo(copy.parent, copy.leafName);
153 var uri = "jar:" + ios.newFileURI(copy).spec + "!/inner40.zip";
154 var chan = ios.newChannel(uri, null, null);
155 var stream = chan.open();
156 do_check_true(chan.contentLength > 0);
157 stream.close();
159 // Drop any jar caches
160 obs.notifyObservers(null, "chrome-flush-caches", null);
162 try {
163 copy.remove(false);
164 }
165 catch (ex) {
166 do_throw(ex);
167 }
169 run_next_test();
170 });
172 /**
173 * Verify that file locks are released when closing an asynchronously
174 * opened jar channel stream
175 */
176 add_test(function testAsyncCloseUnlocks() {
177 var copy = tmpDir.clone();
178 copy.append(fileBase);
179 file.copyTo(copy.parent, copy.leafName);
181 var uri = "jar:" + ios.newFileURI(copy).spec + "!/inner40.zip";
182 var chan = ios.newChannel(uri, null, null);
183 chan.asyncOpen(new Listener(function (l) {
184 do_check_true(chan.contentLength > 0);
186 // Drop any jar caches
187 obs.notifyObservers(null, "chrome-flush-caches", null);
189 try {
190 copy.remove(false);
191 }
192 catch (ex) {
193 do_throw(ex);
194 }
196 run_next_test();
197 }), null);
198 });
200 } // if !inChild
202 function run_test() run_next_test();
