1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
/*!
* ws: a node.js websocket client
* Copyright(c) 2011 Einar Otto Stangvik <einaros@gmail.com>
* MIT Licensed
*/
/**
* Benchmark dependencies.
*/
var benchmark = require('benchmark')
, Receiver = require('../').Receiver
, suite = new benchmark.Suite('Receiver');
require('tinycolor');
require('./util');
/**
* Setup receiver.
*/
suite.on('start', function () {
receiver = new Receiver();
});
suite.on('cycle', function () {
receiver = new Receiver();
});
/**
* Benchmarks.
*/
var pingMessage = 'Hello'
, pingPacket1 = getBufferFromHexString('89 ' + (pack(2, 0x80 | pingMessage.length)) +
' 34 83 a8 68 '+ getHexStringFromBuffer(mask(pingMessage, '34 83 a8 68')));
suite.add('ping message', function () {
receiver.add(pingPacket1);
});
var pingPacket2 = getBufferFromHexString('89 00')
suite.add('ping with no data', function () {
receiver.add(pingPacket2);
});
var closePacket = getBufferFromHexString('88 00');
suite.add('close message', function () {
receiver.add(closePacket);
receiver.endPacket();
});
var maskedTextPacket = getBufferFromHexString('81 93 34 83 a8 68 01 b9 92 52 4f a1 c6 09 59 e6 8a 52 16 e6 cb 00 5b a1 d5');
suite.add('masked text message', function () {
receiver.add(maskedTextPacket);
});
binaryDataPacket = (function() {
var length = 125
, message = new Buffer(length)
for (var i = 0; i < length; ++i) message[i] = i % 10;
return getBufferFromHexString('82 ' + getHybiLengthAsHexString(length, true) + ' 34 83 a8 68 '
+ getHexStringFromBuffer(mask(message), '34 83 a8 68'));
})();
suite.add('binary data (125 bytes)', function () {
try {
receiver.add(binaryDataPacket);
}
catch(e) {console.log(e)}
});
binaryDataPacket2 = (function() {
var length = 65535
, message = new Buffer(length)
for (var i = 0; i < length; ++i) message[i] = i % 10;
return getBufferFromHexString('82 ' + getHybiLengthAsHexString(length, true) + ' 34 83 a8 68 '
+ getHexStringFromBuffer(mask(message), '34 83 a8 68'));
})();
suite.add('binary data (65535 bytes)', function () {
receiver.add(binaryDataPacket2);
});
binaryDataPacket3 = (function() {
var length = 200*1024
, message = new Buffer(length)
for (var i = 0; i < length; ++i) message[i] = i % 10;
return getBufferFromHexString('82 ' + getHybiLengthAsHexString(length, true) + ' 34 83 a8 68 '
+ getHexStringFromBuffer(mask(message), '34 83 a8 68'));
})();
suite.add('binary data (200 kB)', function () {
receiver.add(binaryDataPacket3);
});
/**
* Output progress.
*/
suite.on('cycle', function (bench, details) {
console.log('\n ' + suite.name.grey, details.name.white.bold);
console.log(' ' + [
details.hz.toFixed(2).cyan + ' ops/sec'.grey
, details.count.toString().white + ' times executed'.grey
, 'benchmark took '.grey + details.times.elapsed.toString().white + ' sec.'.grey
,
].join(', '.grey));
});
/**
* Run/export benchmarks.
*/
if (!module.parent) {
suite.run();
} else {
module.exports = suite;
}
|
