if ($? == 0) {
my $content = $self->get_slot($src);
- print "content = $content<br/> $src => $dst<br/>";
+ print "$content ($src) => $dst<br/>";
$self->{slot}->[$src] = 'empty';
$self->set_slot($dst, $content);
return 1;
}
$all->{$vol}->{realslot} = $slot;
- $all->{$vol}->{volbytes} = Bweb::human_size($all->{$vol}->{volbytes}) ;
-
+
push @{ $param }, $all->{$vol};
} else { # empty or no label
MATCH => " ~ ",
STARTTIME_DAY => " date_trunc('day', Job.StartTime) ",
STARTTIME_HOUR => " date_trunc('hour', Job.StartTime) ",
+ STARTTIME_MONTH => " date_trunc('month', Job.StartTime) ",
STARTTIME_PHOUR=> " date_part('hour', Job.StartTime) ",
STARTTIME_PDAY => " date_part('day', Job.StartTime) ",
+ STARTTIME_PMONTH => " date_part('month', Job.StartTime) ",
},
mysql => {
UNIX_TIMESTAMP => 'UNIX_TIMESTAMP',
MATCH => " REGEXP ",
STARTTIME_DAY => " DATE_FORMAT(StartTime, '%Y-%m-%d') ",
STARTTIME_HOUR => " DATE_FORMAT(StartTime, '%Y-%m-%d %H') ",
+ STARTTIME_MONTH => " DATE_FORMAT(StartTime, '%Y-%m') ",
STARTTIME_PHOUR=> " DATE_FORMAT(StartTime, '%H') ",
STARTTIME_PDAY => " DATE_FORMAT(StartTime, '%d') ",
+ STARTTIME_PMONTH => " DATE_FORMAT(StartTime, '%m') ",
},
);
my $all = $self->dbh_selectall_hashref($query, 'name') ;
- foreach (values %$all) {
- $_->{fileretention} = human_sec($_->{fileretention});
- $_->{jobretention} = human_sec($_->{jobretention});
- }
-
my $dsp = { ID => $cur_id++,
clients => [ values %$all] };
type => 1,
);
my %opt_p = ( # option with path
+ fileset=> 1,
mtxcmd => 1,
precmd => 1,
device => 1,
$ret{db_filesets} = [sort {lc($a->{fileset}) cmp lc($b->{fileset}) }
values %$filesets] ;
-
}
if ($what{db_jobnames}) {
$ret{db_jobnames} = [sort {lc($a->{jobname}) cmp lc($b->{jobname}) }
values %$jobnames] ;
-
}
if ($what{db_devices}) {
$ret{db_devices} = [sort {lc($a->{name}) cmp lc($b->{name}) }
values %$devices] ;
-
}
return \%ret;
{
my ($self) = @_;
- my $fields = $self->get_form(qw/age level status clients filesets graph gtype type
- db_clients limit db_filesets width height
- qclients qfilesets qjobnames db_jobnames/);
+ my $fields = $self->get_form(qw/age level status clients filesets
+ graph gtype type
+ db_clients limit db_filesets width height
+ qclients qfilesets qjobnames db_jobnames/);
my $url = CGI::url(-full => 0,
my $all = $self->dbh_selectall_hashref($query, 'jobid') ;
- foreach (values %$all) {
- $_->{jobbytes} = human_size($_->{jobbytes}) ;
- }
-
$self->display({ clientname => $arg{clientname},
Filter => $label,
ID => $cur_id++,
my $status = CGI::param('status') || '';
if ($status =~ /^(\w)$/) {
$ret{status} = $1;
- $limit .= "AND Job.JobStatus = '$1' ";
+ if ($1 eq 'f') {
+ $limit .= "AND Job.JobStatus IN ('f','E') ";
+ } else {
+ $limit .= "AND Job.JobStatus = '$1' ";
+ }
}
}
get last backup
-SELECT DISTINCT Job.JobId AS jobid,
- Client.Name AS client,
- FileSet.FileSet AS fileset,
- Job.Name AS jobname,
- Level AS level,
- StartTime AS starttime,
- JobFiles AS jobfiles,
- JobBytes AS jobbytes,
- VolumeName AS volumename,
- JobStatus AS jobstatus,
- JobErrors AS joberrors
-
- FROM Client,Job,JobMedia,Media,FileSet
- WHERE Client.ClientId=Job.ClientId
- AND Job.FileSetId=FileSet.FileSetId
- AND JobMedia.JobId=Job.JobId
- AND JobMedia.MediaId=Media.MediaId
- $limit
-
=cut
sub display_job
my $all = $self->dbh_selectall_hashref($query, 'jobid') ;
- foreach (values %$all) {
- $_->{jobbytes} = human_size($_->{jobbytes}) ;
- }
-
$self->display({ Filter => $label,
ID => $cur_id++,
Jobs =>
my $row = $self->dbh_selectrow_hashref($query) ;
- $row->{jobbytes} = human_size($row->{jobbytes}) ;
-
# display all volumes associate with this job
$query="
SELECT Media.VolumeName as volumename
";
my $all = $self->dbh_selectall_hashref($query, 'volumename') ;
- foreach (values %$all) {
- $_->{volbytes} = human_size($_->{volbytes}) ;
- }
$self->display({ ID => $cur_id++,
Pool => $elt{pool},
my $all = $self->dbh_selectall_hashref($query, 'volumename') ;
foreach my $media (values %$all) {
- $media->{nb_bytes} = human_size($media->{nb_bytes}) ;
- $media->{voluseduration} = human_sec($media->{voluseduration});
- $media->{volretention} = human_sec($media->{volretention});
- $media->{volreadtime} = human_sec($media->{volreadtime});
- $media->{volwritetime} = human_sec($media->{volwritetime});
my $mq = $self->dbh_quote($media->{volumename});
$query = "
my $jobs = $self->dbh_selectall_hashref($query, 'jobid') ;
- foreach (values %$jobs) {
- $_->{bytes} = human_size($_->{bytes}) ;
- }
-
$query = "
SELECT LocationLog.Date AS date,
Location.Location AS location,
$self->display_location();
}
+sub location_del
+{
+ my ($self) = @_ ;
+ my $arg = $self->get_form(qw/qlocation/) ;
+
+ unless ($arg->{qlocation}) {
+ return $self->error("Can't get location");
+ }
+
+ my $query = "
+SELECT count(Media.MediaId) AS nb
+ FROM Media INNER JOIN Location USING (LocationID)
+WHERE Location = $arg->{qlocation}
+";
+
+ my $res = $self->dbh_selectrow_hashref($query);
+
+ if ($res->{nb}) {
+ return $self->error("Sorry, the location must be empty");
+ }
+
+ $query = "
+DELETE FROM Location WHERE Location = $arg->{qlocation} LIMIT 1
+";
+
+ $self->dbh_do($query);
+
+ $self->display_location();
+}
+
+
sub location_add
{
my ($self) = @_ ;
$update .= " Slot=0, ";
}
} else {
- $update = " Slot=0, InChanger=0, ";
+ $update .= " Slot=0, InChanger=0, ";
}
my $pool = CGI::param('pool') || '';
$self->display({
%$elt,
%$row,
- },
- "update_media.tpl");
+ }, "update_media.tpl");
}
sub save_location
my $nb = $self->dbh_do($query);
- print "$nb media updated";
+ print "$nb media updated, you may have to update your autochanger.";
+
+ $self->display_media();
}
sub change_location
$row->{ID} = $cur_id++;
$row->{label} = $label;
- $row->{nb_bytes} = human_size($row->{nb_bytes}) ;
$self->display($row, "display_client_stats.tpl");
}
# TODO : afficher les tailles et les dates
my $query = "
-SELECT sum(subq.volmax) AS volmax,
- sum(subq.volnum) AS volnum,
- sum(subq.voltotal) AS voltotal,
+SELECT subq.volmax AS volmax,
+ subq.volnum AS volnum,
+ subq.voltotal AS voltotal,
Pool.Name AS name,
Pool.Recycle AS recycle,
Pool.VolRetention AS volretention,
WHERE Media.VolStatus = 'Full'
GROUP BY Media.MediaType
) AS media_avg_size ON (Media.MediaType = media_avg_size.MediaType)
- GROUP BY Media.MediaType, Media.PoolId
- ) AS subq
-INNER JOIN Pool ON (Pool.PoolId = subq.PoolId)
-GROUP BY subq.PoolId
+ GROUP BY Media.MediaType, Media.PoolId, media_avg_size.volavg
+ ) AS subq
+LEFT JOIN Pool ON (Pool.PoolId = subq.PoolId)
";
my $all = $self->dbh_selectall_hashref($query, 'name') ;
foreach my $p (values %$all) {
- $p->{maxvolbytes} = human_size($p->{maxvolbytes}) ;
- $p->{volretention} = human_sec($p->{volretention}) ;
- $p->{voluseduration} = human_sec($p->{voluseduration}) ;
-
if ($p->{volmax}) {
$p->{poolusage} = sprintf('%.2f', $p->{voltotal} * 100/ $p->{volmax}) ;
} else {
sub eject_media
{
my ($self) = @_;
- my $arg = $self->get_form('jmedias', 'slots', 'ach');
+ my $arg = $self->get_form('jmedias');
unless ($arg->{jmedias}) {
return $self->error("Can't get media selection");
}
- my $a = $self->ach_get($arg->{ach});
- unless ($a) {
- return 0;
- }
-
my $query = "
SELECT Media.VolumeName AS volumename,
Storage.Name AS storage,
my $all = $self->dbh_selectall_hashref($query, 'volumename');
- $a->status();
-
foreach my $vol (values %$all) {
+ my $a = $self->ach_get($vol->{location});
+ next unless ($a) ;
+
+ unless ($a->{have_status}) {
+ $a->status();
+ $a->{have_status} = 1;
+ }
+
print "eject $vol->{volumename} from $vol->{storage} : ";
if ($a->send_to_io($vol->{slot})) {
print "ok</br>";
}
}
+sub move_email
+{
+ my ($self) = @_;
+
+ my ($to, $subject, $content) = (CGI::param('email'),
+ CGI::param('subject'),
+ CGI::param('content'));
+ $to =~ s/[^\w\d\.\@<>,]//;
+ $subject =~ s/[^\w\d\.\[\]]/ /;
+
+ open(MAIL, "|mail -s '$subject' '$to'") ;
+ print MAIL $content;
+ close(MAIL);
+
+ print "Mail sent";
+}
+
sub restore
{
my ($self) = @_;
$ach->{drives} =
[ map { { name => $_, index => $i++ } } @{$ach->{drive_name}} ] ;
- my $b = new Bconsole(pref => $self->{info});
+ my $b = $self->get_bconsole();
+
my @storages = $b->list_storage() ;
$ach->{devices} = [ map { { name => $_ } } @storages ];
my ($self) = @_;
my $arg = $self->get_form('ach', 'mtxcmd', 'device', 'precmd');
- my $b = new Bconsole(pref => $self->{info});
+ my $b = $self->get_bconsole();
my @storages = $b->list_storage() ;
unless ($arg->{ach}) {
my ($self) = @_;
my $arg = $self->get_form('jobid');
- my $b = new Bconsole(pref => $self->{info});
-
if ($arg->{jobid}) {
+ my $b = $self->get_bconsole();
my $ret = $b->send_cmd("delete jobid=\"$arg->{jobid}\"");
+
$self->display({
content => $b->send_cmd("delete jobid=\"$arg->{jobid}\""),
title => "Delete a job ",
return $self->error("Bad autochanger name");
}
- my $b = new Bconsole(pref => $self->{info});
- print "<pre>" . $b->update_slots($ach) . "</pre>";
+ print "<pre>";
+ my $b = new Bconsole(pref => $self->{info},timeout => 60,log_stdout => 1);
+ $b->update_slots($ach);
+ print "</pre>\n"
}
sub get_job_log
drive => $arg->{drive},
pool => 'Scratch',
slots => $slots) ;
+ $b->close();
print "</pre>";
}
my @volume = CGI::param('media');
+ unless (@volume) {
+ return $self->error("Can't get media selection");
+ }
+
my $b = new Bconsole(pref => $self->{info}, timeout => 60);
$self->display({
title => "Purge media",
name => "purge volume=" . join(' volume=', @volume),
}, "command.tpl");
+ $b->close();
}
sub prune
{
my ($self) = @_;
+ my @volume = CGI::param('media');
+ unless (@volume) {
+ return $self->error("Can't get media selection");
+ }
+
my $b = new Bconsole(pref => $self->{info}, timeout => 60);
- my @volume = CGI::param('media');
$self->display({
content => $b->prune_volume(@volume),
title => "Prune media",
name => "prune volume=" . join(' volume=', @volume),
}, "command.tpl");
+
+ $b->close();
}
sub cancel_job
my $arg = $self->get_form('jobid');
unless ($arg->{jobid}) {
- return $self->error('Bad jobid');
+ return $self->error("Can't get jobid");
}
- my $b = new Bconsole(pref => $self->{info});
+ my $b = $self->get_bconsole();
$self->display({
content => $b->cancel($arg->{jobid}),
title => "Cancel job",
}, "command.tpl");
}
+sub fileset_view
+{
+ # Warning, we display current fileset
+ my ($self) = @_;
+
+ my $arg = $self->get_form('fileset');
+
+ if ($arg->{fileset}) {
+ my $b = $self->get_bconsole();
+ my $ret = $b->get_fileset($arg->{fileset});
+ $self->display({ fileset => $arg->{fileset},
+ %$ret,
+ }, "fileset_view.tpl");
+ } else {
+ $self->error("Can't get fileset name");
+ }
+}
+
sub director_show_sched
{
my ($self) = @_ ;
my $arg = $self->get_form('days');
- my $b = new Bconsole(pref => $self->{info}) ;
-
+ my $b = $self->get_bconsole();
my $ret = $b->director_get_sched( $arg->{days} );
$self->display({
return $self->error("Can't find job name");
}
- my $b = new Bconsole(pref => $self->{info}) ;
+ my $b = $self->get_bconsole();
my $cmd;
if ($what) {
}, "command.tpl");
}
+sub get_bconsole
+{
+ my ($self) = @_;
+ return new Bconsole(pref => $self->{info});
+}
+
sub run_job_select
{
my ($self) = @_;
- $b = new Bconsole(pref => $self->{info});
+ my $b = $self->get_bconsole();
my $joblist = [ map { { name => $_ } } $b->list_job() ];
sub run_job_mod
{
my ($self) = @_;
- $b = new Bconsole(pref => $self->{info});
+ my $b = $self->get_bconsole();
my $job = CGI::param('job') || '';
sub run_job
{
my ($self) = @_;
- $b = new Bconsole(pref => $self->{info});
+ my $b = $self->get_bconsole();
my $jobs = [ map {{ name => $_ }} $b->list_job() ];
sub run_job_now
{
my ($self) = @_;
- $b = new Bconsole(pref => $self->{info});
+ my $b = $self->get_bconsole();
# TODO: check input (don't use pool, level)
projects / bacula / bacula / blobdiff