]> git.saurik.com Git - apt.git/blame - apt-pkg/pkgcachegen.cc
refactor dpkg execution in deb/debsystem
[apt.git] / apt-pkg / pkgcachegen.cc
CommitLineData
578bfd0a
AL
1// -*- mode: cpp; mode: fold -*-
2// Description /*{{{*/
7db98ffc 3// $Id: pkgcachegen.cc,v 1.53.2.1 2003/12/24 23:09:17 mdz Exp $
578bfd0a
AL
4/* ######################################################################
5
6 Package Cache Generator - Generator for the cache structure.
7
8 This builds the cache structure from the abstract package list parser.
9
10 ##################################################################### */
11 /*}}}*/
12// Include Files /*{{{*/
ea542140 13#include <config.h>
b2e465d6 14
094a497d
AL
15#include <apt-pkg/pkgcachegen.h>
16#include <apt-pkg/error.h>
17#include <apt-pkg/version.h>
b35d2f5f
AL
18#include <apt-pkg/progress.h>
19#include <apt-pkg/sourcelist.h>
20#include <apt-pkg/configuration.h>
b2e465d6 21#include <apt-pkg/pkgsystem.h>
aea7f4c8 22#include <apt-pkg/macros.h>
472ff00e
DK
23#include <apt-pkg/metaindex.h>
24#include <apt-pkg/fileutl.h>
453b82a3
DK
25#include <apt-pkg/hashsum_template.h>
26#include <apt-pkg/indexfile.h>
27#include <apt-pkg/md5.h>
28#include <apt-pkg/mmap.h>
29#include <apt-pkg/pkgcache.h>
30#include <apt-pkg/cacheiterators.h>
31
32#include <stddef.h>
33#include <string.h>
34#include <iostream>
35#include <string>
e7b470ee 36#include <vector>
5465192b
DK
37#include <memory>
38#include <algorithm>
578bfd0a
AL
39#include <sys/stat.h>
40#include <unistd.h>
ea542140
DK
41
42#include <apti18n.h>
350d30d2
JAK
43
44template<class T> using Dynamic = pkgCacheGenerator::Dynamic<T>; /*}}}*/
73688d27 45typedef std::vector<pkgIndexFile *>::iterator FileIterator;
d10cef82 46template <typename Iter> std::vector<Iter*> pkgCacheGenerator::Dynamic<Iter>::toReMap;
578bfd0a 47
60683765 48static bool IsDuplicateDescription(pkgCache::DescIterator Desc,
5f4db009
DK
49 MD5SumValue const &CurMd5, std::string const &CurLang);
50
73688d27
DK
51using std::string;
52
578bfd0a
AL
53// CacheGenerator::pkgCacheGenerator - Constructor /*{{{*/
54// ---------------------------------------------------------------------
25396fb0 55/* We set the dirty flag and make sure that is written to the disk */
b2e465d6 56pkgCacheGenerator::pkgCacheGenerator(DynamicMMap *pMap,OpProgress *Prog) :
45415543 57 Map(*pMap), Cache(pMap,false), Progress(Prog),
1d3eea5c 58 CurrentRlsFile(NULL), CurrentFile(NULL), d(NULL)
578bfd0a 59{
578bfd0a
AL
60 if (Map.Size() == 0)
61 {
b2e465d6
AL
62 // Setup the map interface..
63 Cache.HeaderP = (pkgCache::Header *)Map.Data();
95278287
DK
64 _error->PushToStack();
65 Map.RawAllocate(sizeof(pkgCache::Header));
66 bool const newError = _error->PendingError();
67 _error->MergeWithStack();
68 if (newError)
c5f44afc
DK
69 return;
70
b2e465d6 71 Map.UsePools(*Cache.HeaderP->Pools,sizeof(Cache.HeaderP->Pools)/sizeof(Cache.HeaderP->Pools[0]));
c5f44afc 72
b2e465d6 73 // Starting header
578bfd0a 74 *Cache.HeaderP = pkgCache::Header();
e8a7b0b2
DK
75
76 // make room for the hashtables for packages and groups
32ab4bd0 77 if (Map.RawAllocate(2 * (Cache.HeaderP->GetHashTableSize() * sizeof(map_pointer_t))) == 0)
e8a7b0b2
DK
78 return;
79
4ad8619b 80 map_stringitem_t const idxVerSysName = WriteStringInMap(_system->VS->Label);
7a223b93
DK
81 if (unlikely(idxVerSysName == 0))
82 return;
a9fe5928 83 Cache.HeaderP->VerSysName = idxVerSysName;
78a5476f 84 map_stringitem_t const idxArchitecture = StoreString(MIXED, _config->Find("APT::Architecture"));
7a223b93 85 if (unlikely(idxArchitecture == 0))
a9fe5928 86 return;
7a223b93
DK
87 Cache.HeaderP->Architecture = idxArchitecture;
88
89 std::vector<std::string> archs = APT::Configuration::getArchitectures();
90 if (archs.size() > 1)
91 {
92 std::vector<std::string>::const_iterator a = archs.begin();
93 std::string list = *a;
94 for (++a; a != archs.end(); ++a)
95 list.append(",").append(*a);
4ad8619b 96 map_stringitem_t const idxArchitectures = WriteStringInMap(list);
7a223b93
DK
97 if (unlikely(idxArchitectures == 0))
98 return;
32ab4bd0 99 Cache.HeaderP->SetArchitectures(idxArchitectures);
7a223b93
DK
100 }
101 else
32ab4bd0 102 Cache.HeaderP->SetArchitectures(idxArchitecture);
7a223b93 103
c5f44afc 104 Cache.ReMap();
578bfd0a 105 }
b2e465d6
AL
106 else
107 {
108 // Map directly from the existing file
109 Cache.ReMap();
110 Map.UsePools(*Cache.HeaderP->Pools,sizeof(Cache.HeaderP->Pools)/sizeof(Cache.HeaderP->Pools[0]));
111 if (Cache.VS != _system->VS)
112 {
113 _error->Error(_("Cache has an incompatible versioning system"));
114 return;
e8a7b0b2 115 }
b2e465d6 116 }
e8a7b0b2 117
578bfd0a
AL
118 Cache.HeaderP->Dirty = true;
119 Map.Sync(0,sizeof(pkgCache::Header));
578bfd0a
AL
120}
121 /*}}}*/
122// CacheGenerator::~pkgCacheGenerator - Destructor /*{{{*/
123// ---------------------------------------------------------------------
124/* We sync the data then unset the dirty flag in two steps so as to
125 advoid a problem during a crash */
126pkgCacheGenerator::~pkgCacheGenerator()
127{
128 if (_error->PendingError() == true)
129 return;
130 if (Map.Sync() == false)
131 return;
132
133 Cache.HeaderP->Dirty = false;
1dfda2ce 134 Cache.HeaderP->CacheFileSize = Map.Size();
578bfd0a
AL
135 Map.Sync(0,sizeof(pkgCache::Header));
136}
137 /*}}}*/
a9fe5928
DK
138void pkgCacheGenerator::ReMap(void const * const oldMap, void const * const newMap) {/*{{{*/
139 if (oldMap == newMap)
140 return;
141
64dda04b
MV
142 if (_config->FindB("Debug::pkgCacheGen", false))
143 std::clog << "Remaping from " << oldMap << " to " << newMap << std::endl;
144
a9fe5928
DK
145 Cache.ReMap(false);
146
cf4ff3b7 147 CurrentFile += (pkgCache::PackageFile const * const) newMap - (pkgCache::PackageFile const * const) oldMap;
b07aeb1a 148 CurrentRlsFile += (pkgCache::ReleaseFile const * const) newMap - (pkgCache::ReleaseFile const * const) oldMap;
a9fe5928 149
7635093c 150 for (std::vector<pkgCache::GrpIterator*>::const_iterator i = Dynamic<pkgCache::GrpIterator>::toReMap.begin();
a9fe5928 151 i != Dynamic<pkgCache::GrpIterator>::toReMap.end(); ++i)
f7a35f2e 152 (*i)->ReMap(oldMap, newMap);
7635093c 153 for (std::vector<pkgCache::PkgIterator*>::const_iterator i = Dynamic<pkgCache::PkgIterator>::toReMap.begin();
a9fe5928 154 i != Dynamic<pkgCache::PkgIterator>::toReMap.end(); ++i)
f7a35f2e 155 (*i)->ReMap(oldMap, newMap);
7635093c 156 for (std::vector<pkgCache::VerIterator*>::const_iterator i = Dynamic<pkgCache::VerIterator>::toReMap.begin();
a9fe5928 157 i != Dynamic<pkgCache::VerIterator>::toReMap.end(); ++i)
f7a35f2e 158 (*i)->ReMap(oldMap, newMap);
7635093c 159 for (std::vector<pkgCache::DepIterator*>::const_iterator i = Dynamic<pkgCache::DepIterator>::toReMap.begin();
a9fe5928 160 i != Dynamic<pkgCache::DepIterator>::toReMap.end(); ++i)
f7a35f2e 161 (*i)->ReMap(oldMap, newMap);
7635093c 162 for (std::vector<pkgCache::DescIterator*>::const_iterator i = Dynamic<pkgCache::DescIterator>::toReMap.begin();
a9fe5928 163 i != Dynamic<pkgCache::DescIterator>::toReMap.end(); ++i)
f7a35f2e 164 (*i)->ReMap(oldMap, newMap);
7635093c 165 for (std::vector<pkgCache::PrvIterator*>::const_iterator i = Dynamic<pkgCache::PrvIterator>::toReMap.begin();
a9fe5928 166 i != Dynamic<pkgCache::PrvIterator>::toReMap.end(); ++i)
f7a35f2e 167 (*i)->ReMap(oldMap, newMap);
7635093c 168 for (std::vector<pkgCache::PkgFileIterator*>::const_iterator i = Dynamic<pkgCache::PkgFileIterator>::toReMap.begin();
a9fe5928 169 i != Dynamic<pkgCache::PkgFileIterator>::toReMap.end(); ++i)
f7a35f2e 170 (*i)->ReMap(oldMap, newMap);
b07aeb1a
DK
171 for (std::vector<pkgCache::RlsFileIterator*>::const_iterator i = Dynamic<pkgCache::RlsFileIterator>::toReMap.begin();
172 i != Dynamic<pkgCache::RlsFileIterator>::toReMap.end(); ++i)
173 (*i)->ReMap(oldMap, newMap);
a9fe5928 174} /*}}}*/
7e58ab0c 175// CacheGenerator::WriteStringInMap /*{{{*/
4ad8619b 176map_stringitem_t pkgCacheGenerator::WriteStringInMap(const char *String,
7e58ab0c 177 const unsigned long &Len) {
a9fe5928 178 void const * const oldMap = Map.Data();
4ad8619b 179 map_stringitem_t const index = Map.WriteString(String, Len);
a9fe5928
DK
180 if (index != 0)
181 ReMap(oldMap, Map.Data());
182 return index;
7e58ab0c
DK
183}
184 /*}}}*/
185// CacheGenerator::WriteStringInMap /*{{{*/
4ad8619b 186map_stringitem_t pkgCacheGenerator::WriteStringInMap(const char *String) {
a9fe5928 187 void const * const oldMap = Map.Data();
4ad8619b 188 map_stringitem_t const index = Map.WriteString(String);
a9fe5928
DK
189 if (index != 0)
190 ReMap(oldMap, Map.Data());
191 return index;
7e58ab0c
DK
192}
193 /*}}}*/
4ad8619b 194map_pointer_t pkgCacheGenerator::AllocateInMap(const unsigned long &size) {/*{{{*/
a9fe5928 195 void const * const oldMap = Map.Data();
4ad8619b 196 map_pointer_t const index = Map.Allocate(size);
a9fe5928
DK
197 if (index != 0)
198 ReMap(oldMap, Map.Data());
199 return index;
7e58ab0c
DK
200}
201 /*}}}*/
578bfd0a
AL
202// CacheGenerator::MergeList - Merge the package list /*{{{*/
203// ---------------------------------------------------------------------
204/* This provides the generation of the entries in the cache. Each loop
205 goes through a single package record from the underlying parse engine. */
ddc1d8d0
AL
206bool pkgCacheGenerator::MergeList(ListParser &List,
207 pkgCache::VerIterator *OutVer)
578bfd0a
AL
208{
209 List.Owner = this;
0149949b 210
f9eec0e7 211 unsigned int Counter = 0;
0149949b 212 while (List.Step() == true)
578bfd0a 213 {
5bf15716 214 string const PackageName = List.Package();
65a1e968
AL
215 if (PackageName.empty() == true)
216 return false;
5bf15716 217
99a2ea5a
DK
218 Counter++;
219 if (Counter % 100 == 0 && Progress != 0)
220 Progress->Progress(List.Offset());
221
222 string Arch = List.Architecture();
223 string const Version = List.Version();
224 if (Version.empty() == true && Arch.empty() == true)
225 {
8ec00880 226 // package descriptions
99a2ea5a
DK
227 if (MergeListGroup(List, PackageName) == false)
228 return false;
8ec00880 229 continue;
99a2ea5a
DK
230 }
231
8b32e920 232 // Get a pointer to the package structure
9ddf7030 233 pkgCache::PkgIterator Pkg;
a9fe5928 234 Dynamic<pkgCache::PkgIterator> DynPkg(Pkg);
28166356 235 if (NewPackage(Pkg, PackageName, Arch) == false)
79e9003c
DK
236 // TRANSLATOR: The first placeholder is a package name,
237 // the other two should be copied verbatim as they include debug info
238 return _error->Error(_("Error occurred while processing %s (%s%d)"),
239 PackageName.c_str(), "NewPackage", 1);
8ce4327b 240
99a2ea5a 241
f55a958f
AL
242 if (Version.empty() == true)
243 {
99a2ea5a
DK
244 if (MergeListPackage(List, Pkg) == false)
245 return false;
246 }
247 else
248 {
249 if (MergeListVersion(List, Pkg, Version, OutVer) == false)
250 return false;
251 }
770c32ec 252
99a2ea5a 253 if (OutVer != 0)
99a2ea5a 254 return true;
99a2ea5a
DK
255 }
256
4ad8619b 257 if (Cache.HeaderP->PackageCount >= std::numeric_limits<map_id_t>::max())
99a2ea5a
DK
258 return _error->Error(_("Wow, you exceeded the number of package "
259 "names this APT is capable of."));
4ad8619b 260 if (Cache.HeaderP->VersionCount >= std::numeric_limits<map_id_t>::max())
99a2ea5a
DK
261 return _error->Error(_("Wow, you exceeded the number of versions "
262 "this APT is capable of."));
4ad8619b 263 if (Cache.HeaderP->DescriptionCount >= std::numeric_limits<map_id_t>::max())
99a2ea5a
DK
264 return _error->Error(_("Wow, you exceeded the number of descriptions "
265 "this APT is capable of."));
4ad8619b 266 if (Cache.HeaderP->DependsCount >= std::numeric_limits<map_id_t>::max())
99a2ea5a
DK
267 return _error->Error(_("Wow, you exceeded the number of dependencies "
268 "this APT is capable of."));
269
99a2ea5a
DK
270 return true;
271}
272// CacheGenerator::MergeListGroup /*{{{*/
273bool pkgCacheGenerator::MergeListGroup(ListParser &List, std::string const &GrpName)
274{
275 pkgCache::GrpIterator Grp = Cache.FindGrp(GrpName);
5f4db009
DK
276 // a group has no data on it's own, only packages have it but these
277 // stanzas like this come from Translation- files to add descriptions,
278 // but without a version we don't need a description for it…
99a2ea5a 279 if (Grp.end() == true)
5f4db009 280 return true;
99a2ea5a
DK
281 Dynamic<pkgCache::GrpIterator> DynGrp(Grp);
282
283 pkgCache::PkgIterator Pkg;
284 Dynamic<pkgCache::PkgIterator> DynPkg(Pkg);
285 for (Pkg = Grp.PackageList(); Pkg.end() == false; Pkg = Grp.NextPkg(Pkg))
286 if (MergeListPackage(List, Pkg) == false)
287 return false;
288
289 return true;
290}
291 /*}}}*/
292// CacheGenerator::MergeListPackage /*{{{*/
293bool pkgCacheGenerator::MergeListPackage(ListParser &List, pkgCache::PkgIterator &Pkg)
294{
295 // we first process the package, then the descriptions
296 // (for deb this package processing is in fact a no-op)
297 pkgCache::VerIterator Ver(Cache);
298 Dynamic<pkgCache::VerIterator> DynVer(Ver);
299 if (List.UsePackage(Pkg, Ver) == false)
79e9003c
DK
300 return _error->Error(_("Error occurred while processing %s (%s%d)"),
301 Pkg.Name(), "UsePackage", 1);
99a2ea5a
DK
302
303 // Find the right version to write the description
304 MD5SumValue CurMd5 = List.Description_md5();
ffe3c68e 305 if (CurMd5.Value().empty() == true && List.Description("").empty() == true)
99359751 306 return true;
ffe3c68e 307 std::vector<std::string> availDesc = List.AvailableDescriptionLanguages();
99a2ea5a
DK
308 for (Ver = Pkg.VersionList(); Ver.end() == false; ++Ver)
309 {
a65e22c6 310 pkgCache::DescIterator VerDesc = Ver.DescriptionList();
22f07fc5
DK
311
312 // a version can only have one md5 describing it
a65e22c6 313 if (VerDesc.end() == true || MD5SumValue(VerDesc.md5()) != CurMd5)
22f07fc5 314 continue;
99a2ea5a 315
4ad8619b 316 map_stringitem_t md5idx = VerDesc->md5sum;
ffe3c68e
DK
317 for (std::vector<std::string>::const_iterator CurLang = availDesc.begin(); CurLang != availDesc.end(); ++CurLang)
318 {
319 // don't add a new description if we have one for the given
320 // md5 && language
321 if (IsDuplicateDescription(VerDesc, CurMd5, *CurLang) == true)
322 continue;
a65e22c6 323
ffe3c68e
DK
324 AddNewDescription(List, Ver, *CurLang, CurMd5, md5idx);
325 }
22f07fc5
DK
326
327 // we can stop here as all "same" versions will share the description
328 break;
99a2ea5a
DK
329 }
330
331 return true;
332}
333 /*}}}*/
334// CacheGenerator::MergeListVersion /*{{{*/
335bool pkgCacheGenerator::MergeListVersion(ListParser &List, pkgCache::PkgIterator &Pkg,
336 std::string const &Version, pkgCache::VerIterator* &OutVer)
337{
338 pkgCache::VerIterator Ver = Pkg.VersionList();
339 Dynamic<pkgCache::VerIterator> DynVer(Ver);
4ad8619b 340 map_pointer_t *LastVer = &Pkg->VersionList;
99a2ea5a
DK
341 void const * oldMap = Map.Data();
342
68134bda 343 unsigned short const Hash = List.VersionHash();
99a2ea5a
DK
344 if (Ver.end() == false)
345 {
346 /* We know the list is sorted so we use that fact in the search.
347 Insertion of new versions is done with correct sorting */
2246928b 348 int Res = 1;
804de19f 349 for (; Ver.end() == false; LastVer = &Ver->NextVer, ++Ver)
578bfd0a 350 {
c24972cb 351 Res = Cache.VS->CmpVersion(Version,Ver.VerStr());
7e2b56a3
DK
352 // Version is higher as current version - insert here
353 if (Res > 0)
578bfd0a 354 break;
7e2b56a3 355 // Versionstrings are equal - is hash also equal?
68134bda 356 if (Res == 0 && List.SameVersion(Hash, Ver) == true)
7e2b56a3
DK
357 break;
358 // proceed with the next till we have either the right
359 // or we found another version (which will be lower)
578bfd0a 360 }
7e2b56a3
DK
361
362 /* We already have a version for this item, record that we saw it */
e426a5ff 363 if (Res == 0 && Ver.end() == false && Ver->Hash == Hash)
578bfd0a 364 {
f55a958f 365 if (List.UsePackage(Pkg,Ver) == false)
79e9003c
DK
366 return _error->Error(_("Error occurred while processing %s (%s%d)"),
367 Pkg.Name(), "UsePackage", 2);
f78439bf 368
578bfd0a 369 if (NewFileVer(Ver,List) == false)
79e9003c
DK
370 return _error->Error(_("Error occurred while processing %s (%s%d)"),
371 Pkg.Name(), "NewFileVer", 1);
99a2ea5a 372
ddc1d8d0
AL
373 // Read only a single record and return
374 if (OutVer != 0)
375 {
376 *OutVer = Ver;
377 return true;
378 }
99a2ea5a
DK
379
380 return true;
204fbdcc 381 }
99a2ea5a 382 }
204fbdcc 383
99a2ea5a 384 // Add a new version
4ad8619b 385 map_pointer_t const verindex = NewVersion(Ver, Version, Pkg.Index(), Hash, *LastVer);
95278287 386 if (unlikely(verindex == 0))
79e9003c
DK
387 return _error->Error(_("Error occurred while processing %s (%s%d)"),
388 Pkg.Name(), "NewVersion", 1);
a9fe5928 389
99a2ea5a 390 if (oldMap != Map.Data())
4ad8619b 391 LastVer += (map_pointer_t const * const) Map.Data() - (map_pointer_t const * const) oldMap;
99a2ea5a 392 *LastVer = verindex;
a52f938b 393
79e9003c
DK
394 if (unlikely(List.NewVersion(Ver) == false))
395 return _error->Error(_("Error occurred while processing %s (%s%d)"),
396 Pkg.Name(), "NewVersion", 2);
a9fe5928 397
79e9003c
DK
398 if (unlikely(List.UsePackage(Pkg,Ver) == false))
399 return _error->Error(_("Error occurred while processing %s (%s%d)"),
400 Pkg.Name(), "UsePackage", 3);
401
402 if (unlikely(NewFileVer(Ver,List) == false))
403 return _error->Error(_("Error occurred while processing %s (%s%d)"),
404 Pkg.Name(), "NewFileVer", 2);
a52f938b 405
5a8e963b
DK
406 pkgCache::GrpIterator Grp = Pkg.Group();
407 Dynamic<pkgCache::GrpIterator> DynGrp(Grp);
408
409 /* If it is the first version of this package we need to add implicit
410 Multi-Arch dependencies to all other package versions in the group now -
411 otherwise we just add them for this new version */
412 if (Pkg.VersionList()->NextVer == 0)
413 {
414 pkgCache::PkgIterator P = Grp.PackageList();
415 Dynamic<pkgCache::PkgIterator> DynP(P);
416 for (; P.end() != true; P = Grp.NextPkg(P))
417 {
418 if (P->ID == Pkg->ID)
419 continue;
420 pkgCache::VerIterator V = P.VersionList();
421 Dynamic<pkgCache::VerIterator> DynV(V);
422 for (; V.end() != true; ++V)
423 if (unlikely(AddImplicitDepends(V, Pkg) == false))
424 return _error->Error(_("Error occurred while processing %s (%s%d)"),
425 Pkg.Name(), "AddImplicitDepends", 1);
426 }
427 }
428 if (unlikely(AddImplicitDepends(Grp, Pkg, Ver) == false))
429 return _error->Error(_("Error occurred while processing %s (%s%d)"),
430 Pkg.Name(), "AddImplicitDepends", 2);
a52f938b 431
99a2ea5a
DK
432 // Read only a single record and return
433 if (OutVer != 0)
434 {
435 *OutVer = Ver;
436 return true;
578bfd0a 437 }
0149949b 438
ffe3c68e 439 /* Record the Description(s) based on their master md5sum */
5f4db009 440 MD5SumValue CurMd5 = List.Description_md5();
ffe3c68e 441 if (CurMd5.Value().empty() == true && List.Description("").empty() == true)
5f4db009 442 return true;
5f4db009
DK
443
444 /* Before we add a new description we first search in the group for
445 a version with a description of the same MD5 - if so we reuse this
446 description group instead of creating our own for this version */
5f4db009
DK
447 for (pkgCache::PkgIterator P = Grp.PackageList();
448 P.end() == false; P = Grp.NextPkg(P))
449 {
450 for (pkgCache::VerIterator V = P.VersionList();
451 V.end() == false; ++V)
452 {
ffe3c68e 453 if (V->DescriptionList == 0 || MD5SumValue(V.DescriptionList().md5()) != CurMd5)
5f4db009
DK
454 continue;
455 Ver->DescriptionList = V->DescriptionList;
5f4db009
DK
456 }
457 }
458
ffe3c68e 459 // We haven't found reusable descriptions, so add the first description(s)
4ad8619b 460 map_stringitem_t md5idx = Ver->DescriptionList == 0 ? 0 : Ver.DescriptionList()->md5sum;
ffe3c68e
DK
461 std::vector<std::string> availDesc = List.AvailableDescriptionLanguages();
462 for (std::vector<std::string>::const_iterator CurLang = availDesc.begin(); CurLang != availDesc.end(); ++CurLang)
463 if (AddNewDescription(List, Ver, *CurLang, CurMd5, md5idx) == false)
464 return false;
465 return true;
466}
467 /*}}}*/
4ad8619b 468bool pkgCacheGenerator::AddNewDescription(ListParser &List, pkgCache::VerIterator &Ver, std::string const &lang, MD5SumValue const &CurMd5, map_stringitem_t &md5idx) /*{{{*/
ffe3c68e
DK
469{
470 pkgCache::DescIterator Desc;
99a2ea5a 471 Dynamic<pkgCache::DescIterator> DynDesc(Desc);
99a2ea5a 472
4ad8619b 473 map_pointer_t const descindex = NewDescription(Desc, lang, CurMd5, md5idx);
95278287 474 if (unlikely(descindex == 0))
5954d4d2 475 return _error->Error(_("Error occurred while processing %s (%s%d)"),
ffe3c68e
DK
476 Ver.ParentPkg().Name(), "NewDescription", 1);
477
478 md5idx = Desc->md5sum;
479 Desc->ParentPkg = Ver.ParentPkg().Index();
a65e22c6 480
ffe3c68e
DK
481 // we add at the end, so that the start is constant as we need
482 // that to be able to efficiently share these lists
483 pkgCache::DescIterator VerDesc = Ver.DescriptionList(); // old value might be invalid after ReMap
484 for (;VerDesc.end() == false && VerDesc->NextDesc != 0; ++VerDesc);
4ad8619b 485 map_pointer_t * const LastNextDesc = (VerDesc.end() == true) ? &Ver->DescriptionList : &VerDesc->NextDesc;
ffe3c68e 486 *LastNextDesc = descindex;
99a2ea5a 487
a65e22c6 488 if (NewFileDesc(Desc,List) == false)
79e9003c 489 return _error->Error(_("Error occurred while processing %s (%s%d)"),
ffe3c68e 490 Ver.ParentPkg().Name(), "NewFileDesc", 1);
45415543 491
578bfd0a
AL
492 return true;
493}
494 /*}}}*/
99a2ea5a 495 /*}}}*/
5bf15716
DK
496// CacheGenerator::NewGroup - Add a new group /*{{{*/
497// ---------------------------------------------------------------------
498/* This creates a new group structure and adds it to the hash table */
33dd02e3
DK
499bool pkgCacheGenerator::NewGroup(pkgCache::GrpIterator &Grp, const string &Name)
500{
501 Grp = Cache.FindGrp(Name);
502 if (Grp.end() == false)
503 return true;
5bf15716 504
33dd02e3 505 // Get a structure
4ad8619b 506 map_pointer_t const Group = AllocateInMap(sizeof(pkgCache::Group));
33dd02e3
DK
507 if (unlikely(Group == 0))
508 return false;
5bf15716 509
33dd02e3 510 Grp = pkgCache::GrpIterator(Cache, Cache.GrpP + Group);
b13ce62c 511 map_stringitem_t const idxName = StoreString(PKGNAME, Name);
a9fe5928 512 if (unlikely(idxName == 0))
33dd02e3 513 return false;
a9fe5928 514 Grp->Name = idxName;
5bf15716 515
33dd02e3
DK
516 // Insert it into the hash table
517 unsigned long const Hash = Cache.Hash(Name);
32ab4bd0 518 map_pointer_t *insertAt = &Cache.HeaderP->GrpHashTableP()[Hash];
aa0fe657
DK
519 while (*insertAt != 0 && strcasecmp(Name.c_str(), Cache.StrP + (Cache.GrpP + *insertAt)->Name) > 0)
520 insertAt = &(Cache.GrpP + *insertAt)->Next;
521 Grp->Next = *insertAt;
522 *insertAt = Group;
5bf15716 523
52c41485 524 Grp->ID = Cache.HeaderP->GroupCount++;
33dd02e3 525 return true;
5bf15716
DK
526}
527 /*}}}*/
578bfd0a
AL
528// CacheGenerator::NewPackage - Add a new package /*{{{*/
529// ---------------------------------------------------------------------
530/* This creates a new package structure and adds it to the hash table */
5bf15716
DK
531bool pkgCacheGenerator::NewPackage(pkgCache::PkgIterator &Pkg,const string &Name,
532 const string &Arch) {
533 pkgCache::GrpIterator Grp;
a9fe5928 534 Dynamic<pkgCache::GrpIterator> DynGrp(Grp);
5bf15716
DK
535 if (unlikely(NewGroup(Grp, Name) == false))
536 return false;
537
538 Pkg = Grp.FindPkg(Arch);
539 if (Pkg.end() == false)
540 return true;
a52f938b 541
578bfd0a 542 // Get a structure
4ad8619b 543 map_pointer_t const Package = AllocateInMap(sizeof(pkgCache::Package));
5bf15716 544 if (unlikely(Package == 0))
578bfd0a 545 return false;
f55a958f 546 Pkg = pkgCache::PkgIterator(Cache,Cache.PkgP + Package);
5bf15716 547
ecc138f8
DK
548 // Set the name, arch and the ID
549 APT_IGNORE_DEPRECATED(Pkg->Name = Grp->Name;)
550 Pkg->Group = Grp.Index();
551 // all is mapped to the native architecture
552 map_stringitem_t const idxArch = (Arch == "all") ? Cache.HeaderP->Architecture : StoreString(MIXED, Arch);
553 if (unlikely(idxArch == 0))
554 return false;
555 Pkg->Arch = idxArch;
556 Pkg->ID = Cache.HeaderP->PackageCount++;
557
c408e01e
DK
558 // Insert the package into our package list
559 if (Grp->FirstPackage == 0) // the group is new
560 {
aa0fe657 561 Grp->FirstPackage = Package;
c408e01e 562 // Insert it into the hash table
4ad8619b 563 map_id_t const Hash = Cache.Hash(Name);
32ab4bd0 564 map_pointer_t *insertAt = &Cache.HeaderP->PkgHashTableP()[Hash];
fe86debb 565 while (*insertAt != 0 && strcasecmp(Name.c_str(), Cache.StrP + (Cache.GrpP + (Cache.PkgP + *insertAt)->Group)->Name) > 0)
32ab4bd0
DK
566 insertAt = &(Cache.PkgP + *insertAt)->NextPackage;
567 Pkg->NextPackage = *insertAt;
aa0fe657 568 *insertAt = Package;
c408e01e
DK
569 }
570 else // Group the Packages together
571 {
ecc138f8
DK
572 // but first get implicit provides done
573 if (APT::Configuration::checkArchitecture(Pkg.Arch()) == true)
574 {
575 pkgCache::PkgIterator const M = Grp.FindPreferredPkg(false); // native or any foreign pkg will do
a6deb7a0
JAK
576 if (M.end() == false) {
577 pkgCache::PrvIterator Prv;
578 Dynamic<pkgCache::PrvIterator> DynPrv(Prv);
579 for (Prv = M.ProvidesList(); Prv.end() == false; ++Prv)
ecc138f8
DK
580 {
581 if ((Prv->Flags & pkgCache::Flag::ArchSpecific) != 0)
582 continue;
583 pkgCache::VerIterator Ver = Prv.OwnerVer();
a6deb7a0 584 Dynamic<pkgCache::VerIterator> DynVer(Ver);
ecc138f8
DK
585 if ((Ver->MultiArch & pkgCache::Version::Allowed) == pkgCache::Version::Allowed ||
586 ((Ver->MultiArch & pkgCache::Version::Foreign) == pkgCache::Version::Foreign &&
587 (Prv->Flags & pkgCache::Flag::MultiArchImplicit) == 0))
588 if (NewProvides(Ver, Pkg, Prv->ProvideVersion, Prv->Flags) == false)
589 return false;
590 }
a6deb7a0
JAK
591 }
592
593
594 pkgCache::PkgIterator P;
595 pkgCache::VerIterator Ver;
596 Dynamic<pkgCache::PkgIterator> DynP(P);
597 Dynamic<pkgCache::VerIterator> DynVer(Ver);
ecc138f8 598
a6deb7a0
JAK
599 for (P = Grp.PackageList(); P.end() == false; P = Grp.NextPkg(P))
600 for (Ver = P.VersionList(); Ver.end() == false; ++Ver)
ecc138f8
DK
601 if ((Ver->MultiArch & pkgCache::Version::Foreign) == pkgCache::Version::Foreign)
602 if (NewProvides(Ver, Pkg, Ver->VerStr, pkgCache::Flag::MultiArchImplicit) == false)
603 return false;
604 }
bb0f6a34
DK
605 // and negative dependencies, don't forget negative dependencies
606 {
607 pkgCache::PkgIterator const M = Grp.FindPreferredPkg(false);
05c001c8
JAK
608 if (M.end() == false) {
609 pkgCache::DepIterator Dep;
610 Dynamic<pkgCache::DepIterator> DynDep(Dep);
611 for (Dep = M.RevDependsList(); Dep.end() == false; ++Dep)
bb0f6a34
DK
612 {
613 if ((Dep->CompareOp & (pkgCache::Dep::ArchSpecific | pkgCache::Dep::MultiArchImplicit)) != 0)
614 continue;
615 if (Dep->Type != pkgCache::Dep::DpkgBreaks && Dep->Type != pkgCache::Dep::Conflicts &&
616 Dep->Type != pkgCache::Dep::Replaces)
617 continue;
618 pkgCache::VerIterator Ver = Dep.ParentVer();
05c001c8 619 Dynamic<pkgCache::VerIterator> DynVer(Ver);
bb0f6a34
DK
620 map_pointer_t * unused = NULL;
621 if (NewDepends(Pkg, Ver, Dep->Version, Dep->CompareOp, Dep->Type, unused) == false)
622 return false;
623 }
05c001c8 624 }
bb0f6a34 625 }
ecc138f8 626
c408e01e
DK
627 // this package is the new last package
628 pkgCache::PkgIterator LastPkg(Cache, Cache.PkgP + Grp->LastPackage);
32ab4bd0
DK
629 Pkg->NextPackage = LastPkg->NextPackage;
630 LastPkg->NextPackage = Package;
c408e01e
DK
631 }
632 Grp->LastPackage = Package;
3addaba1
DK
633
634 // lazy-create foo (of amd64) provides foo:amd64 at the time we first need it
635 if (Arch == "any")
636 {
637 size_t const found = Name.find(':');
638 std::string const NameA = Name.substr(0, found);
639 std::string const ArchA = Name.substr(found + 1);
640 pkgCache::PkgIterator PkgA = Cache.FindPkg(NameA, ArchA);
641 if (PkgA.end() == false)
642 {
643 Dynamic<pkgCache::PkgIterator> DynPkgA(PkgA);
644 pkgCache::PrvIterator Prv = PkgA.ProvidesList();
645 for (; Prv.end() == false; ++Prv)
646 {
647 if (Prv.IsMultiArchImplicit())
648 continue;
649 pkgCache::VerIterator V = Prv.OwnerVer();
650 if (ArchA != V.ParentPkg().Arch())
651 continue;
652 if (NewProvides(V, Pkg, V->VerStr, pkgCache::Flag::MultiArchImplicit | pkgCache::Flag::ArchSpecific) == false)
653 return false;
654 }
655 pkgCache::VerIterator V = PkgA.VersionList();
656 Dynamic<pkgCache::VerIterator> DynV(V);
657 for (; V.end() == false; ++V)
658 {
659 if (NewProvides(V, Pkg, V->VerStr, pkgCache::Flag::MultiArchImplicit | pkgCache::Flag::ArchSpecific) == false)
660 return false;
661 }
662 }
663 }
578bfd0a
AL
664 return true;
665}
5a8e963b
DK
666 /*}}}*/
667// CacheGenerator::AddImplicitDepends /*{{{*/
668bool pkgCacheGenerator::AddImplicitDepends(pkgCache::GrpIterator &G,
669 pkgCache::PkgIterator &P,
670 pkgCache::VerIterator &V)
671{
672 // copy P.Arch() into a string here as a cache remap
673 // in NewDepends() later may alter the pointer location
674 string Arch = P.Arch() == NULL ? "" : P.Arch();
4ad8619b 675 map_pointer_t *OldDepLast = NULL;
5a8e963b
DK
676 /* MultiArch handling introduces a lot of implicit Dependencies:
677 - MultiArch: same → Co-Installable if they have the same version
678 - All others conflict with all other group members */
679 bool const coInstall = ((V->MultiArch & pkgCache::Version::Same) == pkgCache::Version::Same);
680 pkgCache::PkgIterator D = G.PackageList();
681 Dynamic<pkgCache::PkgIterator> DynD(D);
4ad8619b 682 map_stringitem_t const VerStrIdx = V->VerStr;
5a8e963b
DK
683 for (; D.end() != true; D = G.NextPkg(D))
684 {
685 if (Arch == D.Arch() || D->VersionList == 0)
686 continue;
687 /* We allow only one installed arch at the time
688 per group, therefore each group member conflicts
689 with all other group members */
690 if (coInstall == true)
691 {
692 // Replaces: ${self}:other ( << ${binary:Version})
9c44383f 693 NewDepends(D, V, VerStrIdx,
8c7af4d4 694 pkgCache::Dep::Less | pkgCache::Dep::MultiArchImplicit, pkgCache::Dep::Replaces,
5a8e963b
DK
695 OldDepLast);
696 // Breaks: ${self}:other (!= ${binary:Version})
9c44383f 697 NewDepends(D, V, VerStrIdx,
8c7af4d4 698 pkgCache::Dep::NotEquals | pkgCache::Dep::MultiArchImplicit, pkgCache::Dep::DpkgBreaks,
5a8e963b
DK
699 OldDepLast);
700 } else {
701 // Conflicts: ${self}:other
9c44383f 702 NewDepends(D, V, 0,
8c7af4d4 703 pkgCache::Dep::NoOp | pkgCache::Dep::MultiArchImplicit, pkgCache::Dep::Conflicts,
5a8e963b
DK
704 OldDepLast);
705 }
706 }
707 return true;
708}
709bool pkgCacheGenerator::AddImplicitDepends(pkgCache::VerIterator &V,
710 pkgCache::PkgIterator &D)
711{
712 /* MultiArch handling introduces a lot of implicit Dependencies:
713 - MultiArch: same → Co-Installable if they have the same version
714 - All others conflict with all other group members */
4ad8619b 715 map_pointer_t *OldDepLast = NULL;
5a8e963b
DK
716 bool const coInstall = ((V->MultiArch & pkgCache::Version::Same) == pkgCache::Version::Same);
717 if (coInstall == true)
718 {
4ad8619b 719 map_stringitem_t const VerStrIdx = V->VerStr;
5a8e963b 720 // Replaces: ${self}:other ( << ${binary:Version})
9c44383f 721 NewDepends(D, V, VerStrIdx,
8c7af4d4 722 pkgCache::Dep::Less | pkgCache::Dep::MultiArchImplicit, pkgCache::Dep::Replaces,
5a8e963b
DK
723 OldDepLast);
724 // Breaks: ${self}:other (!= ${binary:Version})
9c44383f 725 NewDepends(D, V, VerStrIdx,
8c7af4d4 726 pkgCache::Dep::NotEquals | pkgCache::Dep::MultiArchImplicit, pkgCache::Dep::DpkgBreaks,
5a8e963b
DK
727 OldDepLast);
728 } else {
729 // Conflicts: ${self}:other
9c44383f 730 NewDepends(D, V, 0,
8c7af4d4 731 pkgCache::Dep::NoOp | pkgCache::Dep::MultiArchImplicit, pkgCache::Dep::Conflicts,
5a8e963b
DK
732 OldDepLast);
733 }
734 return true;
735}
736
578bfd0a
AL
737 /*}}}*/
738// CacheGenerator::NewFileVer - Create a new File<->Version association /*{{{*/
739// ---------------------------------------------------------------------
740/* */
f55a958f 741bool pkgCacheGenerator::NewFileVer(pkgCache::VerIterator &Ver,
578bfd0a
AL
742 ListParser &List)
743{
ddc1d8d0
AL
744 if (CurrentFile == 0)
745 return true;
746
dcb79bae 747 // Get a structure
4ad8619b 748 map_pointer_t const VerFile = AllocateInMap(sizeof(pkgCache::VerFile));
dcb79bae 749 if (VerFile == 0)
ac2c559b 750 return false;
dcb79bae
AL
751
752 pkgCache::VerFileIterator VF(Cache,Cache.VerFileP + VerFile);
753 VF->File = CurrentFile - Cache.PkgFileP;
03e39e59
AL
754
755 // Link it to the end of the list
4ad8619b 756 map_pointer_t *Last = &Ver->FileList;
f7f0d6c7 757 for (pkgCache::VerFileIterator V = Ver.FileList(); V.end() == false; ++V)
03e39e59
AL
758 Last = &V->NextFile;
759 VF->NextFile = *Last;
760 *Last = VF.Index();
761
dcb79bae
AL
762 VF->Offset = List.Offset();
763 VF->Size = List.Size();
ad00ae81
AL
764 if (Cache.HeaderP->MaxVerFileSize < VF->Size)
765 Cache.HeaderP->MaxVerFileSize = VF->Size;
a7e66b17
AL
766 Cache.HeaderP->VerFileCount++;
767
f55a958f 768 return true;
578bfd0a
AL
769}
770 /*}}}*/
771// CacheGenerator::NewVersion - Create a new Version /*{{{*/
772// ---------------------------------------------------------------------
f55a958f 773/* This puts a version structure in the linked list */
4ad8619b 774map_pointer_t pkgCacheGenerator::NewVersion(pkgCache::VerIterator &Ver,
171c75f1 775 const string &VerStr,
4ad8619b
DK
776 map_pointer_t const ParentPkg,
777 unsigned short const Hash,
778 map_pointer_t const Next)
578bfd0a 779{
f55a958f 780 // Get a structure
4ad8619b 781 map_pointer_t const Version = AllocateInMap(sizeof(pkgCache::Version));
f55a958f 782 if (Version == 0)
0149949b 783 return 0;
f55a958f
AL
784
785 // Fill it in
786 Ver = pkgCache::VerIterator(Cache,Cache.VerP + Version);
dfe45e1f 787 //Dynamic<pkgCache::VerIterator> DynV(Ver); // caller MergeListVersion already takes care of it
f55a958f 788 Ver->NextVer = Next;
885594fc
DK
789 Ver->ParentPkg = ParentPkg;
790 Ver->Hash = Hash;
f55a958f 791 Ver->ID = Cache.HeaderP->VersionCount++;
885594fc
DK
792
793 // try to find the version string in the group for reuse
794 pkgCache::PkgIterator Pkg = Ver.ParentPkg();
795 pkgCache::GrpIterator Grp = Pkg.Group();
796 if (Pkg.end() == false && Grp.end() == false)
797 {
798 for (pkgCache::PkgIterator P = Grp.PackageList(); P.end() == false; P = Grp.NextPkg(P))
799 {
800 if (Pkg == P)
801 continue;
802 for (pkgCache::VerIterator V = P.VersionList(); V.end() == false; ++V)
803 {
804 int const cmp = strcmp(V.VerStr(), VerStr.c_str());
805 if (cmp == 0)
806 {
807 Ver->VerStr = V->VerStr;
808 return Version;
809 }
810 else if (cmp < 0)
811 break;
812 }
813 }
814 }
815 // haven't found the version string, so create
30b45652 816 map_stringitem_t const idxVerStr = StoreString(VERSIONNUMBER, VerStr);
a9fe5928 817 if (unlikely(idxVerStr == 0))
0149949b 818 return 0;
a9fe5928 819 Ver->VerStr = idxVerStr;
0149949b 820 return Version;
578bfd0a
AL
821}
822 /*}}}*/
a52f938b
OS
823// CacheGenerator::NewFileDesc - Create a new File<->Desc association /*{{{*/
824// ---------------------------------------------------------------------
825/* */
826bool pkgCacheGenerator::NewFileDesc(pkgCache::DescIterator &Desc,
827 ListParser &List)
828{
829 if (CurrentFile == 0)
830 return true;
831
832 // Get a structure
4ad8619b 833 map_pointer_t const DescFile = AllocateInMap(sizeof(pkgCache::DescFile));
a52f938b 834 if (DescFile == 0)
c5f44afc 835 return false;
770c32ec 836
a52f938b
OS
837 pkgCache::DescFileIterator DF(Cache,Cache.DescFileP + DescFile);
838 DF->File = CurrentFile - Cache.PkgFileP;
770c32ec 839
a52f938b 840 // Link it to the end of the list
4ad8619b 841 map_pointer_t *Last = &Desc->FileList;
f7f0d6c7 842 for (pkgCache::DescFileIterator D = Desc.FileList(); D.end() == false; ++D)
a52f938b 843 Last = &D->NextFile;
770c32ec 844
a52f938b
OS
845 DF->NextFile = *Last;
846 *Last = DF.Index();
847
848 DF->Offset = List.Offset();
849 DF->Size = List.Size();
850 if (Cache.HeaderP->MaxDescFileSize < DF->Size)
851 Cache.HeaderP->MaxDescFileSize = DF->Size;
852 Cache.HeaderP->DescFileCount++;
853
854 return true;
855}
856 /*}}}*/
857// CacheGenerator::NewDescription - Create a new Description /*{{{*/
858// ---------------------------------------------------------------------
859/* This puts a description structure in the linked list */
4ad8619b 860map_pointer_t pkgCacheGenerator::NewDescription(pkgCache::DescIterator &Desc,
a65e22c6
DK
861 const string &Lang,
862 const MD5SumValue &md5sum,
4ad8619b 863 map_stringitem_t const idxmd5str)
a52f938b
OS
864{
865 // Get a structure
4ad8619b 866 map_pointer_t const Description = AllocateInMap(sizeof(pkgCache::Description));
a52f938b
OS
867 if (Description == 0)
868 return 0;
869
870 // Fill it in
871 Desc = pkgCache::DescIterator(Cache,Cache.DescP + Description);
a52f938b 872 Desc->ID = Cache.HeaderP->DescriptionCount++;
78a5476f 873 map_stringitem_t const idxlanguage_code = StoreString(MIXED, Lang);
a65e22c6 874 if (unlikely(idxlanguage_code == 0))
c5f44afc 875 return 0;
a9fe5928 876 Desc->language_code = idxlanguage_code;
a65e22c6
DK
877
878 if (idxmd5str != 0)
879 Desc->md5sum = idxmd5str;
880 else
881 {
4ad8619b 882 map_stringitem_t const idxmd5sum = WriteStringInMap(md5sum.Value());
a65e22c6
DK
883 if (unlikely(idxmd5sum == 0))
884 return 0;
885 Desc->md5sum = idxmd5sum;
886 }
a52f938b
OS
887
888 return Description;
889}
890 /*}}}*/
25396fb0 891// CacheGenerator::NewDepends - Create a dependency element /*{{{*/
dcb79bae
AL
892// ---------------------------------------------------------------------
893/* This creates a dependency element in the tree. It is linked to the
894 version and to the package that it is pointing to. */
9c44383f
DK
895bool pkgCacheGenerator::NewDepends(pkgCache::PkgIterator &Pkg,
896 pkgCache::VerIterator &Ver,
4ad8619b 897 map_pointer_t const Version,
8c7af4d4
DK
898 uint8_t const Op,
899 uint8_t const Type,
4ad8619b 900 map_pointer_t* &OldDepLast)
dcb79bae 901{
a9fe5928 902 void const * const oldMap = Map.Data();
dcb79bae 903 // Get a structure
4ad8619b 904 map_pointer_t const Dependency = AllocateInMap(sizeof(pkgCache::Dependency));
5bf15716 905 if (unlikely(Dependency == 0))
dcb79bae 906 return false;
9c44383f 907
71c9e95b
DK
908 bool isDuplicate = false;
909 map_pointer_t DependencyData = 0;
b291aa59
DK
910 map_pointer_t PreviousData = 0;
911 if (Pkg->RevDepends != 0)
71c9e95b 912 {
b291aa59
DK
913 pkgCache::Dependency const * const L = Cache.DepP + Pkg->RevDepends;
914 DependencyData = L->DependencyData;
915 do {
916 pkgCache::DependencyData const * const D = Cache.DepDataP + DependencyData;
917 if (Version > D->Version)
918 break;
919 if (D->Version == Version && D->Type == Type && D->CompareOp == Op)
920 {
921 isDuplicate = true;
922 break;
923 }
924 PreviousData = DependencyData;
925 DependencyData = D->NextData;
926 } while (DependencyData != 0);
71c9e95b
DK
927 }
928
929 if (isDuplicate == false)
930 {
71c9e95b
DK
931 DependencyData = AllocateInMap(sizeof(pkgCache::DependencyData));
932 if (unlikely(DependencyData == 0))
933 return false;
71c9e95b 934 }
5bf15716 935
71c9e95b
DK
936 pkgCache::Dependency * Link = Cache.DepP + Dependency;
937 Link->ParentVer = Ver.Index();
938 Link->DependencyData = DependencyData;
939 Link->ID = Cache.HeaderP->DependsCount++;
940
941 pkgCache::DepIterator Dep(Cache, Link);
71c9e95b
DK
942 if (isDuplicate == false)
943 {
944 Dep->Type = Type;
945 Dep->CompareOp = Op;
946 Dep->Version = Version;
947 Dep->Package = Pkg.Index();
948 ++Cache.HeaderP->DependsDataCount;
b291aa59
DK
949 if (PreviousData != 0)
950 {
951 pkgCache::DependencyData * const D = Cache.DepDataP + PreviousData;
952 Dep->NextData = D->NextData;
953 D->NextData = DependencyData;
954 }
955 else if (Pkg->RevDepends != 0)
956 {
957 pkgCache::Dependency const * const D = Cache.DepP + Pkg->RevDepends;
958 Dep->NextData = D->DependencyData;
959 }
960 }
961
962 if (isDuplicate == true || PreviousData != 0)
963 {
964 pkgCache::Dependency * const L = Cache.DepP + Pkg->RevDepends;
965 Link->NextRevDepends = L->NextRevDepends;
966 L->NextRevDepends = Dependency;
71c9e95b
DK
967 }
968 else
969 {
b291aa59
DK
970 Link->NextRevDepends = Pkg->RevDepends;
971 Pkg->RevDepends = Dependency;
71c9e95b 972 }
25396fb0 973
b291aa59 974
25396fb0
DK
975 // Do we know where to link the Dependency to?
976 if (OldDepLast == NULL)
c1a22377 977 {
f9eec0e7 978 OldDepLast = &Ver->DependsList;
f7f0d6c7 979 for (pkgCache::DepIterator D = Ver.DependsList(); D.end() == false; ++D)
f9eec0e7 980 OldDepLast = &D->NextDepends;
a9fe5928 981 } else if (oldMap != Map.Data())
4ad8619b 982 OldDepLast += (map_pointer_t const * const) Map.Data() - (map_pointer_t const * const) oldMap;
45415543 983
f9eec0e7 984 Dep->NextDepends = *OldDepLast;
71c9e95b 985 *OldDepLast = Dependency;
f9eec0e7 986 OldDepLast = &Dep->NextDepends;
dcb79bae
AL
987 return true;
988}
989 /*}}}*/
25396fb0
DK
990// ListParser::NewDepends - Create the environment for a new dependency /*{{{*/
991// ---------------------------------------------------------------------
992/* This creates a Group and the Package to link this dependency to if
993 needed and handles also the caching of the old endpoint */
c9443c01 994bool pkgCacheListParser::NewDepends(pkgCache::VerIterator &Ver,
25396fb0
DK
995 const string &PackageName,
996 const string &Arch,
997 const string &Version,
8c7af4d4
DK
998 uint8_t const Op,
999 uint8_t const Type)
25396fb0
DK
1000{
1001 pkgCache::GrpIterator Grp;
a9fe5928 1002 Dynamic<pkgCache::GrpIterator> DynGrp(Grp);
25396fb0
DK
1003 if (unlikely(Owner->NewGroup(Grp, PackageName) == false))
1004 return false;
1005
bb0f6a34
DK
1006 map_stringitem_t idxVersion = 0;
1007 if (Version.empty() == false)
1008 {
1009 int const CmpOp = Op & 0x0F;
1010 // =-deps are used (79:1) for lockstep on same-source packages (e.g. data-packages)
1011 if (CmpOp == pkgCache::Dep::Equals && strcmp(Version.c_str(), Ver.VerStr()) == 0)
1012 idxVersion = Ver->VerStr;
1013
1014 if (idxVersion == 0)
1015 {
c9443c01 1016 idxVersion = StoreString(pkgCacheGenerator::VERSIONNUMBER, Version);
bb0f6a34
DK
1017 if (unlikely(idxVersion == 0))
1018 return false;
1019 }
25396fb0
DK
1020 }
1021
bb0f6a34
DK
1022 bool const isNegative = (Type == pkgCache::Dep::DpkgBreaks ||
1023 Type == pkgCache::Dep::Conflicts ||
1024 Type == pkgCache::Dep::Replaces);
1025
1026 pkgCache::PkgIterator Pkg;
1027 Dynamic<pkgCache::PkgIterator> DynPkg(Pkg);
1028 if (isNegative == false || (Op & pkgCache::Dep::ArchSpecific) == pkgCache::Dep::ArchSpecific || Grp->FirstPackage == 0)
1029 {
1030 // Locate the target package
1031 Pkg = Grp.FindPkg(Arch);
1032 if (Pkg.end() == true) {
1033 if (unlikely(Owner->NewPackage(Pkg, PackageName, Arch) == false))
1034 return false;
1035 }
1036
1037 /* Caching the old end point speeds up generation substantially */
1038 if (OldDepVer != Ver) {
1039 OldDepLast = NULL;
1040 OldDepVer = Ver;
1041 }
1042
1043 return Owner->NewDepends(Pkg, Ver, idxVersion, Op, Type, OldDepLast);
1044 }
1045 else
1046 {
1047 /* Caching the old end point speeds up generation substantially */
1048 if (OldDepVer != Ver) {
1049 OldDepLast = NULL;
1050 OldDepVer = Ver;
1051 }
1052
1053 for (Pkg = Grp.PackageList(); Pkg.end() == false; Pkg = Grp.NextPkg(Pkg))
1054 {
1055 if (Owner->NewDepends(Pkg, Ver, idxVersion, Op, Type, OldDepLast) == false)
1056 return false;
1057 }
1058 }
1059 return true;
25396fb0
DK
1060}
1061 /*}}}*/
dcb79bae 1062// ListParser::NewProvides - Create a Provides element /*{{{*/
c9443c01 1063bool pkgCacheListParser::NewProvides(pkgCache::VerIterator &Ver,
8c7af4d4 1064 const string &PkgName,
67e0766f 1065 const string &PkgArch,
8c7af4d4
DK
1066 const string &Version,
1067 uint8_t const Flags)
dcb79bae 1068{
ecc138f8 1069 pkgCache const &Cache = Owner->Cache;
8efa2a3b
AL
1070
1071 // We do not add self referencing provides
566046f4 1072 if (Ver.ParentPkg().Name() == PkgName && (PkgArch == Ver.ParentPkg().Arch() ||
b755de25
DK
1073 (PkgArch == "all" && strcmp((Cache.StrP + Cache.HeaderP->Architecture), Ver.ParentPkg().Arch()) == 0)) &&
1074 (Version.empty() || Version == Ver.VerStr()))
8efa2a3b 1075 return true;
ecc138f8
DK
1076
1077 // Locate the target package
1078 pkgCache::PkgIterator Pkg;
1079 Dynamic<pkgCache::PkgIterator> DynPkg(Pkg);
1080 if (unlikely(Owner->NewPackage(Pkg,PkgName, PkgArch) == false))
1081 return false;
1082
1083 map_stringitem_t idxProvideVersion = 0;
1084 if (Version.empty() == false) {
c9443c01 1085 idxProvideVersion = StoreString(pkgCacheGenerator::VERSIONNUMBER, Version);
ecc138f8
DK
1086 if (unlikely(idxProvideVersion == 0))
1087 return false;
1088 }
1089 return Owner->NewProvides(Ver, Pkg, idxProvideVersion, Flags);
1090}
1091bool pkgCacheGenerator::NewProvides(pkgCache::VerIterator &Ver,
1092 pkgCache::PkgIterator &Pkg,
1093 map_pointer_t const ProvideVersion,
1094 uint8_t const Flags)
1095{
dcb79bae 1096 // Get a structure
ecc138f8 1097 map_pointer_t const Provides = AllocateInMap(sizeof(pkgCache::Provides));
5bf15716 1098 if (unlikely(Provides == 0))
dcb79bae 1099 return false;
ecc138f8
DK
1100 ++Cache.HeaderP->ProvidesCount;
1101
dcb79bae
AL
1102 // Fill it in
1103 pkgCache::PrvIterator Prv(Cache,Cache.ProvideP + Provides,Cache.PkgP);
1104 Prv->Version = Ver.Index();
ecc138f8 1105 Prv->ProvideVersion = ProvideVersion;
8c7af4d4 1106 Prv->Flags = Flags;
dcb79bae
AL
1107 Prv->NextPkgProv = Ver->ProvidesList;
1108 Ver->ProvidesList = Prv.Index();
ecc138f8 1109
dcb79bae
AL
1110 // Link it to the package
1111 Prv->ParentPkg = Pkg.Index();
1112 Prv->NextProvides = Pkg->ProvidesList;
1113 Pkg->ProvidesList = Prv.Index();
ecc138f8
DK
1114 return true;
1115}
1116 /*}}}*/
1117// ListParser::NewProvidesAllArch - add provides for all architectures /*{{{*/
c9443c01 1118bool pkgCacheListParser::NewProvidesAllArch(pkgCache::VerIterator &Ver, string const &Package,
ecc138f8
DK
1119 string const &Version, uint8_t const Flags) {
1120 pkgCache &Cache = Owner->Cache;
a6deb7a0
JAK
1121 pkgCache::GrpIterator Grp = Cache.FindGrp(Package);
1122 Dynamic<pkgCache::GrpIterator> DynGrp(Grp);
1123
ecc138f8
DK
1124 if (Grp.end() == true)
1125 return NewProvides(Ver, Package, Cache.NativeArch(), Version, Flags);
1126 else
1127 {
1128 map_stringitem_t idxProvideVersion = 0;
1129 if (Version.empty() == false) {
c9443c01 1130 idxProvideVersion = StoreString(pkgCacheGenerator::VERSIONNUMBER, Version);
ecc138f8
DK
1131 if (unlikely(idxProvideVersion == 0))
1132 return false;
1133 }
1134
1135 bool const isImplicit = (Flags & pkgCache::Flag::MultiArchImplicit) == pkgCache::Flag::MultiArchImplicit;
1136 bool const isArchSpecific = (Flags & pkgCache::Flag::ArchSpecific) == pkgCache::Flag::ArchSpecific;
a6deb7a0
JAK
1137 pkgCache::PkgIterator OwnerPkg = Ver.ParentPkg();
1138 Dynamic<pkgCache::PkgIterator> DynOwnerPkg(OwnerPkg);
1139 pkgCache::PkgIterator Pkg;
1140 Dynamic<pkgCache::PkgIterator> DynPkg(Pkg);
1141 for (Pkg = Grp.PackageList(); Pkg.end() == false; Pkg = Grp.NextPkg(Pkg))
ecc138f8
DK
1142 {
1143 if (isImplicit && OwnerPkg == Pkg)
1144 continue;
1145 if (isArchSpecific == false && APT::Configuration::checkArchitecture(OwnerPkg.Arch()) == false)
1146 continue;
1147 if (Owner->NewProvides(Ver, Pkg, idxProvideVersion, Flags) == false)
1148 return false;
1149 }
1150 }
dcb79bae
AL
1151 return true;
1152}
1153 /*}}}*/
c9443c01 1154bool pkgCacheListParser::SameVersion(unsigned short const Hash, /*{{{*/
68134bda
DK
1155 pkgCache::VerIterator const &Ver)
1156{
1157 return Hash == Ver->Hash;
1158}
1159 /*}}}*/
b07aeb1a
DK
1160// CacheGenerator::SelectReleaseFile - Select the current release file the indexes belong to /*{{{*/
1161bool pkgCacheGenerator::SelectReleaseFile(const string &File,const string &Site,
1162 unsigned long Flags)
1163{
1164 if (File.empty() && Site.empty())
1165 {
1166 CurrentRlsFile = NULL;
1167 return true;
1168 }
1169
1170 // Get some space for the structure
1171 map_pointer_t const idxFile = AllocateInMap(sizeof(*CurrentRlsFile));
1172 if (unlikely(idxFile == 0))
1173 return false;
1174 CurrentRlsFile = Cache.RlsFileP + idxFile;
1175
1176 // Fill it in
1177 map_stringitem_t const idxFileName = WriteStringInMap(File);
1178 map_stringitem_t const idxSite = StoreString(MIXED, Site);
1179 if (unlikely(idxFileName == 0 || idxSite == 0))
1180 return false;
1181 CurrentRlsFile->FileName = idxFileName;
1182 CurrentRlsFile->Site = idxSite;
1183 CurrentRlsFile->NextFile = Cache.HeaderP->RlsFileList;
1184 CurrentRlsFile->Flags = Flags;
1185 CurrentRlsFile->ID = Cache.HeaderP->ReleaseFileCount;
1186 RlsFileName = File;
1187 Cache.HeaderP->RlsFileList = CurrentRlsFile - Cache.RlsFileP;
1188 Cache.HeaderP->ReleaseFileCount++;
1189
1190 return true;
1191}
1192 /*}}}*/
578bfd0a
AL
1193// CacheGenerator::SelectFile - Select the current file being parsed /*{{{*/
1194// ---------------------------------------------------------------------
1195/* This is used to select which file is to be associated with all newly
b2e465d6 1196 added versions. The caller is responsible for setting the IMS fields. */
b07aeb1a
DK
1197bool pkgCacheGenerator::SelectFile(std::string const &File,
1198 pkgIndexFile const &Index,
e185d8b3 1199 std::string const &Architecture,
b07aeb1a
DK
1200 std::string const &Component,
1201 unsigned long const Flags)
578bfd0a 1202{
578bfd0a 1203 // Get some space for the structure
4ad8619b 1204 map_pointer_t const idxFile = AllocateInMap(sizeof(*CurrentFile));
a9fe5928 1205 if (unlikely(idxFile == 0))
578bfd0a 1206 return false;
a9fe5928
DK
1207 CurrentFile = Cache.PkgFileP + idxFile;
1208
578bfd0a 1209 // Fill it in
4ad8619b 1210 map_stringitem_t const idxFileName = WriteStringInMap(File);
b07aeb1a 1211 if (unlikely(idxFileName == 0))
a9fe5928
DK
1212 return false;
1213 CurrentFile->FileName = idxFileName;
578bfd0a 1214 CurrentFile->NextFile = Cache.HeaderP->FileList;
e1b74f61 1215 CurrentFile->ID = Cache.HeaderP->PackageFileCount;
78a5476f 1216 map_stringitem_t const idxIndexType = StoreString(MIXED, Index.GetType()->Label);
a9fe5928
DK
1217 if (unlikely(idxIndexType == 0))
1218 return false;
1219 CurrentFile->IndexType = idxIndexType;
e185d8b3
DK
1220 if (Architecture.empty())
1221 CurrentFile->Architecture = 0;
1222 else
1223 {
1224 map_stringitem_t const arch = StoreString(pkgCacheGenerator::MIXED, Architecture);
1225 if (unlikely(arch == 0))
1226 return false;
1227 CurrentFile->Architecture = arch;
1228 }
b07aeb1a
DK
1229 map_stringitem_t const component = StoreString(pkgCacheGenerator::MIXED, Component);
1230 if (unlikely(component == 0))
1231 return false;
1232 CurrentFile->Component = component;
1233 CurrentFile->Flags = Flags;
1234 if (CurrentRlsFile != NULL)
1235 CurrentFile->Release = CurrentRlsFile - Cache.RlsFileP;
1236 else
1237 CurrentFile->Release = 0;
578bfd0a 1238 PkgFileName = File;
ad00ae81 1239 Cache.HeaderP->FileList = CurrentFile - Cache.PkgFileP;
b35d2f5f 1240 Cache.HeaderP->PackageFileCount++;
b2e465d6 1241
ddc1d8d0 1242 if (Progress != 0)
b2e465d6 1243 Progress->SubProgress(Index.Size());
8efa2a3b 1244 return true;
578bfd0a
AL
1245}
1246 /*}}}*/
f55a958f
AL
1247// CacheGenerator::WriteUniqueString - Insert a unique string /*{{{*/
1248// ---------------------------------------------------------------------
1249/* This is used to create handles to strings. Given the same text it
1250 always returns the same number */
78a5476f 1251map_stringitem_t pkgCacheGenerator::StoreString(enum StringType const type, const char *S,
f55a958f
AL
1252 unsigned int Size)
1253{
78a5476f
DK
1254 std::string const key(S, Size);
1255
1256 std::map<std::string,map_stringitem_t> * strings;
1257 switch(type) {
1258 case MIXED: strings = &strMixed; break;
1259 case PKGNAME: strings = &strPkgNames; break;
30b45652 1260 case VERSIONNUMBER: strings = &strVersions; break;
78a5476f
DK
1261 case SECTION: strings = &strSections; break;
1262 default: _error->Fatal("Unknown enum type used for string storage of '%s'", key.c_str()); return 0;
f55a958f 1263 }
a9fe5928 1264
78a5476f
DK
1265 std::map<std::string,map_stringitem_t>::const_iterator const item = strings->find(key);
1266 if (item != strings->end())
1267 return item->second;
a9fe5928 1268
78a5476f
DK
1269 map_stringitem_t const idxString = WriteStringInMap(S,Size);
1270 strings->insert(std::make_pair(key, idxString));
1271 return idxString;
f55a958f
AL
1272}
1273 /*}}}*/
b2e465d6 1274// CheckValidity - Check that a cache is up-to-date /*{{{*/
b35d2f5f 1275// ---------------------------------------------------------------------
b2e465d6
AL
1276/* This just verifies that each file in the list of index files exists,
1277 has matching attributes with the cache and the cache does not have
1278 any extra files. */
95278287
DK
1279class APT_HIDDEN ScopedErrorRevert {
1280public:
1281 ScopedErrorRevert() { _error->PushToStack(); }
1282 ~ScopedErrorRevert() { _error->RevertToStack(); }
1283};
5465192b 1284static bool CheckValidity(const string &CacheFile,
2ec858bc 1285 pkgSourceList &List,
5465192b
DK
1286 FileIterator const Start,
1287 FileIterator const End,
2ec858bc 1288 MMap **OutMap = 0)
b35d2f5f 1289{
95278287 1290 ScopedErrorRevert ser;
c8e572e3 1291 bool const Debug = _config->FindB("Debug::pkgCacheGen", false);
b2e465d6
AL
1292 // No file, certainly invalid
1293 if (CacheFile.empty() == true || FileExists(CacheFile) == false)
c8e572e3
MV
1294 {
1295 if (Debug == true)
5465192b 1296 std::clog << "CacheFile " << CacheFile << " doesn't exist" << std::endl;
b35d2f5f 1297 return false;
c8e572e3
MV
1298 }
1299
96d14a91 1300 if (List.GetLastModifiedTime() > GetModificationTime(CacheFile))
2ec858bc
MV
1301 {
1302 if (Debug == true)
1303 std::clog << "sources.list is newer than the cache" << std::endl;
1304 return false;
1305 }
1306
b2e465d6 1307 // Map it
b35d2f5f 1308 FileFd CacheF(CacheFile,FileFd::ReadOnly);
6c413b18
JAK
1309 std::unique_ptr<MMap> Map(new MMap(CacheF,0));
1310 pkgCache Cache(Map.get());
95278287 1311 if (_error->PendingError() || Map->Size() == 0)
b35d2f5f 1312 {
c8e572e3 1313 if (Debug == true)
5465192b 1314 std::clog << "Errors are pending or Map is empty() for " << CacheFile << std::endl;
b35d2f5f
AL
1315 return false;
1316 }
b07aeb1a 1317
98cc7fd2
JAK
1318 std::unique_ptr<bool[]> RlsVisited(new bool[Cache.HeaderP->ReleaseFileCount]);
1319 memset(RlsVisited.get(),0,sizeof(RlsVisited[0])*Cache.HeaderP->ReleaseFileCount);
b07aeb1a
DK
1320 std::vector<pkgIndexFile *> Files;
1321 for (pkgSourceList::const_iterator i = List.begin(); i != List.end(); ++i)
1322 {
1323 if (Debug == true)
1324 std::clog << "Checking RlsFile " << (*i)->Describe() << ": ";
3fd89e62 1325 pkgCache::RlsFileIterator const RlsFile = (*i)->FindInCache(Cache, true);
b07aeb1a
DK
1326 if (RlsFile.end() == true)
1327 {
1328 if (Debug == true)
1329 std::clog << "FindInCache returned end-Pointer" << std::endl;
1330 return false;
1331 }
1332
1333 RlsVisited[RlsFile->ID] = true;
1334 if (Debug == true)
1335 std::clog << "with ID " << RlsFile->ID << " is valid" << std::endl;
1336
5465192b
DK
1337 std::vector <pkgIndexFile *> const * const Indexes = (*i)->GetIndexFiles();
1338 std::copy_if(Indexes->begin(), Indexes->end(), std::back_inserter(Files),
1339 [](pkgIndexFile const * const I) { return I->HasPackages(); });
b07aeb1a
DK
1340 }
1341 for (unsigned I = 0; I != Cache.HeaderP->ReleaseFileCount; ++I)
1342 if (RlsVisited[I] == false)
1343 {
1344 if (Debug == true)
1345 std::clog << "RlsFile with ID" << I << " wasn't visited" << std::endl;
1346 return false;
1347 }
1348
5465192b 1349 std::copy(Start, End, std::back_inserter(Files));
b07aeb1a 1350
b2e465d6
AL
1351 /* Now we check every index file, see if it is in the cache,
1352 verify the IMS data and check that it is on the disk too.. */
98cc7fd2
JAK
1353 std::unique_ptr<bool[]> Visited(new bool[Cache.HeaderP->PackageFileCount]);
1354 memset(Visited.get(),0,sizeof(Visited[0])*Cache.HeaderP->PackageFileCount);
b07aeb1a 1355 for (std::vector<pkgIndexFile *>::const_reverse_iterator PkgFile = Files.rbegin(); PkgFile != Files.rend(); ++PkgFile)
c8e572e3
MV
1356 {
1357 if (Debug == true)
b07aeb1a
DK
1358 std::clog << "Checking PkgFile " << (*PkgFile)->Describe() << ": ";
1359 if ((*PkgFile)->Exists() == false)
b35d2f5f 1360 {
c8e572e3
MV
1361 if (Debug == true)
1362 std::clog << "file doesn't exist" << std::endl;
b2e465d6 1363 continue;
b35d2f5f 1364 }
b2e465d6
AL
1365
1366 // FindInCache is also expected to do an IMS check.
b07aeb1a 1367 pkgCache::PkgFileIterator File = (*PkgFile)->FindInCache(Cache);
b2e465d6 1368 if (File.end() == true)
c8e572e3
MV
1369 {
1370 if (Debug == true)
1371 std::clog << "FindInCache returned end-Pointer" << std::endl;
b35d2f5f 1372 return false;
c8e572e3 1373 }
a52f938b 1374
b2e465d6 1375 Visited[File->ID] = true;
c8e572e3
MV
1376 if (Debug == true)
1377 std::clog << "with ID " << File->ID << " is valid" << std::endl;
b35d2f5f 1378 }
b07aeb1a 1379
b2e465d6
AL
1380 for (unsigned I = 0; I != Cache.HeaderP->PackageFileCount; I++)
1381 if (Visited[I] == false)
c8e572e3
MV
1382 {
1383 if (Debug == true)
b07aeb1a 1384 std::clog << "PkgFile with ID" << I << " wasn't visited" << std::endl;
b2e465d6 1385 return false;
c8e572e3 1386 }
b07aeb1a 1387
b35d2f5f
AL
1388 if (_error->PendingError() == true)
1389 {
c8e572e3
MV
1390 if (Debug == true)
1391 {
1392 std::clog << "Validity failed because of pending errors:" << std::endl;
95278287 1393 _error->DumpErrors(std::clog, GlobalError::DEBUG, false);
c8e572e3 1394 }
b35d2f5f
AL
1395 return false;
1396 }
95278287 1397
b2e465d6 1398 if (OutMap != 0)
6c413b18 1399 *OutMap = Map.release();
b35d2f5f
AL
1400 return true;
1401}
1402 /*}}}*/
b2e465d6 1403// ComputeSize - Compute the total size of a bunch of files /*{{{*/
b35d2f5f 1404// ---------------------------------------------------------------------
b2e465d6
AL
1405/* Size is kind of an abstract notion that is only used for the progress
1406 meter */
b07aeb1a 1407static map_filesize_t ComputeSize(pkgSourceList const * const List, FileIterator Start,FileIterator End)
b35d2f5f 1408{
4ad8619b 1409 map_filesize_t TotalSize = 0;
b07aeb1a
DK
1410 if (List != NULL)
1411 {
1412 for (pkgSourceList::const_iterator i = List->begin(); i != List->end(); ++i)
1413 {
1414 std::vector <pkgIndexFile *> *Indexes = (*i)->GetIndexFiles();
1415 for (std::vector<pkgIndexFile *>::const_iterator j = Indexes->begin(); j != Indexes->end(); ++j)
1416 if ((*j)->HasPackages() == true)
1417 TotalSize += (*j)->Size();
1418 }
1419 }
1420
ef74268b 1421 for (; Start < End; ++Start)
b35d2f5f 1422 {
b2e465d6 1423 if ((*Start)->HasPackages() == false)
ef74268b 1424 continue;
b2e465d6 1425 TotalSize += (*Start)->Size();
b35d2f5f 1426 }
b2e465d6 1427 return TotalSize;
2d11135a
AL
1428}
1429 /*}}}*/
b2e465d6 1430// BuildCache - Merge the list of index files into the cache /*{{{*/
b2e465d6 1431static bool BuildCache(pkgCacheGenerator &Gen,
5465192b 1432 OpProgress * const Progress,
4ad8619b 1433 map_filesize_t &CurrentSize,map_filesize_t TotalSize,
b07aeb1a 1434 pkgSourceList const * const List,
5465192b 1435 FileIterator const Start, FileIterator const End)
2d11135a 1436{
b07aeb1a 1437 std::vector<pkgIndexFile *> Files;
5465192b
DK
1438 bool mergeFailure = false;
1439
1440 auto const indexFileMerge = [&](pkgIndexFile * const I) {
5465192b
DK
1441 if (I->HasPackages() == false || mergeFailure)
1442 return;
1443
1444 if (I->Exists() == false)
1445 return;
1446
1447 if (I->FindInCache(Gen.GetCache()).end() == false)
1448 {
1449 _error->Warning("Duplicate sources.list entry %s",
1450 I->Describe().c_str());
1451 return;
1452 }
1453
1454 map_filesize_t const Size = I->Size();
1455 if (Progress != NULL)
1456 Progress->OverallProgress(CurrentSize, TotalSize, Size, _("Reading package lists"));
1457 CurrentSize += Size;
1458
1459 if (I->Merge(Gen,Progress) == false)
1460 mergeFailure = true;
1461 };
b07aeb1a
DK
1462
1463 if (List != NULL)
1464 {
1465 for (pkgSourceList::const_iterator i = List->begin(); i != List->end(); ++i)
1466 {
3fd89e62 1467 if ((*i)->FindInCache(Gen.GetCache(), false).end() == false)
b07aeb1a
DK
1468 {
1469 _error->Warning("Duplicate sources.list entry %s",
1470 (*i)->Describe().c_str());
1471 continue;
1472 }
1473
1474 if ((*i)->Merge(Gen, Progress) == false)
1475 return false;
1476
1477 std::vector <pkgIndexFile *> *Indexes = (*i)->GetIndexFiles();
5465192b
DK
1478 if (Indexes != NULL)
1479 std::for_each(Indexes->begin(), Indexes->end(), indexFileMerge);
1480 if (mergeFailure)
1481 return false;
b07aeb1a
DK
1482 }
1483 }
1484
5465192b 1485 if (Start != End)
2d11135a 1486 {
5465192b
DK
1487 Gen.SelectReleaseFile("", "");
1488 std::for_each(Start, End, indexFileMerge);
1489 if (mergeFailure)
b2e465d6 1490 return false;
5465192b 1491 }
b35d2f5f
AL
1492 return true;
1493}
1494 /*}}}*/
5465192b
DK
1495// CacheGenerator::MakeStatusCache - Construct the status cache /*{{{*/
1496// ---------------------------------------------------------------------
1497/* This makes sure that the status cache (the cache that has all
1498 index files from the sources list and all local ones) is ready
1499 to be mmaped. If OutMap is not zero then a MMap object representing
1500 the cache will be stored there. This is pretty much mandetory if you
1501 are using AllowMem. AllowMem lets the function be run as non-root
1502 where it builds the cache 'fast' into a memory buffer. */
1503static DynamicMMap* CreateDynamicMMap(FileFd * const CacheF, unsigned long Flags)
1504{
4ad8619b
DK
1505 map_filesize_t const MapStart = _config->FindI("APT::Cache-Start", 24*1024*1024);
1506 map_filesize_t const MapGrow = _config->FindI("APT::Cache-Grow", 1*1024*1024);
1507 map_filesize_t const MapLimit = _config->FindI("APT::Cache-Limit", 0);
dcdf1ef1
DK
1508 Flags |= MMap::Moveable;
1509 if (_config->FindB("APT::Cache-Fallback", false) == true)
1510 Flags |= MMap::Fallback;
1511 if (CacheF != NULL)
1512 return new DynamicMMap(*CacheF, Flags, MapStart, MapGrow, MapLimit);
1513 else
1514 return new DynamicMMap(Flags, MapStart, MapGrow, MapLimit);
1515}
5465192b
DK
1516static bool writeBackMMapToFile(pkgCacheGenerator * const Gen, DynamicMMap * const Map,
1517 std::string const &FileName)
1518{
1519 FileFd SCacheF(FileName, FileFd::WriteAtomic);
95278287 1520 if (SCacheF.IsOpen() == false || SCacheF.Failed())
5465192b
DK
1521 return false;
1522
1523 fchmod(SCacheF.Fd(),0644);
1524
1525 // Write out the main data
1526 if (SCacheF.Write(Map->Data(),Map->Size()) == false)
1527 return _error->Error(_("IO Error saving source cache"));
1528 SCacheF.Sync();
1529
1530 // Write out the proper header
1531 Gen->GetCache().HeaderP->Dirty = false;
1532 if (SCacheF.Seek(0) == false ||
1533 SCacheF.Write(Map->Data(),sizeof(*Gen->GetCache().HeaderP)) == false)
1534 return _error->Error(_("IO Error saving source cache"));
1535 Gen->GetCache().HeaderP->Dirty = true;
1536 SCacheF.Sync();
1537 return true;
1538}
1539static bool loadBackMMapFromFile(std::unique_ptr<pkgCacheGenerator> &Gen,
6c413b18 1540 std::unique_ptr<DynamicMMap> &Map, OpProgress * const Progress, std::string const &FileName)
5465192b 1541{
6c413b18 1542 Map.reset(CreateDynamicMMap(NULL, 0));
5465192b 1543 FileFd CacheF(FileName, FileFd::ReadOnly);
95278287
DK
1544 if (CacheF.IsOpen() == false || CacheF.Failed())
1545 return false;
1546 _error->PushToStack();
5465192b 1547 map_pointer_t const alloc = Map->RawAllocate(CacheF.Size());
95278287
DK
1548 bool const newError = _error->PendingError();
1549 _error->MergeWithStack();
1550 if (alloc == 0 && newError)
1551 return false;
1552 if (CacheF.Read((unsigned char *)Map->Data() + alloc, CacheF.Size()) == false)
5465192b 1553 return false;
6c413b18 1554 Gen.reset(new pkgCacheGenerator(Map.get(),Progress));
5465192b
DK
1555 return true;
1556}
453b82a3 1557APT_DEPRECATED bool pkgMakeStatusCache(pkgSourceList &List,OpProgress &Progress,
2e5f4e45
DK
1558 MMap **OutMap, bool AllowMem)
1559 { return pkgCacheGenerator::MakeStatusCache(List, &Progress, OutMap, AllowMem); }
1560bool pkgCacheGenerator::MakeStatusCache(pkgSourceList &List,OpProgress *Progress,
c4171975 1561 MMap **OutMap,bool)
b35d2f5f 1562{
c4171975 1563 // FIXME: deprecate the ignored AllowMem parameter
c8e572e3 1564 bool const Debug = _config->FindB("Debug::pkgCacheGen", false);
73688d27
DK
1565
1566 std::vector<pkgIndexFile *> Files;
b2e465d6
AL
1567 if (_system->AddStatusFiles(Files) == false)
1568 return false;
c5f44afc 1569
b2e465d6 1570 // Decide if we can write to the files..
c8e572e3
MV
1571 string const CacheFile = _config->FindFile("Dir::Cache::pkgcache");
1572 string const SrcCacheFile = _config->FindFile("Dir::Cache::srcpkgcache");
1cd1c398
DK
1573
1574 // ensure the cache directory exists
1575 if (CacheFile.empty() == false || SrcCacheFile.empty() == false)
1576 {
1577 string dir = _config->FindDir("Dir::Cache");
1578 size_t const len = dir.size();
1579 if (len > 5 && dir.find("/apt/", len - 6, 5) == len - 5)
1580 dir = dir.substr(0, len - 5);
1581 if (CacheFile.empty() == false)
1582 CreateDirectory(dir, flNotFile(CacheFile));
1583 if (SrcCacheFile.empty() == false)
1584 CreateDirectory(dir, flNotFile(SrcCacheFile));
1585 }
1586
2e5f4e45
DK
1587 if (Progress != NULL)
1588 Progress->OverallProgress(0,1,1,_("Reading package lists"));
1589
5465192b
DK
1590 bool pkgcache_fine = false;
1591 bool srcpkgcache_fine = false;
1592 bool volatile_fine = List.GetVolatileFiles().empty();
1593
1594 if (CheckValidity(CacheFile, List, Files.begin(), Files.end(), volatile_fine ? OutMap : NULL) == true)
b2e465d6 1595 {
c8e572e3 1596 if (Debug == true)
5465192b
DK
1597 std::clog << "pkgcache.bin is valid - no need to build any cache" << std::endl;
1598 pkgcache_fine = true;
1599 srcpkgcache_fine = true;
b2e465d6 1600 }
5465192b 1601 if (pkgcache_fine == false)
b2e465d6 1602 {
5465192b 1603 if (CheckValidity(SrcCacheFile, List, Files.end(), Files.end()) == true)
41b4dee4 1604 {
41b4dee4 1605 if (Debug == true)
5465192b
DK
1606 std::clog << "srcpkgcache.bin is valid - it can be reused" << std::endl;
1607 srcpkgcache_fine = true;
41b4dee4 1608 }
b35d2f5f 1609 }
5465192b
DK
1610
1611 if (volatile_fine == true && srcpkgcache_fine == true && pkgcache_fine == true)
8ce4327b 1612 {
5465192b
DK
1613 if (Progress != NULL)
1614 Progress->OverallProgress(1,1,1,_("Reading package lists"));
1615 return true;
8ce4327b 1616 }
5465192b
DK
1617
1618 bool Writeable = false;
1619 if (srcpkgcache_fine == false || pkgcache_fine == false)
2d11135a 1620 {
5465192b
DK
1621 if (CacheFile.empty() == false)
1622 Writeable = access(flNotFile(CacheFile).c_str(),W_OK) == 0;
1623 else if (SrcCacheFile.empty() == false)
1624 Writeable = access(flNotFile(SrcCacheFile).c_str(),W_OK) == 0;
1625
c8e572e3 1626 if (Debug == true)
5465192b 1627 std::clog << "Do we have write-access to the cache files? " << (Writeable ? "YES" : "NO") << std::endl;
5465192b 1628 }
b2e465d6 1629
5465192b 1630 // At this point we know we need to construct something, so get storage ready
6c413b18 1631 std::unique_ptr<DynamicMMap> Map(CreateDynamicMMap(NULL, 0));
5465192b
DK
1632 if (Debug == true)
1633 std::clog << "Open memory Map (not filebased)" << std::endl;
c8e572e3 1634
5465192b
DK
1635 std::unique_ptr<pkgCacheGenerator> Gen{nullptr};
1636 map_filesize_t CurrentSize = 0;
1637 std::vector<pkgIndexFile*> VolatileFiles = List.GetVolatileFiles();
1638 map_filesize_t TotalSize = ComputeSize(NULL, VolatileFiles.begin(), VolatileFiles.end());
1639 if (srcpkgcache_fine == true && pkgcache_fine == false)
1640 {
1641 if (Debug == true)
1642 std::clog << "srcpkgcache.bin was valid - populate MMap with it" << std::endl;
1643 if (loadBackMMapFromFile(Gen, Map, Progress, SrcCacheFile) == false)
b2e465d6 1644 return false;
5465192b
DK
1645 srcpkgcache_fine = true;
1646 TotalSize += ComputeSize(NULL, Files.begin(), Files.end());
b2e465d6 1647 }
5465192b 1648 else if (srcpkgcache_fine == false)
2d11135a 1649 {
c8e572e3
MV
1650 if (Debug == true)
1651 std::clog << "srcpkgcache.bin is NOT valid - rebuild" << std::endl;
6c413b18 1652 Gen.reset(new pkgCacheGenerator(Map.get(),Progress));
5465192b
DK
1653
1654 TotalSize += ComputeSize(&List, Files.begin(),Files.end());
1655 if (BuildCache(*Gen, Progress, CurrentSize, TotalSize, &List,
1656 Files.end(),Files.end()) == false)
b2e465d6 1657 return false;
5465192b 1658
b2e465d6 1659 if (Writeable == true && SrcCacheFile.empty() == false)
6c413b18 1660 if (writeBackMMapToFile(Gen.get(), Map.get(), SrcCacheFile) == false)
b2e465d6 1661 return false;
5465192b
DK
1662 }
1663
1664 if (pkgcache_fine == false)
1665 {
1666 if (Debug == true)
1667 std::clog << "Building status cache in pkgcache.bin now" << std::endl;
1668 if (BuildCache(*Gen, Progress, CurrentSize, TotalSize, NULL,
1669 Files.begin(), Files.end()) == false)
b2e465d6 1670 return false;
5465192b
DK
1671
1672 if (Writeable == true && CacheFile.empty() == false)
6c413b18 1673 if (writeBackMMapToFile(Gen.get(), Map.get(), CacheFile) == false)
5465192b 1674 return false;
2d11135a 1675 }
5465192b 1676
c8e572e3 1677 if (Debug == true)
5465192b 1678 std::clog << "Caches done. Now bring in the volatile files (if any)" << std::endl;
2d11135a 1679
5465192b 1680 if (volatile_fine == false)
2d11135a 1681 {
5465192b 1682 if (Gen == nullptr)
2d11135a 1683 {
5465192b
DK
1684 if (Debug == true)
1685 std::clog << "Populate new MMap with cachefile contents" << std::endl;
1686 if (loadBackMMapFromFile(Gen, Map, Progress, CacheFile) == false)
1687 return false;
2d11135a 1688 }
5465192b
DK
1689
1690 Files = List.GetVolatileFiles();
1691 if (BuildCache(*Gen, Progress, CurrentSize, TotalSize, NULL,
1692 Files.begin(), Files.end()) == false)
1693 return false;
2d11135a 1694 }
5465192b
DK
1695
1696 if (OutMap != nullptr)
6c413b18 1697 *OutMap = Map.release();
5465192b
DK
1698
1699 if (Debug == true)
1700 std::clog << "Everything is ready for shipping" << std::endl;
b2e465d6
AL
1701 return true;
1702}
1703 /*}}}*/
2e5f4e45 1704// CacheGenerator::MakeOnlyStatusCache - Build only a status files cache/*{{{*/
95278287
DK
1705class APT_HIDDEN ScopedErrorMerge {
1706public:
1707 ScopedErrorMerge() { _error->PushToStack(); }
1708 ~ScopedErrorMerge() { _error->MergeWithStack(); }
1709};
453b82a3 1710APT_DEPRECATED bool pkgMakeOnlyStatusCache(OpProgress &Progress,DynamicMMap **OutMap)
2e5f4e45
DK
1711 { return pkgCacheGenerator::MakeOnlyStatusCache(&Progress, OutMap); }
1712bool pkgCacheGenerator::MakeOnlyStatusCache(OpProgress *Progress,DynamicMMap **OutMap)
b2e465d6 1713{
73688d27 1714 std::vector<pkgIndexFile *> Files;
b2e465d6
AL
1715 if (_system->AddStatusFiles(Files) == false)
1716 return false;
dcdf1ef1 1717
95278287 1718 ScopedErrorMerge sem;
6c413b18 1719 std::unique_ptr<DynamicMMap> Map(CreateDynamicMMap(NULL, 0));
4ad8619b
DK
1720 map_filesize_t CurrentSize = 0;
1721 map_filesize_t TotalSize = 0;
b07aeb1a 1722 TotalSize = ComputeSize(NULL, Files.begin(), Files.end());
95278287 1723
b2e465d6 1724 // Build the status cache
2e5f4e45
DK
1725 if (Progress != NULL)
1726 Progress->OverallProgress(0,1,1,_("Reading package lists"));
6c413b18 1727 pkgCacheGenerator Gen(Map.get(),Progress);
2d11135a 1728 if (_error->PendingError() == true)
b2e465d6 1729 return false;
b07aeb1a
DK
1730 if (BuildCache(Gen,Progress,CurrentSize,TotalSize, NULL,
1731 Files.begin(), Files.end()) == false)
b2e465d6 1732 return false;
25396fb0 1733
b2e465d6
AL
1734 if (_error->PendingError() == true)
1735 return false;
6c413b18 1736 *OutMap = Map.release();
2d11135a 1737
b2e465d6 1738 return true;
2d11135a
AL
1739}
1740 /*}}}*/
5f4db009 1741// IsDuplicateDescription /*{{{*/
60683765 1742static bool IsDuplicateDescription(pkgCache::DescIterator Desc,
5f4db009
DK
1743 MD5SumValue const &CurMd5, std::string const &CurLang)
1744{
22f07fc5 1745 // Descriptions in the same link-list have all the same md5
7f5aab82 1746 if (Desc.end() == true || MD5SumValue(Desc.md5()) != CurMd5)
22f07fc5
DK
1747 return false;
1748 for (; Desc.end() == false; ++Desc)
1749 if (Desc.LanguageCode() == CurLang)
5f4db009
DK
1750 return true;
1751 return false;
1752}
1753 /*}}}*/
c8a4ce6c 1754
1d3eea5c 1755pkgCacheListParser::pkgCacheListParser() : Owner(NULL), OldDepLast(NULL), d(NULL) {}
c9443c01 1756pkgCacheListParser::~pkgCacheListParser() {}