mirror of
https://github.com/open-goal/jak-project.git
synced 2024-10-20 00:57:44 -04:00
eb703ee96e
Motivated by - https://github.com/open-goal/opengoal-vscode/pull/358 This addresses the following: - Fixes #2939 spam edge-case - Stop picking a different nREPL port based on the game mode by default, this causes friction for tools in the average usecase (having a REPL open for a single game, and wanting to connect to it). `goalc` spins up fine even if the port is already bound to. - For people that need/want this behaviour, adding per-game configuration to the `repl-config.json` is on my todo list. - Allows `goalc` to permit redefining symbols, including functions. This is defaulted to off via the `repl-config.json` but it allows you to for example, change the definition of a function without having to restart and rebuild the entire game.  - Updates the welcome message to include a bunch of useful metadata up-front. Cleaned up all the startup logs that appear when starting goalc, many of whom's information is now included in the welcome message. - Before:  - After: 
108 lines
2.7 KiB
C++
108 lines
2.7 KiB
C++
// clang-format off
|
|
#include "XSocketServer.h"
|
|
|
|
#include "common/cross_sockets/XSocket.h"
|
|
#include "common/common_types.h"
|
|
|
|
#include "fmt/core.h"
|
|
|
|
#ifdef _WIN32
|
|
#define NOMINMAX
|
|
#define WIN32_LEAN_AND_MEAN
|
|
#include <Windows.h>
|
|
#include <WinSock2.h>
|
|
#include <WS2tcpip.h>
|
|
#endif
|
|
#include "common/log/log.h"
|
|
// clang-format on
|
|
|
|
XSocketServer::XSocketServer(std::function<bool()> shutdown_callback,
|
|
int _tcp_port,
|
|
int _buffer_size)
|
|
: want_exit_callback(std::move(shutdown_callback)) {
|
|
tcp_port = _tcp_port;
|
|
buffer.resize(_buffer_size);
|
|
}
|
|
|
|
XSocketServer::~XSocketServer() {
|
|
if (listening_socket >= 0) {
|
|
close_server_socket();
|
|
}
|
|
}
|
|
|
|
void XSocketServer::shutdown_server() {
|
|
// Close the listening and accepted socket socket
|
|
close_server_socket();
|
|
}
|
|
|
|
bool XSocketServer::init_server(bool failure_may_occur) {
|
|
listening_socket = open_socket(AF_INET, SOCK_STREAM, 0);
|
|
if (listening_socket < 0) {
|
|
listening_socket = -1;
|
|
return false;
|
|
}
|
|
|
|
int yes = 1;
|
|
|
|
#ifdef OS_POSIX
|
|
if (set_socket_option(listening_socket, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes)) < 0) {
|
|
close_server_socket();
|
|
return false;
|
|
}
|
|
// macOS doesn't support setting multiple options at once, so we have to do this separately.
|
|
if (set_socket_option(listening_socket, SOL_SOCKET, SO_REUSEPORT, &yes, sizeof(yes)) < 0) {
|
|
close_server_socket();
|
|
return false;
|
|
}
|
|
#elif _WIN32
|
|
if (set_socket_option(listening_socket, SOL_SOCKET, SO_EXCLUSIVEADDRUSE, &yes, sizeof(yes)) < 0) {
|
|
close_server_socket();
|
|
return false;
|
|
};
|
|
#endif
|
|
|
|
if (set_socket_option(listening_socket, TCP_SOCKET_LEVEL, TCP_NODELAY, &yes, sizeof(yes)) < 0) {
|
|
close_server_socket();
|
|
return false;
|
|
}
|
|
|
|
if (set_socket_timeout(listening_socket, 100000) < 0) {
|
|
close_server_socket();
|
|
return false;
|
|
}
|
|
|
|
addr.sin_family = AF_INET;
|
|
addr.sin_addr.s_addr = INADDR_ANY;
|
|
addr.sin_port = htons(tcp_port);
|
|
|
|
if (bind(listening_socket, (sockaddr*)&addr, sizeof(addr)) < 0) {
|
|
if (failure_may_occur) {
|
|
lg::debug("[XSocketServer:{}] failed to bind", tcp_port);
|
|
} else {
|
|
lg::error("[XSocketServer:{}] failed to bind", tcp_port);
|
|
}
|
|
close_server_socket();
|
|
return false;
|
|
}
|
|
|
|
if (listen(listening_socket, 0) < 0) {
|
|
if (failure_may_occur) {
|
|
lg::debug("[XSocketServer:{}] failed to listen", tcp_port);
|
|
} else {
|
|
lg::error("[XSocketServer:{}] failed to listen", tcp_port);
|
|
}
|
|
close_server_socket();
|
|
return false;
|
|
}
|
|
|
|
server_initialized = true;
|
|
lg::debug("[XSocketServer:{}] initialized", tcp_port);
|
|
post_init();
|
|
return true;
|
|
}
|
|
|
|
void XSocketServer::close_server_socket() {
|
|
close_socket(listening_socket);
|
|
listening_socket = -1;
|
|
}
|