[pull] main from ChunelFeng:main

README.md

@@ -409,6 +409,9 @@ if __name__ == '__main__':
 * 优化 `message` 功能
 * 优化 `aspect` 功能
 
+[2025.10.06 - v3.2.0 - Chunel]
+* 提供 本地保存和加载 功能
+
 </details>
 
 ------------

src/CBasic/CBasicDefine.h

@@ -28,6 +28,7 @@ namespace internal {                                                    \
 CGRAPH_INTERNAL_NAMESPACE_BEGIN
 
 using CCHAR = char;
+using CUCHAR = unsigned char;
 using CUINT = unsigned int;
 using CVOID = void;
 using CINT = int;

src/CBasic/CValType.h

@@ -15,6 +15,8 @@
 
 using CChar = CGraph::internal::CCHAR;
 using CCharPtr = CGraph::internal::CCHAR *;
+using CUChar = CGraph::internal::CUCHAR;
+using CUCharPtr = CGraph::internal::CUCHAR *;
 using CUInt = CGraph::internal::CUINT;
 using CSize = CGraph::internal::CSIZE;
 using CVoid = CGraph::internal::CVOID;

src/GraphCtrl/GraphElement/GElement.h

@@ -504,6 +504,8 @@ class GElement : public GElementObject,
     friend class GSeparateOptimizer;
     friend class GElementRepository;
     friend class GPerf;
+    friend class _GElementStorage;
+    friend class GStorage;
 
     CGRAPH_DECLARE_GPARAM_MANAGER_WRAPPER_WITH_MEMBER
     CGRAPH_DECLARE_GEVENT_MANAGER_WRAPPER_WITH_MEMBER

src/GraphCtrl/GraphElement/GElementRepository.h

@@ -94,6 +94,7 @@ class GElementRepository : public GElementObject {
 
     friend class GPipeline;
     friend class GPerf;
+    friend class GStorage;
 };
 
 using GElementRepositoryPtr = GElementRepository *;

src/GraphCtrl/GraphElement/GGroup/GCluster/GCluster.h

@@ -29,6 +29,7 @@ class GCluster : public GGroup {
     friend class GPipeline;
     friend class GDynamicEngine;
     friend class CAllocator;
+    friend class GStorageFactory;
 };
 
 CGRAPH_NAMESPACE_END

src/GraphCtrl/GraphElement/GGroup/GCondition/GCondition.h

@@ -33,6 +33,7 @@ class GCondition : public GGroup {
     CBool isSeparate(GElementCPtr a, GElementCPtr b) const override;
 
     friend class GPipeline;
+    friend class GStorageFactory;
 };
 
 using GConditionPtr = GCondition *;

src/GraphCtrl/GraphElement/GGroup/GCondition/GMultiCondition.h

@@ -42,6 +42,7 @@ class GMultiCondition : public GCondition {
 
     friend class GPipeline;
     friend class CAllocator;
+    friend class GStorageFactory;
 };
 
 CGRAPH_NAMESPACE_END

src/GraphCtrl/GraphElement/GGroup/GGroup.h

@@ -80,6 +80,7 @@ class GGroup : public GElement {
     friend class GCondition;
     friend class GMutable;
     friend class GElementRepository;
+    friend class GStorage;
     template<GMultiConditionType> friend class GMultiCondition;
     template<CInt> friend class GSome;
 

src/GraphCtrl/GraphElement/GGroup/GMutable/GMutable.h

@@ -49,6 +49,7 @@ class GMutable : public GGroup {
 
     friend class GPipeline;
     friend class CAllocator;
+    friend class GStorageFactory;
 };
 
 using GMutablePtr = GMutable *;

src/GraphCtrl/GraphElement/GGroup/GRegion/GRegion.h

@@ -56,6 +56,7 @@ class GRegion : public GGroup {
 
     friend class GPipeline;
     friend class CAllocator;
+    friend class GStorageFactory;
     friend class GTrimOptimizer;
 };
 

src/GraphCtrl/GraphElement/GGroup/GSome/GSome.h

@@ -47,6 +47,7 @@ class GSome : public GGroup {
     friend class GPipeline;
     friend class GDynamicEngine;
     friend class CAllocator;
+    friend class GStorageFactory;
 };
 
 CGRAPH_NAMESPACE_END

src/GraphCtrl/GraphPipeline/GPipeline.cpp

@@ -8,6 +8,7 @@
 
 #include "GPipeline.h"
 #include "_GPerf/GPerfInclude.h"
+#include "_GStroage/GStorageInclude.h"
 #include "../GraphElement/_GOptimizer/GOptimizerInclude.h"
 
 CGRAPH_NAMESPACE_BEGIN
@@ -321,9 +322,44 @@ CBool GPipeline::checkSeparate(GElementPtr fst, GElementPtr snd) const {
 }
 
 
+CStatus GPipeline::save(const std::string& path) {
+    CGRAPH_FUNCTION_BEGIN
+    std::set<std::string> names;
+
+    // 不允许有同名的 element 被存储
+    for (const auto* element : repository_.elements_) {
+        CGRAPH_ASSERT_NOT_NULL(element)
+        CGRAPH_RETURN_ERROR_STATUS_BY_CONDITION(element->isGAdaptor(),
+                                                element->name_ + " is GAdaptor, cannot be saved.")
+        CGRAPH_RETURN_ERROR_STATUS_BY_CONDITION(names.find(element->name_) != names.end(),
+                                                element->name_ + " name is duplicated, cannot be saved.")
+        names.insert(element->name_);
+    }
+
+#if __cplusplus >= 201703L
+    status = GStorage::save(this, path);
+#else
+    status = CStatus("save function support cpp17+ only");
+#endif
+    CGRAPH_FUNCTION_END
+}
+
+
+CStatus GPipeline::load(const std::string& path) {
+    CGRAPH_FUNCTION_BEGIN
+#if __cplusplus >= 201703L
+    status = GStorage::load(this, path);
+#else
+    status = CStatus("load function support cpp17+ only");
+#endif
+
+    CGRAPH_FUNCTION_END
+}
+
+
 CStatus GPipeline::initEnv() {
     CGRAPH_FUNCTION_BEGIN
-    CGRAPH_ASSERT_NOT_NULL(event_manager_, element_manager_)
+    CGRAPH_ASSERT_NOT_NULL(event_manager_, element_manager_, stage_manager_)
 
     status = schedule_.init();
     CGRAPH_FUNCTION_CHECK_STATUS

src/GraphCtrl/GraphPipeline/GPipeline.h

@@ -18,6 +18,7 @@
 
 #include "GPipelineObject.h"
 #include "_GSchedule/GScheduleInclude.h"
+#include "_GStroage/GStorageInclude.h"
 #include "../GraphElement/GElementInclude.h"
 #include "../GraphDaemon/GDaemonInclude.h"
 #include "../GraphEvent/GEventInclude.h"
@@ -393,6 +394,20 @@ class GPipeline : public GPipelineObject,
      */
     CBool checkSeparate(GElementPtr fst, GElementPtr snd) const;
 
+    /**
+     * 存储当前 pipeline 信息到本地
+     * @param path
+     * @return
+     */
+    CStatus save(const std::string& path);
+
+    /**
+     * 从本地文件中加载 pipeline 信息
+     * @param path
+     * @return
+     */
+    CStatus load(const std::string& path);
+
     /**
      * 注册GParam 交互类集合
      * @return
@@ -437,6 +452,7 @@ class GPipeline : public GPipelineObject,
     friend class GPipelineFactory;
     friend class CAllocator;
     friend class GPerf;
+    friend class GStorage;
 
 public:
     CStatus __registerGElement_4py(GElementPtr element, const GElementPtrSet &depends,

src/GraphCtrl/GraphPipeline/GPipelineFactory.cpp

@@ -10,8 +10,8 @@
 
 CGRAPH_NAMESPACE_BEGIN
 
-GPipelinePtrList GPipelineFactory::s_pipeline_list_;
-std::mutex GPipelineFactory::s_lock_;
+GPipelinePtrList GPipelineFactory::s_pipeline_list_ {};
+std::mutex GPipelineFactory::s_lock_ {};
 
 GPipelinePtr GPipelineFactory::create() {
     CGRAPH_FUNCTION_BEGIN

src/GraphCtrl/GraphPipeline/GPipelineFactory.h

@@ -9,8 +9,9 @@
 #ifndef CGRAPH_GPIPELINEFACTORY_H
 #define CGRAPH_GPIPELINEFACTORY_H
 
-#include <list>
 #include <mutex>
+#include <list>
+#include <map>
 
 #include "GPipeline.h"
 #include "GPipelineObject.h"
@@ -38,7 +39,7 @@ class GPipelineFactory : public GPipelineObject {
     static CStatus clear();
 
 private:
-    static GPipelinePtrList s_pipeline_list_;    // 记录所有的
+    static GPipelinePtrList s_pipeline_list_;    // 记录所有的 pipeline 信息
     static std::mutex s_lock_;
 };
 

src/GraphCtrl/GraphPipeline/_GSchedule/GSchedule.h

@@ -46,6 +46,7 @@ class GSchedule : public GraphObject {
     internal::GScheduleType type_ = internal::GScheduleType::UNIQUE;      // 调度类型
 
     friend class GPipeline;
+    friend class GStorage;
 };
 
 CGRAPH_NAMESPACE_END