mirror of
https://github.com/BeamMP/BeamMP-Server.git
synced 2025-07-01 23:35:41 +00:00
fd7b11f436
The event loop tries to run no faster than every 10ms. If it detects that it goes faster, it would incorrectly calculate the difference, and then wait (what I assume was) way too long or too short. Either way, now it's fixed and it correctly works, even when introducing new lua states.
52 lines
2.0 KiB
C++
52 lines
2.0 KiB
C++
#pragma once
|
|
|
|
#include "Compat.h"
|
|
#include "TResourceManager.h"
|
|
#include "TServer.h"
|
|
|
|
struct TConnection;
|
|
|
|
class TNetwork {
|
|
public:
|
|
TNetwork(TServer& Server, TPPSMonitor& PPSMonitor, TResourceManager& ResourceManager);
|
|
|
|
[[nodiscard]] bool TCPSend(TClient& c, const std::string& Data, bool IsSync = false);
|
|
[[nodiscard]] bool SendLarge(TClient& c, std::string Data, bool isSync = false);
|
|
[[nodiscard]] bool Respond(TClient& c, const std::string& MSG, bool Rel, bool isSync = false);
|
|
std::shared_ptr<TClient> CreateClient(SOCKET TCPSock);
|
|
std::string TCPRcv(TClient& c);
|
|
void ClientKick(TClient& c, const std::string& R);
|
|
[[nodiscard]] bool SyncClient(const std::weak_ptr<TClient>& c);
|
|
void Identify(const TConnection& client);
|
|
void Authentication(const TConnection& ClientConnection);
|
|
[[nodiscard]] bool CheckBytes(TClient& c, int32_t BytesRcv);
|
|
void SyncResources(TClient& c);
|
|
[[nodiscard]] bool UDPSend(TClient& Client, std::string Data) const;
|
|
void SendToAll(TClient* c, const std::string& Data, bool Self, bool Rel);
|
|
void UpdatePlayer(TClient& Client);
|
|
|
|
private:
|
|
void UDPServerMain();
|
|
void TCPServerMain();
|
|
|
|
TServer& mServer;
|
|
TPPSMonitor& mPPSMonitor;
|
|
SOCKET mUDPSock {};
|
|
TResourceManager& mResourceManager;
|
|
std::thread mUDPThread;
|
|
std::thread mTCPThread;
|
|
|
|
std::string UDPRcvFromClient(sockaddr_in& client) const;
|
|
void HandleDownload(SOCKET TCPSock);
|
|
void OnConnect(const std::weak_ptr<TClient>& c);
|
|
void TCPClient(const std::weak_ptr<TClient>& c);
|
|
void Looper(const std::weak_ptr<TClient>& c);
|
|
int OpenID();
|
|
void OnDisconnect(const std::weak_ptr<TClient>& ClientPtr, bool kicked);
|
|
void Parse(TClient& c, const std::string& Packet);
|
|
void SendFile(TClient& c, const std::string& Name);
|
|
static bool TCPSendRaw(TClient& C, SOCKET socket, char* Data, int32_t Size);
|
|
static void SplitLoad(TClient& c, size_t Sent, size_t Size, bool D, const std::string& Name);
|
|
static uint8_t* SendSplit(TClient& c, SOCKET Socket, uint8_t* DataPtr, size_t Size);
|
|
};
|