mirror of
https://github.com/open-goal/jak-project
synced 2026-06-10 12:55:45 -04:00
Tyler Wilding
7b6d732a77
* goalc: cleanup goalc's main method and add nrepl listener socket * deps: add standalone ASIO for sockets * lint: formatting * common: make a common interface for creating a server socket * goalc: setup new repl server * deps: remove asio * goalc: debug issues, nrepl is working again * git: rename files * attempt to fix linux function call * test * scripts: make the error message even more obvious.... * goalc: make suggested changes, still can't reconnect properly * game: pull out single-client logic from XSocketServer * nrepl: supports multiple clients and disconnection/reconnects * goalc: some minor fixes for tests * goalc: save repl history when the compiler reloads * common: add include for linux networking * a few small changes to fix tests * is it the assert? * change thread start order and add a print to an assert Co-authored-by: water <awaterford111445@gmail.com>
130 lines
2.9 KiB
C++
130 lines
2.9 KiB
C++
/*!
|
|
* @file xsocket.cpp
|
|
* Cross platform socket library used for the listener.
|
|
*/
|
|
|
|
#ifdef __linux
|
|
#include <sys/socket.h>
|
|
#include <netinet/tcp.h>
|
|
#include <unistd.h>
|
|
#elif _WIN32
|
|
#define WIN32_LEAN_AND_MEAN
|
|
#include <WinSock2.h>
|
|
#include <WS2tcpip.h>
|
|
#endif
|
|
#include <errno.h>
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
|
|
#include "third-party/fmt/core.h"
|
|
|
|
int open_socket(int af, int type, int protocol) {
|
|
#ifdef __linux
|
|
return socket(af, type, protocol);
|
|
#elif _WIN32
|
|
WSADATA wsaData = {0};
|
|
int iResult = 0;
|
|
// Initialize Winsock
|
|
iResult = WSAStartup(MAKEWORD(2, 2), &wsaData);
|
|
if (iResult != 0) {
|
|
printf("WSAStartup failed: %d\n", iResult);
|
|
return 1;
|
|
}
|
|
return socket(af, type, protocol);
|
|
#endif
|
|
}
|
|
|
|
#ifdef __linux
|
|
int accept_socket(int socket, sockaddr* addr, socklen_t* addrLen) {
|
|
return accept(socket, addr, addrLen);
|
|
}
|
|
#endif
|
|
|
|
#ifdef _WIN32
|
|
int accept_socket(int socket, sockaddr* addr, int* addrLen) {
|
|
WSADATA wsaData = {0};
|
|
int iResult = 0;
|
|
// Initialize Winsock
|
|
iResult = WSAStartup(MAKEWORD(2, 2), &wsaData);
|
|
if (iResult != 0) {
|
|
printf("WSAStartup failed: %d\n", iResult);
|
|
return 1;
|
|
}
|
|
return accept(socket, addr, addrLen);
|
|
}
|
|
#endif
|
|
|
|
void close_socket(int sock) {
|
|
if (sock < 0) {
|
|
return;
|
|
}
|
|
#ifdef __linux
|
|
close(sock);
|
|
#elif _WIN32
|
|
closesocket(sock);
|
|
WSACleanup();
|
|
#endif
|
|
}
|
|
|
|
int set_socket_option(int socket, int level, int optname, const void* optval, int optlen) {
|
|
int ret = setsockopt(socket, level, optname, (const char*)optval, optlen);
|
|
if (ret < 0) {
|
|
printf("Failed to setsockopt(%d, %d, %d, _, _) - Error: %s\n", socket, level, optname,
|
|
strerror(errno));
|
|
}
|
|
#ifdef _WIN32
|
|
if (ret < 0) {
|
|
int err = WSAGetLastError();
|
|
printf("WSAGetLastError: %d\n", err);
|
|
}
|
|
#endif
|
|
return ret;
|
|
}
|
|
|
|
int set_socket_timeout(int socket, long microSeconds) {
|
|
#ifdef __linux
|
|
struct timeval timeout = {};
|
|
timeout.tv_sec = 0;
|
|
timeout.tv_usec = microSeconds;
|
|
int ret = setsockopt(socket, SOL_SOCKET, SO_RCVTIMEO, (struct timeval*)&timeout, sizeof(timeout));
|
|
if (ret < 0) {
|
|
printf("Failed to setsockopt(%d, %d, %d, _, _) - Error: %s\n", socket, SOL_SOCKET, SO_RCVTIMEO,
|
|
strerror(errno));
|
|
}
|
|
return ret;
|
|
#elif _WIN32
|
|
DWORD timeout = microSeconds / 1000; // milliseconds
|
|
return set_socket_option(socket, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout));
|
|
#endif
|
|
}
|
|
|
|
int write_to_socket(int socket, const char* buf, int len) {
|
|
int bytes_wrote = 0;
|
|
#ifdef __linux
|
|
bytes_wrote = write(socket, buf, len);
|
|
#elif _WIN32
|
|
bytes_wrote = send(socket, buf, len, 0);
|
|
#endif
|
|
if (bytes_wrote < 0) {
|
|
fmt::print(stderr, "[XSocket:{}] Error writing to socket\n", socket);
|
|
}
|
|
return bytes_wrote;
|
|
}
|
|
|
|
int read_from_socket(int socket, char* buf, int len) {
|
|
#ifdef __linux
|
|
return read(socket, buf, len);
|
|
#elif _WIN32
|
|
return recv(socket, buf, len, 0);
|
|
#endif
|
|
}
|
|
|
|
bool socket_timed_out() {
|
|
#ifdef __linux
|
|
return errno == EAGAIN;
|
|
#elif _WIN32
|
|
auto err = WSAGetLastError();
|
|
return err == WSAETIMEDOUT;
|
|
#endif
|
|
}
|