diff options
Diffstat (limited to 'mdk-stage1')
0 files changed, 0 insertions, 0 deletions
![]() |
index : drakx | |
Mageia Installer and base platform for many utilities | Thierry Vignaud [tv] |
summaryrefslogtreecommitdiffstats |
package pkgs; # $Id$
use strict;
use MDK::Common::System;
use URPM;
use URPM::Resolve;
use URPM::Signature;
use common;
use install_any;
use run_program;
use detect_devices;
use log;
use fs;
use loopback;
use c;
our %preferred = map { $_ => undef } qw(lilo perl-base gstreamer-oss openjade ctags glibc curl sane-backends postfix mdkkdm gcc gcc-cpp gcc-c++ proftpd ghostscript-X vim-minimal kernel db1 db2 libxpm4 zlib1 libncurses5 harddrake cups apache);
#- lower bound on the left ( aka 90 means [90-100[ )
our %compssListDesc = (
5 => N_("must have"),
4 => N_("important"),
3 => N_("very nice"),
2 => N_("nice"),
1 => N_("maybe"),
);
#- constant for small transaction.
our $limitMinTrans = 13;
#- 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}}) {
defined $_->{start} && defined $_->{end} or next;
$p->id >= $_->{start} && $p->id <= $_->{end} and return $_;
}
return {};
}
sub cleanHeaders() {
rm_rf("$::prefix/tmp/headers") if -e "$::prefix/tmp/headers";
}
#- get all headers from an hdlist file.
sub extractHeaders {
my ($pkgs, $media) = @_;
my %medium2pkgs;
cleanHeaders();
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;
log::l("read header file $f");
}
}
sub isSupplCDMedium($) {
my ($medium) = @_;
$medium->{method} eq 'cdrom' && $medium->{medium} =~ /^\d+s$/;
}
#- TODO BEFORE TODO
#- size and correction size functions for packages.
my $B = 1.20873;
my $C = 4.98663; #- does not 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;
my %skip;
#- take care of packages selected...
foreach (@{$packages->{depslist}}) {
if ($_->flag_selected) {
$size += $_->size;
#- if a package is obsoleted with the same name it should
#- have been selected, so a selected new package obsoletes
#- all the old package.
exists $skip{$_->name} and next; $skip{$_->name} = undef;
$size -= $packages->{sizes}{$_->name};
}
}
#- but remove size of package being obsoleted or removed.
foreach (keys %{$packages->{state}{rejected}}) {
my ($name) = /(.*)-[^\-]*-[^\-]*$/ or next;
exists $skip{$name} and next; $skip{$name} = undef;
$size -= $packages->{sizes}{$name};
}
$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;
}
}
sub packagesProviding {
my ($packages, $name) = @_;
map { $packages->{depslist}[$_] } keys %{$packages->{provides}{$name} || {}};
}
#- 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 my $pkg (packagesProviding($packages, $name)) {
$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'");
$best;
}
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 analyse_kernel_name {
my $kernels = join('|', map { "-$_" }
'(p3|i586|i686)-(up|smp)-(1GB|4GB|64GB)',
qw(enterprise secure smp multimedia multimedia-smp xbox),
);
my @l = $_[0] =~ /kernel[^\-]*($kernels)?(-([^\-]+))?$/ or return;
$l[0], $l[-1];
}
sub packages2kernels {
my ($packages) = @_;
map {
if (my ($ext, $version) = analyse_kernel_name($_->name)) {
{ pkg => $_, ext => $ext, version => $version };
} else {
log::l("ERROR: unknown package " . $_->name . " providing kernel");
();
}
} packagesProviding($packages, 'kernel');
}
sub bestKernelPackage {
my ($packages) = @_;
my @kernels = packages2kernels($packages) or internal_error('no kernel available');
my ($version_BOOT) = c::kernel_version() =~ /^(\d+\.\d+)/;
if (my @l = grep { $_->{version} =~ /\Q$version_BOOT/ } @kernels) {
#- favour versions corresponding to current BOOT version
@kernels = @l;
}
my @prefered_exts =
is_xbox() ? '-xbox' :
detect_devices::is_i586() ? '-i586-up-1GB' :
!detect_devices::has_cpu_flag('pae') ? '-i686-up-4GB' :
detect_devices::BIGMEM() ? ('-enterprise', '-smp') :
detect_devices::hasSMP() ? '-smp' :
'';
foreach my $prefered_ext (@prefered_exts, '') {
if (my @l = grep { $_->{ext} eq $prefered_ext } @kernels) {
@kernels = @l;
}
}
log::l("bestKernelPackage (" . join(':', @prefered_exts) . "): " . join(' ', map { $_->{pkg}->name } @kernels) . (@kernels > 1 ? ' (choosing the first)' : ''));
$preferred{'kernel-source-' . $kernels[0]{version}} = undef;
$kernels[0]{pkg};
}
sub packagesOfMedium {
my ($packages, $medium) = @_;
defined $medium->{start} && defined $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_name) = @_;
$packages->{mediums}{$medium_name}{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) = @_;
if (my $prefer = find { $_->arch ne 'src' && exists $preferred{$_->name} } @$choices) {
$prefer;
} else {
my @l = grep {
#- or even if a package requires a specific locales which
#- is already selected.
find {
/locales-/ && do {
my $p = packageByName($urpm, $_);
$p && $p->flag_available;
};
} $_->requires_nosense;
} @$choices;
if (!@l) {
push @l, $choices->[0];
log::l("packageCallbackChoices: default choice from ", join(",", map { $urpm->{depslist}[$_]->name } keys %{$state->{selected}}), " in ", join(",", map { $_->name } @$choices));
}
#-log::l("packageCallbackChoices: chosen " . join(" ", map { $_->name } @l));
@l;
}
}
#- selection, unselection of package.
sub selectPackage {
my ($packages, $pkg, $b_base, $o_otherOnly) = @_;
#- select package and dependancies, o_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} ||= {};
my @l = $packages->resolve_requested($packages->{rpmdb}, $state, packageRequest($packages, $pkg) || {},
callback_choices => \&packageCallbackChoices);
if ($b_base || $o_otherOnly) {
foreach (@l) {
$b_base and $_->set_flag_base;
$o_otherOnly and $o_otherOnly->{$_->id} = $_->flag_requested;
}
$o_otherOnly and $packages->disable_selected($packages->{rpmdb}, $state, @l);
}
1;
}
sub unselectPackage($$;$) {
my ($packages, $pkg, $o_otherOnly) = @_;
#- base package are not unselectable,
#- and already unselected package are no more unselectable.
$pkg->flag_base and return;
$pkg->flag_selected or return;
my $state = $packages->{state} ||= {};
log::l("removing selection on package " . $pkg->fullname);
my @l = $packages->disable_selected($packages->{rpmdb}, $state, $pkg);
log::l(" removed selection on package " . $pkg->fullname . "gives " . join(',', map { scalar $_->fullname } @l));
if ($o_otherOnly) {
foreach (@l) {
$o_otherOnly->{$_->id} = undef;
}
log::l(" reselecting removed selection...");
$packages->resolve_requested($packages->{rpmdb}, $state, $o_otherOnly, callback_choices => \&packageCallbackChoices);
log::l(" done");
}
1;
}
sub setPackageSelection($$$) {
my ($packages, $pkg, $value) = @_;
$value ? selectPackage($packages, $pkg) : unselectPackage($packages, $pkg);
}
sub unselectAllPackages($) {
my ($packages) = @_;
my %keep_selected;
log::l("unselecting all packages...");
foreach (@{$packages->{depslist}}) {
if ($_->flag_base || $_->flag_installed && $_->flag_selected) {
#- keep track of package that should be kept selected.
$keep_selected{$_->id} = $_;
log::l("...keeping " . $_->fullname);
} else {
#- deselect all packages except base or packages that need to be upgraded.
$_->set_flag_required(0);
$_->set_flag_requested(0);
}
}
#- clean staten, in order to start with a brand new set...
$packages->{state} = {};
$packages->resolve_requested($packages->{rpmdb}, $packages->{state}, \%keep_selected,
callback_choices => \&packageCallbackChoices);
}
sub urpmidir() {
my $v = "$::prefix/var/lib/urpmi";
-l $v && !-e _ and unlink $v and mkdir $v, 0755; #- dangling symlink
-w $v ? $v : '/tmp';
}
sub psUpdateHdlistsDeps {
my ($packages) = @_;
my $need_copy = 0;
my $urpmidir = urpmidir();
#- check if current configuration is still up-to-date and do not need to be updated.
foreach (values %{$packages->{mediums}}) {
$_->{selected} || $_->{ignored} or next;
my $hdlistf = "$urpmidir/hdlist.$_->{fakemedium}.cz" . ($_->{hdlist} =~ /\.cz2/ && "2");
my $synthesisf = "$urpmidir/synthesis.hdlist.$_->{fakemedium}.cz" . ($_->{hdlist} =~ /\.cz2/ && "2");
if (-s $hdlistf != $_->{hdlist_size}) {
install_any::getAndSaveFile("media/media_info/$_->{hdlist}", $hdlistf) or die "no $_->{hdlist} found";
symlinkf $hdlistf, "/tmp/$_->{hdlist}";
++$need_copy;
chown 0, 0, $hdlistf;
}
if (-s $synthesisf != $_->{synthesis_hdlist_size}) {
install_any::getAndSaveFile("media/media_info/synthesis.$_->{hdlist}", $synthesisf);
if (-s $synthesisf > 0) { chown 0, 0, $synthesisf } else { unlink $synthesisf }
}
}
if ($need_copy) {
#- this is necessary for urpmi.
install_any::getAndSaveFile("media/media_info/$_", "$urpmidir/$_") && chown 0, 0, "$urpmidir/$_" foreach qw(rpmsrate);
}
}
sub psUsingHdlists {
my ($o, $method, $o_hdlistsprefix, $o_packages, $o_initialmedium, $o_callback) = @_;
my $is_ftp = $o_hdlistsprefix =~ /^ftp:/;
my $listf = install_any::getFile($o_hdlistsprefix && !$is_ftp ? "$o_hdlistsprefix/media/media_info/hdlists" : 'media/media_info/hdlists')
or die "no hdlists found";
my ($suppl_CDs, $deselectionAllowed) = ($o->{supplmedia} || 0, $o->{askmedia} || 0);
if (!$o_packages) {
$o_packages = new URPM;
#- add additional fields used by DrakX.
@$o_packages{qw(count mediums)} = (0, {});
}
#- parse hdlists file.
my $medium_name = $o_initialmedium || 1;
my (@hdlists, %mediumsize);
foreach (<$listf>) {
chomp;
s/\s*#.*$//;
/^\s*$/ and next;
#- we'll ask afterwards for supplementary CDs, if the hdlists file contains
#- a line that begins with "suppl"
if (/^suppl/) { $suppl_CDs = 1; next }
#- if the hdlists contains a line "askmedia", deletion of media found
#- in this hdlist is allowed
if (/^askmedia/) { $deselectionAllowed = 1; next }
my $cdsuppl = index($medium_name, 's') >= 0;
my ($noauto, $hdlist, $rpmsdir, $descr, $size) = m/^\s*(noauto:)?(hdlist\S*\.cz2?)\s+(\S+)\s*([^(]*)(\(.+\))?$/
or die qq(invalid hdlist description "$_" in hdlists file);
$descr =~ s/\s+$//;
push @hdlists, [ $hdlist, $medium_name, $rpmsdir, $descr, !$noauto,
#- hdlist path, suppl CDs are mounted on /mnt/cdrom :
$o_hdlistsprefix ? ($is_ftp ? "media/media_info/$hdlist" : "$o_hdlistsprefix/media/media_info/$hdlist") : undef,
];
if ($size) {
($mediumsize{$hdlist}) = $size =~ /(\d+)/; #- XXX assume Mo
} else {
$mediumsize{$hdlist} = 0;
}
$cdsuppl ? ($medium_name = ($medium_name + 1) . 's') : ++$medium_name;
}
my $copy_rpms_on_disk = 0;
if ($deselectionAllowed && !defined $o_initialmedium) {
(my $finalhdlists, $copy_rpms_on_disk) = $o->deselectFoundMedia(\@hdlists, \%mediumsize);
@hdlists = @$finalhdlists;
}
foreach my $h (@hdlists) {
#- make sure the first medium is always selected!
#- by default select all image.
my $supplmedium = psUsingHdlist($method, $o_packages, @$h);
$o_callback and $o_callback->($supplmedium, $o_hdlistsprefix, $method);
}
log::l("psUsingHdlists read " . int(@{$o_packages->{depslist}}) .
" headers on " . int(keys %{$o_packages->{mediums}}) . " hdlists");
return $o_packages, $suppl_CDs, $copy_rpms_on_disk;
}
sub psUsingHdlist {
my ($method, $packages, $hdlist, $medium_name, $rpmsdir, $descr, $selected, $o_fhdlist, $o_pubkey, $o_nocopy) = @_;
my $fakemedium = "$descr ($method$medium_name)";
my $urpmidir = urpmidir();
log::l("trying to read $hdlist for medium $medium_name");
my $m = { hdlist => $hdlist,
method => $method,
medium => $medium_name,
rpmsdir => $rpmsdir, #- where is RPMS directory.
descr => $descr,
fakemedium => $fakemedium,
selected => $selected, #- default value is only CD1, it is really the minimal.
ignored => !$selected, #- keep track of ignored medium by DrakX.
pubkey => [], #- all pubkey block here
};
#- copy hdlist file directly to urpmi directory, this will be used
#- for getting header of package during installation or after by urpmi.
my $newf = "$urpmidir/hdlist.$fakemedium.cz" . ($hdlist =~ /\.cz2/ && "2");
unless ($o_nocopy) {
my $w_wait;
$w_wait = $::o->wait_message(N("Please wait"), N("Downloading file %s...", $hdlist)) if $::o->{method} =~ /^(?:ftp|http|nfs)$/;
-e $newf and do { unlink $newf or die "cannot remove $newf: $!" };
install_any::getAndSaveFile($o_fhdlist || "media/media_info/$hdlist", $newf) or do { unlink $newf; die "no $hdlist found" };
$m->{hdlist_size} = -s $newf; #- keep track of size for post-check.
symlinkf $newf, "/tmp/$hdlist";
undef $w_wait;
}
my $newsf = "$urpmidir/synthesis.hdlist.$fakemedium.cz" . ($hdlist =~ /\.cz2/ && "2");
#- if $o_fhdlist is a filehandle, it's preferable not to try to find the associated synthesis.
if (!$o_nocopy && !ref $o_fhdlist) {
#- copy existing synthesis file too.
my $synth;
if ($o_fhdlist) {
$synth = $o_fhdlist;
$synth =~ s/hdlist/synthesis.hdlist/ or $synth = undef;
}
$synth ||= "media/media_info/synthesis.$hdlist";
install_any::getAndSaveFile($synth, $newsf);
$m->{synthesis_hdlist_size} = -s $newsf; #- keep track of size for post-check.
-s $newsf > 0 or unlink $newsf;
}
chown 0, 0, $newf, $newsf;
#- get all keys corresponding in the right pubkey file,
#- they will be added in rpmdb later if not found.
if (!$o_fhdlist || $o_pubkey) {
$m->{pubkey} = $o_pubkey;
unless ($m->{pubkey}) {
my $pubkey = install_any::getFile("media/media_info/pubkey" . ($hdlist =~ /hdlist(\S*)\.cz2?/ && $1));
$m->{pubkey} = [ $packages->parse_armored_file($pubkey) ];
}
}
#- integrate medium in media list, only here to avoid download error (update) to be propagated.
$packages->{mediums}{$medium_name} = $m;
#- parse synthesis (if available) of directly hdlist (with packing).
if ($m->{ignored}) {
log::l("ignoring packages in $hdlist");
} else {
my $nb_suppl_pkg_skipped = 0;
my $callback = sub {
my (undef, $p) = @_;
our %uniq_pkg_seen;
if ($uniq_pkg_seen{$p->fullname}++) {
log::l("skipping " . scalar $p->fullname);
++$nb_suppl_pkg_skipped;
return 0;
} else {
return 1;
}
};
if (-s $newsf) {
($m->{start}, $m->{end}) = $packages->parse_synthesis($newsf, callback => $callback);
} elsif (-s $newf) {
($m->{start}, $m->{end}) = $packages->parse_hdlist($newf, callback => $callback);
} else {
delete $packages->{mediums}{$medium_name};
unlink $newf;
$o_fhdlist or unlink $newsf;
die "fatal: no hdlist nor synthesis to read for $fakemedium";
}
$m->{start} > $m->{end} and do { delete $packages->{mediums}{$medium_name};
unlink $newf;
$o_fhdlist or unlink $newsf;
die "fatal: nothing read in hdlist or synthesis for $fakemedium" };
log::l("read " . ($m->{end} - $m->{start} + 1) . " packages in $hdlist, $nb_suppl_pkg_skipped skipped");
}
$m;
}
sub read_rpmsrate_raw {
my ($f) = @_;
my $line_nb = 0;
my $fatal_error;
my (%flags, %rates, @need_to_copy);
my (@l);
local $_;
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[-1][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,) {}
push @m, $flag;
push @l2, [ length $indent, [ @m ] ];
$indent .= $t;
}
if ($data) {
# has packages on same line
my ($rates, $flags) = partition { /^\d$/ } @m;
my ($rate) = @$rates or die sprintf qq(missing rate for "%s" at line %d (flags are %s)\n), $data, $line_nb, join('&&', @m);
foreach my $name (split ' ', $data) {
if (member('INSTALL', @$flags)) {
push @need_to_copy, $name if !member('NOCOPY', @$flags);
next; #- do not need to put INSTALL flag for a package.
}
if (member('PRINTER', @$flags)) {
push @need_to_copy, $name;
}
my @new_flags = @$flags;
if (my $previous = $flags{$name}) {
my @common = intersection($flags, $previous);
my @diff1 = difference2($flags, \@common);
my @diff2 = difference2($previous, \@common);
if (!@diff1 || !@diff2) {
@new_flags = @common;
} elsif (@diff1 == 1 && @diff2 == 1) {
@new_flags = (@common, join('||', $diff1[0], $diff2[0]));
} else {
log::l("can not handle complicate flags for packages appearing twice ($name)");
$fatal_error++;
}
log::l("package $name appearing twice with different rates ($rate != " . $rates{$name} . ")") if $rate != $rates{$name};
}
$rates{$name} = $rate;
$flags{$name} = \@new_flags;
}
push @l, @l2;
} else {
push @l, [ $l2[0][0], $l2[-1][1] ];
}
}
$fatal_error and die "$fatal_error fatal errors in rpmsrate";
\%rates, \%flags, \@need_to_copy;
}
sub read_rpmsrate {
my ($packages, $rpmsrate_flags_chosen, $f) = @_;
my ($rates, $flags, $need_to_copy) = read_rpmsrate_raw($f);
foreach (keys %$flags) {
my $p = packageByName($packages, $_) or next;
my @flags = (@{$flags->{$_}}, map { if_(/locales-(.*)/, qq(LOCALES"$1")) } $p->requires_nosense);
@flags = map {
my ($user_flags, $known_flags) = partition { /^!?CAT_/ } split('\|\|', $_);
my $ok = find {
my $inv = s/^!//;
$inv xor do {
if (my ($p) = /^HW"(.*)"/) {
detect_devices::matching_desc__regexp($p);
} elsif (($p) = /^DRIVER"(.*)"/) {
detect_devices::matching_driver__regexp($p);
} elsif (($p) = /^TYPE"(.*)"/) {
detect_devices::matching_type($p);
} else {
$rpmsrate_flags_chosen->{$_};
}
};
} @$known_flags;
$ok ? 'TRUE' : @$user_flags ? join('||', @$user_flags) : 'FALSE';
} @flags;
$p->set_rate($rates->{$_});
$p->set_rflags(member('FALSE', @flags) ? 'FALSE' : @flags);
}
$packages->{needToCopy} = $need_to_copy;
}
sub readCompssUsers {
my ($file) = @_;
my $f = install_any::getFile($file)
or do { log::l("can not find $file: $!"); return (undef, undef) };
my ($compssUsers, $gtk_display_compssUsers) = eval join('', <$f>);
if ($@) {
log::l("ERROR: bad $file: $@");
} else {
log::l("compssUsers.pl got: ", join(', ', map { qq("$_->{path}|$_->{label}") } @$compssUsers));
}
($compssUsers, $gtk_display_compssUsers);
}
sub saveCompssUsers {
my ($packages, $compssUsers) = @_;
my $flat;
foreach (@$compssUsers) {
my %fl = map { ("CAT_$_" => 1) } @{$_->{flags}};
$flat .= "$_->{label} [icon=xxx] [path=$_->{path}]\n";
foreach my $p (@{$packages->{depslist}}) {
my @flags = $p->rflags;
if ($p->rate && any { any { !/^!/ && $fl{$_} } split('\|\|') } @flags) {
$flat .= sprintf "\t%d %s\n", $p->rate, $p->name;
}
}
}
my $urpmidir = urpmidir();
output "$urpmidir/compssUsers.flat", $flat;
}
sub setSelectedFromCompssList {
my ($packages, $rpmsrate_flags_chosen, $min_level, $max_size) = @_;
$rpmsrate_flags_chosen->{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 ||
any { !any { /^!(.*)/ ? !$rpmsrate_flags_chosen->{$1} : $rpmsrate_flags_chosen->{$_} } split('\|\|') } @flags;
#- determine the packages that will be selected when
#- selecting $p. the packages are not selected.
my $state = $packages->{state} ||= {};
my @l = $packages->resolve_requested($packages->{rpmdb}, $state, packageRequest($packages, $p) || {},
callback_choices => \&packageCallbackChoices);
#- this enable an incremental total size.
my $old_nb = $nb;
foreach (@l) {
$nb += $_->size;
}
if ($max_size && $nb > $max_size) {
$nb = $old_nb;
$min_level = $p->rate;
$packages->disable_selected($packages->{rpmdb}, $state, @l);
last;
}
}
my @flags = map_each { if_($::b, $::a) } %$rpmsrate_flags_chosen;
log::l("setSelectedFromCompssList: reached size ", formatXiB($nb), ", up to indice $min_level (less than ", formatXiB($max_size), ") for flags ", join(' ', sort @flags));
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('\|\|');
}
@l;
}
my %or_ify_cache;
my $or_ify_cached = sub {
$or_ify_cache{$_[0]} ||= join("\t", or_ify(split("\t", $_[0])));
};
sub or_clean {
my ($flags) = @_;
my @l = split("\t", $flags);
@l = map { [ sort split('&&') ] } @l;
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, $slowpart_counter);
log::l("pkgs::computeGroupSize");
my $time = time();
my %pkgs_with_same_rflags;
foreach (@{$packages->{depslist}}) {
next if !$_->rate || $_->rate < $min_level || $_->flag_available;
my $flags = join("\t", $_->rflags);
next if $flags eq 'FALSE';
push @{$pkgs_with_same_rflags{$flags}}, $_;
}
foreach my $raw_flags (keys %pkgs_with_same_rflags) {
my $flags = $or_ify_cached->($raw_flags);
my @pkgs = @{$pkgs_with_same_rflags{$raw_flags}};
#- determine the packages that will be selected when selecting $p.
#- make a fast selection (but potentially erroneous).
#- installed and upgrade flags must have been computed (see compute_installed_flags).
my %newSelection;
my @l2 = map { $_->id } @pkgs;
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 @choices = keys %{$packages->{provides}{$_} || {}};
if (@choices <= 1) {
push @l2, @choices;
} elsif (! find { exists $newSelection{$_} } @choices) {
my ($candidate_id, $prefer_id);
foreach (@choices) {
++$slowpart_counter;
my $ppkg = $packages->{depslist}[$_] or next;
$ppkg->flag_available and $prefer_id = $candidate_id = undef, last;
exists $preferred{$ppkg->name} and $prefer_id = $_;
$ppkg->name =~ /kernel-\d/ and $prefer_id ||= $_;
foreach my $l ($ppkg->requires_nosense) {
/locales-/ or next;
my $pppkg = packageByName($packages, $l) or next;
$pppkg->flag_available and $prefer_id ||= $_;
}
$candidate_id = $_;
}
if (defined $prefer_id || defined $candidate_id) {
push @l2, defined $prefer_id ? $prefer_id : $candidate_id;
}
}
}
}
foreach (keys %newSelection) {
my $p = $packages->{depslist}[$_] or next;
next if $p->flag_selected; #- always installed (accounted in system_size)
my $s = $group{$p->name} || $or_ify_cached->(join("\t", $p->rflags));
my $m = "$flags\t$s";
$group{$p->name} = ($memo{$m} ||= or_clean($m));
}
}
my (%sizes, %pkgs);
while (my ($k, $v) = each %group) {
my $pkg = packageByName($packages, $k) or next;
push @{$pkgs{$v}}, $k;
$sizes{$v} += $pkg->size - $packages->{sizes}{$pkg->name};
}
log::l("pkgs::computeGroupSize took: ", formatTimeRaw(time() - $time));
log::l(sprintf "%s %dMB %s", $_, $sizes{$_} / sqr(1024), join(',', @{$pkgs{$_}})) foreach keys %sizes;
\%sizes, \%pkgs;
}
sub openInstallLog() {
my $f = "$::prefix/root/drakx/install.log";
open(my $LOG, ">> $f") ? log::l("opened $f") : log::l("Failed to open $f. No install log will be kept."); #-#
CORE::select((CORE::select($LOG), $| = 1)[0]);
c::rpmErrorSetCallback(fileno $LOG);
#- c::rpmSetVeryVerbose();
$LOG;
}
sub rpmDbOpen {
my ($o_rebuild_needed) = @_;
if ($o_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 rpmDbOpenForInstall() {
#- there is a bug in rpm 4.2 where all operations for accessing rpmdb files are not
#- always done using prefix, we need to setup a symlink in /var/lib/rpm for that ...
if (! -d '/var/lib/rpm') {
mkdir_p('/var/lib');
symlinkf "$::prefix/var/lib/rpm", "/var/lib/rpm";
}
my $db = URPM::DB::open($::prefix, 1);
$db and log::l("opened rpmdb for writing in $::prefix");
$db;
}
sub cleanOldRpmDb() {
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) = @_;
log::l("computing installed flags and size of installed packages");
$packages->{sizes} = $packages->compute_installed_flags($packages->{rpmdb});
}
sub selectPackagesToUpgrade {
my ($packages, $o_medium) = @_;
#- check before that if medium is given, it should be valid.
$o_medium && (! defined $o_medium->{start} || ! defined $o_medium->{end}) and return;
log::l("selecting packages to upgrade");
my $state = $packages->{state} ||= {};
$state->{selected} = {};
my %selection;
$packages->request_packages_to_upgrade($packages->{rpmdb}, $state, \%selection,
requested => undef,
$o_medium ? (start => $o_medium->{start}, end => $o_medium->{end}) : (),
);
log::l("resolving dependencies...");
$packages->resolve_requested($packages->{rpmdb}, $state, \%selection,
callback_choices => \&packageCallbackChoices);
log::l("...done");
}
sub allowedToUpgrade { $_[0] !~ /^(kernel|kernel22|kernel2.2|kernel-secure|kernel-smp|kernel-linus|kernel-linus2.2|hackkernel|kernel-enterprise)$/ }