/** \file zypp/target/rpm/librpmDb.cv3.cc
*
*/
-#if 0
-#include "librpm.h"
-extern "C"
-{
-#ifdef _RPM_5
-typedef rpmuint32_t rpm_count_t;
-#define HGEPtr_t void *
-#define headerGetEntryMinMemory headerGetEntry
-#define headerNVR(h,n,v,r) headerNEVRA(h,n,NULL,v,r,NULL)
-#else
-#ifdef _RPM_4_4
-typedef int32_t rpm_count_t;
-#define HGEPtr_t const void *
-#endif
-#endif
-}
-
-#include <iostream>
-
-#include "zypp/base/Logger.h"
-
-#include "zypp/target/rpm/librpmDb.h"
-#include "zypp/target/rpm/RpmCallbacks.h"
-#include "zypp/ZYppCallbacks.h"
-
-#define xmalloc malloc
-#define xstrdup strdup
-
-extern "C"
-{
-#include <string.h>
-
-#define FA_MAGIC 0x02050920
-
- struct faFileHeader
- {
- unsigned int magic;
- unsigned int firstFree;
- };
-
- struct faHeader
- {
- unsigned int size;
- unsigned int freeNext; /* offset of the next free block, 0 if none */
- unsigned int freePrev;
- unsigned int isFree;
-
- /* note that the u16's appear last for alignment/space reasons */
- };
-}
-
-namespace zypp
-{
-namespace target
-{
-namespace rpm
-{
-static int fadFileSize;
-
-static ssize_t Pread(FD_t fd, void * buf, size_t count, off_t offset)
-{
- if (Fseek(fd, offset, SEEK_SET) < 0)
- return -1;
- return Fread(buf, sizeof(char), count, fd);
-}
-
-static FD_t fadOpen(const char * path)
-{
- struct faFileHeader newHdr;
- FD_t fd;
- struct stat stb;
-
- fd = Fopen(path, "r.fdio");
- if (!fd || Ferror(fd))
- return NULL;
-
- if (fstat(Fileno(fd), &stb))
- {
- Fclose(fd);
- return NULL;
- }
- fadFileSize = stb.st_size;
-
- /* is this file brand new? */
- if (fadFileSize == 0)
- {
- Fclose(fd);
- return NULL;
- }
- if (Pread(fd, &newHdr, sizeof(newHdr), 0) != sizeof(newHdr))
- {
- Fclose(fd);
- return NULL;
- }
- if (newHdr.magic != FA_MAGIC)
- {
- Fclose(fd);
- return NULL;
- }
- /*@-refcounttrans@*/ return fd /*@=refcounttrans@*/ ;
-}
-
-static int fadNextOffset(FD_t fd, unsigned int lastOffset)
-{
- struct faHeader header;
- int offset;
-
- offset = (lastOffset)
- ? (lastOffset - sizeof(header))
- : sizeof(struct faFileHeader);
-
- if (offset >= fadFileSize)
- return 0;
-
- if (Pread(fd, &header, sizeof(header), offset) != sizeof(header))
- return 0;
-
- if (!lastOffset && !header.isFree)
- return (offset + sizeof(header));
-
- do
- {
- offset += header.size;
-
- if (Pread(fd, &header, sizeof(header), offset) != sizeof(header))
- return 0;
-
- if (!header.isFree) break;
- }
- while (offset < fadFileSize && header.isFree);
-
- if (offset < fadFileSize)
- {
- /* Sanity check this to make sure we're not going in loops */
- offset += sizeof(header);
-
- if (offset < 0 || (unsigned)offset <= lastOffset) return -1;
-
- return offset;
- }
- else
- return 0;
-}
-
-static int fadFirstOffset(FD_t fd)
-{
- return fadNextOffset(fd, 0);
-}
-
-/*@-boundsread@*/
-static int dncmp(const void * a, const void * b)
-/*@*/
-{
- const char *const * first = (const char *const *)a;
- const char *const * second = (const char *const *)b;
- return strcmp(*first, *second);
-}
-/*@=boundsread@*/
-
-/*@-bounds@*/
-#ifndef _RPM_4_X
-static void compressFilelist(Header h)
-/*@*/
-{
- char ** fileNames;
- const char ** dirNames;
- const char ** baseNames;
- int_32 * dirIndexes;
- rpmTagType fnt;
- rpm_count_t count;
- int xx;
- int dirIndex = -1;
-
- /*
- * This assumes the file list is already sorted, and begins with a
- * single '/'. That assumption isn't critical, but it makes things go
- * a bit faster.
- */
-
- if (headerIsEntry(h, RPMTAG_DIRNAMES))
- {
- xx = headerRemoveEntry(h, RPMTAG_OLDFILENAMES);
- return; /* Already converted. */
- }
-
- HGEPtr_t hgePtr = NULL;
- if (!headerGetEntryMinMemory(h, RPMTAG_OLDFILENAMES, hTYP_t(&fnt), &hgePtr, &count))
- return; /* no file list */
- fileNames = (char **)hgePtr;
- if (fileNames == NULL || count <= 0)
- return;
-
- dirNames = (const char **)alloca(sizeof(*dirNames) * count); /* worst case */
- baseNames = (const char **)alloca(sizeof(*dirNames) * count);
- dirIndexes = (int_32 *)alloca(sizeof(*dirIndexes) * count);
-
- if (fileNames[0][0] != '/')
- {
- /* HACK. Source RPM, so just do things differently */
- dirIndex = 0;
- dirNames[dirIndex] = "";
- for (rpm_count_t i = 0; i < count; i++)
- {
- dirIndexes[i] = dirIndex;
- baseNames[i] = fileNames[i];
- }
- goto exit;
- }
-
- /*@-branchstate@*/
- for (rpm_count_t i = 0; i < count; i++)
- {
- const char ** needle;
- char savechar;
- char * baseName;
- int len;
-
- if (fileNames[i] == NULL) /* XXX can't happen */
- continue;
- baseName = strrchr(fileNames[i], '/') + 1;
- len = baseName - fileNames[i];
- needle = dirNames;
- savechar = *baseName;
- *baseName = '\0';
- /*@-compdef@*/
- if (dirIndex < 0 ||
- (needle = (const char **)bsearch(&fileNames[i], dirNames, dirIndex + 1, sizeof(dirNames[0]), dncmp)) == NULL)
- {
- char *s = (char *)alloca(len + 1);
- memcpy(s, fileNames[i], len + 1);
- s[len] = '\0';
- dirIndexes[i] = ++dirIndex;
- dirNames[dirIndex] = s;
- }
- else
- dirIndexes[i] = needle - dirNames;
- /*@=compdef@*/
-
- *baseName = savechar;
- baseNames[i] = baseName;
- }
- /*@=branchstate@*/
-
-exit:
- if (count > 0)
- {
- xx = headerAddEntry(h, RPMTAG_DIRINDEXES, RPM_INT32_TYPE, dirIndexes, count);
- xx = headerAddEntry(h, RPMTAG_BASENAMES, RPM_STRING_ARRAY_TYPE,
- baseNames, count);
- xx = headerAddEntry(h, RPMTAG_DIRNAMES, RPM_STRING_ARRAY_TYPE,
- dirNames, dirIndex + 1);
- }
-
- fileNames = (char**)headerFreeData(fileNames, fnt);
-
- xx = headerRemoveEntry(h, RPMTAG_OLDFILENAMES);
-}
-/*@=bounds@*/
-
-/*
- * Up to rpm 3.0.4, packages implicitly provided their own name-version-release.
- * Retrofit an explicit "Provides: name = epoch:version-release".
- */
-void providePackageNVR(Header h)
-{
- const char *name, *version, *release;
- HGEPtr_t hgePtr = NULL;
- int_32 * epoch;
- const char *pEVR;
- char *p;
- int_32 pFlags = RPMSENSE_EQUAL;
- const char ** provides = NULL;
- const char ** providesEVR = NULL;
- rpmTagType pnt, pvt;
- int_32 * provideFlags = NULL;
- rpm_count_t providesCount;
- int xx;
- int bingo = 1;
-
- /* Generate provides for this package name-version-release. */
- xx = headerNVR(h, &name, &version, &release);
- if (!(name && version && release))
- return;
- pEVR = p = (char *)alloca(21 + strlen(version) + 1 + strlen(release) + 1);
- *p = '\0';
- if (headerGetEntryMinMemory(h, RPMTAG_EPOCH, NULL, &hgePtr, NULL))
- {
- epoch = (int_32 *)hgePtr;
- sprintf(p, "%d:", *epoch);
- while (*p != '\0')
- p++;
- }
- (void) stpcpy( stpcpy( stpcpy(p, version) , "-") , release);
-
- /*
- * Rpm prior to 3.0.3 does not have versioned provides.
- * If no provides at all are available, we can just add.
- */
- if (!headerGetEntryMinMemory(h, RPMTAG_PROVIDENAME, hTYP_t(&pnt), &hgePtr, &providesCount))
- goto exit;
- provides = (const char **)hgePtr;
-
- /*
- * Otherwise, fill in entries on legacy packages.
- */
- if (!headerGetEntryMinMemory(h, RPMTAG_PROVIDEVERSION, hTYP_t(&pvt), &hgePtr, NULL))
- {
- providesEVR = (const char **)hgePtr;
- for (rpm_count_t i = 0; i < providesCount; i++)
- {
- const char * vdummy = "";
- int_32 fdummy = RPMSENSE_ANY;
- xx = headerAddOrAppendEntry(h, RPMTAG_PROVIDEVERSION, RPM_STRING_ARRAY_TYPE,
- &vdummy, 1);
- xx = headerAddOrAppendEntry(h, RPMTAG_PROVIDEFLAGS, RPM_INT32_TYPE,
- &fdummy, 1);
- }
- goto exit;
- }
-
- xx = headerGetEntryMinMemory(h, RPMTAG_PROVIDEFLAGS, NULL, &hgePtr, NULL);
- provideFlags = (int_32 *)hgePtr;
-
- /*@-nullderef@*/ /* LCL: providesEVR is not NULL */
- if (provides && providesEVR && provideFlags)
- for (rpm_count_t i = 0; i < providesCount; i++)
- {
- if (!(provides[i] && providesEVR[i]))
- continue;
- if (!(provideFlags[i] == RPMSENSE_EQUAL &&
- !strcmp(name, provides[i]) && !strcmp(pEVR, providesEVR[i])))
- continue;
- bingo = 0;
- break;
- }
- /*@=nullderef@*/
-
-exit:
- provides = (const char **)headerFreeData(provides, pnt);
- providesEVR = (const char **)headerFreeData(providesEVR, pvt);
-
- if (bingo)
- {
- xx = headerAddOrAppendEntry(h, RPMTAG_PROVIDENAME, RPM_STRING_ARRAY_TYPE,
- &name, 1);
- xx = headerAddOrAppendEntry(h, RPMTAG_PROVIDEFLAGS, RPM_INT32_TYPE,
- &pFlags, 1);
- xx = headerAddOrAppendEntry(h, RPMTAG_PROVIDEVERSION, RPM_STRING_ARRAY_TYPE,
- &pEVR, 1);
- }
-}
-#else
-static void compressFilelist(Header h)
-{
- struct rpmtd_s fileNames;
- char ** dirNames;
- const char ** baseNames;
- uint32_t * dirIndexes;
- rpm_count_t count;
- int xx, i;
- int dirIndex = -1;
-
- /*
- * This assumes the file list is already sorted, and begins with a
- * single '/'. That assumption isn't critical, but it makes things go
- * a bit faster.
- */
-
- if (headerIsEntry(h, RPMTAG_DIRNAMES)) {
- xx = headerDel(h, RPMTAG_OLDFILENAMES);
- return; /* Already converted. */
- }
-
- if (!headerGet(h, RPMTAG_OLDFILENAMES, &fileNames, HEADERGET_MINMEM))
- return;
- count = rpmtdCount(&fileNames);
- if (count < 1)
- return;
-
- dirNames = (char**)malloc(sizeof(*dirNames) * count); /* worst case */
- baseNames = (const char**)malloc(sizeof(*dirNames) * count);
- dirIndexes = (uint32_t*)malloc(sizeof(*dirIndexes) * count);
-
- /* HACK. Source RPM, so just do things differently */
- { const char *fn = rpmtdGetString(&fileNames);
- if (fn && *fn != '/') {
- dirIndex = 0;
- dirNames[dirIndex] = xstrdup("");
- while ((i = rpmtdNext(&fileNames)) >= 0) {
- dirIndexes[i] = dirIndex;
- baseNames[i] = rpmtdGetString(&fileNames);
- }
- goto exit;
- }
- }
-
- while ((i = rpmtdNext(&fileNames)) >= 0) {
- char ** needle;
- char savechar;
- char * baseName;
- size_t len;
- const char *filename = rpmtdGetString(&fileNames);
-
- if (filename == NULL) /* XXX can't happen */
- continue;
- baseName = strrchr((char*)filename, '/') + 1;
- len = baseName - filename;
- needle = dirNames;
- savechar = *baseName;
- *baseName = '\0';
- if (dirIndex < 0 ||
- (needle = (char**)bsearch(&filename, dirNames, dirIndex + 1, sizeof(dirNames[0]), dncmp)) == NULL) {
- char *s = (char*)malloc(len + 1);
- rstrlcpy(s, filename, len + 1);
- dirIndexes[i] = ++dirIndex;
- dirNames[dirIndex] = s;
- } else
- dirIndexes[i] = needle - dirNames;
-
- *baseName = savechar;
- baseNames[i] = baseName;
- }
-
-exit:
- if (count > 0) {
- headerPutUint32(h, RPMTAG_DIRINDEXES, dirIndexes, count);
- headerPutStringArray(h, RPMTAG_BASENAMES, baseNames, count);
- headerPutStringArray(h, RPMTAG_DIRNAMES,
- (const char **) dirNames, dirIndex + 1);
- }
-
- rpmtdFreeData(&fileNames);
- for (i = 0; i <= dirIndex; i++) {
- free(dirNames[i]);
- }
- free(dirNames);
- free(baseNames);
- free(dirIndexes);
-
- xx = headerDel(h, RPMTAG_OLDFILENAMES);
-}
-
-/*
- * Up to rpm 3.0.4, packages implicitly provided their own name-version-release.
- * Retrofit an explicit "Provides: name = epoch:version-release.
- */
-static void providePackageNVR(Header h)
-{
- const char *name;
- char *pEVR;
- rpmsenseFlags pFlags = RPMSENSE_EQUAL;
- int bingo = 1;
- struct rpmtd_s pnames;
- rpmds hds, nvrds;
-
- /* Generate provides for this package name-version-release. */
- pEVR = headerGetEVR(h, &name);
- if (!(name && pEVR))
- return;
-
- /*
- * Rpm prior to 3.0.3 does not have versioned provides.
- * If no provides at all are available, we can just add.
- */
- if (!headerGet(h, RPMTAG_PROVIDENAME, &pnames, HEADERGET_MINMEM)) {
- goto exit;
- }
-
- /*
- * Otherwise, fill in entries on legacy packages.
- */
- if (!headerIsEntry(h, RPMTAG_PROVIDEVERSION)) {
- while (rpmtdNext(&pnames) >= 0) {
- uint32_t fdummy = RPMSENSE_ANY;
-
- headerPutString(h, RPMTAG_PROVIDEVERSION, "");
- headerPutUint32(h, RPMTAG_PROVIDEFLAGS, &fdummy, 1);
- }
- goto exit;
- }
-
- /* see if we already have this provide */
- hds = rpmdsNew(h, RPMTAG_PROVIDENAME, 0);
- nvrds = rpmdsSingle(RPMTAG_PROVIDENAME, name, pEVR, pFlags);
- if (rpmdsFind(hds, nvrds) >= 0) {
- bingo = 0;
- }
- rpmdsFree(hds);
- rpmdsFree(nvrds);
-
-exit:
- if (bingo) {
- const char *evr = pEVR;
- uint32_t fdummy = pFlags;
- headerPutString(h, RPMTAG_PROVIDENAME, name);
- headerPutString(h, RPMTAG_PROVIDEVERSION, evr);
- headerPutUint32(h, RPMTAG_PROVIDEFLAGS, &fdummy, 1);
- }
- rpmtdFreeData(&pnames);
- free(pEVR);
-}
-
-#endif
-
-///////////////////////////////////////////////////////////////////
-///////////////////////////////////////////////////////////////////
-///////////////////////////////////////////////////////////////////
-
-using namespace std;
-
-#undef Y2LOG
-#define Y2LOG "librpmDb"
-
-/******************************************************************
-**
-**
-** FUNCTION NAME : internal_convertV3toV4
-** FUNCTION TYPE : int
-*/
-void internal_convertV3toV4( const Pathname & v3db_r, const librpmDb::constPtr & v4db_r,
- callback::SendReport<ConvertDBReport> & report )
-{
-// Timecount _t( "convert V3 to V4" );
- MIL << "Convert rpm3 database to rpm4" << endl;
-
- // Check arguments
- FD_t fd = fadOpen( v3db_r.asString().c_str() );
- if ( fd == 0 )
- {
- Fclose( fd );
- ZYPP_THROW(RpmDbOpenException(Pathname("/"), v3db_r));
- }
-
- if ( ! v4db_r )
- {
- Fclose( fd );
- INT << "NULL rpmV4 database passed as argument!" << endl;
- ZYPP_THROW(RpmNullDatabaseException());
- }
-
- shared_ptr<RpmException> err = v4db_r->error();
- if ( err )
- {
- Fclose( fd );
- INT << "Can't access rpmV4 database " << v4db_r << endl;
- ZYPP_THROW(*err);
- }
-
- // open rpmV4 database for writing. v4db_r is ok so librpm should
- // be properly initialized.
- rpmdb db = 0;
- string rootstr( v4db_r->root().asString() );
- const char * root = ( rootstr == "/" ? NULL : rootstr.c_str() );
-
- int res = ::rpmdbOpen( root, &db, O_RDWR, 0644 );
- if ( res || ! db )
- {
- if ( db )
- {
- ::rpmdbClose( db );
- }
- Fclose( fd );
- ZYPP_THROW(RpmDbOpenException(root, v4db_r->dbPath()));
- }
-
- // Check ammount of packages to process.
- int max = 0;
- for ( int offset = fadFirstOffset(fd); offset; offset = fadNextOffset(fd, offset) )
- {
- ++max;
- }
- MIL << "Packages in rpmV3 database " << v3db_r << ": " << max << endl;
-
- unsigned failed = 0;
- unsigned ignored = 0;
- unsigned alreadyInV4 = 0;
- report->progress( (100 * (failed + ignored + alreadyInV4) / max), v3db_r );
-
- if ( !max )
- {
- Fclose( fd );
- ::rpmdbClose( db );
- return;
- }
-
- // Start conversion.
-#warning Add CBSuggest handling if needed, also on lines below
-// CBSuggest proceed;
- bool proceed = true;
- for ( int offset = fadFirstOffset(fd); offset && proceed /*!= CBSuggest::CANCEL*/;
- offset = fadNextOffset(fd, offset),
- report->progress( (100 * (failed + ignored + alreadyInV4) / max), v3db_r ) )
- {
-
- // have to use lseek instead of Fseek because headerRead
- // uses low level IO
- if ( lseek( Fileno( fd ), (off_t)offset, SEEK_SET ) == -1 )
- {
- ostream * reportAs = &(ERR);
- /* proceed = report->dbReadError( offset );
- if ( proceed == CBSuggest::SKIP ) {
- // ignore this error
- ++ignored;
- reportAs = &(WAR << "IGNORED: ");
- } else {*/
- // PROCEED will fail after conversion; CANCEL immediately stop loop
- ++failed;
-// }
- (*reportAs) << "rpmV3 database entry: Can't seek to offset " << offset << " (errno " << errno << ")" << endl;
- continue;
- }
- Header h = headerRead(fd, HEADER_MAGIC_NO);
- if ( ! h )
- {
- ostream * reportAs = &(ERR);
- /* proceed = report->dbReadError( offset );
- if ( proceed == CBSuggest::SKIP ) {
- // ignore this error
- ++ignored;
- reportAs = &(WAR << "IGNORED: ");
- } else {*/
- // PROCEED will fail after conversion; CANCEL immediately stop loop
- ++failed;
-// }
- (*reportAs) << "rpmV3 database entry: No header at offset " << offset << endl;
- continue;
- }
- compressFilelist(h);
- providePackageNVR(h);
- const char *name = 0;
- const char *version = 0;
- const char *release = 0;
- headerNVR(h, &name, &version, &release);
- string nrv( string(name) + "-" + version + "-" + release );
- rpmdbMatchIterator mi = rpmdbInitIterator(db, RPMTAG_NAME, name, 0);
- rpmdbSetIteratorRE(mi, RPMTAG_VERSION, RPMMIRE_DEFAULT, version);
- rpmdbSetIteratorRE(mi, RPMTAG_RELEASE, RPMMIRE_DEFAULT, release);
- if (rpmdbNextIterator(mi))
- {
-// report.dbInV4( nrv );
- WAR << "SKIP: rpmV3 database entry: " << nrv << " is already in rpmV4 database" << endl;
- rpmdbFreeIterator(mi);
- headerFree(h);
- ++alreadyInV4;
- continue;
- }
- rpmdbFreeIterator(mi);
-#ifdef _RPM_5
- if (rpmdbAdd(db, -1, h, 0))
-#else
- if (rpmdbAdd(db, -1, h, 0, 0))
-#endif
- {
-// report.dbWriteError( nrv );
- proceed = false;//CBSuggest::CANCEL; // immediately stop loop
- ++failed;
- ERR << "rpmV4 database error: could not add " << nrv << " to rpmV4 database" << endl;
- headerFree(h);
- continue;
- }
- headerFree(h);
- }
-
- Fclose(fd);
- ::rpmdbClose(db);
-
- if ( failed )
- {
- ERR << "Convert rpm3 database to rpm4: Aborted after "
- << alreadyInV4 << " package(s) and " << (failed+ignored) << " error(s)."
- << endl;
- ZYPP_THROW(RpmDbConvertException());
- }
- else
- {
- MIL << "Convert rpm3 database to rpm4: " << max << " package(s) processed";
- if ( alreadyInV4 )
- {
- MIL << "; " << alreadyInV4 << " already present in rpmV4 database";
- }
- if ( ignored )
- {
- MIL << "; IGNORED: " << ignored << " unconverted due to error";
- }
- MIL << endl;
- }
-}
-#endif
-
#include <iostream>
#include "zypp/base/Logger.h"
projects / platform / upstream / libzypp.git / blobdiff