suzanne.soy/wiki.gruntnetwork.com--zimmer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Node.js 10.4.0 BigInt

Browse Source
This commit is contained in:
vss-devel 2019-02-28 21:31:09 +03:00
parent 2b69dccffa
commit 390761df30
1 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
zimmer.js
View File

@ -201,12 +201,18 @@ function mimeFromData ( data ) {
function writeUIntLE( buf, value, offset, byteLength ) { function writeUIntLE( buf, value, offset, byteLength ) {
if ( byteLength == 8 ) { if ( byteLength == 8 ) {
var low = (( value & 0xffffffff ) >>> 1 ) * 2 + ( value & 0x1 ) // unsigned try {
var high = ( value - low ) / 0x100000000 value = BigInt( value )
buf.writeUInt32LE( low, offset ) } catch ( err ) {
buf.writeUInt32LE( high, offset + 4 ) log( err )
}
var low = value & 0xffffffffn
var high = ( value - low ) / 0x100000000n
buf.writeUInt32LE( Number( low ), offset )
buf.writeUInt32LE( Number( high ), offset + 4 )
return offset + byteLength return offset + byteLength
} else { } else {
value = Number( value )
return buf.writeUIntLE( value, offset, byteLength ) return buf.writeUIntLE( value, offset, byteLength )
} }
} }
@ -309,7 +315,7 @@ function cvsReader ( path, options ) {
// //
class Writer { class Writer {
constructor ( path ) { constructor ( path ) {
this.position = 0 this.position = BigInt( 0 )
this.stream = fs.createWriteStream( path, { highWaterMark: 1024*1024*10 }) this.stream = fs.createWriteStream( path, { highWaterMark: 1024*1024*10 })
this.stream.once( 'open', fd => { }) this.stream.once( 'open', fd => { })
this.stream.on( 'error', err => { this.stream.on( 'error', err => {
@ -328,7 +334,7 @@ class Writer {
async write ( data ) { async write ( data ) {
const token = await this.queue.acquire() const token = await this.queue.acquire()
const startPosition = this.position const startPosition = this.position
this.position += data.length this.position += BigInt( data.length )
const saturated = ! this.stream.write( data ) const saturated = ! this.stream.write( data )
if ( saturated ) { if ( saturated ) {
@ -509,7 +515,7 @@ class ClusterPool {
const byteLength = 8 const byteLength = 8
const count = header.clusterCount const count = header.clusterCount
const start = await out.write( Buffer.alloc( 0 )) const start = await out.write( Buffer.alloc( 0 ))
let offset = start + count * byteLength let offset = start + BigInt( count * byteLength )
header.clusterPtrPos = await saveIndex ({ header.clusterPtrPos = await saveIndex ({
query:` query:`
@ -524,7 +530,7 @@ class ClusterPool {
logPrefix: 'storeClusterIndex', logPrefix: 'storeClusterIndex',
rowCb: ( row, index ) => { rowCb: ( row, index ) => {
const val = offset const val = offset
offset += row.size offset += BigInt( row.size )
return val return val
}, },
}) })
@ -662,7 +668,7 @@ class Item {
'INSERT INTO dirEntries (id, offset) VALUES (?,?)', 'INSERT INTO dirEntries (id, offset) VALUES (?,?)',
[ [
id, id,
this.dirEntryOffset, Number( this.dirEntryOffset ), // assume dir entries are written close to the beginning
] ]
) )
} catch ( err ) { } catch ( err ) {