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

Available transport is determined at connection time (#1213)

Browse Source 
* Available transport is determined at connection time

* Update MultiplexTransport.cs
This commit is contained in:
Paul Pacheco 2019-11-13 14:47:18 -06:00 committed by vis2k
parent ce305d95fc
commit c2096d0fb7
1 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
Assets/Mirror/Runtime/Transport/MultiplexTransport.cs
View File

@ -10,6 +10,8 @@ public class MultiplexTransport : Transport
{ {
public Transport[] transports; public Transport[] transports;
Transport available;
// used to partition recipients for each one of the base transports // used to partition recipients for each one of the base transports
// without allocating a new list every time // without allocating a new list every time
List<int>[] recipientsCache; List<int>[] recipientsCache;
@ -51,42 +53,39 @@ void InitClient()
} }
} }
// The client just uses the first transport available public override void ClientConnect(string address)
Transport GetAvailableTransport()
{ {
foreach (Transport transport in transports) foreach (Transport transport in transports)
{ {
if (transport.Available()) if (transport.Available())
{ {
return transport; available = transport;
transport.ClientConnect(address);
} }
} }
throw new Exception("No transport suitable for this platform"); throw new Exception("No transport suitable for this platform");
} }
public override void ClientConnect(string address)
{
GetAvailableTransport().ClientConnect(address);
}
public override bool ClientConnected() public override bool ClientConnected()
{ {
return GetAvailableTransport().ClientConnected(); return available != null && available.ClientConnected();
} }
public override void ClientDisconnect() public override void ClientDisconnect()
{ {
GetAvailableTransport().ClientDisconnect(); if (available != null)
available.ClientDisconnect();
} }
public override bool ClientSend(int channelId, ArraySegment<byte> segment) public override bool ClientSend(int channelId, ArraySegment<byte> segment)
{ {
return GetAvailableTransport().ClientSend(channelId, segment); return available.ClientSend(channelId, segment);
} }
public override int GetMaxPacketSize(int channelId = 0) public override int GetMaxPacketSize(int channelId = 0)
{ {
return GetAvailableTransport().GetMaxPacketSize(channelId); return available.GetMaxPacketSize(channelId);
} }
#endregion #endregion