#!/usr/bin/perl #**************************************************************************** #* #* Copyright (C) 2008 NetUP Inc. All rights reserved. #* #* This file is part of the netup iptvprobe project #* #* This file may be used under the terms of the GNU General Public #* License versions 2.0 or 3.0 as published by the Free Software #* Foundation and appearing in the files LICENSE.GPL2 and LICENSE.GPL3 #* included in the packaging of this file. Alternatively you may (at #* your option) use any later version of the GNU General Public #* License if such license has been publicly approved by NetUP Inc. #* (or its successors, if any). #* #* This file is provided "AS IS" with NO WARRANTY OF ANY KIND, #* INCLUDING THE WARRANTIES OF DESIGN, MERCHANTABILITY AND FITNESS FOR #* A PARTICULAR PURPOSE. NetUP Inc. reserves all rights not expressly #* granted herein. #* #* This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE #* WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. #* #***************************************************************************/ # IP id <49769> time <1215331823116174606> len <1344> # use POSIX qw(ceil floor); use CGI ':standard'; use GD::Graph::lines; use DBI; use CGI; use Socket; $query = new CGI; print "Content-type: text/html\n\n"; print "\n"; print "NetUP IPTVProbe runs\n"; $host = "localhost"; $database = "iptvprobe"; $user = "iptvprobe"; $pw = "tv1000"; $connectionInfo="dbi:mysql:$database;$host"; $dbh = DBI->connect($connectionInfo,$user,$pw); $action = $query->param('action'); if($action eq "add_run"){ my $zond_host = $query->param('zond_host'); my $collector_host = $query->param('collector_host'); my $monitoring_host = $query->param('monitoring_host'); my $description = $query->param('description'); #parse ip ( monitoring_host ) my @ips = split(',', $monitoring_host); foreach my $val (@ips) { $val =~ s/^\s+//; $val =~ s/\s+$//; print "ip=$val\n"; } $dbh->do('INSERT INTO runs (start_timestamp, collector_host, zond_host, monitoring_host, description) VALUES(unix_timestamp(NOW()),?,?,?,?)', undef, $collector_host, $zond_host, $monitoring_host, $description); print ""; exit (0); }elsif($action eq "delete"){ my $run_id4delete = $query->param('run_id4delete'); $dbh->do("DELETE FROM runs WHERE id=$run_id4delete"); print ""; exit (0); }elsif($action eq "clear"){ my $run_id4clear = $query->param('run_id4clear'); $dbh->do("DELETE FROM data_ip WHERE run_id=$run_id4clear"); $dbh->do("DELETE FROM data_ts WHERE run_id=$run_id4clear"); $dbh->do("DELETE FROM stat_bandwidth WHERE run_id=$run_id4clear"); print ""; exit (0); }; %pkts_count = (); %ldate = (); # obtain statistics $sth = $dbh->prepare("select run_id, SUM(ip_pkts_count) as pkts_count, from_unixtime(MIN(create_date)), from_unixtime(MAX(create_date)) as last_date from stat_bandwidth GROUP BY run_id"); $sth->execute(); while (my $ref = $sth->fetchrow_hashref()) { my $run_id = $ref->{'run_id'}; my $last_date = $ref->{'last_date'}; my $pkts_count = $ref->{'pkts_count'}; $pkts_count{$run_id} = $pkts_count; $ldate{$run_id} = $last_date; }; $sth = $dbh->prepare("select id, FROM_UNIXTIME(start_timestamp) as start_timestamp, collector_host, zond_host, monitoring_host, description FROM runs"); $sth->execute(); print "\n"; print ""; while (my $ref = $sth->fetchrow_hashref()) { my $run_id = $ref->{'id'}; my $start_timestamp = $ref->{'start_timestamp'}; my $zond_host = $ref->{'zond_host'}; my $collector_host = $ref->{'collector_host'}; my $monitoring_host = $ref->{'monitoring_host'}; my $description = $ref->{'description'}; print ""; print "\n"; }; print "
run_idstart_timestampzond_hostmonitoring_hostdescriptionCommand to run on probe operationslast stat datepkts count
$run_id$start_timestamp$zond_host$monitoring_host$descriptioniptvprobe "; my @ips = split(',', $monitoring_host); foreach my $val (@ips) { $val =~ s/^\s+//; $val =~ s/\s+$//; print "-i $val "; }; print "-s $collector_host -r $run_id -p 7700"; #parse ip ( monitoring_host ) my @ips = split(',', $monitoring_host); foreach my $val (@ips) { $val =~ s/^\s+//; $val =~ s/\s+$//; my $bip = unpack('N',inet_aton($val)); print"IP=$val:
"; print"UDP timeline graphic
"; print"PCR Arrival Interval
"; print"
"; } print" IGMP packets
\ IGMP timings
\
Clear data
\ Delete
\ 		$ldate{$run_id}$pkts_count{$run_id}


\n"; # new run form print "
"; print ""; print ""; print ""; print ""; print ""; print ""; print ""; print "
Add iptvprobe run
Zond host (Example: 10.0.0.1)
Collector host (Example: 10.1.4.242 )
Multicast IP for monitoring (Example: 224.10.10.10, 224.117.117.10, 224.117.117.11)
Description
"; print "

"; print ""; $dbh->disconnect();