Skip to content

Commit

Permalink
feat: Cleaned up example project
Browse files Browse the repository at this point in the history
  • Loading branch information
@TwoTenPvP
TwoTenPvP committed Sep 9, 2019
1 parent 46f4aaa commit 90d3481
Showing 1 changed file with 32 additions and 252 deletions.
284 changes: 32 additions & 252 deletions Ruffles.Example/Program.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
using System.Text;
using Ruffles.Channeling;
using Ruffles.Configuration;
using Ruffles.Connections;
using Ruffles.Core;

namespace Ruffles.Example
Expand All @@ -23,9 +24,9 @@ public class Program
DualListenPort = 5674,
SimulatorConfig = new Simulation.SimulatorConfig()
{
DropPercentage = 0.1f,
MaxLatency = 1000,
MinLatency = 300
DropPercentage = 0.05f,
MaxLatency = 10,
MinLatency = 0
},
UseSimulator = true
};
Expand All @@ -36,156 +37,49 @@ public class Program
DualListenPort = 0, // Port 0 means we get a port by the operating system
SimulatorConfig = new Simulation.SimulatorConfig()
{
DropPercentage = 0.1f,
MaxLatency = 1000,
MinLatency = 300
DropPercentage = 0.05f,
MaxLatency = 10,
MinLatency = 0
},
UseSimulator = true
};

// Can be turned off for systems that does not support IPv6
static bool IPv6 = true;

public static void Main(string[] args)
{
// Uncomment the thread mode you want to run.

NoRufflesManager();
// RufflesManagerSingleThreaded();
// RufflesManagerThreaded();
}

private static void NoRufflesManager()
{
RuffleSocket server = new RuffleSocket(ServerConfig);

RuffleSocket client = new RuffleSocket(ClientConfig);

// IPv4 Connect
//client.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 5674));

// IPv6 Connect
client.Connect(new IPEndPoint(IPAddress.Parse("0:0:0:0:0:0:0:1"), 5674));

// The server stores the clients id here
ulong clientId = 0;
// The client stores the servers id here
ulong serverId = 0;

// The time when the connection started
DateTime started = DateTime.Now;
RuffleSocket server = new RuffleSocket(ServerConfig);

// The time when the last message was sent
DateTime lastSent = DateTime.MinValue;
RuffleSocket client = new RuffleSocket(ClientConfig);

// The amount of message that has been received
int messagesReceived = 0;

// The amount of messages that has been sent
int messageCounter = 0;

while (true)
if (IPv6)
{
// Runs all the internals
client.RunInternalLoop();
// Runs all the internals
server.RunInternalLoop();

// Polls server for events
NetworkEvent serverEvent = server.Poll();
// Polls client for events
NetworkEvent clientEvent = client.Poll();


if (serverEvent.Type != NetworkEventType.Nothing)
{
if (serverEvent.Type != NetworkEventType.Data)
{
Console.WriteLine("ServerEvent: " + serverEvent.Type);
}

if (serverEvent.Type == NetworkEventType.Connect)
{
clientId = serverEvent.Connection.Id;
}

if (serverEvent.Type == NetworkEventType.Disconnect || serverEvent.Type == NetworkEventType.Timeout)
{
serverEvent.Connection.Recycle();
}
}

if (clientEvent.Type != NetworkEventType.Nothing)
{
if (clientEvent.Type != NetworkEventType.Data)
{
Console.WriteLine("ClientEvent: " + clientEvent.Type);
}

if (clientEvent.Type == NetworkEventType.Connect)
{
serverId = clientEvent.Connection.Id;
}

if (clientEvent.Type == NetworkEventType.Data)
{
Console.WriteLine("IsCorrect: " + (clientEvent.Data.Count == (1024 + 1024 * (messagesReceived % 5))) + ", Expected: " + (1024 + 1024 * (messagesReceived % 5)) + ", got: " + clientEvent.Data.Count);

messagesReceived++;
//Console.WriteLine("Got message of size: " + clientEvent.Data.Count);
//Console.WriteLine("Got message: \"" + Encoding.ASCII.GetString(clientEvent.Data.Array, clientEvent.Data.Offset, clientEvent.Data.Count) + "\"");
clientEvent.Recycle();
}

if (clientEvent.Type == NetworkEventType.Disconnect || clientEvent.Type == NetworkEventType.Timeout)
{
clientEvent.Connection.Recycle();
}
}

if ((DateTime.Now - started).TotalSeconds > 10 && (DateTime.Now - lastSent).TotalSeconds >= 1)
{
Console.WriteLine("Sending size: " + (1024 + (1024 * (messageCounter % 5))));
byte[] largeFragment = new byte[1024 + 1024 * (messageCounter % 5)];


byte[] helloReliable = Encoding.ASCII.GetBytes("This message was sent over a reliable channel" + messageCounter);
byte[] helloReliableSequenced = Encoding.ASCII.GetBytes("This message was sent over a reliable sequenced channel" + messageCounter);

//server.Send(new ArraySegment<byte>(helloReliableSequenced, 0, helloReliableSequenced.Length), clientId, 0, false);
//server.Send(new ArraySegment<byte>(helloReliable, 0, helloReliable.Length), clientId, 1, false);
server.Send(new ArraySegment<byte>(largeFragment, 0, largeFragment.Length), clientId, 4, false);

messageCounter++;
lastSent = DateTime.Now;
}
// IPv6 Connect
client.Connect(new IPEndPoint(IPAddress.Parse("0:0:0:0:0:0:0:1"), 5674));
}
else
{
// IPv4 Connect
client.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 5674));
}
}

private static void RufflesManagerSingleThreaded()
{
// Create a ruffles manager
SocketManager manager = new SocketManager(false);

RuffleSocket server = manager.AddSocket(ServerConfig);

RuffleSocket client = manager.AddSocket(ClientConfig);

// IPv4 Connect
//client.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 5674));

// IPv6 Connect
client.Connect(new IPEndPoint(IPAddress.Parse("0:0:0:0:0:0:0:1"), 5674));

// The server stores the clients id here
ulong clientId = 0;
Connection clientConnection = null;
// The client stores the servers id here
ulong serverId = 0;
Connection serverConnection = null;

// The time when the connection started
DateTime started = DateTime.Now;

// The time when the last message was sent
DateTime lastSent = DateTime.MinValue;

// The time the last status was printed
DateTime lastStatusPrint = DateTime.MinValue;

// The amount of message that has been received
int messagesReceived = 0;

Expand All @@ -194,15 +88,11 @@ private static void RufflesManagerSingleThreaded()

while (true)
{
// Runs all the internals
manager.RunInternals();

// Polls server for events
NetworkEvent serverEvent = server.Poll();
// Polls client for events
NetworkEvent clientEvent = client.Poll();


if (serverEvent.Type != NetworkEventType.Nothing)
{
if (serverEvent.Type != NetworkEventType.Data)
Expand All @@ -213,6 +103,7 @@ private static void RufflesManagerSingleThreaded()
if (serverEvent.Type == NetworkEventType.Connect)
{
clientId = serverEvent.Connection.Id;
clientConnection = serverEvent.Connection;
}

if (serverEvent.Type == NetworkEventType.Disconnect || serverEvent.Type == NetworkEventType.Timeout)
Expand All @@ -231,6 +122,7 @@ private static void RufflesManagerSingleThreaded()
if (clientEvent.Type == NetworkEventType.Connect)
{
serverId = clientEvent.Connection.Id;
serverConnection = clientEvent.Connection;
}

if (clientEvent.Type == NetworkEventType.Data)
Expand All @@ -246,134 +138,22 @@ private static void RufflesManagerSingleThreaded()
}
}

if ((DateTime.Now - started).TotalSeconds > 10 && (DateTime.Now - lastSent).TotalSeconds >= 1)
if ((DateTime.Now - started).TotalSeconds > 10 && (DateTime.Now - lastSent).TotalSeconds >= (1f / 1))
{
byte[] helloReliable = Encoding.ASCII.GetBytes("This message was sent over a reliable channel" + messageCounter);
byte[] helloReliableSequenced = Encoding.ASCII.GetBytes("This message was sent over a reliable sequenced channel" + messageCounter);

server.Send(new ArraySegment<byte>(helloReliableSequenced, 0, helloReliableSequenced.Length), clientId, 0, false);
server.Send(new ArraySegment<byte>(helloReliable, 0, helloReliable.Length), clientId, 1, false);
Console.WriteLine("Sending packet: " + messageCounter);

messageCounter++;
lastSent = DateTime.Now;
}
}
}

private static void RufflesManagerThreaded()
{
// Create a ruffles manager
SocketManager manager = new SocketManager(true);

RuffleSocket server = manager.AddSocket(ServerConfig);

RuffleSocket client = manager.AddSocket(ClientConfig);

// IPv4 Connect
//client.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 5674));

// IPv6 Connect
client.Connect(new IPEndPoint(IPAddress.Parse("0:0:0:0:0:0:0:1"), 5674));

// The server stores the clients id here
ulong clientId = 0;
// The client stores the servers id here
ulong serverId = 0;

// The time when the connection started
DateTime started = DateTime.Now;

// The time when the last message was sent
DateTime lastSent = DateTime.MinValue;

// The amount of message that has been received
int messagesReceived = 0;

// The amount of messages that has been sent
int messageCounter = 0;

while (true)
{
NetworkEvent serverEvent;
NetworkEvent clientEvent;

lock (manager.ThreadLock)
{
// Polls server for events
serverEvent = server.Poll();
// Polls client for events
clientEvent = client.Poll();
}


if (serverEvent.Type != NetworkEventType.Nothing)
{
if (serverEvent.Type != NetworkEventType.Data)
{
Console.WriteLine("ServerEvent: " + serverEvent.Type);
}

if (serverEvent.Type == NetworkEventType.Connect)
{
clientId = serverEvent.Connection.Id;
}

if (serverEvent.Type == NetworkEventType.Disconnect || serverEvent.Type == NetworkEventType.Timeout)
{
lock (manager.ThreadLock)
{
serverEvent.Connection.Recycle();
}
}
}

if (clientEvent.Type != NetworkEventType.Nothing)
{
if (clientEvent.Type != NetworkEventType.Data)
{
Console.WriteLine("ClientEvent: " + clientEvent.Type);
}

if (clientEvent.Type == NetworkEventType.Connect)
{
serverId = clientEvent.Connection.Id;
}

if (clientEvent.Type == NetworkEventType.Data)
{
messagesReceived++;
Console.WriteLine("Got message: \"" + Encoding.ASCII.GetString(clientEvent.Data.Array, clientEvent.Data.Offset, clientEvent.Data.Count) + "\"");

lock (manager.ThreadLock)
{
clientEvent.Recycle();
}
}

if (clientEvent.Type == NetworkEventType.Disconnect || clientEvent.Type == NetworkEventType.Timeout)
{
lock (manager.ThreadLock)
{
clientEvent.Connection.Recycle();
}
}
}

if ((DateTime.Now - started).TotalSeconds > 10 && (DateTime.Now - lastSent).TotalSeconds >= 1)
if ((DateTime.Now - started).TotalSeconds > 10 && (DateTime.Now - lastStatusPrint).TotalSeconds >= 5)
{
byte[] helloReliable = Encoding.ASCII.GetBytes("This message was sent over a reliable channel" + messageCounter);
byte[] helloReliableSequenced = Encoding.ASCII.GetBytes("This message was sent over a reliable sequenced channel" + messageCounter);

lock (manager.ThreadLock)
{
server.Send(new ArraySegment<byte>(helloReliableSequenced, 0, helloReliableSequenced.Length), clientId, 0, false);
server.Send(new ArraySegment<byte>(helloReliable, 0, helloReliable.Length), clientId, 1, false);
}

messageCounter++;
lastSent = DateTime.Now;
Console.WriteLine("Ping: " + serverConnection.Roundtrip + "ms, " + clientConnection.Roundtrip + "ms");
lastStatusPrint = DateTime.Now;
}
}
}
}
}
}

0 comments on commit 90d3481

Please sign in to comment.