diff --git a/include/TServer.h b/include/TServer.h index 60a85ca..f161412 100644 --- a/include/TServer.h +++ b/include/TServer.h @@ -26,7 +26,7 @@ public: void ForEachClient(const std::function)>& Fn); size_t ClientCount() const; - static void GlobalParser(const std::weak_ptr& Client, std::vector&& Packet, TPPSMonitor& PPSMonitor, TNetwork& Network); + static void GlobalParser(const std::weak_ptr& Client, std::vector&& Packet, TNetwork& Network); static void HandleEvent(TClient& c, const std::string& Data); RWMutex& GetClientMutex() const { return mClientsMutex; } diff --git a/src/TNetwork.cpp b/src/TNetwork.cpp index b0d1786..b0615a7 100644 --- a/src/TNetwork.cpp +++ b/src/TNetwork.cpp @@ -110,7 +110,7 @@ void TNetwork::UDPServerMain() { Locked->UdpReceived += Data.size(); ++Locked->UdpPacketsReceived; Data.erase(Data.begin() + 0, Data.begin() + 2); - TServer::GlobalParser(Locked, std::move(Data), mPPSMonitor, *this); + TServer::GlobalParser(Locked, std::move(Data), *this); } catch (const std::exception&) { ++Application::InvalidUdpPackets; } @@ -512,7 +512,7 @@ void TNetwork::TCPClient(const std::weak_ptr& c) { Client->Disconnect("TCPRcv failed"); break; } - TServer::GlobalParser(c, std::move(res), mPPSMonitor, *this); + TServer::GlobalParser(c, std::move(res), *this); } if (QueueSync.joinable()) diff --git a/src/TServer.cpp b/src/TServer.cpp index 401ee11..770e67f 100644 --- a/src/TServer.cpp +++ b/src/TServer.cpp @@ -130,7 +130,7 @@ size_t TServer::ClientCount() const { return mClients.size(); } -void TServer::GlobalParser(const std::weak_ptr& Client, std::vector&& Packet, TPPSMonitor& PPSMonitor, TNetwork& Network) { +void TServer::GlobalParser(const std::weak_ptr& Client, std::vector&& Packet, TNetwork& Network) { constexpr std::string_view ABG = "ABG:"; if (Packet.size() >= ABG.size() && std::equal(Packet.begin(), Packet.begin() + ABG.size(), ABG.begin(), ABG.end())) { Packet.erase(Packet.begin(), Packet.begin() + ABG.size());