-# Copyright (c) 2006 Zmanda Inc. All Rights Reserved.
+# Copyright (c) 2007, 2008, 2009, 2010 Zmanda, Inc. All Rights Reserved.
#
# This program is free software; you can redistribute it and/or modify it
# under the terms of the GNU General Public License version 2 as published
# with this program; if not, write to the Free Software Foundation, Inc.,
# 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
#
-# Contact information: Zmanda Inc, 505 N Mathlida Ave, Suite 120
-# Sunnyvale, CA 94085, USA, or: http://www.zmanda.com
+# Contact information: Zmanda Inc, 465 S. Mathilda Ave., Suite 300
+# Sunnyvale, CA 94086, USA, or: http://www.zmanda.com
-use Test::More qw(no_plan);
-use Amconfig;
+use Test::More tests => 47;
use File::Path;
+use Data::Dumper;
use strict;
+use warnings;
use lib "@amperldir@";
+use Installcheck::Config;
use Amanda::Paths;
use Amanda::Device;
use Amanda::Debug;
+use Amanda::MainLoop;
use Amanda::Config qw( :init :getconf config_dir_relative );
use Amanda::Changer;
# set up debugging so debug output doesn't interfere with test results
Amanda::Debug::dbopen("installcheck");
+Installcheck::log_test_output();
+
+# and disable Debug's die() and warn() overrides
+Amanda::Debug::disable_die_override();
+
+# --------
+# define a "test" changer for purposes of this installcheck
+
+package Amanda::Changer::test;
+use vars qw( @ISA );
+@ISA = qw( Amanda::Changer );
+
+# monkey-patch our test changer into Amanda::Changer, and indicate that
+# the module has already been required by adding a key to %INC
+$INC{'Amanda/Changer/test.pm'} = "Amanda_Changer";
+
+sub new {
+ my $class = shift;
+ my ($config, $tpchanger) = @_;
+
+ my $self = {
+ config => $config,
+ curslot => 0,
+ slots => [ 'TAPE-00', 'TAPE-01', 'TAPE-02', 'TAPE-03' ],
+ reserved_slots => [],
+ clean => 0,
+ };
+ bless ($self, $class);
+ return $self;
+}
+
+sub load {
+ my $self = shift;
+ my %params = @_;
+
+ my $cb = $params{'res_cb'};
+
+ if (exists $params{'label'}) {
+ # search by label
+ my $slot = -1;
+ my $label = $params{'label'};
+
+ for my $i (0 .. $#{$self->{'slots'}}) {
+ if ($self->{'slots'}->[$i] eq $label) {
+ $slot = $i;
+ last;
+ }
+ }
+ if ($slot == -1) {
+ $cb->("No such label '$label'", undef);
+ return;
+ }
+
+ # check that it's not in use
+ for my $used_slot (@{$self->{'reserved_slots'}}) {
+ if ($used_slot == $slot) {
+ $cb->("Volume with label '$label' is already in use", undef);
+ return;
+ }
+ }
+
+ # ok, let's use it.
+ push @{$self->{'reserved_slots'}}, $slot;
+
+ if (exists $params{'set_current'} && $params{'set_current'}) {
+ $self->{'curslot'} = $slot;
+ }
+
+ $cb->(undef, Amanda::Changer::test::Reservation->new($self, $slot, $label));
+ } elsif (exists $params{'slot'} or exists $params{'relative_slot'}) {
+ my $slot = $params{'slot'};
+ if (exists $params{'relative_slot'}) {
+ if ($params{'relative_slot'} eq "current") {
+ $slot = $self->{'curslot'};
+ } elsif ($params{'relative_slot'} eq "next") {
+ $slot = ($self->{'curslot'} + 1) % (scalar @{$self->{'slots'}});
+ } else {
+ die "invalid relative_slot";
+ }
+ }
+
+ if (grep { $_ == $slot } @{$self->{'reserved_slots'}}) {
+ $cb->("Slot $slot is already in use", undef);
+ return;
+ }
+ my $label = $self->{'slots'}->[$slot];
+ push @{$self->{'reserved_slots'}}, $slot;
+
+ if (exists $params{'set_current'} && $params{'set_current'}) {
+ $self->{'curslot'} = $slot;
+ }
+
+ $cb->(undef, Amanda::Changer::test::Reservation->new($self, $slot, $label));
+ } else {
+ die "No label or slot parameter given";
+ }
+}
+
+sub info_key {
+ my $self = shift;
+ my ($key, %params) = @_;
+ my %results;
+
+ if ($key eq 'num_slots') {
+ $results{$key} = 13;
+ } elsif ($key eq 'mkerror1') {
+ return $self->make_error("failed", $params{'info_cb'},
+ reason => "unknown",
+ message => "err1");
+ } elsif ($key eq 'mkerror2') {
+ return $self->make_error("failed", $params{'info_cb'},
+ reason => "unknown",
+ message => "err2");
+ }
+
+ $params{'info_cb'}->(undef, %results) if $params{'info_cb'};
+}
+
+sub reset {
+ my $self = shift;
+ my %params = @_;
+
+ $self->{'curslot'} = 0;
+
+ $params{'finished_cb'}->(undef) if $params{'finished_cb'};
+}
+
+sub clean {
+ my $self = shift;
+ my %params = @_;
+
+ $self->{'clean'} = 1;
+
+ $params{'finished_cb'}->(undef) if $params{'finished_cb'};
+}
+
+sub inventory {
+ my $self = shift;
+ my %params = @_;
+
+ Amanda::MainLoop::call_later($params{'inventory_cb'},
+ undef, [ {
+ slot => 1,
+ empty => 0,
+ label => 'TAPE-99',
+ barcode => '09385A',
+ reserved => 0,
+ import_export => 0,
+ loaded_in => undef,
+ }]);
+}
+
+package Amanda::Changer::test::Reservation;
+use vars qw( @ISA );
+@ISA = qw( Amanda::Changer::Reservation );
+
+sub new {
+ my $class = shift;
+ my ($chg, $slot, $label) = @_;
+ my $self = Amanda::Changer::Reservation::new($class);
+
+ $self->{'chg'} = $chg;
+ $self->{'slot'} = $slot;
+ $self->{'label'} = $label;
+
+ $self->{'device'} = Amanda::Device->new("null:slot-$slot");
+ $self->{'this_slot'} = $slot;
-my $changer_filename = "$AMANDA_TMPDIR/chg-test";
+ return $self;
+}
+
+sub do_release {
+ my $self = shift;
+ my %params = @_;
+ my $slot = $self->{'slot'};
+ my $chg = $self->{'chg'};
+
+ $chg->{'reserved_slots'} = [ grep { $_ != $slot } @{$chg->{'reserved_slots'}} ];
-sub setup_changer {
- my ($changer_script) = @_;
+ $params{'finished_cb'}->(undef) if $params{'finished_cb'};
+}
- open my $chg_test, ">", $changer_filename or die("Could not create test changer");
-
- $changer_script =~ s/\$AMANDA_TMPDIR/$AMANDA_TMPDIR/g;
+sub set_label {
+ my $self = shift;
+ my %params = @_;
+ my $slot = $self->{'slot'};
+ my $chg = $self->{'chg'};
- print $chg_test "#! /bin/sh\n";
- print $chg_test $changer_script;
+ $self->{'chg'}->{'slots'}->[$self->{'slot'}] = $params{'label'};
+ $self->{'label'} = $params{'label'};
- close $chg_test;
- chmod 0755, $changer_filename;
+ $params{'finished_cb'}->(undef) if $params{'finished_cb'};
}
-# set up and load a simple config with a tpchanger
-my $testconf = Amconfig->new();
-$testconf->add_param('tpchanger', "\"$changer_filename\"");
+# --------
+# back to the perl tests..
+
+package main;
+
+# work against a config specifying our test changer, to work out the kinks
+# when it opens devices to check their labels
+my $testconf;
+$testconf = Installcheck::Config->new();
+$testconf->add_changer("mychanger", [
+ 'tpchanger' => '"chg-test:/foo"',
+ 'property' => '"testprop" "testval"',
+]);
$testconf->write();
-config_init($CONFIG_INIT_EXPLICIT_NAME, 'TESTCONF') or die("Could not load test config");
-
-# some variables we'll need
-my ($error, $slot, $device);
-
-# OK, let's get started with some simple stuff
-setup_changer <<'EOC';
-case "${1}" in
- -slot)
- case "${2}" in
- 1) echo "1 fake:1"; exit 0;;
- 2) echo "<ignored> slot 2 is empty"; exit 1;;
- 3) echo "<error> oh noes!"; exit 2;;
- 4) echo "1"; exit 0;; # test missing 'device' portion
- esac;;
- -reset) echo "reset ignored";;
- -eject) echo "eject ignored";;
- -clean) echo "clean ignored";;
- -label)
- case "${2}" in
- foo?bar) echo "1 ok"; exit 0;;
- *) echo "<error> bad label"; exit 1;;
- esac;;
- -info) echo "7 10 1 1"; exit 0;;
- -search)
- case "${2}" in
- TAPE?01) echo "5 fakedev"; exit 0;;
- *) echo "<error> not found"; exit 2;;
- esac;;
-esac
-EOC
-
-is_deeply([ Amanda::Changer::loadslot(1) ], [0, "1", "fake:1"],
- "A successful loadslot() returns the right stuff");
-
-($error, $slot, $device) = Amanda::Changer::loadslot(2);
-is($error, "slot 2 is empty", "A loadslot() with a benign error returns the right stuff");
-
-eval { Amanda::Changer::loadslot(3); };
-like($@, qr/.*oh noes!.*/, "A loadslot() with a serious error croaks");
-
-is_deeply([ Amanda::Changer::loadslot(4) ], [0, "1", undef],
- "a response without a device string returns undef");
-
-is_deeply([ Amanda::Changer::reset() ], [ 0, "reset" ],
- "reset() calls tapechanger -reset");
-is_deeply([ Amanda::Changer::eject() ], [ 0, "eject" ],
- "eject() calls tapechanger -eject");
-is_deeply([ Amanda::Changer::clean() ], [ 0, "clean" ],
- "clean() calls tapechanger -clean");
-
-is_deeply([ Amanda::Changer::label("foo bar") ], [ 0 ],
- "label('foo bar') calls tapechanger -label 'foo bar' (note spaces)");
-
-is_deeply([ Amanda::Changer::query() ], [ 0, 7, 10, 1, 1 ],
- "query() returns the correct values for a 4-value changer script");
-
-is_deeply([ Amanda::Changer::find("TAPE 01") ], [ 0, "5", "fakedev" ],
- "find on a searchable changer invokes -search");
-
-eval { Amanda::Changer::find("TAPE 02") };
-ok($@, "A searchable changer croaks when the label can't be found");
-
-# Now a simple changer that returns three values for -info
-setup_changer <<'EOC';
-case "${1}" in
- -info) echo "11 13 0"; exit 0;;
-esac
-EOC
-
-is_deeply([ Amanda::Changer::query() ], [ 0, 11, 13, 0, 0 ],
- "query() returns the correct values for a 4-value changer script");
-
-# set up 5 vtapes
-for (my $i = 0; $i < 5; $i++) {
- my $vtapedir = "$AMANDA_TMPDIR/chg-test-tapes/$i/data";
- if (-e $vtapedir) {
- rmtree($vtapedir)
- or die("Could not remove '$vtapedir'");
+
+my $cfg_result = config_init($CONFIG_INIT_EXPLICIT_NAME, 'TESTCONF');
+if ($cfg_result != $CFGERR_OK) {
+ my ($level, @errors) = Amanda::Config::config_errors();
+ die(join "\n", @errors);
+}
+
+# check out the relevant changer properties
+my $chg = Amanda::Changer->new("mychanger");
+is($chg->{'config'}->get_property("testprop"), "testval",
+ "changer properties are correctly represented");
+
+# test loading by label
+{
+ my @labels;
+ my @reservations;
+ my ($getres, $rq_reserved, $relres);
+
+ $getres = make_cb('getres' => sub {
+ if (!@labels) {
+ return $rq_reserved->();
+ }
+
+ my $label = pop @labels;
+
+ $chg->load(label => $label,
+ set_current => ($label eq "TAPE-02"),
+ res_cb => sub {
+ my ($err, $res) = @_;
+ ok(!$err, "no error loading $label")
+ or diag($err);
+
+ # keep this reservation
+ push @reservations, $res if $res;
+
+ # and start on the next
+ $getres->();
+ });
+ });
+
+ $rq_reserved = make_cb(rq_reserved => sub {
+ # try to load an already-reserved volume
+ $chg->load(label => 'TAPE-00',
+ res_cb => sub {
+ my ($err, $res) = @_;
+ ok($err, "error when requesting already-reserved volume");
+ push @reservations, $res if $res;
+
+ $relres->();
+ });
+ });
+
+ $relres = make_cb('relres' => sub {
+ if (!@reservations) {
+ return Amanda::MainLoop::quit();
+ }
+
+ my $res = pop @reservations;
+ $res->release(finished_cb => sub {
+ my ($err) = @_;
+ die $err if $err;
+
+ $relres->();
+ });
+ });
+
+ # start the loop
+ @labels = ( 'TAPE-02', 'TAPE-00', 'TAPE-03' );
+ $getres->();
+ Amanda::MainLoop::run();
+
+ $relres->();
+ Amanda::MainLoop::run();
+
+ @labels = ( 'TAPE-00', 'TAPE-01' );
+ $getres->();
+ Amanda::MainLoop::run();
+
+ # explicitly release the reservations (without using the callback)
+ for my $res (@reservations) {
+ $res->release();
+ }
+}
+
+# test loading by slot
+{
+ my ($start, $first_cb, $released, $second_cb, $quit);
+ my $slot;
+
+ # reserves the current slot
+ $start = make_cb('start' => sub {
+ $chg->load(res_cb => $first_cb, relative_slot => "current");
+ });
+
+ # gets a reservation for the "current" slot
+ $first_cb = make_cb('first_cb' => sub {
+ my ($err, $res) = @_;
+ die $err if $err;
+
+ is($res->{'this_slot'}, 2,
+ "'current' slot loads slot 2");
+ is($res->{'device'}->device_name, "null:slot-2",
+ "..device is correct");
+
+ $slot = $res->{'this_slot'};
+ $res->release(finished_cb => $released);
+ });
+
+ $released = make_cb(released => sub {
+ my ($err) = @_;
+
+ $chg->load(res_cb => $second_cb, relative_slot => 'next',
+ slot => $slot, set_current => 1);
+ });
+
+ # gets a reservation for the "next" slot
+ $second_cb = make_cb('second_cb' => sub {
+ my ($err, $res) = @_;
+ die $err if $err;
+
+ is($res->{'this_slot'}, 3,
+ "next slot loads slot 3");
+ is($chg->{'curslot'}, 3,
+ "..which is also now the current slot");
+
+ $res->release(finished_cb => $quit);
+ });
+
+ $quit = make_cb(quit => sub {
+ my ($err) = @_;
+ die $err if $err;
+
+ Amanda::MainLoop::quit();
+ });
+
+ $start->();
+ Amanda::MainLoop::run();
+}
+
+# test set_label
+{
+ my ($start, $load1_cb, $set_cb, $released, $load2_cb, $released2, $load3_cb);
+ my $res;
+
+ # load TAPE-00
+ $start = make_cb('start' => sub {
+ $chg->load(res_cb => $load1_cb, label => "TAPE-00");
+ });
+
+ # rename it to TAPE-99
+ $load1_cb = make_cb('load1_cb' => sub {
+ (my $err, $res) = @_;
+ die $err if $err;
+
+ pass("loaded TAPE-00");
+ $res->set_label(label => "TAPE-99", finished_cb => $set_cb);
+ });
+
+ $set_cb = make_cb('set_cb' => sub {
+ my ($err) = @_;
+
+ $res->release(finished_cb => $released);
+ });
+
+ # try to load TAPE-00
+ $released = make_cb('released' => sub {
+ my ($err) = @_;
+ die $err if $err;
+
+ pass("relabeled TAPE-00 to TAPE-99");
+ $chg->load(res_cb => $load2_cb, label => "TAPE-00");
+ });
+
+ # try to load TAPE-99
+ $load2_cb = make_cb('load2_cb' => sub {
+ (my $err, $res) = @_;
+ ok($err, "loading TAPE-00 is now an error");
+
+ $chg->load(res_cb => $load3_cb, label => "TAPE-99");
+ });
+
+ # check result
+ $load3_cb = make_cb('load3_cb' => sub {
+ (my $err, $res) = @_;
+ die $err if $err;
+
+ pass("but loading TAPE-99 is ok");
+
+ $res->release(finished_cb => $released2);
+ });
+
+ $released2 = make_cb(released2 => sub {
+ my ($err) = @_;
+ die $err if $err;
+
+ Amanda::MainLoop::quit();
+ });
+
+ $start->();
+ Amanda::MainLoop::run();
+}
+
+# test reset and clean and inventory
+sub test_simple {
+ my ($finished_cb) = @_;
+
+ my $steps = define_steps
+ cb_ref => \$finished_cb;
+
+ step do_reset => sub {
+ $chg->reset(finished_cb => sub {
+ is($chg->{'curslot'}, 0,
+ "reset() resets to slot 0");
+ $steps->{'do_clean'}->();
+ });
+ };
+
+ step do_clean => sub {
+ $chg->clean(finished_cb => sub {
+ ok($chg->{'clean'}, "clean 'cleaned' the changer");
+ $steps->{'do_inventory'}->();
+ });
+ };
+
+ step do_inventory => sub {
+ $chg->inventory(inventory_cb => sub {
+ is_deeply($_[1], [ {
+ slot => 1,
+ empty => 0,
+ label => 'TAPE-99',
+ barcode => '09385A',
+ reserved => 0,
+ import_export => 0,
+ loaded_in => undef,
+ }], "inventory returns an inventory");
+ $finished_cb->();
+ });
+ };
+}
+test_simple(\&Amanda::MainLoop::quit);
+Amanda::MainLoop::run();
+
+# test info
+{
+ my ($do_info, $check_info, $do_info_err, $check_info_err);
+
+ $do_info = make_cb('do_info' => sub {
+ $chg->info(info_cb => $check_info,
+ info => [ 'num_slots' ]);
+ });
+
+ $check_info = make_cb('check_info' => sub {
+ my ($err, %results) = @_;
+ die($err) if $err;
+ is_deeply(\%results, { 'num_slots' => 13 },
+ "info() works");
+ $do_info_err->();
+ });
+
+ $do_info_err = make_cb('do_info_err' => sub {
+ $chg->info(info_cb => $check_info_err,
+ info => [ 'mkerror1', 'mkerror2' ]);
+ });
+
+ $check_info_err = make_cb('check_info_err' => sub {
+ my ($err, %results) = @_;
+ is($err,
+ "While getting info key 'mkerror1': err1; While getting info key 'mkerror2': err2",
+ "info errors are handled correctly");
+ is($err->{'type'}, 'failed', "error has type 'failed'");
+ ok($err->failed, "\$err->failed is true");
+ ok(!$err->fatal, "\$err->fatal is false");
+ is($err->{'reason'}, 'unknown', "\$err->{'reason'} is 'unknown'");
+ ok($err->unknown, "\$err->unknown is true");
+ ok(!$err->notimpl, "\$err->notimpl is false");
+ Amanda::MainLoop::quit();
+ });
+
+ $do_info->();
+ Amanda::MainLoop::run();
+}
+
+# Test the various permutations of configuration setup, with a patched
+# _new_from_uri so we can monitor the result
+sub my_new_from_uri {
+ my ($uri, $cc, $name) = @_;
+ return $uri if (ref $uri and $uri->isa("Amanda::Changer::Error"));
+ return [ $uri, $cc? "cc" : undef ];
+}
+*saved_new_from_uri = *Amanda::Changer::_new_from_uri;
+*Amanda::Changer::_new_from_uri = *my_new_from_uri;
+
+sub loadconfig {
+ my ($global_tapedev, $global_tpchanger, $defn_tpchanger, $custom_defn) = @_;
+
+ $testconf = Installcheck::Config->new();
+
+ if (defined($global_tapedev)) {
+ $testconf->add_param('tapedev', "\"$global_tapedev\"")
+ }
+
+ if (defined($global_tpchanger)) {
+ $testconf->add_param('tpchanger', "\"$global_tpchanger\"")
+ }
+
+ if (defined($defn_tpchanger)) {
+ $testconf->add_changer("mychanger", [
+ 'tpchanger' => "\"$defn_tpchanger\"",
+ ]);
+ }
+
+ if (defined($custom_defn)) {
+ $testconf->add_changer("customchanger", $custom_defn);
+ $testconf->add_param('tpchanger', '"customchanger"');
+ }
+
+ $testconf->write();
+
+ my $cfg_result = config_init($CONFIG_INIT_EXPLICIT_NAME, 'TESTCONF');
+ if ($cfg_result != $CFGERR_OK) {
+ my ($level, @errors) = Amanda::Config::config_errors();
+ die(join "\n", @errors);
}
- mkpath($vtapedir)
- or die("Could not create '$vtapedir'");
-}
-
-# label three of them (slot 2 is empty; slot 4 is unlabeled)
-for (my $i = 0; $i < 5; $i++) {
- next if $i == 2 || $i == 4;
- my $dev = Amanda::Device->new("file:$AMANDA_TMPDIR/chg-test-tapes/$i")
- or die("Could not open device");
- $dev->start($Amanda::Device::ACCESS_WRITE, "TAPE$i", "19780615010203")
- or die("Could not write label");
- $dev->finish();
-}
-
-# And finally a "stateful" changer that can support "scan" and "find"
-setup_changer <<'EOC';
-STATEFILE="$AMANDA_TMPDIR/chg-test-state"
-SLOT=0
-[ -f "$STATEFILE" ] && . "$STATEFILE"
-
-case "${1}" in
- -slot)
- case "${2}" in
- current) ;;
- 0|1|2|3|4|5) SLOT="${2}";;
- next|advance) SLOT=`expr $SLOT + 1`;;
- prev) SLOT=`expr $SLOT - 1`;;
- first) SLOT=0;;
- last) SLOT=4;;
- esac
-
- # normalize 0 <= $SLOT < 5
- while [ "$SLOT" -ge 5 ]; do SLOT=`expr $SLOT - 5`; done
- while [ "$SLOT" -lt 0 ]; do SLOT=`expr $SLOT + 5`; done
-
- # signal an empty slot for slot 2
- if [ "$SLOT" = 2 ]; then
- echo "$SLOT slot $SLOT is empty"
- EXIT=1
- else
- echo "$SLOT" "file:$AMANDA_TMPDIR/chg-test-tapes/$SLOT"
- fi
- ;;
- -info) echo "$SLOT 5 1 0";;
-esac
-
-echo SLOT=$SLOT > $STATEFILE
-exit $EXIT
-EOC
-
-($error, $slot, $device) = Amanda::Changer::loadslot(0);
-if ($error) { die("Error loading slot 0: $error"); }
-is_deeply([ Amanda::Changer::find("TAPE3") ], [0, "3", "file:$AMANDA_TMPDIR/chg-test-tapes/3"],
- "Finds a tape after skipping an empty slot");
-
-($error, $slot, $device) = Amanda::Changer::loadslot(3);
-if ($error) { die("Error loading slot 3: $error"); }
-is_deeply([ Amanda::Changer::find("TAPE1") ], [0, "1", "file:$AMANDA_TMPDIR/chg-test-tapes/1"],
- "Finds a tape after skipping an unlabeled but filled slot");
-
-my @scanresults;
-sub cb {
- fail("called too many times") if (!@scanresults);
- my $expected = shift @scanresults;
- my $descr = pop @$expected;
- my $done = pop @$expected;
- is_deeply([ @_ ], $expected, $descr);
- return 1;
-}
-
-# scan the whole changer
-($error, $slot, $device) = Amanda::Changer::loadslot(0);
-if ($error) { die("Error loading slot 0: $error"); }
-@scanresults = (
- [ "0", "file:$AMANDA_TMPDIR/chg-test-tapes/0", 0, 0, "scan starts with slot 0" ],
- [ "1", "file:$AMANDA_TMPDIR/chg-test-tapes/1", 0, 0, "next in slot 1" ],
- [ undef, undef, "slot 2 is empty", 0, "slot 2 is empty" ],
- [ "3", "file:$AMANDA_TMPDIR/chg-test-tapes/3", 0, 0, "next in slot 3" ],
- [ "4", "file:$AMANDA_TMPDIR/chg-test-tapes/4", 0, 0, "next in slot 4" ],
-);
-Amanda::Changer::scan(\&cb);
-
-# make sure it stops when "done"
-($error, $slot, $device) = Amanda::Changer::loadslot(0);
-if ($error) { die("Error loading slot 0: $error"); }
-@scanresults = (
- [ "0", "file:$AMANDA_TMPDIR/chg-test-tapes/0", 0, 1, "scan starts with slot 0" ],
-);
-Amanda::Changer::scan(\&cb);
-
-# cleanup
-unlink("$AMANDA_TMPDIR/chg-test");
-unlink("$AMANDA_TMPDIR/chg-test-state");
-rmtree("$AMANDA_TMPDIR/chg-test-tapes");
+}
+
+sub assert_invalid {
+ my ($global_tapedev, $global_tpchanger, $defn_tpchanger, $custom_defn,
+ $name, $regexp, $msg) = @_;
+ loadconfig($global_tapedev, $global_tpchanger, $defn_tpchanger, $custom_defn);
+ my $err = Amanda::Changer->new($name);
+ if ($err->isa("Amanda::Changer::Error")) {
+ like($err->{'message'}, $regexp, $msg);
+ } else {
+ diag("Amanda::Changer->new did not return an Error object:");
+ diag("".Dumper($err));
+ fail($msg);
+ }
+}
+
+assert_invalid(undef, undef, undef, undef, undef,
+ qr/You must specify one of 'tapedev' or 'tpchanger'/,
+ "supplying a nothing is invalid");
+
+loadconfig(undef, "file:/foo", undef, undef);
+is_deeply( Amanda::Changer->new(), [ "chg-single:file:/foo", undef ],
+ "default changer with global tpchanger naming a device");
+
+loadconfig(undef, "chg-disk:/foo", undef, undef);
+is_deeply( Amanda::Changer->new(), [ "chg-disk:/foo", undef ],
+ "default changer with global tpchanger naming a changer");
+
+loadconfig(undef, "mychanger", "chg-disk:/bar", undef);
+is_deeply( Amanda::Changer->new(), [ "chg-disk:/bar", "cc" ],
+ "default changer with global tpchanger naming a defined changer with a uri");
+
+loadconfig(undef, "mychanger", "chg-zd-mtx", undef);
+is_deeply( Amanda::Changer->new(), [ "chg-compat:chg-zd-mtx", "cc" ],
+ "default changer with global tpchanger naming a defined changer with a compat script");
+
+loadconfig(undef, "chg-zd-mtx", undef, undef);
+is_deeply( Amanda::Changer->new(), [ "chg-compat:chg-zd-mtx", undef ],
+ "default changer with global tpchanger naming a compat script");
+
+loadconfig("tape:/dev/foo", undef, undef, undef);
+is_deeply( Amanda::Changer->new(), [ "chg-single:tape:/dev/foo", undef ],
+ "default changer with global tapedev naming a device and no tpchanger");
+
+assert_invalid("tape:/dev/foo", "tape:/dev/foo", undef, undef, undef,
+ qr/Cannot specify both 'tapedev' and 'tpchanger'/,
+ "supplying a device for both tpchanger and tapedev is invalid");
+
+assert_invalid("tape:/dev/foo", "chg-disk:/foo", undef, undef, undef,
+ qr/Cannot specify both 'tapedev' and 'tpchanger'/,
+ "supplying a device for tapedev and a changer for tpchanger is invalid");
+
+loadconfig("tape:/dev/foo", 'chg-zd-mtx', undef, undef);
+is_deeply( Amanda::Changer->new(), [ "chg-compat:chg-zd-mtx", undef ],
+ "default changer with global tapedev naming a device and a global tpchanger naming a compat script");
+
+assert_invalid("chg-disk:/foo", "tape:/dev/foo", undef, undef, undef,
+ qr/Cannot specify both 'tapedev' and 'tpchanger'/,
+ "supplying a changer for tapedev and a device for tpchanger is invalid");
+
+loadconfig("chg-disk:/foo", undef, undef, undef);
+is_deeply( Amanda::Changer->new(), [ "chg-disk:/foo", undef ],
+ "default changer with global tapedev naming a device");
+
+loadconfig("mychanger", undef, "chg-disk:/bar", undef);
+is_deeply( Amanda::Changer->new(), [ "chg-disk:/bar", "cc" ],
+ "default changer with global tapedev naming a defined changer with a uri");
+
+loadconfig("mychanger", undef, "chg-zd-mtx", undef);
+is_deeply( Amanda::Changer->new(), [ "chg-compat:chg-zd-mtx", "cc" ],
+ "default changer with global tapedev naming a defined changer with a compat script");
+
+loadconfig(undef, undef, "chg-disk:/foo", undef);
+is_deeply( Amanda::Changer->new("mychanger"), [ "chg-disk:/foo", "cc" ],
+ "named changer loads the proper definition");
+
+loadconfig(undef, undef, undef, [
+ tapedev => '"chg-disk:/foo"',
+]);
+is_deeply( Amanda::Changer->new(), [ "chg-disk:/foo", "cc" ],
+ "defined changer with tapedev loads the proper definition");
+
+loadconfig(undef, undef, undef, [
+ tpchanger => '"chg-disk:/bar"',
+]);
+is_deeply( Amanda::Changer->new(), [ "chg-disk:/bar", "cc" ],
+ "defined changer with tpchanger loads the proper definition");
+
+assert_invalid(undef, undef, undef, [
+ tpchanger => '"chg-disk:/bar"',
+ tapedev => '"file:/bar"',
+ ], undef,
+ qr/Cannot specify both 'tapedev' and 'tpchanger'/,
+ "supplying both a new tpchanger and tapedev in a definition is invalid");
+
+assert_invalid(undef, undef, undef, [
+ property => '"this" "will not work"',
+ ], undef,
+ qr/You must specify one of 'tapedev' or 'tpchanger'/,
+ "supplying neither a tpchanger nor tapedev in a definition is invalid");
+
+*Amanda::Changer::_new_from_uri = *saved_new_from_uri;
+
+# test with_locked_state *within* a process
+
+sub test_locked_state {
+ my ($finished_cb) = @_;
+ my $chg;
+ my $stfile = "$Installcheck::TMP/test-statefile";
+ my $num_outstanding = 0;
+
+ my $steps = define_steps
+ cb_ref => \$finished_cb;
+
+ step start => sub {
+ $chg = Amanda::Changer->new("chg-null:");
+
+ for my $num (qw( one two three )) {
+ ++$num_outstanding;
+ $chg->with_locked_state($stfile, $steps->{'maybe_done'}, sub {
+ my ($state, $maybe_done) = @_;
+
+ $state->{$num} = $num;
+ $state->{'count'}++;
+
+ Amanda::MainLoop::call_after(50, $maybe_done, undef, $state);
+ });
+ }
+ };
+
+ step maybe_done => sub {
+ my ($err, $state) = @_;
+ die $err if $err;
+
+ return if (--$num_outstanding);
+
+ is_deeply($state, {
+ one => "one",
+ two => "two",
+ three => "three",
+ count => 3,
+ }, "state is maintained correctly (within a process)");
+
+ unlink($stfile) if -f $stfile;
+
+ $finished_cb->();
+ };
+}
+test_locked_state(\&Amanda::MainLoop::quit);
+Amanda::MainLoop::run();
projects / debian / amanda / blobdiff