quiet => 0,
quick => 0,
service => 'debbugs',
+ progress => 0,
);
'quick|q',
'service|s',
'sysconfdir|c',
+ 'progress!',
'spool_dir|spool-dir=s',
'debug|d+','help|h|?','man|m');
my @USAGE_ERRORS;
$options{verbose} = $options{verbose} - $options{quiet};
+if ($options{progress}) {
+ eval "use Term::ProgressBar";
+ push @USAGE_ERRORS, "You asked for a progress bar, but Term::ProgressBar isn't installed" if $@;
+}
+
+
pod2usage(join("\n",@USAGE_ERRORS)) if @USAGE_ERRORS;
if (exists $options{sysconfdir}) {
exit 1;
}
+
# connect to the database; figure out how to handle errors properly
# here.
my $schema = Debbugs::DB->connect('dbi:Pg:service='.$options{service}) or
my $start_time = time;
-my @dirs = ($initialdir);
+my @dirs = (@ARGV?@ARGV : $initialdir);
my $cnt = 0;
my %tags;
+my %severities;
my %queue;
+my $tot_dirs = @ARGV ? @ARGV : 0;
+my $done_dirs = 0;
+my $avg_subfiles = 0;
+my $completed_files = 0;
+my $p;
+if ($options{progress}) {
+ $p = eval "Term::ProgressBar->new({count => 1,ETA=>q(linear)})";
+ warn "Unable to initialize progress bar: $@" if not $p;
+}
while (my $dir = shift @dirs) {
printf "Doing dir %s ...\n", $dir if $verbose;
closedir(DIR);
my @list = map { m/^(\d+)\.summary$/?($1):() } @subdirs;
+ $tot_dirs -= @dirs;
push @dirs, map { m/^(\d+)$/ && -d "$dir/$1"?("$dir/$1"):() } @subdirs;
+ $tot_dirs += @dirs;
+ if ($avg_subfiles == 0) {
+ $avg_subfiles = @list;
+ }
+
+ $p->target($avg_subfiles*($tot_dirs-$done_dirs)+$completed_files+@list) if $p;
+ $avg_subfiles = ($avg_subfiles * $done_dirs + @list) / ($done_dirs+1);
+ $done_dirs += 1;
for my $bug (@list) {
+ $completed_files++;
+ $p->update($completed_files) if $p;
print "Up to $cnt bugs...\n" if (++$cnt % 100 == 0 && $verbose);
my $stat = stat(getbugcomponent($bug,'summary',$initialdir));
if (not defined $stat) {
next if $stat->mtime < $time;
my $data = read_bug(bug => $bug,
location => $initialdir);
- load_bug(db => $schema,
- data => split_status_fields($data),
- tags => \%tags,
- queue => \%queue);
+ eval {
+ load_bug(db => $schema,
+ data => split_status_fields($data),
+ tags => \%tags,
+ severities => \%severities,
+ queue => \%queue);
+ };
+ if ($@) {
+ use Data::Dumper;
+ print STDERR Dumper($data) if $DEBUG;
+ die "failure while trying to load bug $bug\n$@";
+ }
}
}
+$p->remove();
handle_load_bug_queue(db => $schema,
queue => \%queue);
+
__END__