Function yaml_write_atomic

src/cli/config_yaml_edit.c:846–965

}

static int yaml_write_atomic(const char *path, const char *data, size_t len,
                             const char *expected_data, size_t expected_len,
                             const yaml_file_snapshot_t *expected_snapshot) {
    size_t path_len = 0U;
    if (yaml_bounded_strlen(path, YAML_OUTPUT_MAX, &path_len) != 0 ||
        path_len > SIZE_MAX - YAML_TMP_SUFFIX_MAX - YAML_UNIT) {
        return YAML_ERROR;
    }
    size_t capacity = path_len + YAML_TMP_SUFFIX_MAX + YAML_UNIT;
    char *temp_path = (char *)malloc(capacity);
    if (!temp_path) {
        return YAML_ERROR;
    }

    FILE *file = NULL;
    for (unsigned attempt = 0U; attempt < YAML_TMP_ATTEMPTS; attempt++) {
        unsigned sequence =
            atomic_fetch_add_explicit(&yaml_temp_sequence, YAML_UNIT, memory_order_relaxed);
        int written = snprintf(temp_path, capacity, "%s.cbm-yaml-%ld-%u.tmp", path,
                               (long)YAML_PROCESS_ID(), sequence);
        if (written < 0 || (size_t)written >= capacity) {
            free(temp_path);
            return YAML_ERROR;
        }
        errno = 0;
#ifdef _WIN32
        file = cbm_fopen(temp_path, "wbx");
#else
        int flags = O_WRONLY | O_CREAT | O_EXCL | O_NOFOLLOW;
#ifdef O_CLOEXEC
        flags |= O_CLOEXEC;
#endif
        int descriptor = open(temp_path, flags, YAML_NEW_FILE_MODE);
        if (descriptor >= 0) {
            file = fdopen(descriptor, "wb");
            if (!file) {
                (void)close(descriptor);
                (void)cbm_unlink(temp_path);
                free(temp_path);
                return YAML_ERROR;
            }
        }
#endif
        if (file) {
            break;
        }
        if (errno != EEXIST) {
            free(temp_path);
            return YAML_ERROR;
        }
    }
    if (!file) {
        free(temp_path);
        return YAML_ERROR;
    }

    bool failed = fwrite(data, YAML_UNIT, len, file) != len;
    if (!failed && fflush(file) != 0) {