libtransport.git Changeset - e71c01ded8f1

Changeset - e71c01ded8f1

Parent rev.

Child rev.

[Not reviewed]

0 1 0

Alexander Skovpen - 13 years ago 2012-04-08 17:22:41
a.n.skovpen@gmail.com

added messages statistic to munin plugin

1 file changed with 62 insertions and 6 deletions:

munin/spectrum2_

0 comments (0 inline, 0 general)

munin/spectrum2_

➞

Show inline comments

 #!/usr/bin/perl
 # config:
 # [spectrum2_*]
 # env.admin_jid tradmin@host.org
 # env.password jid_password
 # env.transports icq.host.org xmpp.host.org
+#
 # symlinks:
 #    spectrum2_backends  spectrum2_memory  spectrum2_users
+#    spectrum2_backends  spectrum2_memory  spectrum2_users spectrum2_messages spectrum2_messages_sec
+#
+#
 use AnyEvent;
 use AnyEvent::XMPP::Client;
 use AnyEvent::XMPP::Component;
 use AnyEvent::XMPP::Ext::Disco;
 use AnyEvent::XMPP::Ext::Version;
 use AnyEvent::XMPP::Namespaces qw/xmpp_ns/;
 use AnyEvent::XMPP::Util qw/simxml/;
 use XML::Simple;
 use Time::HiRes qw ( setitimer ITIMER_REAL time );
 use strict;
@@ @@ -42,42 +42,74 @@ my %config=( @@
 	command=>'backends_count',
 	base=>'--base 1000',
 	x=>'1',
     },
     memory => {
 	title=>'Memory usage of transports',
 	vlabel=>'megabytes',
 	info=>'Memory usage of spectrum transports.',
 	command=>'used_memory',
 	base=>'--base 1024',
 	x=>'1024',
     },
     messages => {
 	title=>'Messages send over transport',
 	vlabel=>'messages',
 	info=>'Messages send over spectrum transports.',
 	command=>'',
 	base=>'--base 1000',
 	x=>'1',
     },
     messages_sec => {
 	title=>'Messages send over transport',
 	vlabel=>'messages/sec',
 	info=>'Messages send per second over spectrum transports.',
 	command=>'',
 	base=>'--base 1000',
 	x=>'1',
     },
 );
 my @queue=('_out','_in');
 $0 =~ /spectrum2_(.+)*$/;
 my $func = $1;
 exit 2 unless defined $func;
 my %tr;
 my $count=0;
     foreach (split(' ',$ENV{'transports'})){
         $tr{$_}=$count;
         $count++;
         if ($func=~/messages/)
+	{
 	    $tr{$_."_in"}=$count;
 	    $count++;
 	    $tr{$_."_out"}=$count;
 	    $count++;
+	}
 	else
+	{
 	$tr{$_}=$count;
 	$count++;
+	}
+    }
 if (exists $ARGV[0] and $ARGV[0] eq "config")
+{
     print "graph_title ".$config{$func}->{'title'}."\n";
     print "graph_vlabel ".$config{$func}->{'vlabel'}."\n";
     print "graph_category spectrum2\n";
     foreach (keys (%tr)){
 	print "r".$tr{$_}.".label ".$_."\n";
 	if ($func eq 'messages_sec')
+	{
 	    print "r".$tr{$_}.".type DERIVE\n";
 	    print "r".$tr{$_}.".min 0\n";
+	}
+    }
     print "graph_args ".$config{$func}->{'base'}."\n";
     print "graph_info ".$config{$func}->{'info'}."\n";
     exit 0;
+}
 binmode( STDOUT);
 my $xs=new XML::Simple;
 my $cl=AnyEvent::XMPP::Client->new(debug=>0);
 my $j=AnyEvent->condvar;
 $cl->add_account($ENV{'admin_jid'}.'/'.time,$ENV{'password'});
 $cl->reg_cb(
@@ @@ -89,22 +121,46 @@ $cl->start; @@
 $j->wait;
 sub cl_disc
+{
 my ($cl,$acc,$h,$p,$reas)=@_;
     print "disc ($h:$p) $reas\n";
+}
 sub cl_sess
+{
     my($cl,$acc)=@_;
     foreach (keys (%tr)){
         $cl->send_message($config{$func}->{'command'},$_,undef,'chat');
         if ($func=~/messages/)
+	{
 	    if (s/_in$//)
+	    {
 		$cl->send_message("messages_from_xmpp",$_,undef,'chat');
 	    };
 	    if (s/_out$//)
+	    {
 		$cl->send_message("messages_to_xmpp",$_,undef,'chat');
+	    }
+	}
 	else
+	{
 	    $cl->send_message($config{$func}->{'command'},$_,undef,'chat');
+	}
+    }
+}
 sub cl_msg
+{
     my ($cl,$acc,$msg)=@_;
     print "r".$tr{$msg->from}.".value ".int($msg->any_body/$config{$func}->{'x'})."\n";
     delete( $tr{$msg->from});
     if ($func=~/messages/)
+    {
 	print "r".$tr{$msg->from.$queue[-1]}.".value ".int($msg->any_body/$config{$func}->{'x'})."\n";
 	delete( $tr{$msg->from.$queue[-1]});
 	pop(@queue);
 	if ($#queue==-1){@queue=("_out","_in");}
+    }
     else
+    {
 	print "r".$tr{$msg->from}.".value ".int($msg->any_body/$config{$func}->{'x'})."\n";
 	delete( $tr{$msg->from});
+    }
     exit if (scalar(keys %tr)==0);
+}

0 comments (0 inline, 0 general)