Compare commits
3 Commits
v2.x-carto
...
performanc
Author | SHA1 | Date | |
---|---|---|---|
|
fd3cc95573 | ||
|
922627daaf | ||
|
61bc713e0c |
16
copy-to.js
16
copy-to.js
@ -42,6 +42,16 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) {
|
|||||||
var messageCode;
|
var messageCode;
|
||||||
var needPush = false;
|
var needPush = false;
|
||||||
|
|
||||||
|
var buffer = Buffer.alloc(chunk.length);
|
||||||
|
var buffer_offset = 0;
|
||||||
|
|
||||||
|
this.pushBufferIfneeded = function() {
|
||||||
|
if (needPush && buffer_offset > 0) {
|
||||||
|
this.push(buffer.slice(0, buffer_offset))
|
||||||
|
buffer_offset = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
while((chunk.length - offset) >= (Byte1Len + Int32Len)) {
|
while((chunk.length - offset) >= (Byte1Len + Int32Len)) {
|
||||||
var messageCode = chunk[offset]
|
var messageCode = chunk[offset]
|
||||||
|
|
||||||
@ -70,6 +80,7 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) {
|
|||||||
|
|
||||||
case code.ErrorResponse:
|
case code.ErrorResponse:
|
||||||
case code.CopyDone:
|
case code.CopyDone:
|
||||||
|
this.pushBufferIfneeded();
|
||||||
this._detach()
|
this._detach()
|
||||||
this.push(null)
|
this.push(null)
|
||||||
return cb();
|
return cb();
|
||||||
@ -84,7 +95,8 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) {
|
|||||||
if (needPush) {
|
if (needPush) {
|
||||||
var row = chunk.slice(offset, offset + length - Int32Len)
|
var row = chunk.slice(offset, offset + length - Int32Len)
|
||||||
this.rowCount++
|
this.rowCount++
|
||||||
this.push(row)
|
row.copy(buffer, buffer_offset);
|
||||||
|
buffer_offset += row.length;
|
||||||
}
|
}
|
||||||
offset += (length - Int32Len)
|
offset += (length - Int32Len)
|
||||||
} else {
|
} else {
|
||||||
@ -93,6 +105,8 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
this.pushBufferIfneeded();
|
||||||
|
|
||||||
if(chunk.length - offset) {
|
if(chunk.length - offset) {
|
||||||
var slice = chunk.slice(offset)
|
var slice = chunk.slice(offset)
|
||||||
this._remainder = slice
|
this._remainder = slice
|
||||||
|
Loading…
Reference in New Issue
Block a user