Mirror/Erupe
1
0
Fork 0
mirror of https://github.com/Mezeporta/Erupe.git synced 2025-12-14 16:04:38 +01:00
Code Issues Packages Projects Releases Wiki Activity

rewrite broadcast functions

Browse Source
This commit is contained in:
wish
2023-02-12 15:56:04 +11:00
parent 6897a03781
commit 67122eb908
2 changed files with 5 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
server/channelserver/sys_channel_server.go
View File

@@ -269,6 +269,8 @@ func (s *Server) manageSessions() {
// BroadcastMHF queues a MHFPacket to be sent to all sessions. // BroadcastMHF queues a MHFPacket to be sent to all sessions.
func (s *Server) BroadcastMHF(pkt mhfpacket.MHFPacket, ignoredSession *Session) { func (s *Server) BroadcastMHF(pkt mhfpacket.MHFPacket, ignoredSession *Session) {
// Broadcast the data. // Broadcast the data.
s.Lock()
defer s.Unlock()
for _, session := range s.sessions { for _, session := range s.sessions {
if session == ignoredSession { if session == ignoredSession {
continue continue
@@ -291,16 +293,7 @@ func (s *Server) WorldcastMHF(pkt mhfpacket.MHFPacket, ignoredSession *Session,
if c == ignoredChannel { if c == ignoredChannel {
continue continue
} }
for _, session := range c.sessions { c.BroadcastMHF(pkt, ignoredSession)
if session == ignoredSession {
continue
}
bf := byteframe.NewByteFrame()
bf.WriteUint16(uint16(pkt.Opcode()))
pkt.Build(bf, session.clientContext)
bf.WriteUint16(0x0010)
session.QueueSendNonBlocking(bf.Data())
}
} }
} }

2
server/channelserver/sys_stage.go
View File

@@ -72,6 +72,8 @@ func (s *Stage) BroadcastMHF(pkt mhfpacket.MHFPacket, ignoredSession *Session) {
s.Lock() s.Lock()
defer s.Unlock() defer s.Unlock()
// Broadcast the data. // Broadcast the data.
s.Lock()
defer s.Unlock()
for session := range s.clients { for session := range s.clients {
if session == ignoredSession { if session == ignoredSession {
continue continue