Updated Sub Thread

Author: doesluck1026

ScreenSharing_Desktop/.vs/ScreenSharing_Desktop/v16/.suo

@@ -2,4 +2,10 @@
 8F7D16DB141E09AE923215383304D241133344CB ScreenSharingApp-2.0.2-delta.nupkg 13868
 6ACCBF93CC20700AFBC3CF8489DE434C5ADD1B42 ScreenSharingApp-2.0.2-full.nupkg 1414970
 7F4FB6C1C4392C6F5A709B6650A9C6E1A52E0D80 ScreenSharingApp-2.0.3-delta.nupkg 13761
-B002214063ABD26B49C7307C4596F7AFFA302A33 ScreenSharingApp-2.0.3-full.nupkg 1415091
+B002214063ABD26B49C7307C4596F7AFFA302A33 ScreenSharingApp-2.0.3-full.nupkg 1415091
+33F7C96E27C68780D4BC63CAACD5693E34A1FCDD ScreenSharingApp-2.0.4-delta.nupkg 14311
+A84A8199EF1F26AC8A69F3963AC222F461125285 ScreenSharingApp-2.0.4-full.nupkg 1415346
+8788A6D2313B6B337A5B0E8BEC538EADC7CA7359 ScreenSharingApp-2.0.5-delta.nupkg 13425
+BD62ABA27CC7567E5FB8F8C98F590B556D29E9B5 ScreenSharingApp-2.0.5-full.nupkg 1415365
+9087E3CC5390B7F5D331B157275B5B860658533D ScreenSharingApp-2.0.6-delta.nupkg 13633
+4B591F2E3D3F2815CDAC70D31740A4915F8A4AF5 ScreenSharingApp-2.0.6-full.nupkg 1415383

ScreenSharing_Desktop/Releases/RELEASES

@@ -144,7 +144,29 @@ public static CommunicationTypes CommunicationType
     private static object Lck_Ping = new object();
 
     private static Thread SenderThread;
+    private static Thread ReceiverThread;
 
+    private static bool IsReceiverThreadEnabled = false;
+    private static bool IsSubDataReceived
+    {
+        get
+        {
+            lock (Lck_IsSubDataReceived)
+                return _isSubDataReceived;
+        }
+        set
+        {
+            lock (Lck_IsSubDataReceived)
+                _isSubDataReceived = value;
+        }
+    }
+
+    private static byte[] SubReceivedData;
+
+    private static bool _isSubDataReceived = false;
+
+    private static object Lck_SubReceivedData = new object();
+    private static object Lck_IsSubDataReceived = new object();
     #endregion
 
     #region MQ Variables
@@ -168,6 +190,7 @@ public static CommunicationTypes CommunicationType
 
     private static TimeSpan PublisherTimeBase;
     private static TimeSpan SubscriberPreviousTime;
+    private static int ScanCounter = 0;
 
     public enum CommunicationTypes
     {
@@ -252,8 +275,57 @@ public static void StartReceiving(string ip)
         TimeBaseSubscriber.OnDataReceived += TimeBaseSubscriber_OnDataReceived;
         SubStopwatch = Stopwatch.StartNew();
         CommunicationType = CommunicationTypes.Receiver;
+        IsReceiverThreadEnabled = true;
+        ReceiverThread = new Thread(ReceiverCoreFcn);
+        ReceiverThread.Start();
     }
+    private static void ReceiverCoreFcn()
+    {
+        while(IsReceiverThreadEnabled)
+        {
+            if (IsSubDataReceived)
+            {
+                IsSubDataReceived = false;
+                Stopwatch stp = Stopwatch.StartNew();
+                byte[] timeBytes = new byte[16];
+                byte[] receivedData;
+                lock(Lck_SubReceivedData)
+                {
+                    receivedData = new byte[SubReceivedData.Length];
+                    SubReceivedData.CopyTo(receivedData, 0);
+                }
 
+                Array.Copy(receivedData, 0, timeBytes, 0, timeBytes.Length);
+                string timeString = Encoding.ASCII.GetString(timeBytes);
+                TimeSpan SentTime = TimeSpan.Parse(timeString);
+                TimeSpan CurrentTime = DateTime.UtcNow.TimeOfDay;
+                PublisherTimeBase += (CurrentTime - SubscriberPreviousTime);
+                SubscriberPreviousTime = CurrentTime;
+                double deltaTime = PublisherTimeBase.TotalMilliseconds - SentTime.TotalMilliseconds;
+                if (Ping <= 0)
+                    Ping = deltaTime;
+                Ping = Ping * 0.99 + 0.01 * deltaTime;
+                byte[] ScreenBytes = new byte[receivedData.Length - timeBytes.Length];
+                Array.Copy(receivedData, timeBytes.Length, ScreenBytes, 0, ScreenBytes.Length);
+                ScreenImage = ImageProcessing.ImageFromByteArray(ScreenBytes);
+                TotalBytesReceived += receivedData.Length;
+                FpsCounter++;
+                if (SubStopwatch.ElapsedMilliseconds >= 1000)
+                {
+                    UpdateStats(TotalBytesReceived, SubStopwatch.Elapsed.TotalSeconds);
+                    TotalBytesReceived = 0;
+                    SubStopwatch.Restart();
+                }
+                IsImageShowed = true;
+            }
+            else
+            {
+                ScanCounter++;
+              
+                Thread.Sleep(1);
+            }
+        }
+    }
     private static void TimeBaseSubscriber_OnDataReceived(byte[] data)
     {
         if (data != null)
@@ -265,32 +337,18 @@ private static void TimeBaseSubscriber_OnDataReceived(byte[] data)
 
     private static void Subscriber_OnDataReceived(byte[] data)
     {
-        Stopwatch stp = Stopwatch.StartNew();
         if (data != null)
         {
-            byte[] timeBytes = new byte[16];
-            Array.Copy(data, 0, timeBytes, 0, timeBytes.Length);
-            string timeString = Encoding.ASCII.GetString(timeBytes);
-            TimeSpan SentTime = TimeSpan.Parse(timeString);
-            TimeSpan CurrentTime = DateTime.UtcNow.TimeOfDay;
-            PublisherTimeBase += (CurrentTime - SubscriberPreviousTime);
-            SubscriberPreviousTime = CurrentTime;
-            double deltaTime = PublisherTimeBase.TotalMilliseconds - SentTime.TotalMilliseconds;
-            if (Ping <= 0)
-                Ping = deltaTime;
-            Ping = Ping * 0.99 + 0.01 * deltaTime;
-            byte[] ScreenBytes = new byte[data.Length - timeBytes.Length];
-            Array.Copy(data, timeBytes.Length, ScreenBytes, 0, ScreenBytes.Length);
-            ScreenImage = ImageProcessing.ImageFromByteArray(ScreenBytes);
-            TotalBytesReceived += data.Length;
-            FpsCounter++;
-            if (SubStopwatch.ElapsedMilliseconds >= 1000)
+            lock (Lck_SubReceivedData)
+            {
+                SubReceivedData = data;
+            }
+            IsSubDataReceived = true;
+            if (ScanCounter > 250)
             {
-                UpdateStats(TotalBytesReceived, SubStopwatch.Elapsed.TotalSeconds);
-                TotalBytesReceived = 0;
-                SubStopwatch.Restart();
+                NetworkScanner.ScanAvailableDevices();
+                ScanCounter = 0;
             }
-            IsImageShowed = true;
         }
         else
         {
@@ -301,6 +359,7 @@ public static void StopReceiving()
     {
         Subscriber.Stop();
         TimeBaseSubscriber.Stop();
+        IsReceiverThreadEnabled = false;
         FPS = 0;
         TransferSpeed = 0;
     }