oreolek/nmig
1
0
Fork 0
Code Releases Activity

Added explicit GC usage

Browse source
This commit is contained in:
Anatoly Khaytovich 2016-03-05 19:32:31 +02:00
parent e8704c2cb9
commit cf3be115d2
1 changed files with 14 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
migration/fmtp/FromMySQL2PostgreSQL.js
View file

@ -1091,7 +1091,10 @@ FromMySQL2PostgreSQL.prototype.populateTableWorker = function(self, strSelectFie
self.log(self, msg); self.log(self, msg);
fs.unlink(csvAddr, () => { fs.unlink(csvAddr, () => {
fs.close(fd, () => resolvePopulateTableWorker()); fs.close(fd, () => {
global.gc();
resolvePopulateTableWorker();
});
}); });
}); });
} else { } else {
@ -1100,7 +1103,10 @@ FromMySQL2PostgreSQL.prototype.populateTableWorker = function(self, strSelectFie
self.log(self, msg); self.log(self, msg);
fs.unlink(csvAddr, () => { fs.unlink(csvAddr, () => {
fs.close(fd, () => resolvePopulateTableWorker()); fs.close(fd, () => {
global.gc();
resolvePopulateTableWorker();
});
}); });
} }
@ -1111,7 +1117,10 @@ FromMySQL2PostgreSQL.prototype.populateTableWorker = function(self, strSelectFie
self.log(self, msg); self.log(self, msg);
fs.unlink(csvAddr, () => { fs.unlink(csvAddr, () => {
fs.close(fd, () => resolvePopulateTableWorker()); fs.close(fd, () => {
global.gc();
resolvePopulateTableWorker();
});
}); });
} }
}); });
@ -1608,6 +1617,8 @@ FromMySQL2PostgreSQL.prototype.processTable = function(self, tableName) {
self.createSequence self.createSequence
).then( ).then(
self.processIndexAndKey self.processIndexAndKey
).then(
global.gc
); );
}; };