view release on metacpan or  search on metacpan

t/350_aggregation.t  view on Meta::CPAN

#!/usr/bin/env perl

use t::lib::Test;
use t::lib::Slowops;

use Devel::StatProfiler::Aggregator;
use Devel::StatProfiler::NameMap;
use Time::HiRes qw(time);

my ($profile_dir, $template);
BEGIN { ($profile_dir, $template) = temp_profile_dir(); }

use Devel::StatProfiler -template => $template, -interval => 1000;

for (my $count = 1000; ; $count *= 2) {
    my $start = time;
    note("Trying with $count iterations");
    t::lib::Slowops::foo($count);
    -d '.' for 1..$count;
    last if time - $start >= 0.5;
}

Devel::StatProfiler::stop_profile();

my @files = glob "$template.*";
my $process_id;

my $r1 = Devel::StatProfiler::Report->new(
    slowops => [qw(ftdir unstack)],
);
$r1->add_trace_file($_) for @files;

my $a1 = Devel::StatProfiler::Aggregator->new(
    root_directory  => File::Spec::Functions::catdir($profile_dir, 'aggr1'),
    parts_directory => File::Spec::Functions::catdir($profile_dir, 'aggr1p'),
    shard           => 'shard1',
    slowops         => [qw(ftdir unstack)],
);
for my $file (@files) {
    my $r = Devel::StatProfiler::Reader->new($file);
    ($process_id) = @{$r->get_genealogy_info};
    for (;;) {
        my $sr = t::lib::Test::SingleReader->new($r);
        $a1->process_trace_files($sr);
        last if $sr->done;
    }
}
$a1->save_part;
my $r2 = $a1->merge_report('__main__');

for my $file (@files) {
    my $r = Devel::StatProfiler::Reader->new($file);
    for (;;) {
        my $sr = t::lib::Test::SingleReader->new($r);
        my $a = Devel::StatProfiler::Aggregator->new(
            root_directory  => File::Spec::Functions::catdir($profile_dir, 'aggr2'),
            parts_directory => File::Spec::Functions::catdir($profile_dir, 'aggr2p'),
            shard           => 'shard1',
            slowops         => [qw(ftdir unstack)],
        );
        $a->process_trace_files($sr);
        $a->save_part;
        $a->merge_report('__main__');
        last if $sr->done;
    }
}
my $a2 = Devel::StatProfiler::Aggregator->new(
    root_directory  => File::Spec::Functions::catdir($profile_dir, 'aggr2'),
    parts_directory => File::Spec::Functions::catdir($profile_dir, 'aggr2p'),
    shard           => 'shard1',
    slowops         => [qw(ftdir unstack)],
);
$a2->merge_metadata;
my $r3 = $a2->merge_report('__main__');

my $a3 = Devel::StatProfiler::Aggregate->new(
    mapper        => Devel::StatProfiler::NameMap->new(