AstralTransRocketries/node-minecraft-protocol
1
0
Fork 0
mirror of https://github.com/unmojang/node-minecraft-protocol.git synced 2025-09-28 05:35:56 -04:00
Code Issues Packages Projects Releases Wiki Activity

Rewrite of the internal serializer using transform streams

Browse Source
This commit is contained in:
roblabla 2015-05-22 17:26:48 +00:00
parent 17dea74357
commit ced091b2b2
1 changed files with 7 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
test/benchmark.js
View File

@ -1,21 +1,8 @@
var ITERATIONS = 100000;
var Client = require('../dist/client'),
EventEmitter = require('events').EventEmitter,
var protocol = require('../dist/protocol'),
util = require('util'),
states = require('../dist/protocol').states;
var FakeSocket = function() {
EventEmitter.call(this);
};
util.inherits(FakeSocket, EventEmitter);
FakeSocket.prototype.write = function() {
};
var client = new Client();
var socket = new FakeSocket();
client.setSocket(socket);
client.state = states.PLAY;
states = protocol.states;
var testDataWrite = [
{id: 0x00, params: {keepAliveId: 957759560}},
@ -24,37 +11,21 @@ var testDataWrite = [
// TODO: add more packets for better quality data
];
var inputData = [];
var start, i, j;
console.log('Beginning write test');
start = Date.now();
for(i = 0; i < ITERATIONS; i++) {
for(j = 0; j < testDataWrite.length; j++) {
client.write(testDataWrite[j].id, testDataWrite[j].params);
inputData.push(protocol.createPacketBuffer(testDataWrite[j].id, states.PLAY, testDataWrite[j].params, false));
}
}
console.log('Finished write test in ' + (Date.now() - start) / 1000 + ' seconds');
var testDataRead = [
{id: 0x00, params: {keepAliveId: 957759560}},
{id: 0x02, params: {message: '<Bob> Hello World!', position: 0}},
{id: 0x08, params: {x: 6.5, y: 65.62, z: 7.5, yaw: 0, pitch: 0, flags: 0}},
];
client.isServer = true;
var inputData = new Buffer(0);
socket.write = function(data) {
inputData = Buffer.concat([inputData, data]);
};
for(i = 0; i < testDataRead.length; i++) {
client.write(testDataRead[i].id, testDataRead[i].params);
}
client.isServer = false;
console.log('Beginning read test');
start = Date.now();
for(i = 0; i < ITERATIONS; i++) {
socket.emit('data', inputData);
for (j = 0; j < inputData.length; j++) {
protocol.parsePacketData(inputData[j], states.PLAY, true);
}
console.log('Finished read test in ' + (Date.now() - start) / 1000 + ' seconds');