nodemailer/wildduck
1
1
Fork 0
mirror of https://github.com/nodemailer/wildduck.git synced 2024-09-20 07:16:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

Heap snapshot (#504)

Browse source 
* fix(debug): Added option to generate process-specific heap snapshots
This commit is contained in:
Andris Reinman 2023-09-28 10:44:23 +03:00 committed by GitHub
parent c678a1ed07
commit 69856eb5c2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 46 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
server.js
View file

@ -4,6 +4,9 @@
process.env.UV_THREADPOOL_SIZE = 16;
const v8 = require('node:v8');
const Path = require('path');
const os = require('os');
const config = require('wild-config');
if (process.env.NODE_CONFIG_ONLY === 'true') {
@ -13,7 +16,6 @@ if (process.env.NODE_CONFIG_ONLY === 'true') {
const errors = require('./lib/errors');
const fs = require('fs');
const os = require('os');
const log = require('npmlog');
const packageData = require('./package.json');
const { init: initElasticSearch } = require('./lib/elasticsearch');
@ -139,6 +141,48 @@ if (!processCount || processCount <= 1) {
}
process.on('unhandledRejection', err => {
log.error('App', 'Unhandled rejection: %s' + ((err && err.stack) || err));
log.error('App', 'Unhandled rejection: %s', (err && err.stack) || err);
errors.notify(err);
});
process.on('SIGPIPE', () => {
// generate memory dump
log.info('Process', 'PID=%s Generating heap snapshot...', process.pid);
let stream;
try {
stream = v8.getHeapSnapshot();
} catch (err) {
log.error('Process', 'PID=%s Failed to generate heap snapshot: %s', process.pid, err.stack || err);
return;
}
if (stream) {
const path = Path.join(
os.tmpdir(),
`Heap-${process.pid}-${new Date()
.toISOString()
.substring(0, 19)
.replace(/[^0-9T]+/g, '')}.heapsnapshot`
);
let f;
try {
f = fs.createWriteStream(path);
} catch (err) {
log.error('Process', 'PID=%s Failed to generate heap snapshot: %s', process.pid, err.stack || err);
return;
}
f.once('error', err => {
log.error('Process', 'PID=%s Failed to generate heap snapshot: %s', process.pid, err.stack || err);
});
stream.once('error', err => {
log.error('Process', 'PID=%s Failed to generate heap snapshot: %s', process.pid, err.stack || err);
});
stream.pipe(f);
f.once('finish', () => {
log.info('Process', 'PID=%s Generated heap snapshot: %s', process.pid, path);
});
}
});