[Mp-webinterface-svn] SF.net SVN: mp-webinterface: [22] trunk/source/ECP2Assembly/ clsClientDiscovery.cs

[<sam...@us...>]

Revision: 22
          http://svn.sourceforge.net/mp-webinterface/?rev=22&view=rev
Author:   samuel337
Date:     2007-02-20 06:04:16 -0800 (Tue, 20 Feb 2007)

Log Message:
-----------
Thought of something better - improved client discovery code

Modified Paths:
--------------
    trunk/source/ECP2Assembly/clsClientDiscovery.cs

Modified: trunk/source/ECP2Assembly/clsClientDiscovery.cs
===================================================================
--- trunk/source/ECP2Assembly/clsClientDiscovery.cs	2007-02-20 13:44:06 UTC (rev 21)
+++ trunk/source/ECP2Assembly/clsClientDiscovery.cs	2007-02-20 14:04:16 UTC (rev 22)
@@ -24,9 +24,9 @@
             GroupTTL = groupTTL;
         }
 
-        public void IssueClientPing()
+        public void Refresh()
         {
-            if (udpComm != null)
+            if (udpComm == null)
             {
                 udpComm = new UdpMCHelper(GroupIP, GroupTTL);
                 udpComm.Start(GroupUdpPort);
@@ -35,21 +35,89 @@
             }
 
             ClientList.Clear();
+            ClientListChangedEvent(new ClientListChangedEventArgs(string.Empty, ClientListChangedEventArgs.ChangeTypes.Cleared));
 
             udpComm.Send(GroupUdpPort, UdpCommunication.MessageTypes.PING_REQUEST, "", DateTime.Now);
         }
 
         private void UdpComm_ReceiveEvent(UdpMCHelper.ReceiveEventArgs e)
         {
-            if (e.Type == UdpCommunication.MessageTypes.PING_RESPONSE)
+            switch (e.Type)
             {
-                lock (ClientList)
-                {
-                    ClientList.Add(e.HostName);
-                }
+                case UdpCommunication.MessageTypes.PING_RESPONSE:
+                    lock (ClientList)
+                    {
+                        if (!ClientList.Contains(e.HostName))
+                        {
+                            ClientList.Add(e.HostName);
+                            ClientListChangedEvent(new ClientListChangedEventArgs(e.HostName, ClientListChangedEventArgs.ChangeTypes.Added));
+                        }
+                    }
+                    break;
+
+                case UdpCommunication.MessageTypes.PLUGIN_START:
+                    lock (ClientList)
+                    {
+                        if (!ClientList.Contains(e.HostName))
+                        {
+                            ClientList.Add(e.HostName);
+                            ClientListChangedEvent(new ClientListChangedEventArgs(e.HostName, ClientListChangedEventArgs.ChangeTypes.Started));
+                        }
+                    }
+                    break;
+
+                case UdpCommunication.MessageTypes.PLUGIN_STOP:
+                    lock (ClientList)
+                    {
+                        if (ClientList.Contains(e.HostName))
+                        {
+                            ClientList.Remove(e.HostName);
+                            ClientListChangedEvent(new ClientListChangedEventArgs(e.HostName, ClientListChangedEventArgs.ChangeTypes.Stopped));
+                        }
+                    }
+                    break;
             }
         }
 
+        public delegate void ClientListChangedEventHandler(ClientListChangedEventArgs e);
+        public event ClientListChangedEventHandler ClientListChangedEvent;
+
+        public class ClientListChangedEventArgs : EventArgs
+        {
+            public enum ChangeTypes
+            {
+                Added,
+                Started,
+                Stopped,
+                Cleared
+            }
+            
+            string m_Hostname;
+            ChangeTypes m_Change;
+
+            public ClientListChangedEventArgs()
+            {
+            }
+
+            public ClientListChangedEventArgs(string hostname, ChangeTypes change)
+            {
+                Hostname = hostname;
+                Change = change;
+            }
+
+            public string Hostname
+            {
+                get { return m_Hostname; }
+                set { m_Hostname = value; }
+            }
+
+            public ChangeTypes Change
+            {
+                get { return m_Change; }
+                set { m_Change = value; }
+            }
+        }
+
         public void StopWaitingForResponses()
         {
             if (udpComm != null)


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.