diff options
Diffstat (limited to 'tools')
-rw-r--r-- | tools/README | 8 | ||||
-rw-r--r-- | tools/mini_epn.c | 153 | ||||
-rw-r--r-- | tools/p1.pl | 151 |
3 files changed, 312 insertions, 0 deletions
diff --git a/tools/README b/tools/README new file mode 100644 index 00000000..2279afcf --- /dev/null +++ b/tools/README | |||
@@ -0,0 +1,8 @@ | |||
1 | $Id$ | ||
2 | The tools subdirectory contains anciliary files that can be used to configure | ||
3 | or test the plugins. | ||
4 | |||
5 | 1. setup - used to get the configuration initialized after a CVS download | ||
6 | 2. tango - | ||
7 | 3. mini_epn/p1.pl - used to test perl plugins for functionality under embedded | ||
8 | perl | ||
diff --git a/tools/mini_epn.c b/tools/mini_epn.c new file mode 100644 index 00000000..cd675389 --- /dev/null +++ b/tools/mini_epn.c | |||
@@ -0,0 +1,153 @@ | |||
1 | /* | ||
2 | * | ||
3 | * MINI_EPN.C - Mini Embedded Perl Nagios | ||
4 | * Contributed by Stanley Hopcroft | ||
5 | * Modified by Douglas Warner | ||
6 | * Last Modified: 05/02/2002 | ||
7 | * | ||
8 | * $Id$ | ||
9 | * | ||
10 | * This is a sample mini embedded Perl interpreter (hacked out checks.c and | ||
11 | * perlembed) for use in testing Perl plugins. | ||
12 | * | ||
13 | * It can be compiled with the following command (see 'man perlembed' for | ||
14 | * more info): | ||
15 | * | ||
16 | * gcc -omini_epn mini_epn.c `perl -MExtUtils::Embed -e ccopts -e ldopts` | ||
17 | * | ||
18 | * NOTES: The compiled binary needs to be in the same directory as the p1.pl | ||
19 | * file supplied with Nagios (or vice versa) | ||
20 | * When using mini_epn to test perl scripts, you must place positional | ||
21 | * arguments immediately after the file/script and before any arguments | ||
22 | * processed by Getopt | ||
23 | * | ||
24 | */ | ||
25 | |||
26 | |||
27 | #include <EXTERN.h> | ||
28 | #include <perl.h> | ||
29 | #include <fcntl.h> | ||
30 | #include <string.h> | ||
31 | |||
32 | /* include PERL xs_init code for module and C library support */ | ||
33 | |||
34 | #if defined(__cplusplus) | ||
35 | #define is_cplusplus | ||
36 | #endif | ||
37 | |||
38 | #ifdef is_cplusplus | ||
39 | extern "C" { | ||
40 | #endif | ||
41 | |||
42 | #define NO_XSLOCKS | ||
43 | #include <XSUB.h> | ||
44 | |||
45 | #ifdef is_cplusplus | ||
46 | } | ||
47 | # ifndef EXTERN_C | ||
48 | # define EXTERN_C extern "C" | ||
49 | # endif | ||
50 | #else | ||
51 | # ifndef EXTERN_C | ||
52 | # define EXTERN_C extern | ||
53 | # endif | ||
54 | #endif | ||
55 | |||
56 | |||
57 | EXTERN_C void xs_init _((void)); | ||
58 | |||
59 | EXTERN_C void boot_DynaLoader _((CV* cv)); | ||
60 | |||
61 | EXTERN_C void xs_init(void) | ||
62 | { | ||
63 | char *file = __FILE__; | ||
64 | dXSUB_SYS; | ||
65 | |||
66 | /* DynaLoader is a special case */ | ||
67 | newXS("DynaLoader::boot_DynaLoader", boot_DynaLoader, file); | ||
68 | } | ||
69 | |||
70 | |||
71 | static PerlInterpreter *perl = NULL; | ||
72 | |||
73 | |||
74 | int main(int argc, char **argv, char **env) | ||
75 | { | ||
76 | char *embedding[] = { "", "p1.pl" }; | ||
77 | char plugin_output[1024]; | ||
78 | char buffer[512]; | ||
79 | char tmpfname[32]; | ||
80 | char fname[32]; | ||
81 | char *args[] = {"","0", "", "", NULL }; | ||
82 | FILE *fp; | ||
83 | |||
84 | const int command_line_size = 160; | ||
85 | char command_line[command_line_size]; | ||
86 | char *ap ; | ||
87 | int exitstatus; | ||
88 | int pclose_result; | ||
89 | #ifdef THREADEDPERL | ||
90 | dTHX; | ||
91 | #endif | ||
92 | dSP; | ||
93 | |||
94 | if ((perl=perl_alloc())==NULL) { | ||
95 | snprintf(buffer,sizeof(buffer),"Error: Could not allocate memory for embedded Perl interpreter!\n"); | ||
96 | buffer[sizeof(buffer)-1]='\x0'; | ||
97 | printf("%s\n", buffer); | ||
98 | exit(1); | ||
99 | } | ||
100 | perl_construct(perl); | ||
101 | exitstatus=perl_parse(perl,xs_init,2,embedding,NULL); | ||
102 | if (!exitstatus) { | ||
103 | |||
104 | exitstatus=perl_run(perl); | ||
105 | |||
106 | while(printf("Enter file name: ") && fgets(command_line, command_line_size, stdin)) { | ||
107 | |||
108 | /* call the subroutine, passing it the filename as an argument */ | ||
109 | |||
110 | command_line[strlen(command_line) -1] = '\0'; | ||
111 | |||
112 | strncpy(fname,command_line,strcspn(command_line," ")); | ||
113 | fname[strcspn(command_line," ")] = '\x0'; | ||
114 | args[0] = fname ; | ||
115 | args[3] = command_line + strlen(fname) + 1 ; | ||
116 | |||
117 | /* generate a temporary filename to which stdout can be redirected. */ | ||
118 | sprintf(tmpfname,"/tmp/embedded%d",getpid()); | ||
119 | args[2] = tmpfname; | ||
120 | |||
121 | /* call our perl interpreter to compile and optionally cache the command */ | ||
122 | perl_call_argv("Embed::Persistent::eval_file", G_DISCARD | G_EVAL, args); | ||
123 | |||
124 | perl_call_argv("Embed::Persistent::run_package", G_DISCARD | G_EVAL, args); | ||
125 | |||
126 | /* check return status */ | ||
127 | if(SvTRUE(ERRSV)){ | ||
128 | pclose_result=-2; | ||
129 | printf("embedded perl ran %s with error %s\n",fname,SvPV(ERRSV,PL_na)); | ||
130 | } | ||
131 | |||
132 | /* read back stdout from script */ | ||
133 | fp=fopen(tmpfname, "r"); | ||
134 | |||
135 | /* default return string in case nothing was returned */ | ||
136 | strcpy(plugin_output,"(No output!)"); | ||
137 | |||
138 | fgets(plugin_output,sizeof(plugin_output)-1,fp); | ||
139 | plugin_output[sizeof(plugin_output)-1]='\x0'; | ||
140 | fclose(fp); | ||
141 | unlink(tmpfname); | ||
142 | printf("embedded perl plugin output was %d,%s\n",pclose_result, plugin_output); | ||
143 | |||
144 | } | ||
145 | |||
146 | } | ||
147 | |||
148 | |||
149 | PL_perl_destruct_level = 0; | ||
150 | perl_destruct(perl); | ||
151 | perl_free(perl); | ||
152 | exit(exitstatus); | ||
153 | } | ||
diff --git a/tools/p1.pl b/tools/p1.pl new file mode 100644 index 00000000..2788dbff --- /dev/null +++ b/tools/p1.pl | |||
@@ -0,0 +1,151 @@ | |||
1 | package Embed::Persistent; | ||
2 | # | ||
3 | # Hacked version of the sample code from the perlembedded doco. | ||
4 | # | ||
5 | # Only major changes are to separate the compiling and cacheing from | ||
6 | # the execution so that the cache can be kept in "non-volatile" parent | ||
7 | # process while the execution is done from "volatile" child processes | ||
8 | # and that STDOUT is redirected to a file by means of a tied filehandle | ||
9 | # so that it can be returned to NetSaint in the same way as for | ||
10 | # commands executed via the normal popen method. | ||
11 | # | ||
12 | |||
13 | use strict; | ||
14 | use vars '%Cache'; | ||
15 | use Symbol qw(delete_package); | ||
16 | |||
17 | |||
18 | package OutputTrap; | ||
19 | # | ||
20 | # Methods for use by tied STDOUT in embedded PERL module. | ||
21 | # | ||
22 | # Simply redirects STDOUT to a temporary file associated with the | ||
23 | # current child/grandchild process. | ||
24 | # | ||
25 | |||
26 | use strict; | ||
27 | # Perl before 5.6 does not seem to have warnings.pm ??? | ||
28 | #use warnings; | ||
29 | use IO::File; | ||
30 | |||
31 | sub TIEHANDLE { | ||
32 | my ($class, $fn) = @_; | ||
33 | my $handle = new IO::File "> $fn" or die "Cannot open embedded work filei $!\n"; | ||
34 | bless { FH => $handle, Value => 0}, $class; | ||
35 | } | ||
36 | |||
37 | sub PRINT { | ||
38 | my $self = shift; | ||
39 | my $handle = $self -> {FH}; | ||
40 | print $handle join("",@_); | ||
41 | } | ||
42 | |||
43 | sub PRINTF { | ||
44 | my $self = shift; | ||
45 | my $fmt = shift; | ||
46 | my $handle = $self -> {FH}; | ||
47 | printf $handle ($fmt,@_); | ||
48 | } | ||
49 | |||
50 | sub CLOSE { | ||
51 | my $self = shift; | ||
52 | my $handle = $self -> {FH}; | ||
53 | close $handle; | ||
54 | } | ||
55 | |||
56 | package Embed::Persistent; | ||
57 | |||
58 | sub valid_package_name { | ||
59 | my($string) = @_; | ||
60 | $string =~ s/([^A-Za-z0-9\/])/sprintf("_%2x",unpack("C",$1))/eg; | ||
61 | # second pass only for words starting with a digit | ||
62 | $string =~ s|/(\d)|sprintf("/_%2x",unpack("C",$1))|eg; | ||
63 | |||
64 | # Dress it up as a real package name | ||
65 | $string =~ s|/|::|g; | ||
66 | return "Embed::" . $string; | ||
67 | } | ||
68 | |||
69 | sub eval_file { | ||
70 | my $filename = shift; | ||
71 | my $delete = shift; | ||
72 | my $pn = substr($filename, rindex($filename,"/")+1); | ||
73 | my $package = valid_package_name($pn); | ||
74 | my $mtime = -M $filename; | ||
75 | if(defined $Cache{$package}{mtime} | ||
76 | && | ||
77 | $Cache{$package}{mtime} <= $mtime) | ||
78 | { | ||
79 | # we have compiled this subroutine already, | ||
80 | # it has not been updated on disk, nothing left to do | ||
81 | #print STDERR "already compiled $package->hndlr\n"; | ||
82 | } | ||
83 | else { | ||
84 | local *FH; | ||
85 | open FH, $filename or die "open '$filename' $!"; | ||
86 | local($/) = undef; | ||
87 | my $sub = <FH>; | ||
88 | close FH; | ||
89 | # cater for routines that expect to get args without prgname | ||
90 | # and for those using @ARGV | ||
91 | $sub = "shift(\@_);\n\@ARGV=\@_;\n" . $sub; | ||
92 | |||
93 | # cater for scripts that have embedded EOF symbols (__END__) | ||
94 | $sub =~ s/__END__/\;}\n__END__/; | ||
95 | |||
96 | #wrap the code into a subroutine inside our unique package | ||
97 | my $eval = qq{ | ||
98 | package main; | ||
99 | use subs 'CORE::GLOBAL::exit'; | ||
100 | sub CORE::GLOBAL::exit { die "ExitTrap: \$_[0] ($package)"; } | ||
101 | package $package; sub hndlr { $sub; } | ||
102 | }; | ||
103 | { | ||
104 | # hide our variables within this block | ||
105 | my($filename,$mtime,$package,$sub); | ||
106 | eval $eval; | ||
107 | } | ||
108 | if ($@){ | ||
109 | print STDERR $@."\n"; | ||
110 | die; | ||
111 | } | ||
112 | |||
113 | #cache it unless we're cleaning out each time | ||
114 | $Cache{$package}{mtime} = $mtime unless $delete; | ||
115 | |||
116 | } | ||
117 | } | ||
118 | |||
119 | sub run_package { | ||
120 | my $filename = shift; | ||
121 | my $delete = shift; | ||
122 | my $tmpfname = shift; | ||
123 | my $ar = shift; | ||
124 | my $pn = substr($filename, rindex($filename,"/")+1); | ||
125 | my $package = valid_package_name($pn); | ||
126 | my $res = 0; | ||
127 | |||
128 | tie (*STDOUT, 'OutputTrap', $tmpfname); | ||
129 | |||
130 | my @a = split(/ /,$ar); | ||
131 | |||
132 | eval {$res = $package->hndlr(@a);}; | ||
133 | |||
134 | if ($@){ | ||
135 | if ($@ =~ /^ExitTrap: /) { | ||
136 | $res = 0; | ||
137 | } else { | ||
138 | # get return code (which may be negative) | ||
139 | if ($@ =~ /^ExitTrap: (-?\d+)/) { | ||
140 | $res = $1; | ||
141 | } else { | ||
142 | $res = 2; | ||
143 | print STDERR "<".$@.">\n"; | ||
144 | } | ||
145 | } | ||
146 | } | ||
147 | untie *STDOUT; | ||
148 | return $res; | ||
149 | } | ||
150 | |||
151 | 1; | ||