Mirror/Erupe
1
0
Fork 0
mirror of https://github.com/Mezeporta/Erupe.git synced 2025-12-13 07:25:03 +01:00
Code Issues Packages Projects Releases Wiki Activity

support printing non-blocking packets

Browse Source
This commit is contained in:
wish
2022-11-12 13:36:27 +11:00
parent 9fb8165be0
commit b73ddb8866
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/channelserver/sys_session.go
View File

@@ -116,10 +116,9 @@ func (s *Session) QueueSend(data []byte) {
func (s *Session) QueueSendNonBlocking(data []byte) { func (s *Session) QueueSendNonBlocking(data []byte) {
select { select {
case s.sendPackets <- packet{data, true}: case s.sendPackets <- packet{data, true}:
// Enqueued data s.logMessage(binary.BigEndian.Uint16(data[0:2]), data, "Server", s.Name)
default: default:
s.logger.Warn("Packet queue too full, dropping!") s.logger.Warn("Packet queue too full, dropping!")
// Queue too full
} }
} }