add some memory logging

This commit is contained in:
rubikscraft
2022-09-24 12:23:56 +02:00
parent 3e62412ef8
commit e45510f35a
3 changed files with 17 additions and 11 deletions

View File

@@ -82,7 +82,6 @@ export class IngestService {
},
{
jobId: uuidv4(),
delay: 30000,
},
)) as ImageIngestJob;
if (!job.id) return Fail(FT.Internal, undefined, 'Failed to queue job');

View File

@@ -75,16 +75,6 @@ export class ImageController {
params,
),
);
const isbfufer = image.data instanceof Buffer;
console.log('isabuffer', isbfufer);
if (!isbfufer) {
console.log('not a buffer');
console.log(image.data);
console.trace();
process.exit();
}
res.type(ThrowIfFailed(FileType2Mime(image.filetype)));
return image.data;

View File

@@ -11,6 +11,8 @@ import {
import { UniversalSharpIn, UniversalSharpOut } from './universal-sharp';
export class SharpWorker {
private maxMemoryUsed = 0;
private startTime: number = 0;
private sharpi: Sharp | null = null;
@@ -36,6 +38,17 @@ export class SharpWorker {
process.on('message', this.messageHandler.bind(this));
process.nextTick(() => {
let memUsage = process.memoryUsage();
if (memUsage.rss > this.maxMemoryUsed) {
this.maxMemoryUsed = memUsage.rss;
}
});
setInterval(() => {
console.log(`Used ${JSON.stringify(process.memoryUsage())} bytes`);
}, 100);
this.sendMessage({
type: 'ready',
});
@@ -92,6 +105,10 @@ export class SharpWorker {
const result = await UniversalSharpOut(sharpi, filetype, options);
const processingTime = Date.now() - this.startTime;
console.log(
`\nUsed ${this.maxMemoryUsed} bytes`,
);
this.sendMessage({
type: 'result',
processingTime,