File tree Expand file tree Collapse file tree 4 files changed +5
-6
lines changed Expand file tree Collapse file tree 4 files changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -487,7 +487,7 @@ class AppendSerializer {
487
487
}
488
488
489
489
const blockCount = Math . ceil (
490
- ( activeTable . nextByte % activeTable . logSize + contentLength ) /
490
+ ( ( activeTable . nextByte % activeTable . logSize ) + contentLength ) /
491
491
activeTable . logSize ,
492
492
) ;
493
493
let nextByte = activeTable . nextByte ;
@@ -500,7 +500,7 @@ class AppendSerializer {
500
500
bufferIndex ,
501
501
Math . min (
502
502
bufferIndex +
503
- ( activeTable . logSize - nextByte % activeTable . logSize ) ,
503
+ ( activeTable . logSize - ( nextByte % activeTable . logSize ) ) ,
504
504
contentLength ,
505
505
) ,
506
506
) ;
Original file line number Diff line number Diff line change @@ -9,8 +9,7 @@ class CacacheSerializer {
9
9
const cache = { } ;
10
10
const promises = [ ] ;
11
11
return new Promise ( ( resolve , reject ) => {
12
- cacache . ls
13
- . stream ( this . path )
12
+ cacache . ls . stream ( this . path )
14
13
. on ( 'data' , ( { key } ) => {
15
14
promises . push (
16
15
cacache . get ( this . path , key ) . then ( ( { data } ) => {
Original file line number Diff line number Diff line change @@ -18,8 +18,7 @@ class LevelDbSerializer {
18
18
db =>
19
19
new Promise ( ( resolve , reject ) => {
20
20
const dbClose = promisify ( db . close , { context : db } ) ;
21
- db
22
- . createReadStream ( )
21
+ db . createReadStream ( )
23
22
. on ( 'data' , data => {
24
23
const value = data . value ;
25
24
if ( ! moduleCache [ data . key ] ) {
Original file line number Diff line number Diff line change 1
1
const pluginCompat = require ( './util/plugin-compat' ) ;
2
+ const logMessages = require ( './util/log-messages' ) ;
2
3
const { ParityRoot } = require ( './util/parity' ) ;
3
4
4
5
class ParitySystem {
You can’t perform that action at this time.
0 commit comments