cartodb4
/
node-pg-copy-streams
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Bugfix - Chunk frontiers were not correctly tested

Browse Source
performance-tune-copy-to
jeromew 8 years ago
parent a5e532f20b
commit 9ccda04036
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File

6
copy-to.js
Unescape View File

@ -42,10 +42,10 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) {
var messageCode; var messageCode;
var needPush = false; var needPush = false;
while((chunk.length - offset) > (Byte1Len + Int32Len)) { while((chunk.length - offset) >= (Byte1Len + Int32Len)) {
var messageCode = chunk[offset] var messageCode = chunk[offset]
//console.log(c, w, offset, 'PostgreSQL message ' + String.fromCharCode(messageCode)) //console.log('PostgreSQL message ' + String.fromCharCode(messageCode))
switch(messageCode) { switch(messageCode) {
// detect COPY start // detect COPY start
@ -79,7 +79,7 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) {
} }
length = chunk.readUInt32BE(offset+Byte1Len) length = chunk.readUInt32BE(offset+Byte1Len)
if(chunk.length > (offset + Byte1Len + length)) { if(chunk.length >= (offset + Byte1Len + length)) {
offset += Byte1Len + Int32Len offset += Byte1Len + Int32Len
if (needPush) { if (needPush) {
var row = chunk.slice(offset, offset + length - Int32Len) var row = chunk.slice(offset, offset + length - Int32Len)

Write Preview
Loading…
Cancel
Save