Browse Source

Depreciate onLoad

v0.7.4-release
Ryan 16 years ago
parent
commit
31265be4a6
  1. 8
      src/node.js
  2. 14
      test/mjsunit/test-encode-utf8.js
  3. 32
      test/mjsunit/test-event-emitter-add-listeners.js
  4. 26
      test/mjsunit/test-file-cat-noexist.js
  5. 22
      test/mjsunit/test-http-cat.js
  6. 36
      test/mjsunit/test-http-client-upload.js
  7. 28
      test/mjsunit/test-http-proxy.js
  8. 101
      test/mjsunit/test-http-server.js
  9. 80
      test/mjsunit/test-http.js
  10. 24
      test/mjsunit/test-module-loading.js
  11. 42
      test/mjsunit/test-node-cat.js
  12. 12
      test/mjsunit/test-process-buffering.js
  13. 12
      test/mjsunit/test-process-kill.js
  14. 8
      test/mjsunit/test-process-simple.js
  15. 4
      test/mjsunit/test-process-spawn-loop.js
  16. 38
      test/mjsunit/test-promise-wait.js
  17. 8
      test/mjsunit/test-remote-module-loading.js
  18. 12
      test/mjsunit/test-tcp-many-clients.js
  19. 4
      test/mjsunit/test-tcp-pingpong-delay.js
  20. 10
      test/mjsunit/test-tcp-pingpong.js
  21. 38
      test/mjsunit/test-tcp-raw.js
  22. 69
      test/mjsunit/test-tcp-reconnect.js
  23. 50
      test/mjsunit/test-tcp-throttle-kernel-buffer.js
  24. 56
      test/mjsunit/test-tcp-throttle.js
  25. 60
      test/mjsunit/test-timers.js
  26. 4
      test/mjsunit/test-utf8-scripts.js

8
src/node.js

@ -126,7 +126,13 @@ node.Module.prototype.load = function (callback) {
self.onExit = self.target.__onExit; self.onExit = self.target.__onExit;
self.waitChildrenLoad(function () { self.waitChildrenLoad(function () {
if (self.onLoad) self.onLoad(); if (self.onLoad) {
node.stdio.writeError( "(node) onLoad is depreciated it will be "
+ "removed in the future. Don't want it to "
+ "leave? Discuss on mailing list.\n"
);
self.onLoad();
}
self.loaded = true; self.loaded = true;
loadPromise.emitSuccess([self.target]); loadPromise.emitSuccess([self.target]);
}); });

14
test/mjsunit/test-encode-utf8.js

@ -1,11 +1,9 @@
include("mjsunit.js"); include("mjsunit.js");
function onLoad () { var a = [116,101,115,116,32,206,163,207,131,207,128,206,177,32,226,161,140,226,160, 129,226,160,167,226,160,145];
var a = [116,101,115,116,32,206,163,207,131,207,128,206,177,32,226,161,140,226,160, 129,226,160,167,226,160,145]; var s = node.encodeUtf8(a);
var s = node.encodeUtf8(a); assertEquals("test Σσπα ⡌⠁⠧⠑", s);
assertEquals("test Σσπα ⡌⠁⠧⠑", s);
a = [104, 101, 108, 108, 111]; a = [104, 101, 108, 108, 111];
s = node.encodeUtf8(a); s = node.encodeUtf8(a);
assertEquals("hello", s); assertEquals("hello", s);
}

32
test/mjsunit/test-event-emitter-add-listeners.js

@ -5,23 +5,21 @@ var e = new node.EventEmitter();
var events_new_listener_emited = []; var events_new_listener_emited = [];
var times_hello_emited = 0; var times_hello_emited = 0;
function onLoad () { e.addListener("newListener", function (event, listener) {
e.addListener("newListener", function (event, listener) { puts("newListener: " + event);
puts("newListener: " + event); events_new_listener_emited.push(event);
events_new_listener_emited.push(event); });
});
e.addListener("hello", function (a, b) {
e.addListener("hello", function (a, b) { puts("hello");
puts("hello"); times_hello_emited += 1
times_hello_emited += 1 assertEquals("a", a);
assertEquals("a", a); assertEquals("b", b);
assertEquals("b", b); });
});
puts("start");
puts("start");
e.emit("hello", ["a", "b"]);
e.emit("hello", ["a", "b"]);
}
function onExit () { function onExit () {
assertArrayEquals(["hello"], events_new_listener_emited); assertArrayEquals(["hello"], events_new_listener_emited);

26
test/mjsunit/test-file-cat-noexist.js

@ -1,22 +1,20 @@
include("mjsunit.js"); include("mjsunit.js");
var got_error = false; var got_error = false;
function onLoad () { var dirname = node.path.dirname(__filename);
var dirname = node.path.dirname(__filename); var fixtures = node.path.join(dirname, "fixtures");
var fixtures = node.path.join(dirname, "fixtures"); var filename = node.path.join(fixtures, "does_not_exist.txt");
var filename = node.path.join(fixtures, "does_not_exist.txt"); var promise = node.fs.cat(filename, "raw");
var promise = node.fs.cat(filename, "raw");
promise.addCallback(function (content) { promise.addCallback(function (content) {
node.debug("cat returned some content: " + content); node.debug("cat returned some content: " + content);
node.debug("this shouldn't happen as the file doesn't exist..."); node.debug("this shouldn't happen as the file doesn't exist...");
assertTrue(false); assertTrue(false);
}); });
promise.addErrback(function () { promise.addErrback(function () {
got_error = true; got_error = true;
}); });
}
function onExit () { function onExit () {
assertTrue(got_error); assertTrue(got_error);

22
test/mjsunit/test-http-cat.js

@ -16,19 +16,17 @@ server.listen(PORT);
var got_good_server_content = false; var got_good_server_content = false;
var bad_server_got_error = false; var bad_server_got_error = false;
function onLoad () { node.http.cat("http://localhost:"+PORT+"/", "utf8").addCallback(function (content) {
node.http.cat("http://localhost:"+PORT+"/", "utf8").addCallback(function (content) { puts("got response");
puts("got response"); got_good_server_content = true;
got_good_server_content = true; assertEquals(body, content);
assertEquals(body, content); server.close();
server.close(); });
});
node.http.cat("http://localhost:12312/", "utf8").addErrback(function () { node.http.cat("http://localhost:12312/", "utf8").addErrback(function () {
puts("got error (this should happen)"); puts("got error (this should happen)");
bad_server_got_error = true; bad_server_got_error = true;
}); });
}
function onExit () { function onExit () {
assertTrue(got_good_server_content); assertTrue(got_good_server_content);

36
test/mjsunit/test-http-client-upload.js

@ -24,26 +24,24 @@ var server = node.http.createServer(function(req, res) {
}); });
server.listen(PORT); server.listen(PORT);
function onLoad () { var client = node.http.createClient(PORT);
var client = node.http.createClient(PORT); var req = client.post('/');
var req = client.post('/');
req.sendBody('1\n');
req.sendBody('1\n'); req.sendBody('2\n');
req.sendBody('2\n'); req.sendBody('3\n');
req.sendBody('3\n');
puts("client finished sending request");
puts("client finished sending request"); req.finish(function(res) {
req.finish(function(res) { res.setBodyEncoding("utf8");
res.setBodyEncoding("utf8"); res.addListener('body', function(chunk) {
res.addListener('body', function(chunk) { puts(chunk);
puts(chunk);
});
res.addListener('complete', function() {
client_res_complete = true;
server.close();
});
}); });
} res.addListener('complete', function() {
client_res_complete = true;
server.close();
});
});
function onExit () { function onExit () {
assertEquals("1\n2\n3\n", sent_body); assertEquals("1\n2\n3\n", sent_body);

28
test/mjsunit/test-http-proxy.js

@ -32,22 +32,20 @@ proxy.listen(PROXY_PORT);
var body = ""; var body = "";
function onLoad () { var client = node.http.createClient(PROXY_PORT);
var client = node.http.createClient(PROXY_PORT); var req = client.get("/test");
var req = client.get("/test"); // node.debug("client req")
// node.debug("client req") req.finish(function (res) {
req.finish(function (res) { // node.debug("got res");
// node.debug("got res"); assertEquals(200, res.statusCode);
assertEquals(200, res.statusCode); res.setBodyEncoding("utf8");
res.setBodyEncoding("utf8"); res.addListener("body", function (chunk) { body += chunk; });
res.addListener("body", function (chunk) { body += chunk; }); res.addListener("complete", function () {
res.addListener("complete", function () { proxy.close();
proxy.close(); backend.close();
backend.close(); // node.debug("closed both");
// node.debug("closed both");
});
}); });
} });
function onExit () { function onExit () {
assertEquals(body, "hello world\n"); assertEquals(body, "hello world\n");

101
test/mjsunit/test-http-server.js

@ -7,60 +7,57 @@ var requests_sent = 0;
var server_response = ""; var server_response = "";
var client_got_eof = false; var client_got_eof = false;
function onLoad() { node.http.createServer(function (req, res) {
res.id = request_number;
node.http.createServer(function (req, res) { req.id = request_number++;
res.id = request_number;
req.id = request_number++; if (req.id == 0) {
assertEquals("GET", req.method);
if (req.id == 0) { assertEquals("/hello", req.uri.path);
assertEquals("GET", req.method); }
assertEquals("/hello", req.uri.path);
} if (req.id == 1) {
assertEquals("POST", req.method);
if (req.id == 1) { assertEquals("/quit", req.uri.path);
assertEquals("POST", req.method); this.close();
assertEquals("/quit", req.uri.path); //puts("server closed");
this.close(); }
//puts("server closed");
} setTimeout(function () {
res.sendHeader(200, {"Content-Type": "text/plain"});
setTimeout(function () { res.sendBody(req.uri.path);
res.sendHeader(200, {"Content-Type": "text/plain"}); res.finish();
res.sendBody(req.uri.path); }, 1);
res.finish();
}, 1); }).listen(port);
}).listen(port); var c = node.tcp.createConnection(port);
var c = node.tcp.createConnection(port); c.setEncoding("utf8");
c.addListener("connect", function () {
c.send( "GET /hello HTTP/1.1\r\n\r\n" );
requests_sent += 1;
});
c.addListener("receive", function (chunk) {
server_response += chunk;
if (requests_sent == 1) {
c.send("POST /quit HTTP/1.1\r\n\r\n");
c.close();
assertEquals(c.readyState, "readOnly");
requests_sent += 1;
}
});
c.setEncoding("utf8"); c.addListener("eof", function () {
client_got_eof = true;
});
c.addListener("connect", function () { c.addListener("close", function () {
c.send( "GET /hello HTTP/1.1\r\n\r\n" ); assertEquals(c.readyState, "closed");
requests_sent += 1; });
});
c.addListener("receive", function (chunk) {
server_response += chunk;
if (requests_sent == 1) {
c.send("POST /quit HTTP/1.1\r\n\r\n");
c.close();
assertEquals(c.readyState, "readOnly");
requests_sent += 1;
}
});
c.addListener("eof", function () {
client_got_eof = true;
});
c.addListener("close", function () {
assertEquals(c.readyState, "closed");
});
}
function onExit () { function onExit () {
assertEquals(2, request_number); assertEquals(2, request_number);

80
test/mjsunit/test-http.js

@ -6,57 +6,55 @@ var responses_recvd = 0;
var body0 = ""; var body0 = "";
var body1 = ""; var body1 = "";
function onLoad () { node.http.createServer(function (req, res) {
node.http.createServer(function (req, res) { if (responses_sent == 0) {
if (responses_sent == 0) { assertEquals("GET", req.method);
assertEquals("GET", req.method); assertEquals("/hello", req.uri.path);
assertEquals("/hello", req.uri.path);
p(req.headers); p(req.headers);
assertTrue("Accept" in req.headers); assertTrue("Accept" in req.headers);
assertEquals("*/*", req.headers["Accept"]); assertEquals("*/*", req.headers["Accept"]);
assertTrue("Foo" in req.headers); assertTrue("Foo" in req.headers);
assertEquals("bar", req.headers["Foo"]); assertEquals("bar", req.headers["Foo"]);
} }
if (responses_sent == 1) { if (responses_sent == 1) {
assertEquals("POST", req.method); assertEquals("POST", req.method);
assertEquals("/world", req.uri.path); assertEquals("/world", req.uri.path);
this.close(); this.close();
} }
req.addListener("complete", function () { req.addListener("complete", function () {
res.sendHeader(200, {"Content-Type": "text/plain"}); res.sendHeader(200, {"Content-Type": "text/plain"});
res.sendBody("The path was " + req.uri.path); res.sendBody("The path was " + req.uri.path);
res.finish(); res.finish();
responses_sent += 1; responses_sent += 1;
}); });
//assertEquals("127.0.0.1", res.connection.remoteAddress);
}).listen(PORT);
//assertEquals("127.0.0.1", res.connection.remoteAddress); var client = node.http.createClient(PORT);
}).listen(PORT); var req = client.get("/hello", {"Accept": "*/*", "Foo": "bar"});
req.finish(function (res) {
assertEquals(200, res.statusCode);
responses_recvd += 1;
res.setBodyEncoding("ascii");
res.addListener("body", function (chunk) { body0 += chunk; });
node.debug("Got /hello response");
});
var client = node.http.createClient(PORT); setTimeout(function () {
var req = client.get("/hello", {"Accept": "*/*", "Foo": "bar"}); req = client.post("/world");
req.finish(function (res) { req.finish(function (res) {
assertEquals(200, res.statusCode); assertEquals(200, res.statusCode);
responses_recvd += 1; responses_recvd += 1;
res.setBodyEncoding("ascii"); res.setBodyEncoding("utf8");
res.addListener("body", function (chunk) { body0 += chunk; }); res.addListener("body", function (chunk) { body1 += chunk; });
node.debug("Got /hello response"); node.debug("Got /world response");
}); });
}, 1);
setTimeout(function () {
req = client.post("/world");
req.finish(function (res) {
assertEquals(200, res.statusCode);
responses_recvd += 1;
res.setBodyEncoding("utf8");
res.addListener("body", function (chunk) { body1 += chunk; });
node.debug("Got /world response");
});
}, 1);
}
function onExit () { function onExit () {
node.debug("responses_recvd: " + responses_recvd); node.debug("responses_recvd: " + responses_recvd);

24
test/mjsunit/test-module-loading.js

@ -3,24 +3,22 @@ var a = require("fixtures/a.js");
var d = require("fixtures/b/d.js"); var d = require("fixtures/b/d.js");
var d2 = require("fixtures/b/d.js"); var d2 = require("fixtures/b/d.js");
function onLoad () { assertFalse(false, "testing the test program.");
assertFalse(false, "testing the test program.");
assertInstanceof(a.A, Function); assertInstanceof(a.A, Function);
assertEquals("A", a.A()); assertEquals("A", a.A());
assertInstanceof(a.C, Function); assertInstanceof(a.C, Function);
assertEquals("C", a.C()); assertEquals("C", a.C());
assertInstanceof(a.D, Function); assertInstanceof(a.D, Function);
assertEquals("D", a.D()); assertEquals("D", a.D());
assertInstanceof(d.D, Function); assertInstanceof(d.D, Function);
assertEquals("D", d.D()); assertEquals("D", d.D());
assertInstanceof(d2.D, Function); assertInstanceof(d2.D, Function);
assertEquals("D", d2.D()); assertEquals("D", d2.D());
}
function onExit () { function onExit () {
assertInstanceof(a.A, Function); assertInstanceof(a.A, Function);

42
test/mjsunit/test-node-cat.js

@ -18,34 +18,32 @@ server.listen(PORT);
var errors = 0; var errors = 0;
var successes = 0; var successes = 0;
function onLoad () { var promise = node.cat("http://localhost:"+PORT, "utf8");
var promise = node.cat("http://localhost:"+PORT, "utf8");
promise.addCallback(function (content) { promise.addCallback(function (content) {
assertEquals(body, content); assertEquals(body, content);
server.close(); server.close();
successes += 1; successes += 1;
}); });
promise.addErrback(function () { promise.addErrback(function () {
errors += 1; errors += 1;
}); });
var dirname = node.path.dirname(__filename); var dirname = node.path.dirname(__filename);
var fixtures = node.path.join(dirname, "fixtures"); var fixtures = node.path.join(dirname, "fixtures");
var x = node.path.join(fixtures, "x.txt"); var x = node.path.join(fixtures, "x.txt");
promise = node.cat(x, "utf8"); promise = node.cat(x, "utf8");
promise.addCallback(function (content) { promise.addCallback(function (content) {
assertEquals("xyz", content.replace(/[\r\n]/, '')); assertEquals("xyz", content.replace(/[\r\n]/, ''));
successes += 1; successes += 1;
}); });
promise.addErrback(function () { promise.addErrback(function () {
errors += 1; errors += 1;
}); });
}
function onExit () { function onExit () {
assertEquals(2, successes); assertEquals(2, successes);

12
test/mjsunit/test-process-buffering.js

@ -18,13 +18,11 @@ function pwd (callback) {
} }
function onLoad () { pwd(function (result) {
pwd(function (result) { p(result);
p(result); assertTrue(result.length > 1);
assertTrue(result.length > 1); assertEquals("\n", result[result.length-1]);
assertEquals("\n", result[result.length-1]); });
});
}
function onExit () { function onExit () {
assertTrue(pwd_called); assertTrue(pwd_called);

12
test/mjsunit/test-process-kill.js

@ -2,15 +2,13 @@ include("mjsunit.js");
var exit_status = -1; var exit_status = -1;
function onLoad () { var cat = node.createProcess("cat");
var cat = node.createProcess("cat");
cat.addListener("output", function (chunk) { assertEquals(null, chunk); }); cat.addListener("output", function (chunk) { assertEquals(null, chunk); });
cat.addListener("error", function (chunk) { assertEquals(null, chunk); }); cat.addListener("error", function (chunk) { assertEquals(null, chunk); });
cat.addListener("exit", function (status) { exit_status = status; }); cat.addListener("exit", function (status) { exit_status = status; });
cat.kill(); cat.kill();
}
function onExit () { function onExit () {
assertTrue(exit_status > 0); assertTrue(exit_status > 0);

8
test/mjsunit/test-process-simple.js

@ -24,11 +24,9 @@ cat.addListener("exit", function (status) {
exit_status = status; exit_status = status;
}); });
function onLoad () { cat.write("hello");
cat.write("hello"); cat.write(" ");
cat.write(" "); cat.write("world");
cat.write("world");
}
function onExit () { function onExit () {
assertEquals(0, exit_status); assertEquals(0, exit_status);

4
test/mjsunit/test-process-spawn-loop.js

@ -20,9 +20,7 @@ function spawn (i) {
}); });
} }
function onLoad () { spawn(0);
spawn(0);
}
function onExit () { function onExit () {
assertTrue(finished); assertTrue(finished);

38
test/mjsunit/test-promise-wait.js

@ -44,36 +44,34 @@ p5.addCallback(function () {
}, 100); }, 100);
}); });
function onLoad () {
p2.emitSuccess(); p2.emitSuccess();
assertFalse(p1_done); assertFalse(p1_done);
assertTrue(p2_done); assertTrue(p2_done);
assertFalse(p3_done); assertFalse(p3_done);
var ret1 = p1.wait() var ret1 = p1.wait()
assertEquals("single arg", ret1); assertEquals("single arg", ret1);
assertTrue(p1_done); assertTrue(p1_done);
assertTrue(p2_done); assertTrue(p2_done);
assertFalse(p3_done); assertFalse(p3_done);
p3.emitSuccess(); p3.emitSuccess();
assertFalse(p4_done); assertFalse(p4_done);
assertFalse(p5_done); assertFalse(p5_done);
p5.emitSuccess(); p5.emitSuccess();
assertFalse(p4_done); assertFalse(p4_done);
assertTrue(p5_done); assertTrue(p5_done);
var ret4 = p4.wait(); var ret4 = p4.wait();
assertArrayEquals(["a","b","c"], ret4); assertArrayEquals(["a","b","c"], ret4);
assertTrue(p4_done); assertTrue(p4_done);
}
function onExit() { function onExit() {
assertTrue(p1_done); assertTrue(p1_done);

8
test/mjsunit/test-remote-module-loading.js

@ -12,8 +12,6 @@ s.listen(8000);
include("mjsunit.js"); include("mjsunit.js");
var a = require("http://localhost:8000/") var a = require("http://localhost:8000/")
function onLoad() { assertInstanceof(a.A, Function);
assertInstanceof(a.A, Function); assertEquals("A", a.A());
assertEquals("A", a.A()); s.close();
s.close();
}

12
test/mjsunit/test-tcp-many-clients.js

@ -55,13 +55,11 @@ function runClient (callback) {
} }
function onLoad () { var finished_clients = 0;
var finished_clients = 0; for (var i = 0; i < concurrency; i++) {
for (var i = 0; i < concurrency; i++) { runClient(function () {
runClient(function () { if (++finished_clients == concurrency) server.close();
if (++finished_clients == concurrency) server.close(); });
});
}
} }
function onExit () { function onExit () {

4
test/mjsunit/test-tcp-pingpong-delay.js

@ -83,9 +83,7 @@ function pingPongTest (port, host, on_complete) {
}); });
} }
function onLoad () { pingPongTest(21988);
pingPongTest(21988);
}
function onExit () { function onExit () {
assertEquals(1, tests_run); assertEquals(1, tests_run);

10
test/mjsunit/test-tcp-pingpong.js

@ -77,12 +77,10 @@ function pingPongTest (port, host, on_complete) {
}); });
} }
function onLoad () { /* All are run at once, so run on different ports */
/* All are run at once, so run on different ports */ pingPongTest(20989, "localhost");
pingPongTest(20989, "localhost"); pingPongTest(20988, null);
pingPongTest(20988, null); pingPongTest(20997, "::1");
pingPongTest(20997, "::1");
}
function onExit () { function onExit () {
assertEquals(3, tests_run); assertEquals(3, tests_run);

38
test/mjsunit/test-tcp-raw.js

@ -14,29 +14,27 @@ echoServer.listen(PORT);
var recv = []; var recv = [];
var j = 0; var j = 0;
function onLoad () { var c = node.tcp.createConnection(PORT);
var c = node.tcp.createConnection(PORT);
c.addListener("receive", function (chunk) { c.addListener("receive", function (chunk) {
if (++j < 256) { if (++j < 256) {
c.send([j], "raw");
} else {
c.close();
}
for (var i = 0; i < chunk.length; i++) {
recv.push(chunk[i]);
}
});
c.addListener("connect", function () {
c.send([j], "raw"); c.send([j], "raw");
}); } else {
c.close();
}
for (var i = 0; i < chunk.length; i++) {
recv.push(chunk[i]);
}
});
c.addListener("close", function () { c.addListener("connect", function () {
p(recv); c.send([j], "raw");
echoServer.close(); });
});
}; c.addListener("close", function () {
p(recv);
echoServer.close();
});
function onExit () { function onExit () {
var expected = []; var expected = [];

69
test/mjsunit/test-tcp-reconnect.js

@ -6,48 +6,45 @@ var c = 0;
var client_recv_count = 0; var client_recv_count = 0;
var disconnect_count = 0; var disconnect_count = 0;
function onLoad () { var server = node.tcp.createServer(function (socket) {
socket.addListener("connect", function () {
var server = node.tcp.createServer(function (socket) { socket.send("hello\r\n");
socket.addListener("connect", function () {
socket.send("hello\r\n");
});
socket.addListener("eof", function () {
socket.close();
});
socket.addListener("close", function (had_error) {
//puts("server had_error: " + JSON.stringify(had_error));
assertFalse(had_error);
});
});
server.listen(port);
var client = node.tcp.createConnection(port);
client.setEncoding("UTF8");
client.addListener("connect", function () {
puts("client connected.");
}); });
client.addListener("receive", function (chunk) { socket.addListener("eof", function () {
client_recv_count += 1; socket.close();
puts("client_recv_count " + client_recv_count);
assertEquals("hello\r\n", chunk);
client.close();
}); });
client.addListener("close", function (had_error) { socket.addListener("close", function (had_error) {
puts("disconnect"); //puts("server had_error: " + JSON.stringify(had_error));
assertFalse(had_error); assertFalse(had_error);
if (disconnect_count++ < N)
client.connect(port); // reconnect
else
server.close();
}); });
} });
server.listen(port);
var client = node.tcp.createConnection(port);
client.setEncoding("UTF8");
client.addListener("connect", function () {
puts("client connected.");
});
client.addListener("receive", function (chunk) {
client_recv_count += 1;
puts("client_recv_count " + client_recv_count);
assertEquals("hello\r\n", chunk);
client.close();
});
client.addListener("close", function (had_error) {
puts("disconnect");
assertFalse(had_error);
if (disconnect_count++ < N)
client.connect(port); // reconnect
else
server.close();
});
function onExit () { function onExit () {
assertEquals(N+1, disconnect_count); assertEquals(N+1, disconnect_count);

50
test/mjsunit/test-tcp-throttle-kernel-buffer.js

@ -23,33 +23,31 @@ chars_recved = 0;
npauses = 0; npauses = 0;
function onLoad () { var paused = false;
var paused = false; client = node.tcp.createConnection(PORT);
client = node.tcp.createConnection(PORT); client.setEncoding("ascii");
client.setEncoding("ascii"); client.addListener("receive", function (d) {
client.addListener("receive", function (d) { chars_recved += d.length;
chars_recved += d.length; puts("got " + chars_recved);
puts("got " + chars_recved); if (!paused) {
if (!paused) { client.readPause();
client.readPause(); npauses += 1;
npauses += 1; paused = true;
paused = true; puts("pause");
puts("pause"); x = chars_recved;
x = chars_recved; setTimeout(function () {
setTimeout(function () { assertEquals(chars_recved, x);
assertEquals(chars_recved, x); client.readResume();
client.readResume(); puts("resume");
puts("resume"); paused = false;
paused = false; }, 100);
}, 100); }
} });
});
client.addListener("eof", function () { client.addListener("eof", function () {
server.close(); server.close();
client.close(); client.close();
}); });
}
function onExit () { function onExit () {
assertEquals(N, chars_recved); assertEquals(N, chars_recved);

56
test/mjsunit/test-tcp-throttle.js

@ -21,35 +21,32 @@ server.listen(PORT);
recv = ""; recv = "";
chars_recved = 0; chars_recved = 0;
function onLoad () { client = node.tcp.createConnection(PORT);
client = node.tcp.createConnection(PORT); client.setEncoding("ascii");
client.setEncoding("ascii"); client.addListener("receive", function (d) {
client.addListener("receive", function (d) { print(d);
print(d); recv += d;
recv += d; });
});
setTimeout(function () {
chars_recved = recv.length;
puts("pause at: " + chars_recved);
assertTrue(chars_recved > 1);
client.readPause();
setTimeout(function () { setTimeout(function () {
chars_recved = recv.length; puts("resume at: " + chars_recved);
puts("pause at: " + chars_recved); assertEquals(chars_recved, recv.length);
assertTrue(chars_recved > 1); client.readResume();
client.readPause();
setTimeout(function () { setTimeout(function () {
puts("resume at: " + chars_recved); chars_recved = recv.length;
assertEquals(chars_recved, recv.length); puts("pause at: " + chars_recved);
client.readResume(); client.readPause();
setTimeout(function () { setTimeout(function () {
chars_recved = recv.length; puts("resume at: " + chars_recved);
puts("pause at: " + chars_recved); assertEquals(chars_recved, recv.length);
client.readPause(); client.readResume();
setTimeout(function () {
puts("resume at: " + chars_recved);
assertEquals(chars_recved, recv.length);
client.readResume();
}, 500);
}, 500); }, 500);
@ -57,11 +54,12 @@ function onLoad () {
}, 500); }, 500);
client.addListener("eof", function () { }, 500);
server.close();
client.close(); client.addListener("eof", function () {
}); server.close();
} client.close();
});
function onExit () { function onExit () {
assertEquals(N, recv.length); assertEquals(N, recv.length);

60
test/mjsunit/test-timers.js

@ -5,37 +5,35 @@ var WINDOW = 800; // why is does this need to be so big?
var interval_count = 0; var interval_count = 0;
var setTimeout_called = false; var setTimeout_called = false;
function onLoad () { assertInstanceof(setTimeout, Function);
assertInstanceof(setTimeout, Function); var starttime = new Date;
var starttime = new Date;
setTimeout(function () {
setTimeout(function () { var endtime = new Date;
var endtime = new Date; var diff = endtime - starttime;
var diff = endtime - starttime; if (diff < 0) diff = -diff;
if (diff < 0) diff = -diff; assertTrue(1000 - WINDOW < diff && diff < 1000 + WINDOW);
assertTrue(1000 - WINDOW < diff && diff < 1000 + WINDOW); setTimeout_called = true;
setTimeout_called = true; }, 1000);
}, 1000);
// this timer shouldn't execute
// this timer shouldn't execute var id = setTimeout(function () { assertTrue(false); }, 500);
var id = setTimeout(function () { assertTrue(false); }, 500); clearTimeout(id);
clearTimeout(id);
setInterval(function () {
setInterval(function () { interval_count += 1;
interval_count += 1; var endtime = new Date;
var endtime = new Date; var diff = endtime - starttime;
var diff = endtime - starttime; if (diff < 0) diff = -diff;
if (diff < 0) diff = -diff;
var t = interval_count * 1000;
var t = interval_count * 1000;
assertTrue(t - WINDOW < diff && diff < t + WINDOW);
assertTrue(t - WINDOW < diff && diff < t + WINDOW);
assertTrue(interval_count <= 3);
assertTrue(interval_count <= 3); if (interval_count == 3)
if (interval_count == 3) clearInterval(this);
clearInterval(this); }, 1000);
}, 1000);
}
function onExit () { function onExit () {
assertTrue(setTimeout_called); assertTrue(setTimeout_called);

4
test/mjsunit/test-utf8-scripts.js

@ -4,7 +4,5 @@ include("mjsunit.js");
puts("Σὲ γνωρίζω ἀπὸ τὴν κόψη"); puts("Σὲ γνωρίζω ἀπὸ τὴν κόψη");
function onLoad () { assertTrue( /Hellö Wörld/.test("Hellö Wörld") );
  assertTrue( /Hellö Wörld/.test("Hellö Wörld") );
}

Loading…
Cancel
Save