ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/host/ihost-perl/ihost.pl
(Generate patch)

Comparing projects/cms/source/host/ihost-perl/ihost.pl (file contents):
Revision 1.41 by tdb, Tue Nov 20 12:47:03 2001 UTC vs.
Revision 1.47 by tdb, Thu Mar 21 17:57:13 2002 UTC

# Line 33 | Line 33 | use vars qw (
33               $fqdn
34               $pidfile
35               $retry_wait
36 +             $ostype
37 +             $key
38               @data
39              );
40  
# Line 46 | Line 48 | $filter_manager_port = $ARGV[1];
48   $seq_no = 1;
49   $retry_wait = 60;
50  
51 + # work out our platform, if we can.
52 + $ostype = `uname -s`;
53 + chomp $ostype;
54 + $ostype = "unknown" if not defined $ostype;
55 +
56   # write our PID to a file
57   # use home dir by default
58 < $pidfile = $ENV{"HOME"};
58 > #$pidfile = $ENV{"HOME"};
59   # or drop it in /var/tmp if we can't find HOME
60   $pidfile = "/var/tmp" if not defined $pidfile;
61   $pidfile .= "/.ihost.pid";
62   &write_pid();
63  
64   &tcp_configure();
65 + &send_tcp_heartbeat();
66   &send_udp_packet();
67  
68   $last_udp_time = time;
# Line 266 | Line 274 | sub send_udp_packet() {
274      opendir PLUGINS, $plugins_dir;
275      my(@plugins) = readdir PLUGINS;
276      foreach my $plugin (@plugins) {
277 <        push @data, `$plugins_dir/$plugin` if -x "$plugins_dir/$plugin" && -f "$plugins_dir/$plugin";
277 >        push @data, `$plugins_dir/$plugin $ostype` if -x "$plugins_dir/$plugin" && -f "$plugins_dir/$plugin";
278      }
279      
280      # get some extra data
# Line 275 | Line 283 | sub send_udp_packet() {
283      $ip = inet_ntoa(scalar(gethostbyname(hostname())) || 'localhost') or $ip = 'localhost';
284      
285      # add some extra data to the array
286 <    push(@data, "packet.attributes.seq_no=$seq_no");
287 <    push(@data, "packet.attributes.machine_name=$fqdn");
288 <    push(@data, "packet.attributes.date=$date");
289 <    push(@data, "packet.attributes.type=data");
290 <    push(@data, "packet.attributes.ip=$ip");
286 >    push(@data, "packet.attributes.seq_no $seq_no");
287 >    push(@data, "packet.attributes.machine_name $fqdn");
288 >    push(@data, "packet.attributes.date $date");
289 >    push(@data, "packet.attributes.type data");
290 >    push(@data, "packet.attributes.ip $ip");
291 >    push(@data, "packet.attributes.key $key");
292      
293      # sort the data
294 <    @data = sort(@data);
295 <    
294 >    @data = sort(grep(!/^$/, grep(/^packet\./, @data)));
295 >
296      # turn the array into some nice XML
297      my($xml) = &make_xml("", "");
298 <    
298 >
299      my($sock) = new IO::Socket::INET (
300                                        PeerPort => $udp_port,
301                                        PeerAddr => $filter_addr,
# Line 368 | Line 377 | sub send_tcp_heartbeat() {
377          return;
378      }
379      
380 +    print $sock "KEY\n";
381 +    $key = <$sock>;
382 +    
383      print $sock "ENDHEARTBEAT\n";
384      $response = <$sock>;
385      if (!$response eq "OK\n") {
# Line 407 | Line 419 | sub make_xml() {
419      my($curlevel, $curline) = @_;
420      my($xmltemp) = ""; my($curtag) = ""; my($attributes) = "";
421      while(1) {
422 <        $curline = shift(@data) if $curline eq ""; chomp $curline;
422 >        $curline = shift(@data) if $curline eq "";
423 >        return $xmltemp if not defined $curline;
424 >        chomp $curline;
425 >        # dealing with nest (or attributes)
426          if($curline =~ /^$curlevel([^\.\s]+\.)/) {
427              $curtag=$1;
428 +            if($curline =~ /^$curlevel$curtag([^\.\s]+)\s+(.*)$/) {
429 +                $xmltemp .= &make_xml("$curlevel$curtag", $curline);
430 +            }
431 +            elsif($curline =~ /^$curlevel$curtag(attributes)\.([^\.\s]+)\s+(.*)$/) {
432 +                $attributes .= " $2=\"$3\"";
433 +            }
434 +            else {
435 +                $xmltemp .= &make_xml("$curlevel$curtag", $curline);
436 +            }
437 +            my($nextline) = $data[0]; chomp $nextline if defined $nextline;
438 +            $curtag =~ s/(.*)\./$1/;
439 +            if((defined $nextline) && ($nextline =~ /^$curlevel$curtag\./)) {
440 +                $curline = "";
441 +            }
442 +            else {
443 +                $xmltemp = "<$curtag$attributes>$xmltemp</$curtag>" unless $curtag eq "";
444 +                return $xmltemp;
445 +            }
446          }
447 <        if($curline =~ /^$curlevel$curtag([^\.\s]+)\s+(.*)$/) {
448 <            $xmltemp .= "<$1$attributes>$2</$1>";
447 >        # dealing with value
448 >        elsif($curline =~ /^$curlevel([^\.\s]+)\s+(.*)$/) {
449 >            $curtag=$1;
450 >            $xmltemp=$2;          
451 >            my($nextline) = $data[0]; chomp $nextline if defined $nextline;
452 >            if(defined $nextline && ($nextline =~ /^$curlevel$curtag\./ || $nextline =~ /^$curlevel$curtag\s+/)) {
453 >                $curline = "";
454 >            }
455 >            else {
456 >                $xmltemp = "<$curtag$attributes>$xmltemp</$curtag>" unless $curtag eq "";
457 >                return $xmltemp;
458 >            }
459          }
460 <        elsif($curline =~ /^$curlevel$curtag(attributes)\.([^\.=]+)=(.*)$/) {
461 <            $attributes .= " $2=\"$3\"";
462 <        }
463 <        else {
464 <            $xmltemp .= &make_xml("$curlevel$curtag", $curline);
465 <        }
466 <        my($nextline) = $data[0]; chomp $nextline if defined $nextline;
467 <        $curtag =~ s/(.*)\./$1/;                
468 <        if((defined $nextline) && ($nextline =~ /^$curlevel$curtag\./)) {
469 <            $curline = "";
427 <        }
428 <        else {
429 <            $xmltemp = "<$curtag$attributes>$xmltemp</$curtag>" unless $curtag eq "";
430 <            return $xmltemp;
431 <        }
460 >        # dealing with a null value
461 >        elsif($curline =~ /^$curlevel([^\.\s]+)$/) {
462 >            # simply adding a space makes the above elsif deal with it :)
463 >            # just level with an empty tag in the XML
464 >            $curline .= " ";
465 >        }
466 >        # failing all that, skip the line
467 >        else {
468 >            $curline = "";
469 >        }
470      }
471   }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines