Gecko [ ikeda-bankin-syuuri.click ]

Name	Size	Permission
Algorithm	[ DIR ]	drwxr-xr-x
Alien	[ DIR ]	drwxr-xr-x
Any	[ DIR ]	drwxr-xr-x
AnyEvent	[ DIR ]	drwxr-xr-x
Apache	[ DIR ]	drwxr-xr-x
Apache2	[ DIR ]	drwxr-xr-x
App	[ DIR ]	drwxr-xr-x
AppConfig	[ DIR ]	drwxr-xr-x
Archive	[ DIR ]	drwxr-xr-x
Array	[ DIR ]	drwxr-xr-x
Astro	[ DIR ]	drwxr-xr-x
Authen	[ DIR ]	drwxr-xr-x
B	[ DIR ]	drwxr-xr-x
BZ	[ DIR ]	drwxr-xr-x
Boulder	[ DIR ]	drwxr-xr-x
Browser	[ DIR ]	drwxr-xr-x
Bundle	[ DIR ]	drwxr-xr-x
Business	[ DIR ]	drwxr-xr-x
Bytes	[ DIR ]	drwxr-xr-x
CGI	[ DIR ]	drwxr-xr-x
CHI	[ DIR ]	drwxr-xr-x
CPAN	[ DIR ]	drwxr-xr-x
CPANPLUS	[ DIR ]	drwxr-xr-x
CSS	[ DIR ]	drwxr-xr-x
Cache	[ DIR ]	drwxr-xr-x
Canary	[ DIR ]	drwxr-xr-x
Carp	[ DIR ]	drwxr-xr-x
Check	[ DIR ]	drwxr-xr-x
Child	[ DIR ]	drwxr-xr-x
Class	[ DIR ]	drwxr-xr-x
Clipboard	[ DIR ]	drwxr-xr-x
Clone	[ DIR ]	drwxr-xr-x
Collectd	[ DIR ]	drwxr-xr-x
Config	[ DIR ]	drwxr-xr-x
ConfigReader	[ DIR ]	drwxr-xr-x
Context	[ DIR ]	drwxr-xr-x
Contextual	[ DIR ]	drwxr-xr-x
Convert	[ DIR ]	drwxr-xr-x
Crypt	[ DIR ]	drwxr-xr-x
Curses	[ DIR ]	drwxr-xr-x
Cwd	[ DIR ]	drwxr-xr-x
DBD	[ DIR ]	drwxr-xr-x
DBIx	[ DIR ]	drwxr-xr-x
DBM	[ DIR ]	drwxr-xr-x
DB_File	[ DIR ]	drwxr-xr-x
Data	[ DIR ]	drwxr-xr-x
Database	[ DIR ]	drwxr-xr-x
Date	[ DIR ]	drwxr-xr-x
DateTime	[ DIR ]	drwxr-xr-x
DateTimeX	[ DIR ]	drwxr-xr-x
Declare	[ DIR ]	drwxr-xr-x
Devel	[ DIR ]	drwxr-xr-x
Digest	[ DIR ]	drwxr-xr-x
Directory	[ DIR ]	drwxr-xr-x
Dist	[ DIR ]	drwxr-xr-x
DynaLoader	[ DIR ]	drwxr-xr-x
Email	[ DIR ]	drwxr-xr-x
Encode	[ DIR ]	drwxr-xr-x
Env	[ DIR ]	drwxr-xr-x
Error	[ DIR ]	drwxr-xr-x
Eval	[ DIR ]	drwxr-xr-x
Excel	[ DIR ]	drwxr-xr-x
Exception	[ DIR ]	drwxr-xr-x
Exporter	[ DIR ]	drwxr-xr-x
ExtUtils	[ DIR ]	drwxr-xr-x
FCGI	[ DIR ]	drwxr-xr-x
Feed	[ DIR ]	drwxr-xr-x
Fennec	[ DIR ]	drwxr-xr-x
File	[ DIR ]	drwxr-xr-x
FileHandle	[ DIR ]	drwxr-xr-x
Filesys	[ DIR ]	drwxr-xr-x
Finance	[ DIR ]	drwxr-xr-x
Font	[ DIR ]	drwxr-xr-x
Frontier	[ DIR ]	drwxr-xr-x
Fsdb	[ DIR ]	drwxr-xr-x
GD	[ DIR ]	drwxr-xr-x
Geography	[ DIR ]	drwxr-xr-x
Getopt	[ DIR ]	drwxr-xr-x
Git	[ DIR ]	drwxr-xr-x
GraphViz	[ DIR ]	drwxr-xr-x
Gtk3	[ DIR ]	drwxr-xr-x
HTML	[ DIR ]	drwxr-xr-x
HTTP	[ DIR ]	drwxr-xr-x
Hash	[ DIR ]	drwxr-xr-x
Heap	[ DIR ]	drwxr-xr-x
Hook	[ DIR ]	drwxr-xr-x
IO	[ DIR ]	drwxr-xr-x
IPC	[ DIR ]	drwxr-xr-x
IPTables	[ DIR ]	drwxr-xr-x
IRC	[ DIR ]	drwxr-xr-x
Image	[ DIR ]	drwxr-xr-x
Import	[ DIR ]	drwxr-xr-x
Inline	[ DIR ]	drwxr-xr-x
JSON	[ DIR ]	drwxr-xr-x
JavaScript	[ DIR ]	drwxr-xr-x
Jcode	[ DIR ]	drwxr-xr-x
LWP	[ DIR ]	drwxr-xr-x
Lexical	[ DIR ]	drwxr-xr-x
Lingua	[ DIR ]	drwxr-xr-x
List	[ DIR ]	drwxr-xr-x
Locale	[ DIR ]	drwxr-xr-x
LockFile	[ DIR ]	drwxr-xr-x
Log	[ DIR ]	drwxr-xr-x
MCE	[ DIR ]	drwxr-xr-x
MIME	[ DIR ]	drwxr-xr-x
MLDBM	[ DIR ]	drwxr-xr-x
MRO	[ DIR ]	drwxr-xr-x
Mail	[ DIR ]	drwxr-xr-x
Math	[ DIR ]	drwxr-xr-x
Messaging	[ DIR ]	drwxr-xr-x
Meta	[ DIR ]	drwxr-xr-x
MetaCPAN	[ DIR ]	drwxr-xr-x
Mixin	[ DIR ]	drwxr-xr-x
Mo	[ DIR ]	drwxr-xr-x
Mock	[ DIR ]	drwxr-xr-x
Modern	[ DIR ]	drwxr-xr-x
Module	[ DIR ]	drwxr-xr-x
Mojo	[ DIR ]	drwxr-xr-x
Mojolicious	[ DIR ]	drwxr-xr-x
Mon	[ DIR ]	drwxr-xr-x
Monitoring	[ DIR ]	drwxr-xr-x
Monkey	[ DIR ]	drwxr-xr-x
MooseX	[ DIR ]	drwxr-xr-x
MouseX	[ DIR ]	drwxr-xr-x
Mozilla	[ DIR ]	drwxr-xr-x
Nagios	[ DIR ]	drwxr-xr-x
Net	[ DIR ]	drwxr-xr-x
NetPacket	[ DIR ]	drwxr-xr-x
Nmap	[ DIR ]	drwxr-xr-x
No	[ DIR ]	drwxr-xr-x
Number	[ DIR ]	drwxr-xr-x
OLE	[ DIR ]	drwxr-xr-x
Object	[ DIR ]	drwxr-xr-x
Ocsinventory	[ DIR ]	drwxr-xr-x
PAR	[ DIR ]	drwxr-xr-x
PCP	[ DIR ]	drwxr-xr-x
PDF	[ DIR ]	drwxr-xr-x
PHP	[ DIR ]	drwxr-xr-x
POD2	[ DIR ]	drwxr-xr-x
POE	[ DIR ]	drwxr-xr-x
PPI	[ DIR ]	drwxr-xr-x
PPIx	[ DIR ]	drwxr-xr-x
PSGI	[ DIR ]	drwxr-xr-x
Package	[ DIR ]	drwxr-xr-x
Parallel	[ DIR ]	drwxr-xr-x
Params	[ DIR ]	drwxr-xr-x
Parse	[ DIR ]	drwxr-xr-x
Path	[ DIR ]	drwxr-xr-x
Perl	[ DIR ]	drwxr-xr-x
Perl4	[ DIR ]	drwxr-xr-x
Perl6	[ DIR ]	drwxr-xr-x
PerlIO	[ DIR ]	drwxr-xr-x
Plack	[ DIR ]	drwxr-xr-x
Pod	[ DIR ]	drwxr-xr-x
Probe	[ DIR ]	drwxr-xr-x
Proc	[ DIR ]	drwxr-xr-x
Protocol	[ DIR ]	drwxr-xr-x
REST	[ DIR ]	drwxr-xr-x
RPC	[ DIR ]	drwxr-xr-x
Razor2	[ DIR ]	drwxr-xr-x
Redis	[ DIR ]	drwxr-xr-x
Ref	[ DIR ]	drwxr-xr-x
Regexp	[ DIR ]	drwxr-xr-x
Return	[ DIR ]	drwxr-xr-x
Role	[ DIR ]	drwxr-xr-x
Rose	[ DIR ]	drwxr-xr-x
SGMLS	[ DIR ]	drwxr-xr-x
SNMP	[ DIR ]	drwxr-xr-x
SOAP	[ DIR ]	drwxr-xr-x
SQL	[ DIR ]	drwxr-xr-x
Safe	[ DIR ]	drwxr-xr-x
Scalar	[ DIR ]	drwxr-xr-x
Schedule	[ DIR ]	drwxr-xr-x
Scope	[ DIR ]	drwxr-xr-x
Set	[ DIR ]	drwxr-xr-x
Shared	[ DIR ]	drwxr-xr-x
Software	[ DIR ]	drwxr-xr-x
Sort	[ DIR ]	drwxr-xr-x
Spiffy	[ DIR ]	drwxr-xr-x
Spreadsheet	[ DIR ]	drwxr-xr-x
StackTrace	[ DIR ]	drwxr-xr-x
Statistics	[ DIR ]	drwxr-xr-x
Stone	[ DIR ]	drwxr-xr-x
String	[ DIR ]	drwxr-xr-x
Sub	[ DIR ]	drwxr-xr-x
Swatch	[ DIR ]	drwxr-xr-x
Symbol	[ DIR ]	drwxr-xr-x
Syntax	[ DIR ]	drwxr-xr-x
Sys	[ DIR ]	drwxr-xr-x
Sysadm	[ DIR ]	drwxr-xr-x
TAP	[ DIR ]	drwxr-xr-x
Tangerine	[ DIR ]	drwxr-xr-x
Task	[ DIR ]	drwxr-xr-x
TeX	[ DIR ]	drwxr-xr-x
Template	[ DIR ]	drwxr-xr-x
Term	[ DIR ]	drwxr-xr-x
Test	[ DIR ]	drwxr-xr-x
Test2	[ DIR ]	drwxr-xr-x
Text	[ DIR ]	drwxr-xr-x
Thread	[ DIR ]	drwxr-xr-x
Thrift	[ DIR ]	drwxr-xr-x
Throwable	[ DIR ]	drwxr-xr-x
Tie	[ DIR ]	drwxr-xr-x
Time	[ DIR ]	drwxr-xr-x
Tk	[ DIR ]	drwxr-xr-x
Tree	[ DIR ]	drwxr-xr-x
Try	[ DIR ]	drwxr-xr-x
Types	[ DIR ]	drwxr-xr-x
UNIVERSAL	[ DIR ]	drwxr-xr-x
URI	[ DIR ]	drwxr-xr-x
Unicode	[ DIR ]	drwxr-xr-x
User	[ DIR ]	drwxr-xr-x
VM	[ DIR ]	drwxr-xr-x
Version	[ DIR ]	drwxr-xr-x
WWW	[ DIR ]	drwxr-xr-x
WebService	[ DIR ]	drwxr-xr-x
X10	[ DIR ]	drwxr-xr-x
X11	[ DIR ]	drwxr-xr-x
X2Go	[ DIR ]	drwxr-xr-x
XBase	[ DIR ]	drwxr-xr-x
XML	[ DIR ]	drwxr-xr-x
XMLRPC	[ DIR ]	drwxr-xr-x
YAML	[ DIR ]	drwxr-xr-x
ZMQ	[ DIR ]	drwxr-xr-x
auto	[ DIR ]	drwxr-xr-x
autobox	[ DIR ]	drwxr-xr-x
autodie	[ DIR ]	drwxr-xr-x
common	[ DIR ]	drwxr-xr-x
constant	[ DIR ]	drwxr-xr-x
inc	[ DIR ]	drwxr-xr-x
lib	[ DIR ]	drwxr-xr-x
local	[ DIR ]	drwxr-xr-x
namespace	[ DIR ]	drwxr-xr-x
odern	[ DIR ]	drwxr-xr-x
perl5i	[ DIR ]	drwxr-xr-x
utf8	[ DIR ]	drwxr-xr-x
AppConfig.pm	31.75 KB	-rw-r--r--
AuthCAS.pm	16.91 KB	-rw-r--r--
BER.pm	27.14 KB	-rw-r--r--
Boulder.pod	6.23 KB	-rw-r--r--
CGI.pm	255.24 KB	-rw-r--r--
CHI.pm	46.06 KB	-rw-r--r--
CLASS.pm	1.44 KB	-rw-r--r--
CPANPLUS.pm	7.05 KB	-rw-r--r--
Carp.pm	19.93 KB	-rw-r--r--
Child.pm	6.31 KB	-rw-r--r--
Clipboard.pm	6.09 KB	-rw-r--r--
Collectd.pm	12.61 KB	-r--r--r--
Digest.pm	10.35 KB	-rw-r--r--
Env.pm	5.39 KB	-rw-r--r--
Error.pm	24.27 KB	-rw-r--r--
Expect.pm	53.44 KB	-rw-r--r--
Expect.pod	42.71 KB	-rw-r--r--
Exporter.pm	18.31 KB	-rw-r--r--
Fatal.pm	45.16 KB	-rw-r--r--
Fennec.pm	32.31 KB	-rw-r--r--
FreezeThaw.pm	24.68 KB	-rw-r--r--
Fsdb.pm	91.97 KB	-rw-r--r--
Git.pm	42.55 KB	-r--r--r--
GraphViz.pm	37.08 KB	-rw-r--r--
Gtk3.pm	68.19 KB	-rw-r--r--
Heap.pm	3.8 KB	-rw-r--r--
Inline-API.pod	12.79 KB	-rw-r--r--
Inline-FAQ.pod	6.83 KB	-rw-r--r--
Inline-Support.pod	3.36 KB	-rw-r--r--
Inline.pm	57.2 KB	-rw-r--r--
Inline.pod	38.48 KB	-rw-r--r--
JSON.pm	67.04 KB	-rw-r--r--
Jcode.pm	22.57 KB	-rw-r--r--
LW.pm	8.13 KB	-rw-r--r--
LW2.pm	191.49 KB	-rw-r--r--
MCE.pm	65.36 KB	-rw-r--r--
MCE.pod	7.62 KB	-rw-r--r--
MLDBM.pm	16.21 KB	-rw-r--r--
Mo.pm	560 B	-rw-r--r--
Mo.pod	3.33 KB	-rw-r--r--
Mojo.pm	1.62 KB	-rw-r--r--
Mojolicious.pm	27.54 KB	-rw-r--r--
Monotone.pm	5.4 KB	-rw-r--r--
NetPacket.pm	4.97 KB	-rw-r--r--
PAR.pm	40.11 KB	-rw-r--r--
POE.pm	26.06 KB	-rw-r--r--
PPI.pm	30.58 KB	-rw-r--r--
PSGI.pm	41 B	-rw-r--r--
PSGI.pod	20.21 KB	-rw-r--r--
ReadMe.pod	3.33 KB	-rw-r--r--
Readonly.pm	21.94 KB	-rw-r--r--
Redis.pm	64.92 KB	-rw-r--r--
SGMLS.pm	26.18 KB	-rw-r--r--
SNMP_Session.pm	34.54 KB	-rw-r--r--
SNMP_util.pm	40.27 KB	-rw-r--r--
SUPER.pm	6.63 KB	-rw-r--r--
Sereal.pm	5.29 KB	-rw-r--r--
Spiffy.pm	32.31 KB	-rw-r--r--
Spiffy.pod	17.43 KB	-rw-r--r--
Stone.pm	30.88 KB	-rw-r--r--
Switch.pm	27.79 KB	-rw-r--r--
Tangerine.pm	6.84 KB	-rw-r--r--
Test2.pm	4.03 KB	-rw-r--r--
Thrift.pm	4.1 KB	-r--r--r--
Throwable.pm	1.77 KB	-rw-r--r--
User.pm	2.47 KB	-rw-r--r--
X10.pm	5.18 KB	-rw-r--r--
XBase.pm	39.44 KB	-rw-r--r--
YAML.pm	24.29 KB	-rw-r--r--
abbrev.pl	819 B	-rw-r--r--
aliased.pm	9.39 KB	-rw-r--r--
asa.pm	5.29 KB	-rw-r--r--
assert.pl	1.27 KB	-rw-r--r--
autodie.pm	11.83 KB	-rw-r--r--
bigfloat.pl	7.14 KB	-rw-r--r--
bigint.pl	8.71 KB	-rw-r--r--
bigrat.pl	4.35 KB	-rw-r--r--
boolean.pm	5.75 KB	-rw-r--r--
cacheout.pl	1.1 KB	-rw-r--r--
chat2.pl	9.73 KB	-rw-r--r--
complete.pl	3.12 KB	-rw-r--r--
constant.pm	13.04 KB	-rw-r--r--
cpanfile-faq.pod	4.39 KB	-rw-r--r--
cpanfile.pod	3.39 KB	-rw-r--r--
ctime.pl	1.93 KB	-rw-r--r--
dotsh.pl	2.12 KB	-rw-r--r--
enum.pm	10.63 KB	-rw-r--r--
exceptions.pl	1.7 KB	-rw-r--r--
experimental.pm	6.83 KB	-rw-r--r--
fastcwd.pl	1019 B	-rw-r--r--
find.pl	1.16 KB	-rw-r--r--
finddepth.pl	1.1 KB	-rw-r--r--
flush.pl	642 B	-rw-r--r--
ftp.pl	23.53 KB	-rw-r--r--
getcwd.pl	1.37 KB	-rw-r--r--
getopt.pl	1.27 KB	-rw-r--r--
getopts.pl	1.35 KB	-rw-r--r--
hostname.pl	727 B	-rw-r--r--
importenv.pl	283 B	-rw-r--r--
look.pl	1.23 KB	-rw-r--r--
newgetopt.pl	2.15 KB	-rw-r--r--
ojo.pm	6.81 KB	-rw-r--r--
ok.pm	946 B	-rw-r--r--
open2.pl	185 B	-rw-r--r--
open3.pl	185 B	-rw-r--r--
parent.pm	2.83 KB	-rw-r--r--
perl5i.pm	32.97 KB	-rw-r--r--
perl5ifaq.pod	14.01 KB	-rw-r--r--
perldoc.pod	8.25 KB	-rw-r--r--
pmtools.pm	2.4 KB	-rw-r--r--
pp.pm	20.05 KB	-rw-r--r--
prefork.pm	10.17 KB	-rw-r--r--
pwd.pl	1.44 KB	-rw-r--r--
shellwords.pl	280 B	-rw-r--r--
skel.pl	4.74 KB	-rw-r--r--
stat.pl	525 B	-rw-r--r--
syslog.pl	4.69 KB	-rw-r--r--
tainted.pl	164 B	-rw-r--r--
termcap.pl	4.02 KB	-rw-r--r--
timelocal.pl	690 B	-rw-r--r--
ttfmod.pl	6.62 KB	-rw-r--r--
validate.pl	3.64 KB	-rw-r--r--
yui.pm	132.76 KB	-rw-r--r--

Code Editor : Collectd.pm

# collectd - Collectd.pm
# Copyright (C) 2007-2009  Sebastian Harl
#
# This program is free software; you can redistribute it and/or modify it
# under the terms of the GNU General Public License as published by the
# Free Software Foundation; only version 2 of the License is applicable.
#
# 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.,
# 51 Franklin St, Fifth Floor, Boston, MA  02110-1301 USA
#
# Author:
#   Sebastian Harl <sh at tokkee.org>

package Collectd;

use strict;
use warnings;

use Config;

use threads;
use threads::shared;

BEGIN {
	if (! $Config{'useithreads'}) {
		die "Perl does not support ithreads!";
	}
}

require Exporter;

our @ISA = qw( Exporter );

our %EXPORT_TAGS = (
	'plugin' => [ qw(
			plugin_register
			plugin_unregister
			plugin_dispatch_values
			plugin_get_interval
			plugin_write
			plugin_flush
			plugin_flush_one
			plugin_flush_all
			plugin_dispatch_notification
			plugin_log
	) ],
	'types' => [ qw(
			TYPE_INIT
			TYPE_READ
			TYPE_WRITE
			TYPE_SHUTDOWN
			TYPE_LOG
			TYPE_NOTIF
			TYPE_FLUSH
			TYPE_CONFIG
			TYPE_DATASET
	) ],
	'ds_types' => [ qw(
			DS_TYPE_COUNTER
			DS_TYPE_GAUGE
	) ],
	'log' => [ qw(
			ERROR
			WARNING
			NOTICE
			INFO
			DEBUG
			LOG_ERR
			LOG_WARNING
			LOG_NOTICE
			LOG_INFO
			LOG_DEBUG
	) ],
	'filter_chain' => [ qw(
			fc_register
			FC_MATCH_NO_MATCH
			FC_MATCH_MATCHES
			FC_TARGET_CONTINUE
			FC_TARGET_STOP
			FC_TARGET_RETURN
	) ],
	'fc_types' => [ qw(
			FC_MATCH
			FC_TARGET
	) ],
	'notif' => [ qw(
			NOTIF_FAILURE
			NOTIF_WARNING
			NOTIF_OKAY
	) ],
	'globals' => [ qw(
			$hostname_g
			$interval_g
	) ],
);

{
	my %seen;
	push @{$EXPORT_TAGS{'all'}}, grep {! $seen{$_}++ } @{$EXPORT_TAGS{$_}}
		foreach keys %EXPORT_TAGS;
}

# global variables
our $hostname_g;
our $interval_g;

Exporter::export_ok_tags ('all');

my @plugins : shared = ();
my @fc_plugins : shared = ();
my %cf_callbacks : shared = ();

my %types = (
	TYPE_CONFIG,   "config",
	TYPE_INIT,     "init",
	TYPE_READ,     "read",
	TYPE_WRITE,    "write",
	TYPE_SHUTDOWN, "shutdown",
	TYPE_LOG,      "log",
	TYPE_NOTIF,    "notify",
	TYPE_FLUSH,    "flush"
);

my %fc_types = (
	FC_MATCH,  "match",
	FC_TARGET, "target"
);

my %fc_exec_names = (
	FC_MATCH,  "match",
	FC_TARGET, "invoke"
);

my %fc_cb_types = (
	FC_CB_EXEC, "exec",
	FC_CB_CREATE, "create",
	FC_CB_DESTROY, "destroy"
);

foreach my $type (keys %types) {
	$plugins[$type] = &share ({});
}

foreach my $type (keys %fc_types) {
	$fc_plugins[$type] = &share ({});
}

sub _log {
	my $caller = shift;
	my $lvl    = shift;
	my $msg    = shift;

if ("Collectd" eq $caller) {
		$msg = "perl: $msg";
	}
	return plugin_log ($lvl, $msg);
}

sub ERROR   { _log (scalar caller, LOG_ERR,     shift); }
sub WARNING { _log (scalar caller, LOG_WARNING, shift); }
sub NOTICE  { _log (scalar caller, LOG_NOTICE,  shift); }
sub INFO    { _log (scalar caller, LOG_INFO,    shift); }
sub DEBUG   { _log (scalar caller, LOG_DEBUG,   shift); }

sub plugin_call_all {
	my $type = shift;

my %plugins;

our $cb_name = undef;

if (! defined $type) {
		return;
	}

if (TYPE_LOG != $type) {
		DEBUG ("Collectd::plugin_call_all: type = \"$type\" ("
			. $types{$type} . "), args=\""
			. join(', ', map { defined($_) ? $_ : '<undef>' } @_) . "\"");
	}

if (! defined $plugins[$type]) {
		ERROR ("Collectd::plugin_call_all: unknown type \"$type\"");
		return;
	}

{
		lock %{$plugins[$type]};
		%plugins = %{$plugins[$type]};
	}

foreach my $plugin (keys %plugins) {
		$cb_name = $plugins{$plugin};
		my $status = call_by_name (@_);

if (! $status) {
			my $err = undef;

if ($@) {
				$err = $@;
			}
			else {
				$err = "callback returned false";
			}

if (TYPE_LOG != $type) {
				ERROR ("Execution of callback \"$cb_name\" failed: $err");
			}

$status = 0;
		}

if ($status) {
			#NOOP
		}
		elsif (TYPE_INIT == $type) {
			ERROR ("${plugin}->init() failed with status $status. "
				. "Plugin will be disabled.");

foreach my $type (keys %types) {
				plugin_unregister ($type, $plugin);
			}
		}
		elsif (TYPE_LOG != $type) {
			WARNING ("${plugin}->$types{$type}() failed with status $status.");
		}
	}
	return 1;
}

# Collectd::plugin_register (type, name, data).
#
# type:
#   init, read, write, shutdown, data set
#
# name:
#   name of the plugin
#
# data:
#   reference to the plugin's subroutine that does the work or the data set
#   definition
sub plugin_register {
	my $type = shift;
	my $name = shift;
	my $data = shift;

DEBUG ("Collectd::plugin_register: "
		. "type = \"$type\" (" . $types{$type}
		. "), name = \"$name\", data = \"$data\"");

if (! ((defined $type) && (defined $name) && (defined $data))) {
		ERROR ("Usage: Collectd::plugin_register (type, name, data)");
		return;
	}

if ((! defined $plugins[$type]) && (TYPE_DATASET != $type)
			&& (TYPE_CONFIG != $type)) {
		ERROR ("Collectd::plugin_register: Invalid type \"$type\"");
		return;
	}

if ((TYPE_DATASET == $type) && ("ARRAY" eq ref $data)) {
		return plugin_register_data_set ($name, $data);
	}
	elsif ((TYPE_CONFIG == $type) && (! ref $data)) {
		my $pkg = scalar caller;

if ($data !~ m/^$pkg\:\:/) {
			$data = $pkg . "::" . $data;
		}

lock %cf_callbacks;
		$cf_callbacks{$name} = $data;
	}
	elsif ((TYPE_DATASET != $type) && (! ref $data)) {
		my $pkg = scalar caller;
		if ($data !~ m/^$pkg\:\:/) {
			$data = $pkg . "::" . $data;
		}
		if (TYPE_READ == $type) {
			return plugin_register_read($name, $data);
		}
		if (TYPE_WRITE == $type) {
			return plugin_register_write($name, $data);
		}
		if (TYPE_LOG == $type) {
			return plugin_register_log($name, $data);
		}
		if (TYPE_NOTIF == $type) {
			return plugin_register_notification($name, $data);
		}
		if (TYPE_FLUSH == $type) {
			#For collectd-5.6 only
			lock %{$plugins[$type]};
			$plugins[$type]->{$name} = $data;
			return plugin_register_flush($name, $data);
		}
		lock %{$plugins[$type]};
		$plugins[$type]->{$name} = $data;
	}
	else {
		ERROR ("Collectd::plugin_register: Invalid data.");
		return;
	}
	return 1;
}

sub plugin_unregister {
	my $type = shift;
	my $name = shift;

DEBUG ("Collectd::plugin_unregister: type = \"$type\" ("
		. $types{$type} . "), name = \"$name\"");

if (! ((defined $type) && (defined $name))) {
		ERROR ("Usage: Collectd::plugin_unregister (type, name)");
		return;
	}

if (TYPE_DATASET == $type) {
		return plugin_unregister_data_set ($name);
	}
	elsif (TYPE_CONFIG == $type) {
		lock %cf_callbacks;
		delete $cf_callbacks{$name};
	}
	elsif (TYPE_READ == $type) {
		return plugin_unregister_read ($name);
	}
	elsif (TYPE_WRITE == $type) {
		return plugin_unregister_write($name);
	}
	elsif (TYPE_LOG == $type) {
		return plugin_unregister_log ($name);
	}
	elsif (TYPE_NOTIF == $type) {
		return plugin_unregister_notification($name);
	}
	elsif (TYPE_FLUSH == $type) {
		return plugin_unregister_flush($name);
	}
	elsif (defined $plugins[$type]) {
		lock %{$plugins[$type]};
		delete $plugins[$type]->{$name};
	}
	else {
		ERROR ("Collectd::plugin_unregister: Invalid type.");
		return;
	}
}

sub plugin_write {
	my %args = @_;

my @plugins    = ();
	my @datasets   = ();
	my @valuelists = ();

if (! defined $args{'valuelists'}) {
		ERROR ("Collectd::plugin_write: Missing 'valuelists' argument.");
		return;
	}

DEBUG ("Collectd::plugin_write:"
		. (defined ($args{'plugins'}) ? " plugins = $args{'plugins'}" : "")
		. (defined ($args{'datasets'}) ? " datasets = $args{'datasets'}" : "")
		. " valueslists = $args{'valuelists'}");

if (defined ($args{'plugins'})) {
		if ("ARRAY" eq ref ($args{'plugins'})) {
			@plugins = @{$args{'plugins'}};
		}
		else {
			@plugins = ($args{'plugins'});
		}
	}
	else {
		@plugins = (undef);
	}

if ("ARRAY" eq ref ($args{'valuelists'})) {
		@valuelists = @{$args{'valuelists'}};
	}
	else {
		@valuelists = ($args{'valuelists'});
	}

if (defined ($args{'datasets'})) {
		if ("ARRAY" eq ref ($args{'datasets'})) {
			@datasets = @{$args{'datasets'}};
		}
		else {
			@datasets = ($args{'datasets'});
		}
	}
	else {
		@datasets = (undef) x scalar (@valuelists);
	}

if ($#datasets != $#valuelists) {
		ERROR ("Collectd::plugin_write: Invalid number of datasets.");
		return;
	}

foreach my $plugin (@plugins) {
		for (my $i = 0; $i < scalar (@valuelists); ++$i) {
			_plugin_write ($plugin, $datasets[$i], $valuelists[$i]);
		}
	}
}

sub plugin_flush {
	my %args = @_;

my $timeout = -1;
	my @plugins = ();
	my @ids     = ();

DEBUG ("Collectd::plugin_flush:"
		. (defined ($args{'timeout'}) ? " timeout = $args{'timeout'}" : "")
		. (defined ($args{'plugins'}) ? " plugins = $args{'plugins'}" : "")
		. (defined ($args{'identifiers'})
			? " identifiers = $args{'identifiers'}" : ""));

if (defined ($args{'timeout'}) && ($args{'timeout'} > 0)) {
		$timeout = $args{'timeout'};
	}

if (defined ($args{'plugins'})) {
		if ("ARRAY" eq ref ($args{'plugins'})) {
			@plugins = @{$args{'plugins'}};
		}
		else {
			@plugins = ($args{'plugins'});
		}
	}
	else {
		@plugins = (undef);
	}

if (defined ($args{'identifiers'})) {
		if ("ARRAY" eq ref ($args{'identifiers'})) {
			@ids = @{$args{'identifiers'}};
		}
		else {
			@ids = ($args{'identifiers'});
		}
	}
	else {
		@ids = (undef);
	}

foreach my $plugin (@plugins) {
		foreach my $id (@ids) {
			_plugin_flush($plugin, $timeout, $id);
		}
	}
}

sub fc_call {
	my $type    = shift;
	my $name    = shift;
	my $cb_type = shift;

my %proc;

our $cb_name = undef;
	my  $status;

if (! ((defined $type) && (defined $name) && (defined $cb_type))) {
		ERROR ("Usage: Collectd::fc_call(type, name, cb_type, ...)");
		return;
	}

if (! defined $fc_plugins[$type]) {
		ERROR ("Collectd::fc_call: Invalid type \"$type\"");
		return;
	}

if (! defined $fc_plugins[$type]->{$name}) {
		ERROR ("Collectd::fc_call: Unknown "
			. ($type == FC_MATCH ? "match" : "target")
			. " \"$name\"");
		return;
	}

DEBUG ("Collectd::fc_call: "
		. "type = \"$type\" (" . $fc_types{$type}
		. "), name = \"$name\", cb_type = \"$cb_type\" ("
		. $fc_cb_types{$cb_type} . ")");

{
		lock %{$fc_plugins[$type]};
		%proc = %{$fc_plugins[$type]->{$name}};
	}

if (FC_CB_EXEC == $cb_type) {
		$cb_name = $proc{$fc_exec_names{$type}};
	}
	elsif (FC_CB_CREATE == $cb_type) {
		if (defined $proc{'create'}) {
			$cb_name = $proc{'create'};
		}
		else {
			return 1;
		}
	}
	elsif (FC_CB_DESTROY == $cb_type) {
		if (defined $proc{'destroy'}) {
			$cb_name = $proc{'destroy'};
		}
		else {
			return 1;
		}
	}

$status = call_by_name (@_);

if ($status < 0) {
		my $err = undef;

if ($@) {
			$err = $@;
		}
		else {
			$err = "callback returned false";
		}

ERROR ("Execution of fc callback \"$cb_name\" failed: $err");
		return;
	}
	return $status;
}

sub fc_register {
	my $type = shift;
	my $name = shift;
	my $proc = shift;

my %fc : shared;

DEBUG ("Collectd::fc_register: "
		. "type = \"$type\" (" . $fc_types{$type}
		. "), name = \"$name\", proc = \"$proc\"");

if (! ((defined $type) && (defined $name) && (defined $proc))) {
		ERROR ("Usage: Collectd::fc_register(type, name, proc)");
		return;
	}

if (! defined $fc_plugins[$type]) {
		ERROR ("Collectd::fc_register: Invalid type \"$type\"");
		return;
	}

if (("HASH" ne ref ($proc)) || (! defined $proc->{$fc_exec_names{$type}})
			|| ("" ne ref ($proc->{$fc_exec_names{$type}}))) {
		ERROR ("Collectd::fc_register: Invalid proc.");
		return;
	}

for my $p (qw( create destroy )) {
		if ((defined $proc->{$p}) && ("" ne ref ($proc->{$p}))) {
			ERROR ("Collectd::fc_register: Invalid proc.");
			return;
		}
	}

%fc = %$proc;

foreach my $p (keys %fc) {
		my $pkg = scalar caller;

if ($p !~ m/^(create|destroy|$fc_exec_names{$type})$/) {
			next;
		}

if ($fc{$p} !~ m/^$pkg\:\:/) {
			$fc{$p} = $pkg . "::" . $fc{$p};
		}
	}

lock %{$fc_plugins[$type]};
	if (defined $fc_plugins[$type]->{$name}) {
		WARNING ("Collectd::fc_register: Overwriting previous "
			. "definition of match \"$name\".");
	}

if (! _fc_register ($type, $name)) {
		ERROR ("Collectd::fc_register: Failed to register \"$name\".");
		return;
	}

$fc_plugins[$type]->{$name} = \%fc;
	return 1;
}

sub _plugin_dispatch_config {
	my $plugin = shift;
	my $config = shift;

our $cb_name = undef;

if (! (defined ($plugin) && defined ($config))) {
		return;
	}

if (! defined $cf_callbacks{$plugin}) {
		WARNING ("Found a configuration for the \"$plugin\" plugin, but "
			. "the plugin isn't loaded or didn't register "
			. "a configuration callback.");
		return;
	}

{
		lock %cf_callbacks;
		$cb_name = $cf_callbacks{$plugin};
	}
	call_by_name ($config);
}

# vim: set sw=4 ts=4 tw=78 noexpandtab :

${this.title}

Code Editor : Collectd.pm