GoaLitiuM/FlaxEngine
1
0
Fork 0
Code Issues Pull Requests Actions 7 Packages Projects Releases Wiki Activity

Expose CreateMessage/RecycleMessage to the API

Browse Source
This commit is contained in:
Damian Korczowski
2021-03-11 20:04:10 +01:00
parent 339e5a5d91
commit e7d99057ba
2 changed files with 26 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
Source/Engine/Networking/NetworkManager.cpp
View File

@@ -68,6 +68,8 @@ bool NetworkManager::Listen()
void NetworkManager::Connect()
{
// TODO: Support multiple hosts
LOG(Info, "Connecting to 127.0.0.1:{0}...", Config.Port); // TODO: Proper IP address
ASSERT(NetworkDriver != nullptr);
@@ -97,6 +99,27 @@ bool NetworkManager::PopEvent(NetworkEvent* eventPtr)
return NetworkDriver->PopEvent(eventPtr);
}
NetworkMessage NetworkManager::CreateMessage()
{
ASSERT(MessagePool.Count() > 0);
const uint32 messageId = MessagePool.Pop();
uint8* messageBuffer = GetMessageBuffer(messageId);
return NetworkMessage(messageBuffer, messageId, Config.MessageSize, 0, 0);
}
void NetworkManager::RecycleMessage(const NetworkMessage& message)
{
ASSERT(message.IsValid());
#ifdef BUILD_DEBUG
ASSERT(MessagePool.Contains(message.MessageId) == false);
#endif
// Return the message id
MessagePool.Push(message.MessageId);
}
NetworkMessage NetworkManager::BeginSendMessage()
{
ASSERT(NetworkDriver != nullptr);
@@ -121,27 +144,6 @@ bool NetworkManager::EndSendMessage(const NetworkChannelType channelType, const
return false;
}
NetworkMessage NetworkManager::CreateMessage()
{
ASSERT(MessagePool.Count() > 0);
const uint32 messageId = MessagePool.Pop();
uint8* messageBuffer = GetMessageBuffer(messageId);
return NetworkMessage(messageBuffer, messageId, Config.MessageSize, 0, 0);
}
void NetworkManager::RecycleMessage(const NetworkMessage& message)
{
ASSERT(message.IsValid());
#ifdef BUILD_DEBUG
ASSERT(MessagePool.Contains(message.MessageId) == false);
#endif
// Return the message id
MessagePool.Push(message.MessageId);
}
void NetworkManager::CreateMessageBuffers()
{
ASSERT(MessageBuffer == nullptr);