Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-04-14 21:17:29 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化蓝图

Browse Source
This commit is contained in:
boyce
2026-03-10 17:32:47 +08:00
parent e508c69fa0
commit f3acdc860c
2 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
util/blueprint/blueprint.go
View File

@@ -187,9 +187,12 @@ func (bm *Blueprint) Do(graphID int64, entranceID int64, args ...any) (Port_Arra
return nil, fmt.Errorf("can not find graph:%d", graphID) return nil, fmt.Errorf("can not find graph:%d", graphID)
} }
return graph.Do(entranceID, args...) clone := graph.Clone()
return clone.Do(entranceID, args...)
} }
func (bm *Blueprint) ReleaseGraph(graphID int64) { func (bm *Blueprint) ReleaseGraph(graphID int64) {
if graphID == 0 { if graphID == 0 {
return return

10
util/blueprint/graph.go
View File

@@ -18,6 +18,7 @@ type IGraph interface {
Release() Release()
GetGraphFileName() string GetGraphFileName() string
HotReload(newBaseGraph *baseGraph) HotReload(newBaseGraph *baseGraph)
Clone() IGraph
} }
type IBlueprintModule interface { type IBlueprintModule interface {
@@ -168,7 +169,7 @@ func (gr *Graph) Do(entranceID int64, args ...any) (Port_Array, error) {
if gr.globalVariables == nil { if gr.globalVariables == nil {
gr.globalVariables = map[string]IPort{} gr.globalVariables = map[string]IPort{}
}else { } else {
gr.globalVariables[ReturnVarial] = nil gr.globalVariables[ReturnVarial] = nil
} }
@@ -226,6 +227,11 @@ func (gr *Graph) HotReload(newBaseGraph *baseGraph) {
gr.baseGraph = newBaseGraph gr.baseGraph = newBaseGraph
} }
func (gr *Graph) GetGraphFileName() string{ func (gr *Graph) GetGraphFileName() string {
return gr.graphFileName return gr.graphFileName
} }
func (gr *Graph) Clone() IGraph {
cloneGr := *gr
return &cloneGr
}