|
|
@ -23,21 +23,28 @@ var common = require('../common'); |
|
|
|
var assert = require('assert'); |
|
|
|
var net = require('net'); |
|
|
|
|
|
|
|
var SIZE = 1E5; |
|
|
|
var SIZE = 2E5; |
|
|
|
var N = 10; |
|
|
|
var flushed = 0; |
|
|
|
var received = 0; |
|
|
|
var buf = new Buffer(SIZE); |
|
|
|
buf.fill(0x61); // 'a'
|
|
|
|
|
|
|
|
var server = net.createServer(function(socket) { |
|
|
|
socket.setNoDelay(); |
|
|
|
socket.setTimeout(500); |
|
|
|
socket.setTimeout(200); |
|
|
|
socket.on('timeout', function() { |
|
|
|
assert.fail(); |
|
|
|
assert.fail('flushed: ' + flushed + |
|
|
|
', received: ' + received + '/' + SIZE * N); |
|
|
|
}); |
|
|
|
|
|
|
|
for (var i = 0; i < N; ++i) { |
|
|
|
socket.write(buf); |
|
|
|
socket.write(buf, function() { |
|
|
|
++flushed; |
|
|
|
if (flushed === N) { |
|
|
|
socket.setTimeout(0); |
|
|
|
} |
|
|
|
}); |
|
|
|
} |
|
|
|
socket.end(); |
|
|
|
|
|
|
@ -48,7 +55,7 @@ var server = net.createServer(function(socket) { |
|
|
|
conn.pause(); |
|
|
|
setTimeout(function() { |
|
|
|
conn.resume(); |
|
|
|
}, 50); |
|
|
|
}, 20); |
|
|
|
}); |
|
|
|
conn.on('end', function() { |
|
|
|
server.close(); |
|
|
|