apt-pkg/edsp.cc

   1 // -*- mode: cpp; mode: fold -*-
   2 // Description                                                          /*{{{*/
   3 /* ######################################################################
   4    Set of methods to help writing and reading everything needed for EDSP
   5    ##################################################################### */
   6                                                                         /*}}}*/
   7 // Include Files                                                        /*{{{*/
   8 #include <config.h>
   9
  10 #include <apt-pkg/algorithms.h>
  11 #include <apt-pkg/error.h>
  12 #include <apt-pkg/cacheset.h>
  13 #include <apt-pkg/depcache.h>
  14 #include <apt-pkg/pkgcache.h>
  15 #include <apt-pkg/cacheiterators.h>
  16 #include <apt-pkg/prettyprinters.h>
  17 #include <apt-pkg/packagemanager.h>
  18 #include <apt-pkg/progress.h>
  19 #include <apt-pkg/fileutl.h>
  20 #include <apt-pkg/edsp.h>
  21 #include <apt-pkg/tagfile.h>
  22 #include <apt-pkg/strutl.h>
  23 #include <apt-pkg/string_view.h>
  24 #include <apt-pkg/pkgsystem.h>
  25
  26 #include <sys/stat.h>
  27 #include <ctype.h>
  28 #include <stddef.h>
  29 #include <string.h>
  30 #include <unistd.h>
  31 #include <stdio.h>
  32
  33 #include <array>
  34 #include <limits>
  35 #include <string>
  36
  37 #include <apti18n.h>
  38                                                                         /*}}}*/
  39
  40 using std::string;
  41
  42 // we could use pkgCache::DepType and ::Priority, but these would be localized strings…
  43 constexpr char const * const PrioMap[] = {
  44    nullptr, "important", "required", "standard",
  45    "optional", "extra"
  46 };
  47 constexpr char const * const DepMap[] = {
  48    nullptr, "Depends", "Pre-Depends", "Suggests",
  49    "Recommends" , "Conflicts", "Replaces",
  50    "Obsoletes", "Breaks", "Enhances"
  51 };
  52
  53 // WriteOkay - varaidic helper to easily Write to a FileFd              /*{{{*/
  54 static bool WriteOkay_fn(FileFd &) { return true; }
  55 template<typename... Tail> static bool WriteOkay_fn(FileFd &output, APT::StringView data, Tail... more_data)
  56 {
  57    return likely(output.Write(data.data(), data.length()) && WriteOkay_fn(output, more_data...));
  58 }
  59 template<typename... Tail> static bool WriteOkay_fn(FileFd &output, unsigned int data, Tail... more_data)
  60 {
  61    std::string number;
  62    strprintf(number, "%d", data);
  63    return likely(output.Write(number.data(), number.length()) && WriteOkay_fn(output, more_data...));
  64 }
  65 template<typename... Data> static bool WriteOkay(bool &Okay, FileFd &output, Data&&... data)
  66 {
  67    Okay = likely(Okay && WriteOkay_fn(output, std::forward<Data>(data)...));
  68    return Okay;
  69 }
  70 template<typename... Data> static bool WriteOkay(FileFd &output, Data&&... data)
  71 {
  72    bool Okay = likely(output.Failed() == false);
  73    return WriteOkay(Okay, output, std::forward<Data>(data)...);
  74 }
  75                                                                         /*}}}*/
  76 // WriteScenarioVersion                                                 /*{{{*/
  77 static void WriteScenarioVersion(pkgDepCache &Cache, FILE* output, pkgCache::PkgIterator const &Pkg,
  78                                 pkgCache::VerIterator const &Ver)
  79 {
  80    fprintf(output, "Package: %s\n", Pkg.Name());
  81    fprintf(output, "Source: %s\n", Ver.SourcePkgName());
  82    fprintf(output, "Architecture: %s\n", Ver.Arch());
  83    fprintf(output, "Version: %s\n", Ver.VerStr());
  84    fprintf(output, "Source-Version: %s\n", Ver.SourceVerStr());
  85    if (Pkg.CurrentVer() == Ver)
  86       fprintf(output, "Installed: yes\n");
  87    if (Pkg->SelectedState == pkgCache::State::Hold ||
  88        (Cache[Pkg].Keep() == true && Cache[Pkg].Protect() == true))
  89       fprintf(output, "Hold: yes\n");
  90    fprintf(output, "APT-ID: %d\n", Ver->ID);
  91    if (PrioMap[Ver->Priority] != nullptr)
  92       fprintf(output, "Priority: %s\n", PrioMap[Ver->Priority]);
  93    if ((Pkg->Flags & pkgCache::Flag::Essential) == pkgCache::Flag::Essential)
  94       fprintf(output, "Essential: yes\n");
  95    if (Ver->Section != 0)
  96       fprintf(output, "Section: %s\n", Ver.Section());
  97    if ((Ver->MultiArch & pkgCache::Version::Allowed) == pkgCache::Version::Allowed)
  98       fprintf(output, "Multi-Arch: allowed\n");
  99    else if ((Ver->MultiArch & pkgCache::Version::Foreign) == pkgCache::Version::Foreign)
 100       fprintf(output, "Multi-Arch: foreign\n");
 101    else if ((Ver->MultiArch & pkgCache::Version::Same) == pkgCache::Version::Same)
 102       fprintf(output, "Multi-Arch: same\n");
 103    std::set<string> Releases;
 104    for (pkgCache::VerFileIterator I = Ver.FileList(); I.end() == false; ++I) {
 105       pkgCache::PkgFileIterator File = I.File();
 106       if (File.Flagged(pkgCache::Flag::NotSource) == false) {
 107          string Release = File.RelStr();
 108          if (!Release.empty())
 109             Releases.insert(Release);
 110       }
 111    }
 112    if (!Releases.empty()) {
 113        fprintf(output, "APT-Release:\n");
 114        for (std::set<string>::iterator R = Releases.begin(); R != Releases.end(); ++R)
 115            fprintf(output, " %s\n", R->c_str());
 116    }
 117    fprintf(output, "APT-Pin: %d\n", Cache.GetPolicy().GetPriority(Ver));
 118    if (Cache.GetCandidateVersion(Pkg) == Ver)
 119       fprintf(output, "APT-Candidate: yes\n");
 120    if ((Cache[Pkg].Flags & pkgCache::Flag::Auto) == pkgCache::Flag::Auto)
 121       fprintf(output, "APT-Automatic: yes\n");
 122 }
 123 static bool WriteScenarioVersion(FileFd &output, pkgCache::PkgIterator const &Pkg,
 124                                 pkgCache::VerIterator const &Ver)
 125 {
 126    bool Okay = WriteOkay(output, "Package: ", Pkg.Name(),
 127          "\nArchitecture: ", Ver.Arch(),
 128          "\nVersion: ", Ver.VerStr());
 129    WriteOkay(Okay, output, "\nAPT-ID: ", Ver->ID);
 130    if ((Pkg->Flags & pkgCache::Flag::Essential) == pkgCache::Flag::Essential)
 131       WriteOkay(Okay, output, "\nEssential: yes");
 132    if ((Ver->MultiArch & pkgCache::Version::Allowed) == pkgCache::Version::Allowed)
 133       WriteOkay(Okay, output, "\nMulti-Arch: allowed");
 134    else if ((Ver->MultiArch & pkgCache::Version::Foreign) == pkgCache::Version::Foreign)
 135       WriteOkay(Okay, output, "\nMulti-Arch: foreign");
 136    else if ((Ver->MultiArch & pkgCache::Version::Same) == pkgCache::Version::Same)
 137       WriteOkay(Okay, output, "\nMulti-Arch: same");
 138    return Okay;
 139 }
 140                                                                         /*}}}*/
 141 // WriteScenarioDependency                                              /*{{{*/
 142 static void WriteScenarioDependency( FILE* output, pkgCache::VerIterator const &Ver)
 143 {
 144    std::array<std::string, _count(DepMap)> dependencies;
 145    bool orGroup = false;
 146    for (pkgCache::DepIterator Dep = Ver.DependsList(); Dep.end() == false; ++Dep)
 147    {
 148       if (Dep.IsImplicit() == true)
 149          continue;
 150       if (orGroup == false)
 151          dependencies[Dep->Type].append(", ");
 152       dependencies[Dep->Type].append(Dep.TargetPkg().Name());
 153       if (Dep->Version != 0)
 154          dependencies[Dep->Type].append(" (").append(pkgCache::CompTypeDeb(Dep->CompareOp)).append(" ").append(Dep.TargetVer()).append(")");
 155       if ((Dep->CompareOp & pkgCache::Dep::Or) == pkgCache::Dep::Or)
 156       {
 157          dependencies[Dep->Type].append(" | ");
 158          orGroup = true;
 159       }
 160       else
 161          orGroup = false;
 162    }
 163    for (size_t i = 1; i < dependencies.size(); ++i)
 164       if (dependencies[i].empty() == false)
 165          fprintf(output, "%s: %s\n", DepMap[i], dependencies[i].c_str()+2);
 166    string provides;
 167    for (pkgCache::PrvIterator Prv = Ver.ProvidesList(); Prv.end() == false; ++Prv)
 168    {
 169       if (Prv.IsMultiArchImplicit() == true)
 170          continue;
 171       if (provides.empty() == false)
 172          provides.append(", ");
 173       provides.append(Prv.Name());
 174       if (Prv->ProvideVersion != 0)
 175          provides.append(" (= ").append(Prv.ProvideVersion()).append(")");
 176    }
 177    if (provides.empty() == false)
 178       fprintf(output, "Provides: %s\n", provides.c_str());
 179 }
 180 static bool WriteScenarioDependency(FileFd &output, pkgCache::VerIterator const &Ver, bool const OnlyCritical)
 181 {
 182    std::array<std::string, _count(DepMap)> dependencies;
 183    bool orGroup = false;
 184    for (pkgCache::DepIterator Dep = Ver.DependsList(); Dep.end() == false; ++Dep)
 185    {
 186       if (Dep.IsImplicit() == true)
 187          continue;
 188       if (OnlyCritical && Dep.IsCritical() == false)
 189          continue;
 190       if (orGroup == false && dependencies[Dep->Type].empty() == false)
 191          dependencies[Dep->Type].append(", ");
 192       dependencies[Dep->Type].append(Dep.TargetPkg().Name());
 193       if (Dep->Version != 0)
 194          dependencies[Dep->Type].append(" (").append(pkgCache::CompTypeDeb(Dep->CompareOp)).append(" ").append(Dep.TargetVer()).append(")");
 195       if ((Dep->CompareOp & pkgCache::Dep::Or) == pkgCache::Dep::Or)
 196       {
 197          dependencies[Dep->Type].append(" | ");
 198          orGroup = true;
 199       }
 200       else
 201          orGroup = false;
 202    }
 203    bool Okay = output.Failed() == false;
 204    for (size_t i = 1; i < dependencies.size(); ++i)
 205       if (dependencies[i].empty() == false)
 206          WriteOkay(Okay, output, "\n", DepMap[i], ": ", dependencies[i]);
 207    string provides;
 208    for (pkgCache::PrvIterator Prv = Ver.ProvidesList(); Prv.end() == false; ++Prv)
 209    {
 210       if (Prv.IsMultiArchImplicit() == true)
 211          continue;
 212       if (provides.empty() == false)
 213          provides.append(", ");
 214       provides.append(Prv.Name());
 215       if (Prv->ProvideVersion != 0)
 216          provides.append(" (= ").append(Prv.ProvideVersion()).append(")");
 217    }
 218    if (provides.empty() == false)
 219       WriteOkay(Okay, output, "\nProvides: ", provides);
 220    return WriteOkay(Okay, output, "\n");
 221 }
 222                                                                         /*}}}*/
 223 // WriteScenarioLimitedDependency                                       /*{{{*/
 224 static void WriteScenarioLimitedDependency(FILE* output,
 225                                           pkgCache::VerIterator const &Ver,
 226                                           APT::PackageSet const &pkgset)
 227 {
 228    std::array<std::string, _count(DepMap)> dependencies;
 229    bool orGroup = false;
 230    for (pkgCache::DepIterator Dep = Ver.DependsList(); Dep.end() == false; ++Dep)
 231    {
 232       if (Dep.IsImplicit() == true)
 233          continue;
 234       if (orGroup == false)
 235       {
 236          if (pkgset.find(Dep.TargetPkg()) == pkgset.end())
 237             continue;
 238          if (dependencies[Dep->Type].empty() == false)
 239             dependencies[Dep->Type].append(", ");
 240       }
 241       else if (pkgset.find(Dep.TargetPkg()) == pkgset.end())
 242       {
 243          if ((Dep->CompareOp & pkgCache::Dep::Or) == pkgCache::Dep::Or)
 244             continue;
 245          dependencies[Dep->Type].erase(dependencies[Dep->Type].end()-3, dependencies[Dep->Type].end());
 246          orGroup = false;
 247          continue;
 248       }
 249       dependencies[Dep->Type].append(Dep.TargetPkg().Name());
 250       if (Dep->Version != 0)
 251          dependencies[Dep->Type].append(" (").append(pkgCache::CompTypeDeb(Dep->CompareOp)).append(" ").append(Dep.TargetVer()).append(")");
 252       if ((Dep->CompareOp & pkgCache::Dep::Or) == pkgCache::Dep::Or)
 253       {
 254          dependencies[Dep->Type].append(" | ");
 255          orGroup = true;
 256       }
 257       else
 258          orGroup = false;
 259    }
 260    for (size_t i = 1; i < dependencies.size(); ++i)
 261       if (dependencies[i].empty() == false)
 262          fprintf(output, "%s: %s\n", DepMap[i], dependencies[i].c_str());
 263    string provides;
 264    for (pkgCache::PrvIterator Prv = Ver.ProvidesList(); Prv.end() == false; ++Prv)
 265    {
 266       if (Prv.IsMultiArchImplicit() == true)
 267          continue;
 268       if (pkgset.find(Prv.ParentPkg()) == pkgset.end())
 269          continue;
 270       if (provides.empty() == false)
 271          provides.append(", ");
 272       provides.append(Prv.Name());
 273       if (Prv->ProvideVersion != 0)
 274          provides.append(" (= ").append(Prv.ProvideVersion()).append(")");
 275    }
 276    if (provides.empty() == false)
 277       fprintf(output, "Provides: %s\n", provides.c_str());
 278 }
 279 static bool WriteScenarioLimitedDependency(FileFd &output,
 280                                           pkgCache::VerIterator const &Ver,
 281                                           std::vector<bool> const &pkgset,
 282                                           bool const OnlyCritical)
 283 {
 284    std::array<std::string, _count(DepMap)> dependencies;
 285    bool orGroup = false;
 286    for (pkgCache::DepIterator Dep = Ver.DependsList(); Dep.end() == false; ++Dep)
 287    {
 288       if (Dep.IsImplicit() == true)
 289          continue;
 290       if (OnlyCritical && Dep.IsCritical() == false)
 291          continue;
 292       if (orGroup == false)
 293       {
 294          if (pkgset[Dep.TargetPkg()->ID] == false)
 295             continue;
 296          if (dependencies[Dep->Type].empty() == false)
 297             dependencies[Dep->Type].append(", ");
 298       }
 299       else if (pkgset[Dep.TargetPkg()->ID] == false)
 300       {
 301          if ((Dep->CompareOp & pkgCache::Dep::Or) == pkgCache::Dep::Or)
 302             continue;
 303          dependencies[Dep->Type].erase(dependencies[Dep->Type].end()-3, dependencies[Dep->Type].end());
 304          orGroup = false;
 305          continue;
 306       }
 307       dependencies[Dep->Type].append(Dep.TargetPkg().Name());
 308       if (Dep->Version != 0)
 309          dependencies[Dep->Type].append(" (").append(pkgCache::CompTypeDeb(Dep->CompareOp)).append(" ").append(Dep.TargetVer()).append(")");
 310       if ((Dep->CompareOp & pkgCache::Dep::Or) == pkgCache::Dep::Or)
 311       {
 312          dependencies[Dep->Type].append(" | ");
 313          orGroup = true;
 314       }
 315       else
 316          orGroup = false;
 317    }
 318    bool Okay = output.Failed() == false;
 319    for (size_t i = 1; i < dependencies.size(); ++i)
 320       if (dependencies[i].empty() == false)
 321          WriteOkay(Okay, output, "\n", DepMap[i], ": ", dependencies[i]);
 322    string provides;
 323    for (pkgCache::PrvIterator Prv = Ver.ProvidesList(); Prv.end() == false; ++Prv)
 324    {
 325       if (Prv.IsMultiArchImplicit() == true)
 326          continue;
 327       if (pkgset[Prv.ParentPkg()->ID] == false)
 328          continue;
 329       if (provides.empty() == false)
 330          provides.append(", ");
 331       provides.append(Prv.Name());
 332       if (Prv->ProvideVersion != 0)
 333          provides.append(" (= ").append(Prv.ProvideVersion()).append(")");
 334    }
 335    if (provides.empty() == false)
 336       WriteOkay(Okay, output, "\nProvides: ", provides);
 337    return WriteOkay(Okay, output, "\n");
 338 }
 339                                                                         /*}}}*/
 340 static bool SkipUnavailableVersions(pkgDepCache &Cache, pkgCache::PkgIterator const &Pkg, pkgCache::VerIterator const &Ver)/*{{{*/
 341 {
 342    /* versions which aren't current and aren't available in
 343       any "online" source file are bad, expect if they are the chosen
 344       candidate: The exception is for build-dep implementation as it creates
 345       such pseudo (package) versions and removes them later on again.
 346       We filter out versions at all so packages in 'rc' state only available
 347       in dpkg/status aren't passed to solvers as they can't be installed. */
 348    if (Pkg->CurrentVer != 0)
 349       return false;
 350    if (Cache.GetCandidateVersion(Pkg) == Ver)
 351       return false;
 352    for (pkgCache::VerFileIterator I = Ver.FileList(); I.end() == false; ++I)
 353       if (I.File().Flagged(pkgCache::Flag::NotSource) == false)
 354          return false;
 355    return true;
 356 }
 357                                                                         /*}}}*/
 358 static bool WriteScenarioEDSPVersion(pkgDepCache &Cache, FileFd &output, pkgCache::PkgIterator const &Pkg,/*{{{*/
 359                                 pkgCache::VerIterator const &Ver)
 360 {
 361    bool Okay = WriteOkay(output, "\nSource: ", Ver.SourcePkgName(),
 362          "\nSource-Version: ", Ver.SourceVerStr());
 363    if (PrioMap[Ver->Priority] != nullptr)
 364       WriteOkay(Okay, output, "\nPriority: ", PrioMap[Ver->Priority]);
 365    if (Ver->Section != 0)
 366       WriteOkay(Okay, output, "\nSection: ", Ver.Section());
 367    if (Pkg.CurrentVer() == Ver)
 368       WriteOkay(Okay, output, "\nInstalled: yes");
 369    if (Pkg->SelectedState == pkgCache::State::Hold ||
 370        (Cache[Pkg].Keep() == true && Cache[Pkg].Protect() == true))
 371       WriteOkay(Okay, output, "\nHold: yes");
 372    std::set<string> Releases;
 373    for (pkgCache::VerFileIterator I = Ver.FileList(); I.end() == false; ++I) {
 374       pkgCache::PkgFileIterator File = I.File();
 375       if (File.Flagged(pkgCache::Flag::NotSource) == false) {
 376          string Release = File.RelStr();
 377          if (!Release.empty())
 378             Releases.insert(Release);
 379       }
 380    }
 381    if (!Releases.empty()) {
 382        WriteOkay(Okay, output, "\nAPT-Release:");
 383        for (std::set<string>::iterator R = Releases.begin(); R != Releases.end(); ++R)
 384            WriteOkay(Okay, output, "\n ", *R);
 385    }
 386    WriteOkay(Okay, output, "\nAPT-Pin: ", Cache.GetPolicy().GetPriority(Ver));
 387    if (Cache.GetCandidateVersion(Pkg) == Ver)
 388       WriteOkay(Okay, output, "\nAPT-Candidate: yes");
 389    if ((Cache[Pkg].Flags & pkgCache::Flag::Auto) == pkgCache::Flag::Auto)
 390       WriteOkay(Okay, output, "\nAPT-Automatic: yes");
 391    return Okay;
 392 }
 393                                                                         /*}}}*/
 394 // EDSP::WriteScenario - to the given file descriptor                   /*{{{*/
 395 bool EDSP::WriteScenario(pkgDepCache &Cache, FILE* output, OpProgress *Progress)
 396 {
 397    if (Progress != NULL)
 398       Progress->SubProgress(Cache.Head().VersionCount, _("Send scenario to solver"));
 399    unsigned long p = 0;
 400    std::vector<std::string> archs = APT::Configuration::getArchitectures();
 401    for (pkgCache::PkgIterator Pkg = Cache.PkgBegin(); Pkg.end() == false; ++Pkg)
 402    {
 403       std::string const arch = Pkg.Arch();
 404       if (std::find(archs.begin(), archs.end(), arch) == archs.end())
 405          continue;
 406       for (pkgCache::VerIterator Ver = Pkg.VersionList(); Ver.end() == false; ++Ver, ++p)
 407       {
 408          if (SkipUnavailableVersions(Cache, Pkg, Ver))
 409             continue;
 410          WriteScenarioVersion(Cache, output, Pkg, Ver);
 411          WriteScenarioDependency(output, Ver);
 412          fprintf(output, "\n");
 413          if (Progress != NULL && p % 100 == 0)
 414             Progress->Progress(p);
 415       }
 416    }
 417    return true;
 418 }
 419 bool EDSP::WriteScenario(pkgDepCache &Cache, FileFd &output, OpProgress *Progress)
 420 {
 421    if (Progress != NULL)
 422       Progress->SubProgress(Cache.Head().VersionCount, _("Send scenario to solver"));
 423    unsigned long p = 0;
 424    bool Okay = output.Failed() == false;
 425    std::vector<std::string> archs = APT::Configuration::getArchitectures();
 426    for (pkgCache::PkgIterator Pkg = Cache.PkgBegin(); Pkg.end() == false && likely(Okay); ++Pkg)
 427    {
 428       std::string const arch = Pkg.Arch();
 429       if (std::find(archs.begin(), archs.end(), arch) == archs.end())
 430          continue;
 431       for (pkgCache::VerIterator Ver = Pkg.VersionList(); Ver.end() == false && likely(Okay); ++Ver, ++p)
 432       {
 433          if (SkipUnavailableVersions(Cache, Pkg, Ver))
 434             continue;
 435          Okay &= WriteScenarioVersion(output, Pkg, Ver);
 436          Okay &= WriteScenarioEDSPVersion(Cache, output, Pkg, Ver);
 437          Okay &= WriteScenarioDependency(output, Ver, false);
 438          WriteOkay(Okay, output, "\n");
 439          if (Progress != NULL && p % 100 == 0)
 440             Progress->Progress(p);
 441       }
 442    }
 443    return Okay;
 444 }
 445                                                                         /*}}}*/
 446 // EDSP::WriteLimitedScenario - to the given file descriptor            /*{{{*/
 447 bool EDSP::WriteLimitedScenario(pkgDepCache &Cache, FILE* output,
 448                                 APT::PackageSet const &pkgset,
 449                                 OpProgress *Progress)
 450 {
 451    if (Progress != NULL)
 452       Progress->SubProgress(Cache.Head().VersionCount, _("Send scenario to solver"));
 453    unsigned long p  = 0;
 454    for (APT::PackageSet::const_iterator Pkg = pkgset.begin(); Pkg != pkgset.end(); ++Pkg, ++p)
 455       for (pkgCache::VerIterator Ver = Pkg.VersionList(); Ver.end() == false; ++Ver)
 456       {
 457          if (SkipUnavailableVersions(Cache, Pkg, Ver))
 458             continue;
 459          WriteScenarioVersion(Cache, output, Pkg, Ver);
 460          WriteScenarioLimitedDependency(output, Ver, pkgset);
 461          fprintf(output, "\n");
 462          if (Progress != NULL && p % 100 == 0)
 463             Progress->Progress(p);
 464       }
 465    if (Progress != NULL)
 466       Progress->Done();
 467    return true;
 468 }
 469 bool EDSP::WriteLimitedScenario(pkgDepCache &Cache, FileFd &output,
 470                                 std::vector<bool> const &pkgset,
 471                                 OpProgress *Progress)
 472 {
 473    if (Progress != NULL)
 474       Progress->SubProgress(Cache.Head().VersionCount, _("Send scenario to solver"));
 475    unsigned long p  = 0;
 476    bool Okay = output.Failed() == false;
 477    for (auto Pkg = Cache.PkgBegin(); Pkg.end() == false && likely(Okay); ++Pkg, ++p)
 478    {
 479       if (pkgset[Pkg->ID] == false)
 480          continue;
 481       for (pkgCache::VerIterator Ver = Pkg.VersionList(); Ver.end() == false && likely(Okay); ++Ver)
 482       {
 483          if (SkipUnavailableVersions(Cache, Pkg, Ver))
 484             continue;
 485          Okay &= WriteScenarioVersion(output, Pkg, Ver);
 486          Okay &= WriteScenarioEDSPVersion(Cache, output, Pkg, Ver);
 487          Okay &= WriteScenarioLimitedDependency(output, Ver, pkgset, false);
 488          WriteOkay(Okay, output, "\n");
 489          if (Progress != NULL && p % 100 == 0)
 490             Progress->Progress(p);
 491       }
 492    }
 493    if (Progress != NULL)
 494       Progress->Done();
 495    return Okay;
 496 }
 497                                                                         /*}}}*/
 498 // EDSP::WriteRequest - to the given file descriptor                    /*{{{*/
 499 bool EDSP::WriteRequest(pkgDepCache &Cache, FILE* output, bool const Upgrade,
 500                         bool const DistUpgrade, bool const AutoRemove,
 501                         OpProgress *Progress)
 502 {
 503    if (Progress != NULL)
 504       Progress->SubProgress(Cache.Head().PackageCount, _("Send request to solver"));
 505    unsigned long p = 0;
 506    string del, inst;
 507    for (pkgCache::PkgIterator Pkg = Cache.PkgBegin(); Pkg.end() == false; ++Pkg, ++p)
 508    {
 509       if (Progress != NULL && p % 100 == 0)
 510          Progress->Progress(p);
 511       string* req;
 512       pkgDepCache::StateCache &P = Cache[Pkg];
 513       if (P.Delete() == true)
 514          req = &del;
 515       else if (P.NewInstall() == true || P.Upgrade() == true || P.ReInstall() == true ||
 516                (P.Mode == pkgDepCache::ModeKeep && (P.iFlags & pkgDepCache::Protected) == pkgDepCache::Protected))
 517          req = &inst;
 518       else
 519          continue;
 520       req->append(" ").append(Pkg.FullName());
 521    }
 522    fprintf(output, "Request: EDSP 0.5\n");
 523
 524    const char *arch = _config->Find("APT::Architecture").c_str();
 525    std::vector<string> archs = APT::Configuration::getArchitectures();
 526    fprintf(output, "Architecture: %s\n", arch);
 527    fprintf(output, "Architectures:");
 528    for (std::vector<string>::const_iterator a = archs.begin(); a != archs.end(); ++a)
 529        fprintf(output, " %s", a->c_str());
 530    fprintf(output, "\n");
 531
 532    if (del.empty() == false)
 533       fprintf(output, "Remove: %s\n", del.c_str()+1);
 534    if (inst.empty() == false)
 535       fprintf(output, "Install: %s\n", inst.c_str()+1);
 536    if (Upgrade == true)
 537       fprintf(output, "Upgrade: yes\n");
 538    if (DistUpgrade == true)
 539       fprintf(output, "Dist-Upgrade: yes\n");
 540    if (AutoRemove == true)
 541       fprintf(output, "Autoremove: yes\n");
 542    auto const solver = _config->Find("APT::Solver", "internal");
 543    fprintf(output, "Solver: %s\n", solver.c_str());
 544    auto const solverconf = std::string("APT::Solver::") + solver + "::";
 545    if (_config->FindB(solverconf + "Strict-Pinning", _config->FindB("APT::Solver::Strict-Pinning", true)) == false)
 546       fprintf(output, "Strict-Pinning: no\n");
 547    auto const solverpref = _config->Find(solverconf + "Preferences", _config->Find("APT::Solver::Preferences", ""));
 548    if (solverpref.empty() == false)
 549       fprintf(output, "Preferences: %s\n", solverpref.c_str());
 550    fprintf(output, "\n");
 551    return true;
 552 }
 553 bool EDSP::WriteRequest(pkgDepCache &Cache, FileFd &output,
 554                         unsigned int const flags,
 555                         OpProgress *Progress)
 556 {
 557    if (Progress != NULL)
 558       Progress->SubProgress(Cache.Head().PackageCount, _("Send request to solver"));
 559    unsigned long p = 0;
 560    string del, inst;
 561    for (pkgCache::PkgIterator Pkg = Cache.PkgBegin(); Pkg.end() == false; ++Pkg, ++p)
 562    {
 563       if (Progress != NULL && p % 100 == 0)
 564          Progress->Progress(p);
 565       string* req;
 566       pkgDepCache::StateCache &P = Cache[Pkg];
 567       if (P.Delete() == true)
 568          req = &del;
 569       else if (P.NewInstall() == true || P.Upgrade() == true || P.ReInstall() == true ||
 570                (P.Mode == pkgDepCache::ModeKeep && (P.iFlags & pkgDepCache::Protected) == pkgDepCache::Protected))
 571          req = &inst;
 572       else
 573          continue;
 574       req->append(" ").append(Pkg.FullName());
 575    }
 576    bool Okay = WriteOkay(output, "Request: EDSP 0.5\n");
 577
 578    const char *arch = _config->Find("APT::Architecture").c_str();
 579    std::vector<string> archs = APT::Configuration::getArchitectures();
 580    WriteOkay(Okay, output, "Architecture: ", arch, "\n",
 581          "Architectures:");
 582    for (std::vector<string>::const_iterator a = archs.begin(); a != archs.end(); ++a)
 583        WriteOkay(Okay, output, " ", *a);
 584    WriteOkay(Okay, output, "\n");
 585
 586    if (del.empty() == false)
 587       WriteOkay(Okay, output, "Remove:", del, "\n");
 588    if (inst.empty() == false)
 589       WriteOkay(Okay, output, "Install:", inst, "\n");
 590    if (flags & Request::AUTOREMOVE)
 591       WriteOkay(Okay, output, "Autoremove: yes\n");
 592    if (flags & Request::UPGRADE_ALL)
 593    {
 594       WriteOkay(Okay, output, "Upgrade-All: yes\n");
 595       if (flags & (Request::FORBID_NEW_INSTALL | Request::FORBID_REMOVE))
 596          WriteOkay(Okay, output, "Upgrade: yes\n");
 597       else
 598          WriteOkay(Okay, output, "Dist-Upgrade: yes\n");
 599    }
 600    if (flags & Request::FORBID_NEW_INSTALL)
 601       WriteOkay(Okay, output, "Forbid-New-Install: yes\n");
 602    if (flags & Request::FORBID_REMOVE)
 603       WriteOkay(Okay, output, "Forbid-Remove: yes\n");
 604    auto const solver = _config->Find("APT::Solver", "internal");
 605    WriteOkay(Okay, output, "Solver: ", solver, "\n");
 606    if (_config->FindB("APT::Solver::Strict-Pinning", true) == false)
 607       WriteOkay(Okay, output, "Strict-Pinning: no\n");
 608    string solverpref("APT::Solver::");
 609    solverpref.append(solver).append("::Preferences");
 610    if (_config->Exists(solverpref) == true)
 611       WriteOkay(Okay, output, "Preferences: ", _config->Find(solverpref,""), "\n");
 612    return WriteOkay(Okay, output, "\n");
 613 }
 614                                                                         /*}}}*/
 615 // EDSP::ReadResponse - from the given file descriptor                  /*{{{*/
 616 bool EDSP::ReadResponse(int const input, pkgDepCache &Cache, OpProgress *Progress) {
 617         /* We build an map id to mmap offset here
 618            In theory we could use the offset as ID, but then VersionCount
 619            couldn't be used to create other versionmappings anymore and it
 620            would be too easy for a (buggy) solver to segfault APT… */
 621         unsigned long long const VersionCount = Cache.Head().VersionCount;
 622         unsigned long VerIdx[VersionCount];
 623         for (pkgCache::PkgIterator P = Cache.PkgBegin(); P.end() == false; ++P) {
 624                 for (pkgCache::VerIterator V = P.VersionList(); V.end() == false; ++V)
 625                         VerIdx[V->ID] = V.Index();
 626                 Cache[P].Marked = true;
 627                 Cache[P].Garbage = false;
 628         }
 629
 630         FileFd in;
 631         in.OpenDescriptor(input, FileFd::ReadOnly, true);
 632         pkgTagFile response(&in, 100);
 633         pkgTagSection section;
 634
 635         std::set<decltype(Cache.PkgBegin()->ID)> seenOnce;
 636         while (response.Step(section) == true) {
 637                 std::string type;
 638                 if (section.Exists("Install") == true)
 639                         type = "Install";
 640                 else if (section.Exists("Remove") == true)
 641                         type = "Remove";
 642                 else if (section.Exists("Progress") == true) {
 643                         if (Progress != NULL) {
 644                                 string msg = section.FindS("Message");
 645                                 if (msg.empty() == true)
 646                                         msg = _("Prepare for receiving solution");
 647                                 Progress->SubProgress(100, msg, section.FindI("Percentage", 0));
 648                         }
 649                         continue;
 650                 } else if (section.Exists("Error") == true) {
 651                         if (_error->PendingError()) {
 652                                 if (Progress != nullptr)
 653                                         Progress->Done();
 654                                 Progress = nullptr;
 655                                 _error->DumpErrors(std::cerr, GlobalError::DEBUG, false);
 656                         }
 657                         std::string msg = SubstVar(SubstVar(section.FindS("Message"), "\n .\n", "\n\n"), "\n ", "\n");
 658                         if (msg.empty() == true) {
 659                                 msg = _("External solver failed without a proper error message");
 660                                 _error->Error("%s", msg.c_str());
 661                         } else
 662                                 _error->Error("External solver failed with: %s", msg.substr(0,msg.find('\n')).c_str());
 663                         if (Progress != nullptr)
 664                                 Progress->Done();
 665                         std::cerr << "The solver encountered an error of type: " << section.FindS("Error") << std::endl;
 666                         std::cerr << "The following information might help you to understand what is wrong:" << std::endl;
 667                         std::cerr << msg << std::endl << std::endl;
 668                         return false;
 669                 } else if (section.Exists("Autoremove") == true)
 670                         type = "Autoremove";
 671                 else {
 672                         char const *Start, *End;
 673                         section.GetSection(Start, End);
 674                         _error->Warning("Encountered an unexpected section with %d fields: %s", section.Count(), std::string(Start, End).c_str());
 675                         continue;
 676                 }
 677
 678                 size_t const id = section.FindULL(type.c_str(), VersionCount);
 679                 if (id == VersionCount) {
 680                         _error->Warning("Unable to parse %s request with id value '%s'!", type.c_str(), section.FindS(type.c_str()).c_str());
 681                         continue;
 682                 } else if (id > Cache.Head().VersionCount) {
 683                         _error->Warning("ID value '%s' in %s request stanza is to high to refer to a known version!", section.FindS(type.c_str()).c_str(), type.c_str());
 684                         continue;
 685                 }
 686
 687                 pkgCache::VerIterator Ver(Cache.GetCache(), Cache.GetCache().VerP + VerIdx[id]);
 688                 auto const Pkg = Ver.ParentPkg();
 689                 if (type == "Autoremove") {
 690                         Cache[Pkg].Marked = false;
 691                         Cache[Pkg].Garbage = true;
 692                 } else if (seenOnce.emplace(Pkg->ID).second == false) {
 693                         _error->Warning("Ignoring %s stanza received for package %s which already had a previous stanza effecting it!", type.c_str(), Pkg.FullName(false).c_str());
 694                 } else if (type == "Install") {
 695                         if (Pkg.CurrentVer() == Ver) {
 696                                 _error->Warning("Ignoring Install stanza received for version %s of package %s which is already installed!",
 697                                       Ver.VerStr(), Pkg.FullName(false).c_str());
 698                         } else {
 699                                 Cache.SetCandidateVersion(Ver);
 700                                 Cache.MarkInstall(Pkg, false, 0, false);
 701                         }
 702                 } else if (type == "Remove") {
 703                         if (Pkg->CurrentVer == 0)
 704                                 _error->Warning("Ignoring Remove stanza received for version %s of package %s which isn't installed!",
 705                                       Ver.VerStr(), Pkg.FullName(false).c_str());
 706                         else if (Pkg.CurrentVer() != Ver)
 707                                 _error->Warning("Ignoring Remove stanza received for version %s of package %s which isn't the installed version %s!",
 708                                       Ver.VerStr(), Pkg.FullName(false).c_str(), Pkg.CurrentVer().VerStr());
 709                         else
 710                                 Cache.MarkDelete(Ver.ParentPkg(), false);
 711                 }
 712         }
 713         return true;
 714 }
 715                                                                         /*}}}*/
 716 // ReadLine - first line from the given file descriptor                 /*{{{*/
 717 // ---------------------------------------------------------------------
 718 /* Little helper method to read a complete line into a string. Similar to
 719    fgets but we need to use the low-level read() here as otherwise the
 720    listparser will be confused later on as mixing of fgets and read isn't
 721    a supported action according to the manpages and results are undefined */
 722 static bool ReadLine(int const input, std::string &line) {
 723         char one;
 724         ssize_t data = 0;
 725         line.erase();
 726         line.reserve(100);
 727         while ((data = read(input, &one, sizeof(one))) != -1) {
 728                 if (data != 1)
 729                         continue;
 730                 if (one == '\n')
 731                         return true;
 732                 if (one == '\r')
 733                         continue;
 734                 if (line.empty() == true && isblank(one) != 0)
 735                         continue;
 736                 line += one;
 737         }
 738         return false;
 739 }
 740                                                                         /*}}}*/
 741 // StringToBool - convert yes/no to bool                                /*{{{*/
 742 // ---------------------------------------------------------------------
 743 /* we are not as lazy as we are in the global StringToBool as we really
 744    only accept yes/no here */
 745 static bool localStringToBool(std::string answer, bool const defValue) {
 746    std::transform(answer.begin(), answer.end(), answer.begin(), ::tolower);
 747    if (answer == "yes")
 748       return true;
 749    else if (answer == "no")
 750       return false;
 751    else
 752       _error->Warning("Value '%s' is not a boolean 'yes' or 'no'!", answer.c_str());
 753    return defValue;
 754 }
 755                                                                         /*}}}*/
 756 static bool LineStartsWithAndStrip(std::string &line, APT::StringView const with)/*{{{*/
 757 {
 758    if (line.compare(0, with.size(), with.data()) != 0)
 759       return false;
 760    line = APT::String::Strip(line.substr(with.length()));
 761    return true;
 762 }
 763                                                                         /*}}}*/
 764 static bool ReadFlag(unsigned int &flags, std::string &line, APT::StringView const name, unsigned int const setflag)/*{{{*/
 765 {
 766    if (LineStartsWithAndStrip(line, name) == false)
 767       return false;
 768    if (localStringToBool(line, false))
 769       flags |= setflag;
 770    else
 771       flags &= ~setflag;
 772    return true;
 773 }
 774                                                                         /*}}}*/
 775 // EDSP::ReadRequest - first stanza from the given file descriptor      /*{{{*/
 776 bool EDSP::ReadRequest(int const input, std::list<std::string> &install,
 777                         std::list<std::string> &remove, unsigned int &flags)
 778 {
 779    install.clear();
 780    remove.clear();
 781    flags = 0;
 782    std::string line;
 783    while (ReadLine(input, line) == true)
 784    {
 785       // Skip empty lines before request
 786       if (line.empty() == true)
 787          continue;
 788       // The first Tag must be a request, so search for it
 789       if (LineStartsWithAndStrip(line, "Request:"))
 790          continue;
 791
 792       while (ReadLine(input, line) == true)
 793       {
 794          // empty lines are the end of the request
 795          if (line.empty() == true)
 796             return true;
 797
 798          std::list<std::string> *request = NULL;
 799          if (LineStartsWithAndStrip(line, "Install:"))
 800             request = &install;
 801          else if (LineStartsWithAndStrip(line, "Remove:"))
 802             request = &remove;
 803          else if (ReadFlag(flags, line, "Upgrade:", (Request::UPGRADE_ALL | Request::FORBID_REMOVE | Request::FORBID_NEW_INSTALL)) ||
 804                ReadFlag(flags, line, "Dist-Upgrade:", Request::UPGRADE_ALL) ||
 805                ReadFlag(flags, line, "Upgrade-All:", Request::UPGRADE_ALL) ||
 806                ReadFlag(flags, line, "Forbid-New-Install:", Request::FORBID_NEW_INSTALL) ||
 807                ReadFlag(flags, line, "Forbid-Remove:", Request::FORBID_REMOVE) ||
 808                ReadFlag(flags, line, "Autoremove:", Request::AUTOREMOVE))
 809             ;
 810          else if (LineStartsWithAndStrip(line, "Architecture:"))
 811             _config->Set("APT::Architecture", line);
 812          else if (LineStartsWithAndStrip(line, "Architectures:"))
 813             _config->Set("APT::Architectures", SubstVar(line, " ", ","));
 814          else if (LineStartsWithAndStrip(line, "Solver:"))
 815             ; // purely informational line
 816          else
 817             _error->Warning("Unknown line in EDSP Request stanza: %s", line.c_str());
 818
 819          if (request == NULL)
 820             continue;
 821          auto const pkgs = VectorizeString(line, ' ');
 822          std::move(pkgs.begin(), pkgs.end(), std::back_inserter(*request));
 823       }
 824    }
 825    return false;
 826 }
 827 bool EDSP::ReadRequest(int const input, std::list<std::string> &install,
 828                         std::list<std::string> &remove, bool &upgrade,
 829                         bool &distUpgrade, bool &autoRemove)
 830 {
 831    unsigned int flags;
 832    auto const ret = ReadRequest(input, install, remove, flags);
 833    autoRemove = (flags & Request::AUTOREMOVE);
 834    if (flags & Request::UPGRADE_ALL)
 835    {
 836       if (flags & (Request::FORBID_NEW_INSTALL | Request::FORBID_REMOVE))
 837       {
 838          upgrade = true;
 839          distUpgrade = false;
 840       } else {
 841          upgrade = false;
 842          distUpgrade = false;
 843       }
 844    }
 845    else
 846    {
 847       upgrade = false;
 848       distUpgrade = false;
 849    }
 850    return ret;
 851 }
 852                                                                         /*}}}*/
 853 // EDSP::ApplyRequest - first stanza from the given file descriptor     /*{{{*/
 854 bool EDSP::ApplyRequest(std::list<std::string> const &install,
 855                          std::list<std::string> const &remove,
 856                          pkgDepCache &Cache)
 857 {
 858         for (std::list<std::string>::const_iterator i = install.begin();
 859              i != install.end(); ++i) {
 860                 pkgCache::PkgIterator P = Cache.FindPkg(*i);
 861                 if (P.end() == true)
 862                         _error->Warning("Package %s is not known, so can't be installed", i->c_str());
 863                 else
 864                         Cache.MarkInstall(P, false);
 865         }
 866
 867         for (std::list<std::string>::const_iterator i = remove.begin();
 868              i != remove.end(); ++i) {
 869                 pkgCache::PkgIterator P = Cache.FindPkg(*i);
 870                 if (P.end() == true)
 871                         _error->Warning("Package %s is not known, so can't be installed", i->c_str());
 872                 else
 873                         Cache.MarkDelete(P);
 874         }
 875         return true;
 876 }
 877                                                                         /*}}}*/
 878 // EDSP::WriteSolutionStanza - to the given file descriptor             /*{{{*/
 879 bool EDSP::WriteSolution(pkgDepCache &Cache, FILE* output)
 880 {
 881    bool const Debug = _config->FindB("Debug::EDSP::WriteSolution", false);
 882    for (pkgCache::PkgIterator Pkg = Cache.PkgBegin(); Pkg.end() == false; ++Pkg)
 883    {
 884       if (Cache[Pkg].Delete() == true)
 885       {
 886          fprintf(output, "Remove: %d\n", _system->GetVersionMapping(Pkg.CurrentVer()->ID));
 887          if (Debug == true)
 888             fprintf(output, "Package: %s\nVersion: %s\n", Pkg.FullName().c_str(), Pkg.CurrentVer().VerStr());
 889       }
 890       else if (Cache[Pkg].NewInstall() == true || Cache[Pkg].Upgrade() == true)
 891       {
 892          pkgCache::VerIterator const CandVer = Cache.GetCandidateVersion(Pkg);
 893          fprintf(output, "Install: %d\n", _system->GetVersionMapping(CandVer->ID));
 894          if (Debug == true)
 895             fprintf(output, "Package: %s\nVersion: %s\n", Pkg.FullName().c_str(), CandVer.VerStr());
 896       }
 897       else if (Cache[Pkg].Garbage == true)
 898       {
 899          fprintf(output, "Autoremove: %d\n", _system->GetVersionMapping(Pkg.CurrentVer()->ID));
 900          if (Debug == true)
 901             fprintf(output, "Package: %s\nVersion: %s\n", Pkg.FullName().c_str(), Pkg.CurrentVer().VerStr());
 902       }
 903       else
 904          continue;
 905       fprintf(output, "\n");
 906    }
 907
 908    return true;
 909 }
 910 bool EDSP::WriteSolutionStanza(FileFd &output, char const * const Type, pkgCache::VerIterator const &Ver)
 911 {
 912    bool Okay = output.Failed() == false;
 913    WriteOkay(Okay, output, Type, ": ", _system->GetVersionMapping(Ver->ID));
 914    if (_config->FindB("Debug::EDSP::WriteSolution", false) == true)
 915       WriteOkay(Okay, output, "\nPackage: ", Ver.ParentPkg().FullName(), "\nVersion: ", Ver.VerStr());
 916    return WriteOkay(Okay, output, "\n\n");
 917 }
 918                                                                         /*}}}*/
 919 // EDSP::WriteProgess - pulse to the given file descriptor              /*{{{*/
 920 bool EDSP::WriteProgress(unsigned short const percent, const char* const message, FILE* output) {
 921         fprintf(output, "Progress: %s\n", TimeRFC1123(time(NULL), true).c_str());
 922         fprintf(output, "Percentage: %d\n", percent);
 923         fprintf(output, "Message: %s\n\n", message);
 924         fflush(output);
 925         return true;
 926 }
 927 bool EDSP::WriteProgress(unsigned short const percent, const char* const message, FileFd &output) {
 928         return WriteOkay(output, "Progress: ", TimeRFC1123(time(NULL), true), "\n",
 929               "Percentage: ", percent, "\n",
 930               "Message: ", message, "\n\n") && output.Flush();
 931 }
 932                                                                         /*}}}*/
 933 // EDSP::WriteError - format an error message to be send to file descriptor /*{{{*/
 934 bool EDSP::WriteError(char const * const uuid, std::string const &message, FILE* output) {
 935         fprintf(output, "Error: %s\n", uuid);
 936         fprintf(output, "Message: %s\n\n", SubstVar(SubstVar(message, "\n\n", "\n.\n"), "\n", "\n ").c_str());
 937         return true;
 938 }
 939 bool EDSP::WriteError(char const * const uuid, std::string const &message, FileFd &output) {
 940         return WriteOkay(output, "Error: ", uuid, "\n",
 941               "Message: ", SubstVar(SubstVar(message, "\n\n", "\n.\n"), "\n", "\n "),
 942               "\n\n");
 943 }
 944                                                                         /*}}}*/
 945 static std::string findExecutable(std::vector<std::string> const &dirs, char const * const binary) {/*{{{*/
 946         for (auto && dir : dirs) {
 947                 std::string const file = flCombine(dir, binary);
 948                 if (RealFileExists(file) == true)
 949                         return file;
 950         }
 951         return "";
 952 }
 953                                                                         /*}}}*/
 954 static pid_t ExecuteExternal(char const* const type, char const * const binary, char const * const configdir, int * const solver_in, int * const solver_out) {/*{{{*/
 955         auto const solverDirs = _config->FindVector(configdir);
 956         auto const file = findExecutable(solverDirs, binary);
 957         std::string dumper;
 958         {
 959                 dumper = findExecutable(solverDirs, "apt-dump-solver");
 960                 if (dumper.empty())
 961                         dumper = findExecutable(solverDirs, "dump");
 962         }
 963
 964         if (file.empty() == true)
 965         {
 966                 _error->Error("Can't call external %s '%s' as it is not in a configured directory!", type, binary);
 967                 return 0;
 968         }
 969         int external[4] = {-1, -1, -1, -1};
 970         if (pipe(external) != 0 || pipe(external + 2) != 0)
 971         {
 972                 _error->Errno("Resolve", "Can't create needed IPC pipes for EDSP");
 973                 return 0;
 974         }
 975         for (int i = 0; i < 4; ++i)
 976                 SetCloseExec(external[i], true);
 977
 978         pid_t Solver = ExecFork();
 979         if (Solver == 0) {
 980                 dup2(external[0], STDIN_FILENO);
 981                 dup2(external[3], STDOUT_FILENO);
 982                 auto const dumpfile = _config->FindFile((std::string("Dir::Log::") + type).c_str());
 983                 auto const dumpdir = flNotFile(dumpfile);
 984                 auto const runasuser = _config->Find(std::string("APT::") + type + "::" + binary + "::RunAsUser",
 985                       _config->Find(std::string("APT::") + type + "::RunAsUser",
 986                          _config->Find("APT::Sandbox::User")));
 987                 if (dumper.empty() || dumpfile.empty() || dumper == file || CreateAPTDirectoryIfNeeded(dumpdir, dumpdir) == false)
 988                 {
 989                    _config->Set("APT::Sandbox::User", runasuser);
 990                    DropPrivileges();
 991                    char const * const calling[] = { file.c_str(), nullptr };
 992                    execv(calling[0], const_cast<char**>(calling));
 993                 }
 994                 else
 995                 {
 996                    char const * const calling[] = { dumper.c_str(), "--user", runasuser.c_str(), dumpfile.c_str(), file.c_str(), nullptr };
 997                    execv(calling[0], const_cast<char**>(calling));
 998                 }
 999                 std::cerr << "Failed to execute " << type << " '" << binary << "'!" << std::endl;
1000                 _exit(100);
1001         }
1002         close(external[0]);
1003         close(external[3]);
1004
1005         if (WaitFd(external[1], true, 5) == false)
1006         {
1007                 _error->Errno("Resolve", "Timed out while Waiting on availability of %s stdin", type);
1008                 return 0;
1009         }
1010
1011         *solver_in = external[1];
1012         *solver_out = external[2];
1013         return Solver;
1014 }
1015                                                                         /*}}}*/
1016 // EDSP::ExecuteSolver - fork requested solver and setup ipc pipes      {{{*/
1017 pid_t EDSP::ExecuteSolver(const char* const solver, int * const solver_in, int * const solver_out, bool) {
1018         return ExecuteExternal("solver", solver, "Dir::Bin::Solvers", solver_in, solver_out);
1019 }
1020 bool EDSP::ExecuteSolver(const char* const solver, int *solver_in, int *solver_out) {
1021    if (ExecuteSolver(solver, solver_in, solver_out, true) == 0)
1022       return false;
1023    return true;
1024 }
1025                                                                         /*}}}*/
1026 static bool CreateDumpFile(char const * const id, char const * const type, FileFd &output)/*{{{*/
1027 {
1028         auto const dumpfile = _config->FindFile((std::string("Dir::Log::") + type).c_str());
1029         if (dumpfile.empty())
1030                 return false;
1031         auto const dumpdir = flNotFile(dumpfile);
1032         _error->PushToStack();
1033         bool errored_out = CreateAPTDirectoryIfNeeded(dumpdir, dumpdir) == false ||
1034            output.Open(dumpfile, FileFd::WriteOnly | FileFd::Exclusive | FileFd::Create, FileFd::Extension, 0644) == false;
1035         std::vector<std::string> downgrademsgs;
1036         while (_error->empty() == false)
1037         {
1038                 std::string msg;
1039                 _error->PopMessage(msg);
1040                 downgrademsgs.emplace_back(std::move(msg));
1041         }
1042         _error->RevertToStack();
1043         for (auto && msg : downgrademsgs)
1044            _error->Warning("%s", msg.c_str());
1045         if (errored_out)
1046                 return _error->WarningE(id, _("Could not open file '%s'"), dumpfile.c_str());
1047         return true;
1048 }
1049                                                                         /*}}}*/
1050 // EDSP::ResolveExternal - resolve problems by asking external for help {{{*/
1051 bool EDSP::ResolveExternal(const char* const solver, pkgDepCache &Cache,
1052                          unsigned int const flags, OpProgress *Progress) {
1053         if (strcmp(solver, "internal") == 0)
1054         {
1055                 FileFd output;
1056                 bool Okay = CreateDumpFile("EDSP::Resolve", "solver", output);
1057                 Okay &= EDSP::WriteRequest(Cache, output, flags, nullptr);
1058                 return Okay && EDSP::WriteScenario(Cache, output, nullptr);
1059         }
1060         _error->PushToStack();
1061         int solver_in, solver_out;
1062         pid_t const solver_pid = ExecuteSolver(solver, &solver_in, &solver_out, true);
1063         if (solver_pid == 0)
1064                 return false;
1065
1066         FileFd output;
1067         if (output.OpenDescriptor(solver_in, FileFd::WriteOnly | FileFd::BufferedWrite, true) == false)
1068                 return _error->Errno("ResolveExternal", "Opening solver %s stdin on fd %d for writing failed", solver, solver_in);
1069
1070         bool Okay = output.Failed() == false;
1071         if (Okay && Progress != NULL)
1072                 Progress->OverallProgress(0, 100, 5, _("Execute external solver"));
1073         Okay &= EDSP::WriteRequest(Cache, output, flags, Progress);
1074         if (Okay && Progress != NULL)
1075                 Progress->OverallProgress(5, 100, 20, _("Execute external solver"));
1076         Okay &= EDSP::WriteScenario(Cache, output, Progress);
1077         output.Close();
1078
1079         if (Okay && Progress != NULL)
1080                 Progress->OverallProgress(25, 100, 75, _("Execute external solver"));
1081         bool const ret = EDSP::ReadResponse(solver_out, Cache, Progress);
1082         _error->MergeWithStack();
1083         if (ExecWait(solver_pid, solver))
1084                 return ret;
1085         return false;
1086 }
1087 bool EDSP::ResolveExternal(const char* const solver, pkgDepCache &Cache,
1088                          bool const upgrade, bool const distUpgrade,
1089                          bool const autoRemove, OpProgress *Progress) {
1090    unsigned int flags = 0;
1091    if (autoRemove)
1092       flags |= Request::AUTOREMOVE;
1093    if (upgrade)
1094       flags |= Request::UPGRADE_ALL | Request::FORBID_REMOVE | Request::FORBID_NEW_INSTALL;
1095    if (distUpgrade)
1096       flags |= Request::UPGRADE_ALL;
1097    return ResolveExternal(solver, Cache, flags, Progress);
1098 }
1099                                                                         /*}}}*/
1100
1101 bool EIPP::OrderInstall(char const * const solver, pkgPackageManager * const PM,        /*{{{*/
1102                          unsigned int const flags, OpProgress * const Progress)
1103 {
1104    if (strcmp(solver, "internal") == 0)
1105    {
1106       FileFd output;
1107       _error->PushToStack();
1108       bool Okay = CreateDumpFile("EIPP::OrderInstall", "planner", output);
1109       if (Okay == false && dynamic_cast<pkgSimulate*>(PM) != nullptr)
1110       {
1111          _error->RevertToStack();
1112          return false;
1113       }
1114       _error->MergeWithStack();
1115       Okay &= EIPP::WriteRequest(PM->Cache, output, flags, nullptr);
1116       return Okay && EIPP::WriteScenario(PM->Cache, output, nullptr);
1117    }
1118    _error->PushToStack();
1119    int solver_in, solver_out;
1120    pid_t const solver_pid = ExecuteExternal("planner", solver, "Dir::Bin::Planners", &solver_in, &solver_out);
1121    if (solver_pid == 0)
1122       return false;
1123
1124    FileFd output;
1125    if (output.OpenDescriptor(solver_in, FileFd::WriteOnly | FileFd::BufferedWrite, true) == false)
1126       return _error->Errno("EIPP::OrderInstall", "Opening planner %s stdin on fd %d for writing failed", solver, solver_in);
1127
1128    bool Okay = output.Failed() == false;
1129    if (Okay && Progress != NULL)
1130       Progress->OverallProgress(0, 100, 5, _("Execute external planner"));
1131    Okay &= EIPP::WriteRequest(PM->Cache, output, flags, Progress);
1132    if (Okay && Progress != NULL)
1133       Progress->OverallProgress(5, 100, 20, _("Execute external planner"));
1134    Okay &= EIPP::WriteScenario(PM->Cache, output, Progress);
1135    output.Close();
1136
1137    if (Okay)
1138    {
1139       if (Progress != nullptr)
1140          Progress->OverallProgress(25, 100, 75, _("Execute external planner"));
1141
1142       // we don't tell the external planners about boring things
1143       for (auto Pkg = PM->Cache.PkgBegin(); Pkg.end() == false; ++Pkg)
1144       {
1145          if (Pkg->CurrentState == pkgCache::State::ConfigFiles && PM->Cache[Pkg].Purge() == true)
1146             PM->Remove(Pkg, true);
1147       }
1148    }
1149    bool const ret = EIPP::ReadResponse(solver_out, PM, Progress);
1150    _error->MergeWithStack();
1151    if (ExecWait(solver_pid, solver))
1152       return ret;
1153    return false;
1154 }
1155                                                                         /*}}}*/
1156 bool EIPP::WriteRequest(pkgDepCache &Cache, FileFd &output,             /*{{{*/
1157                         unsigned int const flags,
1158                         OpProgress * const Progress)
1159 {
1160    if (Progress != NULL)
1161       Progress->SubProgress(Cache.Head().PackageCount, _("Send request to planner"));
1162    unsigned long p = 0;
1163    string del, inst, reinst;
1164    for (pkgCache::PkgIterator Pkg = Cache.PkgBegin(); Pkg.end() == false; ++Pkg, ++p)
1165    {
1166       if (Progress != NULL && p % 100 == 0)
1167          Progress->Progress(p);
1168       string* req;
1169       pkgDepCache::StateCache &P = Cache[Pkg];
1170       if (P.Purge() == true && Pkg->CurrentState == pkgCache::State::ConfigFiles)
1171          continue;
1172       if (P.Delete() == true)
1173          req = &del;
1174       else if (P.NewInstall() == true || P.Upgrade() == true || P.Downgrade() == true)
1175          req = &inst;
1176       else if (P.ReInstall() == true)
1177          req = &reinst;
1178       else
1179          continue;
1180       req->append(" ").append(Pkg.FullName());
1181    }
1182    bool Okay = WriteOkay(output, "Request: EIPP 0.1\n");
1183
1184    const char *arch = _config->Find("APT::Architecture").c_str();
1185    std::vector<string> archs = APT::Configuration::getArchitectures();
1186    WriteOkay(Okay, output, "Architecture: ", arch, "\n",
1187          "Architectures:");
1188    for (std::vector<string>::const_iterator a = archs.begin(); a != archs.end(); ++a)
1189        WriteOkay(Okay, output, " ", *a);
1190    WriteOkay(Okay, output, "\n");
1191
1192    if (del.empty() == false)
1193       WriteOkay(Okay, output, "Remove:", del, "\n");
1194    if (inst.empty() == false)
1195       WriteOkay(Okay, output, "Install:", inst, "\n");
1196    if (reinst.empty() == false)
1197       WriteOkay(Okay, output, "ReInstall:", reinst, "\n");
1198    WriteOkay(Okay, output, "Planner: ", _config->Find("APT::Planner", "internal"), "\n");
1199    if ((flags & Request::IMMEDIATE_CONFIGURATION_ALL) != 0)
1200       WriteOkay(Okay, output, "Immediate-Configuration: yes\n");
1201    else if ((flags & Request::NO_IMMEDIATE_CONFIGURATION) != 0)
1202       WriteOkay(Okay, output, "Immediate-Configuration: no\n");
1203    else if ((flags & Request::ALLOW_TEMPORARY_REMOVE_OF_ESSENTIALS) != 0)
1204       WriteOkay(Okay, output, "Allow-Temporary-Remove-of-Essentials: yes\n");
1205    return WriteOkay(Okay, output, "\n");
1206 }
1207                                                                         /*}}}*/
1208 static bool WriteScenarioEIPPVersion(pkgDepCache &, FileFd &output, pkgCache::PkgIterator const &Pkg,/*{{{*/
1209                                 pkgCache::VerIterator const &Ver)
1210 {
1211    bool Okay = true;
1212    if (Pkg.CurrentVer() == Ver)
1213       switch (Pkg->CurrentState)
1214       {
1215          case pkgCache::State::NotInstalled: WriteOkay(Okay, output, "\nStatus: not-installed"); break;
1216          case pkgCache::State::ConfigFiles: WriteOkay(Okay, output, "\nStatus: config-files"); break;
1217          case pkgCache::State::HalfInstalled: WriteOkay(Okay, output, "\nStatus: half-installed"); break;
1218          case pkgCache::State::UnPacked: WriteOkay(Okay, output, "\nStatus: unpacked"); break;
1219          case pkgCache::State::HalfConfigured: WriteOkay(Okay, output, "\nStatus: half-configured"); break;
1220          case pkgCache::State::TriggersAwaited: WriteOkay(Okay, output, "\nStatus: triggers-awaited"); break;
1221          case pkgCache::State::TriggersPending: WriteOkay(Okay, output, "\nStatus: triggers-pending"); break;
1222          case pkgCache::State::Installed: WriteOkay(Okay, output, "\nStatus: installed"); break;
1223       }
1224    return Okay;
1225 }
1226                                                                         /*}}}*/
1227 // EIPP::WriteScenario - to the given file descriptor                   /*{{{*/
1228 template<typename forVersion> void forAllInterestingVersions(pkgDepCache &Cache, pkgCache::PkgIterator const &Pkg, forVersion const &func)
1229 {
1230    if (Pkg->CurrentState == pkgCache::State::NotInstalled)
1231    {
1232       auto P = Cache[Pkg];
1233       if (P.Install() == false)
1234          return;
1235       func(Pkg, P.InstVerIter(Cache));
1236    }
1237    else
1238    {
1239       if (Pkg->CurrentVer != 0)
1240          func(Pkg, Pkg.CurrentVer());
1241       auto P = Cache[Pkg];
1242       auto const V = P.InstVerIter(Cache);
1243       if (P.Delete() == false && Pkg.CurrentVer() != V)
1244          func(Pkg, V);
1245    }
1246 }
1247
1248 bool EIPP::WriteScenario(pkgDepCache &Cache, FileFd &output, OpProgress * const Progress)
1249 {
1250    if (Progress != NULL)
1251       Progress->SubProgress(Cache.Head().PackageCount, _("Send scenario to planner"));
1252    unsigned long p = 0;
1253    bool Okay = output.Failed() == false;
1254    std::vector<std::string> archs = APT::Configuration::getArchitectures();
1255    std::vector<bool> pkgset(Cache.Head().PackageCount, false);
1256    auto const MarkVersion = [&](pkgCache::PkgIterator const &Pkg, pkgCache::VerIterator const &Ver) {
1257       pkgset[Pkg->ID] = true;
1258       for (auto D = Ver.DependsList(); D.end() == false; ++D)
1259       {
1260          if (D.IsCritical() == false)
1261             continue;
1262          auto const P = D.TargetPkg();
1263          for (auto Prv = P.ProvidesList(); Prv.end() == false; ++Prv)
1264          {
1265             auto const V = Prv.OwnerVer();
1266             auto const PV = V.ParentPkg();
1267             if (V == PV.CurrentVer() || V == Cache[PV].InstVerIter(Cache))
1268                pkgset[PV->ID] = true;
1269          }
1270          pkgset[P->ID] = true;
1271          if (strcmp(P.Arch(), "any") == 0)
1272          {
1273             APT::StringView const pkgname(P.Name());
1274             auto const idxColon = pkgname.find(':');
1275             if (idxColon != APT::StringView::npos)
1276             {
1277                pkgCache::PkgIterator PA;
1278                if (pkgname.substr(idxColon + 1) == "any")
1279                {
1280                   auto const GA = Cache.FindGrp(pkgname.substr(0, idxColon).to_string());
1281                   for (auto PA = GA.PackageList(); PA.end() == false; PA = GA.NextPkg(PA))
1282                   {
1283                      pkgset[PA->ID] = true;
1284                   }
1285                }
1286                else
1287                {
1288                   auto const PA = Cache.FindPkg(pkgname.to_string());
1289                   if (PA.end() == false)
1290                      pkgset[PA->ID] = true;
1291                }
1292             }
1293          }
1294          else
1295          {
1296             auto const PA = Cache.FindPkg(P.FullName(false), "any");
1297             if (PA.end() == false)
1298                pkgset[PA->ID] = true;
1299          }
1300       }
1301    };
1302    for (pkgCache::PkgIterator Pkg = Cache.PkgBegin(); Pkg.end() == false; ++Pkg)
1303       forAllInterestingVersions(Cache, Pkg, MarkVersion);
1304    auto const WriteVersion = [&](pkgCache::PkgIterator const &Pkg, pkgCache::VerIterator const &Ver) {
1305       Okay &= WriteScenarioVersion(output, Pkg, Ver);
1306       Okay &= WriteScenarioEIPPVersion(Cache, output, Pkg, Ver);
1307       Okay &= WriteScenarioLimitedDependency(output, Ver, pkgset, true);
1308       WriteOkay(Okay, output, "\n");
1309       if (Progress != NULL && p % 100 == 0)
1310          Progress->Progress(p);
1311    };
1312    for (pkgCache::PkgIterator Pkg = Cache.PkgBegin(); Pkg.end() == false && likely(Okay); ++Pkg, ++p)
1313    {
1314       if (pkgset[Pkg->ID] == false || Pkg->VersionList == 0)
1315          continue;
1316       forAllInterestingVersions(Cache, Pkg, WriteVersion);
1317    }
1318    return Okay;
1319 }
1320                                                                         /*}}}*/
1321 // EIPP::ReadResponse - from the given file descriptor                  /*{{{*/
1322 bool EIPP::ReadResponse(int const input, pkgPackageManager * const PM, OpProgress *Progress) {
1323    /* We build an map id to mmap offset here
1324       In theory we could use the offset as ID, but then VersionCount
1325       couldn't be used to create other versionmappings anymore and it
1326       would be too easy for a (buggy) solver to segfault APT… */
1327    unsigned long long const VersionCount = PM->Cache.Head().VersionCount;
1328    unsigned long VerIdx[VersionCount];
1329    for (pkgCache::PkgIterator P = PM->Cache.PkgBegin(); P.end() == false; ++P) {
1330       for (pkgCache::VerIterator V = P.VersionList(); V.end() == false; ++V)
1331          VerIdx[V->ID] = V.Index();
1332    }
1333
1334    FileFd in;
1335    in.OpenDescriptor(input, FileFd::ReadOnly);
1336    pkgTagFile response(&in, 100);
1337    pkgTagSection section;
1338
1339    while (response.Step(section) == true) {
1340       char const * type = nullptr;
1341       if (section.Exists("Progress") == true) {
1342          if (Progress != NULL) {
1343             string msg = section.FindS("Message");
1344             if (msg.empty() == true)
1345                msg = _("Prepare for receiving solution");
1346             Progress->SubProgress(100, msg, section.FindI("Percentage", 0));
1347          }
1348          continue;
1349       } else if (section.Exists("Error") == true) {
1350          if (_error->PendingError()) {
1351             if (Progress != nullptr)
1352                Progress->Done();
1353             Progress = nullptr;
1354             _error->DumpErrors(std::cerr, GlobalError::DEBUG, false);
1355          }
1356          std::string msg = SubstVar(SubstVar(section.FindS("Message"), "\n .\n", "\n\n"), "\n ", "\n");
1357          if (msg.empty() == true) {
1358             msg = _("External planner failed without a proper error message");
1359             _error->Error("%s", msg.c_str());
1360          } else
1361             _error->Error("External planner failed with: %s", msg.substr(0,msg.find('\n')).c_str());
1362          if (Progress != nullptr)
1363             Progress->Done();
1364          std::cerr << "The planner encountered an error of type: " << section.FindS("Error") << std::endl;
1365          std::cerr << "The following information might help you to understand what is wrong:" << std::endl;
1366          std::cerr << msg << std::endl << std::endl;
1367          return false;
1368       } else if (section.Exists("Unpack") == true)
1369          type = "Unpack";
1370       else if (section.Exists("Configure") == true)
1371          type = "Configure";
1372       else if (section.Exists("Remove") == true)
1373          type = "Remove";
1374       else {
1375          char const *Start, *End;
1376          section.GetSection(Start, End);
1377          _error->Warning("Encountered an unexpected section with %d fields: %s", section.Count(), std::string(Start, End).c_str());
1378          continue;
1379       }
1380
1381       if (type == nullptr)
1382          continue;
1383       size_t const id = section.FindULL(type, VersionCount);
1384       if (id == VersionCount) {
1385          _error->Warning("Unable to parse %s request with id value '%s'!", type, section.FindS(type).c_str());
1386          continue;
1387       } else if (id > PM->Cache.Head().VersionCount) {
1388          _error->Warning("ID value '%s' in %s request stanza is to high to refer to a known version!", section.FindS(type).c_str(), type);
1389          continue;
1390       }
1391
1392       pkgCache::VerIterator Ver(PM->Cache.GetCache(), PM->Cache.GetCache().VerP + VerIdx[id]);
1393       auto const Pkg = Ver.ParentPkg();
1394       if (strcmp(type, "Unpack") == 0)
1395          PM->Install(Pkg, PM->FileNames[Pkg->ID]);
1396       else if (strcmp(type, "Configure") == 0)
1397          PM->Configure(Pkg);
1398       else if (strcmp(type, "Remove") == 0)
1399          PM->Remove(Pkg, PM->Cache[Pkg].Purge());
1400    }
1401    return in.Failed() == false;
1402 }
1403                                                                         /*}}}*/
1404 bool EIPP::ReadRequest(int const input, std::list<std::pair<std::string,PKG_ACTION>> &actions,/*{{{*/
1405       unsigned int &flags)
1406 {
1407    actions.clear();
1408    flags = 0;
1409    std::string line;
1410    while (ReadLine(input, line) == true)
1411    {
1412       // Skip empty lines before request
1413       if (line.empty() == true)
1414          continue;
1415       // The first Tag must be a request, so search for it
1416       if (line.compare(0, 8, "Request:") != 0)
1417          continue;
1418
1419       while (ReadLine(input, line) == true)
1420       {
1421          // empty lines are the end of the request
1422          if (line.empty() == true)
1423             return true;
1424
1425          PKG_ACTION pkgact = PKG_ACTION::NOOP;
1426          if (LineStartsWithAndStrip(line, "Install:"))
1427             pkgact = PKG_ACTION::INSTALL;
1428          else if (LineStartsWithAndStrip(line, "ReInstall:"))
1429             pkgact = PKG_ACTION::REINSTALL;
1430          else if (LineStartsWithAndStrip(line, "Remove:"))
1431             pkgact = PKG_ACTION::REMOVE;
1432          else if (LineStartsWithAndStrip(line, "Architecture:"))
1433             _config->Set("APT::Architecture", line);
1434          else if (LineStartsWithAndStrip(line, "Architectures:"))
1435             _config->Set("APT::Architectures", SubstVar(line, " ", ","));
1436          else if (LineStartsWithAndStrip(line, "Planner:"))
1437             ; // purely informational line
1438          else if (LineStartsWithAndStrip(line, "Immediate-Configuration:"))
1439          {
1440             if (localStringToBool(line, true))
1441                flags |= Request::IMMEDIATE_CONFIGURATION_ALL;
1442             else
1443                flags |= Request::NO_IMMEDIATE_CONFIGURATION;
1444          }
1445          else if (ReadFlag(flags, line, "Allow-Temporary-Remove-of-Essentials:", Request::ALLOW_TEMPORARY_REMOVE_OF_ESSENTIALS))
1446             ;
1447          else
1448             _error->Warning("Unknown line in EIPP Request stanza: %s", line.c_str());
1449
1450          if (pkgact == PKG_ACTION::NOOP)
1451             continue;
1452          for (auto && p: VectorizeString(line, ' '))
1453             actions.emplace_back(std::move(p), pkgact);
1454       }
1455    }
1456    return false;
1457 }
1458                                                                         /*}}}*/
1459 bool EIPP::ApplyRequest(std::list<std::pair<std::string,PKG_ACTION>> &actions,/*{{{*/
1460          pkgDepCache &Cache)
1461 {
1462    for (auto Pkg = Cache.PkgBegin(); Pkg.end() == false; ++Pkg)
1463    {
1464       short versions = 0;
1465       for (auto Ver = Pkg.VersionList(); Ver.end() == false; ++Ver)
1466       {
1467          ++versions;
1468          if (Pkg.CurrentVer() == Ver)
1469             continue;
1470          Cache.SetCandidateVersion(Ver);
1471       }
1472       if (unlikely(versions > 2))
1473          _error->Warning("Package %s has %d versions, but should have at most 2!", Pkg.FullName().c_str(), versions);
1474    }
1475    for (auto && a: actions)
1476    {
1477       pkgCache::PkgIterator P = Cache.FindPkg(a.first);
1478       if (P.end() == true)
1479       {
1480          _error->Warning("Package %s is not known, so can't be acted on", a.first.c_str());
1481          continue;
1482       }
1483       switch (a.second)
1484       {
1485          case PKG_ACTION::NOOP:
1486             _error->Warning("Package %s has NOOP as action?!?", a.first.c_str());
1487             break;
1488          case PKG_ACTION::INSTALL:
1489             Cache.MarkInstall(P, false);
1490             break;
1491          case PKG_ACTION::REINSTALL:
1492             Cache.MarkInstall(P, false);
1493             Cache.SetReInstall(P, true);
1494             break;
1495          case PKG_ACTION::REMOVE:
1496             Cache.MarkDelete(P);
1497             break;
1498       }
1499    }
1500    return true;
1501 }
1502                                                                         /*}}}*/