trunk/bin/lorry.pl

#!/usr/bin/perl

use warnings;
use strict;

use Data::Dump qw(dump);
use File::Slurp;

use lib 'lib';
use Sack::From;
use Sack::Lorry;
use Sack::Color;
use Sack;

use Getopt::Long;
use Time::HiRes qw(time);


my $view   = 'views/00.demo.pl';
my $limit  = 0;
my $cloud;


GetOptions(
        'view=s'  => \$view,
        'limit=i' => \$limit,
        'cloud=s' => \$cloud,
) or die $!;


my $lorry = Sack::Lorry->new( view => $view, cloud => $cloud );

my $from  = Sack::From->new(
        path => '/data/isi/full.txt',
        limit => $limit * $lorry->cloud_size,
);

duration 'pre-load finished';

$lorry->start_nodes;

duration 'cloud up';

$lorry->load_nodes( $from );

duration 'load finished';


our $out;
our $cmd;

do {
        print "sack> ";
        $cmd = <STDIN>;
        last unless defined $cmd; # CTRL+D
        chomp($cmd);
} while $lorry->command($cmd);

warn "exit all nodes\n";
$lorry->send_to_all( { exit => 1 } );

duration 'total usage';

1	#!/usr/bin/perl
2
3	use warnings;
4	use strict;
5
6	use Data::Dump qw(dump);
7	use File::Slurp;
8
9	use lib 'lib';
10	use Sack::From;
11	use Sack::Lorry;
12	use Sack::Color;
13	use Sack;
14
15	use Getopt::Long;
16	use Time::HiRes qw(time);
17
18
19	my $view = 'views/00.demo.pl';
20	my $limit = 0;
21	my $cloud;
22
23
24	GetOptions(
25	'view=s' => \$view,
26	'limit=i' => \$limit,
27	'cloud=s' => \$cloud,
28	) or die $!;
29
30
31	my $lorry = Sack::Lorry->new( view => $view, cloud => $cloud );
32
33	my $from = Sack::From->new(
34	path => '/data/isi/full.txt',
35	limit => $limit * $lorry->cloud_size,
36	);
37
38	duration 'pre-load finished';
39
40	$lorry->start_nodes;
41
42	duration 'cloud up';
43
44	$lorry->load_nodes( $from );
45
46	duration 'load finished';
47
48
49	our $out;
50	our $cmd;
51
52	do {
53	print "sack> ";
54	$cmd = <STDIN>;
55	last unless defined $cmd; # CTRL+D
56	chomp($cmd);
57	} while $lorry->command($cmd);
58
59	warn "exit all nodes\n";
60	$lorry->send_to_all( { exit => 1 } );
61
62	duration 'total usage';
63