Ylianst/MeshCentral
1
0
Fork 0
mirror of https://github.com/Ylianst/MeshCentral.git synced 2024-11-22 22:17:31 +03:00
Code Issues Packages Projects Releases Wiki Activity

Improves the RSA sign async accelerator.

Browse Source
This commit is contained in:
Ylian Saint-Hilaire 2019-05-03 09:59:09 -07:00
parent 6c0f5bfd1c
commit ec07ec678a
1 changed files with 11 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
certoperations.js
View File

@ -598,16 +598,16 @@ module.exports.CertificateOperations = function (parent) {
accelerator.accid = acceleratorCreateCount; accelerator.accid = acceleratorCreateCount;
accelerator.on("message", function (message) { accelerator.on("message", function (message) {
acceleratorMessage++; acceleratorMessage++;
try { this.func(this.tag, message); } catch (ex) { acceleratorMessageException++; acceleratorMessageLastException = ex; } this.x.func(this.x.tag, message);
try { delete this.x;
delete this.tag; if (pendingAccelerator.length > 0) { this.send(this.x = pendingAccelerator.shift()); } else { freeAccelerators.push(this); }
if (pendingAccelerator.length > 0) {
var x = pendingAccelerator.shift();
if (x.tag) { this.tag = x.tag; delete x.tag; }
accelerator.send(x);
} else { freeAccelerators.push(this); }
} catch (ex) { acceleratorException++; acceleratorLastException = ex; }
}); });
accelerator.on("exit", function (code) {
if (this.x) { pendingAccelerator.push(this.x); delete this.x; }
acceleratorCreateCount++;
if (pendingAccelerator.length > 0) { var acc = obj.getAccelerator(); acc.send(acc.x = pendingAccelerator.shift()); }
});
accelerator.on("error", function (code) { }); // Not sure if somethign should be done here to help kill the process.
accelerator.send({ action: "setState", certs: obj.acceleratorCertStore }); accelerator.send({ action: "setState", certs: obj.acceleratorCertStore });
return accelerator; return accelerator;
} }
@ -636,13 +636,11 @@ module.exports.CertificateOperations = function (parent) {
if (acc == null) { if (acc == null) {
// Add to pending accelerator workload // Add to pending accelerator workload
acceleratorPerformSignaturePushFuncCall++; acceleratorPerformSignaturePushFuncCall++;
pendingAccelerator.push({ action: "sign", key: privatekey, data: data, tag: tag }); pendingAccelerator.push({ action: "sign", key: privatekey, data: data, tag: tag, func: func });
} else { } else {
// Send to accelerator now // Send to accelerator now
acceleratorPerformSignatureRunFuncCall++; acceleratorPerformSignatureRunFuncCall++;
acc.func = func; acc.send(acc.x = { action: "sign", key: privatekey, data: data, tag: tag, func: func });
acc.tag = tag;
acc.send({ action: "sign", key: privatekey, data: data });
} }
} }
}; };