x/icebergs
1
0
Fork 1
mirror of https://shylinux.com/x/icebergs synced 2025-04-26 09:34:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

add some

Browse Source
This commit is contained in:
IT 老营长 @云轩领航-创始人 2023-09-29 18:18:07 +08:00
parent 776dc32431
commit ce563e4fea
3 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
base/gdb/gdb.go
View File

@ -36,7 +36,10 @@ func (f *Frame) Start(m *ice.Message, arg ...string) {
} }
} }
} }
func (f *Frame) Close(m *ice.Message, arg ...string) { close(f.s) } func (f *Frame) Close(m *ice.Message, arg ...string) {
close(f.s)
kit.If(ice.Info.PidPath, func(p string) { os.Remove(p) })
}
func (f *Frame) listen(m *ice.Message, s int, arg ...string) { func (f *Frame) listen(m *ice.Message, s int, arg ...string) {
signal.Notify(f.s, syscall.Signal(s)) signal.Notify(f.s, syscall.Signal(s))
mdb.HashCreate(m, SIGNAL, s, arg) mdb.HashCreate(m, SIGNAL, s, arg)

2
base/web/dream.go
View File

@ -262,7 +262,7 @@ func init() {
gdb.Event(m, DREAM_STOP, arg) gdb.Event(m, DREAM_STOP, arg)
m.Cmd(SPACE, mdb.MODIFY, m.OptionSimple(mdb.NAME), mdb.STATUS, cli.STOP) m.Cmd(SPACE, mdb.MODIFY, m.OptionSimple(mdb.NAME), mdb.STATUS, cli.STOP)
m.Go(func() { m.Cmd(SPACE, m.Option(mdb.NAME), ice.EXIT) }) m.Go(func() { m.Cmd(SPACE, m.Option(mdb.NAME), ice.EXIT) })
m.Sleep30ms() m.Sleep300ms()
}}, }},
nfs.TRASH: {Hand: func(m *ice.Message, arg ...string) { nfs.TRASH: {Hand: func(m *ice.Message, arg ...string) {
gdb.Event(m, DREAM_TRASH, arg) gdb.Event(m, DREAM_TRASH, arg)

8
base/web/space.go
View File

@ -29,10 +29,6 @@ func _space_qrcode(m *ice.Message, dev string) {
func _space_dial(m *ice.Message, dev, name string, arg ...string) { func _space_dial(m *ice.Message, dev, name string, arg ...string) {
u := kit.ParseURL(kit.MergeURL2(strings.Replace(m.Cmdv(SPIDE, dev, CLIENT_ORIGIN), HTTP, "ws", 1), PP(SPACE), mdb.TYPE, ice.Info.NodeType, mdb.NAME, name, u := kit.ParseURL(kit.MergeURL2(strings.Replace(m.Cmdv(SPIDE, dev, CLIENT_ORIGIN), HTTP, "ws", 1), PP(SPACE), mdb.TYPE, ice.Info.NodeType, mdb.NAME, name,
nfs.MODULE, ice.Info.Make.Module, nfs.VERSION, ice.Info.Make.Versions(), arg)) nfs.MODULE, ice.Info.Make.Module, nfs.VERSION, ice.Info.Make.Versions(), arg))
m.Debug("what %v", m.Cmd(SPIDE, dev).FormatsMeta(nil))
m.Debug("what %v", u)
m.Debug("what %v", kit.Formats(m.Confv(SPIDE)))
m.Debug("what %v", m.Cmdv(SPIDE, dev, CLIENT_ORIGIN))
args := kit.SimpleKV("type,name,host,port", u.Scheme, dev, u.Hostname(), args := kit.SimpleKV("type,name,host,port", u.Scheme, dev, u.Hostname(),
kit.Select(kit.Select("443", "80", u.Scheme == "ws"), u.Port())) kit.Select(kit.Select("443", "80", u.Scheme == "ws"), u.Port()))
gdb.Go(m, func() { gdb.Go(m, func() {
@ -86,12 +82,10 @@ func _space_fork(m *ice.Message) {
} }
func _space_handle(m *ice.Message, safe bool, name string, c *websocket.Conn) { func _space_handle(m *ice.Message, safe bool, name string, c *websocket.Conn) {
defer m.Cost(SPACE, name) defer m.Cost(SPACE, name)
m.Debug("what %v", name)
m.Options(ice.MSG_USERROLE, "", mdb.TYPE, "", mdb.NAME, "", cli.DAEMON, "") m.Options(ice.MSG_USERROLE, "", mdb.TYPE, "", mdb.NAME, "", cli.DAEMON, "")
for { for {
_, b, e := c.ReadMessage() _, b, e := c.ReadMessage()
if e != nil { if e != nil {
m.Debug("what %v", e)
break break
} }
msg := m.Spawn(b) msg := m.Spawn(b)
@ -249,7 +243,7 @@ func init() {
mdb.REMOVE: {Hand: func(m *ice.Message, arg ...string) { mdb.REMOVE: {Hand: func(m *ice.Message, arg ...string) {
defer mdb.HashModifyDeferRemove(m, m.OptionSimple(mdb.NAME), mdb.STATUS, cli.STOP)() defer mdb.HashModifyDeferRemove(m, m.OptionSimple(mdb.NAME), mdb.STATUS, cli.STOP)()
m.Cmd("", m.Option(mdb.NAME), ice.EXIT) m.Cmd("", m.Option(mdb.NAME), ice.EXIT)
m.Sleep("1s") m.Sleep3s()
}}, }},
DOMAIN: {Hand: func(m *ice.Message, arg ...string) { m.Echo(_space_domain(m)) }}, DOMAIN: {Hand: func(m *ice.Message, arg ...string) { m.Echo(_space_domain(m)) }},
LOGIN: {Help: "授权", Hand: func(m *ice.Message, arg ...string) { LOGIN: {Help: "授权", Hand: func(m *ice.Message, arg ...string) {