From 92757a8d629812303ff3665343bd098917cca611 Mon Sep 17 00:00:00 2001 From: fcolin Date: Thu, 1 Feb 2007 12:04:16 +0000 Subject: modification structure svn --- IvyToDel/Ivy/Ivy.cs | 1183 -------------------------- IvyToDel/Ivy/Ivy.csproj | 189 ---- IvyToDel/Ivy/Ivy.csproj.vspscc | 10 - IvyToDel/Ivy/Ivy.snippet | 43 - IvyToDel/Ivy/IvyApplicationBinding.cs | 186 ---- IvyToDel/Ivy/IvyBinding.cs | 118 --- IvyToDel/Ivy/IvyBindingAttribute.cs | 31 - IvyToDel/Ivy/IvyClient.cs | 592 ------------- IvyToDel/Ivy/IvyDomain.Designer.cs | 75 -- IvyToDel/Ivy/IvyDomain.cs | 60 -- IvyToDel/Ivy/IvyDomain.resx | 120 --- IvyToDel/Ivy/IvyEventArgs.cs | 84 -- IvyToDel/Ivy/IvyException.cs | 19 - IvyToDel/Ivy/IvyProtocol.cs | 25 - IvyToDel/Ivy/IvyTCPStream.cs | 20 - IvyToDel/Ivy/IvyTCPStreamV3.cs | 254 ------ IvyToDel/Ivy/IvyTCPStreamV4.cs | 273 ------ IvyToDel/Ivy/IvyUDPStream.cs | 66 -- IvyToDel/Ivy/IvyUDPStreamV3.cs | 104 --- IvyToDel/Ivy/IvyUDPStreamV4.cs | 80 -- IvyToDel/Ivy/IvyWatcher.cs | 179 ---- IvyToDel/Ivy/Properties/AssemblyInfo.cs | 62 -- IvyToDel/Ivy/Properties/Settings.Designer.cs | 80 -- IvyToDel/Ivy/Properties/Settings.settings | 24 - IvyToDel/Ivy/Settings.cs | 28 - IvyToDel/Ivy/app.config | 30 - 26 files changed, 3935 deletions(-) delete mode 100644 IvyToDel/Ivy/Ivy.cs delete mode 100644 IvyToDel/Ivy/Ivy.csproj delete mode 100644 IvyToDel/Ivy/Ivy.csproj.vspscc delete mode 100644 IvyToDel/Ivy/Ivy.snippet delete mode 100644 IvyToDel/Ivy/IvyApplicationBinding.cs delete mode 100644 IvyToDel/Ivy/IvyBinding.cs delete mode 100644 IvyToDel/Ivy/IvyBindingAttribute.cs delete mode 100644 IvyToDel/Ivy/IvyClient.cs delete mode 100644 IvyToDel/Ivy/IvyDomain.Designer.cs delete mode 100644 IvyToDel/Ivy/IvyDomain.cs delete mode 100644 IvyToDel/Ivy/IvyDomain.resx delete mode 100644 IvyToDel/Ivy/IvyEventArgs.cs delete mode 100644 IvyToDel/Ivy/IvyException.cs delete mode 100644 IvyToDel/Ivy/IvyProtocol.cs delete mode 100644 IvyToDel/Ivy/IvyTCPStream.cs delete mode 100644 IvyToDel/Ivy/IvyTCPStreamV3.cs delete mode 100644 IvyToDel/Ivy/IvyTCPStreamV4.cs delete mode 100644 IvyToDel/Ivy/IvyUDPStream.cs delete mode 100644 IvyToDel/Ivy/IvyUDPStreamV3.cs delete mode 100644 IvyToDel/Ivy/IvyUDPStreamV4.cs delete mode 100644 IvyToDel/Ivy/IvyWatcher.cs delete mode 100644 IvyToDel/Ivy/Properties/AssemblyInfo.cs delete mode 100644 IvyToDel/Ivy/Properties/Settings.Designer.cs delete mode 100644 IvyToDel/Ivy/Properties/Settings.settings delete mode 100644 IvyToDel/Ivy/Settings.cs delete mode 100644 IvyToDel/Ivy/app.config (limited to 'IvyToDel') diff --git a/IvyToDel/Ivy/Ivy.cs b/IvyToDel/Ivy/Ivy.cs deleted file mode 100644 index 1c38396..0000000 --- a/IvyToDel/Ivy/Ivy.cs +++ /dev/null @@ -1,1183 +0,0 @@ -/// François-Régis Colin -/// http://www.tls.cena.fr/products/ivy/ -/// * -/// (C) CENA -/// * -/// - -namespace IvyBus -{ - using System; - using System.IO; - using System.Collections; - using System.Collections.Specialized; - using System.Collections.Generic; - using System.Net; - using System.Net.Sockets; - using System.Threading; - using System.Configuration; - using System.Globalization; - using System.Text.RegularExpressions; - using System.Text; - using System.Reflection; - using System.ComponentModel; - using System.Diagnostics; - -#if (!PocketPC) - using System.ComponentModel.Design; -#endif -// using System.Drawing.Design; - - - /// The Main bus Class - /// - /// -#if (!PocketPC) - // Show this property in the property grid. - [ToolboxItemFilter("System.Windows.Forms.Form", ToolboxItemFilterType.Allow)] - [Description("IVY Main API")] -#endif - [DesignerCategory("Component")] - public class Ivy : System.ComponentModel.Component, ISupportInitialize - { - /* Event */ - /// fires when a new client connect to the bus - public event EventHandler ClientConnected; - /// fires when a client discconnect from the bus - public event EventHandler ClientDisconnected; - /// fires when a client receive a direct message from another client - public event EventHandler DirectMessageReceived; - /// fires when somebody ask for killing every client on the bus - public event EventHandler DieReceived; - /// fires when a client receive a add binding from another client - public event EventHandler BindingAdd; - /// fires when a client receive a remove binding from another client - public event EventHandler BindingRemove; - /// fires when a client receive a binding from another client and it as been filtered - public event EventHandler BindingFilter; - /// fires when a client receive a remove binding from another client - public event EventHandler ErrorMessage; - -#if (!PocketPC) - [Bindable(true)] - [Category("Ivy")] -#endif - [DefaultValue(false)] - public static bool DebugProtocol - { - get - { - return debugProtocol; - } - set - { - debugProtocol = value; - } - - } -#if (!PocketPC) - [Category("Ivy")] -#endif - public CultureInfo Culture - { - get - { - return culture; - } - set - { - culture = value; - } - - } - - /// IvyClients accesses the list of the connected clients -#if (!PocketPC) - [Browsable(false)] -#endif - public List IvyClients - { - get - { - return clients; - } - - } - - /// AppName the application name - -#if (!PocketPC) - [Category("Ivy")] - [Bindable(true)] -#endif - [DefaultValue(null)] - public string AppName - { - set - { - appName = value; - } - get - { - return appName; - } - - } - /// AppId the Application Unique ID - -#if (!PocketPC) - [Browsable(false)] -#endif - public string AppId - { - get - { - return applicationUniqueId; - } - - } - /// AppPriority the Application Priority: the clients list is sorted against priority -#if (!PocketPC) - [Category("Ivy")] -#endif - [DefaultValue(DEFAULT_PRIORITY)] - public ushort AppPriority - { - set - { - applicationPriority = value; - lock (clients) - { - foreach (IvyClient client in clients) - { - client.stream.TokenApplicationId(applicationPriority, AppId); - } - } - - } - get - { - return applicationPriority; - } - - } - -#if (!PocketPC) - [Browsable(false)] -#endif - public int ProtocolVersion - { - get - { - return protocolVersion; - } - - } - - /// IsRunning is the bus Started and connected ? - -#if (!PocketPC) - [Browsable(false)] -#endif - public bool IsRunning - { - get - { - return !stopped; - } - - } - ///SentMessageClasses the first word token of sent messages - /// optimise the parsing process when sending messages - /// -#if (!PocketPC) - [Category("Ivy")] - - [DesignerSerializationVisibility(DesignerSerializationVisibility.Content)] - // sinon bug System.String constructor not found ! - [Editor("System.Windows.Forms.Design.StringCollectionEditor, System.Design", "System.Drawing.Design.UITypeEditor, System.Drawing")] -#endif - public List SentMessageFilter - { - get - { - return sent_messageFilter; - } - } - /// ReadyMessage message send when Application receive all the regexp at the connection of the client - -#if (!PocketPC) - [Bindable(true)] - [Category("Ivy")] -#endif - [DefaultValue(null)] - public string ReadyMessage - { - get { return ready_message; } - set { ready_message = value; } - } - - - - -#if (PocketPC) -#if (!PocketPC) - [Category("Ivy")] -#endif - [DefaultValue(null)] - public System.Windows.Forms.ContainerControl ContainerControl - { - get { return parentControl; } - set - { - parentControl = value; - } - } -#endif -#if (!PocketPC) - [Category("Ivy")] - [DesignerSerializationVisibility(DesignerSerializationVisibility.Content)] -#endif - public List Bindings - { - get { return app_bindings; } - } - - internal class MyTcpListener : TcpListener - { - public MyTcpListener(IPAddress address, int port) - : base(address, port) - { - } - public bool IsActive() - { - return this.Active; - } - } - /// the name of the application on the bus - internal string appName; - /// the port for the UDP rendez vous, if none is supplied - internal const ushort DEFAULT_PORT = 2010; - // client default priority - internal const ushort DEFAULT_PRIORITY = 100; - /// the domain for the UDP rendez vous - private static readonly string DEFAULT_DOMAIN = "127.255.255.255:" + DEFAULT_PORT; - internal int protocolVersion = 3; - private static bool debugProtocol; // false by default runtime - private static ushort serial; /* an unique ID for each regexp */ // 0 by default runtime - private MyTcpListener app; - private List watchers; - private volatile Thread serverThread; // to ensure quick communication of the end - - internal Dictionary bindings; - //TODO should be remove samve as above - private List app_bindings; - private List clients; - private List sent_messageFilter; - private bool stopped = true; - internal ushort applicationPort; /* Application port number */ - internal IPAddress applicationHost; /* Application host number */ - internal string applicationUniqueId; /* identifier Application unique timestamp-ipaddress-port */ - internal ushort applicationPriority = DEFAULT_PRIORITY; - private string ready_message; - private CultureInfo culture = new CultureInfo("en-us"); - // for synchronous event -#if (PocketPC) - private System.Windows.Forms.ContainerControl parentControl; -#else - private readonly SynchronizationContext syncContext; -#endif - - - /// - /// Initializes a new instance of the class. - /// - public Ivy() - { -#if (!PocketPC) - syncContext = SynchronizationContext.Current; -#endif - clients = new List(); - bindings = new Dictionary(); - app_bindings = new List(); - sent_messageFilter = new List(); -#if (!PocketPC) - debugProtocol = Properties.Settings.Default.IvyDebug; - protocolVersion = Properties.Settings.Default.IvyProtocolVersion; -#endif - // get binding from Attribute IvyBinding - //TODO Autobinding attribute -#if (PocketPC) - if (parentControl != null) - BindAttibute(parentControl); -#endif - Assembly assembly = Assembly.GetCallingAssembly(); - if ( assembly != this.GetType().Assembly ) - BindAttibute(assembly); - } - public Ivy(IContainer container) - : this() - { - container.Add(this); - // get binding from Attribute IvyBinding - //TODO Autobinding attribute - Assembly assembly = Assembly.GetCallingAssembly(); - if (assembly != this.GetType().Assembly) - BindAttibute(assembly); - } - /// - /// Readies the structures for the software bus connexion. - /// - /// This sample shows how to start working with Ivy. - /// - /// Ivy bus = new Ivy("Dummy agent","ready"); - /// bus.bindMsg("(.*)",myMessageListener); - /// bus.start(null); - /// - /// How to send & receive: - /// the Ivy agent A performs b.bindMsg("^Hello (*)",cb); - /// the Ivy agent B performs b2.sendMsg("Hello world"); - /// a thread in A will run the callback cb with its second argument set - /// to a array of string, with one single element, "world" - /// - /// - /// the real work begin in the start() method - /// - /// - /// The name of your Ivy agent on the software bus - /// - /// The hellow message you will send once ready - /// - public Ivy(string name, string rdy_message) - : this() - { - appName = name; - ready_message = rdy_message; - // get binding from Attribute IvyBinding - //TODO Autobinding attribute - Assembly assembly = Assembly.GetCallingAssembly(); - if (assembly != this.GetType().Assembly) - BindAttibute(assembly); - } - - protected override void Dispose(bool disposing) - { - try - { - if (disposing) - { - Stop(); - } - } - finally - { - base.Dispose(disposing); - } - } - - // Autobinding on static method - public void BindAttibute(Type type) - { - if (type == null) return; - //Get instance of the IvyBindingAttribute. - foreach (MethodInfo m in type.GetMethods(BindingFlags.Static | BindingFlags.NonPublic)) - { - foreach (IvyBindingAttribute attr in Attribute.GetCustomAttributes(m, typeof(IvyBindingAttribute))) - { - //TODO check paramater type MessageHandler - Debug.WriteLine("IvyBinding '" + attr.GetExpression(null) + "' to Method " + m.Name); - EventHandler handler; -#if (PocketPC) - //Createdelegate mydlg = new Createdelegate(m, null, EventArgs.Empty); - //bindMsg(attr.GetExpression(null), mydlg); - handler = null; -#else - handler = (EventHandler)Delegate.CreateDelegate(typeof(EventHandler), m); -#endif - BindMsg(attr.GetExpression(null), handler); - } - } - } - // Autobinding on instance method - public void BindAttibute(object obj) - { - if (obj == null) return; - Type type = obj.GetType(); - //Get instance of the IvyBindingAttribute. - foreach (MethodInfo m in type.GetMethods(BindingFlags.Instance | BindingFlags.NonPublic)) - { - foreach (IvyBindingAttribute attr in Attribute.GetCustomAttributes(m, typeof(IvyBindingAttribute))) - { - //TODO check paramater type MessageHandler - Ivy.traceProtocol("Ivy", "BindAttibute " + attr.GetExpression(obj) + "' to Method " + m.Name); - EventHandler handler; -#if (PocketPC) - handler = null; // TODO -#else - handler = (EventHandler)Delegate.CreateDelegate(typeof(EventHandler), obj, m); -#endif - BindMsg(attr.GetExpression(obj), handler); - } - } - - } - // Autobinding on IvyBindingAttribute method - public void BindAttibute(Assembly assy) - { - foreach (Type typ in assy.GetTypes()) - { - BindAttibute(typ); - } - - } - /// - /// connects the Ivy bus to a domain or list of domains. - /// - /// a domain of the form 10.0.0:1234, it is similar to the - /// netmask without the trailing .255. This will determine the meeting point - /// of the different applications. Right now, this is done with an UDP - /// broadcast. Beware of routing problems ! You can also use a comma - /// separated list of domains. - /// - /// One thread (IvyWatcher) for each traffic rendezvous (either UDP broadcast or TCP Multicast). - /// One thread (serverThread/Ivy) to accept incoming connexions on server socket. - /// a thread for each IvyClient when the connexion has been done. - /// - public void Start(string domainbus) - { - domainbus = GetDomain(domainbus); - try - { - long seed = DateTime.Now.Ticks / TimeSpan.TicksPerMillisecond; - Random rand = new Random( (int)seed ); - - app = new MyTcpListener(IPAddress.Any, 0); - app.Start(); // should be started before getting port - applicationHost = GetLocalIP(); - applicationPort = (ushort)((IPEndPoint)app.LocalEndpoint).Port; - applicationUniqueId = string.Format(culture,"{0}:{1}:{2}", - rand.Next(), - seed, - //applicationHost.ToString().Replace(".", ""), - applicationPort); - - } - catch (IOException e) - { - throw new IvyException("can't open TCP service socket " + e); - } - Ivy.traceProtocol("BindAttibute", "Ivy protocol: " + ProtocolVersion + " TCP service open on port " + applicationPort); - watchers = new List(); - - Domain[] d = parseDomains(domainbus); - // readies the rendezvous : an IvyWatcher (thread) per domain bus - for (int index = 0; index < d.Length; index++) - { - IvyWatcher watcher = new IvyWatcher(this, d[index].Domainaddr, d[index].Port); - watchers.Add(watcher); - } - serverThread = new Thread(new ThreadStart(this.Run)); - serverThread.Name = "Ivy Tcp Server Thread"; - stopped = false; - serverThread.Start(); - -#if (PocketPC ) - Ivy.traceProtocol("Ivy", "Threading start in progress..."); - Thread.Sleep(100); -#else - // Wait for readyness - while ( serverThread.ThreadState != System.Threading.ThreadState.Running || !app.IsActive()) - { - Ivy.traceError("BindAttibute", " Ivy Threading start in progress..." ); - Thread.Sleep( 100 ); - } -#endif - // sends the broadcasts and listen to incoming connexions - for (int i = 0; i < watchers.Count; i++) - { - watchers[i].start(); - } - } - internal void SortClients() - { - lock (clients) - { - //clients.Sort(new IvyClient.IvyClientPriority()); - clients.Sort(); - } - } - /* a small private method for debbugging purposes */ - - public static string Domains(string toparse) - { - string domainbus = GetDomain(toparse); - StringBuilder s = new StringBuilder("broadcasting on "); - Ivy.Domain[] d = parseDomains(domainbus); - for (int index = 0; index < d.Length; index++) - { - s.Append(d[index].Domainaddr); - s.Append(":"); - s.Append(d[index].Port); - s.Append(" "); - } - return s.ToString(); - } - - internal static Domain[] parseDomains(string domainbus) - { - string[] st = domainbus.Split(','); - Domain[] d = new Domain[st.Length]; - for (int i = 0; i < st.Length; i++) - { - d[i] = new Domain(st[i]); - } - return d; - } - - /// - /// disconnects from the Ivy bus - /// - public void Stop() - { - if (stopped) - return; - lock (app) - { - stopped = true; - Ivy.traceProtocol("Ivy", "beginning stopping the bus"); - try - { - // stopping the serverThread - if (serverThread != null) - { - app.Stop(); - // Wait for Thread to end. - bool term = serverThread.Join(10000); - if (!term && (serverThread != null)) serverThread.Abort(); - serverThread = null; - } - // The serverThread might be stopped even before having been created - if (app != null) - app.Stop(); - // stopping the IvyWatchers - if (watchers != null) - for (int i = 0; i < watchers.Count; i++) - { - ((IvyWatcher)watchers[i]).stop(); - } - // stopping the remaining IvyClients - // copy the values in temporary variable to eliminate Thread modifying collection - if (clients.Count != 0) - { - IvyClient[] copyClient; - copyClient = new IvyClient[clients.Count]; - lock (clients) - { - clients.CopyTo(copyClient, 0); - } - foreach (IvyClient client in copyClient) - { - client.close(true); // will notify the reading thread - //removeClient(client); already donne in the thread - } - } - } - catch (IOException e) - { - Ivy.traceError("Ivy", "IOexception Stop " + e.Message); - } - Ivy.traceProtocol("Ivy", "the bus should have stopped so far"); - } - } - - - /// - /// Send a formated message to someone on the bus - /// - /// - /// Performs a pattern matching according to everyone's regexps, and sends - /// the results to the relevant ivy agents. - /// There is one thread for each client connected, we could also - /// create another thread each time we send a message. - /// - /// A string message format to build the message - /// args used in message format - /// - /// the number of messages actually sent - /// - public int SendMsg(string format, params object[] args) - { - string msg = string.Format(culture, format, args); - int count = 0; - // an alternate implementation would one sender thread per client - // instead of one for all the clients. It might be a performance issue - lock (clients) - { - // hash message in V4 protocol only - if (ProtocolVersion == 4) - IvyBindingSimple.Prepare(msg); - foreach (IvyClient client in clients) - { - count += client.sendMsg(msg); - } - } - return count; - } - // - public ushort BindMsg(IvyApplicationBinding newbind) - { - newbind.Key = serial++; - - lock (bindings) bindings.Add(newbind.Key, newbind); - // notifies the other clients this new regexp - lock (clients) - { - foreach (IvyClient c in clients) - { - c.stream.TokenAddBinding(newbind.Binding, newbind.Key, newbind.FormatedExpression); - } - } - return newbind.Key; - } - /// - /// Subscribes to a regular expression. - /// - /// a regular expression, groups are done with parenthesis - /// any objects implementing the Ivy.MessageListener - /// The args. - /// the id of the regular expression - /// - /// The callback will be executed with - /// the saved parameters of the regexp as arguments when a message will sent - /// by another agent. A program doesn't receive its own messages. - /// - // - public ushort BindMsg(string regexp, EventHandler callback, params object[] args) - { - // creates a new binding (regexp,callback) - IvyApplicationBinding newbind; - newbind = new IvyApplicationBinding(); - newbind.Binding = BindingType.Regexp; - newbind.Expression = regexp; - newbind.Callback += callback; - newbind.Args = args; - return BindMsg(newbind); - } - - /// - /// unsubscribes a regular expression - /// - /// the id of the regular expression, returned when it was bound - public void UnbindMsg(ushort id) - { - if (!bindings.ContainsKey(id)) - { - throw new IvyException("client wants to remove an unexistant regexp " + id); - } - lock (clients) - { - foreach (IvyClient c in clients) - { - c.stream.TokenDelBinding(id); - } - } - lock (bindings) bindings.Remove(id); - } - - /// - /// unsubscribes a regular expression - /// - /// the string for the regular expression - /// - /// a boolean, true if the regexp existed, false otherwise or - /// whenever an exception occured during unbinding - /// - public bool UnbindMsg(string re) - { - foreach (IvyApplicationBinding bind in bindings.Values) - { - if (bind.Expression == re) - { - try - { - UnbindMsg(bind.Key); - } - catch (IvyException) - { - return false; - } - return true; - } - } - return false; - } - - - /// - /// Subscribes to a simple expression ( msg ar1 arg2 arg3 etc). - /// - /// - /// The callback will be executed with - /// the saved parameters of the regexp as arguments when a message will sent - /// by another agent. A program doesn't receive its own messages. - /// - /// - /// a regular expression, groups are done with parenthesis - /// any objects implementing the EventHandler - /// - /// the id of the regular expression - /// - public int BindSimpleMsg(string expression, EventHandler callback, params object[] args) - { - // creates a new binding (regexp,callback) - IvyApplicationBinding newbind; - newbind = new IvyApplicationBinding(); - newbind.Binding = BindingType.Simple; - newbind.Expression = expression; - newbind.Callback += callback; - newbind.Args = args; - return BindMsg(newbind); - } - /// - /// Dies the specified target. - /// - /// The target. - /// The reason message. - /// - public int Die(string target, string message) - { - List v = GetClientsByName(target); - for (int i = 0; i < v.Count; i++) - v[i].stream.TokenDie(0, message); - return v.Count; - } - /// - /// Pings the specified target. - /// - /// The target. - /// The message. - /// - public int Ping(string target, string message) - { - List v = GetClientsByName(target); - for (int i = 0; i < v.Count; i++) - v[i].stream.TokenPing(message); - return v.Count; - } -#if (PocketPC) - internal virtual void FireEvent(EventHandler ev, IvyEventArgs e) - { - if (ev != null) - { - if (parentControl != null) - { - parentControl.Invoke(ev, this, e); - } - else - ev(this, e); - } - } -#else - internal virtual void FireEvent(EventHandler ev, IvyEventArgs e) - { - if (ev != null) - { - if (syncContext != null) - { - SendOrPostCallback update = delegate(object state) - { - IvyEventArgs args = (IvyEventArgs)state; - ev(this, args); - }; - syncContext.Post(update, e); - } - else - ev(this, e); - } - } - -#endif - internal virtual void OnDirectMessage(IvyEventArgs e) - { - // Copy to a temporary variable to be thread-safe. - EventHandler temp = DirectMessageReceived; - FireEvent(temp,e); - } - internal virtual void OnClientConnected(IvyEventArgs e) - { - // Copy to a temporary variable to be thread-safe. - EventHandler temp = ClientConnected; - FireEvent(temp,e); - } - internal virtual void OnClientDisconnected(IvyEventArgs e) - { - // Copy to a temporary variable to be thread-safe. - EventHandler temp = ClientDisconnected; - try - { - FireEvent(temp,e); - } -#if (!PocketPC) - catch (SynchronizationLockException ex) - { - // protect terminaison - } -#endif - catch (ObjectDisposedException) - { - // protect terminaison - } - - } - internal virtual void OnClientAddBinding(IvyEventArgs e) - { - // Copy to a temporary variable to be thread-safe. - EventHandler temp = BindingAdd; - FireEvent(temp,e); - } - internal virtual void OnClientRemoveBinding(IvyEventArgs e) - { - // Copy to a temporary variable to be thread-safe. - EventHandler temp = BindingRemove; - FireEvent(temp,e); - } - internal virtual void OnClientFilterBinding(IvyEventArgs e) - { - // Copy to a temporary variable to be thread-safe. - EventHandler temp = BindingFilter; - FireEvent(temp,e); - } - internal virtual void OnError(IvyEventArgs e) - { - // Copy to a temporary variable to be thread-safe. - EventHandler temp = ErrorMessage; - FireEvent(temp, e); - } -#if (PocketPC) - internal virtual void OnDie(IvyDieEventArgs e) - { - // Copy to a temporary variable to be thread-safe. - EventHandler temp = DieReceived; - if (temp != null) - { - if (parentControl != null) - { - parentControl.Invoke(temp, this, e); - } - else - temp(this, e); - } - } - -#else - internal virtual void OnDie(IvyDieEventArgs e) - { - // Copy to a temporary variable to be thread-safe. - EventHandler temp = DieReceived; - if (temp != null) - { - if (syncContext != null) - { - SendOrPostCallback update = delegate(object state) - { - IvyDieEventArgs args = (IvyDieEventArgs)state; - temp(this, args); - }; - syncContext.Post(update, e); - } - else - temp(this, e); - } - } -#endif - internal void OnMessage(IvyMessageEventArgs e) - { - IvyApplicationBinding bind = bindings[e.Id]; - - if (bind == null) - { - throw new IvyException("(callCallback) Not regexp matching id " + e.Id); - } -#if(PocketPC) - bind.Firevent(parentControl, e); -#else - bind.Firevent(syncContext, e); -#endif - } - - /* - * removes a client from the list - */ - internal void removeClient(IvyClient c) - { - lock (clients) - { - clients.Remove(c); - } - } - - - /// - /// gives a list of IvyClient(s) with the name given in parameter - /// - /// The name of the Ivy agent you're looking for - /// - public List GetClientsByName(string name) - { - List v = new List(); - foreach (IvyClient ic in clients) - { - if (ic.ApplicationName.CompareTo(name) == 0) - v.Add(ic); - } - return v; - } - - /////////////////////////////////////////////////////////////////: - // - // Protected methods - // - /////////////////////////////////////////////////////////////////: - - internal void addClient(Socket socket, string appname) - { - if (stopped) - return; - IvyClient client = new IvyClient(this, socket, appname); - lock (clients) - { - clients.Add(client); - } - client.SendBindings(); - } - - - public static IPAddress GetLocalIP() - { - IPAddress returnaddr = null; - //TODO remove ALL reverse DNS search !!!! - IPHostEntry ip = Dns.GetHostEntry(Dns.GetHostName()); - foreach (IPAddress addr in ip.AddressList) - { - returnaddr = addr; - if (IPAddress.IsLoopback(addr)) continue; - break; - } - return returnaddr; - } - - public static string GetDomain(string domainbus) - { -#if (PocketPC) // TODO integrate in normal version - if (domainbus == null || domainbus.Length == 0) - { - IPAddress addr = GetLocalIP(); - //TODO Find Braodcast addr from IP; - byte[] bytes = addr.GetAddressBytes(); - if (IPAddress.IsLoopback(addr)) - { - // 127.255.255.255 - bytes[1] = 255; - bytes[2] = 255; - bytes[3] = 255; - } - else - { - // else assume class C network - // TODO find exact netmask - bytes[3] = 255; - } - IPAddress bcast = new IPAddress(bytes); - domainbus = bcast + ":" + Domain.getPort(domainbus); - } -#else - if (domainbus == null || domainbus.Length == 0 ) - { - domainbus = Environment.GetEnvironmentVariable("IVYBUS"); - } - - if (domainbus == null || domainbus.Length == 0) - { - domainbus = Properties.Settings.Default.IvyBus; - } -#endif - if (domainbus == null || domainbus.Length == 0) - domainbus = DEFAULT_DOMAIN; - return domainbus; - } - - - /// checks the "validity" of a regular expression. //TODO put in IvyBinding - internal bool CheckRegexp(string exp) - { - bool regexp_ok = true; - // Attention Bug - // ClockStop ClockStart & ^Clock(Start|Pause) - // should Stop to the first parent - if ((sent_messageFilter.Count != 0) && exp.StartsWith("^")) - { - regexp_ok = false; - // extract first word from regexp... - string token = Regex.Replace(exp, @"^\^(?[a-zA-Z_0-9-]+).*", @"${token}"); - - foreach (string exp_class in sent_messageFilter) - { - if (exp_class.StartsWith(token)) - return true; - } - } - return regexp_ok; - } - - /* - * prevents two clients from connecting to each other at the same time - * there might still be a lingering bug here, that we could avoid with the - * SchizoToken. - */ - //TODO bug multiple instance Reco car en 127.0.0.1 - internal bool checkConnected(IvyClient clnt) - { - if (clnt.AppPort == 0) - return false; - lock (clients) - { - foreach (IvyClient client in clients) - { - if (clnt != client && client.sameClient(clnt)) - return true; - } - } - return false; - } - - /* - * the service socket thread reader main loop - */ - private void Run() - { - Ivy.traceProtocol("Ivy", "Ivy service Thread started"); - bool running = true; - while (running) - { - try - { - Socket socket = app.AcceptSocket(); - if (stopped) - break; - // early disconnexion - addClient(socket, "Unkown(waiting for name reception)"); // the peer called me - } - catch (IOException e) - { - Ivy.traceError("Ivy","Ivy server socket reader caught an exception: " + e.Message); - } - catch (SocketException e) - { - Ivy.traceError("Ivy","my server socket has been closed " + e.Message); - running = false; - } - } - Ivy.traceProtocol("Ivy", "Ivy service Thread stopped"); - } - - [Conditional("DEBUG")] - internal static void traceProtocol(string name, string message) - { - if ( debugProtocol ) - Console.WriteLine( "-->{0}<-- {1}", name, message); - } - internal static void traceError(string name, string message) - { - Console.WriteLine("-->{0}<-- {1}", name, message); - } - - internal class Domain - { - public virtual string Domainaddr - { - get - { - return domainaddr; - } - - } - public virtual int Port - { - get - { - return port; - } - - } - private string domainaddr; - private int port; - public Domain(string net) - { - this.domainaddr = getDomain(net); - this.port = getPort(net); - } - public Domain(string domainaddr, int port) - { - this.domainaddr = domainaddr; this.port = port; - } - public override string ToString() - { - return domainaddr + ":" + port; - } - public static string getDomain(string net) - { - int sep_index = net.LastIndexOf(":"); - if (sep_index != -1) - { - net = net.Substring(0, (sep_index) - (0)); - } - try - { - net += ".255.255.255"; - Regex exp = new Regex("^(\\d+\\.\\d+\\.\\d+\\.\\d+).*"); - net = exp.Replace(net, "$1"); - } - catch (ArgumentException e) - { - Ivy.traceError("Ivy","Bad broascat addr " + net + "error " + e.Message); - return null; - } - return net; - } - - public static int getPort(string net) - { - if (net == null) return Ivy.DEFAULT_PORT; - int sep_index = net.LastIndexOf(":"); - int port = (sep_index == -1) ? Ivy.DEFAULT_PORT : Int32.Parse(net.Substring(sep_index + 1)); - return port; - } - } - - - public static bool ValidatingDomain(string p) - { - // domain if of the form ip1[:port][,ip2[:port]] with ip of the form n1.n2.n3.n4 - return Regex.IsMatch(p, @"\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}:\d+"); - } - - #region ISupportInitialize Members - - public void BeginInit() - { - - } - - public void EndInit() - { - // TODO ugly should be added directly the bindings Dictionary ! - foreach (IvyApplicationBinding bind in app_bindings) - { - BindMsg(bind); - } - } - - #endregion - - } -} \ No newline at end of file diff --git a/IvyToDel/Ivy/Ivy.csproj b/IvyToDel/Ivy/Ivy.csproj deleted file mode 100644 index 1944b08..0000000 --- a/IvyToDel/Ivy/Ivy.csproj +++ /dev/null @@ -1,189 +0,0 @@ - - - Local - 8.0.50727 - 2.0 - {F2F03CF7-0087-4EDB-AD15-80C9E8DA2617} - SAK - SAK - SAK - SAK - Debug - AnyCPU - - - - - Ivy - - - JScript - Grid - IE50 - false - Library - IvyBus - OnBuildSuccess - - - - - - - - - bin\Debug\ - false - 285212672 - false - - - - - - - true - 4096 - false - - - false - false - false - false - 1 - full - prompt - AnyCPU - - - bin\Release\ - false - 285212672 - false - - - - - - - false - 4096 - false - - - false - false - false - false - 1 - none - prompt - - - true - bin\x86\Debug\ - 285212672 - 1 - full - x86 - prompt - - - - - bin\x86\Release\ - 285212672 - 1 - - - x86 - prompt - - - - mscorlib - - - System - - - - System.Design - - - - System.Management - - - System.Windows.Forms - - - - - - Component - - - - UserControl - - - IvyDomain.cs - - - - - - - Code - - - Component - - - Code - - - Code - - - Code - - - Code - - - - - Code - - - True - True - Settings.settings - - - - - - - - SettingsSingleFileGenerator - Settings.Designer.cs - - - - - Designer - IvyDomain.cs - - - - - - - - - - \ No newline at end of file diff --git a/IvyToDel/Ivy/Ivy.csproj.vspscc b/IvyToDel/Ivy/Ivy.csproj.vspscc deleted file mode 100644 index 831ab8f..0000000 --- a/IvyToDel/Ivy/Ivy.csproj.vspscc +++ /dev/null @@ -1,10 +0,0 @@ -"" -{ -"FILE_VERSION" = "9237" -"ENLISTMENT_CHOICE" = "NEVER" -"PROJECT_FILE_RELATIVE_PATH" = "relative:Ivy" -"NUMBER_OF_EXCLUDED_FILES" = "0" -"ORIGINAL_PROJECT_FILE_PATH" = "" -"NUMBER_OF_NESTED_PROJECTS" = "0" -"SOURCE_CONTROL_SETTINGS_PROVIDER" = "PROVIDER" -} diff --git a/IvyToDel/Ivy/Ivy.snippet b/IvyToDel/Ivy/Ivy.snippet deleted file mode 100644 index 5319177..0000000 --- a/IvyToDel/Ivy/Ivy.snippet +++ /dev/null @@ -1,43 +0,0 @@ - - - -
- - Ivy Message Callback - -
- - - - Ivy.dll - - - - - IvyBus - - - - - CallbackName - Replace with a function name. - bus_receive - - - Expression - Replace with a regular expression. - "^(.*)" - - - - - - - - diff --git a/IvyToDel/Ivy/IvyApplicationBinding.cs b/IvyToDel/Ivy/IvyApplicationBinding.cs deleted file mode 100644 index 9183850..0000000 --- a/IvyToDel/Ivy/IvyApplicationBinding.cs +++ /dev/null @@ -1,186 +0,0 @@ -using System; -using System.Collections.Generic; -using System.Collections.Specialized; -using System.Text; -using System.ComponentModel; -using System.Threading; - -namespace IvyBus -{ - /* This is the Application side of binding storage */ - /* association of a generated Key and a delegate and the expression */ - /* this is SEND to other client */ -#if (!PocketPC) - [PropertyTab(typeof(System.Windows.Forms.Design.EventsTab), PropertyTabScope.Component)] - [DefaultEvent("Callback")] -#endif - [DesignerCategory("Component")] - [DesignTimeVisible(false)] /* should be added via Ivy component */ - public class IvyApplicationBinding : System.ComponentModel.Component - { - private BindingType binding; - -#if (!PocketPC) - [Category("Ivy")] -#endif - public BindingType Binding - { - get { return binding; } - set { binding = value; } - } - private ushort key; - - #if (!PocketPC) - [Browsable(false)] - [DesignerSerializationVisibility(DesignerSerializationVisibility.Hidden)] -#endif - public ushort Key - { - get { return key; } - set { key = value; } - } - - private object[] args; -#if (!PocketPC) - [Browsable(false)] - [DesignerSerializationVisibility(DesignerSerializationVisibility.Hidden)] -#endif - public object[] Args - { - get { return args; } - set { args = value; } - } - private string expression; -#if (!PocketPC) - [Category("Ivy")] -#endif - [DefaultValue(null)] - public string Expression - { - get { return expression; } - set { expression = value; } - } - private string formated_expression; - public string FormatedExpression - { - get - { - FormatExpression(); - return formated_expression; - } - } - - private List arguments; - ///SentMessageClasses the first word token of sent messages - /// optimise the parsing process when sending messages - /// -#if (!PocketPC) - [Category("Ivy")] - - [DesignerSerializationVisibility(DesignerSerializationVisibility.Content)] - - // sinon bug System.String constructor not found ! - [Editor( - "System.Windows.Forms.Design.StringCollectionEditor, System.Design, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a", - "System.Drawing.Design.UITypeEditor,System.Drawing, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a" - )] - - [Description("Arguments used when formating the expression")] -#endif - public List Arguments - { - get - { - return arguments; - } - } - -#if (!PocketPC) - [Category("Ivy")] - [Description("Event fired when Message Matching expression received")] -#endif - public event EventHandler Callback; - - public IvyApplicationBinding() - { - arguments = new List(); - } - public IvyApplicationBinding(IContainer container) - : this() - { - container.Add(this); - } - // translate part of expression to object property - public void FormatExpression() - { - //// Safely : -#if (!PocketPC)//TODO Pocket PC doesn't have Target Member - EventHandler temp = Callback; - if (temp != null) - { - //TODO Pocket PC doesn't have Target Member - object target = temp.Target; - if (args == null) - { - args = new object[arguments.Count]; - for (int i = 0; i < arguments.Count; i++) - { - System.Reflection.PropertyInfo prop = target.GetType().GetProperty(arguments[i]); - if (prop != null) - args[i] = prop.GetValue(target, null); - else //TODO what else BUG msgbox in desing mode !!! - args[i] = arguments[i]; - } - } - formated_expression = string.Format(expression, args); - } - else //TODO Abnormal condition Design Time -#endif - formated_expression = expression; - - } - -#if ( PocketPC ) - internal void Firevent(System.Windows.Forms.Control control, IvyMessageEventArgs e) - { - //// Safely invoke an event: - EventHandler temp = Callback; - - if (temp == null) - { - throw new IvyException("(callCallback) Not callback for id " + e.Id); - } - if (control != null) - { - control.Invoke(temp, this, e); - } - else - temp(this, e); - } -#else - internal void Firevent(System.Threading.SynchronizationContext syncContext, IvyMessageEventArgs e) - { - //// Safely invoke an event: - EventHandler temp = Callback; - - if (temp == null) - { - throw new IvyException("(callCallback) Not callback for id " + e.Id); - } - if (syncContext != null) - { - SendOrPostCallback update = delegate(object state) - { - IvyMessageEventArgs args = (IvyMessageEventArgs)state; - temp(this, args); - }; - syncContext.Post(update, e); - } - else - temp(this, e); - } - -#endif - } - -} diff --git a/IvyToDel/Ivy/IvyBinding.cs b/IvyToDel/Ivy/IvyBinding.cs deleted file mode 100644 index 624b401..0000000 --- a/IvyToDel/Ivy/IvyBinding.cs +++ /dev/null @@ -1,118 +0,0 @@ -using System; -using System.Collections; -using System.Collections.Specialized; -using System.Text.RegularExpressions; -using System.Diagnostics; - -namespace IvyBus -{ - /* This is the Client side of binding storage */ - /* association of a generated Key and the expression and a compiled Expression matching */ - /* this is RECEIVED from other client */ - - /// - /// Description résumée de IvyBinding. - /// - internal abstract class IvyBindingBase - { - - private ushort key; - - internal ushort Key - { - get { return key; } - } - protected string expression; - - internal string Expression - { - get { return expression; } - } - - internal IvyBindingBase(ushort id, string exp) - { - key = id; - expression = exp; - } - internal abstract string[] Match(string message); - - } - internal class IvyBindingRegexp : IvyBindingBase - { - internal Regex regexp; - - public IvyBindingRegexp(ushort id, string exp) - : base(id, exp) - { - regexp = new Regex(expression, /* RegexOptions.Compiled | */RegexOptions.IgnoreCase | RegexOptions.CultureInvariant); - //regexp.Match("###"); // for really compile the expression really slow on 3000 expression - } - internal override string[] Match(string message) - { - string[] args = null; - // use of regexp to extract info - Match result = regexp.Match(message); - if (result.Success) - { - // Start at 1 because group 0 represent entire matching - args = new string[result.Groups.Count-1]; - for (int sub = 1; sub < result.Groups.Count; sub++) - { - args[sub-1] = result.Groups[sub].Value; - } - } - return args; - } - } - internal class IvyBindingSimple : IvyBindingBase - { - internal string msgname; // message name - internal string[] msgargs; // list of message args names - static string msgtag; // send message name - static StringDictionary args_values; // send message args[name]=value - - internal IvyBindingSimple(ushort id, string exp) - : base(id, exp) - { - string[] expr = expression.Split( ' ' ); - msgname = expr[0]; - msgargs = new string[ expr.Length -1 ]; - for ( int i = 1; i < expr.Length; i++ ) - msgargs[i-1] = expr[i]; - } - static internal void Prepare(string message) - { - string[] msg = message.Split(' '); - msgtag = msg[0]; - args_values = new StringDictionary(); - for( int sub=1 ; sub < msg.Length; sub++ ) - { - string[] arg = msg[sub].Split('='); // champ = valeur - if ( arg.Length == 2 ) - args_values[arg[0]] = arg[1]; - else - { - Ivy.traceError("IvyBindingSimple" , "abnormally Formed message expected 'msg champ=valeur champ=valeur....' :" + message); - } - } - - } - internal override string[] Match(string message) - { - // the message is already parsed by prepare - // - string[] args = null; - - if (msgtag == msgname) - { - args = new string[msgargs.Length]; - for( int sub= 0; sub < msgargs.Length; sub++) - { - args[sub] = args_values[msgargs[sub]]; - } - } - return args; - } - - } -} diff --git a/IvyToDel/Ivy/IvyBindingAttribute.cs b/IvyToDel/Ivy/IvyBindingAttribute.cs deleted file mode 100644 index 90c44ce..0000000 --- a/IvyToDel/Ivy/IvyBindingAttribute.cs +++ /dev/null @@ -1,31 +0,0 @@ -using System; -using System.Collections.Generic; -using System.Text; - -namespace IvyBus -{ - [AttributeUsage(AttributeTargets.Method,AllowMultiple = true)] - public sealed class IvyBindingAttribute : Attribute - { - private string expression; - private string[] args; - - // translate part of expression to object property - public string GetExpression(object obj) - { - if (obj == null) return string.Format(expression); - object[] values = new object[args.Length]; - for (int i = 0; i < args.Length; i++) - { - values[i] = obj.GetType().GetProperty(args[i]).GetValue(obj,null); - } - return string.Format(expression,values); - } - - public IvyBindingAttribute(string expression, params string[] args) - { - this.expression = expression; - this.args = args; - } - } -} diff --git a/IvyToDel/Ivy/IvyClient.cs b/IvyToDel/Ivy/IvyClient.cs deleted file mode 100644 index 3db9f0f..0000000 --- a/IvyToDel/Ivy/IvyClient.cs +++ /dev/null @@ -1,592 +0,0 @@ -/// François-Régis Colin -/// http://www.tls.cena.fr/products/ivy/ -/// * -/// (C) CENA -/// * -namespace IvyBus -{ - using System; - using System.Collections; - using System.Collections.Specialized; - using System.Collections.Generic; - using System.Threading; - using System.Text; - using System.IO; - using System.Net; - using System.Net.Sockets; - using System.Configuration; - using System.Diagnostics; - - /// A Class for the the peers on the bus. - /// - /// - /// each time a connexion is made with a remote peer, the regexp are exchanged - /// once ready, a ready message is sent, and then we can send messages, - /// die messages, direct messages, add or remove regexps, or quit. A thread is - /// created for each remote client. - /// - public class IvyClient : IvyProtocol, IComparable, IDisposable - { - public int CompareTo(IvyClient other) - { - return (other.clientPriority - clientPriority); - } - - public String ApplicationName - { - get - { - return appName; - } - - } - - public List Regexps - { - get - { - List tab = new List(); - lock (bindings) - { - foreach (IvyBindingBase bind in bindings.Values) - tab.Add(bind.Expression); - } - return tab; - } - - } - internal int AppPort - { - get - { - return appPort; - } - - } - public IPAddress RemoteAddress - { - get - { - return remoteHost; - } - - } - public int RemotePort - { - get - { - return remotePort; - } - - } - - private Ivy bus; - private Dictionary bindings; - private int appPort; - private string clientId; /* an unique ID for each IvyClient */ - private int clientPriority; /* client priority */ - - private volatile Thread clientThread; // volatile to ensure the quick communication - private bool doping; // false by runtime default - private const int PINGTIMEOUT = 5000; - private volatile Thread pingerThread; - - private int remotePort; - private IPAddress remoteHost; - - // protected variables - internal String appName; - internal IvyProtocol stream; - - internal IvyClient(Ivy bus, Socket socket, string appname) - { - bindings = new Dictionary(); - appName = appname; - this.bus = bus; - - IPEndPoint endpoint = (IPEndPoint)socket.RemoteEndPoint; - - remoteHost = endpoint.Address; - remotePort = endpoint.Port; - -#if (!PocketPC ) - socket.SetSocketOption( SocketOptionLevel.Tcp, SocketOptionName.KeepAlive, 1 ); -#endif - - if ( bus.ProtocolVersion == 4 ) - stream = new IvyTCPStreamV4( socket, this ); - else - stream = new IvyTCPStreamV3(socket, this); - - clientPriority = Ivy.DEFAULT_PRIORITY; - // spawns a thread to manage the incoming traffic on this - // socket. We should be ready to receive messages now. - clientThread = new Thread(new ThreadStart(this.Run)); - clientThread.Name = "Ivy Tcp Client Reader Thread ("+appname+")"; - clientThread.Start(); - - } - - internal void SendBindings() - { - try - { - stream.TokenApplicationId(bus.applicationPriority, bus.AppId); - - // sends our ID, whether we initiated the connexion or not - // the ID is the couple "host name,application Port", the host name - // information is in the socket itself, the port is not known if we - // initiate the connexion - stream.TokenStartRegexp(bus.applicationPort, bus.appName); - // sends our regexps to the peer - lock (bus.bindings) - { - foreach (IvyApplicationBinding bind in bus.bindings.Values) - { - stream.TokenAddBinding(bind.Binding, bind.Key, bind.FormatedExpression); - } - } - stream.TokenEndRegexp(); - -#if (!PocketPC) - doping = Properties.Settings.Default.IvyPing; -#endif - if (doping) - { - pingerThread = new Thread(new ThreadStart(PingerRun)); - pingerThread.Name = "Ivy Pinger Thread"; - pingerThread.Start(); - } - - - } - catch (IOException ex) - { // the client nous a coupé l'herbe sous le pied - Ivy.traceError("IvyClient","I can't send my message to this client. He probably left " + ex.Message); - // invokes the Disconnected applicationListeners - //bus.OnClientDisconnected(new IvyEventArgs(this,id, message )); - // called by the receiver Thread - close(false); - } - } - - /// returns the name of the remote agent. - /// allow an Ivy package class to access the list of regexps at a - /// given time. - /// perhaps we should implement a new IvyApplicationListener method to - /// allow the notification of regexp addition and deletion - /// - - /// sends a direct message to the peer - /// - /// the numeric value provided to the remote client - /// - /// the string that will be match-tested - /// - /// - public void SendDirectMsg(ushort id, string message) - { - try - { - stream.TokenDirectMsg( id, message); - } - catch (IOException ex) - { - Ivy.traceError("IvyClient","I can't send my message to this client. He probably left "+ex.Message); - // first, I'm not a first class IvyClient any more - bus.removeClient(this); - // invokes the Disconnected applicationListeners - //bus.OnClientDisconnected(new IvyEventArgs(this,id, message )); - // should be called by receiver thread - close(false); - } - } - - /// closes the connexion to the peer. - /// - /// should I send Bye message ? - /// the thread managing the socket is stopped - /// - /// - internal void close(bool notify) - { - Ivy.traceProtocol("IvyClient","closing connexion to " + appName); - if (doping ) - { - StopPinging(); - } - if (notify) - try - { - stream.TokenBye(0, "hasta la vista"); - } - catch (IOException ioe) - { - throw new IvyException(ioe.Message); - } - // stop the thread and close the stream - if (clientThread == null) - return; - // Tell Thread to stop. - if (stream != null) - { - try - { - stream.Close(); // should stop the Reading Client Thread - } - catch (IOException ioe) - { - throw new IvyException(ioe.Message); - } - //socket.Close(); // pris en charge par stream ( NetWorkStream ) - stream = null; - } - // Potential dead lok when thread issue ClientDisconnected event - //if (Thread.CurrentThread != clientThread && (clientThread != null)) - //{ - // // Wait for Thread to end. - // bool term = clientThread.Join(10000); - // if (!term && (clientThread != null)) clientThread.Abort(); - //} - - clientThread = null; - - - } - - /// sends the substrings of a message to the peer for each matching regexp. - /// - /// the string that will be match-tested - /// - /// the number of messages sent to the peer - /// - /// - internal int sendMsg(String message) - { - int count = 0; - - lock( bindings ) - { - try - { - foreach (IvyBindingBase bind in bindings.Values) - { - string[] args = bind.Match(message); - if (stream != null && args != null) - { - stream.TokenMsg(bind.Key, args); - count++; - } - } - } - catch (IOException ex) - { - Ivy.traceError("IvyClient","I can't send my message to this client. He probably left " + ex.Message); - // first, I'm not a first class IvyClient any more - bus.removeClient(this); - // invokes the Disconnected applicationListeners - // in the receiver thread - close(false); - } - - - } - return count; - } - - /// compares two peers the id is the couple (host,service port). - /// - /// the other peer - /// - /// true if the peers are similir. This should not happen, it is bad - /// © ® (tm) - /// - /// - internal bool sameClient(IvyClient clnt) - { - return (appPort != 0 && appPort == clnt.appPort) && (RemoteAddress == clnt.RemoteAddress); - } - - /// the code of the thread handling the incoming messages. - /// - private void Run() - { - Ivy.traceProtocol("IvyClient","Connected from " + RemoteAddress + ":" + RemotePort); - - Ivy.traceProtocol("IvyClient","Thread started"); - - bool running = true; - while ( running && (stream != null) ) - { - try - { - if ( stream.receiveMsg() ) - { - // early stop during readLine() - if (doping && (pingerThread != null)) - pingerThread.Abort(); - } - else - { - Ivy.traceProtocol("IvyClient","receiveMsg false ! leaving the thread"); - running = false; - break; - } - } - catch ( ObjectDisposedException ex ) - { - Ivy.traceError("IvyClient", "socket closed "+ex.Message ); - running = false; - break; - } - catch (IvyException ie) - { - Ivy.traceError("IvyClient","socket closed IvyException" + ie.Message); - running = false; - break; - } - catch (SocketException se) - { - Ivy.traceError("IvyClient", "socket closed "+se.Message ); - running = false; - break; - } - catch (IOException ex) - { - if ( ex.InnerException is SocketException ) - { - Ivy.traceProtocol("IvyClient", "socket closed" ); - - } - else - { - Ivy.traceError("IvyClient","abnormally Disconnected from " + RemoteAddress + ":" + RemotePort); - } - running = false; - break; - } - } - Ivy.traceProtocol("IvyClient","normally Disconnected from " + appName); - Ivy.traceProtocol("IvyClient","Thread stopped"); - // invokes the Disconnected applicationListeners - bus.OnClientDisconnected(new IvyEventArgs(this,0, "" )); - // first, I'm not a first class IvyClient any more - if (stream != null) - { - stream.Close(); - stream = null; - } - bus.removeClient(this); - - } - void IvyProtocol.Close() - { - // never call in this side - } - bool IvyProtocol.receiveMsg() - { - // nerver call in this side - return false; - } - void IvyProtocol.TokenDie(ushort id, string arg) - { - Ivy.traceProtocol("IvyClient","received die Message from " + appName + "Raison: "+ arg); - // invokes the die applicationListeners - IvyDieEventArgs ev = new IvyDieEventArgs(this, id, arg); - bus.OnDie(ev); - // first, I'm not a first class IvyClient any more - bus.removeClient(this); - // makes the bus die - bus.Stop(); - close(false); - if (ev.ForceExit) -#if (PocketPC) - System.Windows.Forms.Application.Exit(); -#else - System.Environment.Exit(0); -#endif - } - void IvyProtocol.TokenBye(ushort err, string arg) - { - // the peer quits - Ivy.traceProtocol("IvyClient","received bye Message from " + appName + "Raison: "+ arg); - // first, I'm not a first class IvyClient any more - //bus.removeClient(this); // this is done in the receive thread terminaison!! - // invokes the disconnect applicationListeners - //bus.FireClientDisconnected(this); done in Running Thread - close(false); // will fire disconnected - } - - void IvyProtocol.TokenAddBinding(BindingType type, ushort id, string expression) - { - - if (type == BindingType.Regexp && !bus.CheckRegexp(expression)) - { - bus.OnClientFilterBinding(new IvyEventArgs(this, id, expression )); - return; - } - IvyBindingBase bind = null; - try - { - switch (type) - { - case BindingType.Regexp: - bind = new IvyBindingRegexp(id, expression); - break; - case BindingType.Simple: - bind = new IvyBindingSimple(id, expression); - break; - } - lock (bindings) - { - bindings.Add(id, bind); - } - - bus.OnClientAddBinding(new IvyEventArgs(this, id, expression)); - - } - catch (ArgumentException ex) - { - throw new IvyException("binding expression error " + ex.Message); - } - - } - void IvyProtocol.TokenDelBinding(ushort id) - { - lock( bindings ) - { - try - { - IvyBindingBase bind = bindings[id]; - bus.OnClientRemoveBinding(new IvyEventArgs(this, bind.Key, bind.Expression)); - bindings.Remove(id); - } - catch (KeyNotFoundException ex) - { - Ivy.traceError("IvyClient","DelBinding " + ex.Message); - } - } - } - void IvyProtocol.TokenMsg(ushort id, string[] args) - { - bus.OnMessage(new IvyMessageEventArgs(this, id, args)); - } - void IvyProtocol.TokenError(ushort id, string arg) - { - bus.OnError(new IvyEventArgs(this, id, arg)); - Ivy.traceError("IvyClient","Error msg " + id + " " + arg); - } - void IvyProtocol.TokenApplicationId(ushort id, string arg) - { - clientId = arg; - if ( clientPriority != id ) - { - clientPriority = id; - bus.SortClients(); - } - } - void IvyProtocol.TokenEndRegexp() - { - /* - * the peer is perhaps not ready to handle this message - * an assymetric processing should be written - */ - if (bus.ReadyMessage != null) - sendMsg(bus.ReadyMessage); - bus.OnClientConnected(new IvyEventArgs(this, 0, "")); - } - void IvyProtocol.TokenStartRegexp(ushort id, string arg) - { - appName = arg; - appPort = id; - if (bus.checkConnected(this)) - { - close(false); - throw new IvyException("Rare ! A concurrent connect occured"); - } - - } - void IvyProtocol.TokenDirectMsg(ushort id, string arg) - { - bus.OnDirectMessage(new IvyEventArgs(this,id,arg)); - } - void IvyProtocol.TokenPing(string arg) - { - // I receive a ping. I can answer a pong. - Ivy.traceProtocol("IvyClient","Ping msg from " + appName + " : " + arg ); - stream.TokenPong(arg); - } - void IvyProtocol.TokenPong(string arg) - { - Ivy.traceProtocol("IvyClient","Ping msg from " + appName + " : " + arg); - } - - - - public override String ToString() - { - return "IvyClient " + bus.appName + ":" + appName; - } - - /* is the Pinging Thread Runninng */ - internal bool isPinging; - - private void PingerRun() - { - isPinging = true; - Ivy.traceProtocol("IvyClient","Pinger Thread started"); - while (isPinging) - { - try - { - Thread.Sleep(PINGTIMEOUT); - stream.TokenPing("are you here ?"); - } - catch (ThreadAbortException ie) - { - Ivy.traceError("IvyClient","Pinger Thread killed "+ie.Message); - } - } - Ivy.traceProtocol("IvyClient","Pinger Thread stopped"); - } - public virtual void StopPinging() - { - isPinging = false; - //pingerThread.Interrupt(); - pingerThread.Abort(); - } - - #region IDisposable Members - - //Implement IDisposable. - public void Dispose() - { - Dispose(true); - GC.SuppressFinalize(this); - } - - protected virtual void Dispose(bool disposing) - { - if (disposing) - { - // Free other state (managed objects). - } - // Free your own state (unmanaged objects). - // Set large fields to null. - if (stream != null) - { - stream.Close(); - stream = null; - } - } - - // Use C# destructor syntax for finalization code. - ~IvyClient() - { - // Simply call Dispose(false). - Dispose(false); - } - - #endregion - } -} \ No newline at end of file diff --git a/IvyToDel/Ivy/IvyDomain.Designer.cs b/IvyToDel/Ivy/IvyDomain.Designer.cs deleted file mode 100644 index 3f89b6a..0000000 --- a/IvyToDel/Ivy/IvyDomain.Designer.cs +++ /dev/null @@ -1,75 +0,0 @@ -namespace IvyBus -{ - partial class IvyDomain - { - /// - /// Required designer variable. - /// - private System.ComponentModel.IContainer components = null; - - /// - /// Clean up any resources being used. - /// - /// true if managed resources should be disposed; otherwise, false. - protected override void Dispose(bool disposing) - { - if (disposing && (components != null)) - { - components.Dispose(); - } - base.Dispose(disposing); - } - - #region Component Designer generated code - - /// - /// Required method for Designer support - do not modify - /// the contents of this method with the code editor. - /// - private void InitializeComponent() - { - this.label1 = new System.Windows.Forms.Label(); - this.ivybus = new System.Windows.Forms.TextBox(); - this.SuspendLayout(); - // - // label1 - // - this.label1.Anchor = ((System.Windows.Forms.AnchorStyles)(((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Bottom) - | System.Windows.Forms.AnchorStyles.Left))); - this.label1.Location = new System.Drawing.Point(0, 5); - this.label1.Name = "label1"; - this.label1.Size = new System.Drawing.Size(24, 13); - this.label1.Text = "Ivy:"; - // - // ivybus - // - this.ivybus.Anchor = ((System.Windows.Forms.AnchorStyles)((((System.Windows.Forms.AnchorStyles.Top | System.Windows.Forms.AnchorStyles.Bottom) - | System.Windows.Forms.AnchorStyles.Left) - | System.Windows.Forms.AnchorStyles.Right))); - this.ivybus.Location = new System.Drawing.Point(30, 0); - this.ivybus.Name = "ivybus"; - this.ivybus.Size = new System.Drawing.Size(129, 20); - this.ivybus.TabIndex = 2; - this.ivybus.Validated += new System.EventHandler(this.ivybus_Validated); - this.ivybus.Validating += new System.ComponentModel.CancelEventHandler(this.ivybus_Validating); - // - // IvyDomain - // - this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Inherit; - this.Controls.Add(this.label1); - this.Controls.Add(this.ivybus); - this.Name = "IvyDomain"; - this.Size = new System.Drawing.Size(159, 22); - this.ResumeLayout(false); -#if (!PocketPC) - this.PerformLayout(); -#endif - - } - - #endregion - - private System.Windows.Forms.Label label1; - private System.Windows.Forms.TextBox ivybus; - } -} diff --git a/IvyToDel/Ivy/IvyDomain.cs b/IvyToDel/Ivy/IvyDomain.cs deleted file mode 100644 index 6c43b73..0000000 --- a/IvyToDel/Ivy/IvyDomain.cs +++ /dev/null @@ -1,60 +0,0 @@ -using System; -using System.Collections.Generic; -using System.ComponentModel; -using System.Text; -using System.Windows.Forms; - -namespace IvyBus -{ - public partial class IvyDomain : UserControl - { - private string domain = ""; - public event EventHandler DomainChanged; -#if (!PocketPC) - [Category("Ivy")] - [DefaultValue("")] - [Bindable(true)] -#endif - public string Domain - { - get { return domain; } - set { - if (domain != value) - { - domain = value; - ivybus.Text = domain; - if (DomainChanged != null) DomainChanged(this, EventArgs.Empty); - } - } - } - - public IvyDomain() - { - InitializeComponent(); - } - public void SetDefault() - { - if (IsEmpty()) - { - domain = Ivy.GetDomain(domain); - ivybus.Text = domain; - } - } - public bool IsEmpty() - { - return String.IsNullOrEmpty( domain ); - } - - private void ivybus_Validating(object sender, CancelEventArgs e) - { - e.Cancel = !Ivy.ValidatingDomain(ivybus.Text); - } - - private void ivybus_Validated(object sender, EventArgs e) - { - if ( domain != ivybus.Text ) - Domain = ivybus.Text; - } - - } -} diff --git a/IvyToDel/Ivy/IvyDomain.resx b/IvyToDel/Ivy/IvyDomain.resx deleted file mode 100644 index ff31a6d..0000000 --- a/IvyToDel/Ivy/IvyDomain.resx +++ /dev/null @@ -1,120 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - text/microsoft-resx - - - 2.0 - - - System.Resources.ResXResourceReader, System.Windows.Forms, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089 - - - System.Resources.ResXResourceWriter, System.Windows.Forms, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089 - - \ No newline at end of file diff --git a/IvyToDel/Ivy/IvyEventArgs.cs b/IvyToDel/Ivy/IvyEventArgs.cs deleted file mode 100644 index e394802..0000000 --- a/IvyToDel/Ivy/IvyEventArgs.cs +++ /dev/null @@ -1,84 +0,0 @@ -using System; -using System.Collections.Generic; -using System.Text; - -namespace IvyBus -{ - /// The EventArgs Classes - /// - /// - public class IvyEventArgs : EventArgs - { - private IvyClient client; - private int id; - private string arg; - - public IvyClient Client - { - get { return client; } - } - - public int Id - { - get { return id; } - } - - public string Argument - { - get { return arg; } - } - public IvyEventArgs(IvyClient app, int id, string arg) - { - this.client = app; - this.id = id; - this.arg = arg; - } - } - public class IvyDieEventArgs : IvyEventArgs - { - /* return value for Die Event */ - private bool forceExit; - - public bool ForceExit - { - get { return forceExit; } - set { forceExit = value; } - } - public IvyDieEventArgs(IvyClient app, int id, string arg) - : base(app, id, arg) - { - forceExit = true; - } - } - public class IvyMessageEventArgs : EventArgs - { - private IvyClient client; - private int id; - private string[] args; - - public IvyClient Client - { - get { return client; } - } - - public int Id - { - get { return id; } - } - - public string[] Arguments - { - get { return args; } - } - public string this[int i] - { - get { return args[i]; } - } - public IvyMessageEventArgs(IvyClient app, int id, string[] args) - { - this.client = app; - this.id = id; - this.args = args; - } - } -} diff --git a/IvyToDel/Ivy/IvyException.cs b/IvyToDel/Ivy/IvyException.cs deleted file mode 100644 index 90a91b8..0000000 --- a/IvyToDel/Ivy/IvyException.cs +++ /dev/null @@ -1,19 +0,0 @@ -/// François-Régis Colin -/// http://www.tls.cena.fr/products/ivy/ -/// * -/// (C) CENA -/// * -namespace IvyBus -{ - using System; - - /// signals that an unrecoverrable Ivy exception has occured. - /// - - public class IvyException:System.Exception - { - public IvyException(System.String s):base(s) - { - } - } -} \ No newline at end of file diff --git a/IvyToDel/Ivy/IvyProtocol.cs b/IvyToDel/Ivy/IvyProtocol.cs deleted file mode 100644 index 1b1f3aa..0000000 --- a/IvyToDel/Ivy/IvyProtocol.cs +++ /dev/null @@ -1,25 +0,0 @@ -using System; -using System.Text; - -namespace IvyBus -{ - public enum BindingType { Regexp, Simple }; - - internal interface IvyProtocol - { - void Close(); - bool receiveMsg(); - void TokenStartRegexp(ushort port, string appName); - void TokenEndRegexp(); - void TokenApplicationId(ushort priority, string appId); - void TokenAddBinding(BindingType type, ushort id, string expression); - void TokenDelBinding(ushort bind); - void TokenDirectMsg(ushort id, string message); - void TokenPong(string s); - void TokenPing(string s); - void TokenBye(ushort id, string message); - void TokenDie(ushort err, string message); - void TokenMsg(ushort key, string[] args); - void TokenError(ushort id, string message); - } -} diff --git a/IvyToDel/Ivy/IvyTCPStream.cs b/IvyToDel/Ivy/IvyTCPStream.cs deleted file mode 100644 index b8fee34..0000000 --- a/IvyToDel/Ivy/IvyTCPStream.cs +++ /dev/null @@ -1,20 +0,0 @@ -using System; -using System.Collections.Specialized; -using System.Text; -using System.Net; -using System.Net.Sockets; -using System.IO; - -namespace IvyBus -{ - abstract class IvyTCPStream : NetworkStream - { - public IvyTCPStream(Socket socket) - : base(socket, true) - { - } - - abstract internal bool receiveMsg(); - - } -} diff --git a/IvyToDel/Ivy/IvyTCPStreamV3.cs b/IvyToDel/Ivy/IvyTCPStreamV3.cs deleted file mode 100644 index 4eef12c..0000000 --- a/IvyToDel/Ivy/IvyTCPStreamV3.cs +++ /dev/null @@ -1,254 +0,0 @@ -using System; -using System.Net; -using System.Net.Sockets; -using System.Text; -using System.Collections; -using System.Collections.Specialized; -using System.IO; - -namespace IvyBus -{ - /// - /// Description résumée de IvyStream. - /// - internal class IvyTCPStreamV3 : NetworkStream, IvyProtocol - { - StreamReader input; - StreamWriter output; - IvyProtocol receiver; - - /// the protocol separator - internal const char ARG_START = '\x02'; - internal const char ARG_END = '\x03'; - internal const char MSG_END = '\n'; - - internal IvyTCPStreamV3(Socket socket, IvyProtocol _receiver) : base ( socket ) - { - output = new StreamWriter(this, Encoding.ASCII); - output.NewLine = MSG_END.ToString(); - input = new StreamReader(this, Encoding.ASCII); - receiver = _receiver; - } - /* the protocol magic numbers */ - internal enum MessageType : ushort - { - Bye = 0, /* end of the peer */ - AddRegexp = 1, /* the peer adds a regexp */ - Msg = 2, /* the peer sends a message */ - Error = 3, /* error message */ - DelBinding = 4, /* the peer removes one of his regex */ // OLD DelRegexp rename to DelBinding - EndRegexp = 5, /* no more regexp in the handshake */ - StartRegexp = 6, /* avoid race condition in concurrent connexions */ - DirectMsg = 7, /* the peer sends a direct message */ - Die = 8, /* the peer wants us to quit */ - Ping = 9, /* checks the presence of the other */ - Pong = 10, /* checks the presence of the other */ - }; - - /* - * message Syntax: - * this is text formated message 'type id STX ARG0 {[ETX] ARG1 [ETX] ARGn}\n' - * - * message Format: - MessageType, id , length, string - */ - - private void sendMsg(MessageType msgType, ushort msgId, string msgData) - { - // IOException Should be traited upstairs - output.Write((ushort)msgType); - output.Write(' '); - output.Write(msgId); - output.Write(ARG_START); - output.Write(msgData); - output.Write(MSG_END); - output.Flush(); - - } - void IvyProtocol.TokenStartRegexp(ushort port, string appName) - { - sendMsg(MessageType.StartRegexp, port, appName); - } - void IvyProtocol.TokenEndRegexp() - { - sendMsg(MessageType.EndRegexp, 0, ""); - } - void IvyProtocol.TokenApplicationId(ushort priority, string appId) - { - // NOt implemented in this protocol version - } - - void IvyProtocol.TokenAddBinding(BindingType type, ushort id, string expression) - { - switch (type) - { - case BindingType.Regexp: - sendMsg(MessageType.AddRegexp, id, expression); /* perhaps we should perform some checking here */ - break; - case BindingType.Simple: - // NO Simple Binding in this protocol - break; - } - } - - void IvyProtocol.TokenDelBinding(ushort id) - { - sendMsg(MessageType.DelBinding, id, ""); - } - - void IvyProtocol.TokenDirectMsg(ushort id, string message) - { - sendMsg(MessageType.DirectMsg, id, message); - } - void IvyProtocol.TokenPong(string s) - { - sendMsg(MessageType.Pong, 0, s); - } - void IvyProtocol.TokenPing(string s) - { - sendMsg(MessageType.Ping, 0, s); - } - - void IvyProtocol.TokenBye(ushort id, string message) - { - sendMsg(MessageType.Bye, id, message); - } - - void IvyProtocol.TokenDie(ushort id, string message) - { - sendMsg(MessageType.Die, id, message); - } - - void IvyProtocol.TokenMsg(ushort key, string[] args) - { - string delimiter = "" + ARG_END; - string data = string.Join(delimiter, args); - // a bad protocol implementation in C add a delimiter to the end of each arg - // we must add a delimiter to the end - data += delimiter; - sendMsg(MessageType.Msg, key, data); - } - - void IvyProtocol.TokenError(ushort key, string arg) - { - sendMsg(MessageType.Msg, key, arg); - } - - private ushort DeserializeShort() - { - int read; - ushort ret = 0; - char digit; - // this will eat next non digit char ie space - do - { - read = input.Read(); - if (read < 0) - throw new EndOfStreamException(); - digit = (char)read; - if (Char.IsDigit(digit)) - ret = (ushort)(ret * 10 + (digit - 0x30)); - } while (Char.IsDigit(digit)); - return ret; - } - private string DeserializeString(char sep) - { - int read; - char car; - StringBuilder str = new StringBuilder(); - // this will eat next non separator char - do - { - read = input.Read(); - if (read < 0) - throw new EndOfStreamException(); - car = (char)read; - if (car != sep ) str.Append(car); - } while (car != sep); - return str.ToString(); - } - - bool IvyProtocol.receiveMsg() - { - MessageType msgType = MessageType.Die; - ushort msgId = 0; - string msgData = null; - - try - { - msgType = (MessageType)DeserializeShort(); - msgId = DeserializeShort(); - msgData = DeserializeString(MSG_END); - - switch (msgType) - { - case MessageType.Die: - receiver.TokenDie(msgId, msgData); - break; - - case MessageType.Bye: - receiver.TokenBye(msgId, msgData); - break; - - case MessageType.AddRegexp: - receiver.TokenAddBinding(BindingType.Regexp, msgId, msgData); - break; - - case MessageType.DelBinding: - receiver.TokenDelBinding(msgId); - break; - - case MessageType.EndRegexp: - receiver.TokenEndRegexp(); - break; - - case MessageType.Msg: - // a bad protocol implementation in C add a delimiter to the end of each arg - // we must remove a delimiter to the end - if ( msgData.Length > 0 ) - msgData = msgData.Remove(msgData.Length - 1,1); - receiver.TokenMsg(msgId, msgData.Split( ARG_END )); - break; - - case MessageType.Pong: - receiver.TokenPong(msgData); - break; - - case MessageType.Ping: - receiver.TokenPing(msgData); - break; - - case MessageType.Error: - receiver.TokenError(msgId, msgData); - break; - - case MessageType.StartRegexp: - receiver.TokenStartRegexp(msgId, msgData); - break; - - case MessageType.DirectMsg: - receiver.TokenDirectMsg(msgId, msgData); - break; - default: - throw new IvyException("protocol error, unknown message type " + msgType); - - } - - - - } - catch (EndOfStreamException) - { - return false; - } - catch (FormatException) - { - throw new IvyException("protocol error on msgType"); - } - - - return true; - } - - } -} diff --git a/IvyToDel/Ivy/IvyTCPStreamV4.cs b/IvyToDel/Ivy/IvyTCPStreamV4.cs deleted file mode 100644 index 9a96d62..0000000 --- a/IvyToDel/Ivy/IvyTCPStreamV4.cs +++ /dev/null @@ -1,273 +0,0 @@ -using System; -using System.Net; -using System.Net.Sockets; -using System.Text; -using System.Collections; -using System.Collections.Specialized; -using System.IO; - -namespace IvyBus -{ - /// - /// Description résumée de IvyStream. - /// - internal class IvyTCPStreamV4 : NetworkStream , IvyProtocol - { - BinaryReader input; - BinaryWriter output; - IvyProtocol receiver; - - /* the protocol magic numbers */ - internal enum MessageType : ushort - { - Bye = 0, /* end of the peer */ - AddRegexp = 1, /* the peer adds a regexp */ - Msg = 2, /* the peer sends a message */ - Error = 3, /* error message */ - DelBinding = 4, /* the peer removes one of his regex */ // OLD DelRegexp rename to DelBinding - EndRegexp = 5, /* no more regexp in the handshake */ - StartRegexp = 6, /* avoid race condition in concurrent connexions */ - DirectMsg = 7, /* the peer sends a direct message */ - Die = 8, /* the peer wants us to quit */ - Ping = 9, /* checks the presence of the other */ - Pong = 10, /* checks the presence of the other */ - ApplicationId = 11, /* on start send my ID and priority */ - AddBinding = 12, /* other methods for binding message based on hash table */ - - }; - - internal IvyTCPStreamV4(Socket socket, IvyProtocol _receiver) : base( socket ) - { - - input = new BinaryReader(this, Encoding.ASCII); - output = new BinaryWriter(this, Encoding.ASCII); - receiver = _receiver; - } - - - /* - * message Syntax: - * this is a binary formated message use of network representation - * - * message Format: - MessageType, id , length, string - */ - private void Serialize(short arg) - { - output.Write((ushort)IPAddress.HostToNetworkOrder(arg)); - } - private void Serialize(string arg) - { - short length = arg != null ? (short)arg.Length : (short)0; - Serialize(length); - if (length != 0) - output.Write(arg.ToCharArray()); - } - private void Serialize(string[] arg) - { - - /* serialize count */ - Serialize((short)arg.Length); - - for (int i = 0; i < arg.Length; i++) - { - Serialize(arg[i]); - } - } - private void sendMsg(MessageType type, int id, params string[] arg) - { - - Serialize( (short)type ); - Serialize( (short)id ); - Serialize(arg); - output.Flush(); - - } - void IvyProtocol.TokenStartRegexp(ushort port, string appName) - { - sendMsg(MessageType.StartRegexp, port, appName); - } - void IvyProtocol.TokenEndRegexp() - { - sendMsg(MessageType.EndRegexp, 0, ""); - } - void IvyProtocol.TokenApplicationId(ushort priority, string appId) - { - sendMsg(MessageType.ApplicationId, priority, appId); - } - - void IvyProtocol.TokenAddBinding(BindingType type, ushort id, string expression) - { - switch (type) - { - case BindingType.Regexp: - sendMsg(MessageType.AddRegexp, id, expression); /* perhaps we should perform some checking here */ - break; - case BindingType.Simple: - sendMsg(MessageType.AddBinding, id, expression); /* perhaps we should perform some checking here */ - break; - } - } - - void IvyProtocol.TokenDelBinding(ushort id) - { - sendMsg(MessageType.DelBinding, id, null ); - } - - void IvyProtocol.TokenDirectMsg(ushort id, string message) - { - sendMsg(MessageType.DirectMsg, id, message); - } - void IvyProtocol.TokenPong(string s) - { - sendMsg(MessageType.Pong, 0, s); - } - void IvyProtocol.TokenPing(string s) - { - sendMsg(MessageType.Ping, 0, s); - } - - void IvyProtocol.TokenBye(ushort id, string message) - { - sendMsg(MessageType.Bye, id, message); - } - - void IvyProtocol.TokenDie(ushort id, string message) - { - sendMsg(MessageType.Die, id, message); - } - - void IvyProtocol.TokenMsg(ushort key, string[] args) - { - sendMsg(MessageType.Msg, key, args ); - } - - void IvyProtocol.TokenError(ushort key, string arg) - { - sendMsg(MessageType.Msg, key, arg); - } - - private short DeserializeShort() - { - return IPAddress.NetworkToHostOrder((short)input.ReadUInt16()); - } - private string DeserializeString() - { - string arg; - int val_len; - char[] data; - val_len = (ushort)DeserializeShort(); - if (val_len != 0) - { - data = input.ReadChars(val_len); - arg = new String(data); - } - else - arg = ""; - return arg; - } - - - private string[] DeserializeArgument() - { - int nb_children; - string[] arg; - - /* Deserialize childrens */ - nb_children = (ushort)DeserializeShort(); - /* deserialize Value */ - arg = new string[nb_children]; - - for (int i = 0; i < nb_children; i++) - { - arg[i] = DeserializeString(); - } - return arg; - } - bool IvyProtocol.receiveMsg() - { - MessageType msgType = MessageType.Die; - ushort msgId = 0; - string[] msgData = null; - - try - { - msgType = (MessageType)(ushort)DeserializeShort(); - msgId = (ushort)DeserializeShort(); - msgData = DeserializeArgument(); - - switch (msgType) - { - case MessageType.Die: - receiver.TokenDie(msgId, msgData[0]); - break; - - case MessageType.Bye: - receiver.TokenBye(msgId, msgData[0]); - break; - - case MessageType.AddRegexp: - receiver.TokenAddBinding(BindingType.Regexp, msgId, msgData[0]); - break; - - case MessageType.AddBinding: - receiver.TokenAddBinding(BindingType.Simple, msgId, msgData[0]); - break; - - case MessageType.DelBinding: - receiver.TokenDelBinding(msgId); - break; - - case MessageType.EndRegexp: - receiver.TokenEndRegexp(); - break; - - case MessageType.Msg: - receiver.TokenMsg( msgId, msgData ); - break; - - case MessageType.Pong: - receiver.TokenPong(msgData[0]); - break; - - case MessageType.Ping: - receiver.TokenPing(msgData[0]); - break; - - case MessageType.Error: - receiver.TokenError(msgId, msgData[0]); - break; - - case MessageType.StartRegexp: - receiver.TokenStartRegexp(msgId, msgData[0]); - break; - - case MessageType.DirectMsg: - receiver.TokenDirectMsg(msgId, msgData[0]); - break; - case MessageType.ApplicationId: - receiver.TokenApplicationId(msgId, msgData[0]); - break; - default: - throw new IvyException("protocol error, unknown message type " + msgType); - - } - - - - } - catch (EndOfStreamException) - { - return false; - } - catch (FormatException) - { - throw new IvyException("protocol error on msgType"); - } - - - return true; - } - - } -} diff --git a/IvyToDel/Ivy/IvyUDPStream.cs b/IvyToDel/Ivy/IvyUDPStream.cs deleted file mode 100644 index 0e3f517..0000000 --- a/IvyToDel/Ivy/IvyUDPStream.cs +++ /dev/null @@ -1,66 +0,0 @@ -using System; -using System.Collections.Generic; -using System.Text; -using System.Net; -using System.Net.Sockets; -using System.IO; - -namespace IvyBus -{ - abstract class IvyUDPStream - { - Socket socket; - byte[] buffer; - - protected MemoryStream out_stream; - protected MemoryStream in_stream; - - ushort protocol_version; - - public ushort ProtocolVersion - { - get { return protocol_version; } - } - - public IvyUDPStream(Socket _socket, ushort protocol) - { - socket = _socket; - buffer = new byte[4096]; - in_stream = new MemoryStream(buffer); - out_stream = new MemoryStream(); - protocol_version = protocol; - } - internal void Close() - { - in_stream.Close(); - out_stream.Close(); - socket.Shutdown(SocketShutdown.Both); - socket.Close(); - } - internal void receiveMsg(out IPEndPoint remote, out ushort version, out ushort port, out string appId, out string appName) - { - int len; - IPEndPoint remoteEP = new IPEndPoint(IPAddress.Any, 0); - EndPoint tempRemoteEP = (EndPoint)remoteEP; - remoteEP = null; - len = socket.ReceiveFrom(buffer, ref tempRemoteEP); - remote = (IPEndPoint)tempRemoteEP; - in_stream.Position = 0; - in_stream.SetLength(len); - in_stream.Seek(0, SeekOrigin.Begin); - //Call Deserialization - Deserialize( out version, out port, out appId, out appName ); - } - internal void sendMsg(IPEndPoint EPhost, ushort port, string appId, string appName) - { - // Call Serialisation - Serialize(port, appId, appName); - - byte[] hellob = out_stream.GetBuffer(); - socket.SendTo(hellob, (int)out_stream.Length, 0, EPhost); - } - abstract internal void Serialize(ushort port, string appId, string appName); - abstract internal void Deserialize(out ushort version, out ushort port, out string appId, out string appName); - - } -} diff --git a/IvyToDel/Ivy/IvyUDPStreamV3.cs b/IvyToDel/Ivy/IvyUDPStreamV3.cs deleted file mode 100644 index 63a8679..0000000 --- a/IvyToDel/Ivy/IvyUDPStreamV3.cs +++ /dev/null @@ -1,104 +0,0 @@ -using System; -using System.Collections.Generic; -using System.Text; -using System.Net; -using System.Net.Sockets; -using System.IO; - -namespace IvyBus -{ - class IvyUDPStreamV3 : IvyUDPStream - { - StreamReader input; - StreamWriter output; - - /// the protocol version number - internal const int PROCOCOLVERSION = 3; - - public IvyUDPStreamV3(Socket _socket) : base( _socket , PROCOCOLVERSION ) - { - input = new StreamReader(in_stream, Encoding.ASCII); - output = new StreamWriter(out_stream, Encoding.ASCII); - } - /* - * message Syntax: - * this is a text formated message - * - * message Format: - protocol_version, TCP server port , appId, appName - */ - private ushort DeserializeShort() - { - int read; - ushort ret = 0; - char digit; - // this will eat next non digit car ie space - do - { - read = input.Read(); - if (read < 0) - throw new EndOfStreamException(); - digit = (char)read; - if ( Char.IsDigit(digit) ) - ret = (ushort)(ret * 10 + (digit-0x30)); - } while (Char.IsDigit(digit)); - return ret; - } - private string DeserializeString(char sep) - { - int read; - char car; - StringBuilder str = new StringBuilder(); - // this will eat next non digit car ie space - do - { - read = input.Read(); - if (read < 0) - throw new EndOfStreamException(); - if (read == 0) break; - car = (char)read; - if (car != sep) - str.Append(car); - } while (car != sep); - return str.ToString(); - } - - internal override void Deserialize(out ushort version, out ushort port, out string appId, out string appName) - { - version = 0; - port = 0; - appId = ""; - appName = ""; - try { - version = DeserializeShort(); - port = DeserializeShort(); - //Optionel in V3 protocol depend on client version - appId = DeserializeString(' '); - appName = DeserializeString('\n'); - } - catch( EndOfStreamException ) - { - // Bad protocol message receive or without appId and appName - } - input.DiscardBufferedData(); - } - private void Serialize(ushort arg, char sep) - { - output.Write(arg); - output.Write(sep); - } - private void Serialize(string arg, char sep) - { - output.Write(arg); - output.Write(sep); - } - internal override void Serialize(ushort port, string appId, string appName) - { - Serialize(PROCOCOLVERSION, ' '); - Serialize(port,' '); - Serialize(appId,' '); //No AppId in V3 - Serialize(appName, '\n'); //No Appname in V3 - output.Flush(); - } - } -} diff --git a/IvyToDel/Ivy/IvyUDPStreamV4.cs b/IvyToDel/Ivy/IvyUDPStreamV4.cs deleted file mode 100644 index b8d329a..0000000 --- a/IvyToDel/Ivy/IvyUDPStreamV4.cs +++ /dev/null @@ -1,80 +0,0 @@ -using System; -using System.Collections.Generic; -using System.Text; -using System.Net; -using System.Net.Sockets; -using System.IO; - -namespace IvyBus -{ - class IvyUDPStreamV4 : IvyUDPStream - { - - BinaryReader input; - BinaryWriter output; - - /// the protocol version number - internal const ushort PROCOCOLVERSION = 4; - public IvyUDPStreamV4(Socket _socket) : base ( _socket, PROCOCOLVERSION) - { - input = new BinaryReader( in_stream,Encoding.ASCII); - output = new BinaryWriter(out_stream, Encoding.ASCII); - } - /* - * message Syntax: - * this is a binary formated message use of network representation - * - * message Format: - protocol_version, TCP server port , lenAppId, appId, lenAppNameId, appName - */ - private ushort DeserializeShort() - { - return (ushort)IPAddress.NetworkToHostOrder((ushort)input.ReadUInt16()); - } - private string DeserializeString() - { - string arg; - int val_len; - char[] data; - val_len = (ushort)IPAddress.NetworkToHostOrder((ushort)input.ReadUInt16()); - if (val_len != 0) - { - data = input.ReadChars(val_len); - arg = new String(data); - } - else - arg = ""; - return arg; - } - - internal override void Deserialize(out ushort version, out ushort port, out string appId, out string appName) - { - version = DeserializeShort(); - port = DeserializeShort(); - appId = DeserializeString(); - appName = DeserializeString(); - - } - private void Serialize(ushort arg) - { - output.Write((ushort)IPAddress.HostToNetworkOrder(arg)); - } - private void Serialize(string arg) - { - ushort length = arg != null ? (ushort)arg.Length : (ushort)0; - Serialize(length); - if (length != 0) - output.Write(arg.ToCharArray()); - } - - internal override void Serialize(ushort port, string appId, string appName) - { - Serialize(PROCOCOLVERSION ); - Serialize(port); - Serialize(appId); - Serialize(appName); - output.Flush(); - } - - } -} diff --git a/IvyToDel/Ivy/IvyWatcher.cs b/IvyToDel/Ivy/IvyWatcher.cs deleted file mode 100644 index 5a3afc8..0000000 --- a/IvyToDel/Ivy/IvyWatcher.cs +++ /dev/null @@ -1,179 +0,0 @@ - -/// François-Régis Colin -/// http://www.tls.cena.fr/products/ivy/ -/// * -/// (C) CENA -/// * - -namespace IvyBus -{ - using System; - using System.Threading; - using System.IO; - using System.Net; - using System.Net.Sockets; - using System.Text.RegularExpressions; - using System.Configuration; - using System.Text; - using System.Diagnostics; - - /// IvyWatcher, A private Class for the Ivy rendezvous - /// - /// right now, the rendez vous is either an UDP socket or a TCP multicast. - /// The watcher will answer to - /// each peer advertising its arrival on the bus. The intrinsics of Unix are so - /// that the broadcast is done using the same socket, which is not a good - /// thing. - /// - internal class IvyWatcher - { - private Ivy bus; /* master bus controler */ - private int port; - private volatile Thread listenThread; - private IPAddress group; - private IvyUDPStream stream; - - /// creates an Ivy watcher - /// - /// the bus - /// - /// the domain - /// - /// the port number - /// - internal IvyWatcher(Ivy bus, String domainaddr, int port) - { - this.bus = bus; - this.port = port; - listenThread = new Thread(new ThreadStart(this.Run)); - listenThread.Name = "Ivy UDP Listener Thread"; - try - { - group = IPAddress.Parse(domainaddr); - /* supervision socket */ - // To do reuseaddr we must use a Socket not a udp client - Socket broadcast = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); - IPEndPoint EPhost = new IPEndPoint(IPAddress.Any, port); - broadcast.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.Broadcast,1); - broadcast.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress,1); - broadcast.Bind(EPhost); - - //test isMulticastAddress // TODO better check - //if ( group.IsIPv6Multicast ) yes but in IPV4 how to do - byte[] addr = group.GetAddressBytes(); - if ((addr[0] & 0xf0) == 0xe0) - { - broadcast.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption( group )); - } - // TODO support the Two protocol - if (bus.protocolVersion == 4) - stream = new IvyUDPStreamV4(broadcast); - else - stream = new IvyUDPStreamV3(broadcast); - } - catch (IOException e) - { - throw new IvyException("IvyWatcher I/O error" + e); - } - } - - /// the behaviour of each thread watching the UDP socket. - /// - public void Run() - { - Ivy.traceProtocol("IvyWatcher", "beginning of a watcher Thread"); - - try - { - bool running = true; - while (running) - { - ushort version; - ushort appPort; - string appId; - string appName; - IPEndPoint remoteEP; - - stream.receiveMsg(out remoteEP, out version, out appPort, out appId, out appName); - IPAddress remotehost = remoteEP.Address; - - Ivy.traceProtocol("IvyWatcher", "Receive Broadcast from " + Dns.GetHostEntry(remotehost).HostName + ":" + remoteEP.Port); - - //TODO if ( !isInDomain( remotehost ) ) continue; - - if (version != stream.ProtocolVersion) - { - Ivy.traceError("IvyWatcher","Ignoring bad protocol version " + version + " expected " + stream.ProtocolVersion); - continue; - } - - // filtrage des self Broadcast - if (appId == bus.AppId) - continue; - if ((appPort == bus.applicationPort) && (remotehost.Equals(bus.applicationHost))) - continue; - - Ivy.traceProtocol("IvyWatcher", "reponse au Broadcast de " + Dns.GetHostEntry(remotehost).HostName + ":" + remoteEP.Port + " port " + appPort + - " version " + version + - " id " + appId + - " name " + appName); - - try - { - Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); - IPEndPoint hostEndPoint = new IPEndPoint(remoteEP.Address, appPort); - socket.Blocking = true; - socket.Connect(hostEndPoint); - bus.addClient(socket, appName); - } - catch (Exception e) - { - Ivy.traceError("IvyWatcher","can't connect to " + remotehost + " port " + appPort + " \n" + e.Message); - } - - } // while - } - catch (SocketException se) - { - Ivy.traceError("IvyWatcher","watcher socket closed: " + se.Message); - } - catch (IOException ioe) - { - Ivy.traceError("IvyWatcher","watcher thread ended: " + ioe.Message); - } - Ivy.traceProtocol("IvyWatcher", "end of a watcher thread"); - } - - /// stops the thread waiting on the broadcast socket - /// - internal virtual void stop() - { - lock (stream) - { - Ivy.traceProtocol("IvyWatcher", "begining stopping an IvyWatcher"); - stream.Close(); - if (listenThread != null) - { - // Wait for Thread to end. - bool term = listenThread.Join(10000); - if (!term && (listenThread != null)) listenThread.Abort(); - listenThread = null; - } - // it might not even have been created - Ivy.traceProtocol("IvyWatcher", "ending stopping an IvyWatcher"); - } - } - - internal virtual void start() - { - lock (stream) - { - listenThread.Start(); - IPEndPoint EPhost = new IPEndPoint(group, port); - stream.sendMsg(EPhost, bus.applicationPort, bus.AppId, bus.AppName);// notifies our arrival on each domain: protocol version + port - } - } - - - } -} \ No newline at end of file diff --git a/IvyToDel/Ivy/Properties/AssemblyInfo.cs b/IvyToDel/Ivy/Properties/AssemblyInfo.cs deleted file mode 100644 index a3ce834..0000000 --- a/IvyToDel/Ivy/Properties/AssemblyInfo.cs +++ /dev/null @@ -1,62 +0,0 @@ -using System.Reflection; -using System.Runtime.CompilerServices; -using System.Runtime.InteropServices; - -// General Information about an assembly is controlled through the following -// set of attributes. Change these attribute values to modify the information -// associated with an assembly. - -[assembly: AssemblyTitle("Ivy")] -[assembly: AssemblyDescription("Dll de communications sur le bus IVY")] -[assembly: AssemblyCompany("DTI/SDER PII")] -[assembly: AssemblyProduct("Ivy")] -[assembly: AssemblyCopyright("SDER")] -[assembly: AssemblyTrademark("")] -[assembly: AssemblyCulture("")] - - -// Version information for an assembly consists of the following four values: -// -// Major Version -// Minor Version -// Revision -// Build Number -// -// You can specify all the values or you can default the Revision and Build Numbers -// by using the '*' as shown below: - -[assembly: AssemblyVersion("2.0.*")] - -// -// In order to sign your assembly you must specify a key to use. Refer to the -// Microsoft .NET Framework documentation for more information on assembly signing. -// -// Use the attributes below to control which key is used for signing. -// -// Notes: -// (*) If no key is specified, the assembly is not signed. -// (*) KeyName refers to a key that has been installed in the Crypto Service -// Provider (CSP) on your machine. KeyFile refers to a file which contains -// a key. -// (*) If the KeyFile and the KeyName values are both specified, the -// following processing occurs: -// (1) If the KeyName can be found in the CSP, that key is used. -// (2) If the KeyName does not exist and the KeyFile does exist, the key -// in the KeyFile is installed into the CSP and used. -// (*) In order to create a KeyFile, you can use the sn.exe (Strong Name) utility. -// When specifying the KeyFile, the location of the KeyFile should be -// relative to the project output directory which is -// %Project Directory%\obj\. For example, if your KeyFile is -// located in the project directory, you would specify the AssemblyKeyFile -// attribute as [assembly: AssemblyKeyFile("..\..\mykey.snk")] -// (*) Delay Signing is an advanced option - see the Microsoft .NET Framework -// documentation for more information on this. -// - -[assembly: AssemblyConfiguration("")] -[assembly: AssemblyDelaySign(false)] -[assembly: AssemblyKeyFile("")] -[assembly: AssemblyKeyName("")] - - -[assembly: ComVisibleAttribute(false)] diff --git a/IvyToDel/Ivy/Properties/Settings.Designer.cs b/IvyToDel/Ivy/Properties/Settings.Designer.cs deleted file mode 100644 index 96b0f2d..0000000 --- a/IvyToDel/Ivy/Properties/Settings.Designer.cs +++ /dev/null @@ -1,80 +0,0 @@ -//------------------------------------------------------------------------------ -// -// This code was generated by a tool. -// Runtime Version:2.0.50727.42 -// -// Changes to this file may cause incorrect behavior and will be lost if -// the code is regenerated. -// -//------------------------------------------------------------------------------ - -namespace IvyBus.Properties { - - - [global::System.Runtime.CompilerServices.CompilerGeneratedAttribute()] - [global::System.CodeDom.Compiler.GeneratedCodeAttribute("Microsoft.VisualStudio.Editors.SettingsDesigner.SettingsSingleFileGenerator", "8.0.0.0")] - internal sealed partial class Settings : global::System.Configuration.ApplicationSettingsBase { - - private static Settings defaultInstance = ((Settings)(global::System.Configuration.ApplicationSettingsBase.Synchronized(new Settings()))); - - public static Settings Default { - get { - return defaultInstance; - } - } - - [global::System.Configuration.ApplicationScopedSettingAttribute()] - [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] - [global::System.Configuration.DefaultSettingValueAttribute("3")] - public int IvyProtocolVersion { - get { - return ((int)(this["IvyProtocolVersion"])); - } - } - - [global::System.Configuration.ApplicationScopedSettingAttribute()] - [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] - [global::System.Configuration.DefaultSettingValueAttribute("False")] - public bool IvyPing { - get { - return ((bool)(this["IvyPing"])); - } - } - - [global::System.Configuration.ApplicationScopedSettingAttribute()] - [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] - [global::System.Configuration.DefaultSettingValueAttribute("False")] - public bool IvyDebug { - get { - return ((bool)(this["IvyDebug"])); - } - } - - [global::System.Configuration.ApplicationScopedSettingAttribute()] - [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] - [global::System.Configuration.DefaultSettingValueAttribute("")] - public string IvyBus { - get { - return ((string)(this["IvyBus"])); - } - } - - [global::System.Configuration.ApplicationScopedSettingAttribute()] - [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] - [global::System.Configuration.DefaultSettingValueAttribute("")] - public string AppName { - get { - return ((string)(this["AppName"])); - } - } - - [global::System.Configuration.ApplicationScopedSettingAttribute()] - [global::System.Diagnostics.DebuggerNonUserCodeAttribute()] - [global::System.Configuration.DefaultSettingValueAttribute("")] - public string ReadyMessage { - get { - return ((string)(this["ReadyMessage"])); - } - } - } -} diff --git a/IvyToDel/Ivy/Properties/Settings.settings b/IvyToDel/Ivy/Properties/Settings.settings deleted file mode 100644 index f23b946..0000000 --- a/IvyToDel/Ivy/Properties/Settings.settings +++ /dev/null @@ -1,24 +0,0 @@ - - - - - - 3 - - - False - - - False - - - - - - - - - - - - \ No newline at end of file diff --git a/IvyToDel/Ivy/Settings.cs b/IvyToDel/Ivy/Settings.cs deleted file mode 100644 index 17744f8..0000000 --- a/IvyToDel/Ivy/Settings.cs +++ /dev/null @@ -1,28 +0,0 @@ -namespace IvyBus.Properties { - - - // This class allows you to handle specific events on the settings class: - // The SettingChanging event is raised before a setting's value is changed. - // The PropertyChanged event is raised after a setting's value is changed. - // The SettingsLoaded event is raised after the setting values are loaded. - // The SettingsSaving event is raised before the setting values are saved. - internal sealed partial class Settings { - - public Settings() { - // // To add event handlers for saving and changing settings, uncomment the lines below: - // - // this.SettingChanging += this.SettingChangingEventHandler; - // - // this.SettingsSaving += this.SettingsSavingEventHandler; - // - } - - private void SettingChangingEventHandler(object sender, System.Configuration.SettingChangingEventArgs e) { - // Add code to handle the SettingChangingEvent event here. - } - - private void SettingsSavingEventHandler(object sender, System.ComponentModel.CancelEventArgs e) { - // Add code to handle the SettingsSaving event here. - } - } -} diff --git a/IvyToDel/Ivy/app.config b/IvyToDel/Ivy/app.config deleted file mode 100644 index e5b53b3..0000000 --- a/IvyToDel/Ivy/app.config +++ /dev/null @@ -1,30 +0,0 @@ - - - - -
- - - - - - 3 - - - False - - - False - - - - - - - - - - - - - \ No newline at end of file -- cgit v1.1