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