@@ -78,10 +78,7 @@ function PersistentState(logFilename, blockSize) {
78
78
if ( stateFileExists ( logFilename ) ) {
79
79
raf . close ( function onRAFClosed ( err ) {
80
80
if ( err ) return cb ( err )
81
- fs . unlink ( raf . filename , function onStateFileDeleted ( err ) {
82
- if ( err ) return cb ( err )
83
- else cb ( )
84
- } )
81
+ fs . unlink ( raf . filename , cb )
85
82
} )
86
83
} else {
87
84
cb ( )
@@ -163,11 +160,9 @@ function Compaction(log, onDone) {
163
160
164
161
function savePersistentState ( cb ) {
165
162
if ( ! unshiftedBlockBuf ) {
166
- loadUnshiftedBlock ( function onUnshiftedBlockLoaded ( ) {
167
- saveIt . call ( this )
168
- } )
163
+ loadUnshiftedBlock ( saveIt )
169
164
} else {
170
- saveIt . call ( this )
165
+ saveIt ( )
171
166
}
172
167
173
168
function saveIt ( ) {
@@ -249,9 +244,7 @@ function Compaction(log, onDone) {
249
244
while ( true ) {
250
245
// Fetch the unshifted block, if necessary
251
246
if ( ! unshiftedBlockBuf ) {
252
- loadUnshiftedBlock ( function onUnshiftedBlockLoaded ( ) {
253
- continueCompactingBlock ( )
254
- } )
247
+ loadUnshiftedBlock ( continueCompactingBlock )
255
248
return
256
249
}
257
250
// When all records have been shifted (thus end of log), stop compacting
@@ -273,7 +266,7 @@ function Compaction(log, onDone) {
273
266
// Proceed to compact the next block if this block is full
274
267
if ( log . hasNoSpaceFor ( unshiftedDataBuf , offsetInCompactedBlock ) ) {
275
268
saveCompactedBlock ( )
276
- setImmediate ( ( ) => compactNextBlock ( ) )
269
+ setImmediate ( compactNextBlock )
277
270
return
278
271
}
279
272
0 commit comments