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