liubin/icebergs
1
0
Fork 0
forked from x/icebergs
Code Pull Requests Activity

fix ice.MSG_DAEMON

Browse Source
This commit is contained in:
IT 老营长 @云轩领航-创始人 2024-01-05 13:02:15 +08:00
parent 97bcf318c6
commit 1f86d5716d
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
base/web/space.go
View File

@ -185,8 +185,11 @@ func _space_exec(m *ice.Message, name string, source, target []string, c *websoc
)
m.Push(mdb.LINK, m.MergePod(kit.Select("", source, -1)))
default:
m.Options("__target", kit.Reverse(kit.Simple(source))).OptionDefault(ice.MSG_COUNT, "0")
m.Option(ice.MSG_DAEMON, kit.Keys(kit.Slice(kit.Simple(m.Optionv("__target")), 0, -1), m.Option(ice.MSG_DAEMON)))
if m.IsErr() {
return
}
m.OptionDefault(ice.MSG_COUNT, "0")
m.Option(ice.MSG_DAEMON, kit.Keys(kit.Slice(kit.Reverse(kit.Simple(source)), 0, -1), m.Option(ice.MSG_DAEMON)))
kit.If(aaa.Right(m, m.Detailv()), func() { m.TryCatch(true, func(_ *ice.Message) { m = m.Cmd() }) })
}
defer m.Cost(kit.Format("%v->%v %v %v", source, target, m.Detailv(), m.FormatSize()))

2
exec.go
View File

@ -156,7 +156,7 @@ func (m *Message) _command(arg ...Any) *Message {
}
}
}
if count := kit.Int(m.Option(MSG_COUNT, kit.Format(kit.Int(m.Option(MSG_COUNT))+1))); m.Warn(count > 3000, ErrTooDeepCount) {
if count := kit.Int(m.Option(MSG_COUNT, kit.Format(kit.Int(m.Option(MSG_COUNT))+1))); m.Warn(count > 300, ErrTooDeepCount) {
panic(count)
}
list := kit.Simple(args...)