Method init

switch/source/server.cpp:396–448

}

void Server::init()
{
    serverShutdown.store(false);
    serverSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    if (serverSocket < 0) {
        Logging::error("Failed to create log server socket with error {}: {}", errno, strerror(errno));
        return;
    }

    // Without SO_REUSEADDR a quick relaunch while port 8000 is still in TIME_WAIT
    // makes bind() fail, silently killing both the /logs endpoints and the
    // wireless receiver with no user-visible reason.
    int reuse = 1;
    setsockopt(serverSocket, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse));

    struct sockaddr_in serverAddr;
    memset(&serverAddr, 0, sizeof(serverAddr));
    serverAddr.sin_family      = AF_INET;
    serverAddr.sin_port        = htons(SERVER_PORT);
    serverAddr.sin_addr.s_addr = gethostid();

    if (bind(serverSocket, (struct sockaddr*)&serverAddr, sizeof(serverAddr)) != 0) {
        Logging::error("Failed to bind log server to port {} with error {}", SERVER_PORT, errno);
        close(serverSocket);
        serverSocket = -1;
        return;
    }

    if (listen(serverSocket, 5) != 0) {
        Logging::error("Failed to listen on log server socket with error {}: {}", errno, strerror(errno));
        close(serverSocket);
        serverSocket = -1;
        return;
    }

    char ipStr[INET_ADDRSTRLEN];
    inet_ntop(AF_INET, &(serverAddr.sin_addr), ipStr, INET_ADDRSTRLEN);

    serverRunning.test_and_set();
    // Same priority/core as the FTP + copy workers; the accept loop is IO-bound.
    if (R_SUCCEEDED(threadCreate(&serverThread, networkLoop, nullptr, nullptr, 0x8000, 0x2C, -2)) && R_SUCCEEDED(threadStart(&serverThread))) {
        threadValid   = true;
        serverAddress = "http://" + std::string(ipStr) + ":" + std::to_string(SERVER_PORT);
        Logging::info("Log server listening on {}", serverAddress);
    }
    else {
        // Could not spawn the worker: nothing will accept connections, so leave
        // the address empty and free the socket.
        serverRunning.clear();
        close(serverSocket);
        serverSocket = -1;
    }
}

void Server::exit()
{