[Code] QueryServConnection Global to Singleton Cleanup (#4938)

* [Code] QueryServConnection Global to Singleton Cleanup

* Fix missed file in PR

---------

Co-authored-by: Chris Miles <akkadius1@gmail.com>
This commit is contained in:
Alex King 2025-06-25 15:43:01 -04:00 committed by GitHub
parent 004e2ca63f
commit f304f9cc61
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 12 additions and 9 deletions

View File

@ -16,7 +16,6 @@
extern ZSList zoneserver_list; extern ZSList zoneserver_list;
extern ClientList client_list; extern ClientList client_list;
extern WorldGuildManager guild_mgr; extern WorldGuildManager guild_mgr;
extern QueryServConnection QSLink;
void callGetZoneList(Json::Value &response) void callGetZoneList(Json::Value &response)
{ {

View File

@ -94,7 +94,6 @@
ClientList client_list; ClientList client_list;
GroupLFPList LFPGroupList; GroupLFPList LFPGroupList;
ZSList zoneserver_list; ZSList zoneserver_list;
QueryServConnection QSLink;
LauncherList launcher_list; LauncherList launcher_list;
WorldEventScheduler event_scheduler; WorldEventScheduler event_scheduler;
volatile bool RunLoops = true; volatile bool RunLoops = true;
@ -269,7 +268,7 @@ int main(int argc, char **argv)
connection->Handle()->RemotePort(), connection->Handle()->RemotePort(),
connection->GetUUID()); connection->GetUUID());
QSLink.AddConnection(connection); QueryServConnection::Instance()->AddConnection(connection);
} }
); );
@ -280,7 +279,7 @@ int main(int argc, char **argv)
connection->GetUUID() connection->GetUUID()
); );
QSLink.RemoveConnection(connection); QueryServConnection::Instance()->RemoveConnection(connection);
} }
); );

View File

@ -15,6 +15,13 @@ public:
void HandleGenericMessage(uint16_t opcode, EQ::Net::Packet &p); void HandleGenericMessage(uint16_t opcode, EQ::Net::Packet &p);
void HandleLFGuildUpdateMessage(uint16_t opcode, EQ::Net::Packet &p); void HandleLFGuildUpdateMessage(uint16_t opcode, EQ::Net::Packet &p);
bool SendPacket(ServerPacket* pack); bool SendPacket(ServerPacket* pack);
static QueryServConnection* Instance()
{
static QueryServConnection instance;
return &instance;
}
private: private:
std::map<std::string, std::shared_ptr<EQ::Net::ServertalkServerConnection>> m_streams; std::map<std::string, std::shared_ptr<EQ::Net::ServertalkServerConnection>> m_streams;
std::unique_ptr<EQ::Timer> m_keepalive; std::unique_ptr<EQ::Timer> m_keepalive;

View File

@ -44,7 +44,6 @@ Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
extern uint32 numzones; extern uint32 numzones;
extern WebInterfaceList web_interface; extern WebInterfaceList web_interface;
extern ClientList client_list; extern ClientList client_list;
extern QueryServConnection QSLink;
volatile bool UCSServerAvailable_ = false; volatile bool UCSServerAvailable_ = false;
void CatchSignal(int sig_num); void CatchSignal(int sig_num);
@ -985,7 +984,7 @@ void ZSList::SendServerReload(ServerReload::Type type, uchar *packet)
EQEmuLogSys::Instance()->LoadLogDatabaseSettings(); EQEmuLogSys::Instance()->LoadLogDatabaseSettings();
player_event_logs.ReloadSettings(); player_event_logs.ReloadSettings();
UCSConnection::Instance()->SendPacket(&pack); UCSConnection::Instance()->SendPacket(&pack);
QSLink.SendPacket(&pack); QueryServConnection::Instance()->SendPacket(&pack);
} else if (type == ServerReload::Type::Tasks) { } else if (type == ServerReload::Type::Tasks) {
SharedTaskManager::Instance()->LoadTaskData(); SharedTaskManager::Instance()->LoadTaskData();
} else if (type == ServerReload::Type::DzTemplates) { } else if (type == ServerReload::Type::DzTemplates) {

View File

@ -57,7 +57,6 @@ extern GroupLFPList LFPGroupList;
extern ZSList zoneserver_list; extern ZSList zoneserver_list;
extern volatile bool RunLoops; extern volatile bool RunLoops;
extern volatile bool UCSServerAvailable_; extern volatile bool UCSServerAvailable_;
extern QueryServConnection QSLink;
void CatchSignal(int sig_num); void CatchSignal(int sig_num);
@ -372,7 +371,7 @@ void ZoneServer::HandleMessage(uint16 opcode, const EQ::Net::Packet &p) {
player_event_logs.AddToQueue(n.player_event_log); player_event_logs.AddToQueue(n.player_event_log);
} }
else { else {
QSLink.SendPacket(pack); QueryServConnection::Instance()->SendPacket(pack);
} }
// if discord enabled for event, ship to UCS to process // if discord enabled for event, ship to UCS to process
@ -1359,7 +1358,7 @@ void ZoneServer::HandleMessage(uint16 opcode, const EQ::Net::Packet &p) {
break; break;
} }
case ServerOP_QueryServGeneric: { case ServerOP_QueryServGeneric: {
QSLink.SendPacket(pack); QueryServConnection::Instance()->SendPacket(pack);
break; break;
} }
case ServerOP_CZDialogueWindow: case ServerOP_CZDialogueWindow: