QSLee-Net · pull · Nov 2, 2025 · Nov 2, 2025 · Nov 2, 2025
diff --git a/src/GraphCtrl/GraphElement/_GEngine/GDynamicEngine/GDynamicEngine.cpp b/src/GraphCtrl/GraphElement/_GEngine/GDynamicEngine/GDynamicEngine.cpp
@@ -28,7 +28,7 @@ CStatus GDynamicEngine::setup(const GSortedGElementPtrSet& elements) {
 
 
 CStatus GDynamicEngine::run() {
-    cur_status_.reset();
+    prepareRun();
 
     switch (dag_type_) {
         case internal::GEngineDagType::COMMON:
@@ -207,13 +207,6 @@ CVoid GDynamicEngine::fatWait() {
          */
         return (finished_end_size_ >= total_end_size_) || cur_status_.isErr();
     });
-
-    // 状态异常的情况下刷新所有element，避免错误的中间状态被带入下一次process
-    if (unlikely(cur_status_.isErr())) {
-        for (auto* element : total_element_arr_) {
-            element->refresh();
-        }
-    }
 }
 
 
@@ -307,4 +300,15 @@ CVoid GDynamicEngine::serialRunAll() {
     }
 }
 
+
+CVoid GDynamicEngine::prepareRun() {
+    if (unlikely(!cur_status_.isOK())) {
+        // 状态异常的情况下刷新所有element，避免错误的中间状态被带入下一次process
+        for (auto* element : total_element_arr_) {
+            element->refresh();
+        }
+        cur_status_.reset();
+    }
+}
+
 CGRAPH_NAMESPACE_END
diff --git a/src/GraphCtrl/GraphElement/_GEngine/GDynamicEngine/GDynamicEngine.h b/src/GraphCtrl/GraphElement/_GEngine/GDynamicEngine/GDynamicEngine.h
@@ -97,6 +97,12 @@ class GDynamicEngine : public GEngine {
      */
     CVoid serialRunAll();
 
+    /**
+     * 执行运行前的准备工作
+     * @return
+     */
+    CVoid prepareRun();
+
 private:
     GElementPtrArr total_element_arr_ {};                                                // pipeline中所有的元素信息集合
     GElementPtrArr front_element_arr_ {};                                                // 没有依赖的元素信息

diff --git a/src/GraphCtrl/GraphPipeline/_GStroage/GStorage.cpp b/src/GraphCtrl/GraphPipeline/_GStroage/GStorage.cpp
@@ -42,6 +42,11 @@ UREFL_CREATE_STRUCT_TRAIT_INFO(_GParamStorage,
     UREFL_DECLARE_FIELD(_GParamStorage, clz_name_, 2)
 )
 
+UREFL_CREATE_STRUCT_TRAIT_INFO(_GPassedParamStorage,
+    UREFL_DECLARE_FIELD(_GPassedParamStorage, key_, 1),
+    UREFL_DECLARE_FIELD(_GPassedParamStorage, clz_name_, 2)
+)
+
 UREFL_CREATE_STRUCT_TRAIT_INFO(_GElementStorage,
     UREFL_DECLARE_FIELD(_GElementStorage, name_, 1),
     UREFL_DECLARE_FIELD(_GElementStorage, loop_, 2),
@@ -57,7 +62,8 @@ UREFL_CREATE_STRUCT_TRAIT_INFO(_GElementStorage,
     UREFL_DECLARE_FIELD(_GElementStorage, belong_session_, 12),
     UREFL_DECLARE_FIELD(_GElementStorage, element_type_, 13),
     UREFL_DECLARE_FIELD(_GElementStorage, children_, 14),
-    UREFL_DECLARE_FIELD(_GElementStorage, aspect_storages_, 15)
+    UREFL_DECLARE_FIELD(_GElementStorage, aspect_storages_, 15),
+    UREFL_DECLARE_FIELD(_GElementStorage, eparam_storages_, 16)
 )
 
 UREFL_CREATE_STRUCT_TRAIT_INFO(UThreadPoolConfig,
@@ -266,6 +272,7 @@ CStatus GStorage::loadElement(GPipelinePtr pipeline, const _GPipelineStorage& st
         }
 
         status += loadAspect(element, cur.aspect_storages_);
+        status += loadEParam(element, cur.eparam_storages_);
         CGRAPH_FUNCTION_CHECK_STATUS
     }
 
@@ -386,6 +393,21 @@ CStatus GStorage::loadAspect(GElementPtr element, const std::vector<_GAspectStor
     CGRAPH_FUNCTION_END
 }
 
+
+CStatus GStorage::loadEParam(GElementPtr element, const std::vector<_GPassedParamStorage>& psdParamStorages) {
+    CGRAPH_FUNCTION_BEGIN
+    CGRAPH_ASSERT_NOT_NULL(element)
+
+    for (const auto& pps : psdParamStorages) {
+        GPassedParamPtr ep = dynamic_cast<GPassedParamPtr>(GStorageFactory::createByType(pps.clz_name_));
+        CGRAPH_RETURN_ERROR_STATUS_BY_CONDITION(!ep,
+                                                pps.clz_name_ + " type create passed param failed.");
+        element->local_params_[pps.key_] = ep;
+    }
+
+    CGRAPH_FUNCTION_END
+}
+
 CGRAPH_NAMESPACE_END
 
 #endif
diff --git a/src/GraphCtrl/GraphPipeline/_GStroage/GStorage.h b/src/GraphCtrl/GraphPipeline/_GStroage/GStorage.h
@@ -115,6 +115,14 @@ class GStorage : public GraphObject {
      */
     static CStatus loadAspect(GElementPtr element, const std::vector<_GAspectStorage>& aspStorages);
 
+    /**
+     * 加载 eparam 信息
+     * @param element
+     * @param psdParamStorages
+     * @return
+     */
+    static CStatus loadEParam(GElementPtr element, const std::vector<_GPassedParamStorage>& psdParamStorages);
+
     friend class GPipeline;
 };
 

diff --git a/src/GraphCtrl/GraphPipeline/_GStroage/GStorageDefine.h b/src/GraphCtrl/GraphPipeline/_GStroage/GStorageDefine.h
@@ -19,38 +19,38 @@
 
 CGRAPH_NAMESPACE_BEGIN
 
-struct _GEventStorage : public CStruct {
+struct _GStorageBasic : public CStruct {
+    std::string clz_name_ {};
+};
+
+struct _GEventStorage : public _GStorageBasic {
     explicit _GEventStorage() = default;
     explicit _GEventStorage(const std::string& key, const std::string& clz) {
         key_ = key;
         clz_name_ = clz;
     }
 
     std::string key_ {};
-    std::string clz_name_ {};
 };
 
-struct _GAspectStorage : public CStruct {
+struct _GAspectStorage : public _GStorageBasic {
     explicit _GAspectStorage() = default;
     explicit _GAspectStorage(const std::string& clz) {
         clz_name_ = clz;
     }
-
-    std::string clz_name_ {};
 };
 
-struct _GDaemonStorage : public CStruct {
+struct _GDaemonStorage : public _GStorageBasic {
     explicit _GDaemonStorage() = default;
     explicit _GDaemonStorage(CMSec msec, const std::string& clz) {
         msec_ = msec;
         clz_name_ = clz;
     }
 
     CMSec msec_ {0};
-    std::string clz_name_ {};
 };
 
-struct _GStageStorage : public CStruct {
+struct _GStageStorage : public _GStorageBasic {
     explicit _GStageStorage() = default;
     explicit _GStageStorage(const std::string& key, CInt threshold, const std::string& clz) {
         key_ = key;
@@ -60,23 +60,30 @@ struct _GStageStorage : public CStruct {
 
     std::string key_ {};
     CInt threshold_ {0};
-    std::string clz_name_ {};
 };
 
-struct _GParamStorage : public CStruct {
+struct _GParamStorage : public _GStorageBasic {
     explicit _GParamStorage() = default;
     explicit _GParamStorage(const std::string& key, CBool backtrace, const std::string& clz) {
         key_ = key;
         backtrace_ = backtrace;
-        clz_name_ = clz;
     }
 
     std::string key_ {};
-    std::string clz_name_ {};
     CBool backtrace_ { false };
 };
 
-struct _GElementStorage : public CStruct {
+struct _GPassedParamStorage : public _GStorageBasic {
+    explicit _GPassedParamStorage() = default;
+    explicit _GPassedParamStorage(const std::string& key, const std::string& clz) {
+        key_ = key;
+        clz_name_ = clz;
+    }
+
+    std::string key_ {};
+};
+
+struct _GElementStorage : public _GStorageBasic {
     std::string name_ {};
     CSize loop_ { CGRAPH_DEFAULT_LOOP_TIMES };
     std::string session_ {};
@@ -92,6 +99,7 @@ struct _GElementStorage : public CStruct {
     std::vector<std::string> dependence_sessions_ {};
     std::vector<_GElementStorage> children_ {};
     std::vector<_GAspectStorage> aspect_storages_ {};
+    std::vector<_GPassedParamStorage> eparam_storages_ {};
 
     explicit _GElementStorage() = default;
 
@@ -119,6 +127,9 @@ struct _GElementStorage : public CStruct {
                 aspect_storages_.emplace_back(typeid(*aspect).name());
             }
         }
+        for (const auto& lp : element->local_params_) {
+            eparam_storages_.emplace_back(lp.first, typeid(*(lp.second)).name());
+        }
     }
 
     /**

diff --git a/src/GraphCtrl/GraphPipeline/_GStroage/GStorageFactory.h b/src/GraphCtrl/GraphPipeline/_GStroage/GStorageFactory.h
@@ -21,6 +21,7 @@ class GParam;
 class GDaemon;
 class GStage;
 class GAspect;
+class GPassedParam;
 
 class GStorageFactory : public GraphObject {
 public:
@@ -31,11 +32,12 @@ class GStorageFactory : public GraphObject {
      */
     template<typename T,
             c_enable_if_t<std::is_base_of<GElement, T>::value
-                         || std::is_base_of<GParam, T>::value
-                         || std::is_base_of<GDaemon, T>::value
-                         || std::is_base_of<GAspect, T>::value
-                         || std::is_base_of<GStage, T>::value
-                         || std::is_base_of<GEvent, T>::value, int> = 0>
+                          || std::is_base_of<GParam, T>::value
+                          || std::is_base_of<GDaemon, T>::value
+                          || std::is_base_of<GAspect, T>::value
+                          || std::is_base_of<GStage, T>::value
+                          || std::is_base_of<GPassedParam, T>::value
+                          || std::is_base_of<GEvent, T>::value, int> = 0>
     static CVoid registerMetaType() {
         const char* key = typeid(T).name();
         meta_types_[key] = []() { return CAllocator::safeMallocCObject<T>(); };

diff --git a/tutorial/MyGNode/HelloCGraphNode.h b/tutorial/MyGNode/HelloCGraphNode.h
@@ -14,9 +14,8 @@
 class HelloCGraphNode : public CGraph::GNode {
 public:
     CStatus run() override {
-        CStatus status;
         std::cout << "Hello, CGraph." << std::endl;
-        return status;
+        return CStatus();
     }
 };