DorianNiemiecSVRJS/svrjs
Archived
1
0
Fork 0
forked from svrjs/svrjs
Code Pull requests Activity

Improve server error handling for Bun.

Browse source
This commit is contained in:
Dorian Niemiec 2023-08-12 12:47:48 +02:00
parent 61dead9b4a
commit f0193b5933
1 changed files with 88 additions and 104 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

192
svr.js
View file

@ -1778,61 +1778,53 @@ if (!cluster.isPrimary) {
} }
server2.on("error", function (err) { server2.on("error", function (err) {
if (err.code == "EADDRINUSE" || err.code == "EADDRNOTAVAIL" || err.code == "EACCES") { attmtsRedir--;
attmtsRedir--; if (cluster.isPrimary === undefined) {
if (cluster.isPrimary === undefined) { if (err.code == "EADDRINUSE") {
if (err.code == "EADDRINUSE") { serverconsole.locerrmessage("Address is already in use by another process.");
serverconsole.locerrmessage("Address is already in use by another process."); } else if (err.code == "EADDRNOTAVAIL") {
} else if (err.code == "EADDRNOTAVAIL") { serverconsole.locerrmessage("Address is not available on this machine.");
serverconsole.locerrmessage("Address is not available on this machine."); } else if (err.code == "EACCES") {
} else if (err.code == "EACCES") { serverconsole.locerrmessage("Permission denied. You may not have sufficient privileges to access the requested address.");
serverconsole.locerrmessage("Permission denied. You may not have sufficient privileges to access the requested address."); } else if (err.code == "EAFNOSUPPORT") {
} else if (err.code == "EAFNOSUPPORT") { serverconsole.locerrmessage("Address family not supported. The address family (IPv4 or IPv6) of the requested address is not supported.");
serverconsole.locerrmessage("Address family not supported. The address family (IPv4 or IPv6) of the requested address is not supported."); } else if (err.code == "EALREADY") {
} else if (err.code == "EALREADY") { serverconsole.locerrmessage("Operation already in progress. The server is already in the process of establishing a connection on the requested address.");
serverconsole.locerrmessage("Operation already in progress. The server is already in the process of establishing a connection on the requested address."); } else if (err.code == "ECONNABORTED") {
} else if (err.code == "ECONNABORTED") { serverconsole.locerrmessage("Connection aborted. The connection to the server was terminated abruptly.");
serverconsole.locerrmessage("Connection aborted. The connection to the server was terminated abruptly."); } else if (err.code == "ECONNREFUSED") {
} else if (err.code == "ECONNREFUSED") { serverconsole.locerrmessage("Connection refused. The server refused the connection attempt.");
serverconsole.locerrmessage("Connection refused. The server refused the connection attempt."); } else if (err.code == "ECONNRESET") {
} else if (err.code == "ECONNRESET") { serverconsole.locerrmessage("Connection reset by peer. The connection to the server was reset by the remote host.");
serverconsole.locerrmessage("Connection reset by peer. The connection to the server was reset by the remote host."); } else if (err.code == "EDESTADDRREQ") {
} else if (err.code == "EDESTADDRREQ") { serverconsole.locerrmessage("Destination address required. The destination address must be specified.");
serverconsole.locerrmessage("Destination address required. The destination address must be specified."); } else if (err.code == "ENETDOWN") {
} else if (err.code == "ENETDOWN") { serverconsole.locerrmessage("Network is down. The network interface used for the connection is not available.");
serverconsole.locerrmessage("Network is down. The network interface used for the connection is not available."); } else if (err.code == "ENETUNREACH") {
} else if (err.code == "ENETUNREACH") { serverconsole.locerrmessage("Network is unreachable. The network destination is not reachable from this host.");
serverconsole.locerrmessage("Network is unreachable. The network destination is not reachable from this host."); } else if (err.code == "ENOBUFS") {
} else if (err.code == "ENOBUFS") { serverconsole.locerrmessage("No buffer space available. Insufficient buffer space is available for the server to process the request.");
serverconsole.locerrmessage("No buffer space available. Insufficient buffer space is available for the server to process the request."); } else if (err.code == "ENOTSOCK") {
} else if (err.code == "ENOTSOCK") { serverconsole.locerrmessage("Not a socket. The file descriptor provided is not a valid socket.");
serverconsole.locerrmessage("Not a socket. The file descriptor provided is not a valid socket."); } else if (err.code == "EPROTO") {
} else if (err.code == "EPROTO") { serverconsole.locerrmessage("Protocol error. An unspecified protocol error occurred.");
serverconsole.locerrmessage("Protocol error. An unspecified protocol error occurred."); } else if (err.code == "EPROTONOSUPPORT") {
} else if (err.code == "EPROTONOSUPPORT") { serverconsole.locerrmessage("Protocol not supported. The requested network protocol is not supported.");
serverconsole.locerrmessage("Protocol not supported. The requested network protocol is not supported."); } else if (err.code == "ETIMEDOUT") {
} else if (err.code == "ETIMEDOUT") { serverconsole.locerrmessage("Connection timed out. The server did not respond within the specified timeout period.");
serverconsole.locerrmessage("Connection timed out. The server did not respond within the specified timeout period.");
} else {
serverconsole.locerrmessage("There was an unknown error with the server.");
}
serverconsole.locmessage(attmtsRedir + " attempts left.");
} else { } else {
process.send("\x12ERRLIST" + attmtsRedir + err.code); serverconsole.locerrmessage("There was an unknown error with the server.");
}
if (attmtsRedir > 0) {
server2.close();
setTimeout(start, 900);
} else {
if (cluster.isPrimary !== undefined) process.send("\x12" + err.code);
process.exit(errors[err.code]);
} }
serverconsole.locmessage(attmtsRedir + " attempts left.");
} else { } else {
serverconsole.locerrmessage("There was a problem starting SVR.JS!!!"); process.send("\x12ERRLIST" + attmtsRedir + err.code);
serverconsole.locerrmessage("Stack:"); }
serverconsole.locerrmessage(generateErrorStack(err)); if (attmtsRedir > 0) {
if (cluster.isPrimary !== undefined) process.send("\x12CRASH"); server2.close();
process.exit(err.code ? errors[err.code] : 1); setTimeout(start, 900);
} else {
if (cluster.isPrimary !== undefined) process.send("\x12" + err.code);
process.exit(errors[err.code]);
} }
}); });
@ -4531,61 +4523,53 @@ if (!cluster.isPrimary) {
} }
//Listen port to server //Listen port to server
server.on("error", function (err) { server.on("error", function (err) {
if (err.code == "EADDRINUSE" || err.code == "EADDRNOTAVAIL" || err.code == "EACCES") { attmts--;
attmts--; if (cluster.isPrimary === undefined) {
if (cluster.isPrimary === undefined) { if (err.code == "EADDRINUSE") {
if (err.code == "EADDRINUSE") { serverconsole.locerrmessage("Address is already in use by another process.");
serverconsole.locerrmessage("Address is already in use by another process."); } else if (err.code == "EADDRNOTAVAIL") {
} else if (err.code == "EADDRNOTAVAIL") { serverconsole.locerrmessage("Address is not available on this machine.");
serverconsole.locerrmessage("Address is not available on this machine."); } else if (err.code == "EACCES") {
} else if (err.code == "EACCES") { serverconsole.locerrmessage("Permission denied. You may not have sufficient privileges to access the requested address.");
serverconsole.locerrmessage("Permission denied. You may not have sufficient privileges to access the requested address."); } else if (err.code == "EAFNOSUPPORT") {
} else if (err.code == "EAFNOSUPPORT") { serverconsole.locerrmessage("Address family not supported. The address family (IPv4 or IPv6) of the requested address is not supported.");
serverconsole.locerrmessage("Address family not supported. The address family (IPv4 or IPv6) of the requested address is not supported."); } else if (err.code == "EALREADY") {
} else if (err.code == "EALREADY") { serverconsole.locerrmessage("Operation already in progress. The server is already in the process of establishing a connection on the requested address.");
serverconsole.locerrmessage("Operation already in progress. The server is already in the process of establishing a connection on the requested address."); } else if (err.code == "ECONNABORTED") {
} else if (err.code == "ECONNABORTED") { serverconsole.locerrmessage("Connection aborted. The connection to the server was terminated abruptly.");
serverconsole.locerrmessage("Connection aborted. The connection to the server was terminated abruptly."); } else if (err.code == "ECONNREFUSED") {
} else if (err.code == "ECONNREFUSED") { serverconsole.locerrmessage("Connection refused. The server refused the connection attempt.");
serverconsole.locerrmessage("Connection refused. The server refused the connection attempt."); } else if (err.code == "ECONNRESET") {
} else if (err.code == "ECONNRESET") { serverconsole.locerrmessage("Connection reset by peer. The connection to the server was reset by the remote host.");
serverconsole.locerrmessage("Connection reset by peer. The connection to the server was reset by the remote host."); } else if (err.code == "EDESTADDRREQ") {
} else if (err.code == "EDESTADDRREQ") { serverconsole.locerrmessage("Destination address required. The destination address must be specified.");
serverconsole.locerrmessage("Destination address required. The destination address must be specified."); } else if (err.code == "ENETDOWN") {
} else if (err.code == "ENETDOWN") { serverconsole.locerrmessage("Network is down. The network interface used for the connection is not available.");
serverconsole.locerrmessage("Network is down. The network interface used for the connection is not available."); } else if (err.code == "ENETUNREACH") {
} else if (err.code == "ENETUNREACH") { serverconsole.locerrmessage("Network is unreachable. The network destination is not reachable from this host.");
serverconsole.locerrmessage("Network is unreachable. The network destination is not reachable from this host."); } else if (err.code == "ENOBUFS") {
} else if (err.code == "ENOBUFS") { serverconsole.locerrmessage("No buffer space available. Insufficient buffer space is available for the server to process the request.");
serverconsole.locerrmessage("No buffer space available. Insufficient buffer space is available for the server to process the request."); } else if (err.code == "ENOTSOCK") {
} else if (err.code == "ENOTSOCK") { serverconsole.locerrmessage("Not a socket. The file descriptor provided is not a valid socket.");
serverconsole.locerrmessage("Not a socket. The file descriptor provided is not a valid socket."); } else if (err.code == "EPROTO") {
} else if (err.code == "EPROTO") { serverconsole.locerrmessage("Protocol error. An unspecified protocol error occurred.");
serverconsole.locerrmessage("Protocol error. An unspecified protocol error occurred."); } else if (err.code == "EPROTONOSUPPORT") {
} else if (err.code == "EPROTONOSUPPORT") { serverconsole.locerrmessage("Protocol not supported. The requested network protocol is not supported.");
serverconsole.locerrmessage("Protocol not supported. The requested network protocol is not supported."); } else if (err.code == "ETIMEDOUT") {
} else if (err.code == "ETIMEDOUT") { serverconsole.locerrmessage("Connection timed out. The server did not respond within the specified timeout period.");
serverconsole.locerrmessage("Connection timed out. The server did not respond within the specified timeout period.");
} else {
serverconsole.locerrmessage("There was an unknown error with the server.");
}
serverconsole.locmessage(attmts + " attempts left.");
} else { } else {
process.send("\x12ERRLIST" + attmts + err.code); serverconsole.locerrmessage("There was an unknown error with the server.");
}
if (attmts > 0) {
server2.close();
setTimeout(start, 900);
} else {
if (cluster.isPrimary !== undefined) process.send("\x12" + err.code);
process.exit(errors[err.code]);
} }
serverconsole.locmessage(attmts + " attempts left.");
} else { } else {
serverconsole.locerrmessage("There was a problem starting SVR.JS!!!"); process.send("\x12ERRLIST" + attmts + err.code);
serverconsole.locerrmessage("Stack:"); }
serverconsole.locerrmessage(generateErrorStack(err)); if (attmts > 0) {
if (cluster.isPrimary !== undefined) process.send("\x12CRASH"); server2.close();
process.exit(err.code ? errors[err.code] : 1); setTimeout(start, 900);
} else {
if (cluster.isPrimary !== undefined) process.send("\x12" + err.code);
process.exit(errors[err.code]);
} }
}); });