Skip to content

Commit 719f844

Browse files
committed
Review
1 parent 0ef6135 commit 719f844

File tree

1 file changed

+15
-17
lines changed

1 file changed

+15
-17
lines changed

com.unity.netcode.gameobjects/Runtime/Core/NetworkBehaviour.cs

Lines changed: 15 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -170,8 +170,6 @@ internal FastBufferWriter __beginSendClientRpc(uint rpcMethodId, ClientRpcParams
170170
internal void __endSendClientRpc(ref FastBufferWriter bufferWriter, uint rpcMethodId, ClientRpcParams clientRpcParams, RpcDelivery rpcDelivery)
171171
#pragma warning restore IDE1006 // restore naming rule violation check
172172
{
173-
// Getting this ahead of time actually improves performance
174-
var networkManager = m_NetworkManager;
175173
var clientRpcMessage = new ClientRpcMessage
176174
{
177175
Metadata = new RpcMetadata
@@ -191,7 +189,7 @@ internal void __endSendClientRpc(ref FastBufferWriter bufferWriter, uint rpcMeth
191189
networkDelivery = MessageDeliveryType<ClientRpcMessage>.DefaultDelivery;
192190
break;
193191
case RpcDelivery.Unreliable:
194-
if (bufferWriter.Length > networkManager.MessageManager.NonFragmentedMessageMaxSize)
192+
if (bufferWriter.Length > m_NetworkManager.MessageManager.NonFragmentedMessageMaxSize)
195193
{
196194
throw new OverflowException("RPC parameters are too large for unreliable delivery.");
197195
}
@@ -208,48 +206,48 @@ internal void __endSendClientRpc(ref FastBufferWriter bufferWriter, uint rpcMeth
208206
{
209207
foreach (var targetClientId in clientRpcParams.Send.TargetClientIds)
210208
{
211-
if (targetClientId == networkManager.ServerClientId)
209+
if (targetClientId == NetworkManager.ServerClientId)
212210
{
213211
shouldInvokeLocally = true;
214212
continue;
215213
}
216214
// Check to make sure we are sending to only observers, if not log an error.
217-
if (networkManager.LogLevel >= LogLevel.Error && !m_NetworkObject.Observers.Contains(targetClientId))
215+
if (m_NetworkManager.LogLevel >= LogLevel.Error && !m_NetworkObject.Observers.Contains(targetClientId))
218216
{
219217
NetworkLog.LogError(GenerateObserverErrorMessage(clientRpcParams, targetClientId));
220218
}
221219
}
222-
rpcWriteSize = networkManager.ConnectionManager.SendMessage(ref clientRpcMessage, networkDelivery, in clientRpcParams.Send.TargetClientIds);
220+
rpcWriteSize = m_NetworkManager.ConnectionManager.SendMessage(ref clientRpcMessage, networkDelivery, in clientRpcParams.Send.TargetClientIds);
223221
}
224222
else if (clientRpcParams.Send.TargetClientIdsNativeArray != null)
225223
{
226224
foreach (var targetClientId in clientRpcParams.Send.TargetClientIdsNativeArray)
227225
{
228-
if (targetClientId == networkManager.ServerClientId)
226+
if (targetClientId == NetworkManager.ServerClientId)
229227
{
230228
shouldInvokeLocally = true;
231229
continue;
232230
}
233231
// Check to make sure we are sending to only observers, if not log an error.
234-
if (networkManager.LogLevel >= LogLevel.Error && !m_NetworkObject.Observers.Contains(targetClientId))
232+
if (m_NetworkManager.LogLevel >= LogLevel.Error && !m_NetworkObject.Observers.Contains(targetClientId))
235233
{
236234
NetworkLog.LogError(GenerateObserverErrorMessage(clientRpcParams, targetClientId));
237235
}
238236
}
239-
rpcWriteSize = networkManager.ConnectionManager.SendMessage(ref clientRpcMessage, networkDelivery, clientRpcParams.Send.TargetClientIdsNativeArray.Value);
237+
rpcWriteSize = m_NetworkManager.ConnectionManager.SendMessage(ref clientRpcMessage, networkDelivery, clientRpcParams.Send.TargetClientIdsNativeArray.Value);
240238
}
241239
else
242240
{
243241
var observerEnumerator = m_NetworkObject.Observers.GetEnumerator();
244242
while (observerEnumerator.MoveNext())
245243
{
246244
// Skip over the host
247-
if (IsHost && observerEnumerator.Current == networkManager.LocalClientId)
245+
if (IsHost && observerEnumerator.Current == m_NetworkManager.LocalClientId)
248246
{
249247
shouldInvokeLocally = true;
250248
continue;
251249
}
252-
rpcWriteSize = networkManager.ConnectionManager.SendMessage(ref clientRpcMessage, networkDelivery, observerEnumerator.Current);
250+
rpcWriteSize = m_NetworkManager.ConnectionManager.SendMessage(ref clientRpcMessage, networkDelivery, observerEnumerator.Current);
253251
}
254252
}
255253

@@ -260,8 +258,8 @@ internal void __endSendClientRpc(ref FastBufferWriter bufferWriter, uint rpcMeth
260258
var context = new NetworkContext
261259
{
262260
SenderId = NetworkManager.ServerClientId,
263-
Timestamp = networkManager.RealTimeProvider.RealTimeSinceStartup,
264-
SystemOwner = networkManager,
261+
Timestamp = m_NetworkManager.RealTimeProvider.RealTimeSinceStartup,
262+
SystemOwner = m_NetworkManager,
265263
// header information isn't valid since it's not a real message.
266264
// RpcMessage doesn't access this stuff so it's just left empty.
267265
Header = new NetworkMessageHeader(),
@@ -284,7 +282,7 @@ internal void __endSendClientRpc(ref FastBufferWriter bufferWriter, uint rpcMeth
284282
{
285283
foreach (var targetClientId in clientRpcParams.Send.TargetClientIds)
286284
{
287-
networkManager.NetworkMetrics.TrackRpcSent(
285+
m_NetworkManager.NetworkMetrics.TrackRpcSent(
288286
targetClientId,
289287
m_NetworkObject,
290288
rpcMethodName,
@@ -296,7 +294,7 @@ internal void __endSendClientRpc(ref FastBufferWriter bufferWriter, uint rpcMeth
296294
{
297295
foreach (var targetClientId in clientRpcParams.Send.TargetClientIdsNativeArray)
298296
{
299-
networkManager.NetworkMetrics.TrackRpcSent(
297+
m_NetworkManager.NetworkMetrics.TrackRpcSent(
300298
targetClientId,
301299
m_NetworkObject,
302300
rpcMethodName,
@@ -309,7 +307,7 @@ internal void __endSendClientRpc(ref FastBufferWriter bufferWriter, uint rpcMeth
309307
var observerEnumerator = m_NetworkObject.Observers.GetEnumerator();
310308
while (observerEnumerator.MoveNext())
311309
{
312-
networkManager.NetworkMetrics.TrackRpcSent(
310+
m_NetworkManager.NetworkMetrics.TrackRpcSent(
313311
observerEnumerator.Current,
314312
m_NetworkObject,
315313
rpcMethodName,
@@ -327,7 +325,7 @@ internal void __endSendClientRpc(ref FastBufferWriter bufferWriter, uint rpcMeth
327325
internal FastBufferWriter __beginSendRpc(uint rpcMethodId, RpcParams rpcParams, RpcAttribute.RpcAttributeParams attributeParams, SendTo defaultTarget, RpcDelivery rpcDelivery)
328326
#pragma warning restore IDE1006 // restore naming rule violation check
329327
{
330-
if (m_NetworkObject == null && !IsSpawned)
328+
if (!IsSpawned)
331329
{
332330
throw new RpcException("The NetworkBehaviour must be spawned before calling this method.");
333331
}

0 commit comments

Comments
 (0)