@@ -19,29 +19,50 @@ while(1) {
19
19
20
20
var PP = require ( '../../lib/packet_parser.js' ) ;
21
21
22
- var count = 0 ;
23
- var cc = 0 ;
22
+ var chunks = [ ] ;
23
+ function benchmarkPackets ( ) {
24
24
25
- function handler ( packet ) {
26
- //console.log(packet.length(), packet.sequenceId);
27
- cc += packet . sequenceId
28
- count ++ ;
29
- }
25
+ if ( chunks . length === 0 ) {
26
+ for ( var csize = 1 ; csize < plen ; ++ csize ) {
27
+ for ( var o = 0 ; o + csize < p . length ; o += csize ) {
28
+ chunks . push ( p . slice ( o , o + csize ) ) ;
29
+ }
30
+ }
31
+ }
30
32
31
- var chunks = [ ] ;
32
- var csize = parseInt ( process . argv [ 2 ] ) ;
33
- for ( var o = 0 ; o + csize < p . length ; o += csize ) {
34
- chunks . push ( p . slice ( o , o + csize ) ) ;
35
- }
33
+ console . log ( chunks ) ;
36
34
37
- var start = process . hrtime ( ) ;
38
- for ( var i = 0 ; i < 50 ; ++ i ) {
35
+ var count = 0 ;
36
+ var cc = 0 ;
37
+
38
+ function handler ( packet ) {
39
+ //console.log(packet.length(), packet.sequenceId);
40
+ cc += packet . sequenceId
41
+ count ++ ;
42
+ }
43
+
44
+ var start = process . hrtime ( ) ;
39
45
var packetParser = new PP ( handler ) ;
40
46
for ( var j = 0 ; j < chunks . length ; ++ j ) {
41
47
packetParser . execute ( chunks [ j ] ) ;
42
48
}
49
+ return count ;
50
+ }
51
+
52
+ module . exports = function ( next ) {
53
+ /*
54
+ var c = benchmarkPackets();
55
+ */
56
+ next ( ) ;
43
57
}
44
- var end = process . hrtime ( start ) ;
45
- var dur = end [ 0 ] * 1e9 + end [ 1 ] ;
46
58
47
- console . log ( 1e9 * count / dur , count , cc ) ;
59
+ module . exports . comment = 'WIP - not implemented yet | packet_parser.execute() in chunks of length 1..packet_length x 156035 packets' ;
60
+ module . exports . toSpeed = function ( time , timeError ) {
61
+ console . log ( 'packet_parser.execute() toSpeed()' , time , timeError ) ;
62
+ var value = 1e9 * 5 * 156975 / time ;
63
+ return {
64
+ value : value ,
65
+ error : value * ( timeError / time ) ,
66
+ units : 'packets/second'
67
+ } ;
68
+ } ;
0 commit comments