From c4ec2efde5b4c6c30bac1db94ca0c78a5f0bdad5 Mon Sep 17 00:00:00 2001 From: wish Date: Sun, 5 Oct 2025 16:18:22 +1100 Subject: [PATCH] alpelo object system backport test commit --- server/channelserver/handlers.go | 1 - server/channelserver/handlers_stage.go | 2 +- server/channelserver/sys_channel_server.go | 38 ++++++++++------------ 3 files changed, 19 insertions(+), 22 deletions(-) diff --git a/server/channelserver/handlers.go b/server/channelserver/handlers.go index da357700d..fc5d67de0 100644 --- a/server/channelserver/handlers.go +++ b/server/channelserver/handlers.go @@ -183,7 +183,6 @@ func logoutPlayer(s *Session) { delete(s.server.sessions, s.rawConn) } s.rawConn.Close() - delete(s.server.objectIDs, s) s.server.Unlock() for _, stage := range s.server.stages { diff --git a/server/channelserver/handlers_stage.go b/server/channelserver/handlers_stage.go index eb59f2bcb..b9bcb5ccf 100644 --- a/server/channelserver/handlers_stage.go +++ b/server/channelserver/handlers_stage.go @@ -8,6 +8,7 @@ import ( "erupe-ce/common/byteframe" ps "erupe-ce/common/pascalstring" "erupe-ce/network/mhfpacket" + "go.uber.org/zap" ) @@ -64,7 +65,6 @@ func doStageTransfer(s *Session, ackHandle uint32, stageID string) { // Confirm the stage entry. doAckSimpleSucceed(s, ackHandle, []byte{0x00, 0x00, 0x00, 0x00}) - var temp mhfpacket.MHFPacket newNotif := byteframe.NewByteFrame() // Cast existing user data to new user diff --git a/server/channelserver/sys_channel_server.go b/server/channelserver/sys_channel_server.go index 16def7021..60dfcc773 100644 --- a/server/channelserver/sys_channel_server.go +++ b/server/channelserver/sys_channel_server.go @@ -38,18 +38,17 @@ type userBinaryPartID struct { // Server is a MHF channel server. type Server struct { sync.Mutex - Channels []*Server - ID uint16 - GlobalID string - IP string - Port uint16 - logger *zap.Logger - db *sqlx.DB - erupeConfig *_config.Config - acceptConns chan net.Conn - deleteConns chan net.Conn - sessions map[net.Conn]*Session - //objectIDs map[*Session]uint16 + Channels []*Server + ID uint16 + GlobalID string + IP string + Port uint16 + logger *zap.Logger + db *sqlx.DB + erupeConfig *_config.Config + acceptConns chan net.Conn + deleteConns chan net.Conn + sessions map[net.Conn]*Session listener net.Listener // Listener that is created when Server.Start is called. isShuttingDown bool @@ -148,14 +147,13 @@ func (s *Server) UpdateRavi(semaID uint32, index uint8, value uint32, update boo // NewServer creates a new Server type. func NewServer(config *Config) *Server { s := &Server{ - ID: config.ID, - logger: config.Logger, - db: config.DB, - erupeConfig: config.ErupeConfig, - acceptConns: make(chan net.Conn), - deleteConns: make(chan net.Conn), - sessions: make(map[net.Conn]*Session), - //objectIDs: make(map[*Session]uint16), + ID: config.ID, + logger: config.Logger, + db: config.DB, + erupeConfig: config.ErupeConfig, + acceptConns: make(chan net.Conn), + deleteConns: make(chan net.Conn), + sessions: make(map[net.Conn]*Session), stages: make(map[string]*Stage), userBinaryParts: make(map[userBinaryPartID][]byte), semaphore: make(map[string]*Semaphore),