mirror/quantum-space-buddies
1
0
Fork 0
mirror of https://github.com/misternebula/quantum-space-buddies.git synced 2025-01-01 03:32:38 +00:00
Code Issues Projects Releases Wiki Activity

cleanup qnetworkserver

Browse Source
This commit is contained in:
Mister_Nebula 2021-08-29 16:46:33 +01:00
parent dd4481e820
commit e83a9219f1
1 changed files with 0 additions and 65 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

65
QuantumUNET/QNetworkServer.cs
View File

@ -39,12 +39,6 @@ namespace QuantumUNET
public static bool dontListen { get; set; }
public static bool useWebSockets
{
get => instance.m_SimpleServerSimple.useWebSockets;
set => instance.m_SimpleServerSimple.useWebSockets = value;
}
internal static QNetworkServer instance
{
get
@ -71,12 +65,6 @@ namespace QuantumUNET
public static int numChannels => instance.m_SimpleServerSimple.hostTopology.DefaultConfig.ChannelCount;
public static float maxDelay
{
get => instance.m_MaxDelay;
set => instance.InternalSetMaxDelay(value);
}
public static Type networkConnectionClass => instance.m_SimpleServerSimple.networkConnectionClass;
public static void SetNetworkConnectionClass<T>() where T : QNetworkConnection => instance.m_SimpleServerSimple.SetNetworkConnectionClass<T>();
@ -140,15 +128,6 @@ namespace QuantumUNET
}
}
public static void ListenRelay(string relayIp, int relayPort, NetworkID netGuid, SourceID sourceId, NodeID nodeId) => instance.InternalListenRelay(relayIp, relayPort, netGuid, sourceId, nodeId);
private void InternalListenRelay(string relayIp, int relayPort, NetworkID netGuid, SourceID sourceId, NodeID nodeId)
{
m_SimpleServerSimple.ListenRelay(relayIp, relayPort, netGuid, sourceId, nodeId);
active = true;
RegisterMessageHandlers();
}
public static bool Listen(int serverPort) => instance.InternalListen(null, serverPort);
public static bool Listen(string ipAddress, int serverPort) => instance.InternalListen(ipAddress, serverPort);
@ -170,16 +149,6 @@ namespace QuantumUNET
return true;
}
private void InternalSetMaxDelay(float seconds)
{
foreach (var networkConnection in connections)
{
networkConnection?.SetMaxDelay(seconds);
}
m_MaxDelay = seconds;
}
internal int AddLocalClient(QLocalClient localClient)
{
int result;
@ -653,40 +622,6 @@ namespace QuantumUNET
public static void ClearSpawners() => QNetworkScene.ClearSpawners();
public static void GetStatsOut(out int numMsgs, out int numBufferedMsgs, out int numBytes, out int lastBufferedPerSecond)
{
numMsgs = 0;
numBufferedMsgs = 0;
numBytes = 0;
lastBufferedPerSecond = 0;
foreach (var networkConnection in connections)
{
if (networkConnection != null)
{
networkConnection.GetStatsOut(out var num, out var num2, out var num3, out var num4);
numMsgs += num;
numBufferedMsgs += num2;
numBytes += num3;
lastBufferedPerSecond += num4;
}
}
}
public static void GetStatsIn(out int numMsgs, out int numBytes)
{
numMsgs = 0;
numBytes = 0;
foreach (var networkConnection in connections)
{
if (networkConnection != null)
{
networkConnection.GetStatsIn(out var num, out var num2);
numMsgs += num;
numBytes += num2;
}
}
}
public static void SendToClientOfPlayer(GameObject player, short msgType, QMessageBase msg)
{
foreach (var networkConnection in connections)