Форум программистов [Powered by Invision Power Board]

Код

#!/usr/bin/perl
use Benchmark;
use DBI;
use Net::Ping;
use threads;

$db="ping";
$host="localhost";
$userid="user";
$passwd="pass";
$connectionInfo="dbi:mysql:$db;$host";

$dbh = DBI->connect($connectionInfo,$userid,$passwd);

for($g=0;$g<18;$g++){

    # чистим
    unlink ("LOG");
    unlink ("LOG2");

    $#hz = -1;
    $#hzz = -1;
    $#arr_ip = -1;
    $#arr_i = -1;
    $#threads = -1;

    $sec=$sec+400;
    if($i!=0){$fir=$sec-399;}else{$fir=0;}


    # запрос на выборку
    $query = "select ip as HOST from users limit $fir,$sec";
    $sth = $dbh->prepare($query);
    $sth->execute();
    $sth->bind_columns(\$HOST);


    while ($pf=$sth->fetchrow_hashref){
        $hzz.=$pf->{HOST}."|";
    }

    @hz=split(/[|]/,$hzz);


    for ($i=0; $i<=$#hz; $i++) {
        push @threads, threads->create(\&pong, $hz[$i]);
    }


foreach $thread (@threads) {
        $thread->join();
    }
    
sub pong {
    $time1 = new Benchmark;
    my $sdp = Net::Ping->new("icmp",1,1);
    if ($sdp->ping($hz[$i])){
        open(F1,">> LOG");
        print (F1 "$hz[$i]\n");
        close (F1);
        
        open(F2,">> LOG2");
        print (F2 "1\n");
        close (F2);
    }else{
        open (F1,">> LOG");
        print (F1 "$hz[$i]\n");
        close (F1);

        open (F2,">> LOG2");
        print (F2 "0\n");
        close (F2);
    }
    open(FILE, "<", "LOG");
    while(<FILE>) {
        chomp;
        push(@arr_ip, $_);
        #print "array element: $_\n";
    }
    close(FILE);
    open(FILE2, "<", "LOG2");
    while(<FILE2>) {
        chomp;
        push(@arr_i, $_);
        #print "array element: $_\n";
    }
    close(FILE2);
    
    for($t=0; $t<=$#arr_ip; $t++){
        #print "update users set ping=$arr_i[$t] where ip=$arr_ip[$t]\n";
        open (FF1,">> LOG2ALL");
        print (FF1 "$t -- update users set ping=$arr_i[$t] where ip=$arr_ip[$t]\n");
        close (FF1);
    }
    
    $time2 = new Benchmark;
    $timebenchmark = timediff($time1, $time2);
    print "Time", timestr($timebenchmark);
    
}
   }               
;