Blame db_conversion.diff

e0a517
--- lib/backend/bdb_ro.c.orig	2022-04-07 11:13:18.994517848 +0000
e0a517
+++ lib/backend/bdb_ro.c	2022-12-02 13:22:16.726408071 +0000
e0a517
@@ -793,6 +793,7 @@ static unsigned int bdbro_pkgdbKey(dbiIn
Bernhard M. Wiedemann 018f1b
 struct rpmdbOps_s bdbro_dbops = {
Bernhard M. Wiedemann 018f1b
     .name       = "bdb_ro",
Bernhard M. Wiedemann 018f1b
     .path       = "Packages",
Bernhard M. Wiedemann 018f1b
+    .readonly   = 1,
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
     .open       = bdbro_Open,
Bernhard M. Wiedemann 018f1b
     .close      = bdbro_Close,
e0a517
--- lib/backend/dbi.c.orig	2022-04-07 11:13:18.994517848 +0000
e0a517
+++ lib/backend/dbi.c	2022-12-02 13:22:16.726408071 +0000
e0a517
@@ -138,11 +138,20 @@ exit:
Bernhard M. Wiedemann 018f1b
     }
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
     rdb->db_descr = rdb->db_ops->name;
ee825d
+    rdb->db_ops_config = cfg;
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
     if (db_backend)
Bernhard M. Wiedemann 018f1b
 	free(db_backend);
Bernhard M. Wiedemann 018f1b
 }
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
+int dbiNeedConversion(rpmdb rdb)
Bernhard M. Wiedemann 018f1b
+{
Bernhard M. Wiedemann 018f1b
+    if (!rdb->db_ops)
Bernhard M. Wiedemann 018f1b
+	dbDetectBackend(rdb);
Bernhard M. Wiedemann 018f1b
+    return rdb->db_ops->readonly && rdb->db_ops_config
Bernhard M. Wiedemann 018f1b
+	&& rdb->db_ops_config->path && !rdb->db_ops_config->readonly;
Bernhard M. Wiedemann 018f1b
+}
Bernhard M. Wiedemann 018f1b
+
Bernhard M. Wiedemann 018f1b
 const char * dbiName(dbiIndex dbi)
Bernhard M. Wiedemann 018f1b
 {
Bernhard M. Wiedemann 018f1b
     return dbi->dbi_file;
e0a517
--- lib/backend/dbi.h.orig	2022-04-07 11:13:18.994517848 +0000
e0a517
+++ lib/backend/dbi.h	2022-12-02 13:22:16.726408071 +0000
e0a517
@@ -13,6 +13,7 @@ enum rpmdbFlags {
Bernhard M. Wiedemann 018f1b
     RPMDB_FLAG_REBUILD		= (1 << 1),
Bernhard M. Wiedemann 018f1b
     RPMDB_FLAG_VERIFYONLY	= (1 << 2),
ee825d
     RPMDB_FLAG_SALVAGE		= (1 << 3),
ee825d
+    RPMDB_FLAG_CONVERT		= (1 << 4),
Bernhard M. Wiedemann 018f1b
 };
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
 typedef enum dbCtrlOp_e {
e0a517
@@ -53,6 +54,7 @@ struct rpmdb_s {
Bernhard M. Wiedemann 018f1b
     int		db_buildindex;	/*!< Index rebuild indicator */
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
     const struct rpmdbOps_s * db_ops;	/*!< backend ops */
Bernhard M. Wiedemann 018f1b
+    const struct rpmdbOps_s * db_ops_config;	/*!< configured backend ops */
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
     /* dbenv and related parameters */
Bernhard M. Wiedemann 018f1b
     void * db_dbenv;		/*!< Backend private handle */
e0a517
@@ -197,6 +199,14 @@ RPM_GNUC_INTERNAL
Bernhard M. Wiedemann 018f1b
 const char * dbiName(dbiIndex dbi);
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
 /** \ingroup dbi
Bernhard M. Wiedemann 018f1b
+ * Check if the database needs to be converted to a different format
Bernhard M. Wiedemann 018f1b
+ * @param db           rpm database
Bernhard M. Wiedemann 018f1b
+ * @return             boolean
Bernhard M. Wiedemann 018f1b
+ */
Bernhard M. Wiedemann 018f1b
+RPM_GNUC_INTERNAL
Bernhard M. Wiedemann 018f1b
+int dbiNeedConversion(rpmdb rdb);
Bernhard M. Wiedemann 018f1b
+
Bernhard M. Wiedemann 018f1b
+/** \ingroup dbi
Bernhard M. Wiedemann 018f1b
  * Open a database cursor.
Bernhard M. Wiedemann 018f1b
  * @param dbi		index database handle
Bernhard M. Wiedemann 018f1b
  * @param flags		DBC_WRITE if writing, or 0 (DBC_READ) for reading
e0a517
@@ -240,6 +250,7 @@ const void * idxdbKey(dbiIndex dbi, dbiC
Bernhard M. Wiedemann 018f1b
 struct rpmdbOps_s {
Bernhard M. Wiedemann 018f1b
     const char *name; /* backend name */
Bernhard M. Wiedemann 018f1b
     const char *path; /* main database name */
Bernhard M. Wiedemann 018f1b
+    int readonly;     /* cannot modify database */
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
     int (*open)(rpmdb rdb, rpmDbiTagVal rpmtag, dbiIndex * dbip, int flags);
Bernhard M. Wiedemann 018f1b
     int (*close)(dbiIndex dbi, unsigned int flags);
e0a517
--- lib/backend/ndb/rpmpkg.c.orig	2022-04-07 11:13:18.997517869 +0000
e0a517
+++ lib/backend/ndb/rpmpkg.c	2022-12-02 13:22:16.726408071 +0000
ee825d
@@ -1116,11 +1116,12 @@ static int rpmpkgPutInternal(rpmpkgdb pk
ee825d
     if (rpmpkgWriteBlob(pkgdb, pkgidx, blkoff, blkcnt, blob, blobl, pkgdb->generation)) {
ee825d
 	return RPMRC_FAIL;
ee825d
     }
ee825d
+    /* update nextpkgidx if needed */
ee825d
+    if (pkgidx >= pkgdb->nextpkgidx) {
ee825d
+	pkgdb->nextpkgidx = pkgidx + 1; 
ee825d
+    }    
ee825d
     /* write slot */
ee825d
     slotno = oldslot ? oldslot->slotno : pkgdb->freeslot;
ee825d
-    if (!slotno) {
ee825d
-	return RPMRC_FAIL;
ee825d
-    }
ee825d
     if (rpmpkgWriteslot(pkgdb, slotno, pkgidx, blkoff, blkcnt)) {
ee825d
 	free(pkgdb->slots);
ee825d
 	pkgdb->slots = 0;
e0a517
--- lib/rpmdb.c.orig	2022-09-20 12:08:27.197920294 +0000
e0a517
+++ lib/rpmdb.c	2022-12-02 13:24:02.830159868 +0000
e0a517
@@ -469,7 +469,12 @@ static int openDatabase(const char * pre
e0a517
 	/* Open just bare minimum when rebuilding a potentially damaged db */
e0a517
 	int justPkgs = (db->db_flags & RPMDB_FLAG_REBUILD) &&
e0a517
 		       ((db->db_mode & O_ACCMODE) == O_RDONLY);
ee825d
-	rc = doOpen(db, justPkgs);
Bernhard M. Wiedemann 018f1b
+	if (!db->db_pkgs && !justCheck && (mode & O_ACCMODE) == O_RDWR && dbiNeedConversion(db)) {
ee825d
+	    rc = rpmdbRebuild(prefix, NULL, NULL, RPMDB_REBUILD_FLAG_CONVERT);
Bernhard M. Wiedemann 018f1b
+	    db->db_ops = NULL;		/* force re-detection of backend */
Bernhard M. Wiedemann 018f1b
+	}
Bernhard M. Wiedemann 018f1b
+	if (!rc)
ee825d
+	    rc = doOpen(db, justPkgs);
ee825d
 
Bernhard M. Wiedemann 018f1b
 	if (!db->db_descr)
Bernhard M. Wiedemann 018f1b
 	    db->db_descr = "unknown db";
e0a517
@@ -2228,6 +2233,15 @@ int rpmdbAdd(rpmdb db, Header h)
Bernhard M. Wiedemann 018f1b
     if (db == NULL)
Bernhard M. Wiedemann 018f1b
 	return 0;
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
+    if ((db->db_flags & RPMDB_FLAG_CONVERT) != 0) {
Bernhard M. Wiedemann 018f1b
+	/* keep old instance numbers when converting */
Bernhard M. Wiedemann 018f1b
+	hdrNum = headerGetInstance(h);
Bernhard M. Wiedemann 018f1b
+	if (hdrNum == 0) {
Bernhard M. Wiedemann 018f1b
+	    ret = -1;
Bernhard M. Wiedemann 018f1b
+	    goto exit;
Bernhard M. Wiedemann 018f1b
+	}
Bernhard M. Wiedemann 018f1b
+    }
Bernhard M. Wiedemann 018f1b
+
Bernhard M. Wiedemann 018f1b
     hdrBlob = headerExport(h, &hdrLen);
Bernhard M. Wiedemann 018f1b
     if (hdrBlob == NULL || hdrLen == 0) {
Bernhard M. Wiedemann 018f1b
 	ret = -1;
e0a517
@@ -2423,7 +2437,22 @@ int rpmdbRebuild(const char * prefix, rp
Bernhard M. Wiedemann 6f42b1
     }
Bernhard M. Wiedemann 6f42b1
     rootdbpath = rpmGetPath(prefix, dbpath, NULL);
Bernhard M. Wiedemann 6f42b1
 
Bernhard M. Wiedemann 6f42b1
-    newdbpath = rpmGetPath("%{?_dbpath_rebuild}", NULL);
ee825d
+    if ((rebuildflags & RPMDB_REBUILD_FLAG_CONVERT) != 0) {
Bernhard M. Wiedemann 6f42b1
+	char lbuf[PATH_MAX];
Bernhard M. Wiedemann 6f42b1
+	ssize_t s = readlink(rootdbpath, lbuf, PATH_MAX);
Bernhard M. Wiedemann 6f42b1
+	if (s > 0 && s < PATH_MAX) {
Bernhard M. Wiedemann 6f42b1
+	    lbuf[s] = 0;
Bernhard M. Wiedemann 6f42b1
+	    free(dbpath);
Bernhard M. Wiedemann 6f42b1
+	    if (lbuf[0] == '/')
Bernhard M. Wiedemann 6f42b1
+		dbpath = strdup(lbuf);
Bernhard M. Wiedemann 6f42b1
+	    else
Bernhard M. Wiedemann 6f42b1
+		dbpath = rpmGetPath("%{?_dbpath}", "/../", lbuf, NULL);
Bernhard M. Wiedemann 6f42b1
+	    free(rootdbpath);
Bernhard M. Wiedemann 6f42b1
+	    rootdbpath = rpmGetPath(prefix, dbpath, NULL);
Bernhard M. Wiedemann 6f42b1
+	}
Bernhard M. Wiedemann 6f42b1
+	newdbpath = strdup("");
Bernhard M. Wiedemann 6f42b1
+    } else
Bernhard M. Wiedemann 6f42b1
+	newdbpath = rpmGetPath("%{?_dbpath_rebuild}", NULL);
Bernhard M. Wiedemann 6f42b1
     if (rstreq(newdbpath, "") || rstreq(newdbpath, dbpath)) {
Bernhard M. Wiedemann 6f42b1
 	newdbpath = _free(newdbpath);
Bernhard M. Wiedemann 6f42b1
 	rasprintf(&newdbpath, "%srebuilddb.%d", dbpath, (int) getpid());
e0a517
@@ -2449,7 +2478,9 @@ int rpmdbRebuild(const char * prefix, rp
Bernhard M. Wiedemann 018f1b
 	goto exit;
Bernhard M. Wiedemann 018f1b
     }
Bernhard M. Wiedemann 018f1b
     if (openDatabase(prefix, newdbpath, &newdb,
Bernhard M. Wiedemann 018f1b
-		     (O_RDWR | O_CREAT), 0644, RPMDB_FLAG_REBUILD)) {
ee825d
+		     (O_RDWR | O_CREAT), 0644, RPMDB_FLAG_REBUILD |
ee825d
+		     (rebuildflags & RPMDB_REBUILD_FLAG_CONVERT ?
ee825d
+			 RPMDB_FLAG_CONVERT : 0))) {
Bernhard M. Wiedemann 018f1b
 	rc = 1;
Bernhard M. Wiedemann 018f1b
 	goto exit;
Bernhard M. Wiedemann 018f1b
     }
e0a517
--- lib/rpmdb_internal.h.orig	2022-04-07 11:13:19.014517984 +0000
e0a517
+++ lib/rpmdb_internal.h	2022-12-02 13:22:16.726408071 +0000
ee825d
@@ -25,6 +25,7 @@ extern "C" {
ee825d
 
ee825d
 enum rpmdbRebuildFlags_e {
ee825d
     RPMDB_REBUILD_FLAG_SALVAGE	= (1 << 0),
ee825d
+    RPMDB_REBUILD_FLAG_CONVERT	= (1 << 1),
ee825d
 };
Bernhard M. Wiedemann 018f1b
 
Bernhard M. Wiedemann 018f1b
 /** \ingroup rpmdb