34 lines
638 B
C
34 lines
638 B
C
|
#pragma once
|
||
|
|
#include "stdafx.h"
|
||
|
|
#include "NetMessage.h"
|
||
|
|
#include "../Utilities/Socket.h"
|
||
|
|
#include "../Utilities/SimpleLock.h"
|
||
|
|
|
||
|
|
class GameConnection
|
||
|
|
{
|
||
|
|
protected:
|
||
|
|
shared_ptr<Socket> _socket;
|
||
|
|
char _readBuffer[0x40000];
|
||
|
|
char _messageBuffer[0x40000];
|
||
|
|
int _readPosition = 0;
|
||
|
|
SimpleLock _socketLock;
|
||
|
|
|
||
|
|
private:
|
||
|
|
void ReadSocket();
|
||
|
|
|
||
|
|
bool ExtractMessage(char *buffer, uint32_t &messageLength);
|
||
|
|
NetMessage* ReadMessage();
|
||
|
|
|
||
|
|
virtual void ProcessMessage(NetMessage* message) = 0;
|
||
|
|
|
||
|
|
protected:
|
||
|
|
void SendNetMessage(NetMessage &message);
|
||
|
|
|
||
|
|
public:
|
||
|
|
GameConnection(shared_ptr<Socket> socket);
|
||
|
|
|
||
|
|
bool ConnectionError();
|
||
|
|
|
||
|
|
void ProcessMessages();
|
||
|
|
|
||
|
|
};
|