From 0a94f3feb8d7841fe8212febcbbdac1073413e05 Mon Sep 17 00:00:00 2001 From: Mystery Man Date: Tue, 23 Jul 2002 11:21:56 +0000 Subject: This commit was manufactured by cvs2svn to create tag 'V1_1_8_14mdk'. --- perl-install/pkgs.pm | 1206 -------------------------------------------------- 1 file changed, 1206 deletions(-) delete mode 100644 perl-install/pkgs.pm (limited to 'perl-install/pkgs.pm') diff --git a/perl-install/pkgs.pm b/perl-install/pkgs.pm deleted file mode 100644 index 3a86713f4..000000000 --- a/perl-install/pkgs.pm +++ /dev/null @@ -1,1206 +0,0 @@ -package pkgs; # $Id$ - -use diagnostics; -use strict; -use vars qw(*LOG %preferred $limitMinTrans %compssListDesc); - -use MDK::Common::System; -use URPM; -use URPM::Resolve; -use common; -use install_any; -use run_program; -use detect_devices; -use log; -use fs; -use loopback; -use c; - - - -my @preferred = qw(perl-GTK postfix gcc gcc-cpp gcc-c++ proftpd ghostscript-X vim-minimal kernel db1 db2 ispell-en Bastille-Curses-module nautilus libxpm4 zlib1 libncurses5 harddrake); -@preferred{@preferred} = (); - -#- lower bound on the left ( aka 90 means [90-100[ ) -%compssListDesc = ( - 5 => __("must have"), - 4 => __("important"), - 3 => __("very nice"), - 2 => __("nice"), - 1 => __("maybe"), -); - -#- constant for small transaction. -$limitMinTrans = 8; - - -#- package to ignore, typically in Application CD. OBSOLETED ? -my %ignoreBadPkg = ( - 'civctp-demo' => 1, - 'eus-demo' => 1, - 'myth2-demo' => 1, - 'heretic2-demo' => 1, - 'heroes3-demo' => 1, - 'rt2-demo' => 1, - ); - -sub packageMedium { my ($packages, $p) = @_; $p or die "invalid package from\n" . backtrace(); - foreach (values %{$packages->{mediums}}) { - $p->id >= $_->{start} && $p->id <= $_->{end} and return $_; - } - return } - -sub cleanHeaders { - my ($prefix) = @_; - rm_rf("$prefix/tmp/headers") if -e "$prefix/tmp/headers"; -} - -#- get all headers from an hdlist file. -sub extractHeaders { - my ($prefix, $pkgs, $media) = @_; - my %medium2pkgs; - - cleanHeaders($prefix); - - foreach (@$pkgs) { - foreach my $medium (values %$media) { - $_->id >= $medium->{start} && $_->id <= $medium->{end} or next; - push @{$medium2pkgs{$medium->{medium}} ||= []}, $_; - } - } - - foreach (keys %medium2pkgs) { - my $medium = $media->{$_}; - - eval { - require packdrake; - my $packer = new packdrake("/tmp/$medium->{hdlist}", quiet => 1); - $packer->extract_archive("$prefix/tmp/headers", map { $_->header_filename } @{$medium2pkgs{$_}}); - }; - } - - foreach (@$pkgs) { - my $f = "$prefix/tmp/headers/". $_->header_filename; - $_->update_header($f) or log::l("unable to open header file $f"), next; - } -} - -#- TODO BEFORE TODO -#- size and correction size functions for packages. -my $B = 1.20873; -my $C = 4.98663; #- doesn't take hdlist's into account as getAvailableSpace will do it. -sub correctSize { $B * $_[0] + $C } -sub invCorrectSize { ($_[0] - $C) / $B } - -sub selectedSize { - my ($packages) = @_; - my $size = 0; - foreach (@{$packages->{depslist}}) { - $_->flag_selected and $size += $_->size; - } - $size; -} -sub correctedSelectedSize { correctSize(selectedSize($_[0]) / sqr(1024)) } - -sub size2time { - my ($x, $max) = @_; - my $A = 7e-07; - my $limit = min($max * 3 / 4, 9e8); - if ($x < $limit) { - $A * $x; - } else { - $x -= $limit; - my $B = 6e-16; - my $C = 15e-07; - $B * $x ** 2 + $C * $x + $A * $limit; - } -} - - -#- searching and grouping methods. -#- package is a reference to list that contains -#- a hash to search by name and -#- a list to search by id. -sub packageByName { - my ($packages, $name) = @_; - #- search package with given name and compatible with current architecture. - #- take the best one found (most up-to-date). - my @packages; - foreach (keys %{$packages->{provides}{$name} || {}}) { - my $pkg = $packages->{depslist}[$_]; - $pkg->is_arch_compat or next; - $pkg->name eq $name or next; - push @packages, $pkg; - } - my $best; - foreach (@packages) { - if ($best && $best != $_) { - $_->compare_pkg($best) > 0 and $best = $_; - } else { - $best = $_; - } - } - $best or log::l("unknown package `$name'") && undef; -} -sub packageById { - my ($packages, $id) = @_; - my $pkg = $packages->{depslist}[$id]; #- do not log as id unsupported are still in depslist. - $pkg->is_arch_compat && $pkg; -} -sub packagesOfMedium { - my ($packages, $medium) = @_; - $medium->{start} <= $medium->{end} ? @{$packages->{depslist}}[$medium->{start} .. $medium->{end}] : (); -} -sub packagesToInstall { - my ($packages) = @_; - my @packages; - foreach (values %{$packages->{mediums}}) { - $_->{selected} or next; - log::l("examining packagesToInstall of medium $_->{descr}"); - push @packages, grep { $_->flag_selected } packagesOfMedium($packages, $_); - } - log::l("found " .scalar(@packages). " packages to install"); - @packages; -} - -sub allMediums { - my ($packages) = @_; - sort { $a <=> $b } keys %{$packages->{mediums}}; -} -sub mediumDescr { - my ($packages, $medium) = @_; - $packages->{mediums}{$medium}{descr}; -} - -sub packageRequest { - my ($packages, $pkg) = @_; - - #- check if the same or better version is installed, - #- do not select in such case. - $pkg && ($pkg->flag_upgrade || !$pkg->flag_installed) or return; - - #- check for medium selection, if the medium has not been - #- selected, the package cannot be selected. - foreach (values %{$packages->{mediums}}) { - !$_->{selected} && $pkg->id >= $_->{start} && $pkg->id <= $_->{end} and return; - } - - return { $pkg->id => 1 }; -} - -sub packageCallbackChoices { - my ($urpm, $db, $state, $choices) = @_; - my $prefer; - foreach (@$choices) { - exists $preferred{$_->name} and $prefer = $_; - $_->name =~ /kernel-\d/ and $prefer ||= $_; - } - $prefer || $choices->[0]; #- first one (for instance). -} - -#- selection, unselection of package. -sub selectPackage { - my ($packages, $pkg, $base, $otherOnly) = @_; - - #- select package and dependancies, otherOnly may be a reference - #- to a hash to indicate package that will strictly be selected - #- when value is true, may be selected when value is false (this - #- is only used for unselection, not selection) - my $state = $packages->{state} ||= {}; - $state->{selected} = {}; - $state->{requested} = packageRequest($packages, $pkg) or return; - $packages->resolve_requested($packages->{rpmdb}, $state, no_flag_update => $otherOnly, keep_state => $otherOnly, - callback_choices => \&packageCallbackChoices); - - if ($base || $otherOnly) { - foreach (keys %{$state->{selected}}) { - my $p = $packages->{depslist}[$_] or next; - #- if base is activated, propagate base flag to all selection. - $base and $p->set_flag_base; - $otherOnly and $otherOnly->{$_} = $state->{selected}{$_}; - } - } - 1; -} - -sub unselectPackage($$;$) { - my ($packages, $pkg, $otherOnly) = @_; - - #- base package are not unselectable, - #- and already unselected package are no more unselectable. - $pkg->flag_base and return; - $pkg->flag_selected or return; - - #- try to unwind selection (requested or required) by keeping - #- rpmdb is right place. - #TODO - if ($otherOnly) { - $otherOnly->{$pkg->id} = undef; - } else { - $pkg->set_flag_requested(0); - $pkg->set_flag_required(0); - - #- clear state. - my $state = $packages->{state} ||= {}; - $state->{selected} = { $pkg->id }; - $state->{requested} = {}; - $packages->resolve_requested($packages->{rpmdb}, $state, keep_state => 1); - } - 1; -} -sub togglePackageSelection($$;$) { - my ($packages, $pkg, $otherOnly) = @_; - $pkg->flag_selected ? unselectPackage($packages, $pkg, $otherOnly) : selectPackage($packages, $pkg, 0, $otherOnly); -} -sub setPackageSelection($$$) { - my ($packages, $pkg, $value) = @_; - $value ? selectPackage($packages, $pkg) : unselectPackage($packages, $pkg); -} - -sub unselectAllPackages($) { - my ($packages) = @_; - my %selected; - foreach (@{$packages->{depslist}}) { - unless ($_->flag_base || $_->flag_installed && $_->flag_selected) { - #- deselect all packages except base or packages that need to be upgraded. - $_->set_flag_requested(0); - $_->set_flag_required(0); - $selected{$_->id} = undef; - } - } - if (%selected && %{$packages->{state} || {}}) { - my $state = $packages->{state} ||= {}; - $state->{selected} = \%selected; - $state->{requested} = {}; - $packages->resolve_requested($packages->{rpmdb}, $state, keep_state => 1); - } -} -sub unselectAllPackagesIncludingUpgradable($) { - my ($packages, $removeUpgradeFlag) = @_; - my %selected; - foreach (@{$packages->{depslist}}) { - unless ($_->flag_base) { - $_->set_flag_requested(0); - $_->set_flag_required(0); - $selected{$_->id} = undef; - } - } - if (%selected && %{$packages->{state} || {}}) { - my $state = $packages->{state} ||= {}; - $state->{selected} = \%selected; - $state->{requested} = {}; - $packages->resolve_requested($packages->{rpmdb}, $state, keep_state => 1); - } -} - -sub psUpdateHdlistsDeps { - my ($prefix, $method, $packages) = @_; - my ($good_hdlists_deps, $mediums) = (0, 0); - - #- check if current configuration is still up-to-date and do not need to be updated. - foreach (values %{$packages->{mediums}}) { - my $hdlistf = "$prefix/var/lib/urpmi/hdlist.$_->{fakemedium}.cz" . ($_->{hdlist} =~ /\.cz2/ && "2"); - my $synthesisf = "$prefix/var/lib/urpmi/synthesis.hdlist.$_->{fakemedium}.cz" . ($_->{hdlist} =~ /\.cz2/ && "2"); - -s $hdlistf == $_->{hdlist_size} && -s $synthesisf == $_->{synthesis_hdlist_size} and ++$good_hdlists_deps; - ++$mediums; - } - $good_hdlists_deps > 0 && $good_hdlists_deps == $mediums and return; #- nothing to do. - - #- at this point, this means partition has problably be reformatted and hdlists should be retrieved. - install_any::useMedium($install_any::boot_medium); - - my $listf = install_any::getFile('Mandrake/base/hdlists') or die "no hdlists found"; - - #- WARNING: this function should be kept in sync with functions - #- psUsingHdlists and psUsingHdlist. - #- it purpose it to update hdlist files on system to install. - - #- parse hdlist.list file. - my $medium = 1; - foreach (<$listf>) { - chomp; - s/\s*#.*$//; - /^\s*$/ and next; - m/^\s*(hdlist\S*\.cz2?)\s+(\S+)\s*(.*)$/ or die "invalid hdlist description \"$_\" in hdlists file"; - my ($hdlist, $rpmsdir, $descr) = ($1, $2, $3); - - #- copy hdlist file directly to $prefix/var/lib/urpmi, this will be used - #- for getting header of package during installation or after by urpmi. - my $fakemedium = "$descr ($method$medium)"; - my $newf = "$prefix/var/lib/urpmi/hdlist.$fakemedium.cz" . ($hdlist =~ /\.cz2/ && "2"); - -e $newf and do { unlink $newf or die "cannot remove $newf: $!"; }; - install_any::getAndSaveFile("Mandrake/base/$hdlist", $newf) or die "no $hdlist found"; - symlinkf $newf, "/tmp/$hdlist"; - install_any::getAndSaveFile("Mandrake/base/synthesis.$hdlist", - "$prefix/var/lib/urpmi/synthesis.hdlist.$fakemedium.cz" . ($hdlist =~ /\.cz2/ && "2")); - ++$medium; - } - - #- this is necessary for urpmi. - install_any::getAndSaveFile("Mandrake/base/$_", "$prefix/var/lib/urpmi/$_") foreach qw(rpmsrate); -} - -sub psUsingHdlists { - my ($prefix, $method) = @_; - my $listf = install_any::getFile('Mandrake/base/hdlists') or die "no hdlists found"; - my $packages = new URPM; - - #- add additional fields used by DrakX. - @{$packages}{qw(count mediums)} = (0, {}); - - #- parse hdlists file. - my $medium = 1; - foreach (<$listf>) { - chomp; - s/\s*#.*$//; - /^\s*$/ and next; - m/^\s*(hdlist\S*\.cz2?)\s+(\S+)\s*(.*)$/ or die "invalid hdlist description \"$_\" in hdlists file"; - - #- make sure the first medium is always selected! - #- by default select all image. - psUsingHdlist($prefix, $method, $packages, $1, $medium, $2, $3, 1); - - ++$medium; - } - - log::l("psUsingHdlists read " . scalar @{$packages->{depslist}} . - " headers on " . scalar keys(%{$packages->{mediums}}) . " hdlists"); - - $packages; -} - -sub psUsingHdlist { - my ($prefix, $method, $packages, $hdlist, $medium, $rpmsdir, $descr, $selected, $fhdlist) = @_; - my $fakemedium = "$descr ($method$medium)"; - my ($relocated, $ignored) = (0, 0); - log::l("trying to read $hdlist for medium $medium"); - - #- if the medium already exist, use it. - $packages->{mediums}{$medium} and return $packages->{mediums}{$medium}; - - my $m = $packages->{mediums}{$medium} = { hdlist => $hdlist, - method => $method, - medium => $medium, - rpmsdir => $rpmsdir, #- where is RPMS directory. - descr => $descr, - fakemedium => $fakemedium, -# min => $packages->{count}, -# max => -1, #- will be updated after reading current hdlist. - selected => $selected, #- default value is only CD1, it is really the minimal. - }; - - #- copy hdlist file directly to $prefix/var/lib/urpmi, this will be used - #- for getting header of package during installation or after by urpmi. - my $newf = "$prefix/var/lib/urpmi/hdlist.$fakemedium.cz" . ($hdlist =~ /\.cz2/ && "2"); - -e $newf and do { unlink $newf or die "cannot remove $newf: $!"; }; - install_any::getAndSaveFile($fhdlist || "Mandrake/base/$hdlist", $newf) or die "no $hdlist found"; - $m->{hdlist_size} = -s $newf; #- keep track of size for post-check. - symlinkf $newf, "/tmp/$hdlist"; - - #- if $fhdlist is defined, this is preferable not to try to find the associated synthesis. - my $newsf = "$prefix/var/lib/urpmi/synthesis.hdlist.$fakemedium.cz" . ($hdlist =~ /\.cz2/ && "2"); - unless ($fhdlist) { - #- copy existing synthesis file too. - install_any::getAndSaveFile("Mandrake/base/synthesis.$hdlist", $newsf); - $m->{synthesis_hdlist_size} = -s $newsf; #- keep track of size for post-check. - -s $newsf > 0 or unlink $newsf; - } - - #- avoid using more than one medium if Cd is not ejectable. - #- but keep all medium here so that urpmi has the whole set. - $method eq 'cdrom' && $medium > 1 && !common::usingRamdisk() and return; - - #- parse synthesis (if available) of directly hdlist (with packing). - if (-s $newsf) { - ($m->{start}, $m->{end}) = $packages->parse_synthesis($newsf); - } elsif (-s $newf) { - ($m->{start}, $m->{end}) = $packages->parse_hdlist($newf, 1); - } else { - die "fatal: no hdlist nor synthesis to read for $fakemedium"; - } - $m->{start} > $m->{end} and die "fatal: nothing read in hdlist or synthesis for $fakemedium"; - log::l("read " . ($m->{end} - $m->{start} + 1) . " packages in $hdlist"); - $m; -} - -#OBSOLETED TODO -sub getOtherDeps($$) { - return; #TODO -} - -#OBSOLETED TODO -sub getDeps { - return; #TODO -} - -#OBSOLETED TODO -sub getProvides($) { - return; #TODO -} - -sub read_rpmsrate { - my ($packages, $f) = @_; - my $line_nb = 0; - my $fatal_error; - my (@l); - while (<$f>) { - $line_nb++; - /\t/ and die "tabulations not allowed at line $line_nb\n"; - s/#.*//; # comments - - my ($indent, $data) = /(\s*)(.*)/; - next if !$data; # skip empty lines - - @l = grep { $_->[0] < length $indent } @l; - - my @m = @l ? @{$l[$#l][1]} : (); - my ($t, $flag, @l2); - while ($data =~ - /^(( - [1-5] - | - (?: (?: !\s*)? [0-9A-Z_]+(?:".*?")?) - (?: \s*\|\|\s* (?: !\s*)? [0-9A-Z_]+(?:".*?")?)* - ) - (?:\s+|$) - )(.*)/x) { #@")) { - ($t, $flag, $data) = ($1,$2,$3); - while ($flag =~ s,^\s*(("[^"]*"|[^"\s]*)*)\s+,$1,) {} - my $ok = 0; - $flag = join('||', grep { - if (my ($inv, $p) = /^(!)?HW"(.*)"/) { - ($inv xor detect_devices::matching_desc($p)) and $ok = 1; - 0; - } else { - 1; - } - } split '\|\|', $flag); - push @m, $ok ? 'TRUE' : $flag || 'FALSE'; - push @l2, [ length $indent, [ @m ] ]; - $indent .= $t; - } - if ($data) { - # has packages on same line - my ($rate) = grep { /^\d$/ } @m or die sprintf qq(missing rate for "%s" at line %d (flags are %s)\n), $data, $line_nb, join('&&', @m); - foreach (split ' ', $data) { - if ($packages) { - my $p = packageByName($packages, $_) or next; - my @m2 = map { if_(/locales-(.*)/, qq(LOCALES"$1")) } $p->requires_nosense; - my @m3 = ((grep { !/^\d$/ } @m), @m2); - if (member('INSTALL', @m3)) { - member('NOCOPY', @m3) or push @{$packages->{needToCopy} ||= []}, $_; - next; #- don't need to put INSTALL flag for a package. - } - if ($p->rate) { - my @m4 = $p->rflags; - if (@m3 > 1 || @m4 > 1) { - log::l("can't handle complicate flags for packages appearing twice ($_)"); - $fatal_error++; - } - log::l("package $_ appearing twice with different rates ($rate != ".$p->rate.")") if $rate != $p->rate; - $p->set_rate($rate); - $p->set_rflags("$m3[0]||$m4[0]"); - } else { - $p->set_rate($rate); - $p->set_rflags(@m3); - } - } else { - print "$_ = ", join(" && ", @m), "\n"; - } - } - push @l, @l2; - } else { - push @l, [ $l2[0][0], $l2[$#l2][1] ]; - } - } - $fatal_error and die "$fatal_error fatal errors in rpmsrate"; -} - -sub readCompssUsers { - my ($meta_class) = @_; - my (%compssUsers, @sorted, $l); - - my $file = 'Mandrake/base/compssUsers'; - my $f = $meta_class && install_any::getFile("$file.$meta_class") || install_any::getFile($file) or die "can't find $file"; - local $_; - while (<$f>) { - /^\s*$/ || /^#/ and next; - s/#.*//; - - if (/^(\S.*)/) { - my $verbatim = $_; - my ($icon, $descr, $path); - /^(.*?)\s*\[path=(.*?)\](.*)/ and $_ = "$1$3", $path = $2; - /^(.*?)\s*\[icon=(.*?)\](.*)/ and $_ = "$1$3", $icon = $2; - /^(.*?)\s*\[descr=(.*?)\](.*)/ and $_ = "$1$3", $descr = $2; - $compssUsers{"$path|$_"} = { label => $_, verbatim => $verbatim, path => $path, icons => $icon, descr => $descr, flags => $l=[] }; - push @sorted, "$path|$_"; - } elsif (/^\s+(.*?)\s*$/) { - push @$l, $1; - } - } - \%compssUsers, \@sorted; -} -sub saveCompssUsers { - my ($prefix, $packages, $compssUsers, $sorted) = @_; - my $flat; - foreach (@$sorted) { - my @fl = @{$compssUsers->{$_}{flags}}; - my %fl; $fl{$_} = 1 foreach @fl; - $flat .= $compssUsers->{$_}{verbatim}; - foreach my $p (@{$packages->{depslist}}) { - my @flags = $p->rflags; - if ($p->rate && grep { grep { !/^!/ && $fl{$_} } split('\|\|') } @flags) { - $flat .= sprintf "\t%d %s\n", $p->rate, $p->name; - } - } - } - output "$prefix/var/lib/urpmi/compssUsers.flat", $flat; -} - -sub setSelectedFromCompssList { - my ($packages, $compssUsersChoice, $min_level, $max_size) = @_; - $compssUsersChoice->{TRUE} = 1; #- ensure TRUE is set - my $nb = selectedSize($packages); - foreach my $p (sort { $b->rate <=> $a->rate } @{$packages->{depslist}}) { - my @flags = $p->rflags; - next if - !$p->rate || $p->rate < $min_level || - grep { !grep { /^!(.*)/ ? !$compssUsersChoice->{$1} : $compssUsersChoice->{$_} } split('\|\|') } @flags; - - #- determine the packages that will be selected when - #- selecting $p. the packages are not selected. - my $state = $packages->{state} ||= {}; - $state->{selected} = {}; - $state->{requested} = packageRequest($packages, $p) || {}; - - $packages->resolve_requested($packages->{rpmdb}, $state, no_flag_update => 1, - callback_choices => \&packageCallbackChoices); - - #- this enable an incremental total size. - my $old_nb = $nb; - foreach (keys %{$state->{selected}}) { - my $p = $packages->{depslist}[$_] or next; - $nb += $p->size; - } - if ($max_size && $nb > $max_size) { - $nb = $old_nb; - $min_level = $p->rate; - $state->{requested} = {}; #- ensure no newer package will be selected. - $packages->resolve_requested($packages->{rpmdb}, $state, keep_state => 1); #- FIXME INCOMPLETE TODO - last; - } - - #- do the effective selection (was not done due to no_flag_update option used. - foreach (keys %{$state->{selected}}) { - my $pkg = $packages->{depslist}[$_]; - $state->{selected}{$_} ? $pkg->set_flag_requested : $pkg->set_flag_required; - } - } - log::l("setSelectedFromCompssList: reached size ", formatXiB($nb), ", up to indice $min_level (less than ", formatXiB($max_size), ")"); - log::l("setSelectedFromCompssList: ", join(" ", sort map { $_->name } grep { $_->flag_selected } @{$packages->{depslist}})); - $min_level; -} - -#- usefull to know the size it would take for a given min_level/max_size -#- just saves the selected packages, call setSelectedFromCompssList and restores the selected packages -sub saveSelected { - my ($packages) = @_; - my $state = delete $packages->{state}; - my @l = @{$packages->{depslist}}; - my @flags = map { ($_->flag_requested && 1) + ($_->flag_required && 2) + ($_->flag_upgrade && 4) } @l; - [ $packages, $state, \@l, \@flags ]; -} -sub restoreSelected { - my ($packages, $state, $l, $flags) = @{$_[0]}; - $packages->{state} = $state; - mapn { my ($pkg, $flag) = @_; - $pkg->set_flag_requested($flag & 1); - $pkg->set_flag_required($flag & 2); - $pkg->set_flag_upgrade($flag & 4); - } $l, $flags; -} - -sub computeGroupSize { - my ($packages, $min_level) = @_; - - sub inside { - my ($l1, $l2) = @_; - my $i = 0; - return if @$l1 > @$l2; - foreach (@$l1) { - my $c; - while ($c = $l2->[$i++] cmp $_ ) { - return if $c == 1 || $i > @$l2; - } - } - 1; - } - - sub or_ify { - my ($first, @other) = @_; - my @l = split('\|\|', $first); - foreach (@other) { - @l = map { - my $n = $_; - map { "$_&&$n" } @l; - } split('\|\|'); - } - #- HACK, remove LOCALES & CHARSET, too costly - grep { !/LOCALES|CHARSET/ } @l; - } - sub or_clean { - my (@l) = map { [ sort split('&&') ] } @_ or return ''; - my @r; - B: while (@l) { - my $e = shift @l; - foreach (@r, @l) { - inside($e, $_) and next B; - } - push @r, $e; - } - join("\t", map { join('&&', @$_) } @r); - } - my (%group, %memo); - - foreach my $p (@{$packages->{depslist}}) { - my @flags = $p->rflags; - next if !$p->rate || $p->rate < $min_level; - - my $flags = join("\t", @flags = or_ify(@flags)); - $group{$p->name} = ($memo{$flags} ||= or_clean(@flags)); - - #- determine the packages that will be selected when selecting $p. - #- make a fast selection (but potentially erroneous). - my %newSelection; - unless ($p->flag_available) { - my @l2 = ($p->id); - my $id; - - while (defined($id = shift @l2)) { - exists $newSelection{$id} and next; - $newSelection{$id} = undef; - - my $pkg = $packages->{depslist}[$id]; - foreach ($pkg->requires_nosense) { - my ($candidate_id, $prefer_id); - foreach (keys %{$packages->{provides}{$_} || {}}) { - my $ppkg = $packages->{depslist}[$_] or next; - if ($ppkg->flag_available) { - $candidate_id = undef; - last; - } else { - exists $preferred{$ppkg->name} and $prefer_id = $_; - $ppkg->name =~ /kernel-\d/ and $prefer_id ||= $_; - $candidate_id = $_; - } - } - push @l2, $prefer_id || $candidate_id; - } - } - } - - foreach (keys %newSelection) { - my $p = $packages->{depslist}[$_] or next; - my $s = $group{$p->name} || do { - join("\t", or_ify($p->rflags)); - }; - next if length($s) > 80; # HACK, truncated too complicated expressions, too costly - my $m = "$flags\t$s"; - $group{$p->name} = ($memo{$m} ||= or_clean(@flags, split("\t", $s))); - } - } - my (%sizes, %pkgs); - while (my ($k, $v) = each %group) { - my $pkg = packageByName($packages, $k) or next; - push @{$pkgs{$v}}, $k; - $sizes{$v} += $pkg->size; - } - log::l(sprintf "%s %dMB %s", $_, $sizes{$_} / sqr(1024), join(',', @{$pkgs{$_}})) foreach keys %sizes; - \%sizes, \%pkgs; -} - - -sub openInstallLog { - my ($prefix) = @_; - - my $f = "$prefix/root/drakx/install.log"; - open(LOG, ">> $f") ? log::l("opened $f") : log::l("Failed to open $f. No install log will be kept."); - *LOG or *LOG = log::F() or *LOG = *STDERR; - CORE::select((CORE::select(LOG), $| = 1)[0]); - c::rpmErrorSetCallback(fileno LOG); -#- c::rpmSetVeryVerbose(); -} - -sub closeInstallLog { - log::l("closing install.log file"); - close LOG; -} - -sub rpmDbOpen { - my ($prefix, $rebuild_needed) = @_; - - if ($rebuild_needed) { - if (my $pid = fork()) { - waitpid $pid, 0; - ($? & 0xff00) and die "rebuilding of rpm database failed"; - } else { - log::l("rebuilding rpm database"); - my $rebuilddb_dir = "$prefix/var/lib/rpmrebuilddb.$$"; - -d $rebuilddb_dir and log::l("removing stale directory $rebuilddb_dir"), rm_rf($rebuilddb_dir); - - URPM::DB::rebuild($prefix) or log::l("rebuilding of rpm database failed: ". c::rpmErrorString()), c::_exit(2); - - c::_exit(0); - } - } - - my $db; - if ($db = URPM::DB::open($prefix)) { - log::l("opened rpm database for examining existing packages"); - } else { - log::l("unable to open rpm database, using empty rpm db emulation"); - $db = new URPM; - } - - $db; -} - -sub cleanOldRpmDb { - my ($prefix) = @_; - my $failed; - - foreach (qw(Basenames Conflictname Group Name Packages Providename Requirename Triggername)) { - -s "$prefix/var/lib/rpm/$_" or $failed = 'failed'; - } - #- rebuilding has been successfull, so remove old rpm database if any. - #- once we have checked the rpm4 db file are present and not null, in case - #- of doubt, avoid removing them... - unless ($failed) { - log::l("rebuilding rpm database completed successfully"); - foreach (qw(conflictsindex.rpm fileindex.rpm groupindex.rpm nameindex.rpm packages.rpm - providesindex.rpm requiredby.rpm triggerindex.rpm)) { - -e "$prefix/var/lib/rpm/$_" or next; - log::l("removing old rpm file $_"); - rm_rf("$prefix/var/lib/rpm/$_"); - } - } -} - -sub selectPackagesAlreadyInstalled { - my ($packages, $prefix) = @_; - - log::l("computing installed flags only"); - $packages->compute_installed_flags($packages->{rpmdb}); -} - -sub selectPackagesToUpgrade { - my ($packages, $prefix, $base, $toRemove, $toSave) = @_; - - log::l("selecting packages to upgrade"); - - my $state = $packages->{state} ||= {}; - $state->{selected} = {}; - $state->{requested} = {}; - - $packages->resolve_packages_to_upgrade($packages->{rpmdb}, $state, requested => undef); - $packages->resolve_requested($packages->{rpmdb}, $state, callback_choices => \&packageCallbackChoices); -} - -sub allowedToUpgrade { $_[0] !~ /^(kernel|kernel22|kernel2.2|kernel-secure|kernel-smp|kernel-linus|kernel-linus2.2|hackkernel|kernel-enterprise)$/ } - -sub installTransactionClosure { - my ($packages, $id2pkg) = @_; - my ($id, %closure, @l, $medium, $min_id, $max_id); - - @l = sort { $a <=> $b } keys %$id2pkg; - - #- search first usable medium (sorted by medium ordering). - foreach (sort { $a->{start} <=> $b->{start} } values %{$packages->{mediums}}) { - unless ($_->{selected}) { - #- this medium is not selected, but we have to make sure no package are left - #- in $id2pkg. - foreach ($_->{start} .. $_->{end}) { - delete $id2pkg->{$_}; - } - #- anyway, examine the next one. - next; - } - if ($l[0] <= $_->{end}) { - #- we have a candidate medium, it could be the right one containing - #- the first package of @l... - $l[0] >= $_->{start} and $medium = $_, last; - #- ... but it could be necessary to find the first - #- medium containing package of @l. - foreach $id (@l) { - $id >= $_->{start} && $id <= $_->{end} and $medium = $_, last; - } - $medium and last; - } - } - $medium or return (); #- no more medium usable -> end of installation by returning empty list. - ($min_id, $max_id) = ($medium->{start}, $medium->{end}); - - #- it is sure at least one package will be installed according to medium chosen. - install_any::useMedium($medium->{medium}); - if ($medium->{method} eq 'cdrom') { - my $pkg = $packages->{depslist}[$l[0]]; - - #- force changeCD callback to be called from main process. - install_any::getFile($pkg->filename, $medium->{descr}); - #- close opened handle above. - install_any::getFile('XXX'); - } - - while (defined($id = shift @l)) { - my @l2 = ($id); - - while (defined($id = shift @l2)) { - exists $closure{$id} and next; - $id >= $min_id && $id <= $max_id or next; - $closure{$id} = undef; - - my $pkg = $packages->{depslist}[$id]; - foreach ($pkg->requires_nosense) { - foreach (keys %{$packages->{provides}{$_} || {}}) { - if ($id2pkg->{$_}) { - push @l2, $_; - last; - } - } - } - } - - keys %closure >= $limitMinTrans and last; - } - - map { delete $id2pkg->{$_} } grep { $id2pkg->{$_} } keys %closure; -} - -sub installCallback { -# my $msg = shift; -# log::l($msg .": ". join(',', @_)); -} - -sub install($$$;$$) { - my ($prefix, $isUpgrade, $toInstall, $packages) = @_; - my %packages; - - return if $::g_auto_install || !scalar(@$toInstall); - - #- for root loopback'ed /boot - my $loop_boot = loopback::prepare_boot($prefix); - - #- first stage to extract some important informations - #- about the packages selected. this is used to select - #- one or many transaction. - my ($total, $nb); - foreach my $pkg (@$toInstall) { - $packages{$pkg->id} = $pkg; - $nb++; - $total += to_int($pkg->size); #- do not correct for upgrade! - } - - log::l("pkgs::install $prefix"); - log::l("pkgs::install the following: ", join(" ", map { $_->name } values %packages)); - eval { fs::mount("/proc", "$prefix/proc", "proc", 0) } unless -e "$prefix/proc/cpuinfo"; - - openInstallLog($prefix); - - #- do not modify/translate the message used with installCallback since - #- these are keys during progressing installation, or change in other - #- place (install_steps_gtk.pm,...). - installCallback($packages, 'user', undef, 'install', $nb, $total); - - do { - my @transToInstall = installTransactionClosure($packages, \%packages); - $nb = values %packages; - - #- added to exit typically after last media unselected. - if ($nb == 0 && scalar(@transToInstall) == 0) { - cleanHeaders($prefix); - - loopback::save_boot($loop_boot); - return; - } - - #- extract headers for parent as they are used by callback. - extractHeaders($prefix, \@transToInstall, $packages->{mediums}); - - my ($retry_pkg, $retry_count); - while ($retry_pkg || @transToInstall) { - local (*INPUT, *OUTPUT); pipe INPUT, OUTPUT; - if (my $pid = fork()) { - close OUTPUT; - my $error_msg = ''; - local $_; - while () { - if (/^die:(.*)/) { - $error_msg = $1; - last; - } else { - chomp; - my @params = split ":"; - if ($params[0] eq 'close') { - my $pkg = $packages->{depslist}[$params[1]]; - $pkg->set_flag_installed(1); - $pkg->set_flag_upgrade(0); - } else { - installCallback($packages, @params); - } - } - } - $error_msg and $error_msg .= join('', ); - waitpid $pid, 0; - close INPUT; - $error_msg and die $error_msg; - } else { - #- child process will run each transaction. - $SIG{SEGV} = sub { log::l("segmentation fault on transactions"); c::_exit(0) }; - my @prev_pids = grep { /^\d+$/ } all("/proc"); - my $db; - eval { - close INPUT; - select((select(OUTPUT), $| = 1)[0]); - my $db = URPM::DB::open($prefix, 1) or die "error opening RPM database: ", c::rpmErrorString(); - my $trans = $db->create_transaction($prefix); - if ($retry_pkg) { - log::l("opened rpm database for retry transaction of 1 package only"); - $trans->add($retry_pkg, $isUpgrade && allowedToUpgrade($retry_pkg->name)); - } else { - log::l("opened rpm database for transaction of ". scalar @transToInstall . - " new packages, still $nb after that to do"); - $trans->add($_, $isUpgrade && allowedToUpgrade($_->name)) - foreach @transToInstall; - } - - $trans->order or die "error ordering package list: " . c::rpmErrorString(); - $trans->set_script_fd(fileno LOG); - - log::l("rpm transactions start"); - my @probs = $trans->run($packages, force => 1, nosize => 1, callback_open => sub { - my ($data, $type, $id) = @_; - my $pkg = defined $id && $data->{depslist}[$id]; - my $f = $pkg && $pkg->filename; - print LOG "$f\n"; - #my $fd = install_any::getFile($f, $media->{$p->[$MEDIUM]}{descr}); - my $fd = install_any::getFile($f); - $fd ? fileno $fd : -1; - }, callback_close => sub { - my ($data, $type, $id) = @_; - my $pkg = defined $id && $data->{depslist}[$id] or return; - my $check_installed; - $db->traverse_tag('name', [ $pkg->name ], sub { - my ($p) = @_; - $check_installed ||= $pkg->compare_pkg($p) == 0; - }); - $check_installed and print OUTPUT "close:$id\n"; - }, callback_inst => sub { - my ($data, $type, $id, $subtype, $amount, $total) = @_; - print OUTPUT "$type:$id:$subtype:$amount:$total\n"; - }); - log::l("transactions done, now trying to close still opened fd"); - install_any::getFile('XXX'); #- close still opened fd. - - @probs and die "installation of rpms failed:\n ", join("\n ", @probs); - }; $@ and print OUTPUT "die:$@\n"; - close OUTPUT; - - #- now search for child process which may be locking the cdrom, making it unable to be ejected. - my @allpids = grep { /^\d+$/ } all("/proc"); - my %ppids; - foreach (@allpids) { - cat_("/proc/$_/status") =~ /^PPid:\s+(\d+)/m; - push @{$ppids{$1 || 1}}, $_; - } - my @killpid = difference2(\@allpids, [ @prev_pids, - difference2([ $$, hashtree2list(getppid, \%ppids) ], - [ hashtree2list($$, \%ppids) ]) ]); - - if (@killpid) { - foreach (@killpid) { - my $s = "$_: " . join(' ', split("\0", cat_("/proc/$_/cmdline"))); - log::l("ERROR: DrakX should not have to clean the packages shit. Killing $s"); - } - kill 15, @killpid; - sleep 2; - kill 9, @killpid; - } - - c::_exit(0); - } - - #- if we are using a retry mode, this means we have to split the transaction with only - #- one package for each real transaction. - unless ($retry_pkg) { - my @badPackages; - foreach (@transToInstall) { - if (!$_->flag_installed && packageMedium($packages, $_)->{selected} && !exists($ignoreBadPkg{$_->name})) { - push @badPackages, $_; - log::l("bad package ".$_->fullname); - } else { - $_->free_header; - } - } - @transToInstall = @badPackages; - #- if we are in retry mode, we have to fetch only one package at a time. - $retry_pkg = shift @transToInstall; - $retry_count = 3; - } else { - if (!$retry_pkg->flag_installed && packageMedium($packages, $retry_pkg)->{selected} && !exists($ignoreBadPkg{$retry_pkg->name})) { - if ($retry_count) { - log::l("retrying installing package ".$retry_pkg->fullname." alone in a transaction"); - --$retry_count; - } else { - log::l("bad package ". $retry_pkg->fullname ." unable to be installed"); - $retry_pkg->set_flag_requested(0); - $retry_pkg->set_flag_required(0); - cdie ("error installing package list: ". $retry_pkg->fullname); - } - } - if ($retry_pkg->flag_installed || !$retry_pkg->flag_selected) { - $retry_pkg->free_header; - $retry_pkg = shift @transToInstall; - $retry_count = 3; - } - } - } - cleanHeaders($prefix); - } while ($nb > 0 && !$pkgs::cancel_install); - - closeInstallLog(); - - cleanHeaders($prefix); - - loopback::save_boot($loop_boot); -} - -sub remove($$) { - my ($prefix, $toRemove) = @_; - - return if $::g_auto_install || !@{$toRemove || []}; - - my $db = URPM::DB::open($prefix, 1) or die "error opening RPM database: ", c::rpmErrorString(); - my $trans = $db->create_transaction($prefix); - - foreach my $p (@$toRemove) { - #- stuff remove all packages that matches $p, not a problem since $p has name-version-release format. - $trans->remove($p) if allowedToUpgrade($p); - } - - eval { fs::mount("/proc", "$prefix/proc", "proc", 0) } unless -e "$prefix/proc/cpuinfo"; - - my $callbackOpen = sub { log::l("trying to open file from $_[0] which should not happen"); }; - my $callbackClose = sub { log::l("trying to close file from $_[0] which should not happen"); }; - - #- we are not checking depends since it should come when - #- upgrading a system. although we may remove some functionalities ? - - #- do not modify/translate the message used with installCallback since - #- these are keys during progressing installation, or change in other - #- place (install_steps_gtk.pm,...). - installCallback($db, 'user', undef, 'remove', scalar @$toRemove); - - if (my @probs = $trans->run(undef, force => 1)) { - die "removing of old rpms failed:\n ", join("\n ", @probs); - } - - #- keep in mind removing of these packages by cleaning $toRemove. - @{$toRemove || []} = (); -} - -sub selected_leaves { - my ($packages) = @_; - my @leaves; - - foreach (@{$packages->{depslist}}) { - $_->flag_requested && !$_->flag_base and push @leaves, $_->name; - } - \@leaves; -} - - -sub naughtyServers { - my ($packages) = @_; - - my @old_81 = qw( -freeswan -); - my @old_82 = qw( -vnc-server -postgresql-server -mon -); - - my @new_80 = qw( -jabber -FreeWnn -MySQL -am-utils -apache -boa -cfengine -cups -drakxtools-http -finger-server -imap -leafnode -lpr -ntp -openssh-server -pidentd -postfix -proftpd -rwall -rwho -squid -webmin -wu-ftpd -ypbind -); # nfs-utils-clients portmap - # X server - - my @new_81 = qw( -apache-mod_perl -ftp-server-krb5 -mcserv -samba -telnet-server-krb5 -ypserv -); - - my @new_82 = qw( -LPRng -bind -httpd-naat -ibod -inn -netatalk -nfs-utils -rusers-server -samba-swat -tftp-server -ucd-snmp -); - - my @naughtyServers = (@new_80, @new_81, @new_82); - - grep { - my $p = packageByName($packages, $_); - $p && $p->flag_selected; - } @naughtyServers; -} - -sub hashtree2list { - my ($e, $h) = @_; - my @l; - my @todo = $e; - while (@todo) { - my $e = shift @todo; - push @l, $e; - push @todo, @{$h->{$e}}; - } - @l; -} - -1; -- cgit v1.2.1