X-Git-Url: https://git.gag.com/?a=blobdiff_plain;f=perl%2FAmanda%2FRecovery%2FClerk.pm;h=39b3c20cd58010d6156bfaf530b14b07f260884c;hb=949b8910a5e23c4285d0b1aedacfc82a14dc97a5;hp=7531421dd1c7b5a5aa259faded153a054eb1ee8a;hpb=c6f0a88c567f8536c498f554285aed1f8150da18;p=debian%2Famanda diff --git a/perl/Amanda/Recovery/Clerk.pm b/perl/Amanda/Recovery/Clerk.pm index 7531421..39b3c20 100644 --- a/perl/Amanda/Recovery/Clerk.pm +++ b/perl/Amanda/Recovery/Clerk.pm @@ -1,4 +1,4 @@ -# Copyright (c) 2010 Zmanda, Inc. All Rights Reserved. +# Copyright (c) 2010-2012 Zmanda, Inc. All Rights Reserved. # # This library is free software; you can redistribute it and/or modify it # under the terms of the GNU Lesser General Public License version 2.1 as @@ -233,7 +233,7 @@ sub get_xfer_src { unless exists $params{$rq_param}; } - die "Clerk is already busy" if $self->{'xfer_state'}; + confess "Clerk is already busy" if $self->{'xfer_state'}; # set up a new xfer_state my $xfer_state = $self->{'xfer_state'} = { @@ -267,8 +267,8 @@ sub start_recovery { unless exists $params{$rq_param}; } - die "no xfer is in progress" unless $self->{'xfer_state'}; - die "get_xfer_src has not finished" + confess "no xfer is in progress" unless $self->{'xfer_state'}; + confess "get_xfer_src has not finished" if defined $self->{'xfer_state'}->{'xfer_src_cb'}; my $xfer_state = $self->{'xfer_state'}; @@ -302,7 +302,7 @@ sub quit { my %params = @_; my $finished_cb = $params{'finished_cb'}; - die "Cannot quit a Clerk while a transfer is in progress" + confess "Cannot quit a Clerk while a transfer is in progress" if $self->{'xfer_state'}; my $steps = define_steps @@ -340,7 +340,7 @@ sub _xmsg_part_done { my $next_label = $xfer_state->{'next_part'}->{'label'}; my $next_filenum = $xfer_state->{'next_part'}->{'filenum'}; - die "read incorrect filenum" + confess "read incorrect filenum" unless $next_filenum == $msg->{'fileno'}; $self->dbg("done reading file $next_filenum on '$next_label'"); @@ -374,6 +374,7 @@ sub _xmsg_done { return $xfer_state->{'recovery_cb'}->( result => $result, errors => $xfer_state->{'errors'}, + bytes_read => $xfer_state->{'xfer_src'}->get_bytes_read() ); } @@ -416,7 +417,7 @@ sub _maybe_start_part { # first, see if anything remains to be done if (!exists $xfer_state->{'dump'}{'parts'}[$xfer_state->{'next_part_idx'}]) { # this should not happen until the xfer is started.. - die "xfer should be running already" + confess "xfer should be running already" unless $xfer_state->{'xfer'}; # tell the source to generate EOF