use lib '@amperldir@';
use strict;
+use warnings;
use File::Basename;
use Getopt::Long;
use Amanda::MainLoop;
use Amanda::Taper::Scan;
use Amanda::Recovery::Scan;
-use Amanda::Interactive;
+use Amanda::Interactivity;
+use Amanda::Tapelist;
my $exit_status = 0;
+my $tl;
##
# Subcommand handling
sub usage {
my ($finished_cb) = @_;
- $finished_cb ||= sub { exit(1); };
+
+ $finished_cb = sub { exit(1); } if (!$finished_cb or !(ref($finished_cb) eq "CODE"));
print STDERR <<EOF;
-Usage: amtape <conf> <command> {<args>} [-o configoption]*
+Usage: amtape [-o configoption]* <conf> <command> {<args>}
Valid commands are:
EOF
local $Text::Wrap::columns = 80 - 20;
sub {
my ($finished_cb, @args) = @_;
- usage($finished_cb);
+ return usage($finished_cb);
});
subcommand("reset", "reset", "reset changer to known state",
$chg->reset(finished_cb => sub {
my ($err) = @_;
+ $chg->quit();
return failure($err, $finished_cb) if $err;
print STDERR "changer is reset\n";
$chg->eject(@drive_args,
finished_cb => sub {
my ($err) = @_;
+ $chg->quit();
return failure($err, $finished_cb) if $err;
print STDERR "drive ejected\n";
$chg->clean(@drive_args,
finished_cb => sub {
my ($err) = @_;
+ $chg->quit();
return failure($err, $finished_cb) if $err;
print STDERR "drive cleaned\n";
my ($finished_cb, @args) = @_;
my $last_slot;
my %seen_slots;
- my $gres;
-
- my $steps = define_steps
- cb_ref => \$finished_cb;
+ my $chg;
if (@args != 0) {
return usage($finished_cb);
}
- my $chg = load_changer($finished_cb) or return;
+ $chg = load_changer($finished_cb) or return;
+
+ my $steps = define_steps
+ cb_ref => \$finished_cb,
+ finalize => sub { $chg->quit() if defined $chg };
step start => sub {
$chg->info(info => [ 'num_slots' ], info_cb => $steps->{'info_cb'});
print STDERR sprintf("slot %3s: date %-14s label %s\n",
$last_slot, $dev->volume_time(),
$dev->volume_label());
- $gres = $res;
- return $res->set_label(label => $dev->volume_label(),
- finished_cb => $steps->{'set_labeled'});
} elsif ($st == $DEVICE_STATUS_VOLUME_UNLABELED) {
print STDERR sprintf("slot %3s: unlabeled volume\n", $last_slot);
} else {
}
};
- step set_labeled => sub {
- $gres->release(finished_cb => $steps->{'released'});
- };
-
step released => sub {
$chg->load(relative_slot => 'next', slot => $last_slot,
except_slots => { %seen_slots }, res_cb => $steps->{'loaded'});
my ($err, $inv) = @_;
if ($err) {
if ($err->notimpl) {
- print STDERR "inventory not supported by this changer\n";
+ if ($err->{'message'}) {
+ print STDERR "inventory not supported by this changer: $err->{'message'}\n";
+ } else {
+ print STDERR "inventory not supported by this changer\n";
+ }
} else {
print STDERR "$err\n";
}
+ $chg->quit();
return $finished_cb->();
}
my $line = "slot $sl->{slot}:";
if (!defined($sl->{device_status}) && !defined($sl->{label})) {
$line .= " unknown state";
- } elsif ($sl->{'status'} == Amanda::Changer::SLOT_EMPTY) {
+ } elsif ($sl->{'state'} == Amanda::Changer::SLOT_EMPTY) {
$line .= " empty";
} else {
if (defined $sl->{label}) {
$line .= " label $sl->{label}";
+ my $tle = $tl->lookup_tapelabel($sl->{label});
+ if ($tle->{'meta'}) {
+ $line .= " ($tle->{'meta'})";
+ }
+ } elsif ($sl->{'device_status'} == $DEVICE_STATUS_VOLUME_UNLABELED) {
+ $line .= " blank";
} elsif ($sl->{'device_status'} != $DEVICE_STATUS_SUCCESS) {
$line .= "device error";
} elsif ($sl->{'f_type'} != $Amanda::Header::F_TAPESTART) {
if ($sl->{'import_export'}) {
$line .= " (import/export slot)";
}
+ if ($sl->{'current'}) {
+ $line .= " (current)";
+ }
# note that inventory goes to stdout
print "$line\n";
}
+ $chg->quit();
$finished_cb->();
});
$chg->inventory(inventory_cb => $inventory_cb);
sub {
my ($finished_cb, @args) = @_;
my @slotarg;
- my $gres;
+ my $chg;
my $steps = define_steps
- cb_ref => \$finished_cb;
+ cb_ref => \$finished_cb,
+ finalize => sub { $chg->quit() if defined $chg };
# NOTE: the syntax of this subcommand precludes actual slots named
# 'current' or 'next' .. when we have a changer using such slot names,
# this subcommand will need to support a --literal flag
- usage($finished_cb) unless (@args == 1);
+ return usage($finished_cb) unless (@args == 1);
my $slot = shift @args;
- my $chg = load_changer($finished_cb) or return;
+ $chg = load_changer($finished_cb) or return;
step get_slot => sub {
if ($slot eq 'current' or $slot eq 'next') {
my $gotslot = $res->{'this_slot'};
print STDERR "changed to slot $gotslot\n";
- if ($res->{device}->volume_label) {
- $gres = $res;
- $res->set_label(label => $res->{device}->volume_label(),
- finished_cb => $steps->{'set_labeled'});
- } else {
- $res->release(finished_cb => $steps->{'released'});
- }
- };
-
- step set_labeled => sub {
- $gres->release(finished_cb => $steps->{'released'});
+ $res->release(finished_cb => $steps->{'released'});
};
step released => sub {
subcommand("label", "label <label>", "load the volume with label <label>",
sub {
my ($finished_cb, @args) = @_;
- my $gres;
- my $inter;
+ my $interactivity;
my $scan;
+ my $chg;
- usage($finished_cb) unless (@args == 1);
+ return usage($finished_cb) unless (@args == 1);
my $label = shift @args;
my $steps = define_steps
- cb_ref => \$finished_cb;
+ cb_ref => \$finished_cb,
+ finalize => sub { $scan->quit() if defined $scan;
+ $chg->quit() if defined $chg };
step start => sub {
my $_user_msg_fn = sub {
}
};
- $inter = Amanda::Interactive->new(name => 'stdin');
- $scan = Amanda::Recovery::Scan->new(interactive => $inter);
+ $interactivity = Amanda::Interactivity->new(name => 'stdin');
+ $chg = load_changer($finished_cb) or return;
+ $scan = Amanda::Recovery::Scan->new(chg => $chg,
+ interactivity => $interactivity);
return failure("$scan", $finished_cb)
if ($scan->isa("Amanda::Changer::Error"));
show_slot($res);
print STDERR "label $label is now loaded from slot $gotslot\n";
- if ($res->{device}->volume_label) {
- $gres = $res;
- $res->set_label(label => $res->{device}->volume_label(),
- finished_cb => $steps->{'set_labeled'});
- } else {
- $res->release(finished_cb => $steps->{'released'});
- }
- };
-
- step set_labeled => sub {
- $gres->release(finished_cb => $steps->{'released'});
+ $res->release(finished_cb => $steps->{'released'});
};
step released => sub {
}
};
- usage($finished_cb) unless (@args == 0);
+ return usage($finished_cb) unless (@args == 0);
my $label = shift @args;
my $chg = load_changer($finished_cb) or return;
+ my $interactivity = Amanda::Interactivity->new(name => 'tty');
+ my $scan_name = getconf($CNF_TAPERSCAN);
+ my $taperscan = Amanda::Taper::Scan->new(algorithm => $scan_name,
+ changer => $chg,
+ tapelist => $tl);
my $result_cb = make_cb(result_cb => sub {
my ($err, $res, $label, $mode) = @_;
- return failure($err, $finished_cb) if $err;
+ if ($err) {
+ $taperscan->quit() if defined $taperscan;
+ return failure($err, $finished_cb);
+ }
my $modestr = ($mode == $ACCESS_APPEND)? "append" : "write";
my $slot = $res->{'this_slot'};
my ($err) = @_;
die "$err" if $err;
+ $taperscan->quit() if defined $taperscan;
$finished_cb->();
});
});
- my $taperscan = Amanda::Taper::Scan->new(changer => $chg);
$taperscan->scan(
result_cb => $result_cb,
user_msg_fn => $taper_user_msg_fn,
return failure($err, $finished_cb) if $err;
print STDERR "update complete\n";
+ $chg->quit();
$finished_cb->();
});
});
sub load_changer {
my ($finished_cb) = @_;
- my $chg = Amanda::Changer->new();
+ my $chg = Amanda::Changer->new(undef, tapelist => $tl);
return failure($chg, $finished_cb) if ($chg->isa("Amanda::Changer::Error"));
return $chg;
}
Amanda::Util::finish_setup($RUNNING_AS_DUMPUSER);
+my $tlf = Amanda::Config::config_dir_relative(getconf($CNF_TAPELIST));
+$tl = Amanda::Tapelist->new($tlf);
+
#make STDOUT not line buffered
my $previous_fh = select(STDOUT);
$| = 1;
sub main {
my ($finished_cb) = @_;
- my $subcmd = shift @ARGV;
- usage($finished_cb) unless defined($subcmd) and exists ($subcommands{$subcmd});
- invoke_subcommand($subcmd, $finished_cb, @ARGV);
+ my $steps = define_steps
+ cb_ref => \$finished_cb;
+
+ step start => sub {
+ my $subcmd = shift @ARGV;
+ return usage($finished_cb) unless defined($subcmd) and exists ($subcommands{$subcmd});
+ invoke_subcommand($subcmd, $finished_cb, @ARGV);
+ }
}
+
main(\&Amanda::MainLoop::quit);
Amanda::MainLoop::run();
Amanda::Util::finish_application();
projects / debian / amanda / blobdiff