encoding = null;
}
- if (data.length === 0) {
- if (typeof callback === 'function')
- process.nextTick(callback);
- return true;
- }
-
var connection = this.connection;
if (connection &&
connection._httpMessage === this &&
this.output = [];
this.outputEncodings = [];
this.outputCallbacks = [];
+ } else if (data.length === 0) {
+ if (typeof callback === 'function')
+ process.nextTick(callback);
+ return true;
}
// Directly write to socket.
// Write string
offset = ROUND_UP(offset, WriteWrap::kAlignSize);
- CHECK_LT(offset, storage_size);
+ CHECK_LE(offset, storage_size);
char* str_storage = req_wrap->Extra(offset);
size_t str_size = storage_size - offset;
--- /dev/null
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const http = require('http');
+const net = require('net');
+
+const COUNT = 10;
+
+var received = 0;
+
+var server = http.createServer(function(req, res) {
+ // Close the server, we have only one TCP connection anyway
+ if (received++ === 0)
+ server.close();
+
+ res.writeHead(200);
+ res.write('data');
+
+ setTimeout(function() {
+ res.end();
+ }, (Math.random() * 100) | 0);
+}).listen(common.PORT, function() {
+ const s = net.connect(common.PORT);
+
+ var big = '';
+ for (var i = 0; i < COUNT; i++)
+ big += 'GET / HTTP/1.0\r\n\r\n';
+ s.write(big);
+ s.resume();
+});
+
+process.on('exit', function() {
+ assert.equal(received, COUNT);
+});