Improve RADIUS client error handling and socket cleanup

- Enhanced error messages in util-server.js to preserve stack traces and provide better context with hostname and port information
- Fixed potential race conditions in radius-client.js by adding proper socket cleanup and preventing multiple cleanup calls
- Added socketClosed flag to prevent operations on closed sockets
- Improved timeout handling to prevent memory leaks and ensure proper resource cleanup
This commit is contained in:
GitTensor Miner 2026-01-21 17:09:43 +02:00
parent 9169a647cb
commit c51761742d
2 changed files with 41 additions and 13 deletions

View File

@ -67,23 +67,47 @@ class RadiusClient {
let attempts = 0;
let responseReceived = false;
let timeoutHandle;
let socketClosed = false;
/**
* Safely close socket and clear timeout
* @returns {void}
*/
const cleanup = () => {
if (timeoutHandle) {
clearTimeout(timeoutHandle);
timeoutHandle = null;
}
if (!socketClosed) {
socketClosed = true;
try {
socket.close();
} catch (err) {
// Ignore errors during cleanup
}
}
};
/**
* Send RADIUS request with retry logic
* @returns {void}
*/
const sendRequest = () => {
if (responseReceived || socketClosed) {
return;
}
attempts++;
socket.send(encodedPacket, 0, encodedPacket.length, this.port, this.host, (err) => {
if (err) {
socket.close();
cleanup();
return reject(new Error(`Failed to send RADIUS request: ${err.message}`));
}
// Set timeout for this attempt
timeoutHandle = setTimeout(() => {
if (responseReceived) {
if (responseReceived || socketClosed) {
return;
}
@ -92,7 +116,7 @@ class RadiusClient {
sendRequest();
} else {
// All retries exhausted
socket.close();
cleanup();
reject(new Error(`RADIUS request timeout after ${attempts} attempts`));
}
}, this.timeout);
@ -101,23 +125,20 @@ class RadiusClient {
// Handle response
socket.on("message", (msg) => {
if (responseReceived) {
if (responseReceived || socketClosed) {
return;
}
responseReceived = true;
clearTimeout(timeoutHandle);
cleanup();
let response;
try {
response = radius.decode({ packet: msg, secret: secret });
} catch (error) {
socket.close();
return reject(new Error(`RADIUS response decoding failed: ${error.message}`));
}
socket.close();
// Map response code to match node-radius-client format
const responseCode = response.code;
@ -140,10 +161,9 @@ class RadiusClient {
// Handle socket errors
socket.on("error", (err) => {
if (!responseReceived) {
if (!responseReceived && !socketClosed) {
responseReceived = true;
clearTimeout(timeoutHandle);
socket.close();
cleanup();
reject(new Error(`RADIUS socket error: ${err.message}`));
}
});

View File

@ -356,10 +356,18 @@ exports.radius = function (
],
})
.catch((error) => {
// Preserve error stack trace and provide better context
if (error.response?.code) {
throw Error(error.response.code);
const radiusError = new Error(`RADIUS ${error.response.code} from ${hostname}:${port}`);
radiusError.response = error.response;
radiusError.originalError = error;
throw radiusError;
} else {
throw Error(error.message);
// Preserve original error message and stack trace
const enhancedError = new Error(`RADIUS authentication failed for ${hostname}:${port}: ${error.message}`);
enhancedError.originalError = error;
enhancedError.stack = error.stack || enhancedError.stack;
throw enhancedError;
}
});
};