From: Florian Forster <octo@leeloo.lan.home.verplant.org>
Date: Mon, 18 Jun 2007 22:12:05 +0000 (+0200)
Subject: Collectd::Unixsock: Implemented the `listval' method.
X-Git-Tag: collectd-4.1.0~48
X-Git-Url: https://git.tokkee.org/?a=commitdiff_plain;h=9d885378da816c09d177792abf5aadd1eab81403;p=collectd.git

Collectd::Unixsock: Implemented the `listval' method.
---

diff --git a/contrib/PerlLib/Collectd/Unixsock.pm b/contrib/PerlLib/Collectd/Unixsock.pm
index 92e8772c..3b8a91cf 100644
--- a/contrib/PerlLib/Collectd/Unixsock.pm
+++ b/contrib/PerlLib/Collectd/Unixsock.pm
@@ -83,6 +83,33 @@ sub _create_identifier
 	return ("$host/$plugin/$type");
 } # _create_identifier
 
+sub _parse_identifier
+{
+	my $string = shift;
+	my $host;
+	my $plugin;
+	my $plugin_instance;
+	my $type;
+	my $type_instance;
+	my $ident;
+
+	($host, $plugin, $type) = split ('/', $string);
+
+	($plugin, $plugin_instance) = split ('-', $plugin, 2);
+	($type, $type_instance) = split ('-', $type, 2);
+
+	$ident =
+	{
+		host => $host,
+		plugin => $plugin,
+		type => $type
+	};
+	$ident->{'plugin_instance'} = $plugin_instance if (defined ($plugin_instance));
+	$ident->{'type_instance'} = $type_instance if (defined ($type_instance));
+
+	return ($ident);
+} # _parse_identifier
+
 =head1 PUBLIC METHODS
 
 =over 4
@@ -217,6 +244,52 @@ sub putval
 	return;
 } # putval
 
+=item I<$res> = I<$obj>-E<gt>B<listval> ()
+
+Queries a list of values from the daemon. The list is returned as an array of
+hash references, where each hash reference is a valid identifier. The C<time>
+member of each hash holds the epoch value of the last update of that value.
+
+=cut
+
+sub listval
+{
+	my $obj = shift;
+	my $msg;
+	my @ret = ();
+	my $status;
+	my $fh = $obj->{'sock'} or confess;
+
+	$msg = "LISTVAL\n";
+	send ($fh, $msg, 0) or confess ("send: $!");
+
+	$msg = <$fh>;
+	($status, $msg) = split (' ', $msg, 2);
+	if ($status < 0)
+	{
+		$obj->{'error'} = $msg;
+		return;
+	}
+
+	for (my $i = 0; $i < $status; $i++)
+	{
+		my $time;
+		my $ident;
+
+		$msg = <$fh>;
+		chomp ($msg);
+
+		($time, $ident) = split (' ', $msg, 2);
+
+		$ident = _parse_identifier ($ident);
+		$ident->{'time'} = int ($time);
+
+		push (@ret, $ident);
+	} # for (i = 0 .. $status)
+
+	return (@ret);
+} # listval
+
 =item I<$obj>-E<gt>destroy ();
 
 Closes the socket before the object is destroyed. This function is also