Function cbm_daemon_ipc_endpoint_new

src/daemon/ipc.c:869–925

}

cbm_daemon_ipc_endpoint_t *cbm_daemon_ipc_endpoint_new(const char *instance_key,
                                                       const char *runtime_parent) {
    if (!instance_key_valid(instance_key)) {
        return NULL;
    }
#ifdef __APPLE__
    const char *default_parent = "/private/tmp"; /* /tmp itself is a symlink on macOS. */
#else
    const char *default_parent = "/tmp";
#endif
    const char *requested_parent = runtime_parent ? runtime_parent : default_parent;
    char canonical_parent[CBM_DAEMON_IPC_PATH_CAP];
    if (!cbm_canonical_path(requested_parent, canonical_parent, sizeof(canonical_parent))) {
        return NULL;
    }
    const char *parent = canonical_parent;
    if (!runtime_parent_valid(parent)) {
        return NULL;
    }

    cbm_daemon_ipc_endpoint_t *endpoint = calloc(1, sizeof(*endpoint));
    if (!endpoint) {
        return NULL;
    }
    endpoint->dir_fd = -1;
    endpoint->runtime_dir =
        string_format("%s%s%s%lu", parent, parent[strlen(parent) - 1] == '/' ? "" : "/",
                      "cbm-daemon-", (unsigned long)geteuid());
    endpoint->socket_name = string_format("cbm-%s.sock", instance_key);
    endpoint->socket_anchor_name = string_format("cbm-%s.anc", instance_key);
    endpoint->socket_identity_name = string_format("cbm-%s.sock.identity", instance_key);
    endpoint->socket_pending_name = string_format("cbm-%s.sock.pending", instance_key);
    endpoint->lock_name = string_format("cbm-%s.lock", instance_key);
    endpoint->startup_v2_lock_name = string_format("cbm-%s.startup-v2.lock", instance_key);
    endpoint->lifetime_lock_name = string_format("cbm-%s.lifetime.lock", instance_key);
    if (!endpoint->runtime_dir || !endpoint->socket_name || !endpoint->socket_anchor_name ||
        !endpoint->socket_identity_name || !endpoint->socket_pending_name || !endpoint->lock_name ||
        !endpoint->startup_v2_lock_name || !endpoint->lifetime_lock_name ||
        !private_runtime_open(endpoint->runtime_dir, &endpoint->dir_fd, &endpoint->dir_device,
                              &endpoint->dir_inode)) {
        cbm_daemon_ipc_endpoint_free(endpoint);
        return NULL;
    }
    endpoint->address = string_format("%s/%s", endpoint->runtime_dir, endpoint->socket_name);
    endpoint->socket_anchor_address =
        string_format("%s/%s", endpoint->runtime_dir, endpoint->socket_anchor_name);
    struct sockaddr_un address;
    socklen_t address_length;
    if (!endpoint->address || !endpoint->socket_anchor_address ||
        strlen(endpoint->socket_anchor_name) >= POSIX_SOCKET_ANCHOR_NAME_CAP ||
        !unix_address_set(&address, endpoint->address, &address_length) ||
        !unix_address_set(&address, endpoint->socket_anchor_address, &address_length)) {
        cbm_daemon_ipc_endpoint_free(endpoint);
        return NULL;
    }
    return endpoint;
}