Use work-threads for ordering instead of IO threads.

CRBairdUSA · Jul 9, 2016 · 79b9fdb · 79b9fdb
1 parent 6ce846e
commit 79b9fdb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/src/MiNET/MiNET/MiNetServer.cs b/src/MiNET/MiNET/MiNetServer.cs
@@ -908,7 +908,7 @@ internal void HandlePackage(Package message, PlayerNetworkSession playerSession)
 
 			if (message.Reliability == Reliability.ReliableOrdered)
 			{
-				playerSession.AddToProcessing(message);
+				Task.Run(() => playerSession.AddToProcessing(message));
 				return;
 			}
 

diff --git a/src/MiNET/MiNET/PlayerNetworkSession.cs b/src/MiNET/MiNET/PlayerNetworkSession.cs
@@ -112,8 +112,6 @@ public void Clean()
 		private AutoResetEvent _mainWaitEvent = new AutoResetEvent(false);
 		private object _eventSync = new object();
 
-		//private BlockingCollection<KeyValuePair<int, Package>> _queue = new BlockingCollection<KeyValuePair<int, Package>>();
-		//private BlockingCollection<KeyValuePair<int, Package>> _queue = new BlockingCollection<KeyValuePair<int, Package>>(new ConcurrentPriorityQueue<int, Package>());
 		private ConcurrentPriorityQueue<int, Package> _queue = new ConcurrentPriorityQueue<int, Package>();
 		private CancellationTokenSource _cancellationToken;
 
@@ -123,7 +121,7 @@ public void AddToProcessing(Package message)
 
 			lock (_eventSync)
 			{
-				if(_queue.Count == 0 && message.OrderingIndex == _lastSequenceNumber + 1)
+				if (_queue.Count == 0 && message.OrderingIndex == _lastSequenceNumber + 1)
 				{
 					_lastSequenceNumber = message.OrderingIndex;
 					HandlePackage(message, this);
-Original file line number
+Diff line change
@@ Expand Up @@
     			if (message.Reliability == Reliability.ReliableOrdered)
     			{
-    				playerSession.AddToProcessing(message);
+    				Task.Run(() => playerSession.AddToProcessing(message));
     				return;
     			}
@@ Expand Down @@