diff options
| -rw-r--r-- | example/ivymainloop.pl | 171 |
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__ + |