MeshCentral/MeshAgent
1
0
Fork 0
mirror of https://github.com/Ylianst/MeshAgent synced 2026-01-14 22:43:27 +00:00
Code Issues Releases Wiki Activity

Updated GC references

Browse Source
This commit is contained in:
Bryan Roe
2021-03-21 16:11:30 -07:00
parent 6431046938
commit b27ebd6c4b
3 changed files with 41 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
microscript/ILibDuktape_Polyfills.c
View File

File diff suppressed because one or more lines are too long

17
modules/user-sessions.js
View File

@@ -1012,25 +1012,18 @@ function UserSessions()
this.enumerateUsers = function enumerateUsers()
{
var promise = require('promise');
var p = new promise(function (res, rej)
{
this.__resolver = res;
this.__rejector = rej;
});
var p = new promise(promise.defaultInit);
p.parent = this;
p.descriptorMetadata = 'user-sessions: enumerateUsers()';
p.__handler = function __handler(users)
{
p.__resolver(users);
};
try
{
this.Current(p.__handler);
this.Current(p.resolve);
}
catch (e)
{
p.__rejector(e);
p.reject(e);
}
p.parent = this;
return (p);
}
}

51
modules/zip-reader.js
View File

@@ -44,7 +44,16 @@ function checkFolderPath(dest)
}
function extractNext(p)
{
if (p.pending.length == 0) { p.source.close(); p._res(); return; }
if (p._stream) { p._stream.unpipe(); }
if (p.pending.length == 0)
{
p.source.close();
p.source = null;
p._output = null;
p._stream = null;
p._res();
return;
}
var next = p.pending.pop();
var dest = p.baseFolder + (process.platform == 'win32' ? '\\' : '/') + next;
if (process.platform == 'win32')
@@ -67,20 +76,24 @@ function extractNext(p)
return;
}
p._stream = p.source.getStream(next);
p._output = require('fs').createWriteStream(dest, { flags: 'wb' });
p._output.name = next;
p._output.promise = p;
p._output.on('close', function ()
var wp = WeakReference(p);
p = null;
wp.object._stream = wp.object.source.getStream(next);
wp.object._output = require('fs').createWriteStream(dest, { flags: 'wb' });
require('events').setFinalizerMetadata.call(wp.object._output, next);
wp.object._output.name = next;
wp.object._output.promise = wp;
wp.object._output.once('close', function ()
{
if (this.promise._stream.crc != this.promise.source.crc(this.name))
if (this.promise.object._stream.crc != this.promise.object.source.crc(this.name))
{
this.promise._rej('CRC Check failed');
this.promise.object._rej('CRC Check failed');
return;
}
extractNext(this.promise);
extractNext(this.promise.object);
});
p._stream.pipe(p._output);
wp.object._stream.pipe(wp.object._output);
}
function zippedObject(table)
@@ -251,18 +264,22 @@ function zippedObject(table)
}
var i;
var ret = new promise(function (res, rej) { this._res = res; this._rej = rej; });
var ret = WeakReference(new promise(promise.defaultInit));
ret.object._res = ret.object.resolve;
ret.object._rej = ret.object.reject;
ret.object.descriptorMetadata = 'extractAll.promise';
if (destFolder.endsWith(process.platform == 'win32' ? '\\' : '/')) { destFolder = destFolder.substring(0, destFolder.length - 1); }
ret.source = this;
ret.baseFolder = destFolder;
ret.pending = [];
ret.object.source = this;
ret.object.baseFolder = destFolder;
ret.object.pending = [];
for (i in this.files)
{
ret.pending.push(this.files[i]);
ret.object.pending.push(this.files[i]);
}
extractNext(ret);
return (ret);
extractNext(ret.object);
return (ret.object);
};
this._extractAllStreams2 = function _extractAllStreams2(prom)
{