jens/flipper
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Track socket usage during file download

Browse Source 
Summary: Should help to investigate further issues like https://fb.workplace.com/groups/flippersupport/permalink/1577911229356196/

Reviewed By: passy

Differential Revision: D43692927

fbshipit-source-id: 723b051f748946c89ece85fb6c11c40705196fe4
This commit is contained in:
Andrey Goncharov
2023-03-01 05:26:00 -08:00
committed by Facebook GitHub Bot
parent fa74ebba68
commit 39b14fc428
1 changed files with 37 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
desktop/flipper-server-core/src/commands/DownloadFile.tsx
View File

@@ -11,6 +11,8 @@ import {FlipperServerCommands, FlipperServerEvents, uuid} from 'flipper-common';
import {pathExists} from 'fs-extra'; import {pathExists} from 'fs-extra';
import {promises, createWriteStream, ReadStream} from 'fs'; import {promises, createWriteStream, ReadStream} from 'fs';
import axios from 'axios'; import axios from 'axios';
import http from 'http';
import https from 'https';
const {unlink} = promises; const {unlink} = promises;
@@ -43,6 +45,21 @@ export const commandDownloadFileStartFactory =
await unlink(dest); await unlink(dest);
} }
console.debug('commandDownloadFileStartFactory -> start', {
http: {
usedSockets: Object.keys(http.globalAgent.sockets).length,
freeSocket: Object.keys(http.globalAgent.freeSockets).length,
maxSockets: http.globalAgent.maxSockets,
maxTotalSockets: http.globalAgent.maxTotalSockets,
},
https: {
usedSockets: Object.keys(https.globalAgent.sockets).length,
freeSocket: Object.keys(https.globalAgent.freeSockets).length,
maxSockets: https.globalAgent.maxSockets,
maxTotalSockets: https.globalAgent.maxTotalSockets,
},
});
const downloadId = uuid(); const downloadId = uuid();
const response = await axios.request<ReadStream>({ const response = await axios.request<ReadStream>({
@@ -84,6 +101,16 @@ export const commandDownloadFileStartFactory =
totalSize, totalSize,
status: 'success', status: 'success',
}); });
console.debug('commandDownloadFileStartFactory -> finish', {
http: {
usedSockets: Object.keys(http.globalAgent.sockets).length,
freeSocket: Object.keys(http.globalAgent.freeSockets).length,
},
https: {
usedSockets: Object.keys(https.globalAgent.sockets).length,
freeSocket: Object.keys(https.globalAgent.freeSockets).length,
},
});
}); });
writeStream.on('error', (e: Error) => { writeStream.on('error', (e: Error) => {
@@ -96,6 +123,16 @@ export const commandDownloadFileStartFactory =
message: e.message, message: e.message,
stack: e.stack, stack: e.stack,
}); });
console.debug('commandDownloadFileStartFactory -> error', {
http: {
usedSockets: Object.keys(http.globalAgent.sockets).length,
freeSocket: Object.keys(http.globalAgent.freeSockets).length,
},
https: {
usedSockets: Object.keys(https.globalAgent.sockets).length,
freeSocket: Object.keys(https.globalAgent.freeSockets).length,
},
});
}); });
return { return {