charleslemaux/Mirror
1
0
Fork 0
mirror of https://github.com/MirrorNetworking/Mirror.git synced 2024-11-18 02:50:32 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

syntax

Browse Source
This commit is contained in:
vis2k 2021-11-28 17:25:26 +01:00
parent 7c8d2bd944
commit c1ae882d76
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
Assets/Mirror/Runtime/Transport/KCP/MirrorTransport/KcpTransport.cs
View File

@ -58,10 +58,10 @@ public class KcpTransport : Transport
public bool statisticsLog;
// translate Kcp <-> Mirror channels
static int KcpToMirrorChannel(KcpChannel channel) =>
static int FromKcpChannel(KcpChannel channel) =>
channel == KcpChannel.Reliable ? Channels.Reliable : Channels.Unreliable;
static KcpChannel MirrorToKcpChannel(int channel) =>
static KcpChannel ToKcpChannel(int channel) =>
channel == Channels.Reliable ? KcpChannel.Reliable : KcpChannel.Unreliable;
void Awake()
@ -80,18 +80,18 @@ void Awake()
client = NonAlloc
? new KcpClientNonAlloc(
() => OnClientConnected.Invoke(),
(message, channel) => OnClientDataReceived.Invoke(message, KcpToMirrorChannel(channel)),
(message, channel) => OnClientDataReceived.Invoke(message, FromKcpChannel(channel)),
() => OnClientDisconnected.Invoke())
: new KcpClient(
() => OnClientConnected.Invoke(),
(message, channel) => OnClientDataReceived.Invoke(message, KcpToMirrorChannel(channel)),
(message, channel) => OnClientDataReceived.Invoke(message, FromKcpChannel(channel)),
() => OnClientDisconnected.Invoke());
// server
server = NonAlloc
? new KcpServerNonAlloc(
(connectionId) => OnServerConnected.Invoke(connectionId),
(connectionId, message, channel) => OnServerDataReceived.Invoke(connectionId, message, KcpToMirrorChannel(channel)),
(connectionId, message, channel) => OnServerDataReceived.Invoke(connectionId, message, FromKcpChannel(channel)),
(connectionId) => OnServerDisconnected.Invoke(connectionId),
DualMode,
NoDelay,
@ -103,7 +103,7 @@ void Awake()
Timeout)
: new KcpServer(
(connectionId) => OnServerConnected.Invoke(connectionId),
(connectionId, message, channel) => OnServerDataReceived.Invoke(connectionId, message, KcpToMirrorChannel(channel)),
(connectionId, message, channel) => OnServerDataReceived.Invoke(connectionId, message, FromKcpChannel(channel)),
(connectionId) => OnServerDisconnected.Invoke(connectionId),
DualMode,
NoDelay,
@ -147,7 +147,7 @@ public override void ClientConnect(Uri uri)
}
public override void ClientSend(ArraySegment<byte> segment, int channelId)
{
client.Send(segment, MirrorToKcpChannel(channelId));
client.Send(segment, ToKcpChannel(channelId));
}
public override void ClientDisconnect() => client.Disconnect();
// process incoming in early update
@ -195,7 +195,7 @@ public override Uri ServerUri()
public override void ServerStart() => server.Start(Port);
public override void ServerSend(int connectionId, ArraySegment<byte> segment, int channelId)
{
server.Send(connectionId, segment, MirrorToKcpChannel(channelId));
server.Send(connectionId, segment, ToKcpChannel(channelId));
}
public override void ServerDisconnect(int connectionId) => server.Disconnect(connectionId);
public override string ServerGetClientAddress(int connectionId) => server.GetClientAddress(connectionId);