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

Cleanup for networking impl

Browse Source
This commit is contained in:
Wojciech Figat
2022-12-02 10:55:12 +01:00
parent adcffab78a
commit f61100deca
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
Source/Engine/Networking/NetworkReplicator.cpp
View File

@@ -31,7 +31,7 @@
#include "Engine/Threading/ThreadLocal.h" #include "Engine/Threading/ThreadLocal.h"
// Enables verbose logging for Network Replicator actions (dev-only) // Enables verbose logging for Network Replicator actions (dev-only)
#define NETWORK_REPLICATOR_DEBUG_LOG 1 #define NETWORK_REPLICATOR_DEBUG_LOG 0
#if NETWORK_REPLICATOR_DEBUG_LOG #if NETWORK_REPLICATOR_DEBUG_LOG
#define NETWORK_REPLICATOR_LOG(messageType, format, ...) LOG(messageType, format, ##__VA_ARGS__) #define NETWORK_REPLICATOR_LOG(messageType, format, ...) LOG(messageType, format, ##__VA_ARGS__)
@@ -757,6 +757,11 @@ void NetworkReplicator::SetObjectOwnership(ScriptingObject* obj, uint32 ownerCli
} }
} }
void DirtyObjectImpl(NetworkReplicatedObject& item, ScriptingObject* obj)
{
// TODO: implement objects state replication frequency and dirtying
}
void NetworkReplicator::DirtyObject(ScriptingObject* obj) void NetworkReplicator::DirtyObject(ScriptingObject* obj)
{ {
ScopeLock lock(ObjectsLock); ScopeLock lock(ObjectsLock);
@@ -766,7 +771,7 @@ void NetworkReplicator::DirtyObject(ScriptingObject* obj)
auto& item = it->Item; auto& item = it->Item;
if (item.Object != obj || item.Role != NetworkObjectRole::OwnedAuthoritative) if (item.Object != obj || item.Role != NetworkObjectRole::OwnedAuthoritative)
return; return;
// TODO: implement objects state replication frequency and dirtying DirtyObjectImpl(item, obj);
} }
Dictionary<NetworkRpcName, NetworkRpcInfo> NetworkRpcInfo::RPCsTable; Dictionary<NetworkRpcName, NetworkRpcInfo> NetworkRpcInfo::RPCsTable;
@@ -1167,7 +1172,9 @@ void NetworkInternal::OnNetworkMessageObjectReplicate(NetworkEvent& event, Netwo
if (item.AsNetworkObject) if (item.AsNetworkObject)
item.AsNetworkObject->OnNetworkDeserialize(); item.AsNetworkObject->OnNetworkDeserialize();
// TODO: speed up replication of client-owned object to other clients from server // Speed up replication of client-owned objects to other clients from server to reduce lag (data has to go from client to server and then to other clients)
if (NetworkManager::IsServer())
DirtyObjectImpl(item, obj);
} }
else else
{ {