Function initSocketProgram

src/shared/sockethelpers.cpp:65–106

#ifndef LIBTAS_LIBRARY
bool initSocketProgram(pid_t fork_pid)
{
#ifdef __unix__
    const struct sockaddr_un addr = { AF_UNIX, SOCKET_FILENAME };
#elif defined(__APPLE__) && defined(__MACH__)
    const struct sockaddr_un addr = { sizeof(struct sockaddr_un), AF_UNIX, SOCKET_FILENAME };
#endif
    socket_fd = socket(AF_UNIX, SOCK_STREAM, 0);

    struct timespec tim = {0, 500L*1000L*1000L};

    const int MAX_RETRIES = 10;
    int retry = 0;

    nanosleep(&tim, NULL);
    while (connect(socket_fd, reinterpret_cast<const struct sockaddr*>(&addr),
                sizeof(struct sockaddr_un))) {
        std::cout << "Attempt " << retry + 1 << ": Couldn't connect to socket." << std::endl;
        retry++;
        if (retry < MAX_RETRIES) {
            nanosleep(&tim, NULL);
        } else {
            return false;
        }
        
        /* Check if game is still running */
        int ret = waitpid(fork_pid, nullptr, WNOHANG);
        if (ret == fork_pid) {
            std::cout << "Game couldn't start properly." << std::endl;
            return false;
        }
        
        tim.tv_nsec *= 1.5;
        if (tim.tv_nsec >= 1000000000) {            
            tim.tv_sec++;
            tim.tv_nsec -= 1000000000;
        }
    }
    std::cout << "Attempt " << retry + 1 << ": Connected." << std::endl;

    return true;
}

#else