/* * solver3.cc - The APT 3.0 solver * * Copyright (c) 2023 Julian Andres Klode * Copyright (c) 2023 Canonical Ltd * * SPDX-License-Identifier: GPL-2.0+ * * This solver started from scratch but turns slowly into a variant of * MiniSat as documented in the paper * "An extensible SAT-solver [extended version 1.2]." * by Niklas Eén, and Niklas Sörensson. * * It extends MiniSAT with support for optional clauses, and differs * in that it removes non-deterministic aspects like the activity based * ordering. Instead it uses a more nuanced static ordering that, to * some extend, preserves some greediness and sub-optimality of the * classic APT solver. */ #define APT_COMPILING_APT #include #include #include #include #include #include #include #include #include #include #include #include #include // FIXME: Helpers stolen from DepCache, please give them back. struct APT::Solver::CompareProviders3 /*{{{*/ { pkgCache &Cache; pkgDepCache::Policy &Policy; pkgCache::PkgIterator const Pkg; APT::Solver &Solver; pkgCache::VerIterator bestVersion(pkgCache::PkgIterator pkg) { pkgCache::VerIterator res = pkg.VersionList(); for (auto v = res; not v.end(); ++v) res = std::max(res, v, *this); return res; } bool operator()(Var a, Var b) { pkgCache::VerIterator va = a.Ver(Cache); pkgCache::VerIterator vb = b.Ver(Cache); if (auto pa = a.Pkg(Cache)) va = bestVersion(pa); if (auto pb = b.Pkg(Cache)) vb = bestVersion(pb); assert(not va.end() && not vb.end()); return (*this)(va, vb); } bool operator()(pkgCache::VerIterator const &AV, pkgCache::VerIterator const &BV) { assert(not AV.end() && not BV.end()); pkgCache::PkgIterator const A = AV.ParentPkg(); pkgCache::PkgIterator const B = BV.ParentPkg(); // Compare versions for the same package. FIXME: Move this to the real implementation if (A == B) { if (AV == BV) return false; // Candidate wins in upgrade scenario if (Solver.IsUpgrade) { auto Cand = Solver.GetCandidateVer(A); if (AV == Cand || BV == Cand) return (AV == Cand); } // Installed version wins otherwise if (A.CurrentVer() == AV || B.CurrentVer() == BV) return (A.CurrentVer() == AV); // Rest is ordered list, first by priority if (auto pinA = Solver.GetPriority(AV), pinB = Solver.GetPriority(BV); pinA != pinB) return pinA > pinB; // Then by version return _system->VS->CmpVersion(AV.VerStr(), BV.VerStr()) > 0; } // Try obsolete choices only after exhausting non-obsolete choices such that we install // packages replacing them and don't keep back upgrades depending on the replacement to // keep the obsolete package installed. if (Solver.IsUpgrade) if (auto obsoleteA = Solver.Obsolete(A), obsoleteB = Solver.Obsolete(B); obsoleteA != obsoleteB) return obsoleteB; // Prefer MA:same packages if other architectures for it are installed if ((AV->MultiArch & pkgCache::Version::Same) == pkgCache::Version::Same || (BV->MultiArch & pkgCache::Version::Same) == pkgCache::Version::Same) { bool instA = false; if ((AV->MultiArch & pkgCache::Version::Same) == pkgCache::Version::Same) { pkgCache::GrpIterator Grp = A.Group(); for (pkgCache::PkgIterator P = Grp.PackageList(); P.end() == false; P = Grp.NextPkg(P)) if (P->CurrentVer != 0) { instA = true; break; } } bool instB = false; if ((BV->MultiArch & pkgCache::Version::Same) == pkgCache::Version::Same) { pkgCache::GrpIterator Grp = B.Group(); for (pkgCache::PkgIterator P = Grp.PackageList(); P.end() == false; P = Grp.NextPkg(P)) { if (P->CurrentVer != 0) { instB = true; break; } } } if (instA != instB) return instA; } if ((A->CurrentVer == 0 || B->CurrentVer == 0) && A->CurrentVer != B->CurrentVer) return A->CurrentVer != 0; // Prefer packages in the same group as the target; e.g. foo:i386, foo:amd64 if (A->Group != B->Group) { if (A->Group == Pkg->Group && B->Group != Pkg->Group) return true; else if (B->Group == Pkg->Group && A->Group != Pkg->Group) return false; } // we like essentials if ((A->Flags & pkgCache::Flag::Essential) != (B->Flags & pkgCache::Flag::Essential)) { if ((A->Flags & pkgCache::Flag::Essential) == pkgCache::Flag::Essential) return true; else if ((B->Flags & pkgCache::Flag::Essential) == pkgCache::Flag::Essential) return false; } if ((A->Flags & pkgCache::Flag::Important) != (B->Flags & pkgCache::Flag::Important)) { if ((A->Flags & pkgCache::Flag::Important) == pkgCache::Flag::Important) return true; else if ((B->Flags & pkgCache::Flag::Important) == pkgCache::Flag::Important) return false; } // prefer native architecture if (strcmp(A.Arch(), B.Arch()) != 0) { if (strcmp(A.Arch(), A.Cache()->NativeArch()) == 0) return true; else if (strcmp(B.Arch(), B.Cache()->NativeArch()) == 0) return false; std::vector archs = APT::Configuration::getArchitectures(); for (std::vector::const_iterator a = archs.begin(); a != archs.end(); ++a) if (*a == A.Arch()) return true; else if (*a == B.Arch()) return false; } // higher priority seems like a good idea if (AV->Priority != BV->Priority) return AV->Priority < BV->Priority; if (auto NameCmp = strcmp(A.Name(), B.Name())) return NameCmp < 0; // unable to decide… return A->ID > B->ID; } }; /** \brief Returns \b true for packages matching a regular * expression in APT::NeverAutoRemove. */ class DefaultRootSetFunc2 : public pkgDepCache::DefaultRootSetFunc { std::unique_ptr Kernels; public: DefaultRootSetFunc2(pkgCache *cache) : Kernels(APT::KernelAutoRemoveHelper::GetProtectedKernelsFilter(cache)) {}; ~DefaultRootSetFunc2() override = default; bool InRootSet(const pkgCache::PkgIterator &pkg) override { return pkg.end() == false && ((*Kernels)(pkg) || DefaultRootSetFunc::InRootSet(pkg)); }; }; // FIXME: DEDUP with pkgDepCache. /*}}}*/ APT::Solver::Solver(pkgCache &cache, pkgDepCache::Policy &policy) : cache(cache), policy(policy), rootState(new State), pkgStates(cache), verStates(cache), pkgObsolete(cache), priorities(cache), candidates(cache) { // Ensure trivially static_assert(std::is_trivially_destructible_v); static_assert(std::is_trivially_destructible_v); static_assert(sizeof(APT::Solver::Var) == sizeof(map_pointer)); static_assert(sizeof(APT::Solver::Var) == sizeof(map_pointer)); // Root state is "true". rootState->decision = Decision::MUST; } // This function determines if a work item is less important than another. bool APT::Solver::Work::operator<(APT::Solver::Work const &b) const { if ((not clause->optional && size < 2) != (not b.clause->optional && b.size < 2)) return not b.clause->optional && b.size < 2; if (clause->optional != b.clause->optional) return clause->optional; if (clause->group != b.clause->group) return clause->group > b.clause->group; if ((size < 2) != (b.size < 2)) return b.size < 2; if (size == 1 && b.size == 1) // Special case: 'shortcircuit' optional packages return clause->solutions.size() < b.clause->solutions.size(); return false; } std::string APT::Solver::Clause::toString(pkgCache &cache) const { std::string out; if (auto Pkg = reason.Pkg(cache); not Pkg.end()) out.append(Pkg.FullName()); if (auto Ver = reason.Ver(cache); not Ver.end()) out.append(Ver.ParentPkg().FullName()).append("=").append(Ver.VerStr()); out.append(" -> "); for (auto var : solutions) out.append(" | ").append(var.toString(cache)); return out; } std::string APT::Solver::Work::toString(pkgCache &cache) const { std::ostringstream out; if (erased) out << "Erased "; if (clause->optional) out << "Optional "; out << "Item (" << ssize_t(size <= clause->solutions.size() ? size : -1) << "@" << depth << ") "; out << clause->toString(cache); return out.str(); } // Prints an implication graph part of the form A -> B -> C, possibly with "not" std::string APT::Solver::WhyStr(Var reason) const { std::vector out; while (not reason.empty()) { if ((*this)[reason].decision == Decision::MUSTNOT) out.push_back(std::string("not ") + reason.toString(cache)); else out.push_back(reason.toString(cache)); reason = (*this)[reason].reason; } std::string outstr; for (auto I = out.rbegin(); I != out.rend(); ++I) { outstr += (outstr.size() == 0 ? "" : " -> ") + *I; } return outstr; } // This is essentially asking whether any other binary in the source package has a higher candidate // version. This pretends that each package is installed at the same source version as the package // under consideration. bool APT::Solver::ObsoletedByNewerSourceVersion(pkgCache::VerIterator cand) const { const auto pkg = cand.ParentPkg(); const int candPriority = GetPriority(cand); for (auto ver = cand.Cache()->FindGrp(cand.SourcePkgName()).VersionsInSource(); not ver.end(); ver = ver.NextInSource()) { // We are only interested in other packages in the same source package; built for the same architecture. if (ver->ParentPkg == cand->ParentPkg || ver.ParentPkg()->Arch != cand.ParentPkg()->Arch || cache.VS->CmpVersion(ver.SourceVerStr(), cand.SourceVerStr()) <= 0) continue; // We also take equal priority here, given that we have a higher version const int priority = GetPriority(ver); if (priority == 0 || priority < candPriority) continue; pkgObsolete[pkg] = 2; if (debug >= 3) std::cerr << "Obsolete: " << cand.ParentPkg().FullName() << "=" << cand.VerStr() << " due to " << ver.ParentPkg().FullName() << "=" << ver.VerStr() << "\n"; return true; } return false; } bool APT::Solver::Obsolete(pkgCache::PkgIterator pkg) const { if (pkgObsolete[pkg] != 0) return pkgObsolete[pkg] == 2; auto ver = GetCandidateVer(pkg); if (ver.end() && not StrictPinning) ver = pkg.VersionList(); if (ver.end()) { if (debug >= 3) std::cerr << "Obsolete: " << pkg.FullName() << " - not installable\n"; pkgObsolete[pkg] = 2; return true; } if (ObsoletedByNewerSourceVersion(ver)) return true; for (auto file = ver.FileList(); !file.end(); file++) if ((file.File()->Flags & pkgCache::Flag::NotSource) == 0) { pkgObsolete[pkg] = 1; return false; } if (debug >= 3) std::cerr << "Obsolete: " << ver.ParentPkg().FullName() << "=" << ver.VerStr() << " - not installable\n"; pkgObsolete[pkg] = 2; return true; } bool APT::Solver::Assume(Var var, bool decision, Var reason) { choices.push_back(solved.size()); return Enqueue(var, decision, std::move(reason)); } bool APT::Solver::Enqueue(Var var, bool decision, Var reason) { auto &state = (*this)[var]; auto decisionCast = decision ? Decision::MUST : Decision::MUSTNOT; if (state.decision != Decision::NONE) { if (state.decision != decisionCast) return _error->Error("Conflict: %s -> %s%s but %s", WhyStr(reason).c_str(), decision ? "" : "not ", var.toString(cache).c_str(), WhyStr(var).c_str()); return true; } state.decision = decisionCast; state.depth = depth(); state.reason = reason; if (unlikely(debug >= 1)) std::cerr << "[" << depth() << "] " << (decision ? "Install" : "Reject") << ":" << var.toString(cache) << " (" << WhyStr(state.reason) << ")\n"; solved.push_back(Solved{var, std::nullopt}); propQ.push(var); if (not decision) needsRescore = true; return true; } bool APT::Solver::Propagate() { while (!propQ.empty()) { Var var = propQ.front(); propQ.pop(); if ((*this)[var].decision == Decision::MUST) { Discover(var); for (auto &clause : (*this)[var].clauses) if (not AddWork(Work{clause.get(), depth()})) return false; } else if ((*this)[var].decision == Decision::MUSTNOT && not PropagateReject(var)) return false; } return true; } void APT::Solver::RegisterClause(Clause &&clause) { auto &clauses = (*this)[clause.reason].clauses; clauses.push_back(std::make_unique(std::move(clause))); } void APT::Solver::Discover(Var var) { auto &state = (*this)[var]; if (state.flags.discovered) return; state.flags.discovered = true; if (auto Pkg = var.Pkg(cache); not Pkg.end()) { Clause clause{Var(Pkg), Group::SelectVersion}; for (auto ver = Pkg.VersionList(); not ver.end(); ver++) clause.solutions.push_back(Var(ver)); std::stable_sort(clause.solutions.begin(), clause.solutions.end(), CompareProviders3{cache, policy, Pkg, *this}); RegisterClause(std::move(clause)); RegisterCommonDependencies(Pkg); } else if (auto Ver = var.Ver(cache); not Ver.end()) { Clause clause{Var(Ver), Group::SelectVersion}; clause.solutions = {Var(Ver.ParentPkg())}; RegisterClause(std::move(clause)); for (auto OV = Ver.ParentPkg().VersionList(); not OV.end(); ++OV) { if (OV == Ver) continue; Clause clause{Var(Ver), Group::SelectVersion, false, true /* negative */}; clause.solutions = {Var(OV)}; RegisterClause(std::move(clause)); } for (auto dep = Ver.DependsList(); not dep.end();) { // Compute a single dependency element (glob or) pkgCache::DepIterator start; pkgCache::DepIterator end; dep.GlobOr(start, end); // advances dep auto clause = TranslateOrGroup(start, end, Var(Ver)); RegisterClause(std::move(clause)); } } } bool APT::Solver::PropagateReject(Var var) { if (auto Pkg = var.Pkg(cache); not Pkg.end()) { for (auto ver = Pkg.VersionList(); not ver.end(); ver++) if (not Enqueue(Var(ver), false, Var(Pkg))) return false; } else if (auto Ver = var.Ver(cache); not Ver.end()) { if (auto pkg = Ver.ParentPkg(); (*this)[pkg].decision != Decision::MUSTNOT) { bool anyInstallable = false; for (auto otherVer = pkg.VersionList(); not otherVer.end(); otherVer++) if (otherVer->ID != Ver->ID && (*this)[otherVer].decision != Decision::MUSTNOT) anyInstallable = true; if (anyInstallable) ; else if ((*this)[pkg].decision == Decision::MUST) // Must install, but none available { _error->Error("Conflict: %s but no versions are installable", WhyStr(Var(pkg)).c_str()); for (auto otherVer = pkg.VersionList(); not otherVer.end(); otherVer++) if ((*this)[otherVer].decision == Decision::MUSTNOT) _error->Error("Uninstallable version: %s", WhyStr(Var(otherVer)).c_str()); return _error->Error("Uninstallable version: %s", WhyStr(Var(Ver)).c_str()); } else if (not Enqueue(Var(Ver.ParentPkg()), false, Var(Ver))) // Last version invalidated return false; } if (not RejectReverseDependencies(Ver)) return false; } return true; } void APT::Solver::RegisterCommonDependencies(pkgCache::PkgIterator Pkg) { for (auto dep = Pkg.VersionList().DependsList(); not dep.end();) { pkgCache::DepIterator start; pkgCache::DepIterator end; dep.GlobOr(start, end); // advances dep bool allHaveDep = true; for (auto ver = Pkg.VersionList()++; not ver.end(); ver++) { bool haveDep = false; for (auto otherDep = ver.DependsList(); not haveDep && not otherDep.end(); otherDep++) haveDep = otherDep->DependencyData == start->DependencyData; if (!haveDep) allHaveDep = haveDep; } if (not allHaveDep) continue; auto clause = TranslateOrGroup(start, end, Var(Pkg)); RegisterClause(std::move(clause)); } } APT::Solver::Clause APT::Solver::TranslateOrGroup(pkgCache::DepIterator start, pkgCache::DepIterator end, Var reason) { auto TgtPkg = start.TargetPkg(); auto Ver = start.ParentVer(); // Non-important dependencies can only be installed if they are currently satisfied, see the check further // below once we have calculated all possible solutions. if (start.ParentPkg()->CurrentVer == 0 && not policy.IsImportantDep(start)) return Clause{reason, Group::Satisfy, true}; // Replaces and Enhances are not a real dependency. if (start->Type == pkgCache::Dep::Replaces || start->Type == pkgCache::Dep::Enhances) return Clause{reason, Group::Satisfy, true}; if (unlikely(debug >= 3)) std::cerr << "Found dependency critical " << Ver.ParentPkg().FullName() << "=" << Ver.VerStr() << " -> " << start.TargetPkg().FullName() << "\n"; Clause clause{reason, Group::Satisfy, not start.IsCritical() /* optional */, start.IsNegative()}; clause.dep = start; do { auto begin = clause.solutions.size(); auto all = start.AllTargets(); for (auto tgt = all; *tgt; ++tgt) { pkgCache::VerIterator tgti(cache, *tgt); if (unlikely(debug >= 3)) std::cerr << "Adding work to item " << reason.toString(cache) << " -> " << tgti.ParentPkg().FullName() << "=" << tgti.VerStr() << (clause.negative ? " (negative)" : "") << "\n"; clause.solutions.push_back(Var(pkgCache::VerIterator(cache, *tgt))); } delete[] all; // If we are fixing the policy, we need to sort each alternative in an or group separately // FIXME: This is not really true, though, we should fix the CompareProviders to ignore the // installed state if (FixPolicyBroken) std::stable_sort(clause.solutions.begin() + begin, clause.solutions.end(), CompareProviders3{cache, policy, TgtPkg, *this}); if (start == end) break; ++start; } while (1); if (not FixPolicyBroken) std::stable_sort(clause.solutions.begin(), clause.solutions.end(), CompareProviders3{cache, policy, TgtPkg, *this}); if (std::all_of(clause.solutions.begin(), clause.solutions.end(), [this](auto var) -> auto { return var.CastPkg(cache)->CurrentVer == 0; })) clause.group = Group::SatisfyNew; if (std::any_of(clause.solutions.begin(), clause.solutions.end(), [this](auto var) -> auto { return Obsolete(var.CastPkg(cache)); })) clause.group = Group::SatisfyObsolete; // Try to perserve satisfied Recommends. FIXME: We should check if the Recommends was there in the installed version? if (clause.optional && start.ParentPkg()->CurrentVer) { bool important = policy.IsImportantDep(start); bool newOptional = true; bool wasImportant = false; for (auto D = start.ParentPkg().CurrentVer().DependsList(); not D.end(); D++) if (not D.IsCritical() && not D.IsNegative() && D.TargetPkg() == start.TargetPkg()) newOptional = false, wasImportant = policy.IsImportantDep(D); bool satisfied = std::any_of(clause.solutions.begin(), clause.solutions.end(), [this](auto var) { return Var(var.CastPkg(cache).CurrentVer()) == var; }); if (important && wasImportant && not newOptional && not satisfied) { if (unlikely(debug >= 3)) std::cerr << "Ignoring unsatisfied Recommends " << clause.toString(cache) << std::endl; clause.solutions.clear(); } else if (not important && not wasImportant && not newOptional && satisfied) { if (unlikely(debug >= 3)) std::cerr << "Promoting satisfied Suggests to Recommends: " << clause.toString(cache) << std::endl; important = true; } else if (not important) { if (unlikely(debug >= 3)) std::cerr << "Ignoring Suggests " << clause.toString(cache) << std::endl; return Clause{reason, Group::Satisfy, true}; } } return clause; } // \brief Find the or group containing the given dependency. static void FindOrGroup(pkgCache::DepIterator const &D, pkgCache::DepIterator &start, pkgCache::DepIterator &end) { for (auto dep = D.ParentVer().DependsList(); not dep.end();) { dep.GlobOr(start, end); // advances dep for (auto member = start;;) { if (member == D) return; if (member == end) break; member++; } } _error->Fatal("Found a dependency that does not exist in its parent version"); abort(); } // This is the opposite of EnqueueOrDependencies, it rejects the reverse dependencies of the // given version iterator. bool APT::Solver::RejectReverseDependencies(pkgCache::VerIterator Ver) { // This checks whether an or group is still satisfiable. auto stillPossible = [this](pkgCache::DepIterator start, pkgCache::DepIterator end) { while (1) { std::unique_ptr Ts{start.AllTargets()}; for (size_t i = 0; Ts[i] != nullptr; ++i) if ((*this)[Ts[i]].decision != Decision::MUSTNOT) return true; if (start == end) return false; start++; } }; for (auto RD = Ver.ParentPkg().RevDependsList(); not RD.end(); ++RD) { auto RDV = RD.ParentVer(); if (RD.IsNegative() || not RD.IsCritical() || not RD.IsSatisfied(Ver)) continue; if ((*this)[RDV].decision == Decision::MUSTNOT) continue; pkgCache::DepIterator start; pkgCache::DepIterator end; FindOrGroup(RD, start, end); if (stillPossible(start, end)) continue; if (unlikely(debug >= 3)) std::cerr << "Propagate NOT " << Ver.ParentPkg().FullName() << "=" << Ver.VerStr() << " to " << RDV.ParentPkg().FullName() << "=" << RDV.VerStr() << " for dependency group starting with" << start.TargetPkg().FullName() << std::endl; if (not Enqueue(Var(RDV), false, Var(Ver))) return false; } return true; } void APT::Solver::Push(Work work) { if (unlikely(debug >= 2)) std::cerr << "Trying choice for " << work.toString(cache) << std::endl; choices.push_back(solved.size()); solved.push_back(Solved{Var(), std::move(work)}); // Pop() will call MergeWithStack() when reverting to level 0, or RevertToStack after dumping to the debug log. _error->PushToStack(); } void APT::Solver::UndoOne() { auto solvedItem = solved.back(); if (unlikely(debug >= 4)) std::cerr << "Undoing a single decision\n"; if (not solvedItem.assigned.empty()) { if (unlikely(debug >= 4)) { if (auto P = solvedItem.assigned.Pkg(cache); not P.end()) std::cerr << "Unassign " << P.FullName() << "\n"; if (auto V = solvedItem.assigned.Ver(cache); not V.end()) std::cerr << "Unassign " << V.ParentPkg().FullName() << "=" << V.VerStr() << "\n"; } auto &state = (*this)[solvedItem.assigned]; state.decision = Decision::NONE; state.reason = Var(); state.depth = 0; } if (auto work = solvedItem.work) { if (unlikely(debug >= 4)) std::cerr << "Adding work item " << work->toString(cache) << std::endl; if (not AddWork(std::move(*work))) abort(); } solved.pop_back(); // FIXME: Add the undo handling here once we have watchers. } bool APT::Solver::Pop() { if (depth() == 0) return false; if (unlikely(debug >= 2)) for (std::string msg; _error->PopMessage(msg);) std::cerr << "Branch failed: " << msg << std::endl; _error->RevertToStack(); assert(choices.back() < solved.size()); int itemsToUndo = solved.size() - choices.back(); auto choice = solved[choices.back()].work->choice; for (; itemsToUndo; --itemsToUndo) UndoOne(); // We need to remove any work that is at a higher depth. // FIXME: We should just mark the entries as erased and only do a compaction // of the heap once we have a lot of erased entries in it. choices.pop_back(); work.erase(std::remove_if(work.begin(), work.end(), [this](Work &w) -> bool { return w.depth > depth() || w.erased; }), work.end()); std::make_heap(work.begin(), work.end()); if (unlikely(debug >= 2)) std::cerr << "Backtracking to choice " << choice.toString(cache) << "\n"; // FIXME: There should be a reason! if (not Enqueue(choice, false, {})) return false; if (unlikely(debug >= 2)) std::cerr << "Backtracked to choice " << choice.toString(cache) << "\n"; return true; } bool APT::Solver::AddWork(Work &&w) { if (w.clause->negative) { for (auto var : w.clause->solutions) if (not Enqueue(var, false, w.clause->reason)) return false; } else if (not w.clause->solutions.empty()) { if (unlikely(debug >= 3 && w.clause->optional)) std::cerr << "Enqueuing Recommends " << w.clause->toString(cache) << std::endl; if (w.clause->solutions.size() == 1 && not w.clause->optional) return Enqueue(w.clause->solutions[0], true, w.clause->reason); w.size = std::count_if(w.clause->solutions.begin(), w.clause->solutions.end(), [this](auto V) { return (*this)[V].decision != Decision::MUSTNOT; }); work.push_back(std::move(w)); std::push_heap(work.begin(), work.end()); } else if (not w.clause->optional && w.clause->dep) return _error->Error("Unsatisfiable dependency group %s -> %s", w.clause->reason.toString(cache).c_str(), pkgCache::DepIterator(cache, w.clause->dep).TargetPkg().FullName().c_str()); else if (not w.clause->optional) return _error->Error("Unsatisfiable dependency group %s", w.clause->reason.toString(cache).c_str()); return true; } void APT::Solver::RescoreWorkIfNeeded() { if (not needsRescore) return; needsRescore = false; std::vector resized; for (auto &w : work) { if (w.erased) continue; size_t newSize = std::count_if(w.clause->solutions.begin(), w.clause->solutions.end(), [this](auto V) { return (*this)[V].decision != Decision::MUSTNOT; }); // Notably we only insert the work into the queue if it got smaller. Work that got larger // we just move around when we get to it too early in Solve(). This reduces memory usage // at the expense of counting each item we see in Solve(). if (newSize < w.size) { Work newWork(w); newWork.size = newSize; resized.push_back(std::move(newWork)); w.erased = true; } } if (unlikely(debug >= 2)) std::cerr << "Rescored: " << resized.size() << "items\n"; for (auto &w : resized) { work.push_back(std::move(w)); std::push_heap(work.begin(), work.end()); } } bool APT::Solver::Solve() { while (true) { while (not Propagate()) { if (not Pop()) return false; } if (work.empty()) break; // Rescore the work if we need to RescoreWorkIfNeeded(); // *NOW* we can pop the item. std::pop_heap(work.begin(), work.end()); // This item has been replaced with a new one. Remove it. if (work.back().erased) { work.pop_back(); continue; } // If our size increased, queue again. size_t newSize = std::count_if(work.back().clause->solutions.begin(), work.back().clause->solutions.end(), [this](auto V) { return (*this)[V].decision != Decision::MUSTNOT; }); if (newSize > work.back().size) { work.back().size = newSize; std::push_heap(work.begin(), work.end()); continue; } assert(newSize == work.back().size); auto item = std::move(work.back()); work.pop_back(); solved.push_back(Solved{Var(), item}); if (std::any_of(item.clause->solutions.begin(), item.clause->solutions.end(), [this](auto ver) { return (*this)[ver].decision == Decision::MUST; })) { if (unlikely(debug >= 2)) std::cerr << "ELIDED " << item.toString(cache) << std::endl; continue; } if (unlikely(debug >= 1)) std::cerr << item.toString(cache) << std::endl; assert(item.clause->solutions.size() > 1 || item.clause->optional); bool foundSolution = false; for (auto &sol : item.clause->solutions) { if ((*this)[sol].decision == Decision::MUSTNOT) { if (unlikely(debug >= 3)) std::cerr << "(existing conflict: " << sol.toString(cache) << ")\n"; continue; } if (item.size > 1 || item.clause->optional) { item.choice = sol; Push(item); } if (unlikely(debug >= 3)) std::cerr << "(try it: " << sol.toString(cache) << ")\n"; if (not Enqueue(sol, true, item.clause->reason) && not Pop()) return false; foundSolution = true; break; } if (not foundSolution && not item.clause->optional) { std::ostringstream dep; assert(item.clause->solutions.size() > 0); for (auto &sol : item.clause->solutions) dep << (dep.tellp() == 0 ? "" : " | ") << sol.toString(cache); _error->Error("Unsatisfiable dependency: %s -> %s", WhyStr(item.clause->reason).c_str(), dep.str().c_str()); for (auto &sol : item.clause->solutions) if ((*this)[sol].decision == Decision::MUSTNOT) _error->Error("Not considered: %s: %s", sol.toString(cache).c_str(), WhyStr(sol).c_str()); if (not Pop()) return false; } } return true; } // \brief Apply the selections from the dep cache to the solver bool APT::Solver::FromDepCache(pkgDepCache &depcache) { DefaultRootSetFunc2 rootSet(&cache); // Enforce strict pinning rules by rejecting all forbidden versions. if (StrictPinning) { for (auto P = cache.PkgBegin(); not P.end(); P++) { for (auto V = P.VersionList(); not V.end(); ++V) if (P.CurrentVer() != V && depcache.GetCandidateVersion(P) != V) if (not Enqueue(Var(V), false, {})) return false; } } for (auto P = cache.PkgBegin(); not P.end(); P++) { if (P->VersionList == nullptr) continue; auto state = depcache[P]; if (P->SelectedState == pkgCache::State::Hold && not state.Protect()) { if (unlikely(debug >= 1)) std::cerr << "Hold " << P.FullName() << "\n"; if (P->CurrentVer ? not Enqueue(Var(P.CurrentVer()), true, {}) : not Enqueue(Var(P), false, Var())) return false; } else if (state.Delete() // Normal delete request. || (not P->CurrentVer && state.Keep() && state.Protect()) // Delete request of not installed package. || (not P->CurrentVer && state.Keep() && not AllowInstall) // New package installs not allowed. ) { if (unlikely(debug >= 1)) std::cerr << "Delete " << P.FullName() << "\n"; if (not Enqueue(Var(P), false, Var())) return false; } else if (state.Install() || (state.Keep() && P->CurrentVer)) { auto isEssential = P->Flags & (pkgCache::Flag::Essential | pkgCache::Flag::Important); auto isAuto = (depcache[P].Flags & pkgCache::Flag::Auto); auto isOptional = ((isAuto && AllowRemove) || AllowRemoveManual) && not isEssential && not depcache[P].Protect(); auto Root = rootSet.InRootSet(P); auto Upgrade = depcache.GetCandidateVersion(P) != P.CurrentVer(); auto Group = isAuto ? (Upgrade ? Group::UpgradeAuto : Group::KeepAuto) : (Upgrade ? Group::UpgradeManual : Group::InstallManual); if (isAuto && not depcache[P].Protect() && not isEssential && not KeepAuto && not rootSet.InRootSet(P)) { if (unlikely(debug >= 1)) std::cerr << "Ignore automatic install " << P.FullName() << " (" << (isEssential ? "E" : "") << (isAuto ? "M" : "") << (Root ? "R" : "") << ")" << "\n"; continue; } if (unlikely(debug >= 1)) std::cerr << "Install " << P.FullName() << " (" << (isEssential ? "E" : "") << (isAuto ? "M" : "") << (Root ? "R" : "") << ")" << "\n"; if (not isOptional) { // Pre-empt the non-optional requests, as we don't want to queue them, we can just "unit propagate" here. if (depcache[P].Keep() ? not Enqueue(Var(P), true, {}) : not Enqueue(Var(depcache.GetCandidateVersion(P)), true, {})) return false; } else { Clause w{Var(), Group, isOptional}; w.solutions.push_back(Var(P)); RegisterClause(std::move(w)); if (not AddWork(Work{rootState->clauses.back().get(), depth()})) return false; // Given A->A2|A1, B->B1|B2; Bn->An, if we select `not A1`, we // should try to install A2 before trying B so we end up with // A2, B2, instead of removing A1 to keep B1 installed. This // requires some special casing in Work::operator< above. // Compare test-bug-712116-dpkg-pre-install-pkgs-hook-multiarch Clause shortcircuit{Var(), Group, isOptional}; for (auto V = P.VersionList(); not V.end(); ++V) shortcircuit.solutions.push_back(Var(V)); std::stable_sort(shortcircuit.solutions.begin(), shortcircuit.solutions.end(), CompareProviders3{cache, policy, P, *this}); RegisterClause(std::move(shortcircuit)); if (not AddWork(Work{rootState->clauses.back().get(), depth()})) return false; } } } return Propagate(); } bool APT::Solver::ToDepCache(pkgDepCache &depcache) const { pkgDepCache::ActionGroup group(depcache); for (auto P = cache.PkgBegin(); not P.end(); P++) { depcache[P].Marked = 0; depcache[P].Garbage = 0; if ((*this)[P].decision == Decision::MUST) { for (auto V = P.VersionList(); not V.end(); V++) { if ((*this)[V].decision == Decision::MUST) { depcache.SetCandidateVersion(V); break; } } auto reason = (*this)[depcache.GetCandidateVersion(P)].reason; if (auto RP = reason.Pkg(); RP == P.MapPointer()) reason = (*this)[P].reason; depcache.MarkInstall(P, false, 0, reason.empty()); if (not P->CurrentVer) depcache.MarkAuto(P, not reason.empty()); depcache[P].Marked = 1; depcache[P].Garbage = 0; } else if (P->CurrentVer || depcache[P].Install()) { depcache.MarkDelete(P, false, 0, (*this)[P].reason.empty()); depcache[P].Marked = 0; depcache[P].Garbage = 1; } } return true; }