Merge pull request #101 from PepperDash/hotfix/udp-server-queue

removed udp server queue

Pepperdash Core/Pepperdash Core/Comm/GenericUdpServer.cs

@@ -34,11 +34,6 @@ namespace PepperDash.Core
         /// </summary>
 		public event EventHandler<GenericUdpReceiveTextExtraArgs> DataRecievedExtra;
 
-        /// <summary>
-        /// Queue to temporarily store received messages with the source IP and Port info
-        /// </summary>
-		private CrestronQueue<GenericUdpReceiveTextExtraArgs> MessageQueue;
-
         /// <summary>
         /// 
         /// </summary>
@@ -68,8 +63,6 @@ namespace PepperDash.Core
             get { return (ushort)Server.ServerStatus; }
         }
 
-
-		CCriticalSection DequeueLock;
         /// <summary>
         /// Address of server
         /// </summary>
@@ -124,8 +117,6 @@ namespace PepperDash.Core
         {
             StreamDebugging = new CommunicationStreamDebugging(SplusKey);
             BufferSize = 5000;
-            DequeueLock = new CCriticalSection();
-            MessageQueue = new CrestronQueue<GenericUdpReceiveTextExtraArgs>();
 
             CrestronEnvironment.ProgramStatusEventHandler += new ProgramStatusEventHandler(CrestronEnvironment_ProgramStatusEventHandler);
             CrestronEnvironment.EthernetEventHandler += new EthernetEventHandler(CrestronEnvironment_EthernetEventHandler);
@@ -146,9 +137,6 @@ namespace PepperDash.Core
             Port = port;
             BufferSize = buffefSize;
 
-			DequeueLock = new CCriticalSection();
-			MessageQueue = new CrestronQueue<GenericUdpReceiveTextExtraArgs>();
-
             CrestronEnvironment.ProgramStatusEventHandler += new ProgramStatusEventHandler(CrestronEnvironment_ProgramStatusEventHandler);
             CrestronEnvironment.EthernetEventHandler += new EthernetEventHandler(CrestronEnvironment_EthernetEventHandler);
         }
@@ -186,12 +174,12 @@ namespace PepperDash.Core
         /// <param name="programEventType"></param>
         void CrestronEnvironment_ProgramStatusEventHandler(eProgramStatusEventType programEventType)
         {
-            if (programEventType == eProgramStatusEventType.Stopping)
+            if (programEventType != eProgramStatusEventType.Stopping) 
-            {
+                return;
+
             Debug.Console(1, this, "Program stopping. Disabling Server");
             Disconnect();
         }
-        }
 
         /// <summary>
         /// Enables the UDP Server
@@ -255,13 +243,19 @@ namespace PepperDash.Core
         {
             Debug.Console(2, this, "Received {0} bytes", numBytes);
 
-            if (numBytes > 0)
+            try
             {
+                if (numBytes <= 0) 
+                    return;
+
                 var sourceIp = Server.IPAddressLastMessageReceivedFrom;
                 var sourcePort = Server.IPPortLastMessageReceivedFrom;
                 var bytes = server.IncomingDataBuffer.Take(numBytes).ToArray();
                 var str = Encoding.GetEncoding(28591).GetString(bytes, 0, bytes.Length);
-				MessageQueue.TryToEnqueue(new GenericUdpReceiveTextExtraArgs(str, sourceIp, sourcePort, bytes));
+
+                var dataRecivedExtra = DataRecievedExtra;
+                if (dataRecivedExtra != null)
+                    dataRecivedExtra(this, new GenericUdpReceiveTextExtraArgs(str, sourceIp, sourcePort, bytes));
 
                 Debug.Console(2, this, "Bytes: {0}", bytes.ToString());
                 var bytesHandler = BytesReceived;
@@ -269,6 +263,7 @@ namespace PepperDash.Core
                     bytesHandler(this, new GenericCommMethodReceiveBytesArgs(bytes));
                 else
                     Debug.Console(2, this, "bytesHandler is null");
+
                 var textHandler = TextReceived;
                 if (textHandler != null)
                 {
@@ -280,41 +275,13 @@ namespace PepperDash.Core
                 else
                     Debug.Console(2, this, "textHandler is null");
             }
+            catch (Exception ex)
+            {
+                Debug.Console(0, "GenericUdpServer Receive error: {0}{1}", ex.Message, ex.StackTrace);
+            }
+            finally
+            {
                 server.ReceiveDataAsync(Receive);
-
-            //  Attempt to enter the CCritical Secion and if we can, start the dequeue thread 
-            var gotLock = DequeueLock.TryEnter();
-            if (gotLock)
-                CrestronInvoke.BeginInvoke((o) => DequeueEvent());
-        }
-
-        /// <summary>
-        /// This method gets spooled up in its own thread an protected by a CCriticalSection to prevent multiple threads from running concurrently.
-        /// It will dequeue items as they are enqueued automatically.
-        /// </summary>
-		void DequeueEvent()
-		{
-			try
-			{
-				while (true)
-				{
-					// Pull from Queue and fire an event. Block indefinitely until an item can be removed, similar to a Gather.
-					var message = MessageQueue.Dequeue();
-					var dataRecivedExtra = DataRecievedExtra;
-					if (dataRecivedExtra != null)
-					{
-						dataRecivedExtra(this, message);
-					}
-				}
-			}
-			catch (Exception e)
-			{
-				Debug.Console(0, "GenericUdpServer DequeueEvent error: {0}\r", e);
-			}
-			// Make sure to leave the CCritical section in case an exception above stops this thread, or we won't be able to restart it.
-			if (DequeueLock != null)
-			{
-				DequeueLock.Leave();
             }
         }