]>
git.saurik.com Git - apt.git/blob - apt-pkg/pkgcachegen.cc
b11ddcf9e084ba766c886fe937a322bab036d500
1 // -*- mode: cpp; mode: fold -*-
3 // $Id: pkgcachegen.cc,v 1.53.2.1 2003/12/24 23:09:17 mdz Exp $
4 /* ######################################################################
6 Package Cache Generator - Generator for the cache structure.
8 This builds the cache structure from the abstract package list parser.
10 ##################################################################### */
12 // Include Files /*{{{*/
15 #include <apt-pkg/pkgcachegen.h>
16 #include <apt-pkg/error.h>
17 #include <apt-pkg/version.h>
18 #include <apt-pkg/progress.h>
19 #include <apt-pkg/sourcelist.h>
20 #include <apt-pkg/configuration.h>
21 #include <apt-pkg/aptconfiguration.h>
22 #include <apt-pkg/strutl.h>
23 #include <apt-pkg/sptr.h>
24 #include <apt-pkg/pkgsystem.h>
25 #include <apt-pkg/macros.h>
26 #include <apt-pkg/tagfile.h>
27 #include <apt-pkg/metaindex.h>
28 #include <apt-pkg/fileutl.h>
38 typedef std::vector
<pkgIndexFile
*>::iterator FileIterator
;
39 template <typename Iter
> std::vector
<Iter
*> pkgCacheGenerator::Dynamic
<Iter
>::toReMap
;
41 static bool IsDuplicateDescription(pkgCache::DescIterator Desc
,
42 MD5SumValue
const &CurMd5
, std::string
const &CurLang
);
46 // CacheGenerator::pkgCacheGenerator - Constructor /*{{{*/
47 // ---------------------------------------------------------------------
48 /* We set the dirty flag and make sure that is written to the disk */
49 pkgCacheGenerator::pkgCacheGenerator(DynamicMMap
*pMap
,OpProgress
*Prog
) :
50 Map(*pMap
), Cache(pMap
,false), Progress(Prog
),
54 memset(UniqHash
,0,sizeof(UniqHash
));
56 if (_error
->PendingError() == true)
61 // Setup the map interface..
62 Cache
.HeaderP
= (pkgCache::Header
*)Map
.Data();
63 if (Map
.RawAllocate(sizeof(pkgCache::Header
)) == 0 && _error
->PendingError() == true)
66 Map
.UsePools(*Cache
.HeaderP
->Pools
,sizeof(Cache
.HeaderP
->Pools
)/sizeof(Cache
.HeaderP
->Pools
[0]));
69 *Cache
.HeaderP
= pkgCache::Header();
70 map_ptrloc
const idxVerSysName
= WriteStringInMap(_system
->VS
->Label
);
71 Cache
.HeaderP
->VerSysName
= idxVerSysName
;
72 // this pointer is set in ReMap, but we need it now for WriteUniqString
73 Cache
.StringItemP
= (pkgCache::StringItem
*)Map
.Data();
74 map_ptrloc
const idxArchitecture
= WriteUniqString(_config
->Find("APT::Architecture"));
75 Cache
.HeaderP
->Architecture
= idxArchitecture
;
76 if (unlikely(idxVerSysName
== 0 || idxArchitecture
== 0))
82 // Map directly from the existing file
84 Map
.UsePools(*Cache
.HeaderP
->Pools
,sizeof(Cache
.HeaderP
->Pools
)/sizeof(Cache
.HeaderP
->Pools
[0]));
85 if (Cache
.VS
!= _system
->VS
)
87 _error
->Error(_("Cache has an incompatible versioning system"));
92 Cache
.HeaderP
->Dirty
= true;
93 Map
.Sync(0,sizeof(pkgCache::Header
));
96 // CacheGenerator::~pkgCacheGenerator - Destructor /*{{{*/
97 // ---------------------------------------------------------------------
98 /* We sync the data then unset the dirty flag in two steps so as to
99 advoid a problem during a crash */
100 pkgCacheGenerator::~pkgCacheGenerator()
102 if (_error
->PendingError() == true)
104 if (Map
.Sync() == false)
107 Cache
.HeaderP
->Dirty
= false;
108 Cache
.HeaderP
->CacheFileSize
= Map
.Size();
109 Map
.Sync(0,sizeof(pkgCache::Header
));
112 void pkgCacheGenerator::ReMap(void const * const oldMap
, void const * const newMap
) {/*{{{*/
113 if (oldMap
== newMap
)
116 if (_config
->FindB("Debug::pkgCacheGen", false))
117 std::clog
<< "Remaping from " << oldMap
<< " to " << newMap
<< std::endl
;
121 CurrentFile
+= (pkgCache::PackageFile
*) newMap
- (pkgCache::PackageFile
*) oldMap
;
123 for (size_t i
= 0; i
< _count(UniqHash
); ++i
)
124 if (UniqHash
[i
] != 0)
125 UniqHash
[i
] += (pkgCache::StringItem
*) newMap
- (pkgCache::StringItem
*) oldMap
;
127 for (std::vector
<pkgCache::GrpIterator
*>::const_iterator i
= Dynamic
<pkgCache::GrpIterator
>::toReMap
.begin();
128 i
!= Dynamic
<pkgCache::GrpIterator
>::toReMap
.end(); ++i
)
129 (*i
)->ReMap(oldMap
, newMap
);
130 for (std::vector
<pkgCache::PkgIterator
*>::const_iterator i
= Dynamic
<pkgCache::PkgIterator
>::toReMap
.begin();
131 i
!= Dynamic
<pkgCache::PkgIterator
>::toReMap
.end(); ++i
)
132 (*i
)->ReMap(oldMap
, newMap
);
133 for (std::vector
<pkgCache::VerIterator
*>::const_iterator i
= Dynamic
<pkgCache::VerIterator
>::toReMap
.begin();
134 i
!= Dynamic
<pkgCache::VerIterator
>::toReMap
.end(); ++i
)
135 (*i
)->ReMap(oldMap
, newMap
);
136 for (std::vector
<pkgCache::DepIterator
*>::const_iterator i
= Dynamic
<pkgCache::DepIterator
>::toReMap
.begin();
137 i
!= Dynamic
<pkgCache::DepIterator
>::toReMap
.end(); ++i
)
138 (*i
)->ReMap(oldMap
, newMap
);
139 for (std::vector
<pkgCache::DescIterator
*>::const_iterator i
= Dynamic
<pkgCache::DescIterator
>::toReMap
.begin();
140 i
!= Dynamic
<pkgCache::DescIterator
>::toReMap
.end(); ++i
)
141 (*i
)->ReMap(oldMap
, newMap
);
142 for (std::vector
<pkgCache::PrvIterator
*>::const_iterator i
= Dynamic
<pkgCache::PrvIterator
>::toReMap
.begin();
143 i
!= Dynamic
<pkgCache::PrvIterator
>::toReMap
.end(); ++i
)
144 (*i
)->ReMap(oldMap
, newMap
);
145 for (std::vector
<pkgCache::PkgFileIterator
*>::const_iterator i
= Dynamic
<pkgCache::PkgFileIterator
>::toReMap
.begin();
146 i
!= Dynamic
<pkgCache::PkgFileIterator
>::toReMap
.end(); ++i
)
147 (*i
)->ReMap(oldMap
, newMap
);
149 // CacheGenerator::WriteStringInMap /*{{{*/
150 map_ptrloc
pkgCacheGenerator::WriteStringInMap(const char *String
,
151 const unsigned long &Len
) {
152 void const * const oldMap
= Map
.Data();
153 map_ptrloc
const index
= Map
.WriteString(String
, Len
);
155 ReMap(oldMap
, Map
.Data());
159 // CacheGenerator::WriteStringInMap /*{{{*/
160 map_ptrloc
pkgCacheGenerator::WriteStringInMap(const char *String
) {
161 void const * const oldMap
= Map
.Data();
162 map_ptrloc
const index
= Map
.WriteString(String
);
164 ReMap(oldMap
, Map
.Data());
168 map_ptrloc
pkgCacheGenerator::AllocateInMap(const unsigned long &size
) {/*{{{*/
169 void const * const oldMap
= Map
.Data();
170 map_ptrloc
const index
= Map
.Allocate(size
);
172 ReMap(oldMap
, Map
.Data());
176 // CacheGenerator::MergeList - Merge the package list /*{{{*/
177 // ---------------------------------------------------------------------
178 /* This provides the generation of the entries in the cache. Each loop
179 goes through a single package record from the underlying parse engine. */
180 bool pkgCacheGenerator::MergeList(ListParser
&List
,
181 pkgCache::VerIterator
*OutVer
)
185 unsigned int Counter
= 0;
186 while (List
.Step() == true)
188 string
const PackageName
= List
.Package();
189 if (PackageName
.empty() == true)
193 if (Counter
% 100 == 0 && Progress
!= 0)
194 Progress
->Progress(List
.Offset());
196 string Arch
= List
.Architecture();
197 string
const Version
= List
.Version();
198 if (Version
.empty() == true && Arch
.empty() == true)
200 // package descriptions
201 if (MergeListGroup(List
, PackageName
) == false)
206 if (Arch
.empty() == true)
208 // use the pseudo arch 'none' for arch-less packages
210 /* We might built a SingleArchCache here, which we don't want to blow up
211 just for these :none packages to a proper MultiArchCache, so just ensure
212 that we have always a native package structure first for SingleArch */
213 pkgCache::PkgIterator NP
;
214 Dynamic
<pkgCache::PkgIterator
> DynPkg(NP
);
215 if (NewPackage(NP
, PackageName
, _config
->Find("APT::Architecture")) == false)
216 // TRANSLATOR: The first placeholder is a package name,
217 // the other two should be copied verbatim as they include debug info
218 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
219 PackageName
.c_str(), "NewPackage", 0);
222 // Get a pointer to the package structure
223 pkgCache::PkgIterator Pkg
;
224 Dynamic
<pkgCache::PkgIterator
> DynPkg(Pkg
);
225 if (NewPackage(Pkg
, PackageName
, Arch
) == false)
226 // TRANSLATOR: The first placeholder is a package name,
227 // the other two should be copied verbatim as they include debug info
228 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
229 PackageName
.c_str(), "NewPackage", 1);
232 if (Version
.empty() == true)
234 if (MergeListPackage(List
, Pkg
) == false)
239 if (MergeListVersion(List
, Pkg
, Version
, OutVer
) == false)
245 FoundFileDeps
|= List
.HasFileDeps();
250 if (Cache
.HeaderP
->PackageCount
>= (1ULL<<sizeof(Cache
.PkgP
->ID
)*8)-1)
251 return _error
->Error(_("Wow, you exceeded the number of package "
252 "names this APT is capable of."));
253 if (Cache
.HeaderP
->VersionCount
>= (1ULL<<(sizeof(Cache
.VerP
->ID
)*8))-1)
254 return _error
->Error(_("Wow, you exceeded the number of versions "
255 "this APT is capable of."));
256 if (Cache
.HeaderP
->DescriptionCount
>= (1ULL<<(sizeof(Cache
.DescP
->ID
)*8))-1)
257 return _error
->Error(_("Wow, you exceeded the number of descriptions "
258 "this APT is capable of."));
259 if (Cache
.HeaderP
->DependsCount
>= (1ULL<<(sizeof(Cache
.DepP
->ID
)*8))-1ULL)
260 return _error
->Error(_("Wow, you exceeded the number of dependencies "
261 "this APT is capable of."));
263 FoundFileDeps
|= List
.HasFileDeps();
266 // CacheGenerator::MergeListGroup /*{{{*/
267 bool pkgCacheGenerator::MergeListGroup(ListParser
&List
, std::string
const &GrpName
)
269 pkgCache::GrpIterator Grp
= Cache
.FindGrp(GrpName
);
270 // a group has no data on it's own, only packages have it but these
271 // stanzas like this come from Translation- files to add descriptions,
272 // but without a version we don't need a description for it…
273 if (Grp
.end() == true)
275 Dynamic
<pkgCache::GrpIterator
> DynGrp(Grp
);
277 pkgCache::PkgIterator Pkg
;
278 Dynamic
<pkgCache::PkgIterator
> DynPkg(Pkg
);
279 for (Pkg
= Grp
.PackageList(); Pkg
.end() == false; Pkg
= Grp
.NextPkg(Pkg
))
280 if (MergeListPackage(List
, Pkg
) == false)
286 // CacheGenerator::MergeListPackage /*{{{*/
287 bool pkgCacheGenerator::MergeListPackage(ListParser
&List
, pkgCache::PkgIterator
&Pkg
)
289 // we first process the package, then the descriptions
290 // (for deb this package processing is in fact a no-op)
291 pkgCache::VerIterator
Ver(Cache
);
292 Dynamic
<pkgCache::VerIterator
> DynVer(Ver
);
293 if (List
.UsePackage(Pkg
, Ver
) == false)
294 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
295 Pkg
.Name(), "UsePackage", 1);
297 // Find the right version to write the description
298 MD5SumValue CurMd5
= List
.Description_md5();
299 std::string CurLang
= List
.DescriptionLanguage();
301 for (Ver
= Pkg
.VersionList(); Ver
.end() == false; ++Ver
)
303 pkgCache::DescIterator VerDesc
= Ver
.DescriptionList();
305 // a version can only have one md5 describing it
306 if (VerDesc
.end() == true || MD5SumValue(VerDesc
.md5()) != CurMd5
)
309 // don't add a new description if we have one for the given
311 if (IsDuplicateDescription(VerDesc
, CurMd5
, CurLang
) == true)
314 pkgCache::DescIterator Desc
;
315 Dynamic
<pkgCache::DescIterator
> DynDesc(Desc
);
317 map_ptrloc
const descindex
= NewDescription(Desc
, CurLang
, CurMd5
, VerDesc
->md5sum
);
318 if (unlikely(descindex
== 0 && _error
->PendingError()))
319 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
320 Pkg
.Name(), "NewDescription", 1);
322 Desc
->ParentPkg
= Pkg
.Index();
324 // we add at the end, so that the start is constant as we need
325 // that to be able to efficiently share these lists
326 VerDesc
= Ver
.DescriptionList(); // old value might be invalid after ReMap
327 for (;VerDesc
.end() == false && VerDesc
->NextDesc
!= 0; ++VerDesc
);
328 map_ptrloc
* const LastNextDesc
= (VerDesc
.end() == true) ? &Ver
->DescriptionList
: &VerDesc
->NextDesc
;
329 *LastNextDesc
= descindex
;
331 if (NewFileDesc(Desc
,List
) == false)
332 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
333 Pkg
.Name(), "NewFileDesc", 1);
335 // we can stop here as all "same" versions will share the description
342 // CacheGenerator::MergeListVersion /*{{{*/
343 bool pkgCacheGenerator::MergeListVersion(ListParser
&List
, pkgCache::PkgIterator
&Pkg
,
344 std::string
const &Version
, pkgCache::VerIterator
* &OutVer
)
346 pkgCache::VerIterator Ver
= Pkg
.VersionList();
347 Dynamic
<pkgCache::VerIterator
> DynVer(Ver
);
348 map_ptrloc
*LastVer
= &Pkg
->VersionList
;
349 void const * oldMap
= Map
.Data();
351 unsigned long const Hash
= List
.VersionHash();
352 if (Ver
.end() == false)
354 /* We know the list is sorted so we use that fact in the search.
355 Insertion of new versions is done with correct sorting */
357 for (; Ver
.end() == false; LastVer
= &Ver
->NextVer
, Ver
++)
359 Res
= Cache
.VS
->CmpVersion(Version
,Ver
.VerStr());
360 // Version is higher as current version - insert here
363 // Versionstrings are equal - is hash also equal?
364 if (Res
== 0 && Ver
->Hash
== Hash
)
366 // proceed with the next till we have either the right
367 // or we found another version (which will be lower)
370 /* We already have a version for this item, record that we saw it */
371 if (Res
== 0 && Ver
.end() == false && Ver
->Hash
== Hash
)
373 if (List
.UsePackage(Pkg
,Ver
) == false)
374 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
375 Pkg
.Name(), "UsePackage", 2);
377 if (NewFileVer(Ver
,List
) == false)
378 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
379 Pkg
.Name(), "NewFileVer", 1);
381 // Read only a single record and return
393 map_ptrloc
const verindex
= NewVersion(Ver
,Version
,*LastVer
);
394 if (verindex
== 0 && _error
->PendingError())
395 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
396 Pkg
.Name(), "NewVersion", 1);
398 if (oldMap
!= Map
.Data())
399 LastVer
+= (map_ptrloc
*) Map
.Data() - (map_ptrloc
*) oldMap
;
401 Ver
->ParentPkg
= Pkg
.Index();
404 if (unlikely(List
.NewVersion(Ver
) == false))
405 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
406 Pkg
.Name(), "NewVersion", 2);
408 if (unlikely(List
.UsePackage(Pkg
,Ver
) == false))
409 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
410 Pkg
.Name(), "UsePackage", 3);
412 if (unlikely(NewFileVer(Ver
,List
) == false))
413 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
414 Pkg
.Name(), "NewFileVer", 2);
416 pkgCache::GrpIterator Grp
= Pkg
.Group();
417 Dynamic
<pkgCache::GrpIterator
> DynGrp(Grp
);
419 /* If it is the first version of this package we need to add implicit
420 Multi-Arch dependencies to all other package versions in the group now -
421 otherwise we just add them for this new version */
422 if (Pkg
.VersionList()->NextVer
== 0)
424 pkgCache::PkgIterator P
= Grp
.PackageList();
425 Dynamic
<pkgCache::PkgIterator
> DynP(P
);
426 for (; P
.end() != true; P
= Grp
.NextPkg(P
))
428 if (P
->ID
== Pkg
->ID
)
430 pkgCache::VerIterator V
= P
.VersionList();
431 Dynamic
<pkgCache::VerIterator
> DynV(V
);
432 for (; V
.end() != true; ++V
)
433 if (unlikely(AddImplicitDepends(V
, Pkg
) == false))
434 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
435 Pkg
.Name(), "AddImplicitDepends", 1);
437 /* :none packages are packages without an architecture. They are forbidden by
438 debian-policy, so usually they will only be in (old) dpkg status files -
439 and dpkg will complain about them - and are pretty rare. We therefore do
440 usually not create conflicts while the parent is created, but only if a :none
441 package (= the target) appears. This creates incorrect dependencies on :none
442 for architecture-specific dependencies on the package we copy from, but we
443 will ignore this bug as architecture-specific dependencies are only allowed
444 in jessie and until then the :none packages should be extinct (hopefully).
445 In other words: This should work long enough to allow graceful removal of
446 these packages, it is not supposed to allow users to keep using them … */
447 if (strcmp(Pkg
.Arch(), "none") == 0)
449 pkgCache::PkgIterator M
= Grp
.FindPreferredPkg();
450 if (M
.end() == false && Pkg
!= M
)
452 pkgCache::DepIterator D
= M
.RevDependsList();
453 Dynamic
<pkgCache::DepIterator
> DynD(D
);
454 for (; D
.end() == false; ++D
)
456 if ((D
->Type
!= pkgCache::Dep::Conflicts
&&
457 D
->Type
!= pkgCache::Dep::DpkgBreaks
&&
458 D
->Type
!= pkgCache::Dep::Replaces
) ||
459 D
.ParentPkg().Group() == Grp
)
462 map_ptrloc
*OldDepLast
= NULL
;
463 pkgCache::VerIterator ConVersion
= D
.ParentVer();
464 Dynamic
<pkgCache::VerIterator
> DynV(ConVersion
);
465 // duplicate the Conflicts/Breaks/Replaces for :none arch
466 NewDepends(Pkg
, ConVersion
, D
->Version
,
467 D
->CompareOp
, D
->Type
, OldDepLast
);
472 if (unlikely(AddImplicitDepends(Grp
, Pkg
, Ver
) == false))
473 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
474 Pkg
.Name(), "AddImplicitDepends", 2);
476 // Read only a single record and return
483 /* Record the Description (it is not translated) */
484 MD5SumValue CurMd5
= List
.Description_md5();
485 if (CurMd5
.Value().empty() == true)
487 std::string CurLang
= List
.DescriptionLanguage();
489 /* Before we add a new description we first search in the group for
490 a version with a description of the same MD5 - if so we reuse this
491 description group instead of creating our own for this version */
492 for (pkgCache::PkgIterator P
= Grp
.PackageList();
493 P
.end() == false; P
= Grp
.NextPkg(P
))
495 for (pkgCache::VerIterator V
= P
.VersionList();
496 V
.end() == false; ++V
)
498 if (IsDuplicateDescription(V
.DescriptionList(), CurMd5
, "") == false)
500 Ver
->DescriptionList
= V
->DescriptionList
;
505 // We haven't found reusable descriptions, so add the first description
506 pkgCache::DescIterator Desc
= Ver
.DescriptionList();
507 Dynamic
<pkgCache::DescIterator
> DynDesc(Desc
);
509 map_ptrloc
const descindex
= NewDescription(Desc
, CurLang
, CurMd5
, 0);
510 if (unlikely(descindex
== 0 && _error
->PendingError()))
511 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
512 Pkg
.Name(), "NewDescription", 2);
514 Desc
->ParentPkg
= Pkg
.Index();
515 Ver
->DescriptionList
= descindex
;
517 if (NewFileDesc(Desc
,List
) == false)
518 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
519 Pkg
.Name(), "NewFileDesc", 2);
525 // CacheGenerator::MergeFileProvides - Merge file provides /*{{{*/
526 // ---------------------------------------------------------------------
527 /* If we found any file depends while parsing the main list we need to
528 resolve them. Since it is undesired to load the entire list of files
529 into the cache as virtual packages we do a two stage effort. MergeList
530 identifies the file depends and this creates Provdies for them by
531 re-parsing all the indexs. */
532 bool pkgCacheGenerator::MergeFileProvides(ListParser
&List
)
536 unsigned int Counter
= 0;
537 while (List
.Step() == true)
539 string PackageName
= List
.Package();
540 if (PackageName
.empty() == true)
542 string Version
= List
.Version();
543 if (Version
.empty() == true)
546 pkgCache::PkgIterator Pkg
= Cache
.FindPkg(PackageName
);
547 Dynamic
<pkgCache::PkgIterator
> DynPkg(Pkg
);
548 if (Pkg
.end() == true)
549 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
550 PackageName
.c_str(), "FindPkg", 1);
552 if (Counter
% 100 == 0 && Progress
!= 0)
553 Progress
->Progress(List
.Offset());
555 unsigned long Hash
= List
.VersionHash();
556 pkgCache::VerIterator Ver
= Pkg
.VersionList();
557 Dynamic
<pkgCache::VerIterator
> DynVer(Ver
);
558 for (; Ver
.end() == false; ++Ver
)
560 if (Ver
->Hash
== Hash
&& Version
.c_str() == Ver
.VerStr())
562 if (List
.CollectFileProvides(Cache
,Ver
) == false)
563 return _error
->Error(_("Error occurred while processing %s (%s%d)"),
564 PackageName
.c_str(), "CollectFileProvides", 1);
569 if (Ver
.end() == true)
570 _error
->Warning(_("Package %s %s was not found while processing file dependencies"),PackageName
.c_str(),Version
.c_str());
576 // CacheGenerator::NewGroup - Add a new group /*{{{*/
577 // ---------------------------------------------------------------------
578 /* This creates a new group structure and adds it to the hash table */
579 bool pkgCacheGenerator::NewGroup(pkgCache::GrpIterator
&Grp
, const string
&Name
)
581 Grp
= Cache
.FindGrp(Name
);
582 if (Grp
.end() == false)
586 map_ptrloc
const Group
= AllocateInMap(sizeof(pkgCache::Group
));
587 if (unlikely(Group
== 0))
590 Grp
= pkgCache::GrpIterator(Cache
, Cache
.GrpP
+ Group
);
591 map_ptrloc
const idxName
= WriteStringInMap(Name
);
592 if (unlikely(idxName
== 0))
596 // Insert it into the hash table
597 unsigned long const Hash
= Cache
.Hash(Name
);
598 Grp
->Next
= Cache
.HeaderP
->GrpHashTable
[Hash
];
599 Cache
.HeaderP
->GrpHashTable
[Hash
] = Group
;
601 Grp
->ID
= Cache
.HeaderP
->GroupCount
++;
605 // CacheGenerator::NewPackage - Add a new package /*{{{*/
606 // ---------------------------------------------------------------------
607 /* This creates a new package structure and adds it to the hash table */
608 bool pkgCacheGenerator::NewPackage(pkgCache::PkgIterator
&Pkg
,const string
&Name
,
609 const string
&Arch
) {
610 pkgCache::GrpIterator Grp
;
611 Dynamic
<pkgCache::GrpIterator
> DynGrp(Grp
);
612 if (unlikely(NewGroup(Grp
, Name
) == false))
615 Pkg
= Grp
.FindPkg(Arch
);
616 if (Pkg
.end() == false)
620 map_ptrloc
const Package
= AllocateInMap(sizeof(pkgCache::Package
));
621 if (unlikely(Package
== 0))
623 Pkg
= pkgCache::PkgIterator(Cache
,Cache
.PkgP
+ Package
);
625 // Insert the package into our package list
626 if (Grp
->FirstPackage
== 0) // the group is new
628 // Insert it into the hash table
629 unsigned long const Hash
= Cache
.Hash(Name
);
630 Pkg
->NextPackage
= Cache
.HeaderP
->PkgHashTable
[Hash
];
631 Cache
.HeaderP
->PkgHashTable
[Hash
] = Package
;
632 Grp
->FirstPackage
= Package
;
634 else // Group the Packages together
636 // this package is the new last package
637 pkgCache::PkgIterator
LastPkg(Cache
, Cache
.PkgP
+ Grp
->LastPackage
);
638 Pkg
->NextPackage
= LastPkg
->NextPackage
;
639 LastPkg
->NextPackage
= Package
;
641 Grp
->LastPackage
= Package
;
643 // Set the name, arch and the ID
644 Pkg
->Name
= Grp
->Name
;
645 Pkg
->Group
= Grp
.Index();
646 // all is mapped to the native architecture
647 map_ptrloc
const idxArch
= (Arch
== "all") ? Cache
.HeaderP
->Architecture
: WriteUniqString(Arch
.c_str());
648 if (unlikely(idxArch
== 0))
651 Pkg
->ID
= Cache
.HeaderP
->PackageCount
++;
656 // CacheGenerator::AddImplicitDepends /*{{{*/
657 bool pkgCacheGenerator::AddImplicitDepends(pkgCache::GrpIterator
&G
,
658 pkgCache::PkgIterator
&P
,
659 pkgCache::VerIterator
&V
)
661 // copy P.Arch() into a string here as a cache remap
662 // in NewDepends() later may alter the pointer location
663 string Arch
= P
.Arch() == NULL
? "" : P
.Arch();
664 map_ptrloc
*OldDepLast
= NULL
;
665 /* MultiArch handling introduces a lot of implicit Dependencies:
666 - MultiArch: same → Co-Installable if they have the same version
667 - All others conflict with all other group members */
668 bool const coInstall
= ((V
->MultiArch
& pkgCache::Version::Same
) == pkgCache::Version::Same
);
669 pkgCache::PkgIterator D
= G
.PackageList();
670 Dynamic
<pkgCache::PkgIterator
> DynD(D
);
671 map_ptrloc
const VerStrIdx
= V
->VerStr
;
672 for (; D
.end() != true; D
= G
.NextPkg(D
))
674 if (Arch
== D
.Arch() || D
->VersionList
== 0)
676 /* We allow only one installed arch at the time
677 per group, therefore each group member conflicts
678 with all other group members */
679 if (coInstall
== true)
681 // Replaces: ${self}:other ( << ${binary:Version})
682 NewDepends(D
, V
, VerStrIdx
,
683 pkgCache::Dep::Less
, pkgCache::Dep::Replaces
,
685 // Breaks: ${self}:other (!= ${binary:Version})
686 NewDepends(D
, V
, VerStrIdx
,
687 pkgCache::Dep::NotEquals
, pkgCache::Dep::DpkgBreaks
,
690 // Conflicts: ${self}:other
692 pkgCache::Dep::NoOp
, pkgCache::Dep::Conflicts
,
698 bool pkgCacheGenerator::AddImplicitDepends(pkgCache::VerIterator
&V
,
699 pkgCache::PkgIterator
&D
)
701 /* MultiArch handling introduces a lot of implicit Dependencies:
702 - MultiArch: same → Co-Installable if they have the same version
703 - All others conflict with all other group members */
704 map_ptrloc
*OldDepLast
= NULL
;
705 bool const coInstall
= ((V
->MultiArch
& pkgCache::Version::Same
) == pkgCache::Version::Same
);
706 if (coInstall
== true)
708 map_ptrloc
const VerStrIdx
= V
->VerStr
;
709 // Replaces: ${self}:other ( << ${binary:Version})
710 NewDepends(D
, V
, VerStrIdx
,
711 pkgCache::Dep::Less
, pkgCache::Dep::Replaces
,
713 // Breaks: ${self}:other (!= ${binary:Version})
714 NewDepends(D
, V
, VerStrIdx
,
715 pkgCache::Dep::NotEquals
, pkgCache::Dep::DpkgBreaks
,
718 // Conflicts: ${self}:other
720 pkgCache::Dep::NoOp
, pkgCache::Dep::Conflicts
,
727 // CacheGenerator::NewFileVer - Create a new File<->Version association /*{{{*/
728 // ---------------------------------------------------------------------
730 bool pkgCacheGenerator::NewFileVer(pkgCache::VerIterator
&Ver
,
733 if (CurrentFile
== 0)
737 map_ptrloc
const VerFile
= AllocateInMap(sizeof(pkgCache::VerFile
));
741 pkgCache::VerFileIterator
VF(Cache
,Cache
.VerFileP
+ VerFile
);
742 VF
->File
= CurrentFile
- Cache
.PkgFileP
;
744 // Link it to the end of the list
745 map_ptrloc
*Last
= &Ver
->FileList
;
746 for (pkgCache::VerFileIterator V
= Ver
.FileList(); V
.end() == false; ++V
)
748 VF
->NextFile
= *Last
;
751 VF
->Offset
= List
.Offset();
752 VF
->Size
= List
.Size();
753 if (Cache
.HeaderP
->MaxVerFileSize
< VF
->Size
)
754 Cache
.HeaderP
->MaxVerFileSize
= VF
->Size
;
755 Cache
.HeaderP
->VerFileCount
++;
760 // CacheGenerator::NewVersion - Create a new Version /*{{{*/
761 // ---------------------------------------------------------------------
762 /* This puts a version structure in the linked list */
763 unsigned long pkgCacheGenerator::NewVersion(pkgCache::VerIterator
&Ver
,
764 const string
&VerStr
,
768 map_ptrloc
const Version
= AllocateInMap(sizeof(pkgCache::Version
));
773 Ver
= pkgCache::VerIterator(Cache
,Cache
.VerP
+ Version
);
774 //Dynamic<pkgCache::VerIterator> DynV(Ver); // caller MergeListVersion already takes care of it
776 Ver
->ID
= Cache
.HeaderP
->VersionCount
++;
777 map_ptrloc
const idxVerStr
= WriteStringInMap(VerStr
);
778 if (unlikely(idxVerStr
== 0))
780 Ver
->VerStr
= idxVerStr
;
785 // CacheGenerator::NewFileDesc - Create a new File<->Desc association /*{{{*/
786 // ---------------------------------------------------------------------
788 bool pkgCacheGenerator::NewFileDesc(pkgCache::DescIterator
&Desc
,
791 if (CurrentFile
== 0)
795 map_ptrloc
const DescFile
= AllocateInMap(sizeof(pkgCache::DescFile
));
799 pkgCache::DescFileIterator
DF(Cache
,Cache
.DescFileP
+ DescFile
);
800 DF
->File
= CurrentFile
- Cache
.PkgFileP
;
802 // Link it to the end of the list
803 map_ptrloc
*Last
= &Desc
->FileList
;
804 for (pkgCache::DescFileIterator D
= Desc
.FileList(); D
.end() == false; ++D
)
807 DF
->NextFile
= *Last
;
810 DF
->Offset
= List
.Offset();
811 DF
->Size
= List
.Size();
812 if (Cache
.HeaderP
->MaxDescFileSize
< DF
->Size
)
813 Cache
.HeaderP
->MaxDescFileSize
= DF
->Size
;
814 Cache
.HeaderP
->DescFileCount
++;
819 // CacheGenerator::NewDescription - Create a new Description /*{{{*/
820 // ---------------------------------------------------------------------
821 /* This puts a description structure in the linked list */
822 map_ptrloc
pkgCacheGenerator::NewDescription(pkgCache::DescIterator
&Desc
,
824 const MD5SumValue
&md5sum
,
825 map_ptrloc idxmd5str
)
828 map_ptrloc
const Description
= AllocateInMap(sizeof(pkgCache::Description
));
829 if (Description
== 0)
833 Desc
= pkgCache::DescIterator(Cache
,Cache
.DescP
+ Description
);
834 Desc
->ID
= Cache
.HeaderP
->DescriptionCount
++;
835 map_ptrloc
const idxlanguage_code
= WriteUniqString(Lang
);
836 if (unlikely(idxlanguage_code
== 0))
838 Desc
->language_code
= idxlanguage_code
;
841 Desc
->md5sum
= idxmd5str
;
844 map_ptrloc
const idxmd5sum
= WriteStringInMap(md5sum
.Value());
845 if (unlikely(idxmd5sum
== 0))
847 Desc
->md5sum
= idxmd5sum
;
853 // CacheGenerator::NewDepends - Create a dependency element /*{{{*/
854 // ---------------------------------------------------------------------
855 /* This creates a dependency element in the tree. It is linked to the
856 version and to the package that it is pointing to. */
857 bool pkgCacheGenerator::NewDepends(pkgCache::PkgIterator
&Pkg
,
858 pkgCache::VerIterator
&Ver
,
859 string
const &Version
,
860 unsigned int const &Op
,
861 unsigned int const &Type
,
862 map_ptrloc
* &OldDepLast
)
864 map_ptrloc index
= 0;
865 if (Version
.empty() == false)
867 int const CmpOp
= Op
& 0x0F;
868 // =-deps are used (79:1) for lockstep on same-source packages (e.g. data-packages)
869 if (CmpOp
== pkgCache::Dep::Equals
&& strcmp(Version
.c_str(), Ver
.VerStr()) == 0)
874 void const * const oldMap
= Map
.Data();
875 index
= WriteStringInMap(Version
);
876 if (unlikely(index
== 0))
878 if (oldMap
!= Map
.Data())
879 OldDepLast
+= (map_ptrloc
*) Map
.Data() - (map_ptrloc
*) oldMap
;
882 return NewDepends(Pkg
, Ver
, index
, Op
, Type
, OldDepLast
);
884 bool pkgCacheGenerator::NewDepends(pkgCache::PkgIterator
&Pkg
,
885 pkgCache::VerIterator
&Ver
,
886 map_ptrloc
const Version
,
887 unsigned int const &Op
,
888 unsigned int const &Type
,
889 map_ptrloc
* &OldDepLast
)
891 void const * const oldMap
= Map
.Data();
893 map_ptrloc
const Dependency
= AllocateInMap(sizeof(pkgCache::Dependency
));
894 if (unlikely(Dependency
== 0))
898 pkgCache::DepIterator
Dep(Cache
,Cache
.DepP
+ Dependency
);
899 Dynamic
<pkgCache::DepIterator
> DynDep(Dep
);
900 Dep
->ParentVer
= Ver
.Index();
903 Dep
->Version
= Version
;
904 Dep
->ID
= Cache
.HeaderP
->DependsCount
++;
906 // Link it to the package
907 Dep
->Package
= Pkg
.Index();
908 Dep
->NextRevDepends
= Pkg
->RevDepends
;
909 Pkg
->RevDepends
= Dep
.Index();
911 // Do we know where to link the Dependency to?
912 if (OldDepLast
== NULL
)
914 OldDepLast
= &Ver
->DependsList
;
915 for (pkgCache::DepIterator D
= Ver
.DependsList(); D
.end() == false; ++D
)
916 OldDepLast
= &D
->NextDepends
;
917 } else if (oldMap
!= Map
.Data())
918 OldDepLast
+= (map_ptrloc
*) Map
.Data() - (map_ptrloc
*) oldMap
;
920 Dep
->NextDepends
= *OldDepLast
;
921 *OldDepLast
= Dep
.Index();
922 OldDepLast
= &Dep
->NextDepends
;
927 // ListParser::NewDepends - Create the environment for a new dependency /*{{{*/
928 // ---------------------------------------------------------------------
929 /* This creates a Group and the Package to link this dependency to if
930 needed and handles also the caching of the old endpoint */
931 bool pkgCacheGenerator::ListParser::NewDepends(pkgCache::VerIterator
&Ver
,
932 const string
&PackageName
,
934 const string
&Version
,
938 pkgCache::GrpIterator Grp
;
939 Dynamic
<pkgCache::GrpIterator
> DynGrp(Grp
);
940 if (unlikely(Owner
->NewGroup(Grp
, PackageName
) == false))
943 // Locate the target package
944 pkgCache::PkgIterator Pkg
= Grp
.FindPkg(Arch
);
945 // we don't create 'none' packages and their dependencies if we can avoid it …
946 if (Pkg
.end() == true && Arch
== "none" && strcmp(Ver
.ParentPkg().Arch(), "none") != 0)
948 Dynamic
<pkgCache::PkgIterator
> DynPkg(Pkg
);
949 if (Pkg
.end() == true) {
950 if (unlikely(Owner
->NewPackage(Pkg
, PackageName
, Arch
) == false))
954 // Is it a file dependency?
955 if (unlikely(PackageName
[0] == '/'))
956 FoundFileDeps
= true;
958 /* Caching the old end point speeds up generation substantially */
959 if (OldDepVer
!= Ver
) {
964 return Owner
->NewDepends(Pkg
, Ver
, Version
, Op
, Type
, OldDepLast
);
967 // ListParser::NewProvides - Create a Provides element /*{{{*/
968 // ---------------------------------------------------------------------
970 bool pkgCacheGenerator::ListParser::NewProvides(pkgCache::VerIterator
&Ver
,
971 const string
&PkgName
,
972 const string
&PkgArch
,
973 const string
&Version
)
975 pkgCache
&Cache
= Owner
->Cache
;
977 // We do not add self referencing provides
978 if (Ver
.ParentPkg().Name() == PkgName
&& (PkgArch
== Ver
.ParentPkg().Arch() ||
979 (PkgArch
== "all" && strcmp((Cache
.StrP
+ Cache
.HeaderP
->Architecture
), Ver
.ParentPkg().Arch()) == 0)))
983 map_ptrloc
const Provides
= Owner
->AllocateInMap(sizeof(pkgCache::Provides
));
984 if (unlikely(Provides
== 0))
986 Cache
.HeaderP
->ProvidesCount
++;
989 pkgCache::PrvIterator
Prv(Cache
,Cache
.ProvideP
+ Provides
,Cache
.PkgP
);
990 Dynamic
<pkgCache::PrvIterator
> DynPrv(Prv
);
991 Prv
->Version
= Ver
.Index();
992 Prv
->NextPkgProv
= Ver
->ProvidesList
;
993 Ver
->ProvidesList
= Prv
.Index();
994 if (Version
.empty() == false) {
995 map_ptrloc
const idxProvideVersion
= WriteString(Version
);
996 Prv
->ProvideVersion
= idxProvideVersion
;
997 if (unlikely(idxProvideVersion
== 0))
1001 // Locate the target package
1002 pkgCache::PkgIterator Pkg
;
1003 Dynamic
<pkgCache::PkgIterator
> DynPkg(Pkg
);
1004 if (unlikely(Owner
->NewPackage(Pkg
,PkgName
, PkgArch
) == false))
1007 // Link it to the package
1008 Prv
->ParentPkg
= Pkg
.Index();
1009 Prv
->NextProvides
= Pkg
->ProvidesList
;
1010 Pkg
->ProvidesList
= Prv
.Index();
1015 // CacheGenerator::SelectFile - Select the current file being parsed /*{{{*/
1016 // ---------------------------------------------------------------------
1017 /* This is used to select which file is to be associated with all newly
1018 added versions. The caller is responsible for setting the IMS fields. */
1019 bool pkgCacheGenerator::SelectFile(const string
&File
,const string
&Site
,
1020 const pkgIndexFile
&Index
,
1021 unsigned long Flags
)
1023 // Get some space for the structure
1024 map_ptrloc
const idxFile
= AllocateInMap(sizeof(*CurrentFile
));
1025 if (unlikely(idxFile
== 0))
1027 CurrentFile
= Cache
.PkgFileP
+ idxFile
;
1030 map_ptrloc
const idxFileName
= WriteStringInMap(File
);
1031 map_ptrloc
const idxSite
= WriteUniqString(Site
);
1032 if (unlikely(idxFileName
== 0 || idxSite
== 0))
1034 CurrentFile
->FileName
= idxFileName
;
1035 CurrentFile
->Site
= idxSite
;
1036 CurrentFile
->NextFile
= Cache
.HeaderP
->FileList
;
1037 CurrentFile
->Flags
= Flags
;
1038 CurrentFile
->ID
= Cache
.HeaderP
->PackageFileCount
;
1039 map_ptrloc
const idxIndexType
= WriteUniqString(Index
.GetType()->Label
);
1040 if (unlikely(idxIndexType
== 0))
1042 CurrentFile
->IndexType
= idxIndexType
;
1044 Cache
.HeaderP
->FileList
= CurrentFile
- Cache
.PkgFileP
;
1045 Cache
.HeaderP
->PackageFileCount
++;
1048 Progress
->SubProgress(Index
.Size());
1052 // CacheGenerator::WriteUniqueString - Insert a unique string /*{{{*/
1053 // ---------------------------------------------------------------------
1054 /* This is used to create handles to strings. Given the same text it
1055 always returns the same number */
1056 unsigned long pkgCacheGenerator::WriteUniqString(const char *S
,
1059 /* We use a very small transient hash table here, this speeds up generation
1060 by a fair amount on slower machines */
1061 pkgCache::StringItem
*&Bucket
= UniqHash
[(S
[0]*5 + S
[1]) % _count(UniqHash
)];
1063 stringcmp(S
,S
+Size
,Cache
.StrP
+ Bucket
->String
) == 0)
1064 return Bucket
->String
;
1066 // Search for an insertion point
1067 pkgCache::StringItem
*I
= Cache
.StringItemP
+ Cache
.HeaderP
->StringList
;
1069 map_ptrloc
*Last
= &Cache
.HeaderP
->StringList
;
1070 for (; I
!= Cache
.StringItemP
; Last
= &I
->NextItem
,
1071 I
= Cache
.StringItemP
+ I
->NextItem
)
1073 Res
= stringcmp(S
,S
+Size
,Cache
.StrP
+ I
->String
);
1086 void const * const oldMap
= Map
.Data();
1087 map_ptrloc
const Item
= AllocateInMap(sizeof(pkgCache::StringItem
));
1091 map_ptrloc
const idxString
= WriteStringInMap(S
,Size
);
1092 if (unlikely(idxString
== 0))
1094 if (oldMap
!= Map
.Data()) {
1095 Last
+= (map_ptrloc
*) Map
.Data() - (map_ptrloc
*) oldMap
;
1096 I
+= (pkgCache::StringItem
*) Map
.Data() - (pkgCache::StringItem
*) oldMap
;
1100 // Fill in the structure
1101 pkgCache::StringItem
*ItemP
= Cache
.StringItemP
+ Item
;
1102 ItemP
->NextItem
= I
- Cache
.StringItemP
;
1103 ItemP
->String
= idxString
;
1106 return ItemP
->String
;
1109 // CheckValidity - Check that a cache is up-to-date /*{{{*/
1110 // ---------------------------------------------------------------------
1111 /* This just verifies that each file in the list of index files exists,
1112 has matching attributes with the cache and the cache does not have
1114 static bool CheckValidity(const string
&CacheFile
,
1115 pkgSourceList
&List
,
1120 bool const Debug
= _config
->FindB("Debug::pkgCacheGen", false);
1121 // No file, certainly invalid
1122 if (CacheFile
.empty() == true || FileExists(CacheFile
) == false)
1125 std::clog
<< "CacheFile doesn't exist" << std::endl
;
1129 if (List
.GetLastModifiedTime() > GetModificationTime(CacheFile
))
1132 std::clog
<< "sources.list is newer than the cache" << std::endl
;
1137 FileFd
CacheF(CacheFile
,FileFd::ReadOnly
);
1138 SPtr
<MMap
> Map
= new MMap(CacheF
,0);
1139 pkgCache
Cache(Map
);
1140 if (_error
->PendingError() == true || Map
->Size() == 0)
1143 std::clog
<< "Errors are pending or Map is empty()" << std::endl
;
1148 /* Now we check every index file, see if it is in the cache,
1149 verify the IMS data and check that it is on the disk too.. */
1150 SPtrArray
<bool> Visited
= new bool[Cache
.HeaderP
->PackageFileCount
];
1151 memset(Visited
,0,sizeof(*Visited
)*Cache
.HeaderP
->PackageFileCount
);
1152 for (; Start
!= End
; ++Start
)
1155 std::clog
<< "Checking PkgFile " << (*Start
)->Describe() << ": ";
1156 if ((*Start
)->HasPackages() == false)
1159 std::clog
<< "Has NO packages" << std::endl
;
1163 if ((*Start
)->Exists() == false)
1165 #if 0 // mvo: we no longer give a message here (Default Sources spec)
1166 _error
->WarningE("stat",_("Couldn't stat source package list %s"),
1167 (*Start
)->Describe().c_str());
1170 std::clog
<< "file doesn't exist" << std::endl
;
1174 // FindInCache is also expected to do an IMS check.
1175 pkgCache::PkgFileIterator File
= (*Start
)->FindInCache(Cache
);
1176 if (File
.end() == true)
1179 std::clog
<< "FindInCache returned end-Pointer" << std::endl
;
1183 Visited
[File
->ID
] = true;
1185 std::clog
<< "with ID " << File
->ID
<< " is valid" << std::endl
;
1188 for (unsigned I
= 0; I
!= Cache
.HeaderP
->PackageFileCount
; I
++)
1189 if (Visited
[I
] == false)
1192 std::clog
<< "File with ID" << I
<< " wasn't visited" << std::endl
;
1196 if (_error
->PendingError() == true)
1200 std::clog
<< "Validity failed because of pending errors:" << std::endl
;
1201 _error
->DumpErrors();
1208 *OutMap
= Map
.UnGuard();
1212 // ComputeSize - Compute the total size of a bunch of files /*{{{*/
1213 // ---------------------------------------------------------------------
1214 /* Size is kind of an abstract notion that is only used for the progress
1216 static unsigned long ComputeSize(FileIterator Start
,FileIterator End
)
1218 unsigned long TotalSize
= 0;
1219 for (; Start
!= End
; ++Start
)
1221 if ((*Start
)->HasPackages() == false)
1223 TotalSize
+= (*Start
)->Size();
1228 // BuildCache - Merge the list of index files into the cache /*{{{*/
1229 // ---------------------------------------------------------------------
1231 static bool BuildCache(pkgCacheGenerator
&Gen
,
1232 OpProgress
*Progress
,
1233 unsigned long &CurrentSize
,unsigned long TotalSize
,
1234 FileIterator Start
, FileIterator End
)
1237 for (I
= Start
; I
!= End
; ++I
)
1239 if ((*I
)->HasPackages() == false)
1242 if ((*I
)->Exists() == false)
1245 if ((*I
)->FindInCache(Gen
.GetCache()).end() == false)
1247 _error
->Warning("Duplicate sources.list entry %s",
1248 (*I
)->Describe().c_str());
1252 unsigned long Size
= (*I
)->Size();
1253 if (Progress
!= NULL
)
1254 Progress
->OverallProgress(CurrentSize
,TotalSize
,Size
,_("Reading package lists"));
1255 CurrentSize
+= Size
;
1257 if ((*I
)->Merge(Gen
,Progress
) == false)
1261 if (Gen
.HasFileDeps() == true)
1263 if (Progress
!= NULL
)
1265 TotalSize
= ComputeSize(Start
, End
);
1267 for (I
= Start
; I
!= End
; ++I
)
1269 unsigned long Size
= (*I
)->Size();
1270 if (Progress
!= NULL
)
1271 Progress
->OverallProgress(CurrentSize
,TotalSize
,Size
,_("Collecting File Provides"));
1272 CurrentSize
+= Size
;
1273 if ((*I
)->MergeFileProvides(Gen
,Progress
) == false)
1281 // CacheGenerator::CreateDynamicMMap - load an mmap with configuration options /*{{{*/
1282 DynamicMMap
* pkgCacheGenerator::CreateDynamicMMap(FileFd
*CacheF
, unsigned long Flags
) {
1283 unsigned long const MapStart
= _config
->FindI("APT::Cache-Start", 24*1024*1024);
1284 unsigned long const MapGrow
= _config
->FindI("APT::Cache-Grow", 1*1024*1024);
1285 unsigned long const MapLimit
= _config
->FindI("APT::Cache-Limit", 0);
1286 Flags
|= MMap::Moveable
;
1287 if (_config
->FindB("APT::Cache-Fallback", false) == true)
1288 Flags
|= MMap::Fallback
;
1290 return new DynamicMMap(*CacheF
, Flags
, MapStart
, MapGrow
, MapLimit
);
1292 return new DynamicMMap(Flags
, MapStart
, MapGrow
, MapLimit
);
1295 // CacheGenerator::MakeStatusCache - Construct the status cache /*{{{*/
1296 // ---------------------------------------------------------------------
1297 /* This makes sure that the status cache (the cache that has all
1298 index files from the sources list and all local ones) is ready
1299 to be mmaped. If OutMap is not zero then a MMap object representing
1300 the cache will be stored there. This is pretty much mandetory if you
1301 are using AllowMem. AllowMem lets the function be run as non-root
1302 where it builds the cache 'fast' into a memory buffer. */
1303 __deprecated
bool pkgMakeStatusCache(pkgSourceList
&List
,OpProgress
&Progress
,
1304 MMap
**OutMap
, bool AllowMem
)
1305 { return pkgCacheGenerator::MakeStatusCache(List
, &Progress
, OutMap
, AllowMem
); }
1306 bool pkgCacheGenerator::MakeStatusCache(pkgSourceList
&List
,OpProgress
*Progress
,
1307 MMap
**OutMap
,bool AllowMem
)
1309 bool const Debug
= _config
->FindB("Debug::pkgCacheGen", false);
1311 std::vector
<pkgIndexFile
*> Files
;
1312 for (std::vector
<metaIndex
*>::const_iterator i
= List
.begin();
1316 std::vector
<pkgIndexFile
*> *Indexes
= (*i
)->GetIndexFiles();
1317 for (std::vector
<pkgIndexFile
*>::const_iterator j
= Indexes
->begin();
1318 j
!= Indexes
->end();
1320 Files
.push_back (*j
);
1323 unsigned long const EndOfSource
= Files
.size();
1324 if (_system
->AddStatusFiles(Files
) == false)
1327 // Decide if we can write to the files..
1328 string
const CacheFile
= _config
->FindFile("Dir::Cache::pkgcache");
1329 string
const SrcCacheFile
= _config
->FindFile("Dir::Cache::srcpkgcache");
1331 // ensure the cache directory exists
1332 if (CacheFile
.empty() == false || SrcCacheFile
.empty() == false)
1334 string dir
= _config
->FindDir("Dir::Cache");
1335 size_t const len
= dir
.size();
1336 if (len
> 5 && dir
.find("/apt/", len
- 6, 5) == len
- 5)
1337 dir
= dir
.substr(0, len
- 5);
1338 if (CacheFile
.empty() == false)
1339 CreateDirectory(dir
, flNotFile(CacheFile
));
1340 if (SrcCacheFile
.empty() == false)
1341 CreateDirectory(dir
, flNotFile(SrcCacheFile
));
1344 // Decide if we can write to the cache
1345 bool Writeable
= false;
1346 if (CacheFile
.empty() == false)
1347 Writeable
= access(flNotFile(CacheFile
).c_str(),W_OK
) == 0;
1349 if (SrcCacheFile
.empty() == false)
1350 Writeable
= access(flNotFile(SrcCacheFile
).c_str(),W_OK
) == 0;
1352 std::clog
<< "Do we have write-access to the cache files? " << (Writeable
? "YES" : "NO") << std::endl
;
1354 if (Writeable
== false && AllowMem
== false && CacheFile
.empty() == false)
1355 return _error
->Error(_("Unable to write to %s"),flNotFile(CacheFile
).c_str());
1357 if (Progress
!= NULL
)
1358 Progress
->OverallProgress(0,1,1,_("Reading package lists"));
1360 // Cache is OK, Fin.
1361 if (CheckValidity(CacheFile
, List
, Files
.begin(),Files
.end(),OutMap
) == true)
1363 if (Progress
!= NULL
)
1364 Progress
->OverallProgress(1,1,1,_("Reading package lists"));
1366 std::clog
<< "pkgcache.bin is valid - no need to build anything" << std::endl
;
1369 else if (Debug
== true)
1370 std::clog
<< "pkgcache.bin is NOT valid" << std::endl
;
1372 /* At this point we know we need to reconstruct the package cache,
1374 SPtr
<FileFd
> CacheF
;
1375 SPtr
<DynamicMMap
> Map
;
1376 if (Writeable
== true && CacheFile
.empty() == false)
1378 _error
->PushToStack();
1379 unlink(CacheFile
.c_str());
1380 CacheF
= new FileFd(CacheFile
,FileFd::WriteAtomic
);
1381 fchmod(CacheF
->Fd(),0644);
1382 Map
= CreateDynamicMMap(CacheF
, MMap::Public
);
1383 if (_error
->PendingError() == true)
1385 delete CacheF
.UnGuard();
1386 delete Map
.UnGuard();
1388 std::clog
<< "Open filebased MMap FAILED" << std::endl
;
1390 if (AllowMem
== false)
1392 _error
->MergeWithStack();
1395 _error
->RevertToStack();
1399 _error
->MergeWithStack();
1401 std::clog
<< "Open filebased MMap" << std::endl
;
1404 if (Writeable
== false || CacheFile
.empty() == true)
1406 // Just build it in memory..
1407 Map
= CreateDynamicMMap(NULL
);
1409 std::clog
<< "Open memory Map (not filebased)" << std::endl
;
1412 // Lets try the source cache.
1413 unsigned long CurrentSize
= 0;
1414 unsigned long TotalSize
= 0;
1415 if (CheckValidity(SrcCacheFile
, List
, Files
.begin(),
1416 Files
.begin()+EndOfSource
) == true)
1419 std::clog
<< "srcpkgcache.bin is valid - populate MMap with it." << std::endl
;
1420 // Preload the map with the source cache
1421 FileFd
SCacheF(SrcCacheFile
,FileFd::ReadOnly
);
1422 unsigned long const alloc
= Map
->RawAllocate(SCacheF
.Size());
1423 if ((alloc
== 0 && _error
->PendingError())
1424 || SCacheF
.Read((unsigned char *)Map
->Data() + alloc
,
1425 SCacheF
.Size()) == false)
1428 TotalSize
= ComputeSize(Files
.begin()+EndOfSource
,Files
.end());
1430 // Build the status cache
1431 pkgCacheGenerator
Gen(Map
.Get(),Progress
);
1432 if (_error
->PendingError() == true)
1434 if (BuildCache(Gen
,Progress
,CurrentSize
,TotalSize
,
1435 Files
.begin()+EndOfSource
,Files
.end()) == false)
1441 std::clog
<< "srcpkgcache.bin is NOT valid - rebuild" << std::endl
;
1442 TotalSize
= ComputeSize(Files
.begin(),Files
.end());
1444 // Build the source cache
1445 pkgCacheGenerator
Gen(Map
.Get(),Progress
);
1446 if (_error
->PendingError() == true)
1448 if (BuildCache(Gen
,Progress
,CurrentSize
,TotalSize
,
1449 Files
.begin(),Files
.begin()+EndOfSource
) == false)
1453 if (Writeable
== true && SrcCacheFile
.empty() == false)
1455 FileFd
SCacheF(SrcCacheFile
,FileFd::WriteAtomic
);
1456 if (_error
->PendingError() == true)
1459 fchmod(SCacheF
.Fd(),0644);
1461 // Write out the main data
1462 if (SCacheF
.Write(Map
->Data(),Map
->Size()) == false)
1463 return _error
->Error(_("IO Error saving source cache"));
1466 // Write out the proper header
1467 Gen
.GetCache().HeaderP
->Dirty
= false;
1468 if (SCacheF
.Seek(0) == false ||
1469 SCacheF
.Write(Map
->Data(),sizeof(*Gen
.GetCache().HeaderP
)) == false)
1470 return _error
->Error(_("IO Error saving source cache"));
1471 Gen
.GetCache().HeaderP
->Dirty
= true;
1475 // Build the status cache
1476 if (BuildCache(Gen
,Progress
,CurrentSize
,TotalSize
,
1477 Files
.begin()+EndOfSource
,Files
.end()) == false)
1481 std::clog
<< "Caches are ready for shipping" << std::endl
;
1483 if (_error
->PendingError() == true)
1489 delete Map
.UnGuard();
1490 *OutMap
= new MMap(*CacheF
,0);
1494 *OutMap
= Map
.UnGuard();
1501 // CacheGenerator::MakeOnlyStatusCache - Build only a status files cache/*{{{*/
1502 // ---------------------------------------------------------------------
1504 __deprecated
bool pkgMakeOnlyStatusCache(OpProgress
&Progress
,DynamicMMap
**OutMap
)
1505 { return pkgCacheGenerator::MakeOnlyStatusCache(&Progress
, OutMap
); }
1506 bool pkgCacheGenerator::MakeOnlyStatusCache(OpProgress
*Progress
,DynamicMMap
**OutMap
)
1508 std::vector
<pkgIndexFile
*> Files
;
1509 unsigned long EndOfSource
= Files
.size();
1510 if (_system
->AddStatusFiles(Files
) == false)
1513 SPtr
<DynamicMMap
> Map
= CreateDynamicMMap(NULL
);
1514 unsigned long CurrentSize
= 0;
1515 unsigned long TotalSize
= 0;
1517 TotalSize
= ComputeSize(Files
.begin()+EndOfSource
,Files
.end());
1519 // Build the status cache
1520 if (Progress
!= NULL
)
1521 Progress
->OverallProgress(0,1,1,_("Reading package lists"));
1522 pkgCacheGenerator
Gen(Map
.Get(),Progress
);
1523 if (_error
->PendingError() == true)
1525 if (BuildCache(Gen
,Progress
,CurrentSize
,TotalSize
,
1526 Files
.begin()+EndOfSource
,Files
.end()) == false)
1529 if (_error
->PendingError() == true)
1531 *OutMap
= Map
.UnGuard();
1536 // IsDuplicateDescription /*{{{*/
1537 static bool IsDuplicateDescription(pkgCache::DescIterator Desc
,
1538 MD5SumValue
const &CurMd5
, std::string
const &CurLang
)
1540 // Descriptions in the same link-list have all the same md5
1541 if (Desc
.end() == true || MD5SumValue(Desc
.md5()) != CurMd5
)
1543 for (; Desc
.end() == false; ++Desc
)
1544 if (Desc
.LanguageCode() == CurLang
)
1549 // CacheGenerator::FinishCache /*{{{*/
1550 bool pkgCacheGenerator::FinishCache(OpProgress
*Progress
)