@@ -90,14 +90,14 @@ if (cluster.isMaster) {
90
90
}
91
91
}
92
92
93
- closestBlock ( temps , filter , cb ) {
93
+ closestBlock ( temps , key , filter , cb ) {
94
94
let worker = this . _freeWorker ( )
95
95
if ( worker ) {
96
96
_callbacks . set ( worker , cb )
97
- worker . send ( { type : 'content' , temps, filter} )
97
+ worker . send ( { type : 'content' , temps, key , filter} )
98
98
} else {
99
99
let queue = _queue . get ( this )
100
- queue . unshift ( { type : 'content' , temps, filter, cb : cb } )
100
+ queue . unshift ( { type : 'content' , temps, key , filter, cb : cb } )
101
101
}
102
102
}
103
103
_free ( threadId ) {
@@ -107,20 +107,9 @@ if (cluster.isMaster) {
107
107
if ( next ) {
108
108
let pool = _pool . get ( this )
109
109
let worker = pool . get ( threadId )
110
- switch ( next . type ) {
111
- case 'content' :
112
- _callbacks . set ( worker , next . cb )
113
- worker . send ( { type : next . type , temps : next . temps } )
114
- break
115
- case 'contentFilter' :
116
- _callbacks . set ( worker , next . cb )
117
- worker . send ( { type : next . type , temps : next . temps } )
118
- break
119
- case 'closestBlock' :
120
- _callbacks . set ( worker , next . cb )
121
- worker . send ( { type : next . type , temps : next . temps , filter : next . filter } )
122
- break
123
- }
110
+ _callbacks . set ( worker , next . cb )
111
+ delete next . cb
112
+ worker . send ( { ...next } )
124
113
}
125
114
} )
126
115
}
@@ -146,7 +135,7 @@ if (cluster.isMaster) {
146
135
} )
147
136
break
148
137
case 'closestBlock' :
149
- closestBlock ( msg . temps , msg . filter , ( err , key ) => {
138
+ closestBlock ( msg . temps , msg . key , Buffer . from ( msg . filter ) , ( err , key ) => {
150
139
if ( err ) {
151
140
return process . send ( { err : err } )
152
141
}
@@ -185,7 +174,7 @@ if (cluster.isMaster) {
185
174
}
186
175
} )
187
176
}
188
- function closestBlock ( temps , filter , cb ) {
177
+ function closestBlock ( temps , key , filter , cb ) {
189
178
content ( ( err , content ) => {
190
179
if ( err ) {
191
180
return cb ( err )
0 commit comments