float linear_start = 0.00085f,

float linear_end = 0.0120,

int timesteps = TIMESTEPS) {

float ls_sqrt = sqrtf(linear_start);

float le_sqrt = sqrtf(linear_end);

float amount = le_sqrt - ls_sqrt;

float product = 1.0f;

for (int i = 0; i < timesteps; i++) {

float beta = ls_sqrt + amount * ((float)i / (timesteps - 1));

product *= 1.0f - powf(beta, 2.0f);

alphas_cumprod[i] = product;

}

ggml_backend_t backend = NULL; // general backend

ggml_backend_t clip_backend = NULL;

ggml_backend_t control_net_backend = NULL;

ggml_backend_t vae_backend = NULL;

ggml_type model_wtype = GGML_TYPE_COUNT;

ggml_type conditioner_wtype = GGML_TYPE_COUNT;

ggml_type diffusion_model_wtype = GGML_TYPE_COUNT;

ggml_type vae_wtype = GGML_TYPE_COUNT;

SDVersion version;

bool vae_decode_only = false;

bool free_params_immediately = false;

std::shared_ptr<RNG> rng = std::make_shared<STDDefaultRNG>();

int n_threads = -1;

float scale_factor = 0.18215f;

std::shared_ptr<Conditioner> cond_stage_model;

std::shared_ptr<FrozenCLIPVisionEmbedder> clip_vision; // for svd

std::shared_ptr<DiffusionModel> diffusion_model;

std::shared_ptr<AutoEncoderKL> first_stage_model;

std::shared_ptr<TinyAutoEncoder> tae_first_stage;

std::shared_ptr<ControlNet> control_net;

std::shared_ptr<PhotoMakerIDEncoder> pmid_model;

std::shared_ptr<LoraModel> pmid_lora;

std::shared_ptr<PhotoMakerIDEmbed> pmid_id_embeds;

std::string taesd_path;

bool use_tiny_autoencoder = false;

bool vae_tiling = false;

bool stacked_id = false;

bool is_using_v_parameterization = false;

bool is_using_edm_v_parameterization = false;

std::map<std::string, struct ggml_tensor*> tensors;

std::string lora_model_dir;

// lora_name => multiplier

std::unordered_map<std::string, float> curr_lora_state;

std::shared_ptr<Denoiser> denoiser = std::make_shared<CompVisDenoiser>();

StableDiffusionGGML() = default;

~StableDiffusionGGML() {

if (clip_backend != backend) {

ggml_backend_free(clip_backend);

}

if (control_net_backend != backend) {

ggml_backend_free(control_net_backend);

}

if (vae_backend != backend) {

ggml_backend_free(vae_backend);

}

ggml_backend_free(backend);

}

void init_backend() {

#ifdef SD_USE_CUDA

LOG_DEBUG("Using CUDA backend");

backend = ggml_backend_cuda_init(0);

#endif

#ifdef SD_USE_METAL

LOG_DEBUG("Using Metal backend");

ggml_log_set(ggml_log_callback_default, nullptr);

backend = ggml_backend_metal_init();

#endif

#ifdef SD_USE_VULKAN

LOG_DEBUG("Using Vulkan backend");

for (int device = 0; device < ggml_backend_vk_get_device_count(); ++device) {

backend = ggml_backend_vk_init(device);

}

if (!backend) {

LOG_WARN("Failed to initialize Vulkan backend");

}

#endif

#ifdef SD_USE_OPENCL

LOG_DEBUG("Using OpenCL backend");

// ggml_log_set(ggml_log_callback_default, nullptr); // Optional ggml logs

backend = ggml_backend_opencl_init();

if (!backend) {

LOG_WARN("Failed to initialize OpenCL backend");

}

#endif

#ifdef SD_USE_SYCL

LOG_DEBUG("Using SYCL backend");

backend = ggml_backend_sycl_init(0);

#endif

if (!backend) {

LOG_DEBUG("Using CPU backend");

backend = ggml_backend_cpu_init();

}

}

bool init(const sd_ctx_params_t* sd_ctx_params) {

n_threads = sd_ctx_params->n_threads;

vae_decode_only = sd_ctx_params->vae_decode_only;

free_params_immediately = sd_ctx_params->free_params_immediately;

lora_model_dir = SAFE_STR(sd_ctx_params->lora_model_dir);

taesd_path = SAFE_STR(sd_ctx_params->taesd_path);

use_tiny_autoencoder = taesd_path.size() > 0;

vae_tiling = sd_ctx_params->vae_tiling;

if (sd_ctx_params->rng_type == STD_DEFAULT_RNG) {

rng = std::make_shared<STDDefaultRNG>();

} else if (sd_ctx_params->rng_type == CUDA_RNG) {

rng = std::make_shared<PhiloxRNG>();

}

init_backend();

ModelLoader model_loader;

if (strlen(SAFE_STR(sd_ctx_params->model_path)) > 0) {

LOG_INFO("loading model from '%s'", sd_ctx_params->model_path);

if (!model_loader.init_from_file(sd_ctx_params->model_path)) {

LOG_ERROR("init model loader from file failed: '%s'", sd_ctx_params->model_path);

}

}

if (strlen(SAFE_STR(sd_ctx_params->diffusion_model_path)) > 0) {

LOG_INFO("loading diffusion model from '%s'", sd_ctx_params->diffusion_model_path);

if (!model_loader.init_from_file(sd_ctx_params->diffusion_model_path, "model.diffusion_model.")) {

LOG_WARN("loading diffusion model from '%s' failed", sd_ctx_params->diffusion_model_path);

}

}

bool is_unet = model_loader.model_is_unet();

if (strlen(SAFE_STR(sd_ctx_params->clip_l_path)) > 0) {

LOG_INFO("loading clip_l from '%s'", sd_ctx_params->clip_l_path);

std::string prefix = is_unet ? "cond_stage_model.transformer." : "text_encoders.clip_l.transformer.";

if (!model_loader.init_from_file(sd_ctx_params->clip_l_path, prefix)) {

LOG_WARN("loading clip_l from '%s' failed", sd_ctx_params->clip_l_path);

}

}

if (strlen(SAFE_STR(sd_ctx_params->clip_g_path)) > 0) {

LOG_INFO("loading clip_g from '%s'", sd_ctx_params->clip_g_path);

std::string prefix = is_unet ? "cond_stage_model.1.transformer." : "text_encoders.clip_g.transformer.";

if (!model_loader.init_from_file(sd_ctx_params->clip_g_path, prefix)) {

LOG_WARN("loading clip_g from '%s' failed", sd_ctx_params->clip_g_path);

}

}

if (strlen(SAFE_STR(sd_ctx_params->t5xxl_path)) > 0) {

LOG_INFO("loading t5xxl from '%s'", sd_ctx_params->t5xxl_path);

if (!model_loader.init_from_file(sd_ctx_params->t5xxl_path, "text_encoders.t5xxl.transformer.")) {

LOG_WARN("loading t5xxl from '%s' failed", sd_ctx_params->t5xxl_path);

}

}

if (strlen(SAFE_STR(sd_ctx_params->vae_path)) > 0) {

LOG_INFO("loading vae from '%s'", sd_ctx_params->vae_path);

if (!model_loader.init_from_file(sd_ctx_params->vae_path, "vae.")) {

LOG_WARN("loading vae from '%s' failed", sd_ctx_params->vae_path);

}

}

version = model_loader.get_sd_version();

if (version == VERSION_COUNT) {

LOG_ERROR("get sd version from file failed: '%s'", SAFE_STR(sd_ctx_params->model_path));

return false;

}

LOG_INFO("Version: %s ", model_version_to_str[version]);

ggml_type wtype = (ggml_type)sd_ctx_params->wtype;

if (wtype == GGML_TYPE_COUNT) {

model_wtype = model_loader.get_sd_wtype();

if (model_wtype == GGML_TYPE_COUNT) {

model_wtype = GGML_TYPE_F32;

LOG_WARN("can not get mode wtype frome weight, use f32");

}

conditioner_wtype = model_loader.get_conditioner_wtype();

if (conditioner_wtype == GGML_TYPE_COUNT) {

conditioner_wtype = wtype;

}

diffusion_model_wtype = model_loader.get_diffusion_model_wtype();

if (diffusion_model_wtype == GGML_TYPE_COUNT) {

diffusion_model_wtype = wtype;

}

vae_wtype = model_loader.get_vae_wtype();

if (vae_wtype == GGML_TYPE_COUNT) {

vae_wtype = wtype;

}

} else {

model_wtype = wtype;

conditioner_wtype = wtype;

diffusion_model_wtype = wtype;

vae_wtype = wtype;

model_loader.set_wtype_override(wtype);

}

if (sd_version_is_sdxl(version)) {

vae_wtype = GGML_TYPE_F32;

model_loader.set_wtype_override(GGML_TYPE_F32, "vae.");

}

LOG_INFO("Weight type: %s", model_wtype != GGML_TYPE_COUNT ? ggml_type_name(model_wtype) : "??");

LOG_INFO("Conditioner weight type: %s", conditioner_wtype != GGML_TYPE_COUNT ? ggml_type_name(conditioner_wtype) : "??");

LOG_INFO("Diffusion model weight type: %s", diffusion_model_wtype != GGML_TYPE_COUNT ? ggml_type_name(diffusion_model_wtype) : "??");

LOG_INFO("VAE weight type: %s", vae_wtype != GGML_TYPE_COUNT ? ggml_type_name(vae_wtype) : "??");

LOG_DEBUG("ggml tensor size = %d bytes", (int)sizeof(ggml_tensor));

if (sd_version_is_sdxl(version)) {

scale_factor = 0.13025f;

if (strlen(SAFE_STR(sd_ctx_params->vae_path)) == 0 && strlen(SAFE_STR(sd_ctx_params->taesd_path)) == 0) {

LOG_WARN(

"!!!It looks like you are using SDXL model. "

"If you find that the generated images are completely black, "

"try specifying SDXL VAE FP16 Fix with the --vae parameter. "

"You can find it here: https://huggingface.co/madebyollin/sdxl-vae-fp16-fix/blob/main/sdxl_vae.safetensors");

}

} else if (sd_version_is_sd3(version)) {

scale_factor = 1.5305f;

} else if (sd_version_is_flux(version)) {

scale_factor = 0.3611;

// TODO: shift_factor

}

bool clip_on_cpu = sd_ctx_params->keep_clip_on_cpu;

if (version == VERSION_SVD) {

clip_vision = std::make_shared<FrozenCLIPVisionEmbedder>(backend, model_loader.tensor_storages_types);

clip_vision->alloc_params_buffer();

clip_vision->get_param_tensors(tensors);

diffusion_model = std::make_shared<UNetModel>(backend, model_loader.tensor_storages_types, version);

diffusion_model->alloc_params_buffer();

diffusion_model->get_param_tensors(tensors);

first_stage_model = std::make_shared<AutoEncoderKL>(backend, model_loader.tensor_storages_types, "first_stage_model", vae_decode_only, true, version);

LOG_DEBUG("vae_decode_only %d", vae_decode_only);

first_stage_model->alloc_params_buffer();

first_stage_model->get_param_tensors(tensors, "first_stage_model");

} else {

clip_backend = backend;

bool use_t5xxl = false;

if (sd_version_is_dit(version)) {

use_t5xxl = true;

}

if (!ggml_backend_is_cpu(backend) && use_t5xxl && conditioner_wtype != GGML_TYPE_F32) {

clip_on_cpu = true;

LOG_INFO("set clip_on_cpu to true");

}

if (clip_on_cpu && !ggml_backend_is_cpu(backend)) {

LOG_INFO("CLIP: Using CPU backend");

clip_backend = ggml_backend_cpu_init();

}

if (sd_ctx_params->diffusion_flash_attn) {

LOG_INFO("Using flash attention in the diffusion model");

}

if (sd_version_is_sd3(version)) {

if (sd_ctx_params->diffusion_flash_attn) {

LOG_WARN("flash attention in this diffusion model is currently unsupported!");

}

cond_stage_model = std::make_shared<SD3CLIPEmbedder>(clip_backend, model_loader.tensor_storages_types);

diffusion_model = std::make_shared<MMDiTModel>(backend, model_loader.tensor_storages_types);

} else if (sd_version_is_flux(version)) {

bool is_chroma = false;

for (auto pair : model_loader.tensor_storages_types) {

if (pair.first.find("distilled_guidance_layer.in_proj.weight") != std::string::npos) {

is_chroma = true;

break;

}

}

if (is_chroma) {

cond_stage_model = std::make_shared<PixArtCLIPEmbedder>(clip_backend,

model_loader.tensor_storages_types,

-1,

sd_ctx_params->chroma_use_t5_mask,

sd_ctx_params->chroma_t5_mask_pad);

} else {

cond_stage_model = std::make_shared<FluxCLIPEmbedder>(clip_backend, model_loader.tensor_storages_types);

}

diffusion_model = std::make_shared<FluxModel>(backend,

model_loader.tensor_storages_types,

version,

sd_ctx_params->diffusion_flash_attn,

sd_ctx_params->chroma_use_dit_mask);

} else {

if (strstr(SAFE_STR(sd_ctx_params->stacked_id_embed_dir), "v2")) {

cond_stage_model = std::make_shared<FrozenCLIPEmbedderWithCustomWords>(clip_backend,

model_loader.tensor_storages_types,

SAFE_STR(sd_ctx_params->embedding_dir),

version,

PM_VERSION_2);

} else {

cond_stage_model = std::make_shared<FrozenCLIPEmbedderWithCustomWords>(clip_backend,

model_loader.tensor_storages_types,

SAFE_STR(sd_ctx_params->embedding_dir),

version);

}

diffusion_model = std::make_shared<UNetModel>(backend,

model_loader.tensor_storages_types,

version,

sd_ctx_params->diffusion_flash_attn);

if (sd_ctx_params->diffusion_conv_direct) {

LOG_INFO("Using Conv2d direct in the diffusion model");

std::dynamic_pointer_cast<UNetModel>(diffusion_model)->unet.enable_conv2d_direct();

}

}

cond_stage_model->alloc_params_buffer();

cond_stage_model->get_param_tensors(tensors);

diffusion_model->alloc_params_buffer();

diffusion_model->get_param_tensors(tensors);

if (!use_tiny_autoencoder) {

if (sd_ctx_params->keep_vae_on_cpu && !ggml_backend_is_cpu(backend)) {

LOG_INFO("VAE Autoencoder: Using CPU backend");

vae_backend = ggml_backend_cpu_init();

} else {

vae_backend = backend;

}

first_stage_model = std::make_shared<AutoEncoderKL>(vae_backend,

model_loader.tensor_storages_types,

"first_stage_model",

vae_decode_only,

false,

version);

if (sd_ctx_params->vae_conv_direct) {

LOG_INFO("Using Conv2d direct in the vae model");

first_stage_model->enable_conv2d_direct();

}

first_stage_model->alloc_params_buffer();

first_stage_model->get_param_tensors(tensors, "first_stage_model");

} else {

tae_first_stage = std::make_shared<TinyAutoEncoder>(backend,

model_loader.tensor_storages_types,

"decoder.layers",

vae_decode_only,

version);

if (sd_ctx_params->vae_conv_direct) {

LOG_INFO("Using Conv2d direct in the tae model");

tae_first_stage->enable_conv2d_direct();

}

}

// first_stage_model->get_param_tensors(tensors, "first_stage_model.");

if (strlen(SAFE_STR(sd_ctx_params->control_net_path)) > 0) {

ggml_backend_t controlnet_backend = NULL;

if (sd_ctx_params->keep_control_net_on_cpu && !ggml_backend_is_cpu(backend)) {

LOG_DEBUG("ControlNet: Using CPU backend");

controlnet_backend = ggml_backend_cpu_init();

} else {

controlnet_backend = backend;

}

control_net = std::make_shared<ControlNet>(controlnet_backend, model_loader.tensor_storages_types, version);

if (sd_ctx_params->diffusion_conv_direct) {

LOG_INFO("Using Conv2d direct in the control net");

control_net->enable_conv2d_direct();

}

}

if (strstr(SAFE_STR(sd_ctx_params->stacked_id_embed_dir), "v2")) {

pmid_model = std::make_shared<PhotoMakerIDEncoder>(backend, model_loader.tensor_storages_types, "pmid", version, PM_VERSION_2);

LOG_INFO("using PhotoMaker Version 2");

} else {

pmid_model = std::make_shared<PhotoMakerIDEncoder>(backend, model_loader.tensor_storages_types, "pmid", version);

}

if (strlen(SAFE_STR(sd_ctx_params->stacked_id_embed_dir)) > 0) {

pmid_lora = std::make_shared<LoraModel>(backend, sd_ctx_params->stacked_id_embed_dir, "");

if (!pmid_lora->load_from_file(true)) {

LOG_WARN("load photomaker lora tensors from %s failed", sd_ctx_params->stacked_id_embed_dir);

return false;

}

LOG_INFO("loading stacked ID embedding (PHOTOMAKER) model file from '%s'", sd_ctx_params->stacked_id_embed_dir);

if (!model_loader.init_from_file(sd_ctx_params->stacked_id_embed_dir, "pmid.")) {

LOG_WARN("loading stacked ID embedding from '%s' failed", sd_ctx_params->stacked_id_embed_dir);

} else {

stacked_id = true;

}

}

if (stacked_id) {

if (!pmid_model->alloc_params_buffer()) {

LOG_ERROR(" pmid model params buffer allocation failed");

return false;

}

pmid_model->get_param_tensors(tensors, "pmid");

}

}

struct ggml_init_params params;

params.mem_size = static_cast<size_t>(10 * 1024) * 1024; // 10M

params.mem_buffer = NULL;

params.no_alloc = false;

// LOG_DEBUG("mem_size %u ", params.mem_size);

struct ggml_context* ctx = ggml_init(params); // for alphas_cumprod and is_using_v_parameterization check

GGML_ASSERT(ctx != NULL);

ggml_tensor* alphas_cumprod_tensor = ggml_new_tensor_1d(ctx, GGML_TYPE_F32, TIMESTEPS);

calculate_alphas_cumprod((float*)alphas_cumprod_tensor->data);

// load weights

LOG_DEBUG("loading weights");

int64_t t0 = ggml_time_ms();

std::set<std::string> ignore_tensors;

tensors["alphas_cumprod"] = alphas_cumprod_tensor;

if (use_tiny_autoencoder) {

ignore_tensors.insert("first_stage_model.");

}

if (stacked_id) {

ignore_tensors.insert("lora.");

}

if (vae_decode_only) {

ignore_tensors.insert("first_stage_model.encoder");

ignore_tensors.insert("first_stage_model.quant");

}

if (version == VERSION_SVD) {

ignore_tensors.insert("conditioner.embedders.3");

}

bool success = model_loader.load_tensors(tensors, backend, ignore_tensors);

if (!success) {

LOG_ERROR("load tensors from model loader failed");

ggml_free(ctx);

return false;

}

// LOG_DEBUG("model size = %.2fMB", total_size / 1024.0 / 1024.0);

if (version == VERSION_SVD) {

// diffusion_model->test();

// first_stage_model->test();

// return false;

} else {

size_t clip_params_mem_size = cond_stage_model->get_params_buffer_size();

size_t unet_params_mem_size = diffusion_model->get_params_buffer_size();

size_t vae_params_mem_size = 0;

if (!use_tiny_autoencoder) {

vae_params_mem_size = first_stage_model->get_params_buffer_size();

} else {

if (!tae_first_stage->load_from_file(taesd_path)) {

return false;

}

vae_params_mem_size = tae_first_stage->get_params_buffer_size();

}

size_t control_net_params_mem_size = 0;

if (control_net) {

if (!control_net->load_from_file(SAFE_STR(sd_ctx_params->control_net_path))) {

return false;

}

control_net_params_mem_size = control_net->get_params_buffer_size();

}

size_t pmid_params_mem_size = 0;

if (stacked_id) {

pmid_params_mem_size = pmid_model->get_params_buffer_size();

}

size_t total_params_ram_size = 0;

size_t total_params_vram_size = 0;

if (ggml_backend_is_cpu(clip_backend)) {

total_params_ram_size += clip_params_mem_size + pmid_params_mem_size;

} else {

total_params_vram_size += clip_params_mem_size + pmid_params_mem_size;

}

if (ggml_backend_is_cpu(backend)) {

total_params_ram_size += unet_params_mem_size;

} else {

total_params_vram_size += unet_params_mem_size;

}

if (ggml_backend_is_cpu(vae_backend)) {

total_params_ram_size += vae_params_mem_size;

} else {

total_params_vram_size += vae_params_mem_size;

}

if (ggml_backend_is_cpu(control_net_backend)) {

total_params_ram_size += control_net_params_mem_size;

} else {

total_params_vram_size += control_net_params_mem_size;

}

size_t total_params_size = total_params_ram_size + total_params_vram_size;

LOG_INFO(

"total params memory size = %.2fMB (VRAM %.2fMB, RAM %.2fMB): "

"clip %.2fMB(%s), unet %.2fMB(%s), vae %.2fMB(%s), controlnet %.2fMB(%s), pmid %.2fMB(%s)",

total_params_size / 1024.0 / 1024.0,

total_params_vram_size / 1024.0 / 1024.0,

total_params_ram_size / 1024.0 / 1024.0,

clip_params_mem_size / 1024.0 / 1024.0,

ggml_backend_is_cpu(clip_backend) ? "RAM" : "VRAM",

unet_params_mem_size / 1024.0 / 1024.0,

ggml_backend_is_cpu(backend) ? "RAM" : "VRAM",

vae_params_mem_size / 1024.0 / 1024.0,

ggml_backend_is_cpu(vae_backend) ? "RAM" : "VRAM",

control_net_params_mem_size / 1024.0 / 1024.0,

ggml_backend_is_cpu(control_net_backend) ? "RAM" : "VRAM",

pmid_params_mem_size / 1024.0 / 1024.0,

ggml_backend_is_cpu(clip_backend) ? "RAM" : "VRAM");

}

int64_t t1 = ggml_time_ms();

LOG_INFO("loading model from '%s' completed, taking %.2fs", SAFE_STR(sd_ctx_params->model_path), (t1 - t0) * 1.0f / 1000);

// check is_using_v_parameterization_for_sd2

if (sd_version_is_sd2(version)) {

if (is_using_v_parameterization_for_sd2(ctx, sd_version_is_inpaint(version))) {

is_using_v_parameterization = true;

}

} else if (sd_version_is_sdxl(version)) {

if (model_loader.tensor_storages_types.find("edm_vpred.sigma_max") != model_loader.tensor_storages_types.end()) {

// CosXL models

// TODO: get sigma_min and sigma_max values from file

is_using_edm_v_parameterization = true;

}

if (model_loader.tensor_storages_types.find("v_pred") != model_loader.tensor_storages_types.end()) {

is_using_v_parameterization = true;

}

} else if (version == VERSION_SVD) {

// TODO: V_PREDICTION_EDM

is_using_v_parameterization = true;

}

if (sd_version_is_sd3(version)) {

LOG_INFO("running in FLOW mode");

denoiser = std::make_shared<DiscreteFlowDenoiser>();

} else if (sd_version_is_flux(version)) {

LOG_INFO("running in Flux FLOW mode");

float shift = 1.0f; // TODO: validate

for (auto pair : model_loader.tensor_storages_types) {

if (pair.first.find("model.diffusion_model.guidance_in.in_layer.weight") != std::string::npos) {

shift = 1.15f;

break;

}

}

denoiser = std::make_shared<FluxFlowDenoiser>(shift);

} else if (is_using_v_parameterization) {

LOG_INFO("running in v-prediction mode");

denoiser = std::make_shared<CompVisVDenoiser>();

} else if (is_using_edm_v_parameterization) {

LOG_INFO("running in v-prediction EDM mode");

denoiser = std::make_shared<EDMVDenoiser>();

} else {

LOG_INFO("running in eps-prediction mode");

}

if (sd_ctx_params->schedule != DEFAULT) {

switch (sd_ctx_params->schedule) {

case DISCRETE:

LOG_INFO("running with discrete schedule");

denoiser->schedule = std::make_shared<DiscreteSchedule>();

break;

case KARRAS:

LOG_INFO("running with Karras schedule");

denoiser->schedule = std::make_shared<KarrasSchedule>();

break;

case EXPONENTIAL:

LOG_INFO("running exponential schedule");

denoiser->schedule = std::make_shared<ExponentialSchedule>();

break;

case AYS:

LOG_INFO("Running with Align-Your-Steps schedule");

denoiser->schedule = std::make_shared<AYSSchedule>();

denoiser->schedule->version = version;

break;

case GITS:

LOG_INFO("Running with GITS schedule");

denoiser->schedule = std::make_shared<GITSSchedule>();

denoiser->schedule->version = version;

break;

case DEFAULT:

// Don't touch anything.

break;

default:

LOG_ERROR("Unknown schedule %i", sd_ctx_params->schedule);

abort();

}

}

auto comp_vis_denoiser = std::dynamic_pointer_cast<CompVisDenoiser>(denoiser);

if (comp_vis_denoiser) {

for (int i = 0; i < TIMESTEPS; i++) {

comp_vis_denoiser->sigmas[i] = std::sqrt((1 - ((float*)alphas_cumprod_tensor->data)[i]) / ((float*)alphas_cumprod_tensor->data)[i]);

comp_vis_denoiser->log_sigmas[i] = std::log(comp_vis_denoiser->sigmas[i]);

}

}

LOG_DEBUG("finished loaded file");

ggml_free(ctx);

return true;

}

bool is_using_v_parameterization_for_sd2(ggml_context* work_ctx, bool is_inpaint = false) {

struct ggml_tensor* x_t = ggml_new_tensor_4d(work_ctx, GGML_TYPE_F32, 8, 8, 4, 1);

ggml_set_f32(x_t, 0.5);

struct ggml_tensor* c = ggml_new_tensor_4d(work_ctx, GGML_TYPE_F32, 1024, 2, 1, 1);

ggml_set_f32(c, 0.5);

struct ggml_tensor* timesteps = ggml_new_tensor_1d(work_ctx, GGML_TYPE_F32, 1);

ggml_set_f32(timesteps, 999);

struct ggml_tensor* concat = is_inpaint ? ggml_new_tensor_4d(work_ctx, GGML_TYPE_F32, 8, 8, 5, 1) : NULL;

if (concat != NULL) {

ggml_set_f32(concat, 0);

}

int64_t t0 = ggml_time_ms();

struct ggml_tensor* out = ggml_dup_tensor(work_ctx, x_t);

diffusion_model->compute(n_threads, x_t, timesteps, c, concat, NULL, NULL, {}, -1, {}, 0.f, &out);

diffusion_model->free_compute_buffer();

double result = 0.f;

{

float* vec_x = (float*)x_t->data;

float* vec_out = (float*)out->data;

int64_t n = ggml_nelements(out);

for (int i = 0; i < n; i++) {

result += ((double)vec_out[i] - (double)vec_x[i]);

}

result /= n;

}

int64_t t1 = ggml_time_ms();

LOG_DEBUG("check is_using_v_parameterization_for_sd2, taking %.2fs", (t1 - t0) * 1.0f / 1000);

return result < -1;

}

void apply_lora(const std::string& lora_name, float multiplier) {

int64_t t0 = ggml_time_ms();

std::string st_file_path = path_join(lora_model_dir, lora_name + ".safetensors");

std::string ckpt_file_path = path_join(lora_model_dir, lora_name + ".ckpt");

std::string file_path;

if (file_exists(st_file_path)) {

file_path = st_file_path;

} else if (file_exists(ckpt_file_path)) {

file_path = ckpt_file_path;

} else {

LOG_WARN("can not find %s or %s for lora %s", st_file_path.c_str(), ckpt_file_path.c_str(), lora_name.c_str());

return;

}

LoraModel lora(backend, file_path);

if (!lora.load_from_file()) {

LOG_WARN("load lora tensors from %s failed", file_path.c_str());

return;

}

lora.multiplier = multiplier;

// TODO: send version?

lora.apply(tensors, version, n_threads);

lora.free_params_buffer();

int64_t t1 = ggml_time_ms();

LOG_INFO("lora '%s' applied, taking %.2fs", lora_name.c_str(), (t1 - t0) * 1.0f / 1000);

}

void apply_loras(const std::unordered_map<std::string, float>& lora_state) {

if (lora_state.size() > 0 && model_wtype != GGML_TYPE_F16 && model_wtype != GGML_TYPE_F32) {

LOG_WARN("In quantized models when applying LoRA, the images have poor quality.");

}

std::unordered_map<std::string, float> lora_state_diff;

for (auto& kv : lora_state) {

const std::string& lora_name = kv.first;

float multiplier = kv.second;

lora_state_diff[lora_name] += multiplier;

}

for (auto& kv : curr_lora_state) {

const std::string& lora_name = kv.first;

float curr_multiplier = kv.second;

lora_state_diff[lora_name] -= curr_multiplier;

}

size_t rm = lora_state_diff.size() - lora_state.size();

if (rm != 0) {

LOG_INFO("Attempting to apply %lu LoRAs (removing %lu applied LoRAs)", lora_state.size(), rm);

} else {

LOG_INFO("Attempting to apply %lu LoRAs", lora_state.size());

}

for (auto& kv : lora_state_diff) {

apply_lora(kv.first, kv.second);

}

curr_lora_state = lora_state;

}

ggml_tensor* id_encoder(ggml_context* work_ctx,

ggml_tensor* init_img,

ggml_tensor* prompts_embeds,

ggml_tensor* id_embeds,

std::vector<bool>& class_tokens_mask) {

ggml_tensor* res = NULL;

pmid_model->compute(n_threads, init_img, prompts_embeds, id_embeds, class_tokens_mask, &res, work_ctx);

return res;

}

SDCondition get_svd_condition(ggml_context* work_ctx,

sd_image_t init_image,

int width,

int height,

int fps = 6,

int motion_bucket_id = 127,

float augmentation_level = 0.f,

bool force_zero_embeddings = false) {

// c_crossattn

int64_t t0 = ggml_time_ms();

struct ggml_tensor* c_crossattn = NULL;

{

if (force_zero_embeddings) {

c_crossattn = ggml_new_tensor_1d(work_ctx, GGML_TYPE_F32, clip_vision->vision_model.projection_dim);

ggml_set_f32(c_crossattn, 0.f);

} else {

sd_image_f32_t image = sd_image_t_to_sd_image_f32_t(init_image);

sd_image_f32_t resized_image = clip_preprocess(image, clip_vision->vision_model.image_size);

free(image.data);

image.data = NULL;

ggml_tensor* pixel_values = ggml_new_tensor_4d(work_ctx, GGML_TYPE_F32, resized_image.width, resized_image.height, 3, 1);

sd_image_f32_to_tensor(resized_image.data, pixel_values, false);

free(resized_image.data);

resized_image.data = NULL;

// print_ggml_tensor(pixel_values);

clip_vision->compute(n_threads, pixel_values, &c_crossattn, work_ctx);

// print_ggml_tensor(c_crossattn);

}

}

// c_concat

struct ggml_tensor* c_concat = NULL;

{

if (force_zero_embeddings) {

c_concat = ggml_new_tensor_4d(work_ctx, GGML_TYPE_F32, width / 8, height / 8, 4, 1);

ggml_set_f32(c_concat, 0.f);

} else {

ggml_tensor* init_img = ggml_new_tensor_4d(work_ctx, GGML_TYPE_F32, width, height, 3, 1);

if (width != init_image.width || height != init_image.height) {

sd_image_f32_t image = sd_image_t_to_sd_image_f32_t(init_image);

sd_image_f32_t resized_image = resize_sd_image_f32_t(image, width, height);

free(image.data);

image.data = NULL;

sd_image_f32_to_tensor(resized_image.data, init_img, false);

free(resized_image.data);

resized_image.data = NULL;

} else {

sd_image_to_tensor(init_image.data, init_img);

}

if (augmentation_level > 0.f) {

struct ggml_tensor* noise = ggml_dup_tensor(work_ctx, init_img);

ggml_tensor_set_f32_randn(noise, rng);

// encode_pixels += torch.randn_like(pixels) * augmentation_level

ggml_tensor_scale(noise, augmentation_level);

ggml_tensor_add(init_img, noise);

}

ggml_tensor* moments = encode_first_stage(work_ctx, init_img);

c_concat = get_first_stage_encoding(work_ctx, moments);

}

}

// y

struct ggml_tensor* y = NULL;

{

y = ggml_new_tensor_1d(work_ctx, GGML_TYPE_F32, diffusion_model->get_adm_in_channels());

int out_dim = 256;

int fps_id = fps - 1;

std::vector<float> timesteps = {(float)fps_id, (float)motion_bucket_id, augmentation_level};

set_timestep_embedding(timesteps, y, out_dim);

}

int64_t t1 = ggml_time_ms();

LOG_DEBUG("computing svd condition graph completed, taking %" PRId64 " ms", t1 - t0);

return {c_crossattn, y, c_concat};

}

ggml_tensor* sample(ggml_context* work_ctx,

ggml_tensor* init_latent,

ggml_tensor* noise,

SDCondition cond,

SDCondition uncond,

SDCondition img_cond,

ggml_tensor* control_hint,

float control_strength,

sd_guidance_params_t guidance,

float eta,

sample_method_t method,

const std::vector<float>& sigmas,

int start_merge_step,

SDCondition id_cond,

std::vector<ggml_tensor*> ref_latents = {},

ggml_tensor* denoise_mask = nullptr) {

std::vector<int> skip_layers(guidance.slg.layers, guidance.slg.layers + guidance.slg.layer_count);

float cfg_scale = guidance.txt_cfg;

float img_cfg_scale = guidance.img_cfg;

float slg_scale = guidance.slg.scale;

float min_cfg = guidance.min_cfg;

if (img_cfg_scale != cfg_scale && !sd_version_is_inpaint_or_unet_edit(version)) {

LOG_WARN("2-conditioning CFG is not supported with this model, disabling it for better performance...");

img_cfg_scale = cfg_scale;

}

LOG_DEBUG("Sample");

struct ggml_init_params params;

size_t data_size = ggml_row_size(init_latent->type, init_latent->ne[0]);

for (int i = 1; i < 4; i++) {

data_size *= init_latent->ne[i];

}

data_size += 1024;

params.mem_size = data_size * 3;

params.mem_buffer = NULL;

params.no_alloc = false;

ggml_context* tmp_ctx = ggml_init(params);

size_t steps = sigmas.size() - 1;

// noise = load_tensor_from_file(work_ctx, "./rand0.bin");

// print_ggml_tensor(noise);

struct ggml_tensor* x = ggml_dup_tensor(work_ctx, init_latent);

copy_ggml_tensor(x, init_latent);

x = denoiser->noise_scaling(sigmas[0], noise, x);

struct ggml_tensor* noised_input = ggml_dup_tensor(work_ctx, noise);

bool has_unconditioned = img_cfg_scale != 1.0 && uncond.c_crossattn != NULL;

bool has_img_cond = cfg_scale != img_cfg_scale && img_cond.c_crossattn != NULL;

bool has_skiplayer = slg_scale != 0.0 && skip_layers.size() > 0;

// denoise wrapper

struct ggml_tensor* out_cond = ggml_dup_tensor(work_ctx, x);

struct ggml_tensor* out_uncond = NULL;

struct ggml_tensor* out_skip = NULL;

struct ggml_tensor* out_img_cond = NULL;

if (has_unconditioned) {

out_uncond = ggml_dup_tensor(work_ctx, x);

}

if (has_skiplayer) {

if (sd_version_is_dit(version)) {

out_skip = ggml_dup_tensor(work_ctx, x);

} else {

has_skiplayer = false;

LOG_WARN("SLG is incompatible with %s models", model_version_to_str[version]);

}

}

if (has_img_cond) {

out_img_cond = ggml_dup_tensor(work_ctx, x);

}

struct ggml_tensor* denoised = ggml_dup_tensor(work_ctx, x);

auto denoise = [&](ggml_tensor* input, float sigma, int step) -> ggml_tensor* {

if (step == 1) {

pretty_progress(0, (int)steps, 0);

}

int64_t t0 = ggml_time_us();

std::vector<float> scaling = denoiser->get_scalings(sigma);

GGML_ASSERT(scaling.size() == 3);

float c_skip = scaling[0];

float c_out = scaling[1];

float c_in = scaling[2];

float t = denoiser->sigma_to_t(sigma);

std::vector<float> timesteps_vec(x->ne[3], t); // [N, ]

auto timesteps = vector_to_ggml_tensor(work_ctx, timesteps_vec);

std::vector<float> guidance_vec(x->ne[3], guidance.distilled_guidance);

auto guidance_tensor = vector_to_ggml_tensor(work_ctx, guidance_vec);

copy_ggml_tensor(noised_input, input);

// noised_input = noised_input * c_in

ggml_tensor_scale(noised_input, c_in);

std::vector<struct ggml_tensor*> controls;

if (control_hint != NULL) {

control_net->compute(n_threads, noised_input, control_hint, timesteps, cond.c_crossattn, cond.c_vector);

controls = control_net->controls;

// print_ggml_tensor(controls[12]);

// GGML_ASSERT(0);

}

if (start_merge_step == -1 || step <= start_merge_step) {

// cond

diffusion_model->compute(n_threads,

noised_input,

timesteps,

cond.c_crossattn,

cond.c_concat,

cond.c_vector,

guidance_tensor,

ref_latents,

-1,

controls,

control_strength,

&out_cond);

} else {

diffusion_model->compute(n_threads,

noised_input,

timesteps,

id_cond.c_crossattn,

cond.c_concat,

id_cond.c_vector,

guidance_tensor,

ref_latents,

-1,

controls,

control_strength,

&out_cond);

}

float* negative_data = NULL;

if (has_unconditioned) {

// uncond

if (control_hint != NULL) {

control_net->compute(n_threads, noised_input, control_hint, timesteps, uncond.c_crossattn, uncond.c_vector);

controls = control_net->controls;

}

diffusion_model->compute(n_threads,

noised_input,

timesteps,

uncond.c_crossattn,

uncond.c_concat,

uncond.c_vector,