summaryrefslogtreecommitdiff
path: root/CSharp
diff options
context:
space:
mode:
Diffstat (limited to 'CSharp')
-rw-r--r--CSharp/Ivy/IvyFilter/Filter.cs119
1 files changed, 119 insertions, 0 deletions
diff --git a/CSharp/Ivy/IvyFilter/Filter.cs b/CSharp/Ivy/IvyFilter/Filter.cs
new file mode 100644
index 0000000..1e4fbed
--- /dev/null
+++ b/CSharp/Ivy/IvyFilter/Filter.cs
@@ -0,0 +1,119 @@
+
+using System;
+using IvyBus;
+using System.Threading;
+using Gnu;
+
+namespace IvyFilter
+{
+ class Filter
+ {
+
+ internal Ivy bus;
+
+ [STAThread]
+ public static void Main(System.String[] args)
+ {
+ GetOpt opt = new GetOpt(args, "b:n:t:");
+ System.String domain = Ivy.GetDomain(null);
+ int nb = 10000;
+ int t = 1000;
+ Arg a;
+ while ((a = opt.NextArg() )!= null)
+ {
+ switch (a.Flag)
+ {
+
+ case 'b':
+ domain = a.Parameter;
+ break;
+
+ case 't':
+ t = int.Parse(a.Parameter);
+ break;
+
+ case 'n':
+ nb = int.Parse(a.Parameter);
+ break;
+
+ default:
+ System.Environment.Exit(0);
+ break;
+
+ }
+ }
+ new Filter(domain, nb, t, true);
+ }
+
+ private int nbmsg;
+ private int bounded = 0, unbounded = 0;
+ private string[] filter = new string[] { "GetDummy" };
+
+ public Filter(string domain, int n, int t, bool f)
+ {
+ System.Console.Out.WriteLine("trying Filter on " + n + " messages, " + t + " ms delay");
+ nbmsg = n;
+ bus = new Ivy("Filter", "Filter ready");
+ if (f)
+ bus.SentMessageFilter.AddRange(filter);
+ bus.BindingAdd += new EventHandler<IvyEventArgs>(bus_BindingAdd);
+ bus.BindingRemove += new EventHandler<IvyEventArgs>(bus_BindingRemove);
+ bus.BindingFilter += new EventHandler<IvyEventArgs>(bus_BindingFilter);
+ bus.Start(domain);
+ /* attend une seconde ou deux */
+ try
+ {
+ Thread.Sleep(2000);
+ }
+ catch (System.Threading.ThreadInterruptedException )
+ {
+ }
+ System.Console.Out.WriteLine(bounded + " bounded subscriptions, " + unbounded + " unbounded");
+ System.Console.Out.WriteLine(bus.IvyClients.Count + " clients");
+ DateTime debut = System.DateTime.Now;
+ TimeSpan total = new TimeSpan();
+ DateTime debutlocal = System.DateTime.Now;
+ DateTime finlocal = System.DateTime.Now;
+ for (int i = 0; i < n; i++)
+ {
+ try
+ {
+ // System.out.println("sending msg");
+ debutlocal = System.DateTime.Now;
+ bus.SendMsg("GetDummy message");
+ finlocal = System.DateTime.Now;
+ total += finlocal - debutlocal;
+ Thread.Sleep( t );
+ }
+ catch (IvyException )
+ {
+ System.Environment.Exit(-1);
+ }
+ catch (ThreadInterruptedException )
+ {
+ }
+ }
+ System.Console.Out.WriteLine(((f) ? "[filtered] " : "[non filtered] ") + total + "ms elapsed, " + (finlocal - debut) + " ms total out of " + n * t);
+ bus.Stop();
+ if (f == true)
+ new Filter(domain, n, t, false); // relance le même test sans filtre
+ System.Console.ReadLine();
+ }
+
+ void bus_BindingFilter(object sender, IvyEventArgs e)
+ {
+ unbounded++;
+ }
+
+ void bus_BindingRemove(object sender, IvyEventArgs e)
+ {
+ bounded--;
+ }
+
+ void bus_BindingAdd(object sender, IvyEventArgs e)
+ {
+ bounded++;
+ }
+
+ }
+} \ No newline at end of file