From 60e715105d19a93bea7ff167bf81a35ea477a717 Mon Sep 17 00:00:00 2001
From: fcolin
Date: Thu, 1 Feb 2007 10:04:27 +0000
Subject: Utilisateur : Fcolin Date : 30/11/05 Heure : 10:27 Créé
Commentaire: (vss 1)
---
CSharp/Ivy/IvyPerf/IvyPerf.cs | 58 +++++++++++++++++++++++++++++++++++++++++++
1 file changed, 58 insertions(+)
create mode 100644 CSharp/Ivy/IvyPerf/IvyPerf.cs
(limited to 'CSharp/Ivy/IvyPerf')
diff --git a/CSharp/Ivy/IvyPerf/IvyPerf.cs b/CSharp/Ivy/IvyPerf/IvyPerf.cs
new file mode 100644
index 0000000..2a23d22
--- /dev/null
+++ b/CSharp/Ivy/IvyPerf/IvyPerf.cs
@@ -0,0 +1,58 @@
+using System;
+using IvyBus;
+using System.Threading;
+using System.Globalization;
+
+namespace IvyPerf
+{
+ ///
+ /// Description résumée de Class1.
+ ///
+ class IvyPerf
+ {
+ static Ivy bus;
+ // manque d'homogeneitee format float en langue US
+ static CultureInfo c;
+
+ static double currentTime() // en ms
+ {
+ double time;
+ time = (double)DateTime.Now.Ticks / (double)TimeSpan.TicksPerMillisecond;
+ //time = Environment.TickCount;
+ return time;
+ }
+ static void Reply(IvyClient client, IvyArgument args)
+ {
+ bus.sendMsg(c,"pong ts={0} tr={1}", args, currentTime());
+ }
+ static void Pong(IvyClient client, IvyArgument args)
+ {
+ double current = currentTime();
+ double ts = double.Parse( args[0].Value, c );
+ double tr = double.Parse(args[1].Value, c);
+ double roundtrip1 = tr-ts;
+ double roundtrip2 = current - ts;
+ Console.WriteLine( "round trip {0} {1}", roundtrip1 , roundtrip2 );
+ }
+ ///
+ /// Point d'entrée principal de l'application.
+ ///
+ [STAThread]
+ static void Main(string[] args)
+ {
+ c = new CultureInfo("en-us");
+ bus = new Ivy("IvyPerf", "IvyPref ready");
+ bus.bindMsg( "^ping ts=(.*)", new Ivy.MessageHandler( Reply ) );
+ bus.bindMsg( "^pong ts=(.*) tr=(.*)", new Ivy.MessageHandler( Pong ) );
+ //bus.bindSimpleMsg( "ping:ts", new Ivy.MessageHandler( Reply ) );
+ //bus.bindSimpleMsg( "pong:ts,tr", new Ivy.MessageHandler( Pong ) );
+ bus.start(null);
+ while( true )
+ {
+ Thread.Sleep( 1000 );
+ int count = bus.sendMsg(c,"ping ts={0}", currentTime());
+ if ( count == 0 ) Console.Write( "." );
+ }
+ }
+ }
+}
--
cgit v1.1