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
|
Cu.import("resource://testing-common/httpd.js");
Cu.import("resource://gre/modules/NetUtil.jsm");
XPCOMUtils.defineLazyGetter(this, "URL", function() {
return "http://localhost:" + httpserver.identity.primaryPort;
});
var httpserver = new HttpServer();
var testpath = "/simple";
var httpbody = "0123456789";
var last = 0, max = 0;
const STATUS_RECEIVING_FROM = 0x804b0006;
const LOOPS = 50000;
const TYPE_ONSTATUS = 1;
const TYPE_ONPROGRESS = 2;
const TYPE_ONSTARTREQUEST = 3;
const TYPE_ONDATAAVAILABLE = 4;
const TYPE_ONSTOPREQUEST = 5;
var progressCallback = {
_listener: null,
_got_onstartrequest: false,
_got_onstatus_after_onstartrequest: false,
_last_callback_handled: null,
QueryInterface: function (iid) {
if (iid.equals(Ci.nsISupports) ||
iid.equals(Ci.nsIProgressEventSink) ||
iid.equals(Ci.nsIStreamListener) ||
iid.equals(Ci.nsIRequestObserver))
return this;
throw Cr.NS_ERROR_NO_INTERFACE;
},
getInterface: function (iid) {
if (iid.equals(Ci.nsIProgressEventSink) ||
iid.equals(Ci.nsIStreamListener) ||
iid.equals(Ci.nsIRequestObserver))
return this;
throw Cr.NS_ERROR_NO_INTERFACE;
},
onStartRequest: function(request, context) {
do_check_eq(this._last_callback_handled, TYPE_ONSTATUS);
this._got_onstartrequest = true;
this._last_callback_handled = TYPE_ONSTARTREQUEST;
this._listener = new ChannelListener(checkRequest, request);
this._listener.onStartRequest(request, context);
},
onDataAvailable: function(request, context, data, offset, count) {
do_check_eq(this._last_callback_handled, TYPE_ONPROGRESS);
this._last_callback_handled = TYPE_ONDATAAVAILABLE;
this._listener.onDataAvailable(request, context, data, offset, count);
},
onStopRequest: function(request, context, status) {
do_check_eq(this._last_callback_handled, TYPE_ONDATAAVAILABLE);
do_check_true(this._got_onstatus_after_onstartrequest);
this._last_callback_handled = TYPE_ONSTOPREQUEST;
this._listener.onStopRequest(request, context, status);
delete this._listener;
},
onProgress: function (request, context, progress, progressMax) {
do_check_eq(this._last_callback_handled, TYPE_ONSTATUS);
this._last_callback_handled = TYPE_ONPROGRESS;
do_check_eq(mStatus, STATUS_RECEIVING_FROM);
last = progress;
max = progressMax;
},
onStatus: function (request, context, status, statusArg) {
if (!this._got_onstartrequest) {
// Ensure that all messages before onStartRequest are onStatus
if (this._last_callback_handled)
do_check_eq(this._last_callback_handled, TYPE_ONSTATUS);
} else if (this._last_callback_handled == TYPE_ONSTARTREQUEST) {
this._got_onstatus_after_onstartrequest = true;
} else {
do_check_eq(this._last_callback_handled, TYPE_ONDATAAVAILABLE);
}
this._last_callback_handled = TYPE_ONSTATUS;
do_check_eq(statusArg, "localhost");
mStatus = status;
},
mStatus: 0,
};
function run_test() {
httpserver.registerPathHandler(testpath, serverHandler);
httpserver.start(-1);
var channel = setupChannel(testpath);
channel.asyncOpen2(progressCallback);
do_test_pending();
}
function setupChannel(path) {
var chan = NetUtil.newChannel({
uri: URL + path,
loadUsingSystemPrincipal: true
});
chan.QueryInterface(Ci.nsIHttpChannel);
chan.requestMethod = "GET";
chan.notificationCallbacks = progressCallback;
return chan;
}
function serverHandler(metadata, response) {
response.setHeader("Content-Type", "text/plain", false);
for (let i = 0; i < LOOPS; i++)
response.bodyOutputStream.write(httpbody, httpbody.length);
}
function checkRequest(request, data, context) {
do_check_eq(last, httpbody.length*LOOPS);
do_check_eq(max, httpbody.length*LOOPS);
httpserver.stop(do_test_finished);
}
|
