MetzNet
/
graphvent
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix

graph-rework-2
noah metz 2023-07-24 20:21:14 -06:00
parent 8e191543d6
commit 8c12eae3a7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
thread.go
Unescape Escape View File

@ -537,7 +537,7 @@ func ThreadStartChild(ctx *Context, node ThreadNode, signal GraphSignal) (string
thread := node.ThreadHandle() thread := node.ThreadHandle()
context := NewWriteContext(ctx) context := NewWriteContext(ctx)
return "wait", UpdateStates(context, thread, NewLockInfo(thread, []string{"children"}), func(context *StateContext) error { return "wait", UpdateStates(context, node, NewLockInfo(node, []string{"children"}), func(context *StateContext) error {
info, exists:= thread.Children[sig.ID] info, exists:= thread.Children[sig.ID]
if exists == false { if exists == false {
return fmt.Errorf("%s is not a child of %s", sig.ID, thread.ID()) return fmt.Errorf("%s is not a child of %s", sig.ID, thread.ID())
@ -561,8 +561,8 @@ func ThreadStartChild(ctx *Context, node ThreadNode, signal GraphSignal) (string
func ThreadRestore(ctx * Context, node ThreadNode, start bool) error { func ThreadRestore(ctx * Context, node ThreadNode, start bool) error {
thread := node.ThreadHandle() thread := node.ThreadHandle()
context := NewWriteContext(ctx) context := NewWriteContext(ctx)
return UpdateStates(context, thread, NewLockInfo(thread, []string{"children"}), func(context *StateContext) error { return UpdateStates(context, node, NewLockInfo(node, []string{"children"}), func(context *StateContext) error {
return UpdateStates(context, thread, LockList(thread.ChildList(), []string{"start"}), func(context *StateContext) error { return UpdateStates(context, node, LockList(thread.ChildList(), []string{"start"}), func(context *StateContext) error {
for _, info := range(thread.Children) { for _, info := range(thread.Children) {
parent_info := info.Infos["parent"].(*ParentThreadInfo) parent_info := info.Infos["parent"].(*ParentThreadInfo)
if parent_info.Start == true && info.Child.ThreadHandle().StateName != "finished" { if parent_info.Start == true && info.Child.ThreadHandle().StateName != "finished" {