Skip to content

Commit 3b6bfa7

Browse files
develop merge conflict fix
1 parent 2b745c3 commit 3b6bfa7

File tree

3 files changed

+4
-5
lines changed

3 files changed

+4
-5
lines changed

com.unity.multiplayer.mlapi/Runtime/Core/NetworkedBehaviour.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ internal BitWriter BeginSendClientRpc(ClientRpcSendParams sendParams, bool isRel
8989
//This will start a new queue item entry and will then return the writer to the current frame's stream
9090
var rpcQueueContainer = NetworkingManager.Singleton.rpcQueueContainer;
9191

92-
var writer = rpcQueueContainer.BeginAddQueueItemToOutboundFrame(RpcQueueContainer.QueueItemType.ClientRpc, Time.realtimeSinceStartup, Transport.MLAPI_SERVER_RPC, 0, NetworkId, sendParams.TargetClientIds ?? NetworkingManager.Singleton.ConnectedClientsList.Select(c => c.ClientId).ToArray());
92+
var writer = rpcQueueContainer.BeginAddQueueItemToOutboundFrame(RpcQueueContainer.QueueItemType.ClientRpc, Time.realtimeSinceStartup, Transport.MLAPI_STDRPC_CHANNEL, 0, NetworkId, sendParams.TargetClientIds ?? NetworkingManager.Singleton.ConnectedClientsList.Select(c => c.ClientId).ToArray());
9393

9494
if(!rpcQueueContainer.IsUsingBatching())
9595
{

com.unity.multiplayer.mlapi/Runtime/Messaging/RPCQueue/FrameQueueItem.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ public struct FrameQueueItem
1717
public RpcQueueContainer.QueueItemType queueItemType;
1818
public SecuritySendFlags sendFlags;
1919
public ulong networkId; //Sender's network Identifier
20-
public string channel;
20+
public byte channel;
2121
public ulong[] clientIds; //Server invoked Client RPCs only
2222
public long streamSize;
2323
public float timeStamp;

com.unity.multiplayer.mlapi/Runtime/Messaging/RPCQueue/RPCQueueProcessing.cs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ private void SendFrameQueueItem(FrameQueueItem queueItem)
231231
{
232232
case RpcQueueContainer.QueueItemType.ServerRpc:
233233
{
234-
NetworkingManager.Singleton.NetworkConfig.NetworkTransport.Send(queueItem.networkId, queueItem.messageData, string.IsNullOrEmpty(queueItem.channel) ? "MLAPI_DEFAULT_MESSAGE" : queueItem.channel);
234+
NetworkingManager.Singleton.NetworkConfig.NetworkTransport.Send(queueItem.networkId, queueItem.messageData, Transport.GetChannelString(queueItem.channel));
235235

236236
//For each packet sent, we want to record how much data we have sent
237237
ProfilerStatManager.bytesSent.Record((int)queueItem.streamSize);
@@ -242,8 +242,7 @@ private void SendFrameQueueItem(FrameQueueItem queueItem)
242242
{
243243
foreach (ulong clientid in queueItem.clientIds)
244244
{
245-
NetworkingManager.Singleton.NetworkConfig.NetworkTransport.Send(clientid, queueItem.messageData, string.IsNullOrEmpty(queueItem.channel) ? "MLAPI_DEFAULT_MESSAGE" : queueItem.channel);
246-
245+
NetworkingManager.Singleton.NetworkConfig.NetworkTransport.Send(clientid, queueItem.messageData, Transport.GetChannelString(queueItem.channel));
247246
//For each packet sent, we want to record how much data we have sent
248247
ProfilerStatManager.bytesSent.Record((int)queueItem.streamSize);
249248
}

0 commit comments

Comments
 (0)