2263 lines
60 KiB
C
2263 lines
60 KiB
C
/** \ingroup rpmts
|
|
* \file lib/transaction.c
|
|
*/
|
|
|
|
#include "system.h"
|
|
#include "rpmlib.h"
|
|
|
|
#include "rpmmacro.h" /* XXX for rpmExpand */
|
|
|
|
#include "fsm.h"
|
|
#include "psm.h"
|
|
|
|
#include "rpmdb.h"
|
|
#include "rpmdb_internal.h" /* XXX for dbiIndexSetCount */
|
|
|
|
#include "rpmds.h"
|
|
|
|
#include "rpmlock.h"
|
|
|
|
#define _RPMFI_INTERNAL /* fi->replaced, fi->actions... */
|
|
#include "rpmfi.h"
|
|
|
|
#define _RPMTE_INTERNAL /* XXX te->h, te->fd, te->h */
|
|
#include "rpmte.h"
|
|
|
|
#include "rpmts_internal.h"
|
|
|
|
#include "cpio.h"
|
|
#include "fprint.h"
|
|
#include "legacy.h" /* XXX domd5 */
|
|
#include "misc.h" /* XXX (free)splitString, currentDirectory */
|
|
|
|
#include "debug.h"
|
|
|
|
#include "idtx.h"
|
|
|
|
/**
|
|
*/
|
|
static int archOkay(const char * pkgArch)
|
|
{
|
|
if (pkgArch == NULL) return 0;
|
|
return (rpmMachineScore(RPM_MACHTABLE_INSTARCH, pkgArch) ? 1 : 0);
|
|
}
|
|
|
|
/**
|
|
*/
|
|
static int osOkay(const char * pkgOs)
|
|
{
|
|
if (pkgOs == NULL) return 0;
|
|
return (rpmMachineScore(RPM_MACHTABLE_INSTOS, pkgOs) ? 1 : 0);
|
|
}
|
|
|
|
/**
|
|
*/
|
|
static int sharedCmp(const void * one, const void * two)
|
|
{
|
|
sharedFileInfo a = (sharedFileInfo) one;
|
|
sharedFileInfo b = (sharedFileInfo) two;
|
|
|
|
if (a->otherPkg < b->otherPkg)
|
|
return -1;
|
|
else if (a->otherPkg > b->otherPkg)
|
|
return 1;
|
|
|
|
return 0;
|
|
}
|
|
|
|
/**
|
|
* handleInstInstalledFiles.
|
|
* @param ts transaction set
|
|
* @param p current transaction element
|
|
* @param fi file info set
|
|
* @param shared shared file info
|
|
* @param sharedCount no. of shared elements
|
|
* @param reportConflicts
|
|
*/
|
|
/* XXX only ts->{probs,rpmdb} modified */
|
|
static int handleInstInstalledFiles(const rpmts ts,
|
|
rpmte p, rpmfi fi,
|
|
sharedFileInfo shared,
|
|
int sharedCount, int reportConflicts)
|
|
{
|
|
uint32_t tscolor = rpmtsColor(ts);
|
|
uint32_t prefcolor = rpmtsPrefColor(ts);
|
|
uint32_t otecolor, tecolor;
|
|
uint32_t oFColor, FColor;
|
|
const char * altNEVR = NULL;
|
|
rpmfi otherFi = NULL;
|
|
int numReplaced = 0;
|
|
rpmps ps;
|
|
int i;
|
|
|
|
{ rpmdbMatchIterator mi;
|
|
Header h;
|
|
int scareMem = 0;
|
|
|
|
mi = rpmtsInitIterator(ts, RPMDBI_PACKAGES,
|
|
&shared->otherPkg, sizeof(shared->otherPkg));
|
|
while ((h = rpmdbNextIterator(mi)) != NULL) {
|
|
altNEVR = hGetNEVRA(h, NULL);
|
|
otherFi = rpmfiNew(ts, h, RPMTAG_BASENAMES, scareMem);
|
|
break;
|
|
}
|
|
mi = rpmdbFreeIterator(mi);
|
|
}
|
|
|
|
/* Compute package color. */
|
|
tecolor = rpmteColor(p);
|
|
tecolor &= tscolor;
|
|
|
|
/* Compute other pkg color. */
|
|
otecolor = 0;
|
|
otherFi = rpmfiInit(otherFi, 0);
|
|
if (otherFi != NULL)
|
|
while (rpmfiNext(otherFi) >= 0)
|
|
otecolor |= rpmfiFColor(otherFi);
|
|
otecolor &= tscolor;
|
|
|
|
if (otherFi == NULL)
|
|
return 1;
|
|
|
|
fi->replaced = xcalloc(sharedCount, sizeof(*fi->replaced));
|
|
|
|
ps = rpmtsProblems(ts);
|
|
for (i = 0; i < sharedCount; i++, shared++) {
|
|
int otherFileNum, fileNum;
|
|
int isCfgFile;
|
|
|
|
otherFileNum = shared->otherFileNum;
|
|
(void) rpmfiSetFX(otherFi, otherFileNum);
|
|
oFColor = rpmfiFColor(otherFi);
|
|
oFColor &= tscolor;
|
|
|
|
fileNum = shared->pkgFileNum;
|
|
(void) rpmfiSetFX(fi, fileNum);
|
|
FColor = rpmfiFColor(fi);
|
|
FColor &= tscolor;
|
|
|
|
isCfgFile = ((rpmfiFFlags(otherFi) | rpmfiFFlags(fi)) & RPMFILE_CONFIG);
|
|
|
|
#ifdef DYING
|
|
/* XXX another tedious segfault, assume file state normal. */
|
|
if (otherStates && otherStates[otherFileNum] != RPMFILE_STATE_NORMAL)
|
|
continue;
|
|
#endif
|
|
|
|
if (XFA_SKIPPING(fi->actions[fileNum]))
|
|
continue;
|
|
|
|
if (!(fi->mapflags & CPIO_SBIT_CHECK)) {
|
|
int16_t omode = rpmfiFMode(otherFi);
|
|
if (S_ISREG(omode) && (omode & 06000) != 0) {
|
|
fi->mapflags |= CPIO_SBIT_CHECK;
|
|
}
|
|
}
|
|
|
|
if (rpmfiCompare(otherFi, fi)) {
|
|
int rConflicts;
|
|
|
|
rConflicts = reportConflicts;
|
|
/* Resolve file conflicts to prefer Elf64 (if not forced). */
|
|
if (tscolor != 0 && FColor != 0 && FColor != oFColor)
|
|
{
|
|
if (oFColor & prefcolor) {
|
|
fi->actions[fileNum] = FA_SKIPCOLOR;
|
|
rConflicts = 0;
|
|
} else
|
|
if (FColor & prefcolor) {
|
|
fi->actions[fileNum] = FA_CREATE;
|
|
rConflicts = 0;
|
|
}
|
|
}
|
|
|
|
if (rConflicts) {
|
|
rpmpsAppend(ps, RPMPROB_FILE_CONFLICT,
|
|
rpmteNEVRA(p), rpmteKey(p),
|
|
rpmfiDN(fi), rpmfiBN(fi),
|
|
altNEVR,
|
|
0);
|
|
}
|
|
/* Save file identifier to mark as state REPLACED. */
|
|
if ( !(isCfgFile || XFA_SKIPPING(fi->actions[fileNum])) ) {
|
|
/* FIX: p->replaced, not fi */
|
|
if (!shared->isRemoved)
|
|
fi->replaced[numReplaced++] = *shared;
|
|
}
|
|
}
|
|
|
|
/* Determine config file dispostion, skipping missing files (if any). */
|
|
if (isCfgFile) {
|
|
int skipMissing =
|
|
((rpmtsFlags(ts) & RPMTRANS_FLAG_ALLFILES) ? 0 : 1);
|
|
rpmFileAction action = rpmfiDecideFate(otherFi, fi, skipMissing);
|
|
fi->actions[fileNum] = action;
|
|
}
|
|
fi->replacedSizes[fileNum] = rpmfiFSize(otherFi);
|
|
}
|
|
ps = rpmpsFree(ps);
|
|
|
|
altNEVR = _free(altNEVR);
|
|
otherFi = rpmfiFree(otherFi);
|
|
|
|
fi->replaced = xrealloc(fi->replaced, /* XXX memory leak */
|
|
sizeof(*fi->replaced) * (numReplaced + 1));
|
|
fi->replaced[numReplaced].otherPkg = 0;
|
|
|
|
return 0;
|
|
}
|
|
|
|
/**
|
|
*/
|
|
/* XXX only ts->rpmdb modified */
|
|
static int handleRmvdInstalledFiles(const rpmts ts, rpmfi fi,
|
|
sharedFileInfo shared, int sharedCount)
|
|
{
|
|
HGE_t hge = fi->hge;
|
|
Header h;
|
|
const char * otherStates;
|
|
int i, xx;
|
|
|
|
rpmdbMatchIterator mi;
|
|
|
|
mi = rpmtsInitIterator(ts, RPMDBI_PACKAGES,
|
|
&shared->otherPkg, sizeof(shared->otherPkg));
|
|
h = rpmdbNextIterator(mi);
|
|
if (h == NULL) {
|
|
mi = rpmdbFreeIterator(mi);
|
|
return 1;
|
|
}
|
|
|
|
xx = hge(h, RPMTAG_FILESTATES, NULL, (void **) &otherStates, NULL);
|
|
|
|
for (i = 0; i < sharedCount; i++, shared++) {
|
|
int otherFileNum, fileNum;
|
|
otherFileNum = shared->otherFileNum;
|
|
fileNum = shared->pkgFileNum;
|
|
|
|
if (otherStates[otherFileNum] != RPMFILE_STATE_NORMAL)
|
|
continue;
|
|
|
|
fi->actions[fileNum] = FA_SKIP;
|
|
}
|
|
|
|
mi = rpmdbFreeIterator(mi);
|
|
|
|
return 0;
|
|
}
|
|
|
|
#define ISROOT(_d) (((_d)[0] == '/' && (_d)[1] == '\0') ? "" : (_d))
|
|
|
|
int _fps_debug = 0;
|
|
|
|
static int fpsCompare (const void * one, const void * two)
|
|
{
|
|
const struct fingerPrint_s * a = (const struct fingerPrint_s *)one;
|
|
const struct fingerPrint_s * b = (const struct fingerPrint_s *)two;
|
|
int adnlen = strlen(a->entry->dirName);
|
|
int asnlen = (a->subDir ? strlen(a->subDir) : 0);
|
|
int abnlen = strlen(a->baseName);
|
|
int bdnlen = strlen(b->entry->dirName);
|
|
int bsnlen = (b->subDir ? strlen(b->subDir) : 0);
|
|
int bbnlen = strlen(b->baseName);
|
|
char * afn, * bfn, * t;
|
|
int rc = 0;
|
|
|
|
if (adnlen == 1 && asnlen != 0) adnlen = 0;
|
|
if (bdnlen == 1 && bsnlen != 0) bdnlen = 0;
|
|
|
|
afn = t = alloca(adnlen+asnlen+abnlen+2);
|
|
if (adnlen) t = stpcpy(t, a->entry->dirName);
|
|
*t++ = '/';
|
|
if (a->subDir && asnlen) t = stpcpy(t, a->subDir);
|
|
if (abnlen) t = stpcpy(t, a->baseName);
|
|
if (afn[0] == '/' && afn[1] == '/') afn++;
|
|
|
|
bfn = t = alloca(bdnlen+bsnlen+bbnlen+2);
|
|
if (bdnlen) t = stpcpy(t, b->entry->dirName);
|
|
*t++ = '/';
|
|
if (b->subDir && bsnlen) t = stpcpy(t, b->subDir);
|
|
if (bbnlen) t = stpcpy(t, b->baseName);
|
|
if (bfn[0] == '/' && bfn[1] == '/') bfn++;
|
|
|
|
rc = strcmp(afn, bfn);
|
|
if (_fps_debug)
|
|
fprintf(stderr, "\trc(%d) = strcmp(\"%s\", \"%s\")\n", rc, afn, bfn);
|
|
|
|
if (_fps_debug)
|
|
fprintf(stderr, "\t%s/%s%s\trc %d\n",
|
|
ISROOT(b->entry->dirName),
|
|
(b->subDir ? b->subDir : ""),
|
|
b->baseName,
|
|
rc
|
|
);
|
|
|
|
return rc;
|
|
}
|
|
|
|
static int _linear_fps_search = 0;
|
|
|
|
static int findFps(const struct fingerPrint_s * fiFps,
|
|
const struct fingerPrint_s * otherFps,
|
|
int otherFc)
|
|
{
|
|
int otherFileNum;
|
|
|
|
if (_fps_debug)
|
|
fprintf(stderr, "==> %s/%s%s\n",
|
|
ISROOT(fiFps->entry->dirName),
|
|
(fiFps->subDir ? fiFps->subDir : ""),
|
|
fiFps->baseName);
|
|
|
|
if (_linear_fps_search) {
|
|
|
|
linear:
|
|
for (otherFileNum = 0; otherFileNum < otherFc; otherFileNum++, otherFps++) {
|
|
|
|
if (_fps_debug)
|
|
fprintf(stderr, "\t%4d %s/%s%s\n", otherFileNum,
|
|
ISROOT(otherFps->entry->dirName),
|
|
(otherFps->subDir ? otherFps->subDir : ""),
|
|
otherFps->baseName);
|
|
|
|
/* If the addresses are the same, so are the values. */
|
|
if (fiFps == otherFps)
|
|
break;
|
|
|
|
/* Otherwise, compare fingerprints by value. */
|
|
if (FP_EQUAL((*fiFps), (*otherFps)))
|
|
break;
|
|
}
|
|
|
|
if (otherFileNum == otherFc) {
|
|
if (_fps_debug)
|
|
fprintf(stderr, "*** FP_EQUAL NULL %s/%s%s\n",
|
|
ISROOT(fiFps->entry->dirName),
|
|
(fiFps->subDir ? fiFps->subDir : ""),
|
|
fiFps->baseName);
|
|
}
|
|
|
|
return otherFileNum;
|
|
|
|
} else {
|
|
|
|
const struct fingerPrint_s * bingoFps;
|
|
|
|
bingoFps = bsearch(fiFps, otherFps, otherFc, sizeof(*otherFps), fpsCompare);
|
|
if (bingoFps == NULL) {
|
|
if (_fps_debug)
|
|
fprintf(stderr, "*** bingoFps NULL %s/%s%s\n",
|
|
ISROOT(fiFps->entry->dirName),
|
|
(fiFps->subDir ? fiFps->subDir : ""),
|
|
fiFps->baseName);
|
|
goto linear;
|
|
}
|
|
|
|
/* If the addresses are the same, so are the values. */
|
|
/* LCL: looks good to me */
|
|
if (!(fiFps == bingoFps || FP_EQUAL((*fiFps), (*bingoFps)))) {
|
|
if (_fps_debug)
|
|
fprintf(stderr, "*** BAD %s/%s%s\n",
|
|
ISROOT(bingoFps->entry->dirName),
|
|
(bingoFps->subDir ? bingoFps->subDir : ""),
|
|
bingoFps->baseName);
|
|
goto linear;
|
|
}
|
|
|
|
otherFileNum = (bingoFps != NULL ? (bingoFps - otherFps) : 0);
|
|
|
|
}
|
|
|
|
return otherFileNum;
|
|
}
|
|
|
|
/**
|
|
* Update disk space needs on each partition for this package's files.
|
|
*/
|
|
/* XXX only ts->{probs,di} modified */
|
|
static void handleOverlappedFiles(const rpmts ts,
|
|
const rpmte p, rpmfi fi)
|
|
{
|
|
uint32_t fixupSize = 0;
|
|
rpmps ps;
|
|
const char * fn;
|
|
int i, j;
|
|
|
|
ps = rpmtsProblems(ts);
|
|
fi = rpmfiInit(fi, 0);
|
|
if (fi != NULL)
|
|
while ((i = rpmfiNext(fi)) >= 0) {
|
|
uint32_t tscolor = rpmtsColor(ts);
|
|
uint32_t prefcolor = rpmtsPrefColor(ts);
|
|
uint32_t oFColor, FColor;
|
|
struct fingerPrint_s * fiFps;
|
|
int otherPkgNum, otherFileNum;
|
|
rpmfi otherFi;
|
|
int32_t FFlags;
|
|
int16_t FMode;
|
|
const rpmfi * recs;
|
|
int numRecs;
|
|
|
|
if (XFA_SKIPPING(fi->actions[i]))
|
|
continue;
|
|
|
|
fn = rpmfiFN(fi);
|
|
fiFps = fi->fps + i;
|
|
FFlags = rpmfiFFlags(fi);
|
|
FMode = rpmfiFMode(fi);
|
|
FColor = rpmfiFColor(fi);
|
|
FColor &= tscolor;
|
|
|
|
fixupSize = 0;
|
|
|
|
/*
|
|
* Retrieve all records that apply to this file. Note that the
|
|
* file info records were built in the same order as the packages
|
|
* will be installed and removed so the records for an overlapped
|
|
* files will be sorted in exactly the same order.
|
|
*/
|
|
(void) htGetEntry(ts->ht, fiFps,
|
|
(const void ***) &recs, &numRecs, NULL);
|
|
|
|
/*
|
|
* If this package is being added, look only at other packages
|
|
* being added -- removed packages dance to a different tune.
|
|
*
|
|
* If both this and the other package are being added, overlapped
|
|
* files must be identical (or marked as a conflict). The
|
|
* disposition of already installed config files leads to
|
|
* a small amount of extra complexity.
|
|
*
|
|
* If this package is being removed, then there are two cases that
|
|
* need to be worried about:
|
|
* If the other package is being added, then skip any overlapped files
|
|
* so that this package removal doesn't nuke the overlapped files
|
|
* that were just installed.
|
|
* If both this and the other package are being removed, then each
|
|
* file removal from preceding packages needs to be skipped so that
|
|
* the file removal occurs only on the last occurence of an overlapped
|
|
* file in the transaction set.
|
|
*
|
|
*/
|
|
|
|
/* Locate this overlapped file in the set of added/removed packages. */
|
|
for (j = 0; j < numRecs && recs[j] != fi; j++)
|
|
{};
|
|
|
|
/* Find what the previous disposition of this file was. */
|
|
otherFileNum = -1; /* keep gcc quiet */
|
|
otherFi = NULL;
|
|
for (otherPkgNum = j - 1; otherPkgNum >= 0; otherPkgNum--) {
|
|
struct fingerPrint_s * otherFps;
|
|
int otherFc;
|
|
|
|
otherFi = recs[otherPkgNum];
|
|
|
|
/* Added packages need only look at other added packages. */
|
|
if (rpmteType(p) == TR_ADDED && rpmteType(otherFi->te) != TR_ADDED)
|
|
continue;
|
|
|
|
otherFps = otherFi->fps;
|
|
otherFc = rpmfiFC(otherFi);
|
|
|
|
otherFileNum = findFps(fiFps, otherFps, otherFc);
|
|
(void) rpmfiSetFX(otherFi, otherFileNum);
|
|
|
|
/* XXX Happens iff fingerprint for incomplete package install. */
|
|
if (otherFi->actions[otherFileNum] != FA_UNKNOWN)
|
|
break;
|
|
}
|
|
|
|
oFColor = rpmfiFColor(otherFi);
|
|
oFColor &= tscolor;
|
|
|
|
switch (rpmteType(p)) {
|
|
case TR_ADDED:
|
|
{
|
|
int reportConflicts =
|
|
!(rpmtsFilterFlags(ts) & RPMPROB_FILTER_REPLACENEWFILES);
|
|
int done = 0;
|
|
|
|
if (otherPkgNum < 0) {
|
|
/* XXX is this test still necessary? */
|
|
if (fi->actions[i] != FA_UNKNOWN)
|
|
break;
|
|
if (rpmfiConfigConflict(fi)) {
|
|
/* Here is a non-overlapped pre-existing config file. */
|
|
fi->actions[i] = (FFlags & RPMFILE_NOREPLACE)
|
|
? FA_ALTNAME : FA_BACKUP;
|
|
} else {
|
|
fi->actions[i] = FA_CREATE;
|
|
}
|
|
break;
|
|
}
|
|
|
|
assert(otherFi != NULL);
|
|
/* Mark added overlapped non-identical files as a conflict. */
|
|
if (rpmfiCompare(otherFi, fi)) {
|
|
int rConflicts;
|
|
|
|
rConflicts = reportConflicts;
|
|
/* Resolve file conflicts to prefer Elf64 (if not forced) ... */
|
|
if (tscolor != 0) {
|
|
if (FColor & prefcolor) {
|
|
/* ... last file of preferred colour is installed ... */
|
|
if (!XFA_SKIPPING(fi->actions[i])) {
|
|
/* XXX static helpers are order dependent. Ick. */
|
|
if (strcmp(fn, "/usr/sbin/libgcc_post_upgrade")
|
|
&& strcmp(fn, "/usr/sbin/glibc_post_upgrade"))
|
|
otherFi->actions[otherFileNum] = FA_SKIPCOLOR;
|
|
}
|
|
fi->actions[i] = FA_CREATE;
|
|
rConflicts = 0;
|
|
} else
|
|
if (oFColor & prefcolor) {
|
|
/* ... first file of preferred colour is installed ... */
|
|
if (XFA_SKIPPING(fi->actions[i]))
|
|
otherFi->actions[otherFileNum] = FA_CREATE;
|
|
fi->actions[i] = FA_SKIPCOLOR;
|
|
rConflicts = 0;
|
|
} else
|
|
if (FColor == 0 && oFColor == 0) {
|
|
/* ... otherwise, do both, last in wins. */
|
|
otherFi->actions[otherFileNum] = FA_CREATE;
|
|
fi->actions[i] = FA_CREATE;
|
|
rConflicts = 0;
|
|
}
|
|
done = 1;
|
|
}
|
|
|
|
if (rConflicts) {
|
|
rpmpsAppend(ps, RPMPROB_NEW_FILE_CONFLICT,
|
|
rpmteNEVRA(p), rpmteKey(p),
|
|
fn, NULL,
|
|
rpmteNEVRA(otherFi->te),
|
|
0);
|
|
}
|
|
}
|
|
|
|
/* Try to get the disk accounting correct even if a conflict. */
|
|
fixupSize = rpmfiFSize(otherFi);
|
|
|
|
if (rpmfiConfigConflict(fi)) {
|
|
/* Here is an overlapped pre-existing config file. */
|
|
fi->actions[i] = (FFlags & RPMFILE_NOREPLACE)
|
|
? FA_ALTNAME : FA_SKIP;
|
|
} else {
|
|
if (!done)
|
|
fi->actions[i] = FA_CREATE;
|
|
}
|
|
} break;
|
|
|
|
case TR_REMOVED:
|
|
if (otherPkgNum >= 0) {
|
|
assert(otherFi != NULL);
|
|
/* Here is an overlapped added file we don't want to nuke. */
|
|
if (otherFi->actions[otherFileNum] != FA_ERASE) {
|
|
/* On updates, don't remove files. */
|
|
fi->actions[i] = FA_SKIP;
|
|
break;
|
|
}
|
|
/* Here is an overlapped removed file: skip in previous. */
|
|
otherFi->actions[otherFileNum] = FA_SKIP;
|
|
}
|
|
if (XFA_SKIPPING(fi->actions[i]))
|
|
break;
|
|
if (rpmfiFState(fi) != RPMFILE_STATE_NORMAL)
|
|
break;
|
|
if (!(S_ISREG(FMode) && (FFlags & RPMFILE_CONFIG))) {
|
|
fi->actions[i] = FA_ERASE;
|
|
break;
|
|
}
|
|
|
|
/* Here is a pre-existing modified config file that needs saving. */
|
|
{ unsigned char md5sum[50];
|
|
const unsigned char * MD5 = rpmfiMD5(fi);
|
|
if (!domd5(fn, md5sum, 0, NULL) && memcmp(MD5, md5sum, 16)) {
|
|
fi->actions[i] = FA_BACKUP;
|
|
break;
|
|
}
|
|
}
|
|
fi->actions[i] = FA_ERASE;
|
|
break;
|
|
}
|
|
|
|
/* Update disk space info for a file. */
|
|
rpmtsUpdateDSI(ts, fiFps->entry->dev, rpmfiFSize(fi),
|
|
fi->replacedSizes[i], fixupSize, fi->actions[i]);
|
|
|
|
}
|
|
ps = rpmpsFree(ps);
|
|
}
|
|
|
|
/**
|
|
* Ensure that current package is newer than installed package.
|
|
* @param ts transaction set
|
|
* @param p current transaction element
|
|
* @param h installed header
|
|
* @return 0 if not newer, 1 if okay
|
|
*/
|
|
static int ensureOlder(rpmts ts,
|
|
const rpmte p, const Header h)
|
|
{
|
|
int32_t reqFlags = (RPMSENSE_LESS | RPMSENSE_EQUAL);
|
|
const char * reqEVR;
|
|
rpmds req;
|
|
char * t;
|
|
int nb;
|
|
int rc;
|
|
|
|
if (p == NULL || h == NULL)
|
|
return 1;
|
|
|
|
nb = strlen(rpmteNEVR(p)) + (rpmteE(p) != NULL ? strlen(rpmteE(p)) : 0) + 1;
|
|
t = alloca(nb);
|
|
*t = '\0';
|
|
reqEVR = t;
|
|
if (rpmteE(p) != NULL) t = stpcpy( stpcpy(t, rpmteE(p)), ":");
|
|
if (rpmteV(p) != NULL) t = stpcpy(t, rpmteV(p));
|
|
*t++ = '-';
|
|
if (rpmteR(p) != NULL) t = stpcpy(t, rpmteR(p));
|
|
|
|
req = rpmdsSingle(RPMTAG_REQUIRENAME, rpmteN(p), reqEVR, reqFlags);
|
|
rc = rpmdsNVRMatchesDep(h, req, _rpmds_nopromote);
|
|
req = rpmdsFree(req);
|
|
|
|
if (rc == 0) {
|
|
rpmps ps = rpmtsProblems(ts);
|
|
const char * altNEVR = hGetNEVRA(h, NULL);
|
|
rpmpsAppend(ps, RPMPROB_OLDPACKAGE,
|
|
rpmteNEVRA(p), rpmteKey(p),
|
|
NULL, NULL,
|
|
altNEVR,
|
|
0);
|
|
altNEVR = _free(altNEVR);
|
|
ps = rpmpsFree(ps);
|
|
rc = 1;
|
|
} else
|
|
rc = 0;
|
|
|
|
return rc;
|
|
}
|
|
|
|
/**
|
|
* Skip any files that do not match install policies.
|
|
* @param ts transaction set
|
|
* @param fi file info set
|
|
*/
|
|
/* FIX: fi->actions is modified. */
|
|
static void skipFiles(const rpmts ts, rpmfi fi)
|
|
{
|
|
uint32_t tscolor = rpmtsColor(ts);
|
|
uint32_t FColor;
|
|
int noConfigs = (rpmtsFlags(ts) & RPMTRANS_FLAG_NOCONFIGS);
|
|
int noDocs = (rpmtsFlags(ts) & RPMTRANS_FLAG_NODOCS);
|
|
char ** netsharedPaths = NULL;
|
|
const char ** languages;
|
|
const char * dn, * bn;
|
|
int dnlen, bnlen, ix;
|
|
const char * s;
|
|
int * drc;
|
|
char * dff;
|
|
int dc;
|
|
int i, j;
|
|
|
|
if (!noDocs)
|
|
noDocs = rpmExpandNumeric("%{_excludedocs}");
|
|
|
|
{ const char *tmpPath = rpmExpand("%{_netsharedpath}", NULL);
|
|
if (tmpPath && *tmpPath != '%')
|
|
netsharedPaths = splitString(tmpPath, strlen(tmpPath), ':');
|
|
tmpPath = _free(tmpPath);
|
|
}
|
|
|
|
s = rpmExpand("%{_install_langs}", NULL);
|
|
if (!(s && *s != '%'))
|
|
s = _free(s);
|
|
if (s) {
|
|
languages = (const char **) splitString(s, strlen(s), ':');
|
|
s = _free(s);
|
|
} else
|
|
languages = NULL;
|
|
|
|
/* Compute directory refcount, skip directory if now empty. */
|
|
dc = rpmfiDC(fi);
|
|
drc = alloca(dc * sizeof(*drc));
|
|
memset(drc, 0, dc * sizeof(*drc));
|
|
dff = alloca(dc * sizeof(*dff));
|
|
memset(dff, 0, dc * sizeof(*dff));
|
|
|
|
fi = rpmfiInit(fi, 0);
|
|
if (fi != NULL) /* XXX lclint */
|
|
while ((i = rpmfiNext(fi)) >= 0)
|
|
{
|
|
char ** nsp;
|
|
|
|
bn = rpmfiBN(fi);
|
|
bnlen = strlen(bn);
|
|
ix = rpmfiDX(fi);
|
|
dn = rpmfiDN(fi);
|
|
dnlen = strlen(dn);
|
|
if (dn == NULL)
|
|
continue; /* XXX can't happen */
|
|
|
|
drc[ix]++;
|
|
|
|
/* Don't bother with skipped files */
|
|
if (XFA_SKIPPING(fi->actions[i])) {
|
|
drc[ix]--; dff[ix] = 1;
|
|
continue;
|
|
}
|
|
|
|
/* Ignore colored files not in our rainbow. */
|
|
FColor = rpmfiFColor(fi);
|
|
if (tscolor && FColor && !(tscolor & FColor)) {
|
|
drc[ix]--; dff[ix] = 1;
|
|
fi->actions[i] = FA_SKIPCOLOR;
|
|
continue;
|
|
}
|
|
|
|
/*
|
|
* Skip net shared paths.
|
|
* Net shared paths are not relative to the current root (though
|
|
* they do need to take package relocations into account).
|
|
*/
|
|
for (nsp = netsharedPaths; nsp && *nsp; nsp++) {
|
|
int len;
|
|
|
|
len = strlen(*nsp);
|
|
if (dnlen >= len) {
|
|
if (strncmp(dn, *nsp, len))
|
|
continue;
|
|
/* Only directories or complete file paths can be net shared */
|
|
if (!(dn[len] == '/' || dn[len] == '\0'))
|
|
continue;
|
|
} else {
|
|
if (len < (dnlen + bnlen))
|
|
continue;
|
|
if (strncmp(dn, *nsp, dnlen))
|
|
continue;
|
|
/* Insure that only the netsharedpath basename is compared. */
|
|
if ((s = strchr((*nsp) + dnlen, '/')) != NULL && s[1] != '\0')
|
|
continue;
|
|
if (strncmp(bn, (*nsp) + dnlen, bnlen))
|
|
continue;
|
|
len = dnlen + bnlen;
|
|
/* Only directories or complete file paths can be net shared */
|
|
if (!((*nsp)[len] == '/' || (*nsp)[len] == '\0'))
|
|
continue;
|
|
}
|
|
|
|
break;
|
|
}
|
|
|
|
if (nsp && *nsp) {
|
|
drc[ix]--; dff[ix] = 1;
|
|
fi->actions[i] = FA_SKIPNETSHARED;
|
|
continue;
|
|
}
|
|
|
|
/*
|
|
* Skip i18n language specific files.
|
|
*/
|
|
if (languages != NULL && fi->flangs != NULL && *fi->flangs[i]) {
|
|
const char **lang, *l, *le;
|
|
for (lang = languages; *lang != NULL; lang++) {
|
|
if (!strcmp(*lang, "all"))
|
|
break;
|
|
for (l = fi->flangs[i]; *l != '\0'; l = le) {
|
|
for (le = l; *le != '\0' && *le != '|'; le++)
|
|
{};
|
|
if ((le-l) > 0 && !strncmp(*lang, l, (le-l)))
|
|
break;
|
|
if (*le == '|') le++; /* skip over | */
|
|
}
|
|
if (*l != '\0')
|
|
break;
|
|
}
|
|
if (*lang == NULL) {
|
|
drc[ix]--; dff[ix] = 1;
|
|
fi->actions[i] = FA_SKIPNSTATE;
|
|
continue;
|
|
}
|
|
}
|
|
|
|
/*
|
|
* Skip config files if requested.
|
|
*/
|
|
if (noConfigs && (rpmfiFFlags(fi) & RPMFILE_CONFIG)) {
|
|
drc[ix]--; dff[ix] = 1;
|
|
fi->actions[i] = FA_SKIPNSTATE;
|
|
continue;
|
|
}
|
|
|
|
/*
|
|
* Skip documentation if requested.
|
|
*/
|
|
if (noDocs && (rpmfiFFlags(fi) & RPMFILE_DOC)) {
|
|
drc[ix]--; dff[ix] = 1;
|
|
fi->actions[i] = FA_SKIPNSTATE;
|
|
continue;
|
|
}
|
|
}
|
|
|
|
/* Skip (now empty) directories that had skipped files. */
|
|
#ifndef NOTYET
|
|
if (fi != NULL) /* XXX can't happen */
|
|
for (j = 0; j < dc; j++)
|
|
#else
|
|
if ((fi = rpmfiInitD(fi)) != NULL)
|
|
while (j = rpmfiNextD(fi) >= 0)
|
|
#endif
|
|
{
|
|
|
|
if (drc[j]) continue; /* dir still has files. */
|
|
if (!dff[j]) continue; /* dir was not emptied here. */
|
|
|
|
/* Find parent directory and basename. */
|
|
dn = fi->dnl[j]; dnlen = strlen(dn) - 1;
|
|
bn = dn + dnlen; bnlen = 0;
|
|
while (bn > dn && bn[-1] != '/') {
|
|
bnlen++;
|
|
dnlen--;
|
|
bn--;
|
|
}
|
|
|
|
/* If explicitly included in the package, skip the directory. */
|
|
fi = rpmfiInit(fi, 0);
|
|
if (fi != NULL) /* XXX lclint */
|
|
while ((i = rpmfiNext(fi)) >= 0) {
|
|
const char * fdn, * fbn;
|
|
int16_t fFMode;
|
|
|
|
if (XFA_SKIPPING(fi->actions[i]))
|
|
continue;
|
|
|
|
fFMode = rpmfiFMode(fi);
|
|
|
|
if (rpmfiWhatis(fFMode) != XDIR)
|
|
continue;
|
|
fdn = rpmfiDN(fi);
|
|
if (strlen(fdn) != dnlen)
|
|
continue;
|
|
if (strncmp(fdn, dn, dnlen))
|
|
continue;
|
|
fbn = rpmfiBN(fi);
|
|
if (strlen(fbn) != bnlen)
|
|
continue;
|
|
if (strncmp(fbn, bn, bnlen))
|
|
continue;
|
|
rpmlog(RPMLOG_DEBUG, _("excluding directory %s\n"), dn);
|
|
fi->actions[i] = FA_SKIPNSTATE;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (netsharedPaths) freeSplitString(netsharedPaths);
|
|
#ifdef DYING /* XXX freeFi will deal with this later. */
|
|
fi->flangs = _free(fi->flangs);
|
|
#endif
|
|
if (languages) freeSplitString((char **)languages);
|
|
}
|
|
|
|
/**
|
|
* Return transaction element's file info.
|
|
* @todo Take a rpmfi refcount here.
|
|
* @param tsi transaction element iterator
|
|
* @return transaction element file info
|
|
*/
|
|
static
|
|
rpmfi rpmtsiFi(const rpmtsi tsi)
|
|
{
|
|
rpmfi fi = NULL;
|
|
|
|
if (tsi != NULL && tsi->ocsave != -1) {
|
|
/* FIX: rpmte not opaque */
|
|
rpmte te = rpmtsElement(tsi->ts, tsi->ocsave);
|
|
if (te != NULL && (fi = te->fi) != NULL)
|
|
fi->te = te;
|
|
}
|
|
return fi;
|
|
}
|
|
|
|
/**
|
|
* This is not a generalized function to be called from outside
|
|
* librpm. It is called internally by rpmtsRun() to rollback
|
|
* a failed transaction.
|
|
* @param rollbackTransaction rollback transaction
|
|
* @return RPMRC_OK, or RPMRC_FAIL
|
|
*/
|
|
static rpmRC _rpmtsRollback(rpmts rollbackTransaction)
|
|
{
|
|
int rc = 0;
|
|
int numAdded = 0;
|
|
int numRemoved = 0;
|
|
int32_t tid;
|
|
rpmtsi tsi;
|
|
rpmte te;
|
|
rpmps ps;
|
|
|
|
/*
|
|
* Gather information about this rollback transaction for reporting.
|
|
* 1) Get tid
|
|
*/
|
|
tid = rpmtsGetTid(rollbackTransaction);
|
|
|
|
/*
|
|
* 2) Get number of install elments and erase elements
|
|
*/
|
|
tsi = rpmtsiInit(rollbackTransaction);
|
|
while((te = rpmtsiNext(tsi, 0)) != NULL) {
|
|
switch (rpmteType(te)) {
|
|
case TR_ADDED:
|
|
numAdded++;
|
|
break;
|
|
case TR_REMOVED:
|
|
numRemoved++;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
tsi = rpmtsiFree(tsi);
|
|
|
|
rpmlog(RPMLOG_NOTICE, _("Transaction failed...rolling back\n"));
|
|
rpmlog(RPMLOG_NOTICE,
|
|
_("Rollback packages (+%d/-%d) to %-24.24s (0x%08x):\n"),
|
|
numAdded, numRemoved, ctime((time_t*) &tid), tid);
|
|
|
|
/* Check the transaction to see if it is doable */
|
|
rc = rpmtsCheck(rollbackTransaction);
|
|
ps = rpmtsProblems(rollbackTransaction);
|
|
if (rc != 0 && rpmpsNumProblems(ps) > 0) {
|
|
rpmlog(RPMLOG_ERR, _("Failed dependencies:\n"));
|
|
rpmpsPrint(NULL, ps);
|
|
ps = rpmpsFree(ps);
|
|
return -1;
|
|
}
|
|
ps = rpmpsFree(ps);
|
|
|
|
/* Order the transaction */
|
|
rc = rpmtsOrder(rollbackTransaction);
|
|
if (rc != 0) {
|
|
rpmlog(RPMLOG_ERR,
|
|
_("Could not order auto-rollback transaction!\n"));
|
|
return -1;
|
|
}
|
|
|
|
|
|
|
|
/* Run the transaction and print any problems
|
|
* We want to stay with the original transactions flags except
|
|
* that we want to add what is essentially a force.
|
|
* This handles two things in particular:
|
|
*
|
|
* 1. We we want to upgrade over a newer package.
|
|
* 2. If a header for the old package is there we
|
|
* we want to replace it. No questions asked.
|
|
*/
|
|
rc = rpmtsRun(rollbackTransaction, NULL,
|
|
RPMPROB_FILTER_REPLACEPKG
|
|
| RPMPROB_FILTER_REPLACEOLDFILES
|
|
| RPMPROB_FILTER_REPLACENEWFILES
|
|
| RPMPROB_FILTER_OLDPACKAGE
|
|
);
|
|
ps = rpmtsProblems(rollbackTransaction);
|
|
if (rc > 0 && rpmpsNumProblems(ps) > 0)
|
|
rpmpsPrint(stderr, ps);
|
|
ps = rpmpsFree(ps);
|
|
|
|
/*
|
|
* After we have ran through the transaction we need to
|
|
* remove any repackaged packages we just installed/upgraded
|
|
* from the rp repository.
|
|
*/
|
|
tsi = rpmtsiInit(rollbackTransaction);
|
|
while((te = rpmtsiNext(tsi, 0)) != NULL) {
|
|
fnpyKey key = NULL;
|
|
rpmlog(RPMLOG_NOTICE, _("Cleaning up repackaged packages:\n"));
|
|
switch (rpmteType(te)) {
|
|
/* The install elements are repackaged packages */
|
|
case TR_ADDED:
|
|
/* Make sure the filename is still there. XXX: Can't happen */
|
|
key = rpmteKey(te);
|
|
if(key) {
|
|
rpmlog(RPMLOG_NOTICE, _("\tRemoving %s:\n"), key);
|
|
(void) unlink(key); /* XXX: Should check for an error? */
|
|
}
|
|
break;
|
|
|
|
/* Ignore erase elements...nothing to do */
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
tsi = rpmtsiFree(tsi);
|
|
|
|
/* Free the rollback transaction */
|
|
rollbackTransaction = rpmtsFree(rollbackTransaction);
|
|
|
|
return rc;
|
|
}
|
|
|
|
/**
|
|
* Get the repackaged header and filename from the repackage directory.
|
|
* @todo Find a suitable home for this function.
|
|
* @todo This function creates an IDTX everytime it is called. Needs to
|
|
* be made more efficient (only create on per running transaction).
|
|
* @param ts rpm transaction
|
|
* @param te transaction element
|
|
* @retval hdrp Repackaged header
|
|
* @retval fnp Repackaged package's path (transaction key)
|
|
* @return RPMRC_NOTFOUND or RPMRC_OK
|
|
*/
|
|
static rpmRC getRepackageHeaderFromTE(rpmts ts, rpmte te,
|
|
Header *hdrp,
|
|
const char **fnp)
|
|
{
|
|
int32_t tid;
|
|
const char * name;
|
|
const char * rpname = NULL;
|
|
const char * _repackage_dir = NULL;
|
|
const char * globStr = "-*.rpm";
|
|
char * rp = NULL; /* Rollback package name */
|
|
IDTX rtids = NULL;
|
|
IDT rpIDT;
|
|
int nrids = 0;
|
|
int nb; /* Number of bytes */
|
|
Header h = NULL;
|
|
int rc = RPMRC_NOTFOUND; /* Assume we do not find it*/
|
|
int xx;
|
|
|
|
rpmlog(RPMLOG_DEBUG,
|
|
_("Getting repackaged header from transaction element\n"));
|
|
|
|
/* Set header pointer to null if its not already */
|
|
if (hdrp)
|
|
*hdrp = NULL;
|
|
if (fnp)
|
|
*fnp = NULL;
|
|
|
|
/* Get the TID of the current transaction */
|
|
tid = rpmtsGetTid(ts);
|
|
/* Need the repackage dir if the user want to
|
|
* rollback on a failure.
|
|
*/
|
|
_repackage_dir = rpmExpand("%{?_repackage_dir}", NULL);
|
|
if (_repackage_dir == NULL) goto exit;
|
|
|
|
/* Build the glob string to find the possible repackaged
|
|
* packages for this package.
|
|
*/
|
|
name = rpmteN(te);
|
|
nb = strlen(_repackage_dir) + strlen(name) + strlen(globStr) + 2;
|
|
rp = memset((char *) malloc(nb), 0, nb);
|
|
xx = snprintf(rp, nb, "%s/%s%s.rpm", _repackage_dir, name, globStr);
|
|
|
|
/* Get the index of possible repackaged packages */
|
|
rpmlog(RPMLOG_DEBUG, _("\tLooking for %s...\n"), rp);
|
|
rtids = IDTXglob(ts, rp, RPMTAG_REMOVETID);
|
|
rp = _free(rp);
|
|
if (rtids != NULL) {
|
|
rpmlog(RPMLOG_DEBUG, _("\tMatches found.\n"));
|
|
rpIDT = rtids->idt;
|
|
nrids = rtids->nidt;
|
|
} else {
|
|
rpmlog(RPMLOG_DEBUG, _("\tNo matches found.\n"));
|
|
goto exit;
|
|
}
|
|
|
|
/* Now walk through index until we find the package (or we have
|
|
* exhausted the index.
|
|
*/
|
|
do {
|
|
/* If index is null we have exhausted the list and need to
|
|
* get out of here...the repackaged package was not found.
|
|
*/
|
|
if (rpIDT == NULL) {
|
|
rpmlog(RPMLOG_DEBUG, _("\tRepackaged package not found!.\n"));
|
|
break;
|
|
}
|
|
|
|
/* Is this the same tid. If not decrement the list and continue */
|
|
if (rpIDT->val.u32 != tid) {
|
|
nrids--;
|
|
if (nrids > 0)
|
|
rpIDT++;
|
|
else
|
|
rpIDT = NULL;
|
|
continue;
|
|
}
|
|
|
|
/* OK, the tid matches. Now lets see if the name is the same.
|
|
* If I could not get the name from the package, I will go onto
|
|
* the next one. Perhaps I should return an error at this
|
|
* point, but if this was not the correct one, at least the correct one
|
|
* would be found.
|
|
* XXX: Should Match NAC!
|
|
*/
|
|
rpmlog(RPMLOG_DEBUG, _("\tREMOVETID matched INSTALLTID.\n"));
|
|
if (headerGetEntry(rpIDT->h, RPMTAG_NAME, NULL, (void **) &rpname, NULL)) {
|
|
rpmlog(RPMLOG_DEBUG, _("\t\tName: %s.\n"), rpname);
|
|
if (!strcmp(name,rpname)) {
|
|
/* It matched we have a canidate */
|
|
h = headerLink(rpIDT->h);
|
|
nb = strlen(rpIDT->key) + 1;
|
|
rp = memset((char *) malloc(nb), 0, nb);
|
|
rp = strncat(rp, rpIDT->key, nb);
|
|
rc = RPMRC_OK;
|
|
break;
|
|
}
|
|
}
|
|
|
|
/* Decrement list */
|
|
nrids--;
|
|
if (nrids > 0)
|
|
rpIDT++;
|
|
else
|
|
rpIDT = NULL;
|
|
} while (1);
|
|
|
|
exit:
|
|
if (rc != RPMRC_NOTFOUND && h != NULL && hdrp != NULL) {
|
|
rpmlog(RPMLOG_DEBUG, _("\tRepackaged Package was %s...\n"), rp);
|
|
if (hdrp != NULL)
|
|
*hdrp = headerLink(h);
|
|
if (fnp != NULL)
|
|
*fnp = rp;
|
|
else
|
|
rp = _free(rp);
|
|
}
|
|
if (h != NULL)
|
|
h = headerFree(h);
|
|
rtids = IDTXfree(rtids);
|
|
return rc;
|
|
}
|
|
|
|
/**
|
|
* This is not a generalized function to be called from outside
|
|
* librpm. It is called internally by rpmtsRun() to add elements
|
|
* to its autorollback transaction.
|
|
* @param rollbackTransaction rollback transaction
|
|
* @param runningTransaction running transaction (the one you want to rollback)
|
|
* @param te Transaction element.
|
|
* @return RPMRC_OK, or RPMRC_FAIL
|
|
*/
|
|
static rpmRC _rpmtsAddRollbackElement(rpmts rollbackTransaction,
|
|
rpmts runningTransaction, rpmte te)
|
|
{
|
|
Header h = NULL;
|
|
Header rph = NULL;
|
|
const char * rpn;
|
|
unsigned int db_instance = 0;
|
|
rpmtsi pi;
|
|
rpmte p;
|
|
int rc = RPMRC_FAIL; /* Assume Failure */
|
|
|
|
switch(rpmteType(te)) {
|
|
case TR_ADDED:
|
|
{ rpmdbMatchIterator mi;
|
|
|
|
rpmlog(RPMLOG_DEBUG,
|
|
_("Adding install element to auto-rollback transaction.\n"));
|
|
|
|
/* Get the header for this package from the database
|
|
* First get the database instance (the key).
|
|
*/
|
|
db_instance = rpmteDBInstance(te);
|
|
if (db_instance == 0) {
|
|
/* Could not get the db instance: WTD! */
|
|
rpmlog(RPMLOG_CRIT,
|
|
_("Could not get install element database instance!\n"));
|
|
break;
|
|
}
|
|
|
|
/* Now suck the header out of the database */
|
|
mi = rpmtsInitIterator(rollbackTransaction,
|
|
RPMDBI_PACKAGES, &db_instance, sizeof(db_instance));
|
|
h = rpmdbNextIterator(mi);
|
|
if (h != NULL) h = headerLink(h);
|
|
mi = rpmdbFreeIterator(mi);
|
|
if (h == NULL) {
|
|
/* Header was not there??? */
|
|
rpmlog(RPMLOG_CRIT,
|
|
_("Could not get header for auto-rollback transaction!\n"));
|
|
break;
|
|
}
|
|
|
|
/* Now see if there is a repackaged package for this */
|
|
rc = getRepackageHeaderFromTE(runningTransaction, te, &rph, &rpn);
|
|
switch(rc) {
|
|
case RPMRC_OK:
|
|
/* Add the install element, as we had a repackaged package */
|
|
rpmlog(RPMLOG_DEBUG,
|
|
_("\tAdded repackaged package header: %s.\n"), rpn);
|
|
rpmlog(RPMLOG_DEBUG,
|
|
_("\tAdded from install element %s.\n"), rpmteNEVRA(te));
|
|
rc = rpmtsAddInstallElement(rollbackTransaction, headerLink(rph),
|
|
(fnpyKey) rpn, 1, te->relocs);
|
|
break;
|
|
|
|
case RPMRC_NOTFOUND:
|
|
/* Add the header as an erase element, we did not
|
|
* have a repackaged package
|
|
*/
|
|
rpmlog(RPMLOG_DEBUG, _("\tAdded erase element.\n"));
|
|
rpmlog(RPMLOG_DEBUG,
|
|
_("\tAdded from install element %s.\n"), rpmteNEVRA(te));
|
|
rc = rpmtsAddEraseElement(rollbackTransaction, h, db_instance);
|
|
break;
|
|
|
|
default:
|
|
/* Not sure what to do on failure...just give up */
|
|
rpmlog(RPMLOG_CRIT,
|
|
_("Could not get repackaged header for auto-rollback transaction!\n"));
|
|
break;
|
|
}
|
|
} break;
|
|
|
|
case TR_REMOVED:
|
|
rpmlog(RPMLOG_DEBUG,
|
|
_("Add erase element to auto-rollback transaction.\n"));
|
|
/* See if this element has already been added.
|
|
* If so we want to do nothing. Compare N's for match.
|
|
* XXX: Really should compare NAC's.
|
|
*/
|
|
pi = rpmtsiInit(rollbackTransaction);
|
|
while ((p = rpmtsiNext(pi, 0)) != NULL) {
|
|
if (!strcmp(rpmteN(p), rpmteN(te))) {
|
|
rpmlog(RPMLOG_DEBUG, _("\tFound existing upgrade element.\n"));
|
|
rpmlog(RPMLOG_DEBUG, _("\tNot adding erase element for %s.\n"),
|
|
rpmteN(te));
|
|
rc = RPMRC_OK;
|
|
pi = rpmtsiFree(pi);
|
|
goto cleanup;
|
|
}
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
|
|
/* Get the repackage header from the current transaction
|
|
* element.
|
|
*/
|
|
rc = getRepackageHeaderFromTE(runningTransaction, te, &rph, &rpn);
|
|
switch(rc) {
|
|
case RPMRC_OK:
|
|
/* Add the install element */
|
|
rpmlog(RPMLOG_DEBUG,
|
|
_("\tAdded repackaged package %s.\n"), rpn);
|
|
rpmlog(RPMLOG_DEBUG,
|
|
_("\tAdded from erase element %s.\n"), rpmteNEVRA(te));
|
|
rc = rpmtsAddInstallElement(rollbackTransaction, rph,
|
|
(fnpyKey) rpn, 1, te->relocs);
|
|
if (rc != RPMRC_OK)
|
|
rpmlog(RPMLOG_CRIT,
|
|
_("Could not add erase element to auto-rollback transaction.\n"));
|
|
break;
|
|
|
|
case RPMRC_NOTFOUND:
|
|
/* Just did not have a repackaged package */
|
|
rpmlog(RPMLOG_DEBUG,
|
|
_("\tNo repackaged package...nothing to do.\n"));
|
|
rc = RPMRC_OK;
|
|
break;
|
|
|
|
default:
|
|
rpmlog(RPMLOG_CRIT,
|
|
_("Failure reading repackaged package!\n"));
|
|
break;
|
|
}
|
|
break;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
|
|
/* XXX: I want to free this, but if I do then the consumers of
|
|
* are hosed. Just leaving you a little note Jeff, so you
|
|
* know that this does introduce a memory leak. I wanted
|
|
* keep the patch as simple as possible so I am not fixxing
|
|
* the leak.
|
|
* if (rpn != NULL)
|
|
* free(rpn);
|
|
*/
|
|
|
|
cleanup:
|
|
/* Clean up */
|
|
if (h != NULL)
|
|
h = headerFree(h);
|
|
if (rph != NULL)
|
|
rph = headerFree(rph);
|
|
return rc;
|
|
}
|
|
|
|
#define NOTIFY(_ts, _al) if ((_ts)->notify) (void) (_ts)->notify _al
|
|
|
|
int rpmtsRun(rpmts ts, rpmps okProbs, rpmprobFilterFlags ignoreSet)
|
|
{
|
|
uint32_t tscolor = rpmtsColor(ts);
|
|
int i, j;
|
|
int ourrc = 0;
|
|
int totalFileCount = 0;
|
|
rpmfi fi;
|
|
sharedFileInfo shared, sharedList;
|
|
int numShared;
|
|
int nexti;
|
|
rpmalKey lastFailKey;
|
|
fingerPrintCache fpc;
|
|
rpmps ps;
|
|
rpmpsm psm;
|
|
rpmtsi pi; rpmte p;
|
|
rpmtsi qi; rpmte q;
|
|
int numAdded;
|
|
int numRemoved;
|
|
rpmts rollbackTransaction = NULL;
|
|
int rollbackOnFailure = 0;
|
|
void * lock = NULL;
|
|
int xx;
|
|
|
|
/* XXX programmer error segfault avoidance. */
|
|
if (rpmtsNElements(ts) <= 0)
|
|
return -1;
|
|
|
|
/* See if we need to rollback on failure */
|
|
rollbackOnFailure = rpmExpandNumeric(
|
|
"%{?_rollback_transaction_on_failure}");
|
|
if (rpmtsGetType(ts) & (RPMTRANS_TYPE_ROLLBACK
|
|
| RPMTRANS_TYPE_AUTOROLLBACK)) {
|
|
rollbackOnFailure = 0;
|
|
}
|
|
/* If we are in test mode, there is no need to rollback on
|
|
* failure, nor acquire the transaction lock.
|
|
*/
|
|
/* If we are in test mode, then there's no need for transaction lock. */
|
|
if (rpmtsFlags(ts) & RPMTRANS_FLAG_TEST) {
|
|
rollbackOnFailure = 0;
|
|
} else {
|
|
lock = rpmtsAcquireLock(ts);
|
|
if (lock == NULL)
|
|
return -1; /* XXX W2DO? */
|
|
}
|
|
|
|
if (rpmtsFlags(ts) & RPMTRANS_FLAG_NOSCRIPTS)
|
|
(void) rpmtsSetFlags(ts, (rpmtsFlags(ts) | _noTransScripts | _noTransTriggers));
|
|
if (rpmtsFlags(ts) & RPMTRANS_FLAG_NOTRIGGERS)
|
|
(void) rpmtsSetFlags(ts, (rpmtsFlags(ts) | _noTransTriggers));
|
|
|
|
if (rpmtsFlags(ts) & RPMTRANS_FLAG_JUSTDB)
|
|
(void) rpmtsSetFlags(ts, (rpmtsFlags(ts) | _noTransScripts | _noTransTriggers));
|
|
|
|
/* if SELinux isn't enabled or init fails, don't bother... */
|
|
if (!rpmtsSELinuxEnabled(ts)) {
|
|
rpmtsSetFlags(ts, (rpmtsFlags(ts) | RPMTRANS_FLAG_NOCONTEXTS));
|
|
}
|
|
|
|
if (!rpmtsFlags(ts) & RPMTRANS_FLAG_NOCONTEXTS) {
|
|
const char *fn = rpmGetPath("%{?_install_file_context_path}", NULL);
|
|
if (matchpathcon_init(fn) == -1) {
|
|
rpmtsSetFlags(ts, (rpmtsFlags(ts) | RPMTRANS_FLAG_NOCONTEXTS));
|
|
}
|
|
_free(fn);
|
|
}
|
|
|
|
ts->probs = rpmpsFree(ts->probs);
|
|
ts->probs = rpmpsCreate();
|
|
|
|
/* XXX Make sure the database is open RDWR for package install/erase. */
|
|
{ int dbmode = (rpmtsFlags(ts) & RPMTRANS_FLAG_TEST)
|
|
? O_RDONLY : (O_RDWR|O_CREAT);
|
|
|
|
/* Open database RDWR for installing packages. */
|
|
if (rpmtsOpenDB(ts, dbmode)) {
|
|
rpmtsFreeLock(lock);
|
|
return -1; /* XXX W2DO? */
|
|
}
|
|
}
|
|
|
|
ts->ignoreSet = ignoreSet;
|
|
{ const char * currDir = currentDirectory();
|
|
rpmtsSetCurrDir(ts, currDir);
|
|
currDir = _free(currDir);
|
|
}
|
|
|
|
(void) rpmtsSetChrootDone(ts, 0);
|
|
|
|
{ int32_t tid = (int32_t) time(NULL);
|
|
(void) rpmtsSetTid(ts, tid);
|
|
}
|
|
|
|
/* Get available space on mounted file systems. */
|
|
xx = rpmtsInitDSI(ts);
|
|
|
|
/* ===============================================
|
|
* For packages being installed:
|
|
* - verify package arch/os.
|
|
* - verify package epoch:version-release is newer.
|
|
* - count files.
|
|
* For packages being removed:
|
|
* - count files.
|
|
*/
|
|
|
|
rpmlog(RPMLOG_DEBUG, _("sanity checking %d elements\n"), rpmtsNElements(ts));
|
|
ps = rpmtsProblems(ts);
|
|
/* The ordering doesn't matter here */
|
|
pi = rpmtsiInit(ts);
|
|
/* XXX Only added packages need be checked. */
|
|
while ((p = rpmtsiNext(pi, TR_ADDED)) != NULL) {
|
|
rpmdbMatchIterator mi;
|
|
int fc;
|
|
|
|
if ((fi = rpmtsiFi(pi)) == NULL)
|
|
continue; /* XXX can't happen */
|
|
fc = rpmfiFC(fi);
|
|
|
|
if (!(rpmtsFilterFlags(ts) & RPMPROB_FILTER_IGNOREARCH) && !tscolor)
|
|
if (!archOkay(rpmteA(p)))
|
|
rpmpsAppend(ps, RPMPROB_BADARCH,
|
|
rpmteNEVRA(p), rpmteKey(p),
|
|
rpmteA(p), NULL,
|
|
NULL, 0);
|
|
|
|
if (!(rpmtsFilterFlags(ts) & RPMPROB_FILTER_IGNOREOS))
|
|
if (!osOkay(rpmteO(p)))
|
|
rpmpsAppend(ps, RPMPROB_BADOS,
|
|
rpmteNEVRA(p), rpmteKey(p),
|
|
rpmteO(p), NULL,
|
|
NULL, 0);
|
|
|
|
if (!(rpmtsFilterFlags(ts) & RPMPROB_FILTER_OLDPACKAGE)) {
|
|
Header h;
|
|
mi = rpmtsInitIterator(ts, RPMTAG_NAME, rpmteN(p), 0);
|
|
while ((h = rpmdbNextIterator(mi)) != NULL)
|
|
xx = ensureOlder(ts, p, h);
|
|
mi = rpmdbFreeIterator(mi);
|
|
}
|
|
|
|
if (!(rpmtsFilterFlags(ts) & RPMPROB_FILTER_REPLACEPKG)) {
|
|
mi = rpmtsInitIterator(ts, RPMTAG_NAME, rpmteN(p), 0);
|
|
xx = rpmdbSetIteratorRE(mi, RPMTAG_EPOCH, RPMMIRE_STRCMP,
|
|
rpmteE(p));
|
|
xx = rpmdbSetIteratorRE(mi, RPMTAG_VERSION, RPMMIRE_STRCMP,
|
|
rpmteV(p));
|
|
xx = rpmdbSetIteratorRE(mi, RPMTAG_RELEASE, RPMMIRE_STRCMP,
|
|
rpmteR(p));
|
|
if (tscolor) {
|
|
xx = rpmdbSetIteratorRE(mi, RPMTAG_ARCH, RPMMIRE_STRCMP,
|
|
rpmteA(p));
|
|
xx = rpmdbSetIteratorRE(mi, RPMTAG_OS, RPMMIRE_STRCMP,
|
|
rpmteO(p));
|
|
}
|
|
|
|
while (rpmdbNextIterator(mi) != NULL) {
|
|
rpmpsAppend(ps, RPMPROB_PKG_INSTALLED,
|
|
rpmteNEVRA(p), rpmteKey(p),
|
|
NULL, NULL,
|
|
NULL, 0);
|
|
break;
|
|
}
|
|
mi = rpmdbFreeIterator(mi);
|
|
}
|
|
|
|
/* Count no. of files (if any). */
|
|
totalFileCount += fc;
|
|
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
ps = rpmpsFree(ps);
|
|
|
|
/* The ordering doesn't matter here */
|
|
pi = rpmtsiInit(ts);
|
|
while ((p = rpmtsiNext(pi, TR_REMOVED)) != NULL) {
|
|
int fc;
|
|
|
|
if ((fi = rpmtsiFi(pi)) == NULL)
|
|
continue; /* XXX can't happen */
|
|
fc = rpmfiFC(fi);
|
|
|
|
totalFileCount += fc;
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
|
|
|
|
/* Run pre-transaction scripts, but only if there are no known
|
|
* problems up to this point. */
|
|
if (!((rpmtsFlags(ts) & (RPMTRANS_FLAG_BUILD_PROBS|RPMTRANS_FLAG_TEST))
|
|
|| (rpmpsNumProblems(ts->probs) &&
|
|
(okProbs == NULL || rpmpsTrim(ts->probs, okProbs))))) {
|
|
rpmlog(RPMLOG_DEBUG, _("running pre-transaction scripts\n"));
|
|
pi = rpmtsiInit(ts);
|
|
while ((p = rpmtsiNext(pi, TR_ADDED)) != NULL) {
|
|
if ((fi = rpmtsiFi(pi)) == NULL)
|
|
continue; /* XXX can't happen */
|
|
|
|
/* If no pre-transaction script, then don't bother. */
|
|
if (fi->pretrans == NULL)
|
|
continue;
|
|
|
|
p->fd = ts->notify(p->h, RPMCALLBACK_INST_OPEN_FILE, 0, 0,
|
|
rpmteKey(p), ts->notifyData);
|
|
p->h = NULL;
|
|
if (rpmteFd(p) != NULL) {
|
|
rpmVSFlags ovsflags = rpmtsVSFlags(ts);
|
|
rpmVSFlags vsflags = ovsflags | RPMVSF_NEEDPAYLOAD;
|
|
rpmRC rpmrc;
|
|
ovsflags = rpmtsSetVSFlags(ts, vsflags);
|
|
rpmrc = rpmReadPackageFile(ts, rpmteFd(p),
|
|
rpmteNEVR(p), &p->h);
|
|
vsflags = rpmtsSetVSFlags(ts, ovsflags);
|
|
switch (rpmrc) {
|
|
default:
|
|
/* FIX: notify annotations */
|
|
p->fd = ts->notify(p->h, RPMCALLBACK_INST_CLOSE_FILE,
|
|
0, 0,
|
|
rpmteKey(p), ts->notifyData);
|
|
p->fd = NULL;
|
|
break;
|
|
case RPMRC_NOTTRUSTED:
|
|
case RPMRC_NOKEY:
|
|
case RPMRC_OK:
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (rpmteFd(p) != NULL) {
|
|
fi = rpmfiNew(ts, p->h, RPMTAG_BASENAMES, 1);
|
|
if (fi != NULL) { /* XXX can't happen */
|
|
fi->te = p;
|
|
p->fi = fi;
|
|
}
|
|
psm = rpmpsmNew(ts, p, p->fi);
|
|
assert(psm != NULL);
|
|
psm->scriptTag = RPMTAG_PRETRANS;
|
|
psm->progTag = RPMTAG_PRETRANSPROG;
|
|
xx = rpmpsmStage(psm, PSM_SCRIPT);
|
|
psm = rpmpsmFree(psm);
|
|
|
|
(void) ts->notify(p->h, RPMCALLBACK_INST_CLOSE_FILE, 0, 0,
|
|
rpmteKey(p), ts->notifyData);
|
|
p->fd = NULL;
|
|
p->h = headerFree(p->h);
|
|
}
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
}
|
|
|
|
/* ===============================================
|
|
* Initialize transaction element file info for package:
|
|
*/
|
|
|
|
/*
|
|
* FIXME?: we'd be better off assembling one very large file list and
|
|
* calling fpLookupList only once. I'm not sure that the speedup is
|
|
* worth the trouble though.
|
|
*/
|
|
rpmlog(RPMLOG_DEBUG, _("computing %d file fingerprints\n"), totalFileCount);
|
|
|
|
numAdded = numRemoved = 0;
|
|
pi = rpmtsiInit(ts);
|
|
while ((p = rpmtsiNext(pi, 0)) != NULL) {
|
|
int fc;
|
|
|
|
if ((fi = rpmtsiFi(pi)) == NULL)
|
|
continue; /* XXX can't happen */
|
|
fc = rpmfiFC(fi);
|
|
|
|
switch (rpmteType(p)) {
|
|
case TR_ADDED:
|
|
numAdded++;
|
|
fi->record = 0;
|
|
/* Skip netshared paths, not our i18n files, and excluded docs */
|
|
if (fc > 0)
|
|
skipFiles(ts, fi);
|
|
break;
|
|
case TR_REMOVED:
|
|
numRemoved++;
|
|
fi->record = rpmteDBOffset(p);
|
|
break;
|
|
}
|
|
|
|
fi->fps = (fc > 0 ? xmalloc(fc * sizeof(*fi->fps)) : NULL);
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
|
|
if (!rpmtsChrootDone(ts)) {
|
|
const char * rootDir = rpmtsRootDir(ts);
|
|
xx = chdir("/");
|
|
if (rootDir != NULL && strcmp(rootDir, "/") && *rootDir == '/') {
|
|
/* opening db before chroot not optimal, see rhbz#103852 c#3 */
|
|
xx = rpmdbOpenAll(ts->rdb);
|
|
xx = chroot(rootDir);
|
|
}
|
|
(void) rpmtsSetChrootDone(ts, 1);
|
|
}
|
|
|
|
ts->ht = htCreate(totalFileCount * 2, 0, 0, fpHashFunction, fpEqual);
|
|
fpc = fpCacheCreate(totalFileCount);
|
|
|
|
/* ===============================================
|
|
* Add fingerprint for each file not skipped.
|
|
*/
|
|
pi = rpmtsiInit(ts);
|
|
while ((p = rpmtsiNext(pi, 0)) != NULL) {
|
|
int fc;
|
|
|
|
(void) rpmdbCheckSignals();
|
|
|
|
if ((fi = rpmtsiFi(pi)) == NULL)
|
|
continue; /* XXX can't happen */
|
|
fc = rpmfiFC(fi);
|
|
|
|
(void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_FINGERPRINT), 0);
|
|
fpLookupList(fpc, fi->dnl, fi->bnl, fi->dil, fc, fi->fps);
|
|
fi = rpmfiInit(fi, 0);
|
|
if (fi != NULL) /* XXX lclint */
|
|
while ((i = rpmfiNext(fi)) >= 0) {
|
|
if (XFA_SKIPPING(fi->actions[i]))
|
|
continue;
|
|
htAddEntry(ts->ht, fi->fps + i, (void *) fi);
|
|
}
|
|
(void) rpmswExit(rpmtsOp(ts, RPMTS_OP_FINGERPRINT), fc);
|
|
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
|
|
NOTIFY(ts, (NULL, RPMCALLBACK_TRANS_START, 6, ts->orderCount,
|
|
NULL, ts->notifyData));
|
|
|
|
/* ===============================================
|
|
* Compute file disposition for each package in transaction set.
|
|
*/
|
|
rpmlog(RPMLOG_DEBUG, _("computing file dispositions\n"));
|
|
ps = rpmtsProblems(ts);
|
|
pi = rpmtsiInit(ts);
|
|
while ((p = rpmtsiNext(pi, 0)) != NULL) {
|
|
dbiIndexSet * matches;
|
|
int knownBad;
|
|
int fc;
|
|
|
|
(void) rpmdbCheckSignals();
|
|
|
|
if ((fi = rpmtsiFi(pi)) == NULL)
|
|
continue; /* XXX can't happen */
|
|
fc = rpmfiFC(fi);
|
|
|
|
NOTIFY(ts, (NULL, RPMCALLBACK_TRANS_PROGRESS, rpmtsiOc(pi),
|
|
ts->orderCount, NULL, ts->notifyData));
|
|
|
|
if (fc == 0) continue;
|
|
|
|
(void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_FINGERPRINT), 0);
|
|
/* Extract file info for all files in this package from the database. */
|
|
matches = xcalloc(fc, sizeof(*matches));
|
|
if (rpmdbFindFpList(rpmtsGetRdb(ts), fi->fps, matches, fc)) {
|
|
ps = rpmpsFree(ps);
|
|
rpmtsFreeLock(lock);
|
|
return 1; /* XXX WTFO? */
|
|
}
|
|
|
|
numShared = 0;
|
|
fi = rpmfiInit(fi, 0);
|
|
while ((i = rpmfiNext(fi)) >= 0)
|
|
numShared += dbiIndexSetCount(matches[i]);
|
|
|
|
/* Build sorted file info list for this package. */
|
|
shared = sharedList = xcalloc((numShared + 1), sizeof(*sharedList));
|
|
|
|
fi = rpmfiInit(fi, 0);
|
|
while ((i = rpmfiNext(fi)) >= 0) {
|
|
/*
|
|
* Take care not to mark files as replaced in packages that will
|
|
* have been removed before we will get here.
|
|
*/
|
|
for (j = 0; j < dbiIndexSetCount(matches[i]); j++) {
|
|
int ro;
|
|
ro = dbiIndexRecordOffset(matches[i], j);
|
|
knownBad = 0;
|
|
qi = rpmtsiInit(ts);
|
|
while ((q = rpmtsiNext(qi, TR_REMOVED)) != NULL) {
|
|
if (ro == knownBad)
|
|
break;
|
|
if (rpmteDBOffset(q) == ro)
|
|
knownBad = ro;
|
|
}
|
|
qi = rpmtsiFree(qi);
|
|
|
|
shared->pkgFileNum = i;
|
|
shared->otherPkg = dbiIndexRecordOffset(matches[i], j);
|
|
shared->otherFileNum = dbiIndexRecordFileNumber(matches[i], j);
|
|
shared->isRemoved = (knownBad == ro);
|
|
shared++;
|
|
}
|
|
matches[i] = dbiFreeIndexSet(matches[i]);
|
|
}
|
|
numShared = shared - sharedList;
|
|
shared->otherPkg = -1;
|
|
matches = _free(matches);
|
|
|
|
/* Sort file info by other package index (otherPkg) */
|
|
qsort(sharedList, numShared, sizeof(*shared), sharedCmp);
|
|
|
|
/* For all files from this package that are in the database ... */
|
|
for (i = 0; i < numShared; i = nexti) {
|
|
int beingRemoved;
|
|
|
|
shared = sharedList + i;
|
|
|
|
/* Find the end of the files in the other package. */
|
|
for (nexti = i + 1; nexti < numShared; nexti++) {
|
|
if (sharedList[nexti].otherPkg != shared->otherPkg)
|
|
break;
|
|
}
|
|
|
|
/* Is this file from a package being removed? */
|
|
beingRemoved = 0;
|
|
if (ts->removedPackages != NULL)
|
|
for (j = 0; j < ts->numRemovedPackages; j++) {
|
|
if (ts->removedPackages[j] != shared->otherPkg)
|
|
continue;
|
|
beingRemoved = 1;
|
|
break;
|
|
}
|
|
|
|
/* Determine the fate of each file. */
|
|
switch (rpmteType(p)) {
|
|
case TR_ADDED:
|
|
xx = handleInstInstalledFiles(ts, p, fi, shared, nexti - i,
|
|
!(beingRemoved || (rpmtsFilterFlags(ts) & RPMPROB_FILTER_REPLACEOLDFILES)));
|
|
break;
|
|
case TR_REMOVED:
|
|
if (!beingRemoved)
|
|
xx = handleRmvdInstalledFiles(ts, fi, shared, nexti - i);
|
|
break;
|
|
}
|
|
}
|
|
|
|
free(sharedList);
|
|
|
|
/* Update disk space needs on each partition for this package. */
|
|
handleOverlappedFiles(ts, p, fi);
|
|
|
|
/* Check added package has sufficient space on each partition used. */
|
|
switch (rpmteType(p)) {
|
|
case TR_ADDED:
|
|
rpmtsCheckDSIProblems(ts, p);
|
|
break;
|
|
case TR_REMOVED:
|
|
break;
|
|
}
|
|
/* check for s-bit files to be removed */
|
|
if (rpmteType(p) == TR_REMOVED) {
|
|
fi = rpmfiInit(fi, 0);
|
|
while ((i = rpmfiNext(fi)) >= 0) {
|
|
int16_t mode;
|
|
if (XFA_SKIPPING(fi->actions[i]))
|
|
continue;
|
|
(void) rpmfiSetFX(fi, i);
|
|
mode = rpmfiFMode(fi);
|
|
if (S_ISREG(mode) && (mode & 06000) != 0) {
|
|
fi->mapflags |= CPIO_SBIT_CHECK;
|
|
}
|
|
}
|
|
}
|
|
(void) rpmswExit(rpmtsOp(ts, RPMTS_OP_FINGERPRINT), fc);
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
ps = rpmpsFree(ps);
|
|
|
|
if (rpmtsChrootDone(ts)) {
|
|
const char * rootDir = rpmtsRootDir(ts);
|
|
const char * currDir = rpmtsCurrDir(ts);
|
|
if (rootDir != NULL && strcmp(rootDir, "/") && *rootDir == '/')
|
|
xx = chroot(".");
|
|
(void) rpmtsSetChrootDone(ts, 0);
|
|
if (currDir != NULL)
|
|
xx = chdir(currDir);
|
|
}
|
|
|
|
NOTIFY(ts, (NULL, RPMCALLBACK_TRANS_STOP, 6, ts->orderCount,
|
|
NULL, ts->notifyData));
|
|
|
|
/* ===============================================
|
|
* Free unused memory as soon as possible.
|
|
*/
|
|
pi = rpmtsiInit(ts);
|
|
while ((p = rpmtsiNext(pi, 0)) != NULL) {
|
|
if ((fi = rpmtsiFi(pi)) == NULL)
|
|
continue; /* XXX can't happen */
|
|
if (rpmfiFC(fi) == 0)
|
|
continue;
|
|
fi->fps = _free(fi->fps);
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
|
|
fpc = fpCacheFree(fpc);
|
|
ts->ht = htFree(ts->ht);
|
|
|
|
/* ===============================================
|
|
* If unfiltered problems exist, free memory and return.
|
|
*/
|
|
if ((rpmtsFlags(ts) & RPMTRANS_FLAG_BUILD_PROBS)
|
|
|| (rpmpsNumProblems(ts->probs) &&
|
|
(okProbs == NULL || rpmpsTrim(ts->probs, okProbs)))
|
|
)
|
|
{
|
|
rpmtsFreeLock(lock);
|
|
return ts->orderCount;
|
|
}
|
|
|
|
/* ===============================================
|
|
* If we were requested to rollback this transaction
|
|
* if an error occurs, then we need to create a
|
|
* a rollback transaction.
|
|
*/
|
|
if (rollbackOnFailure) {
|
|
rpmtransFlags tsFlags;
|
|
rpmVSFlags ovsflags;
|
|
rpmVSFlags vsflags;
|
|
|
|
rpmlog(RPMLOG_DEBUG,
|
|
_("Creating auto-rollback transaction\n"));
|
|
|
|
rollbackTransaction = rpmtsCreate();
|
|
|
|
/* Set the verify signature flags:
|
|
* - can't verify digests on repackaged packages. Other than
|
|
* they are wrong, this will cause segfaults down stream.
|
|
* - signatures are out too.
|
|
* - header check are out.
|
|
*/
|
|
vsflags = rpmExpandNumeric("%{?_vsflags_erase}");
|
|
vsflags |= _RPMVSF_NODIGESTS;
|
|
vsflags |= _RPMVSF_NOSIGNATURES;
|
|
vsflags |= RPMVSF_NOHDRCHK;
|
|
vsflags |= RPMVSF_NEEDPAYLOAD; /* XXX no legacy signatures */
|
|
ovsflags = rpmtsSetVSFlags(ts, vsflags);
|
|
|
|
/*
|
|
* If we run this thing its imperitive that it be known that it
|
|
* is an autorollback transaction. This will affect the instance
|
|
* counts passed to the scriptlets in the psm.
|
|
*/
|
|
rpmtsSetType(rollbackTransaction, RPMTRANS_TYPE_AUTOROLLBACK);
|
|
|
|
/* Set transaction flags to be the same as the running transaction */
|
|
tsFlags = rpmtsSetFlags(rollbackTransaction, rpmtsFlags(ts));
|
|
|
|
/* Set root dir to be the same as the running transaction */
|
|
rpmtsSetRootDir(rollbackTransaction, rpmtsRootDir(ts));
|
|
|
|
/* Setup the notify of the call back to be the same as the running
|
|
* transaction
|
|
*/
|
|
xx = rpmtsSetNotifyCallback(rollbackTransaction, ts->notify, ts->notifyData);
|
|
|
|
/* Create rpmtsScore for running transaction and rollback transaction */
|
|
xx = rpmtsScoreInit(ts, rollbackTransaction);
|
|
}
|
|
|
|
/* ===============================================
|
|
* Save removed files before erasing.
|
|
*/
|
|
if (rpmtsFlags(ts) & (RPMTRANS_FLAG_DIRSTASH | RPMTRANS_FLAG_REPACKAGE)) {
|
|
int progress;
|
|
|
|
progress = 0;
|
|
pi = rpmtsiInit(ts);
|
|
while ((p = rpmtsiNext(pi, 0)) != NULL) {
|
|
|
|
if ((fi = rpmtsiFi(pi)) == NULL)
|
|
continue; /* XXX can't happen */
|
|
switch (rpmteType(p)) {
|
|
case TR_ADDED:
|
|
break;
|
|
case TR_REMOVED:
|
|
if (!(rpmtsFlags(ts) & RPMTRANS_FLAG_REPACKAGE))
|
|
break;
|
|
if (!progress)
|
|
NOTIFY(ts, (NULL, RPMCALLBACK_REPACKAGE_START,
|
|
7, numRemoved, NULL, ts->notifyData));
|
|
|
|
NOTIFY(ts, (NULL, RPMCALLBACK_REPACKAGE_PROGRESS, progress,
|
|
numRemoved, NULL, ts->notifyData));
|
|
progress++;
|
|
|
|
(void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_REPACKAGE), 0);
|
|
|
|
/* XXX TR_REMOVED needs CPIO_MAP_{ABSOLUTE,ADDDOT} CPIO_ALL_HARDLINKS */
|
|
fi->mapflags |= CPIO_MAP_ABSOLUTE;
|
|
fi->mapflags |= CPIO_MAP_ADDDOT;
|
|
fi->mapflags |= CPIO_ALL_HARDLINKS;
|
|
psm = rpmpsmNew(ts, p, fi);
|
|
assert(psm != NULL);
|
|
xx = rpmpsmStage(psm, PSM_PKGSAVE);
|
|
psm = rpmpsmFree(psm);
|
|
fi->mapflags &= ~CPIO_MAP_ABSOLUTE;
|
|
fi->mapflags &= ~CPIO_MAP_ADDDOT;
|
|
fi->mapflags &= ~CPIO_ALL_HARDLINKS;
|
|
|
|
(void) rpmswExit(rpmtsOp(ts, RPMTS_OP_REPACKAGE), 0);
|
|
|
|
break;
|
|
}
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
if (progress) {
|
|
NOTIFY(ts, (NULL, RPMCALLBACK_REPACKAGE_STOP, 7, numRemoved,
|
|
NULL, ts->notifyData));
|
|
}
|
|
}
|
|
|
|
/* ===============================================
|
|
* Install and remove packages.
|
|
*/
|
|
lastFailKey = (rpmalKey)-2; /* erased packages have -1 */
|
|
pi = rpmtsiInit(ts);
|
|
/* FIX: fi reload needs work */
|
|
while ((p = rpmtsiNext(pi, 0)) != NULL) {
|
|
rpmalKey pkgKey;
|
|
int gotfd;
|
|
|
|
gotfd = 0;
|
|
if ((fi = rpmtsiFi(pi)) == NULL)
|
|
continue; /* XXX can't happen */
|
|
|
|
psm = rpmpsmNew(ts, p, fi);
|
|
assert(psm != NULL);
|
|
psm->unorderedSuccessor =
|
|
(rpmtsiOc(pi) >= rpmtsUnorderedSuccessors(ts, -1) ? 1 : 0);
|
|
|
|
switch (rpmteType(p)) {
|
|
case TR_ADDED:
|
|
(void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_INSTALL), 0);
|
|
|
|
pkgKey = rpmteAddedKey(p);
|
|
|
|
rpmlog(RPMLOG_DEBUG, "========== +++ %s %s-%s 0x%x\n",
|
|
rpmteNEVR(p), rpmteA(p), rpmteO(p), rpmteColor(p));
|
|
|
|
p->h = NULL;
|
|
/* FIX: rpmte not opaque */
|
|
{
|
|
/* FIX: notify annotations */
|
|
p->fd = ts->notify(p->h, RPMCALLBACK_INST_OPEN_FILE, 0, 0,
|
|
rpmteKey(p), ts->notifyData);
|
|
if (rpmteFd(p) != NULL) {
|
|
rpmVSFlags ovsflags = rpmtsVSFlags(ts);
|
|
rpmVSFlags vsflags = ovsflags | RPMVSF_NEEDPAYLOAD;
|
|
rpmRC rpmrc;
|
|
|
|
ovsflags = rpmtsSetVSFlags(ts, vsflags);
|
|
rpmrc = rpmReadPackageFile(ts, rpmteFd(p),
|
|
rpmteNEVR(p), &p->h);
|
|
vsflags = rpmtsSetVSFlags(ts, ovsflags);
|
|
|
|
switch (rpmrc) {
|
|
default:
|
|
/* FIX: notify annotations */
|
|
p->fd = ts->notify(p->h, RPMCALLBACK_INST_CLOSE_FILE,
|
|
0, 0,
|
|
rpmteKey(p), ts->notifyData);
|
|
p->fd = NULL;
|
|
ourrc++;
|
|
|
|
/* If we should rollback this transaction
|
|
on failure, lets do it. */
|
|
if (rollbackOnFailure) {
|
|
rpmlog(RPMLOG_ERR,
|
|
_("Add failed. Could not read package header.\n"));
|
|
/* Clean up the current transaction */
|
|
p->h = headerFree(p->h);
|
|
xx = rpmdbSync(rpmtsGetRdb(ts));
|
|
psm = rpmpsmFree(psm);
|
|
p->fi = rpmfiFree(p->fi);
|
|
pi = rpmtsiFree(pi);
|
|
|
|
/* Run the rollback transaction */
|
|
xx = _rpmtsRollback(rollbackTransaction);
|
|
return -1;
|
|
}
|
|
break;
|
|
case RPMRC_NOTTRUSTED:
|
|
case RPMRC_NOKEY:
|
|
case RPMRC_OK:
|
|
break;
|
|
}
|
|
if (rpmteFd(p) != NULL) gotfd = 1;
|
|
}
|
|
}
|
|
|
|
if (rpmteFd(p) != NULL) {
|
|
/*
|
|
* XXX Sludge necessary to tranfer existing fstates/actions
|
|
* XXX around a recreated file info set.
|
|
*/
|
|
psm->fi = rpmfiFree(psm->fi);
|
|
{
|
|
char * fstates = fi->fstates;
|
|
rpmFileAction * actions = fi->actions;
|
|
sharedFileInfo replaced = fi->replaced;
|
|
int mapflags = fi->mapflags;
|
|
rpmte savep;
|
|
int numShared = 0;
|
|
|
|
if (replaced != NULL) {
|
|
for (; replaced->otherPkg; replaced++) {
|
|
numShared++;
|
|
}
|
|
if (numShared > 0) {
|
|
replaced = xcalloc(numShared + 1,
|
|
sizeof(*fi->replaced));
|
|
memcpy(replaced, fi->replaced,
|
|
sizeof(*fi->replaced) * (numShared + 1));
|
|
}
|
|
}
|
|
|
|
fi->fstates = NULL;
|
|
fi->actions = NULL;
|
|
fi->replaced = NULL;
|
|
/* FIX: fi->actions is NULL */
|
|
fi = rpmfiFree(fi);
|
|
|
|
savep = rpmtsSetRelocateElement(ts, p);
|
|
fi = rpmfiNew(ts, p->h, RPMTAG_BASENAMES, 1);
|
|
(void) rpmtsSetRelocateElement(ts, savep);
|
|
|
|
if (fi != NULL) { /* XXX can't happen */
|
|
fi->te = p;
|
|
fi->fstates = _free(fi->fstates);
|
|
fi->fstates = fstates;
|
|
fi->actions = _free(fi->actions);
|
|
fi->actions = actions;
|
|
if (replaced != NULL)
|
|
fi->replaced = replaced;
|
|
if (mapflags & CPIO_SBIT_CHECK)
|
|
fi->mapflags |= CPIO_SBIT_CHECK;
|
|
p->fi = fi;
|
|
}
|
|
}
|
|
psm->fi = rpmfiLink(p->fi, NULL);
|
|
|
|
/* FIX: psm->fi may be NULL */
|
|
if (rpmpsmStage(psm, PSM_PKGINSTALL)) {
|
|
ourrc++;
|
|
lastFailKey = pkgKey;
|
|
|
|
/* If we should rollback this transaction
|
|
on failure, lets do it. */
|
|
if (rollbackOnFailure) {
|
|
rpmlog(RPMLOG_ERR,
|
|
_("Add failed in rpmpsmStage().\n"));
|
|
/* Clean up the current transaction */
|
|
p->h = headerFree(p->h);
|
|
xx = rpmdbSync(rpmtsGetRdb(ts));
|
|
psm = rpmpsmFree(psm);
|
|
p->fi = rpmfiFree(p->fi);
|
|
pi = rpmtsiFree(pi);
|
|
|
|
/* Run the rollback transaction */
|
|
xx = _rpmtsRollback(rollbackTransaction);
|
|
return -1;
|
|
}
|
|
}
|
|
|
|
/* If we should rollback on failure lets add
|
|
* this element to the rollback transaction
|
|
* as an erase element as it has installed succesfully.
|
|
*/
|
|
if (rollbackOnFailure) {
|
|
int rc;
|
|
|
|
rc = _rpmtsAddRollbackElement(rollbackTransaction, ts, p);
|
|
if (rc != RPMRC_OK) {
|
|
/* Clean up the current transaction */
|
|
p->h = headerFree(p->h);
|
|
xx = rpmdbSync(rpmtsGetRdb(ts));
|
|
psm = rpmpsmFree(psm);
|
|
p->fi = rpmfiFree(p->fi);
|
|
pi = rpmtsiFree(pi);
|
|
|
|
/* Clean up rollback transaction */
|
|
rollbackTransaction = rpmtsFree(rollbackTransaction);
|
|
return -1;
|
|
}
|
|
}
|
|
} else {
|
|
ourrc++;
|
|
lastFailKey = pkgKey;
|
|
|
|
/* If we should rollback this transaction
|
|
* on failure, lets do it.
|
|
*/
|
|
if (rollbackOnFailure) {
|
|
rpmlog(RPMLOG_ERR, _("Add failed. Could not get file list.\n"));
|
|
/* Clean up the current transaction */
|
|
p->h = headerFree(p->h);
|
|
xx = rpmdbSync(rpmtsGetRdb(ts));
|
|
psm = rpmpsmFree(psm);
|
|
p->fi = rpmfiFree(p->fi);
|
|
pi = rpmtsiFree(pi);
|
|
|
|
/* Run the rollback transaction */
|
|
xx = _rpmtsRollback(rollbackTransaction);
|
|
return -1;
|
|
}
|
|
}
|
|
|
|
if (gotfd) {
|
|
/* FIX: check rc */
|
|
(void) ts->notify(p->h, RPMCALLBACK_INST_CLOSE_FILE, 0, 0,
|
|
rpmteKey(p), ts->notifyData);
|
|
p->fd = NULL;
|
|
}
|
|
|
|
p->h = headerFree(p->h);
|
|
|
|
(void) rpmswExit(rpmtsOp(ts, RPMTS_OP_INSTALL), 0);
|
|
|
|
break;
|
|
|
|
case TR_REMOVED:
|
|
(void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_ERASE), 0);
|
|
|
|
rpmlog(RPMLOG_DEBUG, "========== --- %s %s-%s 0x%x\n",
|
|
rpmteNEVR(p), rpmteA(p), rpmteO(p), rpmteColor(p));
|
|
|
|
/*
|
|
* XXX This has always been a hack, now mostly broken.
|
|
* If install failed, then we shouldn't erase.
|
|
*/
|
|
if (rpmteDependsOnKey(p) != lastFailKey) {
|
|
if (rpmpsmStage(psm, PSM_PKGERASE)) {
|
|
ourrc++;
|
|
|
|
/* If we should rollback this transaction
|
|
* on failure, lets do it.
|
|
*/
|
|
if (rollbackOnFailure) {
|
|
rpmlog(RPMLOG_ERR,
|
|
_("Erase failed failed in rpmpsmStage().\n"));
|
|
/* Clean up the current transaction */
|
|
xx = rpmdbSync(rpmtsGetRdb(ts));
|
|
psm = rpmpsmFree(psm);
|
|
p->fi = rpmfiFree(p->fi);
|
|
pi = rpmtsiFree(pi);
|
|
|
|
/* Run the rollback transaction */
|
|
xx = _rpmtsRollback(rollbackTransaction);
|
|
return -1;
|
|
}
|
|
}
|
|
|
|
/* If we should rollback on failure lets add
|
|
* this element to the rollback transaction
|
|
* as an install element as it has erased succesfully.
|
|
*/
|
|
if (rollbackOnFailure) {
|
|
int rc;
|
|
|
|
rc = _rpmtsAddRollbackElement(rollbackTransaction, ts, p);
|
|
|
|
if (rc != RPMRC_OK) {
|
|
/* Clean up the current transaction */
|
|
xx = rpmdbSync(rpmtsGetRdb(ts));
|
|
psm = rpmpsmFree(psm);
|
|
p->fi = rpmfiFree(p->fi);
|
|
pi = rpmtsiFree(pi);
|
|
|
|
/* Clean up rollback transaction */
|
|
rollbackTransaction = rpmtsFree(rollbackTransaction);
|
|
return -1;
|
|
}
|
|
}
|
|
}
|
|
|
|
(void) rpmswExit(rpmtsOp(ts, RPMTS_OP_ERASE), 0);
|
|
|
|
break;
|
|
}
|
|
xx = rpmdbSync(rpmtsGetRdb(ts));
|
|
|
|
/* FIX: psm->fi may be NULL */
|
|
psm = rpmpsmFree(psm);
|
|
|
|
#ifdef DYING
|
|
/* FIX: p is almost opaque */
|
|
p->fi = rpmfiFree(p->fi);
|
|
#endif
|
|
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
|
|
/* If we created a rollback transaction lets get rid of it */
|
|
if (rollbackOnFailure && rollbackTransaction != NULL)
|
|
rollbackTransaction = rpmtsFree(rollbackTransaction);
|
|
|
|
if (!(rpmtsFlags(ts) & RPMTRANS_FLAG_TEST)) {
|
|
rpmlog(RPMLOG_DEBUG, _("running post-transaction scripts\n"));
|
|
pi = rpmtsiInit(ts);
|
|
while ((p = rpmtsiNext(pi, TR_ADDED)) != NULL) {
|
|
int haspostscript;
|
|
|
|
if ((fi = rpmtsiFi(pi)) == NULL)
|
|
continue; /* XXX can't happen */
|
|
|
|
haspostscript = (fi->posttrans != NULL ? 1 : 0);
|
|
p->fi = rpmfiFree(p->fi);
|
|
|
|
/* If no post-transaction script, then don't bother. */
|
|
if (!haspostscript)
|
|
continue;
|
|
|
|
p->fd = ts->notify(p->h, RPMCALLBACK_INST_OPEN_FILE, 0, 0,
|
|
rpmteKey(p), ts->notifyData);
|
|
p->h = NULL;
|
|
if (rpmteFd(p) != NULL) {
|
|
rpmVSFlags ovsflags = rpmtsVSFlags(ts);
|
|
rpmVSFlags vsflags = ovsflags | RPMVSF_NEEDPAYLOAD;
|
|
rpmRC rpmrc;
|
|
ovsflags = rpmtsSetVSFlags(ts, vsflags);
|
|
rpmrc = rpmReadPackageFile(ts, rpmteFd(p),
|
|
rpmteNEVR(p), &p->h);
|
|
vsflags = rpmtsSetVSFlags(ts, ovsflags);
|
|
switch (rpmrc) {
|
|
default:
|
|
p->fd = ts->notify(p->h, RPMCALLBACK_INST_CLOSE_FILE,
|
|
0, 0, rpmteKey(p), ts->notifyData);
|
|
p->fd = NULL;
|
|
break;
|
|
case RPMRC_NOTTRUSTED:
|
|
case RPMRC_NOKEY:
|
|
case RPMRC_OK:
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (rpmteFd(p) != NULL) {
|
|
p->fi = rpmfiNew(ts, p->h, RPMTAG_BASENAMES, 1);
|
|
if (p->fi != NULL) /* XXX can't happen */
|
|
p->fi->te = p;
|
|
psm = rpmpsmNew(ts, p, p->fi);
|
|
assert(psm != NULL);
|
|
psm->scriptTag = RPMTAG_POSTTRANS;
|
|
psm->progTag = RPMTAG_POSTTRANSPROG;
|
|
xx = rpmpsmStage(psm, PSM_SCRIPT);
|
|
psm = rpmpsmFree(psm);
|
|
|
|
(void) ts->notify(p->h, RPMCALLBACK_INST_CLOSE_FILE, 0, 0,
|
|
rpmteKey(p), ts->notifyData);
|
|
p->fd = NULL;
|
|
p->fi = rpmfiFree(p->fi);
|
|
p->h = headerFree(p->h);
|
|
}
|
|
}
|
|
pi = rpmtsiFree(pi);
|
|
}
|
|
|
|
rpmtsFreeLock(lock);
|
|
|
|
/* FIX: ts->flList may be NULL */
|
|
if (ourrc)
|
|
return -1;
|
|
else
|
|
return 0;
|
|
}
|