From a12d2b15e48bf62f48b0026a5bdcbcd9633b502f Mon Sep 17 00:00:00 2001
From: Mr Robot <benoit@mobilispro.com>
Date: Tue, 12 Jan 2016 15:51:47 +0100
Subject: [PATCH] Fixing issue
 https://github.com/CollectionFS/Meteor-CollectionFS/issues/731 and
 https://github.com/CollectionFS/Meteor-CollectionFS/issues/408

---
 packages/tempstore/tempStore.js | 2 ++
 packages/worker/fileWorker.js   | 1 +
 2 files changed, 3 insertions(+)

diff --git a/packages/tempstore/tempStore.js b/packages/tempstore/tempStore.js
index f7d4d5f0..eacb644d 100644
--- a/packages/tempstore/tempStore.js
+++ b/packages/tempstore/tempStore.js
@@ -299,6 +299,8 @@ FS.TempStore.createWriteStream = function(fileObj, options) {
     // Progress
     self.emit('progress', fileObj, chunkNum, chunkCount, chunkSum, result);
 
+    fileObj.update({ $set: {node_id: process.env.METEOR_PARENT_PID} });
+
     // If upload is completed
     if (chunkCount === chunkSum) {
       // We no longer need the chunk info
diff --git a/packages/worker/fileWorker.js b/packages/worker/fileWorker.js
index b21ff870..893c8243 100644
--- a/packages/worker/fileWorker.js
+++ b/packages/worker/fileWorker.js
@@ -84,6 +84,7 @@ function getReadyQuery(storeName) {
   var selector = {uploadedAt: {$exists: true}};
   selector['copies.' + storeName] = null;
   selector['failures.copies.' + storeName + '.doneTrying'] = {$ne: true};
+  selector['node_id'] = process.env.METEOR_PARENT_PID;
   return selector;
 }