Method Ipc

src/Ipc.cpp:388–502

}

Ipc::Ipc(string_view hostname) : mSocketFd{INVALID_SOCKET} {
    if (hostname.empty()) {
        if (!flatpakInfo() || flatpakInfo()->hasNetworkAccess()) {
            hostname = "127.0.0.1:14158";
        } else {
            hostname = "unix";
        }
    }

    try {
        fs::create_directories(runtimeDirectory());
    } catch (const fs::filesystem_error& e) {
        tlog::warning("Runtime directory {} does not exist and could not be created: {}", runtimeDirectory(), e.what());
    }

    mLockName = fmt::format(".tev.{}.lock", hostname);

    const auto parts = split(hostname, ":");
    if (parts.size() == 1 || (parts.size() == 2 && parts.back() == "unix")) {
        mHostInfo = UnixHost{.socketPath = runtimeDirectory() / fmt::format(".tev.{}.sock", parts.front())};
        tlog::debug("Initializing IPC on unix socket {}", this->hostname());
    } else if (parts.size() == 2) {
        mHostInfo = IpHost{.ip = string{parts.front()}, .port = string{parts.back()}};
        tlog::debug("Initializing IPC on IP host {}", this->hostname());
    } else {
        throw runtime_error{fmt::format("IPC hostname must not include more than one ':' symbol but is {}.", hostname)};
    }

    try {
        // Networking
#ifdef _WIN32
        // FIXME: only do this once if multiple Ipc objects are created.
        WSADATA wsaData;
        int wsaStartupResult = WSAStartup(MAKEWORD(2, 2), &wsaData);
        if (wsaStartupResult != NO_ERROR) {
            throw runtime_error{fmt::format("Could not initialize WSA: {}", errorString(wsaStartupResult))};
        }
#else
        // We don't care about getting a SIGPIPE if the display server goes away...
        signal(SIGPIPE, SIG_IGN);
#endif

        if (attemptToBecomePrimaryInstance()) {
            return;
        }

        // If we're not the primary instance, try to connect to it as a client

        struct addrinfo addrinfo = {}, *heapaddrinfo = nullptr;
        struct sockaddr_un unixAddr = {};

        visit(
            visitor{
                [&](const IpHost& ipHostInfo) {
                    addrinfo.ai_family = PF_UNSPEC;
                    addrinfo.ai_socktype = SOCK_STREAM;

                    const int err = getaddrinfo(ipHostInfo.ip.c_str(), ipHostInfo.port.c_str(), &addrinfo, &heapaddrinfo);