Buckets:
| /** | |
| * NeuroFlowMultiModal - 多模态类脑模块化神经网络 | |
| * | |
| * 整合: | |
| * 1. Vision Encoder (图像编码) | |
| * 2. Cross-Modal Fusion (文本-图像融合) | |
| * 3. ExecutiveControlNetwork (ECN) - 多模态推理决策 | |
| * 4. DefaultModeNetwork (DMN) - 跨模态联想记忆 | |
| * 5. SalienceNetwork (SN) - 多模态显著性分配 | |
| * 6. Memory Module - 长记忆存储 | |
| */ | |
| namespace neuroflow { | |
| /** | |
| * NeuroFlowMultiModal - 多模态类脑神经网络 | |
| */ | |
| class NeuroFlowMultiModal { | |
| public: | |
| // 配置 | |
| struct Config { | |
| size_t text_dim = 512; // 文本特征维度 | |
| size_t image_size = 224; // 图像大小 | |
| size_t patch_size = 16; // ViT patch大小 | |
| size_t vision_dim = 256; // 视觉编码维度 | |
| size_t fusion_dim = 256; // 融合维度 | |
| size_t hidden_dim = 256; // 隐藏维度 | |
| size_t output_dim = 10; // 输出维度 | |
| size_t memory_dim = 128; // 记忆维度 | |
| size_t memory_slots = 64; // 记忆槽数量 | |
| size_t num_layers = 2; // ECN层数 | |
| size_t num_associations = 8; // DMN联想头数量 | |
| size_t vision_layers = 4; // Vision Encoder层数 | |
| size_t vision_heads = 8; // Vision注意力头数 | |
| bool use_quantization = false; | |
| bool use_mla = false; | |
| size_t mla_latent_dim = 32; | |
| }; | |
| Config config; | |
| // ========== 多模态组件 ========== | |
| std::unique_ptr<VisionEncoder> vision_encoder; | |
| std::unique_ptr<CrossModalFusion> cross_modal_fusion; | |
| std::unique_ptr<MultiModalAttention> multimodal_attention; | |
| // ========== 类脑模块 ========== | |
| std::unique_ptr<ExecutiveControlNetwork> ecn; | |
| std::unique_ptr<DefaultModeNetwork> dmn; | |
| std::unique_ptr<SalienceNetwork> sn; | |
| std::unique_ptr<MemoryConsolidationModule> memory; | |
| std::unique_ptr<LatentKVCache> mla_cache; | |
| // ========== 输入投影 ========== | |
| std::shared_ptr<Linear> text_proj; | |
| std::shared_ptr<LayerNorm> text_norm; | |
| // ========== 融合后处理 ========== | |
| std::shared_ptr<Linear> multimodal_proj; | |
| std::shared_ptr<LayerNorm> multimodal_norm; | |
| // ========== 输出层 ========== | |
| std::shared_ptr<Linear> output_layer; | |
| std::shared_ptr<LayerNorm> output_norm; | |
| // ========== 流形投影 ========== | |
| std::shared_ptr<Linear> manifold_proj1; | |
| std::shared_ptr<LayerNorm> manifold_norm; | |
| std::shared_ptr<Linear> manifold_proj2; | |
| bool training_mode; | |
| NeuroFlowMultiModal(const Config& cfg) : config(cfg), training_mode(false) { | |
| // 多模态组件 | |
| vision_encoder = std::make_unique<VisionEncoder>( | |
| config.image_size, config.patch_size, | |
| config.vision_dim, config.vision_heads, config.vision_layers); | |
| cross_modal_fusion = std::make_unique<CrossModalFusion>( | |
| config.text_dim, config.vision_dim, config.fusion_dim); | |
| multimodal_attention = std::make_unique<MultiModalAttention>( | |
| config.fusion_dim, config.fusion_dim, 8); | |
| // 文本投影 | |
| text_proj = std::make_shared<Linear>(config.text_dim, config.hidden_dim); | |
| text_norm = std::make_shared<LayerNorm>(config.hidden_dim); | |
| // 多模态融合投影 | |
| multimodal_proj = std::make_shared<Linear>(config.fusion_dim, config.hidden_dim); | |
| multimodal_norm = std::make_shared<LayerNorm>(config.hidden_dim); | |
| // 类脑模块 (基于融合后的特征) | |
| ecn = std::make_unique<ExecutiveControlNetwork>( | |
| config.hidden_dim, config.hidden_dim, config.output_dim, config.num_layers); | |
| dmn = std::make_unique<DefaultModeNetwork>( | |
| config.memory_dim, config.hidden_dim / 2, config.num_associations); | |
| sn = std::make_unique<SalienceNetwork>( | |
| config.hidden_dim, config.hidden_dim / 2); | |
| memory = std::make_unique<MemoryConsolidationModule>( | |
| config.hidden_dim, config.memory_slots, config.memory_dim); | |
| if (config.use_mla) { | |
| mla_cache = std::make_unique<LatentKVCache>( | |
| config.hidden_dim, 8, config.mla_latent_dim, 4096); | |
| } | |
| // 输出层 | |
| output_layer = std::make_shared<Linear>(config.hidden_dim, config.output_dim); | |
| output_norm = std::make_shared<LayerNorm>(config.output_dim); | |
| // 流形投影 | |
| manifold_proj1 = std::make_shared<Linear>(config.hidden_dim, config.hidden_dim); | |
| manifold_norm = std::make_shared<LayerNorm>(config.hidden_dim); | |
| manifold_proj2 = std::make_shared<Linear>(config.hidden_dim, 32); | |
| if (config.use_quantization) { | |
| quantize(); | |
| } | |
| } | |
| NeuroFlowMultiModal() : NeuroFlowMultiModal(Config()) {} | |
| // ========== 输出结构 ========== | |
| struct Output { | |
| Tensor output; // 最终输出 | |
| Tensor decision; // ECN决策 | |
| Tensor value; // OFC价值 | |
| Tensor saliency; // SN显著性 | |
| Tensor text_image_sim; // 文本-图像相似度 | |
| Tensor gates; // ECN/DMN门控 | |
| Tensor anomaly; // 异常评分 | |
| Tensor retrieved_mem; // 检索记忆 | |
| Tensor manifold; // 流形表征 | |
| Tensor vision_feat; // 视觉特征 | |
| Tensor text_feat; // 文本特征 (对齐后) | |
| Tensor fused_feat; // 融合特征 | |
| }; | |
| // ========== 纯文本模式 ========== | |
| Output forward_text(const Tensor& text_input) { | |
| Output out; | |
| size_t batch = text_input.shape_[0]; | |
| // 文本投影 | |
| Tensor h = text_proj->forward(text_input); | |
| h = text_norm->forward(h); | |
| // 类脑处理 (纯文本模式) | |
| auto sn_out = sn->forward(h); | |
| auto ecn_out = ecn->forward(h); | |
| out.saliency = sn_out.saliency; | |
| out.gates = sn_out.gates; | |
| out.decision = ecn_out.decision; | |
| out.value = ecn_out.value; | |
| // 记忆 | |
| auto mem_out = memory->forward(h); | |
| out.retrieved_mem = mem_out.retrieved; | |
| // 输出 | |
| out.output = output_layer->forward(h); | |
| out.output = output_norm->forward(out.output); | |
| return out; | |
| } | |
| // ========== 多模态模式 (文本+图像) ========== | |
| Output forward_multimodal(const Tensor& text_input, const Tensor& image_input, | |
| bool consolidate = false, bool return_manifold = false) { | |
| Output out; | |
| size_t batch = text_input.shape_[0]; | |
| // 1. Vision Encoder: 图像编码 | |
| Tensor vision_feat = vision_encoder->forward(image_input); | |
| out.vision_feat = vision_feat.clone(); | |
| // 2. Cross-Modal Fusion: 文本-图像对齐融合 | |
| auto fusion_out = cross_modal_fusion->forward(text_input, vision_feat); | |
| out.text_feat = fusion_out.text_feat.clone(); | |
| out.text_image_sim = fusion_out.similarity.clone(); | |
| out.fused_feat = fusion_out.fused.clone(); | |
| // 3. 多模态融合投影 | |
| Tensor multimodal_h = multimodal_proj->forward(fusion_out.fused); | |
| multimodal_h = multimodal_norm->forward(multimodal_h); | |
| // 4. Cross-Modal Attention (可选增强) | |
| Tensor text_enhanced = multimodal_attention->text_attend_image( | |
| text_proj->forward(text_input), vision_feat); | |
| // 残差融合 | |
| float* mh = multimodal_h.as_fp32(); | |
| float* te = text_enhanced.as_fp32(); | |
| size_t min_dim = std::min(multimodal_h.shape_[1], text_enhanced.shape_[1]); | |
| for (size_t b = 0; b < batch; ++b) { | |
| for (size_t d = 0; d < min_dim; ++d) { | |
| mh[b * multimodal_h.shape_[1] + d] += 0.3f * te[b * text_enhanced.shape_[1] + d]; | |
| } | |
| } | |
| // 5. Salience Network: 多模态显著性检测 | |
| auto sn_out = sn->forward(multimodal_h); | |
| out.saliency = sn_out.saliency; | |
| out.gates = sn_out.gates; | |
| out.anomaly = sn_out.anomaly; | |
| // 提取门控 | |
| float* gates = out.gates.as_fp32(); | |
| Tensor ecn_gate({batch, 1}, QuantType::FP32); | |
| Tensor dmn_gate({batch, 1}, QuantType::FP32); | |
| for (size_t i = 0; i < batch; ++i) { | |
| ecn_gate.as_fp32()[i] = gates[i * 2]; | |
| dmn_gate.as_fp32()[i] = gates[i * 2 + 1]; | |
| } | |
| // 6. ECN: 多模态推理决策 (模拟前额叶整合视觉信息做决策) | |
| auto ecn_out = ecn->forward(multimodal_h); | |
| out.decision = ecn_out.decision; | |
| out.value = ecn_out.value; | |
| // 7. DMN: 跨模态联想记忆 (模拟后扣带回将视觉与记忆关联) | |
| Tensor mem_seed = memory->encode(multimodal_h); | |
| auto dmn_out = dmn->forward(mem_seed); | |
| // 8. Memory Retrieval | |
| auto mem_out = memory->forward(multimodal_h); | |
| out.retrieved_mem = mem_out.retrieved; | |
| if (consolidate) { | |
| memory->consolidate(multimodal_h); | |
| } | |
| // 9. 门控加权融合 | |
| Tensor ecn_weighted = out.decision.clone(); | |
| Tensor dmn_weighted = dmn_out.vision.reshape({batch, dmn_out.vision.shape_[1]}); | |
| float* eg = ecn_gate.as_fp32(); | |
| float* dg = dmn_gate.as_fp32(); | |
| float* ew = ecn_weighted.as_fp32(); | |
| float* dw = dmn_weighted.as_fp32(); | |
| for (size_t i = 0; i < batch; ++i) { | |
| for (size_t j = 0; j < config.output_dim && j < ecn_weighted.shape_[1]; ++j) { | |
| ew[i * ecn_weighted.shape_[1] + j] *= eg[i]; | |
| } | |
| for (size_t j = 0; j < dmn_weighted.shape_[1]; ++j) { | |
| dw[i * dmn_weighted.shape_[1] + j] *= dg[i]; | |
| } | |
| } | |
| // 10. 最终融合输出 | |
| // 综合ECN决策 + DMN联想 + Memory + 融合特征 | |
| Tensor combined({batch, config.hidden_dim}, QuantType::FP32); | |
| float* c = combined.as_fp32(); | |
| // 加权组合 | |
| for (size_t b = 0; b < batch; ++b) { | |
| for (size_t d = 0; d < config.hidden_dim; ++d) { | |
| float val = 0; | |
| if (d < out.decision.shape_[1]) { | |
| val += 0.3f * ew[b * out.decision.shape_[1] + d]; | |
| } | |
| if (d < dmn_weighted.shape_[1]) { | |
| val += 0.2f * dw[b * dmn_weighted.shape_[1] + d]; | |
| } | |
| if (d < out.retrieved_mem.shape_[1]) { | |
| val += 0.2f * out.retrieved_mem.as_fp32()[b * out.retrieved_mem.shape_[1] + d]; | |
| } | |
| if (d < multimodal_h.shape_[1]) { | |
| val += 0.3f * mh[b * multimodal_h.shape_[1] + d]; | |
| } | |
| c[b * config.hidden_dim + d] = val; | |
| } | |
| } | |
| out.output = output_layer->forward(combined); | |
| out.output = output_norm->forward(out.output); | |
| // 11. 流形 (可选) | |
| if (return_manifold) { | |
| Tensor manifold_in({batch, config.hidden_dim}, QuantType::FP32); | |
| float* mi = manifold_in.as_fp32(); | |
| float* eh = ecn_out.hidden_states.back().as_fp32(); | |
| for (size_t i = 0; i < batch; ++i) { | |
| for (size_t j = 0; j < config.hidden_dim && j < ecn_out.hidden_states.back().shape_[1]; ++j) { | |
| mi[i * config.hidden_dim + j] = eh[i * ecn_out.hidden_states.back().shape_[1] + j]; | |
| } | |
| for (size_t j = ecn_out.hidden_states.back().shape_[1]; j < config.hidden_dim; ++j) { | |
| mi[i * config.hidden_dim + j] = 0; | |
| } | |
| } | |
| Tensor m = manifold_proj1->forward(manifold_in); | |
| m = manifold_norm->forward(m); | |
| TensorOps::gelu(m); | |
| out.manifold = manifold_proj2->forward(m); | |
| } | |
| return out; | |
| } | |
| // ========== 通用forward接口 ========== | |
| Output forward(const Tensor& text_input, const Tensor* image_input = nullptr, | |
| bool consolidate = false, bool return_manifold = false) { | |
| if (image_input) { | |
| return forward_multimodal(text_input, *image_input, consolidate, return_manifold); | |
| } else { | |
| return forward_text(text_input); | |
| } | |
| } | |
| // ========== 图像理解模式 (无文本,纯视觉推理) ========== | |
| Output forward_image_only(const Tensor& image_input) { | |
| Output out; | |
| size_t batch = image_input.shape_[0]; | |
| // Vision Encoder | |
| Tensor vision_feat = vision_encoder->forward(image_input); | |
| out.vision_feat = vision_feat.clone(); | |
| // 直接投影到隐藏层 | |
| Tensor h = multimodal_proj->forward(vision_feat); | |
| h = multimodal_norm->forward(h); | |
| // 类脑处理 (纯视觉决策) | |
| auto sn_out = sn->forward(h); | |
| auto ecn_out = ecn->forward(h); | |
| out.saliency = sn_out.saliency; | |
| out.gates = sn_out.gates; | |
| out.decision = ecn_out.decision; | |
| out.value = ecn_out.value; | |
| // 记忆 | |
| auto mem_out = memory->forward(h); | |
| out.retrieved_mem = mem_out.retrieved; | |
| // 输出 | |
| out.output = output_layer->forward(h); | |
| out.output = output_norm->forward(out.output); | |
| return out; | |
| } | |
| // ========== 设置训练模式 ========== | |
| void set_training(bool t) { | |
| training_mode = t; | |
| ecn->set_training(t); | |
| } | |
| // ========== 量化 ========== | |
| void quantize() { | |
| vision_encoder->quantize(); | |
| cross_modal_fusion->quantize(); | |
| multimodal_attention->quantize(); | |
| text_proj->quantize(); | |
| multimodal_proj->quantize(); | |
| output_layer->quantize(); | |
| manifold_proj1->quantize(); | |
| manifold_proj2->quantize(); | |
| ecn->quantize(); | |
| dmn->quantize(); | |
| sn->quantize(); | |
| memory->encode_proj->quantize(); | |
| memory->retrieve_proj->quantize(); | |
| memory->query_proj->quantize(); | |
| } | |
| // ========== 获取模型统计 ========== | |
| struct Stats { | |
| size_t total_params; | |
| size_t vision_params; | |
| size_t fusion_params; | |
| size_t brain_params; | |
| size_t memory_bytes; | |
| float quantization_ratio; | |
| }; | |
| Stats get_stats() { | |
| Stats s; | |
| s.total_params = 0; | |
| s.vision_params = 0; | |
| s.fusion_params = 0; | |
| s.brain_params = 0; | |
| s.memory_bytes = 0; | |
| s.quantization_ratio = 0.0f; | |
| auto count_linear = [&](std::shared_ptr<Linear>& l, size_t& category) { | |
| s.total_params += l->weight.numel(); | |
| if (l->bias.data_) s.total_params += l->bias.numel(); | |
| category += l->weight.numel(); | |
| s.memory_bytes += l->weight.data_size_ + l->bias.data_size_; | |
| }; | |
| // Vision Encoder | |
| count_linear(vision_encoder->patch_embed->proj, s.vision_params); | |
| for (auto& l : vision_encoder->self_attn_qkv) count_linear(l, s.vision_params); | |
| for (auto& l : vision_encoder->self_attn_proj) count_linear(l, s.vision_params); | |
| for (auto& l : vision_encoder->mlp_fc1) count_linear(l, s.vision_params); | |
| for (auto& l : vision_encoder->mlp_fc2) count_linear(l, s.vision_params); | |
| count_linear(vision_encoder->output_proj, s.vision_params); | |
| // Cross-Modal Fusion | |
| count_linear(cross_modal_fusion->text_proj, s.fusion_params); | |
| count_linear(cross_modal_fusion->image_proj, s.fusion_params); | |
| count_linear(cross_modal_fusion->fusion_layer, s.fusion_params); | |
| // Multi-Modal Attention | |
| count_linear(multimodal_attention->text_query, s.fusion_params); | |
| count_linear(multimodal_attention->image_key, s.fusion_params); | |
| count_linear(multimodal_attention->image_value, s.fusion_params); | |
| count_linear(multimodal_attention->text_output, s.fusion_params); | |
| count_linear(multimodal_attention->image_query, s.fusion_params); | |
| count_linear(multimodal_attention->text_key, s.fusion_params); | |
| count_linear(multimodal_attention->text_value, s.fusion_params); | |
| count_linear(multimodal_attention->image_output, s.fusion_params); | |
| // 类脑模块 | |
| count_linear(text_proj, s.brain_params); | |
| count_linear(multimodal_proj, s.brain_params); | |
| count_linear(output_layer, s.brain_params); | |
| count_linear(manifold_proj1, s.brain_params); | |
| count_linear(manifold_proj2, s.brain_params); | |
| for (auto& l : ecn->dlpfc_linear) count_linear(l, s.brain_params); | |
| count_linear(ecn->ofc1, s.brain_params); | |
| count_linear(ecn->ofc2, s.brain_params); | |
| count_linear(ecn->vmpfc1, s.brain_params); | |
| count_linear(ecn->vmpfc2, s.brain_params); | |
| count_linear(dmn->mem_encoder1, s.brain_params); | |
| count_linear(dmn->mem_encoder2, s.brain_params); | |
| count_linear(dmn->future_proj1, s.brain_params); | |
| for (auto& [h1, h2] : dmn->association_heads) { | |
| count_linear(h1, s.brain_params); | |
| count_linear(h2, s.brain_params); | |
| } | |
| count_linear(sn->saliency1, s.brain_params); | |
| count_linear(sn->saliency2, s.brain_params); | |
| count_linear(sn->saliency3, s.brain_params); | |
| count_linear(sn->gate1, s.brain_params); | |
| count_linear(sn->gate2, s.brain_params); | |
| count_linear(sn->anomaly1, s.brain_params); | |
| count_linear(sn->anomaly2, s.brain_params); | |
| count_linear(memory->encode_proj, s.brain_params); | |
| count_linear(memory->retrieve_proj, s.brain_params); | |
| count_linear(memory->query_proj, s.brain_params); | |
| s.memory_bytes += memory->memory_bank.data_size_; | |
| s.total_params += memory->memory_bank.numel(); | |
| return s; | |
| } | |
| // ========== 序列化 ========== | |
| void save(const std::string& path) { | |
| std::ofstream ofs(path, std::ios::binary); | |
| if (!ofs) throw std::runtime_error("Cannot open file for save: " + path); | |
| // Magic header | |
| ofs.write("NFv1", 4); | |
| // Helper: serialize a named tensor | |
| auto save_tensor = [&](const std::string& name, const Tensor& t) { | |
| uint32_t name_len = name.size(); | |
| ofs.write(reinterpret_cast<const char*>(&name_len), 4); | |
| ofs.write(name.data(), name_len); | |
| uint32_t ndim = t.shape_.size(); | |
| ofs.write(reinterpret_cast<const char*>(&ndim), 4); | |
| for (auto d : t.shape_) { | |
| uint32_t dim = d; | |
| ofs.write(reinterpret_cast<const char*>(&dim), 4); | |
| } | |
| uint32_t dsize = t.data_size_; | |
| ofs.write(reinterpret_cast<const char*>(&dsize), 4); | |
| ofs.write(reinterpret_cast<const char*>(t.data_.get()), dsize); | |
| }; | |
| // Helper: save Linear layer (accepts shared_ptr or raw ref) | |
| auto save_linear = [&](const std::string& prefix, const std::shared_ptr<Linear>& layer) { | |
| save_tensor(prefix + ".weight", layer->weight); | |
| if (layer->bias.data_) save_tensor(prefix + ".bias", layer->bias); | |
| if (layer->weight_scale.data_) save_tensor(prefix + ".weight_scale", layer->weight_scale); | |
| }; | |
| auto save_linear_raw = [&](const std::string& prefix, const Linear& layer) { | |
| save_tensor(prefix + ".weight", layer.weight); | |
| if (layer.bias.data_) save_tensor(prefix + ".bias", layer.bias); | |
| if (layer.weight_scale.data_) save_tensor(prefix + ".weight_scale", layer.weight_scale); | |
| }; | |
| // Helper: save LayerNorm | |
| auto save_ln = [&](const std::string& prefix, const LayerNorm& ln) { | |
| save_tensor(prefix + ".weight", ln.weight); | |
| save_tensor(prefix + ".bias", ln.bias); | |
| }; | |
| // === 投影层 === | |
| save_linear_raw("text_proj", *text_proj); | |
| save_ln("text_norm", *text_norm); | |
| save_linear_raw("output_layer", *output_layer); | |
| save_ln("output_norm", *output_norm); | |
| // === 类脑网络 === | |
| save_linear("ecn.dlpfc0", ecn->dlpfc_linear[0]); | |
| save_linear("ecn.dlpfc1", ecn->dlpfc_linear[1]); | |
| save_linear("ecn.ofc1", ecn->ofc1); | |
| save_linear("ecn.ofc2", ecn->ofc2); | |
| save_linear("ecn.vmpfc1", ecn->vmpfc1); | |
| save_linear("ecn.vmpfc2", ecn->vmpfc2); | |
| save_linear("dmn.mem_encoder1", dmn->mem_encoder1); | |
| save_linear("dmn.mem_encoder2", dmn->mem_encoder2); | |
| save_linear("dmn.future_proj1", dmn->future_proj1); | |
| int head_idx = 0; | |
| for (auto& [h1, h2] : dmn->association_heads) { | |
| save_linear("dmn.head" + std::to_string(head_idx) + ".1", h1); | |
| save_linear("dmn.head" + std::to_string(head_idx) + ".2", h2); | |
| head_idx++; | |
| } | |
| save_linear("sn.saliency1", sn->saliency1); | |
| save_linear("sn.saliency2", sn->saliency2); | |
| save_linear("sn.saliency3", sn->saliency3); | |
| save_linear("sn.gate1", sn->gate1); | |
| save_linear("sn.gate2", sn->gate2); | |
| save_linear("sn.anomaly1", sn->anomaly1); | |
| save_linear("sn.anomaly2", sn->anomaly2); | |
| save_linear("memory.encode", memory->encode_proj); | |
| save_linear("memory.retrieve", memory->retrieve_proj); | |
| save_linear("memory.query_proj", memory->query_proj); | |
| save_tensor("memory.bank", memory->memory_bank); | |
| // End marker | |
| uint32_t zero = 0; | |
| ofs.write(reinterpret_cast<const char*>(&zero), 4); | |
| ofs.close(); | |
| } | |
| void load(const std::string& path) { | |
| std::ifstream ifs(path, std::ios::binary); | |
| if (!ifs) throw std::runtime_error("Cannot open file for load: " + path); | |
| // Magic header | |
| char magic[5] = {0}; | |
| ifs.read(magic, 4); | |
| if (std::string(magic) != "NFv1") throw std::runtime_error("Invalid model file"); | |
| // Helper: load a tensor and set its data | |
| auto load_tensor_data = [&](Tensor& t) { | |
| uint32_t ndim; | |
| ifs.read(reinterpret_cast<char*>(&ndim), 4); | |
| std::vector<size_t> shape(ndim); | |
| for (uint32_t i = 0; i < ndim; i++) { | |
| uint32_t d; | |
| ifs.read(reinterpret_cast<char*>(&d), 4); | |
| shape[i] = d; | |
| } | |
| uint32_t dsize; | |
| ifs.read(reinterpret_cast<char*>(&dsize), 4); | |
| // Only load if shapes match | |
| if (shape == t.shape_ && dsize == t.data_size_) { | |
| ifs.read(reinterpret_cast<char*>(t.data_.get()), dsize); | |
| } else if (shape != t.shape_) { | |
| // Skip mismatched data | |
| ifs.seekg(dsize, std::ios::cur); | |
| } | |
| }; | |
| // Read tensors | |
| while (ifs.good()) { | |
| uint32_t name_len; | |
| ifs.read(reinterpret_cast<char*>(&name_len), 4); | |
| if (name_len == 0 || !ifs) break; | |
| std::string name(name_len, '\0'); | |
| ifs.read(&name[0], name_len); | |
| // Match name to tensor | |
| if (name == "text_proj.weight") load_tensor_data(text_proj->weight); | |
| else if (name == "text_proj.bias") load_tensor_data(text_proj->bias); | |
| else if (name == "text_norm.weight") load_tensor_data(text_norm->weight); | |
| else if (name == "text_norm.bias") load_tensor_data(text_norm->bias); | |
| else if (name == "output_layer.weight") load_tensor_data(output_layer->weight); | |
| else if (name == "output_layer.bias") load_tensor_data(output_layer->bias); | |
| else if (name == "output_norm.weight") load_tensor_data(output_norm->weight); | |
| else if (name == "output_norm.bias") load_tensor_data(output_norm->bias); | |
| else if (name == "ecn.dlpfc0.weight") load_tensor_data(ecn->dlpfc_linear[0]->weight); | |
| else if (name == "ecn.dlpfc0.bias") load_tensor_data(ecn->dlpfc_linear[0]->bias); | |
| else if (name == "ecn.dlpfc1.weight") load_tensor_data(ecn->dlpfc_linear[1]->weight); | |
| else if (name == "ecn.dlpfc1.bias") load_tensor_data(ecn->dlpfc_linear[1]->bias); | |
| else if (name == "ecn.ofc1.weight") load_tensor_data(ecn->ofc1->weight); | |
| else if (name == "ecn.ofc1.bias") load_tensor_data(ecn->ofc1->bias); | |
| else if (name == "ecn.ofc2.weight") load_tensor_data(ecn->ofc2->weight); | |
| else if (name == "ecn.ofc2.bias") load_tensor_data(ecn->ofc2->bias); | |
| else if (name == "ecn.vmpfc1.weight") load_tensor_data(ecn->vmpfc1->weight); | |
| else if (name == "ecn.vmpfc1.bias") load_tensor_data(ecn->vmpfc1->bias); | |
| else if (name == "ecn.vmpfc2.weight") load_tensor_data(ecn->vmpfc2->weight); | |
| else if (name == "ecn.vmpfc2.bias") load_tensor_data(ecn->vmpfc2->bias); | |
| else if (name == "dmn.mem_encoder1.weight") load_tensor_data(dmn->mem_encoder1->weight); | |
| else if (name == "dmn.mem_encoder1.bias") load_tensor_data(dmn->mem_encoder1->bias); | |
| else if (name == "dmn.mem_encoder2.weight") load_tensor_data(dmn->mem_encoder2->weight); | |
| else if (name == "dmn.mem_encoder2.bias") load_tensor_data(dmn->mem_encoder2->bias); | |
| else if (name == "dmn.future_proj1.weight") load_tensor_data(dmn->future_proj1->weight); | |
| else if (name == "dmn.future_proj1.bias") load_tensor_data(dmn->future_proj1->bias); | |
| else if (name.find("dmn.head") == 0) { | |
| int idx = std::stoi(name.substr(9, name.find('.', 9) - 9)); | |
| bool is_h1 = (name[name.size()-1] == '1'); | |
| auto& [h1, h2] = dmn->association_heads[idx]; | |
| if (is_h1) load_tensor_data(h1->weight); | |
| else load_tensor_data(h2->weight); | |
| } | |
| else if (name == "sn.saliency1.weight") load_tensor_data(sn->saliency1->weight); | |
| else if (name == "sn.saliency1.bias") load_tensor_data(sn->saliency1->bias); | |
| else if (name == "sn.saliency2.weight") load_tensor_data(sn->saliency2->weight); | |
| else if (name == "sn.saliency2.bias") load_tensor_data(sn->saliency2->bias); | |
| else if (name == "sn.saliency3.weight") load_tensor_data(sn->saliency3->weight); | |
| else if (name == "sn.saliency3.bias") load_tensor_data(sn->saliency3->bias); | |
| else if (name == "sn.gate1.weight") load_tensor_data(sn->gate1->weight); | |
| else if (name == "sn.gate1.bias") load_tensor_data(sn->gate1->bias); | |
| else if (name == "sn.gate2.weight") load_tensor_data(sn->gate2->weight); | |
| else if (name == "sn.gate2.bias") load_tensor_data(sn->gate2->bias); | |
| else if (name == "sn.anomaly1.weight") load_tensor_data(sn->anomaly1->weight); | |
| else if (name == "sn.anomaly1.bias") load_tensor_data(sn->anomaly1->bias); | |
| else if (name == "sn.anomaly2.weight") load_tensor_data(sn->anomaly2->weight); | |
| else if (name == "sn.anomaly2.bias") load_tensor_data(sn->anomaly2->bias); | |
| else if (name == "memory.encode.weight") load_tensor_data(memory->encode_proj->weight); | |
| else if (name == "memory.encode.bias") load_tensor_data(memory->encode_proj->bias); | |
| else if (name == "memory.retrieve.weight") load_tensor_data(memory->retrieve_proj->weight); | |
| else if (name == "memory.retrieve.bias") load_tensor_data(memory->retrieve_proj->bias); | |
| else if (name == "memory.query_proj.weight") load_tensor_data(memory->query_proj->weight); | |
| else if (name == "memory.query_proj.bias") load_tensor_data(memory->query_proj->bias); | |
| else if (name == "memory.bank") load_tensor_data(memory->memory_bank); | |
| else { | |
| // Unknown tensor: skip | |
| uint32_t ndim; ifs.read(reinterpret_cast<char*>(&ndim), 4); | |
| for (uint32_t i = 0; i < ndim; i++) { uint32_t d; ifs.read(reinterpret_cast<char*>(&d), 4); } | |
| uint32_t dsize; ifs.read(reinterpret_cast<char*>(&dsize), 4); | |
| ifs.seekg(dsize, std::ios::cur); | |
| } | |
| } | |
| ifs.close(); | |
| } | |
| }; | |
| /** | |
| * NeuroFlowMultiModalLite - 超轻量多模态版 | |
| */ | |
| class NeuroFlowMultiModalLite : public NeuroFlowMultiModal { | |
| public: | |
| NeuroFlowMultiModalLite(size_t text_dim = 256, size_t image_size = 112) { | |
| Config cfg; | |
| cfg.text_dim = text_dim; | |
| cfg.image_size = image_size; | |
| cfg.patch_size = 8; | |
| cfg.vision_dim = 128; | |
| cfg.fusion_dim = 128; | |
| cfg.hidden_dim = 128; | |
| cfg.output_dim = 10; | |
| cfg.memory_dim = 64; | |
| cfg.memory_slots = 32; | |
| cfg.num_layers = 1; | |
| cfg.num_associations = 4; | |
| cfg.vision_layers = 2; | |
| cfg.vision_heads = 4; | |
| cfg.use_quantization = true; | |
| cfg.use_mla = true; | |
| cfg.mla_latent_dim = 32; | |
| // 需要重新初始化... | |
| } | |
| }; | |
| } // namespace neuroflow | |
Xet Storage Details
- Size:
- 29.7 kB
- Xet hash:
- 1a37310ca3a20fa7f3e3d6bce2f34522bfac079a163c22f20063fdf355f0d7b7
·
Xet efficiently stores files, intelligently splitting them into unique chunks and accelerating uploads and downloads. More info.