Fix up the tcp raw benchmarks after an internal API change.
PR-URL: https://github.com/iojs/io.js/pull/495
Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl>
});
var TCP = process.binding('tcp_wrap').TCP;
+var TCPConnectWrap = process.binding('tcp_wrap').TCPConnectWrap;
+var WriteWrap = process.binding('stream_wrap').WriteWrap;
var PORT = common.PORT;
var dur;
}
var clientHandle = new TCP();
- var connectReq = {};
+ var connectReq = new TCPConnectWrap();
var err = clientHandle.connect(connectReq, '127.0.0.1', PORT);
if (err)
};
function write() {
- var writeReq = { oncomplete: afterWrite };
+ var writeReq = new WriteWrap();
+ writeReq.oncomplete = afterWrite;
var err;
switch (type) {
case 'buf':
});
var TCP = process.binding('tcp_wrap').TCP;
+var TCPConnectWrap = process.binding('tcp_wrap').TCPConnectWrap;
+var WriteWrap = process.binding('stream_wrap').WriteWrap;
var PORT = common.PORT;
var dur;
if (nread < 0)
fail(nread, 'read');
- var writeReq = { async: false };
+ var writeReq = new WriteWrap();
+ writeReq.async = false;
err = clientHandle.writeBuffer(writeReq, buffer);
if (err)
fail(err, 'write');
- writeReq.oncomplete = function(status, handle, req) {
- if (status)
+ writeReq.oncomplete = function(status, handle, req, err) {
+ if (err)
fail(err, 'write');
};
};
}
var clientHandle = new TCP();
- var connectReq = {};
+ var connectReq = new TCPConnectWrap();
var err = clientHandle.connect(connectReq, '127.0.0.1', PORT);
var bytes = 0;
};
function write() {
- var writeReq = { oncomplete: afterWrite };
+ var writeReq = new WriteWrap();
+ writeReq.oncomplete = afterWrite;
var err;
switch (type) {
case 'buf':
});
var TCP = process.binding('tcp_wrap').TCP;
+var TCPConnectWrap = process.binding('tcp_wrap').TCPConnectWrap;
+var WriteWrap = process.binding('stream_wrap').WriteWrap;
var PORT = common.PORT;
var dur;
write();
function write() {
- var writeReq = { async: false, oncomplete: afterWrite };
+ var writeReq = new WriteWrap();
+ writeReq.async = false;
+ writeReq.oncomplete = afterWrite;
var err;
switch (type) {
case 'buf':
}
}
- function afterWrite(err, handle, req) {
+ function afterWrite(status, handle, req, err) {
if (err)
fail(err, 'write');
function client() {
var clientHandle = new TCP();
- var connectReq = {};
+ var connectReq = new TCPConnectWrap();
var err = clientHandle.connect(connectReq, '127.0.0.1', PORT);
if (err)