]> git.saurik.com Git - apt.git/blame - apt-pkg/pkgcachegen.cc
make the specify order of packages irrelevant (half-close #196021)
[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 /*{{{*/
b2e465d6
AL
13#define APT_COMPATIBILITY 986
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>
25396fb0 21#include <apt-pkg/aptconfiguration.h>
cdcc6d34 22#include <apt-pkg/strutl.h>
b2e465d6
AL
23#include <apt-pkg/sptr.h>
24#include <apt-pkg/pkgsystem.h>
aea7f4c8 25#include <apt-pkg/macros.h>
578bfd0a 26
afb1e2e3
MV
27#include <apt-pkg/tagfile.h>
28
b2e465d6 29#include <apti18n.h>
e7b470ee
AL
30
31#include <vector>
32
578bfd0a
AL
33#include <sys/stat.h>
34#include <unistd.h>
803fafcb 35#include <errno.h>
7ef72446 36#include <stdio.h>
578bfd0a 37 /*}}}*/
e7b470ee 38typedef vector<pkgIndexFile *>::iterator FileIterator;
578bfd0a
AL
39
40// CacheGenerator::pkgCacheGenerator - Constructor /*{{{*/
41// ---------------------------------------------------------------------
25396fb0 42/* We set the dirty flag and make sure that is written to the disk */
b2e465d6 43pkgCacheGenerator::pkgCacheGenerator(DynamicMMap *pMap,OpProgress *Prog) :
45415543
AL
44 Map(*pMap), Cache(pMap,false), Progress(Prog),
45 FoundFileDeps(0)
578bfd0a 46{
ddc1d8d0 47 CurrentFile = 0;
b2e465d6 48 memset(UniqHash,0,sizeof(UniqHash));
ddc1d8d0 49
578bfd0a
AL
50 if (_error->PendingError() == true)
51 return;
b2e465d6 52
578bfd0a
AL
53 if (Map.Size() == 0)
54 {
b2e465d6
AL
55 // Setup the map interface..
56 Cache.HeaderP = (pkgCache::Header *)Map.Data();
c5f44afc
DK
57 if (Map.RawAllocate(sizeof(pkgCache::Header)) == 0 && _error->PendingError() == true)
58 return;
59
b2e465d6 60 Map.UsePools(*Cache.HeaderP->Pools,sizeof(Cache.HeaderP->Pools)/sizeof(Cache.HeaderP->Pools[0]));
c5f44afc 61
b2e465d6 62 // Starting header
578bfd0a 63 *Cache.HeaderP = pkgCache::Header();
b2e465d6
AL
64 Cache.HeaderP->VerSysName = Map.WriteString(_system->VS->Label);
65 Cache.HeaderP->Architecture = Map.WriteString(_config->Find("APT::Architecture"));
c5f44afc 66 Cache.ReMap();
578bfd0a 67 }
b2e465d6
AL
68 else
69 {
70 // Map directly from the existing file
71 Cache.ReMap();
72 Map.UsePools(*Cache.HeaderP->Pools,sizeof(Cache.HeaderP->Pools)/sizeof(Cache.HeaderP->Pools[0]));
73 if (Cache.VS != _system->VS)
74 {
75 _error->Error(_("Cache has an incompatible versioning system"));
76 return;
77 }
78 }
79
578bfd0a
AL
80 Cache.HeaderP->Dirty = true;
81 Map.Sync(0,sizeof(pkgCache::Header));
578bfd0a
AL
82}
83 /*}}}*/
84// CacheGenerator::~pkgCacheGenerator - Destructor /*{{{*/
85// ---------------------------------------------------------------------
86/* We sync the data then unset the dirty flag in two steps so as to
87 advoid a problem during a crash */
88pkgCacheGenerator::~pkgCacheGenerator()
89{
90 if (_error->PendingError() == true)
91 return;
92 if (Map.Sync() == false)
93 return;
94
95 Cache.HeaderP->Dirty = false;
96 Map.Sync(0,sizeof(pkgCache::Header));
97}
98 /*}}}*/
99// CacheGenerator::MergeList - Merge the package list /*{{{*/
100// ---------------------------------------------------------------------
101/* This provides the generation of the entries in the cache. Each loop
102 goes through a single package record from the underlying parse engine. */
ddc1d8d0
AL
103bool pkgCacheGenerator::MergeList(ListParser &List,
104 pkgCache::VerIterator *OutVer)
578bfd0a
AL
105{
106 List.Owner = this;
0149949b 107
f9eec0e7 108 unsigned int Counter = 0;
0149949b 109 while (List.Step() == true)
578bfd0a 110 {
5bf15716 111 string const PackageName = List.Package();
65a1e968
AL
112 if (PackageName.empty() == true)
113 return false;
5bf15716 114
8b32e920
DK
115 /* As we handle Arch all packages as architecture bounded
116 we add all information to every (simulated) arch package */
117 std::vector<string> genArch;
803ea2a8 118 if (List.ArchitectureAll() == true) {
8b32e920 119 genArch = APT::Configuration::getArchitectures();
42d71ab5
DK
120 if (genArch.size() != 1)
121 genArch.push_back("all");
803ea2a8 122 } else
8b32e920
DK
123 genArch.push_back(List.Architecture());
124
125 for (std::vector<string>::const_iterator arch = genArch.begin();
126 arch != genArch.end(); ++arch)
127 {
128 // Get a pointer to the package structure
9ddf7030 129 pkgCache::PkgIterator Pkg;
8b32e920 130 if (NewPackage(Pkg, PackageName, *arch) == false)
6804503b 131 return _error->Error(_("Error occurred while processing %s (NewPackage)"),PackageName.c_str());
a246f2dc 132 Counter++;
ddc1d8d0
AL
133 if (Counter % 100 == 0 && Progress != 0)
134 Progress->Progress(List.Offset());
8ce4327b 135
578bfd0a
AL
136 /* Get a pointer to the version structure. We know the list is sorted
137 so we use that fact in the search. Insertion of new versions is
138 done with correct sorting */
139 string Version = List.Version();
f55a958f
AL
140 if (Version.empty() == true)
141 {
770c32ec
MV
142 // we first process the package, then the descriptions
143 // (this has the bonus that we get MMap error when we run out
144 // of MMap space)
f55a958f 145 if (List.UsePackage(Pkg,pkgCache::VerIterator(Cache)) == false)
6804503b 146 return _error->Error(_("Error occurred while processing %s (UsePackage1)"),
7a3c2ab0 147 PackageName.c_str());
770c32ec 148
a52f938b
OS
149 // Find the right version to write the description
150 MD5SumValue CurMd5 = List.Description_md5();
151 pkgCache::VerIterator Ver = Pkg.VersionList();
152 map_ptrloc *LastVer = &Pkg->VersionList;
770c32ec 153
9ee47c29 154 for (; Ver.end() == false; LastVer = &Ver->NextVer, Ver++)
a52f938b
OS
155 {
156 pkgCache::DescIterator Desc = Ver.DescriptionList();
157 map_ptrloc *LastDesc = &Ver->DescriptionList;
c76c44b1 158 bool duplicate=false;
159
160 // don't add a new description if we have one for the given
161 // md5 && language
9ee47c29 162 for ( ; Desc.end() == false; Desc++)
c76c44b1 163 if (MD5SumValue(Desc.md5()) == CurMd5 &&
164 Desc.LanguageCode() == List.DescriptionLanguage())
165 duplicate=true;
166 if(duplicate)
167 continue;
168
169 for (Desc = Ver.DescriptionList();
9ee47c29 170 Desc.end() == false;
c76c44b1 171 LastDesc = &Desc->NextDesc, Desc++)
770c32ec 172 {
770c32ec
MV
173 if (MD5SumValue(Desc.md5()) == CurMd5)
174 {
a52f938b
OS
175 // Add new description
176 *LastDesc = NewDescription(Desc, List.DescriptionLanguage(), CurMd5, *LastDesc);
177 Desc->ParentPkg = Pkg.Index();
770c32ec 178
c5f44afc 179 if ((*LastDesc == 0 && _error->PendingError()) || NewFileDesc(Desc,List) == false)
f0f66a3d 180 return _error->Error(_("Error occurred while processing %s (NewFileDesc1)"),PackageName.c_str());
a52f938b
OS
181 break;
182 }
770c32ec 183 }
a52f938b 184 }
770c32ec 185
f55a958f
AL
186 continue;
187 }
188
578bfd0a 189 pkgCache::VerIterator Ver = Pkg.VersionList();
a52f938b 190 map_ptrloc *LastVer = &Pkg->VersionList;
2246928b 191 int Res = 1;
7e2b56a3 192 unsigned long const Hash = List.VersionHash();
9ee47c29 193 for (; Ver.end() == false; LastVer = &Ver->NextVer, Ver++)
578bfd0a 194 {
c24972cb 195 Res = Cache.VS->CmpVersion(Version,Ver.VerStr());
7e2b56a3
DK
196 // Version is higher as current version - insert here
197 if (Res > 0)
578bfd0a 198 break;
7e2b56a3
DK
199 // Versionstrings are equal - is hash also equal?
200 if (Res == 0 && Ver->Hash == Hash)
201 break;
202 // proceed with the next till we have either the right
203 // or we found another version (which will be lower)
578bfd0a 204 }
7e2b56a3
DK
205
206 /* We already have a version for this item, record that we saw it */
e426a5ff 207 if (Res == 0 && Ver.end() == false && Ver->Hash == Hash)
578bfd0a 208 {
f55a958f 209 if (List.UsePackage(Pkg,Ver) == false)
6804503b 210 return _error->Error(_("Error occurred while processing %s (UsePackage2)"),
7a3c2ab0 211 PackageName.c_str());
f78439bf 212
578bfd0a 213 if (NewFileVer(Ver,List) == false)
6804503b 214 return _error->Error(_("Error occurred while processing %s (NewFileVer1)"),
7a3c2ab0 215 PackageName.c_str());
578bfd0a 216
ddc1d8d0
AL
217 // Read only a single record and return
218 if (OutVer != 0)
219 {
220 *OutVer = Ver;
45415543 221 FoundFileDeps |= List.HasFileDeps();
ddc1d8d0
AL
222 return true;
223 }
224
578bfd0a 225 continue;
204fbdcc
AL
226 }
227
578bfd0a 228 // Add a new version
a52f938b 229 *LastVer = NewVersion(Ver,Version,*LastVer);
f55a958f 230 Ver->ParentPkg = Pkg.Index();
204fbdcc 231 Ver->Hash = Hash;
a52f938b 232
c5f44afc 233 if ((*LastVer == 0 && _error->PendingError()) || List.NewVersion(Ver) == false)
6804503b 234 return _error->Error(_("Error occurred while processing %s (NewVersion1)"),
7a3c2ab0 235 PackageName.c_str());
0149949b 236
f55a958f 237 if (List.UsePackage(Pkg,Ver) == false)
6804503b 238 return _error->Error(_("Error occurred while processing %s (UsePackage3)"),
7a3c2ab0 239 PackageName.c_str());
f55a958f 240
578bfd0a 241 if (NewFileVer(Ver,List) == false)
6804503b 242 return _error->Error(_("Error occurred while processing %s (NewVersion2)"),
7a3c2ab0 243 PackageName.c_str());
ddc1d8d0
AL
244
245 // Read only a single record and return
246 if (OutVer != 0)
247 {
248 *OutVer = Ver;
45415543 249 FoundFileDeps |= List.HasFileDeps();
ddc1d8d0
AL
250 return true;
251 }
a52f938b
OS
252
253 /* Record the Description data. Description data always exist in
254 Packages and Translation-* files. */
255 pkgCache::DescIterator Desc = Ver.DescriptionList();
256 map_ptrloc *LastDesc = &Ver->DescriptionList;
257
258 // Skip to the end of description set
9ee47c29 259 for (; Desc.end() == false; LastDesc = &Desc->NextDesc, Desc++);
a52f938b
OS
260
261 // Add new description
262 *LastDesc = NewDescription(Desc, List.DescriptionLanguage(), List.Description_md5(), *LastDesc);
263 Desc->ParentPkg = Pkg.Index();
264
c5f44afc 265 if ((*LastDesc == 0 && _error->PendingError()) || NewFileDesc(Desc,List) == false)
f0f66a3d 266 return _error->Error(_("Error occurred while processing %s (NewFileDesc2)"),PackageName.c_str());
8b32e920 267 }
578bfd0a 268 }
0149949b 269
45415543
AL
270 FoundFileDeps |= List.HasFileDeps();
271
6a3da7a6
AL
272 if (Cache.HeaderP->PackageCount >= (1ULL<<sizeof(Cache.PkgP->ID)*8)-1)
273 return _error->Error(_("Wow, you exceeded the number of package "
274 "names this APT is capable of."));
275 if (Cache.HeaderP->VersionCount >= (1ULL<<(sizeof(Cache.VerP->ID)*8))-1)
276 return _error->Error(_("Wow, you exceeded the number of versions "
277 "this APT is capable of."));
a52f938b
OS
278 if (Cache.HeaderP->DescriptionCount >= (1ULL<<(sizeof(Cache.DescP->ID)*8))-1)
279 return _error->Error(_("Wow, you exceeded the number of descriptions "
280 "this APT is capable of."));
6a3da7a6
AL
281 if (Cache.HeaderP->DependsCount >= (1ULL<<(sizeof(Cache.DepP->ID)*8))-1ULL)
282 return _error->Error(_("Wow, you exceeded the number of dependencies "
283 "this APT is capable of."));
578bfd0a
AL
284 return true;
285}
286 /*}}}*/
45415543
AL
287// CacheGenerator::MergeFileProvides - Merge file provides /*{{{*/
288// ---------------------------------------------------------------------
289/* If we found any file depends while parsing the main list we need to
290 resolve them. Since it is undesired to load the entire list of files
291 into the cache as virtual packages we do a two stage effort. MergeList
292 identifies the file depends and this creates Provdies for them by
293 re-parsing all the indexs. */
294bool pkgCacheGenerator::MergeFileProvides(ListParser &List)
295{
296 List.Owner = this;
297
298 unsigned int Counter = 0;
299 while (List.Step() == true)
300 {
301 string PackageName = List.Package();
302 if (PackageName.empty() == true)
303 return false;
304 string Version = List.Version();
305 if (Version.empty() == true)
306 continue;
307
308 pkgCache::PkgIterator Pkg = Cache.FindPkg(PackageName);
309 if (Pkg.end() == true)
6804503b 310 return _error->Error(_("Error occurred while processing %s (FindPkg)"),
45415543
AL
311 PackageName.c_str());
312 Counter++;
313 if (Counter % 100 == 0 && Progress != 0)
314 Progress->Progress(List.Offset());
315
316 unsigned long Hash = List.VersionHash();
317 pkgCache::VerIterator Ver = Pkg.VersionList();
9ee47c29 318 for (; Ver.end() == false; Ver++)
45415543
AL
319 {
320 if (Ver->Hash == Hash && Version.c_str() == Ver.VerStr())
321 {
322 if (List.CollectFileProvides(Cache,Ver) == false)
6804503b 323 return _error->Error(_("Error occurred while processing %s (CollectFileProvides)"),PackageName.c_str());
45415543
AL
324 break;
325 }
326 }
327
328 if (Ver.end() == true)
329 _error->Warning(_("Package %s %s was not found while processing file dependencies"),PackageName.c_str(),Version.c_str());
330 }
331
332 return true;
333}
334 /*}}}*/
5bf15716
DK
335// CacheGenerator::NewGroup - Add a new group /*{{{*/
336// ---------------------------------------------------------------------
337/* This creates a new group structure and adds it to the hash table */
33dd02e3
DK
338bool pkgCacheGenerator::NewGroup(pkgCache::GrpIterator &Grp, const string &Name)
339{
340 Grp = Cache.FindGrp(Name);
341 if (Grp.end() == false)
342 return true;
5bf15716 343
33dd02e3
DK
344 // Get a structure
345 unsigned long const Group = Map.Allocate(sizeof(pkgCache::Group));
346 if (unlikely(Group == 0))
347 return false;
5bf15716 348
33dd02e3
DK
349 Grp = pkgCache::GrpIterator(Cache, Cache.GrpP + Group);
350 Grp->Name = Map.WriteString(Name);
351 if (unlikely(Grp->Name == 0))
352 return false;
5bf15716 353
33dd02e3
DK
354 // Insert it into the hash table
355 unsigned long const Hash = Cache.Hash(Name);
356 Grp->Next = Cache.HeaderP->GrpHashTable[Hash];
357 Cache.HeaderP->GrpHashTable[Hash] = Group;
5bf15716 358
52c41485 359 Grp->ID = Cache.HeaderP->GroupCount++;
33dd02e3 360 return true;
5bf15716
DK
361}
362 /*}}}*/
578bfd0a
AL
363// CacheGenerator::NewPackage - Add a new package /*{{{*/
364// ---------------------------------------------------------------------
365/* This creates a new package structure and adds it to the hash table */
5bf15716
DK
366bool pkgCacheGenerator::NewPackage(pkgCache::PkgIterator &Pkg,const string &Name,
367 const string &Arch) {
368 pkgCache::GrpIterator Grp;
369 if (unlikely(NewGroup(Grp, Name) == false))
370 return false;
371
372 Pkg = Grp.FindPkg(Arch);
373 if (Pkg.end() == false)
374 return true;
a52f938b 375
578bfd0a 376 // Get a structure
5bf15716
DK
377 unsigned long const Package = Map.Allocate(sizeof(pkgCache::Package));
378 if (unlikely(Package == 0))
578bfd0a 379 return false;
f55a958f 380 Pkg = pkgCache::PkgIterator(Cache,Cache.PkgP + Package);
5bf15716 381
c408e01e
DK
382 // Insert the package into our package list
383 if (Grp->FirstPackage == 0) // the group is new
384 {
385 // Insert it into the hash table
386 unsigned long const Hash = Cache.Hash(Name);
387 Pkg->NextPackage = Cache.HeaderP->PkgHashTable[Hash];
388 Cache.HeaderP->PkgHashTable[Hash] = Package;
389 Grp->FirstPackage = Package;
390 }
391 else // Group the Packages together
392 {
393 // this package is the new last package
394 pkgCache::PkgIterator LastPkg(Cache, Cache.PkgP + Grp->LastPackage);
395 Pkg->NextPackage = LastPkg->NextPackage;
396 LastPkg->NextPackage = Package;
397 }
398 Grp->LastPackage = Package;
5bf15716
DK
399
400 // Set the name, arch and the ID
401 Pkg->Name = Grp->Name;
402 Pkg->Group = Grp.Index();
403 Pkg->Arch = WriteUniqString(Arch.c_str());
404 if (unlikely(Pkg->Arch == 0))
578bfd0a
AL
405 return false;
406 Pkg->ID = Cache.HeaderP->PackageCount++;
5bf15716 407
578bfd0a
AL
408 return true;
409}
410 /*}}}*/
411// CacheGenerator::NewFileVer - Create a new File<->Version association /*{{{*/
412// ---------------------------------------------------------------------
413/* */
f55a958f 414bool pkgCacheGenerator::NewFileVer(pkgCache::VerIterator &Ver,
578bfd0a
AL
415 ListParser &List)
416{
ddc1d8d0
AL
417 if (CurrentFile == 0)
418 return true;
419
dcb79bae
AL
420 // Get a structure
421 unsigned long VerFile = Map.Allocate(sizeof(pkgCache::VerFile));
422 if (VerFile == 0)
423 return 0;
424
425 pkgCache::VerFileIterator VF(Cache,Cache.VerFileP + VerFile);
426 VF->File = CurrentFile - Cache.PkgFileP;
03e39e59
AL
427
428 // Link it to the end of the list
349cd3b8 429 map_ptrloc *Last = &Ver->FileList;
eb162ff7 430 for (pkgCache::VerFileIterator V = Ver.FileList(); V.end() == false; V++)
03e39e59
AL
431 Last = &V->NextFile;
432 VF->NextFile = *Last;
433 *Last = VF.Index();
434
dcb79bae
AL
435 VF->Offset = List.Offset();
436 VF->Size = List.Size();
ad00ae81
AL
437 if (Cache.HeaderP->MaxVerFileSize < VF->Size)
438 Cache.HeaderP->MaxVerFileSize = VF->Size;
a7e66b17
AL
439 Cache.HeaderP->VerFileCount++;
440
f55a958f 441 return true;
578bfd0a
AL
442}
443 /*}}}*/
444// CacheGenerator::NewVersion - Create a new Version /*{{{*/
445// ---------------------------------------------------------------------
f55a958f 446/* This puts a version structure in the linked list */
578bfd0a 447unsigned long pkgCacheGenerator::NewVersion(pkgCache::VerIterator &Ver,
171c75f1 448 const string &VerStr,
578bfd0a
AL
449 unsigned long Next)
450{
f55a958f
AL
451 // Get a structure
452 unsigned long Version = Map.Allocate(sizeof(pkgCache::Version));
453 if (Version == 0)
0149949b 454 return 0;
f55a958f
AL
455
456 // Fill it in
457 Ver = pkgCache::VerIterator(Cache,Cache.VerP + Version);
f55a958f
AL
458 Ver->NextVer = Next;
459 Ver->ID = Cache.HeaderP->VersionCount++;
460 Ver->VerStr = Map.WriteString(VerStr);
461 if (Ver->VerStr == 0)
0149949b 462 return 0;
f55a958f 463
0149949b 464 return Version;
578bfd0a
AL
465}
466 /*}}}*/
a52f938b
OS
467// CacheGenerator::NewFileDesc - Create a new File<->Desc association /*{{{*/
468// ---------------------------------------------------------------------
469/* */
470bool pkgCacheGenerator::NewFileDesc(pkgCache::DescIterator &Desc,
471 ListParser &List)
472{
473 if (CurrentFile == 0)
474 return true;
475
476 // Get a structure
477 unsigned long DescFile = Map.Allocate(sizeof(pkgCache::DescFile));
478 if (DescFile == 0)
c5f44afc 479 return false;
770c32ec 480
a52f938b
OS
481 pkgCache::DescFileIterator DF(Cache,Cache.DescFileP + DescFile);
482 DF->File = CurrentFile - Cache.PkgFileP;
770c32ec 483
a52f938b
OS
484 // Link it to the end of the list
485 map_ptrloc *Last = &Desc->FileList;
eb162ff7 486 for (pkgCache::DescFileIterator D = Desc.FileList(); D.end() == false; D++)
a52f938b 487 Last = &D->NextFile;
770c32ec 488
a52f938b
OS
489 DF->NextFile = *Last;
490 *Last = DF.Index();
491
492 DF->Offset = List.Offset();
493 DF->Size = List.Size();
494 if (Cache.HeaderP->MaxDescFileSize < DF->Size)
495 Cache.HeaderP->MaxDescFileSize = DF->Size;
496 Cache.HeaderP->DescFileCount++;
497
498 return true;
499}
500 /*}}}*/
501// CacheGenerator::NewDescription - Create a new Description /*{{{*/
502// ---------------------------------------------------------------------
503/* This puts a description structure in the linked list */
504map_ptrloc pkgCacheGenerator::NewDescription(pkgCache::DescIterator &Desc,
c76c44b1 505 const string &Lang,
506 const MD5SumValue &md5sum,
a52f938b
OS
507 map_ptrloc Next)
508{
509 // Get a structure
510 map_ptrloc Description = Map.Allocate(sizeof(pkgCache::Description));
511 if (Description == 0)
512 return 0;
513
514 // Fill it in
515 Desc = pkgCache::DescIterator(Cache,Cache.DescP + Description);
516 Desc->NextDesc = Next;
517 Desc->ID = Cache.HeaderP->DescriptionCount++;
518 Desc->language_code = Map.WriteString(Lang);
519 Desc->md5sum = Map.WriteString(md5sum.Value());
c5f44afc
DK
520 if (Desc->language_code == 0 || Desc->md5sum == 0)
521 return 0;
a52f938b
OS
522
523 return Description;
524}
525 /*}}}*/
25396fb0
DK
526// CacheGenerator::FinishCache - do various finish operations /*{{{*/
527// ---------------------------------------------------------------------
528/* This prepares the Cache for delivery */
2e5f4e45 529bool pkgCacheGenerator::FinishCache(OpProgress *Progress)
33dd02e3
DK
530{
531 // FIXME: add progress reporting for this operation
532 // Do we have different architectures in your groups ?
533 vector<string> archs = APT::Configuration::getArchitectures();
534 if (archs.size() > 1)
535 {
536 // Create Conflicts in between the group
537 for (pkgCache::GrpIterator G = GetCache().GrpBegin(); G.end() != true; G++)
538 {
539 string const PkgName = G.Name();
540 for (pkgCache::PkgIterator P = G.PackageList(); P.end() != true; P = G.NextPkg(P))
541 {
542 if (strcmp(P.Arch(),"all") == 0)
543 continue;
544 pkgCache::PkgIterator allPkg;
545 for (pkgCache::VerIterator V = P.VersionList(); V.end() != true; V++)
546 {
547 string const Arch = V.Arch(true);
548 map_ptrloc *OldDepLast = NULL;
549 /* MultiArch handling introduces a lot of implicit Dependencies:
550 - MultiArch: same → Co-Installable if they have the same version
551 - Architecture: all → Need to be Co-Installable for internal reasons
552 - All others conflict with all other group members */
553 bool const coInstall = (V->MultiArch == pkgCache::Version::All ||
554 V->MultiArch == pkgCache::Version::Same);
555 if (V->MultiArch == pkgCache::Version::All && allPkg.end() == true)
556 allPkg = G.FindPkg("all");
557 for (vector<string>::const_iterator A = archs.begin(); A != archs.end(); ++A)
558 {
559 if (*A == Arch)
560 continue;
561 /* We allow only one installed arch at the time
562 per group, therefore each group member conflicts
563 with all other group members */
564 pkgCache::PkgIterator D = G.FindPkg(*A);
565 if (D.end() == true)
566 continue;
567 if (coInstall == true)
568 {
569 // Replaces: ${self}:other ( << ${binary:Version})
570 NewDepends(D, V, V.VerStr(),
571 pkgCache::Dep::Less, pkgCache::Dep::Replaces,
572 OldDepLast);
573 // Breaks: ${self}:other (!= ${binary:Version})
574 NewDepends(D, V, V.VerStr(),
575 pkgCache::Dep::Less, pkgCache::Dep::DpkgBreaks,
576 OldDepLast);
577 NewDepends(D, V, V.VerStr(),
578 pkgCache::Dep::Greater, pkgCache::Dep::DpkgBreaks,
579 OldDepLast);
580 if (V->MultiArch == pkgCache::Version::All)
581 {
582 // Depend on ${self}:all which does depend on nothing
583 NewDepends(allPkg, V, V.VerStr(),
584 pkgCache::Dep::Equals, pkgCache::Dep::Depends,
585 OldDepLast);
586 }
587 } else {
588 // Conflicts: ${self}:other
589 NewDepends(D, V, "",
590 pkgCache::Dep::NoOp, pkgCache::Dep::Conflicts,
591 OldDepLast);
592 }
593 }
594 }
595 }
596 }
597 }
598 return true;
25396fb0
DK
599}
600 /*}}}*/
601// CacheGenerator::NewDepends - Create a dependency element /*{{{*/
dcb79bae
AL
602// ---------------------------------------------------------------------
603/* This creates a dependency element in the tree. It is linked to the
604 version and to the package that it is pointing to. */
25396fb0
DK
605bool pkgCacheGenerator::NewDepends(pkgCache::PkgIterator &Pkg,
606 pkgCache::VerIterator &Ver,
607 string const &Version,
608 unsigned int const &Op,
609 unsigned int const &Type,
610 map_ptrloc *OldDepLast)
dcb79bae 611{
dcb79bae 612 // Get a structure
25396fb0 613 unsigned long const Dependency = Map.Allocate(sizeof(pkgCache::Dependency));
5bf15716 614 if (unlikely(Dependency == 0))
dcb79bae
AL
615 return false;
616
617 // Fill it in
618 pkgCache::DepIterator Dep(Cache,Cache.DepP + Dependency);
619 Dep->ParentVer = Ver.Index();
620 Dep->Type = Type;
621 Dep->CompareOp = Op;
622 Dep->ID = Cache.HeaderP->DependsCount++;
5bf15716 623
dcb79bae
AL
624 // Probe the reverse dependency list for a version string that matches
625 if (Version.empty() == false)
626 {
b2e465d6 627/* for (pkgCache::DepIterator I = Pkg.RevDependsList(); I.end() == false; I++)
dcb79bae 628 if (I->Version != 0 && I.TargetVer() == Version)
f9eec0e7 629 Dep->Version = I->Version;*/
dcb79bae 630 if (Dep->Version == 0)
25396fb0 631 if (unlikely((Dep->Version = Map.WriteString(Version)) == 0))
dcb79bae
AL
632 return false;
633 }
25396fb0 634
dcb79bae
AL
635 // Link it to the package
636 Dep->Package = Pkg.Index();
637 Dep->NextRevDepends = Pkg->RevDepends;
638 Pkg->RevDepends = Dep.Index();
25396fb0
DK
639
640 // Do we know where to link the Dependency to?
641 if (OldDepLast == NULL)
c1a22377 642 {
f9eec0e7 643 OldDepLast = &Ver->DependsList;
eb162ff7 644 for (pkgCache::DepIterator D = Ver.DependsList(); D.end() == false; D++)
f9eec0e7 645 OldDepLast = &D->NextDepends;
c1a22377 646 }
45415543 647
f9eec0e7
AL
648 Dep->NextDepends = *OldDepLast;
649 *OldDepLast = Dep.Index();
650 OldDepLast = &Dep->NextDepends;
c1a22377 651
dcb79bae
AL
652 return true;
653}
654 /*}}}*/
25396fb0
DK
655// ListParser::NewDepends - Create the environment for a new dependency /*{{{*/
656// ---------------------------------------------------------------------
657/* This creates a Group and the Package to link this dependency to if
658 needed and handles also the caching of the old endpoint */
659bool pkgCacheGenerator::ListParser::NewDepends(pkgCache::VerIterator Ver,
660 const string &PackageName,
661 const string &Arch,
662 const string &Version,
663 unsigned int Op,
664 unsigned int Type)
665{
666 pkgCache::GrpIterator Grp;
667 if (unlikely(Owner->NewGroup(Grp, PackageName) == false))
668 return false;
669
670 // Locate the target package
671 pkgCache::PkgIterator Pkg = Grp.FindPkg(Arch);
672 if (Pkg.end() == true) {
673 if (unlikely(Owner->NewPackage(Pkg, PackageName, Arch) == false))
674 return false;
675 }
676
677 // Is it a file dependency?
678 if (unlikely(PackageName[0] == '/'))
679 FoundFileDeps = true;
680
681 /* Caching the old end point speeds up generation substantially */
682 if (OldDepVer != Ver) {
683 OldDepLast = NULL;
684 OldDepVer = Ver;
685 }
686
687 return Owner->NewDepends(Pkg, Ver, Version, Op, Type, OldDepLast);
688}
689 /*}}}*/
dcb79bae
AL
690// ListParser::NewProvides - Create a Provides element /*{{{*/
691// ---------------------------------------------------------------------
692/* */
693bool pkgCacheGenerator::ListParser::NewProvides(pkgCache::VerIterator Ver,
67e0766f
DK
694 const string &PkgName,
695 const string &PkgArch,
171c75f1 696 const string &Version)
dcb79bae
AL
697{
698 pkgCache &Cache = Owner->Cache;
8efa2a3b
AL
699
700 // We do not add self referencing provides
803ea2a8 701 if (Ver.ParentPkg().Name() == PkgName && PkgArch == Ver.Arch(true))
8efa2a3b 702 return true;
dcb79bae
AL
703
704 // Get a structure
5bf15716
DK
705 unsigned long const Provides = Owner->Map.Allocate(sizeof(pkgCache::Provides));
706 if (unlikely(Provides == 0))
dcb79bae 707 return false;
a7e66b17 708 Cache.HeaderP->ProvidesCount++;
dcb79bae
AL
709
710 // Fill it in
711 pkgCache::PrvIterator Prv(Cache,Cache.ProvideP + Provides,Cache.PkgP);
712 Prv->Version = Ver.Index();
713 Prv->NextPkgProv = Ver->ProvidesList;
714 Ver->ProvidesList = Prv.Index();
5bf15716 715 if (Version.empty() == false && unlikely((Prv->ProvideVersion = WriteString(Version)) == 0))
dcb79bae
AL
716 return false;
717
718 // Locate the target package
8efa2a3b 719 pkgCache::PkgIterator Pkg;
67e0766f 720 if (unlikely(Owner->NewPackage(Pkg,PkgName, PkgArch) == false))
8efa2a3b 721 return false;
dcb79bae
AL
722
723 // Link it to the package
724 Prv->ParentPkg = Pkg.Index();
725 Prv->NextProvides = Pkg->ProvidesList;
726 Pkg->ProvidesList = Prv.Index();
727
728 return true;
729}
730 /*}}}*/
578bfd0a
AL
731// CacheGenerator::SelectFile - Select the current file being parsed /*{{{*/
732// ---------------------------------------------------------------------
733/* This is used to select which file is to be associated with all newly
b2e465d6 734 added versions. The caller is responsible for setting the IMS fields. */
171c75f1 735bool pkgCacheGenerator::SelectFile(const string &File,const string &Site,
b2e465d6
AL
736 const pkgIndexFile &Index,
737 unsigned long Flags)
578bfd0a 738{
578bfd0a
AL
739 // Get some space for the structure
740 CurrentFile = Cache.PkgFileP + Map.Allocate(sizeof(*CurrentFile));
741 if (CurrentFile == Cache.PkgFileP)
742 return false;
743
744 // Fill it in
745 CurrentFile->FileName = Map.WriteString(File);
b2e465d6 746 CurrentFile->Site = WriteUniqString(Site);
578bfd0a
AL
747 CurrentFile->NextFile = Cache.HeaderP->FileList;
748 CurrentFile->Flags = Flags;
e1b74f61 749 CurrentFile->ID = Cache.HeaderP->PackageFileCount;
b2e465d6 750 CurrentFile->IndexType = WriteUniqString(Index.GetType()->Label);
578bfd0a 751 PkgFileName = File;
ad00ae81 752 Cache.HeaderP->FileList = CurrentFile - Cache.PkgFileP;
b35d2f5f 753 Cache.HeaderP->PackageFileCount++;
b2e465d6 754
578bfd0a
AL
755 if (CurrentFile->FileName == 0)
756 return false;
404ec98e 757
ddc1d8d0 758 if (Progress != 0)
b2e465d6 759 Progress->SubProgress(Index.Size());
8efa2a3b 760 return true;
578bfd0a
AL
761}
762 /*}}}*/
f55a958f
AL
763// CacheGenerator::WriteUniqueString - Insert a unique string /*{{{*/
764// ---------------------------------------------------------------------
765/* This is used to create handles to strings. Given the same text it
766 always returns the same number */
767unsigned long pkgCacheGenerator::WriteUniqString(const char *S,
768 unsigned int Size)
769{
f9eec0e7
AL
770 /* We use a very small transient hash table here, this speeds up generation
771 by a fair amount on slower machines */
772 pkgCache::StringItem *&Bucket = UniqHash[(S[0]*5 + S[1]) % _count(UniqHash)];
773 if (Bucket != 0 &&
774 stringcmp(S,S+Size,Cache.StrP + Bucket->String) == 0)
775 return Bucket->String;
776
f55a958f
AL
777 // Search for an insertion point
778 pkgCache::StringItem *I = Cache.StringItemP + Cache.HeaderP->StringList;
779 int Res = 1;
349cd3b8 780 map_ptrloc *Last = &Cache.HeaderP->StringList;
f55a958f
AL
781 for (; I != Cache.StringItemP; Last = &I->NextItem,
782 I = Cache.StringItemP + I->NextItem)
783 {
9c14e3d6 784 Res = stringcmp(S,S+Size,Cache.StrP + I->String);
f55a958f
AL
785 if (Res >= 0)
786 break;
787 }
788
789 // Match
790 if (Res == 0)
f9eec0e7
AL
791 {
792 Bucket = I;
0149949b 793 return I->String;
f9eec0e7 794 }
f55a958f
AL
795
796 // Get a structure
797 unsigned long Item = Map.Allocate(sizeof(pkgCache::StringItem));
798 if (Item == 0)
0149949b
AL
799 return 0;
800
f55a958f
AL
801 // Fill in the structure
802 pkgCache::StringItem *ItemP = Cache.StringItemP + Item;
803 ItemP->NextItem = I - Cache.StringItemP;
804 *Last = Item;
805 ItemP->String = Map.WriteString(S,Size);
806 if (ItemP->String == 0)
0149949b 807 return 0;
f55a958f 808
f9eec0e7 809 Bucket = ItemP;
0149949b 810 return ItemP->String;
f55a958f
AL
811}
812 /*}}}*/
b2e465d6 813// CheckValidity - Check that a cache is up-to-date /*{{{*/
b35d2f5f 814// ---------------------------------------------------------------------
b2e465d6
AL
815/* This just verifies that each file in the list of index files exists,
816 has matching attributes with the cache and the cache does not have
817 any extra files. */
171c75f1 818static bool CheckValidity(const string &CacheFile, FileIterator Start,
e7b470ee 819 FileIterator End,MMap **OutMap = 0)
b35d2f5f 820{
c8e572e3 821 bool const Debug = _config->FindB("Debug::pkgCacheGen", false);
b2e465d6
AL
822 // No file, certainly invalid
823 if (CacheFile.empty() == true || FileExists(CacheFile) == false)
c8e572e3
MV
824 {
825 if (Debug == true)
826 std::clog << "CacheFile doesn't exist" << std::endl;
b35d2f5f 827 return false;
c8e572e3
MV
828 }
829
b2e465d6 830 // Map it
b35d2f5f 831 FileFd CacheF(CacheFile,FileFd::ReadOnly);
eb162ff7 832 SPtr<MMap> Map = new MMap(CacheF,0);
b35d2f5f 833 pkgCache Cache(Map);
b2e465d6 834 if (_error->PendingError() == true || Map->Size() == 0)
b35d2f5f 835 {
c8e572e3
MV
836 if (Debug == true)
837 std::clog << "Errors are pending or Map is empty()" << std::endl;
b35d2f5f
AL
838 _error->Discard();
839 return false;
840 }
b35d2f5f 841
b2e465d6
AL
842 /* Now we check every index file, see if it is in the cache,
843 verify the IMS data and check that it is on the disk too.. */
844 SPtrArray<bool> Visited = new bool[Cache.HeaderP->PackageFileCount];
845 memset(Visited,0,sizeof(*Visited)*Cache.HeaderP->PackageFileCount);
846 for (; Start != End; Start++)
c8e572e3
MV
847 {
848 if (Debug == true)
849 std::clog << "Checking PkgFile " << (*Start)->Describe() << ": ";
b2e465d6 850 if ((*Start)->HasPackages() == false)
c8e572e3
MV
851 {
852 if (Debug == true)
853 std::clog << "Has NO packages" << std::endl;
b2e465d6 854 continue;
c8e572e3 855 }
a77ad7c3 856
b2e465d6 857 if ((*Start)->Exists() == false)
b35d2f5f 858 {
a791a450 859#if 0 // mvo: we no longer give a message here (Default Sources spec)
b2e465d6
AL
860 _error->WarningE("stat",_("Couldn't stat source package list %s"),
861 (*Start)->Describe().c_str());
a791a450 862#endif
c8e572e3
MV
863 if (Debug == true)
864 std::clog << "file doesn't exist" << std::endl;
b2e465d6 865 continue;
b35d2f5f 866 }
b2e465d6
AL
867
868 // FindInCache is also expected to do an IMS check.
869 pkgCache::PkgFileIterator File = (*Start)->FindInCache(Cache);
870 if (File.end() == true)
c8e572e3
MV
871 {
872 if (Debug == true)
873 std::clog << "FindInCache returned end-Pointer" << std::endl;
b35d2f5f 874 return false;
c8e572e3 875 }
a52f938b 876
b2e465d6 877 Visited[File->ID] = true;
c8e572e3
MV
878 if (Debug == true)
879 std::clog << "with ID " << File->ID << " is valid" << std::endl;
b35d2f5f
AL
880 }
881
b2e465d6
AL
882 for (unsigned I = 0; I != Cache.HeaderP->PackageFileCount; I++)
883 if (Visited[I] == false)
c8e572e3
MV
884 {
885 if (Debug == true)
886 std::clog << "File with ID" << I << " wasn't visited" << std::endl;
b2e465d6 887 return false;
c8e572e3 888 }
b35d2f5f 889
b35d2f5f
AL
890 if (_error->PendingError() == true)
891 {
c8e572e3
MV
892 if (Debug == true)
893 {
894 std::clog << "Validity failed because of pending errors:" << std::endl;
895 _error->DumpErrors();
896 }
b35d2f5f
AL
897 _error->Discard();
898 return false;
899 }
b35d2f5f 900
b2e465d6
AL
901 if (OutMap != 0)
902 *OutMap = Map.UnGuard();
b35d2f5f
AL
903 return true;
904}
905 /*}}}*/
b2e465d6 906// ComputeSize - Compute the total size of a bunch of files /*{{{*/
b35d2f5f 907// ---------------------------------------------------------------------
b2e465d6
AL
908/* Size is kind of an abstract notion that is only used for the progress
909 meter */
e7b470ee 910static unsigned long ComputeSize(FileIterator Start,FileIterator End)
b35d2f5f 911{
b2e465d6
AL
912 unsigned long TotalSize = 0;
913 for (; Start != End; Start++)
b35d2f5f 914 {
b2e465d6
AL
915 if ((*Start)->HasPackages() == false)
916 continue;
917 TotalSize += (*Start)->Size();
b35d2f5f 918 }
b2e465d6 919 return TotalSize;
2d11135a
AL
920}
921 /*}}}*/
b2e465d6 922// BuildCache - Merge the list of index files into the cache /*{{{*/
2d11135a 923// ---------------------------------------------------------------------
b2e465d6
AL
924/* */
925static bool BuildCache(pkgCacheGenerator &Gen,
2e5f4e45 926 OpProgress *Progress,
b2e465d6 927 unsigned long &CurrentSize,unsigned long TotalSize,
e7b470ee 928 FileIterator Start, FileIterator End)
2d11135a 929{
45415543
AL
930 FileIterator I;
931 for (I = Start; I != End; I++)
2d11135a 932 {
45415543 933 if ((*I)->HasPackages() == false)
2d11135a
AL
934 continue;
935
45415543 936 if ((*I)->Exists() == false)
2d11135a 937 continue;
b2e465d6 938
45415543 939 if ((*I)->FindInCache(Gen.GetCache()).end() == false)
a77ad7c3
AL
940 {
941 _error->Warning("Duplicate sources.list entry %s",
45415543 942 (*I)->Describe().c_str());
a77ad7c3
AL
943 continue;
944 }
945
45415543 946 unsigned long Size = (*I)->Size();
2e5f4e45
DK
947 if (Progress != NULL)
948 Progress->OverallProgress(CurrentSize,TotalSize,Size,_("Reading package lists"));
b2e465d6 949 CurrentSize += Size;
2d11135a 950
45415543 951 if ((*I)->Merge(Gen,Progress) == false)
b2e465d6
AL
952 return false;
953 }
45415543
AL
954
955 if (Gen.HasFileDeps() == true)
956 {
2e5f4e45
DK
957 if (Progress != NULL)
958 Progress->Done();
45415543
AL
959 TotalSize = ComputeSize(Start, End);
960 CurrentSize = 0;
961 for (I = Start; I != End; I++)
962 {
963 unsigned long Size = (*I)->Size();
2e5f4e45
DK
964 if (Progress != NULL)
965 Progress->OverallProgress(CurrentSize,TotalSize,Size,_("Collecting File Provides"));
45415543
AL
966 CurrentSize += Size;
967 if ((*I)->MergeFileProvides(Gen,Progress) == false)
968 return false;
969 }
970 }
2d11135a 971
b35d2f5f
AL
972 return true;
973}
974 /*}}}*/
2e5f4e45 975// CacheGenerator::MakeStatusCache - Construct the status cache /*{{{*/
b35d2f5f 976// ---------------------------------------------------------------------
b2e465d6
AL
977/* This makes sure that the status cache (the cache that has all
978 index files from the sources list and all local ones) is ready
979 to be mmaped. If OutMap is not zero then a MMap object representing
980 the cache will be stored there. This is pretty much mandetory if you
981 are using AllowMem. AllowMem lets the function be run as non-root
982 where it builds the cache 'fast' into a memory buffer. */
2e5f4e45
DK
983__deprecated bool pkgMakeStatusCache(pkgSourceList &List,OpProgress &Progress,
984 MMap **OutMap, bool AllowMem)
985 { return pkgCacheGenerator::MakeStatusCache(List, &Progress, OutMap, AllowMem); }
986bool pkgCacheGenerator::MakeStatusCache(pkgSourceList &List,OpProgress *Progress,
b2e465d6 987 MMap **OutMap,bool AllowMem)
b35d2f5f 988{
c8e572e3
MV
989 bool const Debug = _config->FindB("Debug::pkgCacheGen", false);
990 unsigned long const MapSize = _config->FindI("APT::Cache-Limit",24*1024*1024);
67db871e 991
7db98ffc
MZ
992 vector<pkgIndexFile *> Files;
993 for (vector<metaIndex *>::const_iterator i = List.begin();
994 i != List.end();
995 i++)
996 {
997 vector <pkgIndexFile *> *Indexes = (*i)->GetIndexFiles();
998 for (vector<pkgIndexFile *>::const_iterator j = Indexes->begin();
999 j != Indexes->end();
1000 j++)
1001 Files.push_back (*j);
1002 }
1003
c8e572e3 1004 unsigned long const EndOfSource = Files.size();
b2e465d6
AL
1005 if (_system->AddStatusFiles(Files) == false)
1006 return false;
c5f44afc 1007
b2e465d6 1008 // Decide if we can write to the files..
c8e572e3
MV
1009 string const CacheFile = _config->FindFile("Dir::Cache::pkgcache");
1010 string const SrcCacheFile = _config->FindFile("Dir::Cache::srcpkgcache");
1cd1c398
DK
1011
1012 // ensure the cache directory exists
1013 if (CacheFile.empty() == false || SrcCacheFile.empty() == false)
1014 {
1015 string dir = _config->FindDir("Dir::Cache");
1016 size_t const len = dir.size();
1017 if (len > 5 && dir.find("/apt/", len - 6, 5) == len - 5)
1018 dir = dir.substr(0, len - 5);
1019 if (CacheFile.empty() == false)
1020 CreateDirectory(dir, flNotFile(CacheFile));
1021 if (SrcCacheFile.empty() == false)
1022 CreateDirectory(dir, flNotFile(SrcCacheFile));
1023 }
1024
b2e465d6
AL
1025 // Decide if we can write to the cache
1026 bool Writeable = false;
1027 if (CacheFile.empty() == false)
1028 Writeable = access(flNotFile(CacheFile).c_str(),W_OK) == 0;
1029 else
1030 if (SrcCacheFile.empty() == false)
1031 Writeable = access(flNotFile(SrcCacheFile).c_str(),W_OK) == 0;
c8e572e3
MV
1032 if (Debug == true)
1033 std::clog << "Do we have write-access to the cache files? " << (Writeable ? "YES" : "NO") << std::endl;
1034
b2e465d6
AL
1035 if (Writeable == false && AllowMem == false && CacheFile.empty() == false)
1036 return _error->Error(_("Unable to write to %s"),flNotFile(CacheFile).c_str());
2e5f4e45
DK
1037
1038 if (Progress != NULL)
1039 Progress->OverallProgress(0,1,1,_("Reading package lists"));
1040
b2e465d6
AL
1041 // Cache is OK, Fin.
1042 if (CheckValidity(CacheFile,Files.begin(),Files.end(),OutMap) == true)
1043 {
2e5f4e45
DK
1044 if (Progress != NULL)
1045 Progress->OverallProgress(1,1,1,_("Reading package lists"));
c8e572e3
MV
1046 if (Debug == true)
1047 std::clog << "pkgcache.bin is valid - no need to build anything" << std::endl;
b2e465d6
AL
1048 return true;
1049 }
c8e572e3
MV
1050 else if (Debug == true)
1051 std::clog << "pkgcache.bin is NOT valid" << std::endl;
b2e465d6
AL
1052
1053 /* At this point we know we need to reconstruct the package cache,
1054 begin. */
1055 SPtr<FileFd> CacheF;
1056 SPtr<DynamicMMap> Map;
1057 if (Writeable == true && CacheFile.empty() == false)
1058 {
1059 unlink(CacheFile.c_str());
1060 CacheF = new FileFd(CacheFile,FileFd::WriteEmpty);
7a3c2ab0 1061 fchmod(CacheF->Fd(),0644);
b2e465d6 1062 Map = new DynamicMMap(*CacheF,MMap::Public,MapSize);
b35d2f5f
AL
1063 if (_error->PendingError() == true)
1064 return false;
c8e572e3
MV
1065 if (Debug == true)
1066 std::clog << "Open filebased MMap" << std::endl;
b35d2f5f 1067 }
b2e465d6 1068 else
8ce4327b 1069 {
b2e465d6 1070 // Just build it in memory..
eb162ff7 1071 Map = new DynamicMMap(0,MapSize);
c8e572e3
MV
1072 if (Debug == true)
1073 std::clog << "Open memory Map (not filebased)" << std::endl;
8ce4327b 1074 }
b35d2f5f 1075
b2e465d6 1076 // Lets try the source cache.
b35d2f5f 1077 unsigned long CurrentSize = 0;
b2e465d6
AL
1078 unsigned long TotalSize = 0;
1079 if (CheckValidity(SrcCacheFile,Files.begin(),
1080 Files.begin()+EndOfSource) == true)
2d11135a 1081 {
c8e572e3
MV
1082 if (Debug == true)
1083 std::clog << "srcpkgcache.bin is valid - populate MMap with it." << std::endl;
b2e465d6
AL
1084 // Preload the map with the source cache
1085 FileFd SCacheF(SrcCacheFile,FileFd::ReadOnly);
c8e572e3 1086 unsigned long const alloc = Map->RawAllocate(SCacheF.Size());
eb162ff7
DK
1087 if ((alloc == 0 && _error->PendingError())
1088 || SCacheF.Read((unsigned char *)Map->Data() + alloc,
1089 SCacheF.Size()) == false)
b2e465d6
AL
1090 return false;
1091
1092 TotalSize = ComputeSize(Files.begin()+EndOfSource,Files.end());
c8e572e3 1093
b2e465d6 1094 // Build the status cache
2e5f4e45 1095 pkgCacheGenerator Gen(Map.Get(),Progress);
2d11135a 1096 if (_error->PendingError() == true)
b2e465d6
AL
1097 return false;
1098 if (BuildCache(Gen,Progress,CurrentSize,TotalSize,
1099 Files.begin()+EndOfSource,Files.end()) == false)
1100 return false;
25396fb0
DK
1101
1102 // FIXME: move me to a better place
1103 Gen.FinishCache(Progress);
b2e465d6
AL
1104 }
1105 else
2d11135a 1106 {
c8e572e3
MV
1107 if (Debug == true)
1108 std::clog << "srcpkgcache.bin is NOT valid - rebuild" << std::endl;
b2e465d6 1109 TotalSize = ComputeSize(Files.begin(),Files.end());
2d11135a 1110
b2e465d6 1111 // Build the source cache
2e5f4e45 1112 pkgCacheGenerator Gen(Map.Get(),Progress);
b2e465d6
AL
1113 if (_error->PendingError() == true)
1114 return false;
1115 if (BuildCache(Gen,Progress,CurrentSize,TotalSize,
1116 Files.begin(),Files.begin()+EndOfSource) == false)
1117 return false;
2d11135a 1118
b2e465d6
AL
1119 // Write it back
1120 if (Writeable == true && SrcCacheFile.empty() == false)
2d11135a 1121 {
b2e465d6
AL
1122 FileFd SCacheF(SrcCacheFile,FileFd::WriteEmpty);
1123 if (_error->PendingError() == true)
1124 return false;
7a3c2ab0
AL
1125
1126 fchmod(SCacheF.Fd(),0644);
1127
b2e465d6
AL
1128 // Write out the main data
1129 if (SCacheF.Write(Map->Data(),Map->Size()) == false)
1130 return _error->Error(_("IO Error saving source cache"));
1131 SCacheF.Sync();
1132
1133 // Write out the proper header
1134 Gen.GetCache().HeaderP->Dirty = false;
1135 if (SCacheF.Seek(0) == false ||
1136 SCacheF.Write(Map->Data(),sizeof(*Gen.GetCache().HeaderP)) == false)
1137 return _error->Error(_("IO Error saving source cache"));
b2e465d6 1138 Gen.GetCache().HeaderP->Dirty = true;
7a3c2ab0 1139 SCacheF.Sync();
2d11135a
AL
1140 }
1141
b2e465d6
AL
1142 // Build the status cache
1143 if (BuildCache(Gen,Progress,CurrentSize,TotalSize,
1144 Files.begin()+EndOfSource,Files.end()) == false)
1145 return false;
25396fb0
DK
1146
1147 // FIXME: move me to a better place
1148 Gen.FinishCache(Progress);
2d11135a 1149 }
c8e572e3
MV
1150 if (Debug == true)
1151 std::clog << "Caches are ready for shipping" << std::endl;
2d11135a 1152
b2e465d6
AL
1153 if (_error->PendingError() == true)
1154 return false;
1155 if (OutMap != 0)
2d11135a 1156 {
b2e465d6 1157 if (CacheF != 0)
2d11135a 1158 {
b2e465d6 1159 delete Map.UnGuard();
eb162ff7 1160 *OutMap = new MMap(*CacheF,0);
2d11135a 1161 }
b2e465d6
AL
1162 else
1163 {
1164 *OutMap = Map.UnGuard();
1165 }
2d11135a
AL
1166 }
1167
b2e465d6
AL
1168 return true;
1169}
1170 /*}}}*/
2e5f4e45 1171// CacheGenerator::MakeOnlyStatusCache - Build only a status files cache/*{{{*/
b2e465d6
AL
1172// ---------------------------------------------------------------------
1173/* */
2e5f4e45
DK
1174__deprecated bool pkgMakeOnlyStatusCache(OpProgress &Progress,DynamicMMap **OutMap)
1175 { return pkgCacheGenerator::MakeOnlyStatusCache(&Progress, OutMap); }
1176bool pkgCacheGenerator::MakeOnlyStatusCache(OpProgress *Progress,DynamicMMap **OutMap)
b2e465d6 1177{
5177f802 1178 unsigned long MapSize = _config->FindI("APT::Cache-Limit",20*1024*1024);
b2e465d6
AL
1179 vector<pkgIndexFile *> Files;
1180 unsigned long EndOfSource = Files.size();
1181 if (_system->AddStatusFiles(Files) == false)
1182 return false;
1183
eb162ff7 1184 SPtr<DynamicMMap> Map = new DynamicMMap(0,MapSize);
b2e465d6
AL
1185 unsigned long CurrentSize = 0;
1186 unsigned long TotalSize = 0;
1187
1188 TotalSize = ComputeSize(Files.begin()+EndOfSource,Files.end());
1189
1190 // Build the status cache
2e5f4e45
DK
1191 if (Progress != NULL)
1192 Progress->OverallProgress(0,1,1,_("Reading package lists"));
1193 pkgCacheGenerator Gen(Map.Get(),Progress);
2d11135a 1194 if (_error->PendingError() == true)
b2e465d6
AL
1195 return false;
1196 if (BuildCache(Gen,Progress,CurrentSize,TotalSize,
1197 Files.begin()+EndOfSource,Files.end()) == false)
1198 return false;
25396fb0
DK
1199
1200 // FIXME: move me to a better place
1201 Gen.FinishCache(Progress);
1202
b2e465d6
AL
1203 if (_error->PendingError() == true)
1204 return false;
1205 *OutMap = Map.UnGuard();
2d11135a 1206
b2e465d6 1207 return true;
2d11135a
AL
1208}
1209 /*}}}*/