2 * \file lib/transaction.c
8 #include <rpmmacro.h> /* XXX for rpmExpand */
17 #define _RPMFI_INTERNAL
20 #define _RPMTE_INTERNAL
23 #define _RPMTS_INTERNAL
28 #include "legacy.h" /* XXX domd5 */
29 #include "misc.h" /* XXX stripTrailingChar, splitString, currentDirectory */
33 /*@access FD_t @*/ /* XXX compared with NULL */
34 /*@access Header @*/ /* XXX compared with NULL */
35 /*@access rpmps @*/ /* XXX need rpmProblemSetOK() */
36 /*@access dbiIndexSet @*/
52 static int archOkay(/*@null@*/ const char * pkgArch)
55 if (pkgArch == NULL) return 0;
56 return (rpmMachineScore(RPM_MACHTABLE_INSTARCH, pkgArch) ? 1 : 0);
61 static int osOkay(/*@null@*/ const char * pkgOs)
64 if (pkgOs == NULL) return 0;
65 return (rpmMachineScore(RPM_MACHTABLE_INSTOS, pkgOs) ? 1 : 0);
70 static int sharedCmp(const void * one, const void * two)
73 sharedFileInfo a = (sharedFileInfo) one;
74 sharedFileInfo b = (sharedFileInfo) two;
76 if (a->otherPkg < b->otherPkg)
78 else if (a->otherPkg > b->otherPkg)
87 static fileAction decideFileFate(const rpmts ts,
88 const rpmfi ofi, rpmfi nfi)
89 /*@globals fileSystem, internalState @*/
90 /*@modifies nfi, fileSystem, internalState @*/
92 const char * fn = rpmfiFN(nfi);
93 int newFlags = rpmfiFFlags(nfi);
95 fileTypes dbWhat, newWhat, diskWhat;
97 int save = (newFlags & RPMFILE_NOREPLACE) ? FA_ALTNAME : FA_SAVE;
101 * The file doesn't exist on the disk. Create it unless the new
102 * package has marked it as missingok, or allfiles is requested.
104 if (!(rpmtsFlags(ts) & RPMTRANS_FLAG_ALLFILES)
105 && (newFlags & RPMFILE_MISSINGOK))
107 rpmMessage(RPMMESS_DEBUG, _("%s skipped due to missingok flag\n"),
115 diskWhat = whatis((int_16)sb.st_mode);
116 dbWhat = whatis(rpmfiFMode(ofi));
117 newWhat = whatis(rpmfiFMode(nfi));
120 * RPM >= 2.3.10 shouldn't create config directories -- we'll ignore
121 * them in older packages as well.
126 if (diskWhat != newWhat)
128 else if (newWhat != dbWhat && diskWhat != dbWhat)
130 else if (dbWhat != newWhat)
132 else if (dbWhat != LINK && dbWhat != REG)
136 * This order matters - we'd prefer to CREATE the file if at all
137 * possible in case something else (like the timestamp) has changed.
140 const unsigned char * omd5, * nmd5;
141 if (domd5(fn, buffer, 0, NULL))
142 return FA_CREATE; /* assume file has been removed */
143 omd5 = rpmfiMD5(ofi);
144 if (omd5 && !memcmp(omd5, buffer, 16))
145 return FA_CREATE; /* unmodified config file, replace. */
146 nmd5 = rpmfiMD5(nfi);
148 if (omd5 && nmd5 && !memcmp(omd5, nmd5, 16))
149 return FA_SKIP; /* identical file, don't bother. */
151 } else /* dbWhat == LINK */ {
152 const char * oFLink, * nFLink;
153 memset(buffer, 0, sizeof(buffer));
154 if (readlink(fn, buffer, sizeof(buffer) - 1) == -1)
155 return FA_CREATE; /* assume file has been removed */
156 oFLink = rpmfiFLink(ofi);
157 if (oFLink && !strcmp(oFLink, buffer))
158 return FA_CREATE; /* unmodified config file, replace. */
159 nFLink = rpmfiFLink(nfi);
161 if (oFLink && nFLink && !strcmp(oFLink, nFLink))
162 return FA_SKIP; /* identical file, don't bother. */
167 * The config file on the disk has been modified, but
168 * the ones in the two packages are different. It would
169 * be nice if RPM was smart enough to at least try and
170 * merge the difference ala CVS, but...
179 static int filecmp(rpmfi afi, rpmfi bfi)
182 fileTypes awhat = whatis(rpmfiFMode(afi));
183 fileTypes bwhat = whatis(rpmfiFMode(bfi));
185 if (awhat != bwhat) return 1;
188 const char * alink = rpmfiFLink(afi);
189 const char * blink = rpmfiFLink(bfi);
190 if (alink == blink) return 0;
191 if (alink == NULL) return 1;
192 if (blink == NULL) return -1;
193 return strcmp(alink, blink);
194 } else if (awhat == REG) {
195 const unsigned char * amd5 = rpmfiMD5(afi);
196 const unsigned char * bmd5 = rpmfiMD5(bfi);
197 if (amd5 == bmd5) return 0;
198 if (amd5 == NULL) return 1;
199 if (bmd5 == NULL) return -1;
200 return memcmp(amd5, bmd5, 16);
209 /* XXX only ts->{probs,rpmdb} modified */
211 static int handleInstInstalledFiles(const rpmts ts,
213 sharedFileInfo shared,
214 int sharedCount, int reportConflicts)
215 /*@globals rpmGlobalMacroContext, fileSystem, internalState @*/
216 /*@modifies ts, fi, rpmGlobalMacroContext, fileSystem, internalState @*/
218 const char * altNEVR = NULL;
219 rpmfi otherFi = NULL;
224 { rpmdbMatchIterator mi;
228 mi = rpmtsInitIterator(ts, RPMDBI_PACKAGES,
229 &shared->otherPkg, sizeof(shared->otherPkg));
230 while ((h = rpmdbNextIterator(mi)) != NULL) {
231 altNEVR = hGetNEVR(h, NULL);
232 otherFi = rpmfiNew(ts, h, RPMTAG_BASENAMES, scareMem);
235 mi = rpmdbFreeIterator(mi);
241 fi->replaced = xcalloc(sharedCount, sizeof(*fi->replaced));
243 ps = rpmtsProblems(ts);
244 for (i = 0; i < sharedCount; i++, shared++) {
245 int otherFileNum, fileNum;
248 otherFileNum = shared->otherFileNum;
249 (void) rpmfiSetFX(otherFi, otherFileNum);
251 fileNum = shared->pkgFileNum;
252 (void) rpmfiSetFX(fi, fileNum);
254 isCfgFile = ((rpmfiFFlags(otherFi) | rpmfiFFlags(fi)) & RPMFILE_CONFIG);
257 /* XXX another tedious segfault, assume file state normal. */
258 if (otherStates && otherStates[otherFileNum] != RPMFILE_STATE_NORMAL)
262 if (XFA_SKIPPING(fi->actions[fileNum]))
265 if (filecmp(otherFi, fi)) {
266 if (reportConflicts) {
267 rpmpsAppend(ps, RPMPROB_FILE_CONFLICT,
268 rpmteNEVR(p), rpmteKey(p),
269 rpmfiDN(fi), rpmfiBN(fi),
274 /*@-assignexpose@*/ /* FIX: p->replaced, not fi */
275 if (!shared->isRemoved)
276 fi->replaced[numReplaced++] = *shared;
283 action = decideFileFate(ts, otherFi, fi);
284 fi->actions[fileNum] = action;
286 fi->replacedSizes[fileNum] = rpmfiFSize(otherFi);
290 altNEVR = _free(altNEVR);
291 otherFi = rpmfiFree(otherFi);
293 fi->replaced = xrealloc(fi->replaced, /* XXX memory leak */
294 sizeof(*fi->replaced) * (numReplaced + 1));
295 fi->replaced[numReplaced].otherPkg = 0;
303 /* XXX only ts->rpmdb modified */
304 static int handleRmvdInstalledFiles(const rpmts ts, rpmfi fi,
305 sharedFileInfo shared, int sharedCount)
306 /*@globals rpmGlobalMacroContext, fileSystem, internalState @*/
307 /*@modifies ts, fi, rpmGlobalMacroContext, fileSystem, internalState @*/
311 const char * otherStates;
314 rpmdbMatchIterator mi;
316 mi = rpmtsInitIterator(ts, RPMDBI_PACKAGES,
317 &shared->otherPkg, sizeof(shared->otherPkg));
318 h = rpmdbNextIterator(mi);
320 mi = rpmdbFreeIterator(mi);
324 xx = hge(h, RPMTAG_FILESTATES, NULL, (void **) &otherStates, NULL);
327 for (i = 0; i < sharedCount; i++, shared++) {
328 int otherFileNum, fileNum;
329 otherFileNum = shared->otherFileNum;
330 fileNum = shared->pkgFileNum;
332 if (otherStates[otherFileNum] != RPMFILE_STATE_NORMAL)
335 fi->actions[fileNum] = FA_SKIP;
339 mi = rpmdbFreeIterator(mi);
344 #define ISROOT(_d) (((_d)[0] == '/' && (_d)[1] == '\0') ? "" : (_d))
349 static int fpsCompare (const void * one, const void * two)
352 const struct fingerPrint_s * a = (const struct fingerPrint_s *)one;
353 const struct fingerPrint_s * b = (const struct fingerPrint_s *)two;
354 int adnlen = strlen(a->entry->dirName);
355 int asnlen = (a->subDir ? strlen(a->subDir) : 0);
356 int abnlen = strlen(a->baseName);
357 int bdnlen = strlen(b->entry->dirName);
358 int bsnlen = (b->subDir ? strlen(b->subDir) : 0);
359 int bbnlen = strlen(b->baseName);
360 char * afn, * bfn, * t;
363 if (adnlen == 1 && asnlen != 0) adnlen = 0;
364 if (bdnlen == 1 && bsnlen != 0) bdnlen = 0;
367 afn = t = alloca(adnlen+asnlen+abnlen+2);
368 if (adnlen) t = stpcpy(t, a->entry->dirName);
370 if (a->subDir && asnlen) t = stpcpy(t, a->subDir);
371 if (abnlen) t = stpcpy(t, a->baseName);
372 if (afn[0] == '/' && afn[1] == '/') afn++;
374 bfn = t = alloca(bdnlen+bsnlen+bbnlen+2);
375 if (bdnlen) t = stpcpy(t, b->entry->dirName);
377 if (b->subDir && bsnlen) t = stpcpy(t, b->subDir);
378 if (bbnlen) t = stpcpy(t, b->baseName);
379 if (bfn[0] == '/' && bfn[1] == '/') bfn++;
382 rc = strcmp(afn, bfn);
385 fprintf(stderr, "\trc(%d) = strcmp(\"%s\", \"%s\")\n", rc, afn, bfn);
390 fprintf(stderr, "\t%s/%s%s\trc %d\n",
391 ISROOT(b->entry->dirName),
392 (b->subDir ? b->subDir : ""),
402 static int _linear_fps_search = 0;
404 static int findFps(const struct fingerPrint_s * fiFps,
405 const struct fingerPrint_s * otherFps,
413 fprintf(stderr, "==> %s/%s%s\n",
414 ISROOT(fiFps->entry->dirName),
415 (fiFps->subDir ? fiFps->subDir : ""),
419 if (_linear_fps_search) {
422 for (otherFileNum = 0; otherFileNum < otherFc; otherFileNum++, otherFps++) {
426 fprintf(stderr, "\t%4d %s/%s%s\n", otherFileNum,
427 ISROOT(otherFps->entry->dirName),
428 (otherFps->subDir ? otherFps->subDir : ""),
432 /* If the addresses are the same, so are the values. */
433 if (fiFps == otherFps)
436 /* Otherwise, compare fingerprints by value. */
437 /*@-nullpass@*/ /* LCL: looks good to me */
438 if (FP_EQUAL((*fiFps), (*otherFps)))
443 if (otherFileNum == otherFc) {
446 fprintf(stderr, "*** FP_EQUAL NULL %s/%s%s\n",
447 ISROOT(fiFps->entry->dirName),
448 (fiFps->subDir ? fiFps->subDir : ""),
457 const struct fingerPrint_s * bingoFps;
460 bingoFps = bsearch(fiFps, otherFps, otherFc, sizeof(*otherFps), fpsCompare);
462 if (bingoFps == NULL) {
465 fprintf(stderr, "*** bingoFps NULL %s/%s%s\n",
466 ISROOT(fiFps->entry->dirName),
467 (fiFps->subDir ? fiFps->subDir : ""),
473 /* If the addresses are the same, so are the values. */
474 /*@-nullpass@*/ /* LCL: looks good to me */
475 if (!(fiFps == bingoFps || FP_EQUAL((*fiFps), (*bingoFps)))) {
478 fprintf(stderr, "*** BAD %s/%s%s\n",
479 ISROOT(bingoFps->entry->dirName),
480 (bingoFps->subDir ? bingoFps->subDir : ""),
486 otherFileNum = (bingoFps != NULL ? (bingoFps - otherFps) : 0);
494 * Update disk space needs on each partition for this package's files.
496 /* XXX only ts->{probs,di} modified */
497 static void handleOverlappedFiles(const rpmts ts,
498 const rpmte p, rpmfi fi)
499 /*@globals fileSystem, internalState @*/
500 /*@modifies ts, fi, fileSystem, internalState @*/
502 uint_32 fixupSize = 0;
507 ps = rpmtsProblems(ts);
508 fi = rpmfiInit(fi, 0);
510 while ((i = rpmfiNext(fi)) >= 0) {
511 struct fingerPrint_s * fiFps;
512 int otherPkgNum, otherFileNum;
519 if (XFA_SKIPPING(fi->actions[i]))
524 FFlags = rpmfiFFlags(fi);
525 FMode = rpmfiFMode(fi);
530 * Retrieve all records that apply to this file. Note that the
531 * file info records were built in the same order as the packages
532 * will be installed and removed so the records for an overlapped
533 * files will be sorted in exactly the same order.
535 (void) htGetEntry(ts->ht, fiFps,
536 (const void ***) &recs, &numRecs, NULL);
539 * If this package is being added, look only at other packages
540 * being added -- removed packages dance to a different tune.
542 * If both this and the other package are being added, overlapped
543 * files must be identical (or marked as a conflict). The
544 * disposition of already installed config files leads to
545 * a small amount of extra complexity.
547 * If this package is being removed, then there are two cases that
548 * need to be worried about:
549 * If the other package is being added, then skip any overlapped files
550 * so that this package removal doesn't nuke the overlapped files
551 * that were just installed.
552 * If both this and the other package are being removed, then each
553 * file removal from preceding packages needs to be skipped so that
554 * the file removal occurs only on the last occurence of an overlapped
555 * file in the transaction set.
559 /* Locate this overlapped file in the set of added/removed packages. */
560 for (j = 0; j < numRecs && recs[j] != fi; j++)
563 /* Find what the previous disposition of this file was. */
564 otherFileNum = -1; /* keep gcc quiet */
566 for (otherPkgNum = j - 1; otherPkgNum >= 0; otherPkgNum--) {
567 struct fingerPrint_s * otherFps;
570 otherFi = recs[otherPkgNum];
572 /* Added packages need only look at other added packages. */
573 if (rpmteType(p) == TR_ADDED && rpmteType(otherFi->te) != TR_ADDED)
574 /*@innercontinue@*/ continue;
576 otherFps = otherFi->fps;
577 otherFc = rpmfiFC(otherFi);
579 otherFileNum = findFps(fiFps, otherFps, otherFc);
580 (void) rpmfiSetFX(otherFi, otherFileNum);
582 /* XXX Happens iff fingerprint for incomplete package install. */
583 if (otherFi->actions[otherFileNum] != FA_UNKNOWN)
584 /*@innerbreak@*/ break;
588 switch (rpmteType(p)) {
591 if (otherPkgNum < 0) {
592 /* XXX is this test still necessary? */
593 if (fi->actions[i] != FA_UNKNOWN)
594 /*@switchbreak@*/ break;
595 if ((FFlags & RPMFILE_CONFIG) && !lstat(fn, &sb)) {
596 /* Here is a non-overlapped pre-existing config file. */
597 fi->actions[i] = (FFlags & RPMFILE_NOREPLACE)
598 ? FA_ALTNAME : FA_BACKUP;
600 fi->actions[i] = FA_CREATE;
602 /*@switchbreak@*/ break;
605 assert(otherFi != NULL);
606 /* Mark added overlapped non-identical files as a conflict. */
607 if ((rpmtsFilterFlags(ts) & RPMPROB_FILTER_REPLACENEWFILES)
608 && filecmp(otherFi, fi))
610 rpmpsAppend(ps, RPMPROB_NEW_FILE_CONFLICT,
611 rpmteNEVR(p), rpmteKey(p),
613 rpmteNEVR(otherFi->te),
617 /* Try to get the disk accounting correct even if a conflict. */
618 fixupSize = rpmfiFSize(otherFi);
620 if ((FFlags & RPMFILE_CONFIG) && !lstat(fn, &sb)) {
621 /* Here is an overlapped pre-existing config file. */
622 fi->actions[i] = (FFlags & RPMFILE_NOREPLACE)
623 ? FA_ALTNAME : FA_SKIP;
625 fi->actions[i] = FA_CREATE;
627 } /*@switchbreak@*/ break;
630 if (otherPkgNum >= 0) {
631 assert(otherFi != NULL);
632 /* Here is an overlapped added file we don't want to nuke. */
633 if (otherFi->actions[otherFileNum] != FA_ERASE) {
634 /* On updates, don't remove files. */
635 fi->actions[i] = FA_SKIP;
636 /*@switchbreak@*/ break;
638 /* Here is an overlapped removed file: skip in previous. */
639 otherFi->actions[otherFileNum] = FA_SKIP;
641 if (XFA_SKIPPING(fi->actions[i]))
642 /*@switchbreak@*/ break;
643 if (rpmfiFState(fi) != RPMFILE_STATE_NORMAL)
644 /*@switchbreak@*/ break;
645 if (!(S_ISREG(FMode) && (FFlags & RPMFILE_CONFIG))) {
646 fi->actions[i] = FA_ERASE;
647 /*@switchbreak@*/ break;
650 /* Here is a pre-existing modified config file that needs saving. */
652 const unsigned char * MD5 = rpmfiMD5(fi);
653 if (!domd5(fn, md5sum, 0, NULL) && memcmp(MD5, md5sum, 16)) {
654 fi->actions[i] = FA_BACKUP;
655 /*@switchbreak@*/ break;
658 fi->actions[i] = FA_ERASE;
659 /*@switchbreak@*/ break;
663 /* Update disk space info for a file. */
664 rpmtsUpdateDSI(ts, fiFps->entry->dev,
665 rpmfiFSize(fi), fi->replacedSizes[i], fixupSize, fi->actions[i]);
672 * Ensure that current package is newer than installed package.
673 * @param ts transaction set
674 * @param p current transaction element
675 * @param h installed header
676 * @return 0 if not newer, 1 if okay
678 static int ensureOlder(rpmts ts,
679 const rpmte p, const Header h)
682 int_32 reqFlags = (RPMSENSE_LESS | RPMSENSE_EQUAL);
689 if (p == NULL || h == NULL)
693 nb = strlen(rpmteNEVR(p)) + (rpmteE(p) != NULL ? strlen(rpmteE(p)) : 0) + 1;
697 if (rpmteE(p) != NULL) t = stpcpy( stpcpy(t, rpmteE(p)), ":");
698 if (rpmteV(p) != NULL) t = stpcpy(t, rpmteV(p));
700 if (rpmteR(p) != NULL) t = stpcpy(t, rpmteR(p));
703 req = rpmdsSingle(RPMTAG_REQUIRENAME, rpmteN(p), reqEVR, reqFlags);
704 rc = rpmdsNVRMatchesDep(h, req, _rpmds_nopromote);
705 req = rpmdsFree(req);
708 rpmps ps = rpmtsProblems(ts);
709 const char * altNEVR = hGetNEVR(h, NULL);
710 rpmpsAppend(ps, RPMPROB_OLDPACKAGE,
711 rpmteNEVR(p), rpmteKey(p),
715 altNEVR = _free(altNEVR);
725 * Skip any files that do not match install policies.
726 * @param ts transaction set
727 * @param fi file info set
729 /*@-mustmod@*/ /* FIX: fi->actions is modified. */
731 static void skipFiles(const rpmts ts, rpmfi fi)
732 /*@globals rpmGlobalMacroContext @*/
733 /*@modifies fi, rpmGlobalMacroContext @*/
735 uint_32 tscolor = rpmtsColor(ts);
737 int noConfigs = (rpmtsFlags(ts) & RPMTRANS_FLAG_NOCONFIGS);
738 int noDocs = (rpmtsFlags(ts) & RPMTRANS_FLAG_NODOCS);
739 char ** netsharedPaths = NULL;
740 const char ** languages;
741 const char * dn, * bn;
742 int dnlen, bnlen, ix;
750 noDocs = rpmExpandNumeric("%{_excludedocs}");
752 { const char *tmpPath = rpmExpand("%{_netsharedpath}", NULL);
754 if (tmpPath && *tmpPath != '%')
755 netsharedPaths = splitString(tmpPath, strlen(tmpPath), ':');
757 tmpPath = _free(tmpPath);
760 s = rpmExpand("%{_install_langs}", NULL);
762 if (!(s && *s != '%'))
765 languages = (const char **) splitString(s, strlen(s), ':');
771 /* Compute directory refcount, skip directory if now empty. */
773 drc = alloca(dc * sizeof(*drc));
774 memset(drc, 0, dc * sizeof(*drc));
775 dff = alloca(dc * sizeof(*dff));
776 memset(dff, 0, dc * sizeof(*dff));
778 fi = rpmfiInit(fi, 0);
779 if (fi != NULL) /* XXX lclint */
780 while ((i = rpmfiNext(fi)) >= 0)
790 continue; /* XXX can't happen */
794 /* Don't bother with skipped files */
795 if (XFA_SKIPPING(fi->actions[i])) {
796 drc[ix]--; dff[ix] = 1;
800 /* Ignore colored files not in our rainbow. */
801 ficolor = rpmfiFColor(fi);
802 if (tscolor && ficolor && !(tscolor & ficolor)) {
803 drc[ix]--; dff[ix] = 1;
804 fi->actions[i] = FA_SKIPCOLOR;
809 * Skip net shared paths.
810 * Net shared paths are not relative to the current root (though
811 * they do need to take package relocations into account).
813 for (nsp = netsharedPaths; nsp && *nsp; nsp++) {
818 if (strncmp(dn, *nsp, len))
819 /*@innercontinue@*/ continue;
820 /* Only directories or complete file paths can be net shared */
821 if (!(dn[len] == '/' || dn[len] == '\0'))
822 /*@innercontinue@*/ continue;
824 if (len < (dnlen + bnlen))
825 /*@innercontinue@*/ continue;
826 if (strncmp(dn, *nsp, dnlen))
827 /*@innercontinue@*/ continue;
828 if (strncmp(bn, (*nsp) + dnlen, bnlen))
829 /*@innercontinue@*/ continue;
831 /* Only directories or complete file paths can be net shared */
832 if (!((*nsp)[len] == '/' || (*nsp)[len] == '\0'))
833 /*@innercontinue@*/ continue;
836 /*@innerbreak@*/ break;
840 drc[ix]--; dff[ix] = 1;
841 fi->actions[i] = FA_SKIPNETSHARED;
846 * Skip i18n language specific files.
848 if (fi->flangs && languages && *fi->flangs[i]) {
849 const char **lang, *l, *le;
850 for (lang = languages; *lang != NULL; lang++) {
851 if (!strcmp(*lang, "all"))
852 /*@innerbreak@*/ break;
853 for (l = fi->flangs[i]; *l != '\0'; l = le) {
854 for (le = l; *le != '\0' && *le != '|'; le++)
856 if ((le-l) > 0 && !strncmp(*lang, l, (le-l)))
857 /*@innerbreak@*/ break;
858 if (*le == '|') le++; /* skip over | */
861 /*@innerbreak@*/ break;
864 drc[ix]--; dff[ix] = 1;
865 fi->actions[i] = FA_SKIPNSTATE;
871 * Skip config files if requested.
873 if (noConfigs && (rpmfiFFlags(fi) & RPMFILE_CONFIG)) {
874 drc[ix]--; dff[ix] = 1;
875 fi->actions[i] = FA_SKIPNSTATE;
880 * Skip documentation if requested.
882 if (noDocs && (rpmfiFFlags(fi) & RPMFILE_DOC)) {
883 drc[ix]--; dff[ix] = 1;
884 fi->actions[i] = FA_SKIPNSTATE;
889 /* Skip (now empty) directories that had skipped files. */
891 if (fi != NULL) /* XXX can't happen */
892 for (j = 0; j < dc; j++)
894 if ((fi = rpmfiInitD(fi)) != NULL)
895 while (j = rpmfiNextD(fi) >= 0)
899 if (drc[j]) continue; /* dir still has files. */
900 if (!dff[j]) continue; /* dir was not emptied here. */
902 /* Find parent directory and basename. */
903 dn = fi->dnl[j]; dnlen = strlen(dn) - 1;
904 bn = dn + dnlen; bnlen = 0;
905 while (bn > dn && bn[-1] != '/') {
911 /* If explicitly included in the package, skip the directory. */
912 fi = rpmfiInit(fi, 0);
913 if (fi != NULL) /* XXX lclint */
914 while ((i = rpmfiNext(fi)) >= 0) {
915 const char * fdn, * fbn;
918 if (XFA_SKIPPING(fi->actions[i]))
919 /*@innercontinue@*/ continue;
921 fFMode = rpmfiFMode(fi);
923 if (whatis(fFMode) != XDIR)
924 /*@innercontinue@*/ continue;
926 if (strlen(fdn) != dnlen)
927 /*@innercontinue@*/ continue;
928 if (strncmp(fdn, dn, dnlen))
929 /*@innercontinue@*/ continue;
931 if (strlen(fbn) != bnlen)
932 /*@innercontinue@*/ continue;
933 if (strncmp(fbn, bn, bnlen))
934 /*@innercontinue@*/ continue;
935 rpmMessage(RPMMESS_DEBUG, _("excluding directory %s\n"), dn);
936 fi->actions[i] = FA_SKIPNSTATE;
937 /*@innerbreak@*/ break;
941 if (netsharedPaths) freeSplitString(netsharedPaths);
942 #ifdef DYING /* XXX freeFi will deal with this later. */
943 fi->flangs = _free(fi->flangs);
945 if (languages) freeSplitString((char **)languages);
951 * Return transaction element's file info.
952 * @todo Take a rpmfi refcount here.
953 * @param tsi transaction element iterator
954 * @return transaction element file info
957 rpmfi rpmtsiFi(const rpmtsi tsi)
962 if (tsi != NULL && tsi->ocsave != -1) {
963 /*@-type -abstract@*/ /* FIX: rpmte not opaque */
964 rpmte te = rpmtsElement(tsi->ts, tsi->ocsave);
966 if (te != NULL && (fi = te->fi) != NULL)
969 /*@=type =abstract@*/
971 /*@-compdef -refcounttrans -usereleased @*/
973 /*@=compdef =refcounttrans =usereleased @*/
976 #define NOTIFY(_ts, _al) /*@i@*/ if ((_ts)->notify) (void) (_ts)->notify _al
978 int rpmtsRun(rpmts ts, rpmps okProbs, rpmprobFilterFlags ignoreSet)
980 uint_32 tscolor = rpmtsColor(ts);
983 int totalFileCount = 0;
985 sharedFileInfo shared, sharedList;
989 fingerPrintCache fpc;
998 /* FIXME: what if the same package is included in ts twice? */
1000 if (rpmtsFlags(ts) & RPMTRANS_FLAG_NOSCRIPTS)
1001 (void) rpmtsSetFlags(ts, (rpmtsFlags(ts) | _noTransScripts | _noTransTriggers));
1002 if (rpmtsFlags(ts) & RPMTRANS_FLAG_NOTRIGGERS)
1003 (void) rpmtsSetFlags(ts, (rpmtsFlags(ts) | _noTransTriggers));
1005 /* XXX MULTILIB is broken, as packages can and do execute /sbin/ldconfig. */
1006 if (rpmtsFlags(ts) & (RPMTRANS_FLAG_JUSTDB | RPMTRANS_FLAG_MULTILIB))
1007 (void) rpmtsSetFlags(ts, (rpmtsFlags(ts) | _noTransScripts | _noTransTriggers));
1009 ts->probs = rpmpsFree(ts->probs);
1010 ts->probs = rpmpsCreate();
1012 /* XXX Make sure the database is open RDWR for package install/erase. */
1013 { int dbmode = (rpmtsFlags(ts) & RPMTRANS_FLAG_TEST)
1014 ? O_RDONLY : (O_RDWR|O_CREAT);
1016 /* Open database RDWR for installing packages. */
1017 if (rpmtsOpenDB(ts, dbmode))
1018 return -1; /* XXX W2DO? */
1021 ts->ignoreSet = ignoreSet;
1022 { const char * currDir = currentDirectory();
1023 rpmtsSetCurrDir(ts, currDir);
1024 currDir = _free(currDir);
1027 (void) rpmtsSetChrootDone(ts, 0);
1029 { int_32 tid = (int_32) time(NULL);
1030 (void) rpmtsSetTid(ts, tid);
1033 /* Get available space on mounted file systems. */
1034 xx = rpmtsInitDSI(ts);
1036 /* ===============================================
1037 * For packages being installed:
1038 * - verify package arch/os.
1039 * - verify package epoch:version-release is newer.
1041 * For packages being removed:
1045 rpmMessage(RPMMESS_DEBUG, _("sanity checking %d elements\n"), rpmtsNElements(ts));
1046 ps = rpmtsProblems(ts);
1047 /* The ordering doesn't matter here */
1048 pi = rpmtsiInit(ts);
1049 while ((p = rpmtsiNext(pi, TR_ADDED)) != NULL) {
1050 rpmdbMatchIterator mi;
1053 if ((fi = rpmtsiFi(pi)) == NULL)
1054 continue; /* XXX can't happen */
1057 if (!(rpmtsFilterFlags(ts) & RPMPROB_FILTER_IGNOREARCH) && !tscolor)
1058 if (!archOkay(rpmteA(p)))
1059 rpmpsAppend(ps, RPMPROB_BADARCH,
1060 rpmteNEVR(p), rpmteKey(p),
1064 if (!(rpmtsFilterFlags(ts) & RPMPROB_FILTER_IGNOREOS))
1065 if (!osOkay(rpmteO(p)))
1066 rpmpsAppend(ps, RPMPROB_BADOS,
1067 rpmteNEVR(p), rpmteKey(p),
1071 if (!(rpmtsFilterFlags(ts) & RPMPROB_FILTER_OLDPACKAGE)) {
1073 mi = rpmtsInitIterator(ts, RPMTAG_NAME, rpmteN(p), 0);
1074 while ((h = rpmdbNextIterator(mi)) != NULL)
1075 xx = ensureOlder(ts, p, h);
1076 mi = rpmdbFreeIterator(mi);
1080 /* XXX multilib should not display "already installed" problems */
1081 if (!(rpmtsFilterFlags(ts) & RPMPROB_FILTER_REPLACEPKG) && !rpmteColor(p))
1083 if (!(rpmtsFilterFlags(ts) & RPMPROB_FILTER_REPLACEPKG) && !tscolor)
1086 mi = rpmtsInitIterator(ts, RPMTAG_NAME, rpmteN(p), 0);
1087 xx = rpmdbSetIteratorRE(mi, RPMTAG_EPOCH, RPMMIRE_DEFAULT,
1089 xx = rpmdbSetIteratorRE(mi, RPMTAG_VERSION, RPMMIRE_DEFAULT,
1091 xx = rpmdbSetIteratorRE(mi, RPMTAG_RELEASE, RPMMIRE_DEFAULT,
1094 while (rpmdbNextIterator(mi) != NULL) {
1095 rpmpsAppend(ps, RPMPROB_PKG_INSTALLED,
1096 rpmteNEVR(p), rpmteKey(p),
1099 /*@innerbreak@*/ break;
1101 mi = rpmdbFreeIterator(mi);
1104 /* Count no. of files (if any). */
1105 totalFileCount += fc;
1108 pi = rpmtsiFree(pi);
1111 /* The ordering doesn't matter here */
1112 pi = rpmtsiInit(ts);
1113 while ((p = rpmtsiNext(pi, TR_REMOVED)) != NULL) {
1116 if ((fi = rpmtsiFi(pi)) == NULL)
1117 continue; /* XXX can't happen */
1120 totalFileCount += fc;
1122 pi = rpmtsiFree(pi);
1124 /* ===============================================
1125 * Initialize transaction element file info for package:
1129 * FIXME?: we'd be better off assembling one very large file list and
1130 * calling fpLookupList only once. I'm not sure that the speedup is
1131 * worth the trouble though.
1133 rpmMessage(RPMMESS_DEBUG, _("computing %d file fingerprints\n"), totalFileCount);
1134 numAdded = numRemoved = 0;
1135 pi = rpmtsiInit(ts);
1136 while ((p = rpmtsiNext(pi, 0)) != NULL) {
1139 if ((fi = rpmtsiFi(pi)) == NULL)
1140 continue; /* XXX can't happen */
1144 switch (rpmteType(p)) {
1148 /* Skip netshared paths, not our i18n files, and excluded docs */
1151 /*@switchbreak@*/ break;
1154 fi->record = rpmteDBOffset(p);
1155 /*@switchbreak@*/ break;
1159 fi->fps = (fc > 0 ? xmalloc(fc * sizeof(*fi->fps)) : NULL);
1161 pi = rpmtsiFree(pi);
1163 if (!rpmtsChrootDone(ts)) {
1164 const char * rootDir = rpmtsRootDir(ts);
1166 /*@-superuser -noeffect @*/
1167 if (rootDir != NULL)
1168 xx = chroot(rootDir);
1169 /*@=superuser =noeffect @*/
1170 (void) rpmtsSetChrootDone(ts, 1);
1173 ts->ht = htCreate(totalFileCount * 2, 0, 0, fpHashFunction, fpEqual);
1174 fpc = fpCacheCreate(totalFileCount);
1176 /* ===============================================
1177 * Add fingerprint for each file not skipped.
1179 pi = rpmtsiInit(ts);
1180 while ((p = rpmtsiNext(pi, 0)) != NULL) {
1183 (void) rpmdbCheckSignals();
1185 if ((fi = rpmtsiFi(pi)) == NULL)
1186 continue; /* XXX can't happen */
1189 fpLookupList(fpc, fi->dnl, fi->bnl, fi->dil, fc, fi->fps);
1191 fi = rpmfiInit(fi, 0);
1192 if (fi != NULL) /* XXX lclint */
1193 while ((i = rpmfiNext(fi)) >= 0) {
1194 if (XFA_SKIPPING(fi->actions[i]))
1195 /*@innercontinue@*/ continue;
1196 /*@-dependenttrans@*/
1197 htAddEntry(ts->ht, fi->fps + i, (void *) fi);
1198 /*@=dependenttrans@*/
1202 pi = rpmtsiFree(pi);
1204 NOTIFY(ts, (NULL, RPMCALLBACK_TRANS_START, 6, ts->orderCount,
1205 NULL, ts->notifyData));
1207 /* ===============================================
1208 * Compute file disposition for each package in transaction set.
1210 rpmMessage(RPMMESS_DEBUG, _("computing file dispositions\n"));
1211 ps = rpmtsProblems(ts);
1212 pi = rpmtsiInit(ts);
1213 while ((p = rpmtsiNext(pi, 0)) != NULL) {
1214 dbiIndexSet * matches;
1218 (void) rpmdbCheckSignals();
1220 if ((fi = rpmtsiFi(pi)) == NULL)
1221 continue; /* XXX can't happen */
1224 NOTIFY(ts, (NULL, RPMCALLBACK_TRANS_PROGRESS, rpmtsiOc(pi),
1225 ts->orderCount, NULL, ts->notifyData));
1227 if (fc == 0) continue;
1229 /* Extract file info for all files in this package from the database. */
1230 matches = xcalloc(fc, sizeof(*matches));
1231 if (rpmdbFindFpList(rpmtsGetRdb(ts), fi->fps, matches, fc)) {
1233 return 1; /* XXX WTFO? */
1237 fi = rpmfiInit(fi, 0);
1238 while ((i = rpmfiNext(fi)) >= 0)
1239 numShared += dbiIndexSetCount(matches[i]);
1241 /* Build sorted file info list for this package. */
1242 shared = sharedList = xcalloc((numShared + 1), sizeof(*sharedList));
1244 fi = rpmfiInit(fi, 0);
1245 while ((i = rpmfiNext(fi)) >= 0) {
1247 * Take care not to mark files as replaced in packages that will
1248 * have been removed before we will get here.
1250 for (j = 0; j < dbiIndexSetCount(matches[i]); j++) {
1252 ro = dbiIndexRecordOffset(matches[i], j);
1254 qi = rpmtsiInit(ts);
1255 while ((q = rpmtsiNext(qi, TR_REMOVED)) != NULL) {
1257 /*@innerbreak@*/ break;
1258 if (rpmteDBOffset(q) == ro)
1261 qi = rpmtsiFree(qi);
1263 shared->pkgFileNum = i;
1264 shared->otherPkg = dbiIndexRecordOffset(matches[i], j);
1265 shared->otherFileNum = dbiIndexRecordFileNumber(matches[i], j);
1266 shared->isRemoved = (knownBad == ro);
1269 matches[i] = dbiFreeIndexSet(matches[i]);
1271 numShared = shared - sharedList;
1272 shared->otherPkg = -1;
1273 matches = _free(matches);
1275 /* Sort file info by other package index (otherPkg) */
1276 qsort(sharedList, numShared, sizeof(*shared), sharedCmp);
1278 /* For all files from this package that are in the database ... */
1280 for (i = 0; i < numShared; i = nexti) {
1283 shared = sharedList + i;
1285 /* Find the end of the files in the other package. */
1286 for (nexti = i + 1; nexti < numShared; nexti++) {
1287 if (sharedList[nexti].otherPkg != shared->otherPkg)
1288 /*@innerbreak@*/ break;
1291 /* Is this file from a package being removed? */
1293 if (ts->removedPackages != NULL)
1294 for (j = 0; j < ts->numRemovedPackages; j++) {
1295 if (ts->removedPackages[j] != shared->otherPkg)
1296 /*@innercontinue@*/ continue;
1298 /*@innerbreak@*/ break;
1301 /* Determine the fate of each file. */
1302 switch (rpmteType(p)) {
1304 xx = handleInstInstalledFiles(ts, p, fi, shared, nexti - i,
1305 !(beingRemoved || (rpmtsFilterFlags(ts) & RPMPROB_FILTER_REPLACEOLDFILES)));
1306 /*@switchbreak@*/ break;
1309 xx = handleRmvdInstalledFiles(ts, fi, shared, nexti - i);
1310 /*@switchbreak@*/ break;
1317 /* Update disk space needs on each partition for this package. */
1318 handleOverlappedFiles(ts, p, fi);
1320 /* Check added package has sufficient space on each partition used. */
1321 switch (rpmteType(p)) {
1323 rpmtsCheckDSIProblems(ts, p);
1324 /*@switchbreak@*/ break;
1326 /*@switchbreak@*/ break;
1329 pi = rpmtsiFree(pi);
1332 if (rpmtsChrootDone(ts)) {
1333 const char * currDir = rpmtsCurrDir(ts);
1334 /*@-superuser -noeffect @*/
1336 /*@=superuser =noeffect @*/
1337 (void) rpmtsSetChrootDone(ts, 0);
1338 if (currDir != NULL)
1339 xx = chdir(currDir);
1342 NOTIFY(ts, (NULL, RPMCALLBACK_TRANS_STOP, 6, ts->orderCount,
1343 NULL, ts->notifyData));
1345 /* ===============================================
1346 * Free unused memory as soon as possible.
1348 pi = rpmtsiInit(ts);
1349 while ((p = rpmtsiNext(pi, 0)) != NULL) {
1350 if ((fi = rpmtsiFi(pi)) == NULL)
1351 continue; /* XXX can't happen */
1352 if (rpmfiFC(fi) == 0)
1354 fi->fps = _free(fi->fps);
1356 pi = rpmtsiFree(pi);
1358 fpc = fpCacheFree(fpc);
1359 ts->ht = htFree(ts->ht);
1361 /* ===============================================
1362 * If unfiltered problems exist, free memory and return.
1364 if ((rpmtsFlags(ts) & RPMTRANS_FLAG_BUILD_PROBS)
1365 || (ts->probs->numProblems &&
1366 (okProbs != NULL || rpmpsTrim(ts->probs, okProbs)))
1369 return ts->orderCount;
1372 /* ===============================================
1373 * Save removed files before erasing.
1375 if (rpmtsFlags(ts) & (RPMTRANS_FLAG_DIRSTASH | RPMTRANS_FLAG_REPACKAGE)) {
1378 pi = rpmtsiInit(ts);
1379 while ((p = rpmtsiNext(pi, 0)) != NULL) {
1381 (void) rpmdbCheckSignals();
1383 if ((fi = rpmtsiFi(pi)) == NULL)
1384 continue; /* XXX can't happen */
1385 switch (rpmteType(p)) {
1387 /*@switchbreak@*/ break;
1389 if (!(rpmtsFlags(ts) & RPMTRANS_FLAG_REPACKAGE))
1390 /*@switchbreak@*/ break;
1392 NOTIFY(ts, (NULL, RPMCALLBACK_REPACKAGE_START,
1393 7, numRemoved, NULL, ts->notifyData));
1395 NOTIFY(ts, (NULL, RPMCALLBACK_REPACKAGE_PROGRESS, progress,
1396 numRemoved, NULL, ts->notifyData));
1399 /* XXX TR_REMOVED needs CPIO_MAP_{ABSOLUTE,ADDDOT} CPIO_ALL_HARDLINKS */
1400 fi->mapflags |= CPIO_MAP_ABSOLUTE;
1401 fi->mapflags |= CPIO_MAP_ADDDOT;
1402 fi->mapflags |= CPIO_ALL_HARDLINKS;
1403 psm = rpmpsmNew(ts, p, fi);
1404 xx = rpmpsmStage(psm, PSM_PKGSAVE);
1405 psm = rpmpsmFree(psm);
1406 fi->mapflags &= ~CPIO_MAP_ABSOLUTE;
1407 fi->mapflags &= ~CPIO_MAP_ADDDOT;
1408 fi->mapflags &= ~CPIO_ALL_HARDLINKS;
1410 /*@switchbreak@*/ break;
1413 pi = rpmtsiFree(pi);
1415 NOTIFY(ts, (NULL, RPMCALLBACK_REPACKAGE_STOP, 7, numRemoved,
1416 NULL, ts->notifyData));
1420 /* ===============================================
1421 * Install and remove packages.
1423 lastFailKey = (alKey)-2; /* erased packages have -1 */
1424 pi = rpmtsiInit(ts);
1425 /*@-branchstate@*/ /* FIX: fi reload needs work */
1426 while ((p = rpmtsiNext(pi, 0)) != NULL) {
1430 (void) rpmdbCheckSignals();
1433 if ((fi = rpmtsiFi(pi)) == NULL)
1434 continue; /* XXX can't happen */
1436 psm = rpmpsmNew(ts, p, fi);
1437 psm->unorderedSuccessor =
1438 (rpmtsiOc(pi) >= rpmtsUnorderedSuccessors(ts, -1) ? 1 : 0);
1440 switch (rpmteType(p)) {
1443 pkgKey = rpmteAddedKey(p);
1445 rpmMessage(RPMMESS_DEBUG, "========== +++ %s\n", rpmteNEVR(p));
1447 /*@-type@*/ /* FIX: rpmte not opaque */
1449 /*@-noeffectuncon@*/ /* FIX: notify annotations */
1450 p->fd = ts->notify(p->h, RPMCALLBACK_INST_OPEN_FILE, 0, 0,
1451 rpmteKey(p), ts->notifyData);
1452 /*@=noeffectuncon@*/
1453 if (rpmteFd(p) != NULL) {
1454 rpmVSFlags ovsflags = rpmtsVSFlags(ts);
1455 rpmVSFlags vsflags = ovsflags | RPMVSF_NEEDPAYLOAD;
1458 ovsflags = rpmtsSetVSFlags(ts, vsflags);
1459 rpmrc = rpmReadPackageFile(ts, rpmteFd(p),
1460 rpmteNEVR(p), &p->h);
1461 vsflags = rpmtsSetVSFlags(ts, ovsflags);
1465 /*@-noeffectuncon@*/ /* FIX: notify annotations */
1466 p->fd = ts->notify(p->h, RPMCALLBACK_INST_CLOSE_FILE,
1468 rpmteKey(p), ts->notifyData);
1469 /*@=noeffectuncon@*/
1472 /*@innerbreak@*/ break;
1473 case RPMRC_NOTTRUSTED:
1476 /*@innerbreak@*/ break;
1478 if (rpmteFd(p) != NULL) gotfd = 1;
1483 if (rpmteFd(p) != NULL) {
1485 * XXX Sludge necessary to tranfer existing fstates/actions
1486 * XXX around a recreated file info set.
1488 psm->fi = rpmfiFree(psm->fi);
1490 char * fstates = fi->fstates;
1491 fileAction * actions = fi->actions;
1498 savep = rpmtsSetRelocateElement(ts, p);
1499 fi = rpmfiNew(ts, p->h, RPMTAG_BASENAMES, 1);
1500 (void) rpmtsSetRelocateElement(ts, savep);
1502 if (fi != NULL) { /* XXX can't happen */
1504 fi->fstates = _free(fi->fstates);
1505 fi->fstates = fstates;
1506 fi->actions = _free(fi->actions);
1507 fi->actions = actions;
1511 psm->fi = rpmfiLink(p->fi, NULL);
1515 (void) rpmtsSetFlags(ts, (rpmtsFlags(ts) | RPMTRANS_FLAG_MULTILIB));
1518 (void) rpmtsSetFlags(ts, (rpmtsFlags(ts) & ~RPMTRANS_FLAG_MULTILIB));
1520 /*@-nullstate@*/ /* FIX: psm->fi may be NULL */
1521 if (rpmpsmStage(psm, PSM_PKGINSTALL)) {
1523 lastFailKey = pkgKey;
1528 lastFailKey = pkgKey;
1532 /*@-noeffectuncon @*/ /* FIX: check rc */
1533 (void) ts->notify(p->h, RPMCALLBACK_INST_CLOSE_FILE, 0, 0,
1534 rpmteKey(p), ts->notifyData);
1535 /*@=noeffectuncon @*/
1541 p->h = headerFree(p->h);
1543 /*@switchbreak@*/ break;
1545 rpmMessage(RPMMESS_DEBUG, "========== --- %s\n", rpmteNEVR(p));
1547 * XXX This has always been a hack, now mostly broken.
1548 * If install failed, then we shouldn't erase.
1550 if (rpmteDependsOnKey(p) != lastFailKey) {
1551 if (rpmpsmStage(psm, PSM_PKGERASE))
1554 /*@switchbreak@*/ break;
1556 xx = rpmdbSync(rpmtsGetRdb(ts));
1558 /*@-nullstate@*/ /* FIX: psm->fi may be NULL */
1559 psm = rpmpsmFree(psm);
1562 /*@-type@*/ /* FIX: p is almost opaque */
1563 p->fi = rpmfiFree(p->fi);
1568 pi = rpmtsiFree(pi);
1570 /*@-nullstate@*/ /* FIX: ts->flList may be NULL */