Leahnaya/wfc-server
1
0
Fork 0
mirror of https://github.com/WiiLink24/wfc-server.git synced 2026-07-19 09:19:00 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

GameStats: Log connections

Browse Source
This commit is contained in:
mkwcat 2024-02-06 20:04:19 -05:00
parent 1c0aa46524
commit 886230a0c8
No known key found for this signature in database
GPG Key ID: 7A505679CE9E7AA9
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
gamestats/main.go
View File

@ -96,11 +96,9 @@ func handleRequest(conn net.Conn) {
defer conn.Close()
moduleName := "GSTATS"
err := conn.(*net.TCPConn).SetKeepAlive(true)
if err != nil {
logging.Notice(moduleName, "Unable to set keepalive:", err.Error())
logging.Notice(session.ModuleName, "Unable to set keepalive:", err.Error())
}
// Send challenge
@ -115,12 +113,15 @@ func handleRequest(conn net.Conn) {
conn.Write(session.WriteBuffer)
session.WriteBuffer = []byte{}
logging.Notice(session.ModuleName, "Connection established from", conn.RemoteAddr())
// Here we go into the listening loop
for {
// TODO: Handle split packets
buffer := make([]byte, 1024)
n, err := bufio.NewReader(conn).Read(buffer)
if err != nil {
logging.Notice(session.ModuleName, "Connection lost:", err.Error())
return
}
@ -136,8 +137,8 @@ func handleRequest(conn net.Conn) {
commands, err := common.ParseGameSpyMessage(string(buffer[:n]))
if err != nil {
logging.Error(moduleName, "Error parsing message:", err.Error())
logging.Error(moduleName, "Raw data:", string(buffer[:n]))
logging.Error(session.ModuleName, "Error parsing message:", err.Error())
logging.Error(session.ModuleName, "Raw data:", string(buffer[:n]))
session.replyError(gpcm.ErrParse)
return
}