initial release

1 files changed, 171 insertions, 0 deletions

diff --git a/example/ivymainloop.pl b/example/ivymainloop.pl
new file mode 100644
index 0000000..252afe8
--- /dev/null
+++ b/example/ivymainloop.pl
@@ -0,0 +1,171 @@
+#!/usr/bin/perl -w
+#
+# $Source$
+# $Revision$
+#
+# $Author$
+# $Date$
+#	This program is free software; you can redistribute it and/or
+#	modify it under the terms of the GNU GPL General Public License
+#	as published by the Free Software Foundation; either version 2
+#	of the License, or (at your option) any later version.
+#	      
+#	This program is distributed in the hope that it will be useful,
+#	but WITHOUT ANY WARRANTY; without even the implied warranty of
+#	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#	GNU General Public License for more details.
+#	
+#	You should have received a copy of the GNU General Public License
+#	along with this program; if not, write to the Free Software
+#	Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA,
+#	or refer to http://www.gnu.org/copyleft/gpl.html
+#
+
+use strict;
+use Ivy;
+use Getopt::Long;
+use Carp;
+use Time::Gettimeofday;  # this module is needed by Ivy!
+
+#delay between every request asking if a distant appli is still living!   
+my $delay_between_living_request = 3000;
+
+# a hash table containing connected applis
+my %connected_applications;
+
+# when false, no request are send any more
+my $running = 1;
+
+my $opt_name;
+
+my $bus;
+
+&check_options;
+
+my $appliname = (defined $opt_name) ? $opt_name : "IvyTestLoop";
+
+Ivy->init (-ivyBus => (defined $bus) ? $bus : undef,
+	   -appName => $appliname,
+	   -loopMode => 'LOCAL',
+	   -messWhenReady => "$appliname READY",
+	   );
+
+my $IvyObj = Ivy->new(-statusFunc => \&statusFunc,
+		      );
+
+
+
+$IvyObj->start;
+
+$IvyObj->bindRegexp(  "$appliname are you here\?", [ "unused", \&yes_I_am_here] );
+
+$IvyObj->bindRegexp(  "^pause", [ "unused", \&pause] );
+$IvyObj->bindRegexp("^unpause", [ "unused", \&unpause] );
+
+Ivy->mainLoop;
+
+
+
+# this function has 3 additionnal parameters till Ivy Version 4.6
+# and now getting the new/dying applications is straightforward.
+# The first 3 parameters are kept only for upward compatibility! 
+sub statusFunc {
+    my ($ref_ready, $ref_nonReady, $ref_hashReady, $appname, $status, $host_or_regexp) = @_;
+
+    if ($status eq "new") {
+	print "$appname connected from $host_or_regexp\n";
+	$connected_applications{$appname}="";
+	&ask_periodic_status($appname);
+    }
+    elsif ($status eq "died") {
+	print "$appname disconnected from $host_or_regexp\n";
+	undef $connected_applications{$appname};
+    }
+    elsif ($status eq 'subscribing') {
+	print "$appname subscribed to '$host_or_regexp'\n";
+    }
+    elsif ($status eq 'unsubscribing') {
+	print "$appname unsubscribed to '$host_or_regexp'\n";
+    }
+    else {
+	print "Bug: unkown status; $status in &statusFunc\n";
+    }
+    
+#    %connected_applications = %$ref_hashReady;
+}
+
+sub pause {
+    $running = 0;
+    print "appliname is now pausing\n";
+}
+
+sub unpause {
+    $running = 1;
+    print "appliname is now running\n";
+}
+
+sub ask_periodic_status {
+    my ($distantAppli) = @_;
+    my $repeat_id = $IvyObj->repeat($delay_between_living_request,
+					[  sub {&ask_if_living ($distantAppli);} ,
+					   ]
+					);
+    $connected_applications{$distantAppli} = $repeat_id;
+}
+
+sub preciseTime {
+    my $preciseTime = timeofday ();
+    my ($fracSeconds) = $preciseTime =~ /(\.\d*)/ ;
+    my ($ss, $mm, $hh) = (localtime)[0..2];
+    return sprintf ( "%02d:%02d:%02d.%03d", $hh,$mm,$ss,$fracSeconds*1000 );
+}
+
+sub ask_if_living {
+    my ($distantAppli) = @_;
+    return if (!$running);
+    my $reply = "$distantAppli are you here?     (at " . &preciseTime . ")";
+    $IvyObj->sendMsgs($reply);
+}
+
+
+sub yes_I_am_here {
+    my ($ivy, $appname, @param) = @_;
+    my $reply = "$appliname is here and living at " .  &preciseTime;
+    print "$appname asked if I am here and I reply: '$reply'\n";
+    $IvyObj->sendMsgs($reply);
+}
+
+
+
+sub check_options {
+    # on traite la ligne de commande
+    my ($opt_help, $opt_gf);
+    GetOptions("help" => \$opt_help,
+	       "b:s"    => \$bus,
+	       "name:s" => \$opt_name,
+	       );
+
+    &usage if ($opt_help && $opt_help);
+}
+
+
+sub usage {
+    print "ivymainloop.pl [-h] [ -b <network>:<port> ] [ -name ivyname]\n";
+    print "   ivymainloop.pl is a simple test application for the ivy-perl library\n";
+    print "   It sends periodic request on the bus and replies on similar requests\n";
+    print "   Both requests and replies are precisely dated to get\n";
+    print "   a general idea of performance\n";
+    print " To use it as a demo : you should start at least two instances\n";
+    print "   of this script as well as one instance of ivyprobe.pl\n";
+    print "   in 3 xterms and have a look on messages exchanged with ivyprobe\n";
+    print "Example:\n";
+    print " > ivymainloop.pl -name foo\n";
+    print " > ivymainloop.pl -name bar\n";
+    print " > ivyprobe.pl\n\n";
+    exit;
+}
+
+
+
+__END__
+