From 20c3e15f930a0c7f4ff39b9f0acb21b04e75efb0 Mon Sep 17 00:00:00 2001 From: Henrique Dias Date: Fri, 14 Aug 2015 19:58:38 -0300 Subject: [PATCH] fix bulk insert limit --- services/track-changes/app/coffee/MongoAWS.coffee | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/services/track-changes/app/coffee/MongoAWS.coffee b/services/track-changes/app/coffee/MongoAWS.coffee index d5d243cb2d..9b4271c167 100644 --- a/services/track-changes/app/coffee/MongoAWS.coffee +++ b/services/track-changes/app/coffee/MongoAWS.coffee @@ -59,9 +59,9 @@ module.exports = MongoAWS = .on 'data', (line) -> if line.length > 2 ops.push(JSON.parse(line)) - if ops.length > MongoAWS.bulkLimit - MongoAWS.handleBulk ops, () -> - ops.splice(0,ops.length) + if ops.length == MongoAWS.bulkLimit + MongoAWS.handleBulk ops.slice(0), () -> + ops.splice(0,ops.length) .on 'end', () -> MongoAWS.handleBulk ops, callback .on 'error', (err) -> @@ -80,7 +80,7 @@ module.exports = MongoAWS = if err? logger.error err:err, "error bulking ReadlineStream" else - logger.log result:result, "bulked ReadlineStream" + logger.log count:ops.length, result:result, "bulked ReadlineStream" cb(err)