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

opt some

Browse Source
This commit is contained in:
IT 老营长 @云轩领航-创始人 2023-02-26 00:27:49 +08:00
parent 00aea9d1c9
commit 85f3ab8503
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
base/web/broad.go
View File

@ -39,14 +39,14 @@ func _broad_serve(m *ice.Message, host, port string) {
} }
m.Logs(mdb.IMPORT, BROAD, string(buf[:n]), "from", from) m.Logs(mdb.IMPORT, BROAD, string(buf[:n]), "from", from)
msg := m.Spawn(buf[:n]) msg := m.Spawn(buf[:n])
if m.Cmd(BROAD, kit.Format("%s,%s", msg.Option(tcp.HOST), msg.Option(tcp.PORT))).Length() > 0 {
continue
}
if remote := _broad_addr(m, msg.Option(tcp.HOST), msg.Option(tcp.PORT)); remote != nil { if remote := _broad_addr(m, msg.Option(tcp.HOST), msg.Option(tcp.PORT)); remote != nil {
m.Cmd(BROAD, func(value ice.Maps) { m.Cmd(BROAD, func(value ice.Maps) {
m.Logs(mdb.EXPORT, BROAD, kit.Format(value), "to", kit.Format(remote)) m.Logs(mdb.EXPORT, BROAD, kit.Format(value), "to", kit.Format(remote))
s.WriteToUDP([]byte(m.Spawn(value).FormatMeta()), remote) s.WriteToUDP([]byte(m.Spawn(value).FormatMeta()), remote)
}) })
if m.Cmd(BROAD, kit.Format("%s,%s", msg.Option(tcp.HOST), msg.Option(tcp.PORT))).Length() > 0 {
continue
}
mdb.HashCreate(m, msg.OptionSimple(tcp.HOST, tcp.PORT)) mdb.HashCreate(m, msg.OptionSimple(tcp.HOST, tcp.PORT))
} }
} }