File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -19,10 +19,10 @@ if (cluster.isMaster) {
1919 serialization
2020} ) {
2121const expectedPerBroadcast = sendsPerBroadcast * workers ;
22- var readies = 0 ;
23- var broadcasts = 0 ;
24- var msgCount = 0 ;
25- var data ;
22+ let readies = 0 ;
23+ let broadcasts = 0 ;
24+ let msgCount = 0 ;
25+ let data ;
2626
2727cluster . settings . serialization = serialization ;
2828
@@ -37,7 +37,7 @@ if (cluster.isMaster) {
3737throw new Error ( 'Unsupported payload type' ) ;
3838}
3939
40- for ( var i = 0 ; i < workers ; ++ i )
40+ for ( let i = 0 ; i < workers ; ++ i )
4141cluster . fork ( ) . on ( 'online' , onOnline ) . on ( 'message' , onMessage ) ;
4242
4343function onOnline ( ) {
@@ -48,16 +48,15 @@ if (cluster.isMaster) {
4848}
4949
5050function broadcast ( ) {
51- var id ;
5251if ( broadcasts ++ === n ) {
5352bench . end ( n ) ;
54- for ( id in cluster . workers )
53+ for ( const id in cluster . workers )
5554cluster . workers [ id ] . disconnect ( ) ;
5655return ;
5756}
58- for ( id in cluster . workers ) {
57+ for ( const id in cluster . workers ) {
5958const worker = cluster . workers [ id ] ;
60- for ( var i = 0 ; i < sendsPerBroadcast ; ++ i )
59+ for ( let i = 0 ; i < sendsPerBroadcast ; ++ i )
6160worker . send ( data ) ;
6261}
6362}
You can’t perform that action at this time.
0 commit comments