From e5be34335ca8ff9df4ec53c2ab421522a6ca02c3 Mon Sep 17 00:00:00 2001 From: Timo Teras Date: Fri, 24 Jul 2009 14:00:57 +0300 Subject: db: create cache index with non-repository packages this enables virtual packages and files specified from command line to work on non-harddisk installs. --- src/database.c | 161 ++++++++++++++++++++++++++++++++++++--------------------- 1 file changed, 101 insertions(+), 60 deletions(-) (limited to 'src/database.c') diff --git a/src/database.c b/src/database.c index bf0a0a6..ce90aea 100644 --- a/src/database.c +++ b/src/database.c @@ -1,7 +1,7 @@ /* database.c - Alpine Package Keeper (APK) * * Copyright (C) 2005-2008 Natanael Copa - * Copyright (C) 2008 Timo Teräs + * Copyright (C) 2008-2009 Timo Teräs * All rights reserved. * * This program is free software; you can redistribute it and/or modify it @@ -395,6 +395,23 @@ struct apk_package *apk_db_pkg_add(struct apk_database *db, struct apk_package * return idb; } +static void apk_db_cache_get_name(char *buf, size_t bufsz, + struct apk_database *db, + struct apk_checksum *csum, + const char *file, int temp) +{ + char csumstr[APK_CACHE_CSUM_BYTES*2+1]; + apk_blob_t bbuf = APK_BLOB_BUF(csumstr); + + apk_blob_push_hexdump(&bbuf, + APK_BLOB_PTR_LEN((char *) csum->data, + APK_CACHE_CSUM_BYTES)); + apk_blob_push_blob(&bbuf, APK_BLOB_PTR_LEN("", 1)); + + snprintf(buf, bufsz, "%s/%s/%s.%s%s", + db->root, db->cache_dir, csumstr, file, temp ? ".new" : ""); +} + int apk_db_index_read(struct apk_database *db, struct apk_bstream *bs, int repo) { struct apk_package *pkg = NULL; @@ -410,9 +427,9 @@ int apk_db_index_read(struct apk_database *db, struct apk_bstream *bs, int repo) if (pkg == NULL) continue; - if (repo != -1) + if (repo >= 0) pkg->repos |= BIT(repo); - else + else if (repo == -1) apk_pkg_set_state(db, pkg, APK_PKG_INSTALLED); if (apk_db_pkg_add(db, pkg) != pkg && repo == -1) { @@ -678,6 +695,12 @@ static int apk_db_read_state(struct apk_database *db, int flags) apk_db_index_read(db, bs, -1); bs->close(bs, NULL); } + + bs = apk_bstream_from_file("etc/apk/cache/installed"); + if (bs != NULL) { + apk_db_index_read(db, bs, -2); + bs->close(bs, NULL); + } } if (!(flags & APK_OPENF_NO_SCRIPTS)) { @@ -696,6 +719,73 @@ static int apk_db_read_state(struct apk_database *db, int flags) return 0; } +struct index_write_ctx { + struct apk_ostream *os; + int count; + int force; +}; + +static int write_index_entry(apk_hash_item item, void *ctx) +{ + struct index_write_ctx *iwctx = (struct index_write_ctx *) ctx; + struct apk_package *pkg = (struct apk_package *) item; + int r; + + if (!iwctx->force && pkg->filename == NULL) + return 0; + + r = apk_pkg_write_index_entry(pkg, iwctx->os); + if (r < 0) + return r; + + if (iwctx->os->write(iwctx->os, "\n", 1) != 1) + return -1; + + iwctx->count++; + return 0; +} + +static int apk_db_index_write_nr_cache(struct apk_database *db) +{ + struct index_write_ctx ctx = { NULL, 0, TRUE }; + struct apk_package *pkg; + struct apk_ostream *os; + int r; + + if (!apk_db_cache_active(db)) + return 0; + + /* Write list of installed non-repository packages to + * cached index file */ + ctx.os = os = apk_ostream_to_file("etc/apk/cache/installed.new", 0644); + if (os == NULL) + return -1; + + list_for_each_entry(pkg, &db->installed.packages, installed_pkgs_list) { + if (pkg->repos != 0) + continue; + r = write_index_entry(pkg, &ctx); + if (r != 0) + return r; + } + + os->close(os); + if (rename("etc/apk/cache/installed.new", + "etc/apk/cache/installed") < 0) + return -errno; + + return ctx.count; +} + +int apk_db_index_write(struct apk_database *db, struct apk_ostream *os) +{ + struct index_write_ctx ctx = { os, 0, FALSE }; + + apk_hash_foreach(&db->available.packages, write_index_entry, &ctx); + + return ctx.count; +} + static int add_protected_path(void *ctx, apk_blob_t blob) { struct apk_database *db = (struct apk_database *) ctx; @@ -746,6 +836,7 @@ int apk_db_open(struct apk_database *db, const char *root, unsigned int flags) apk_hash_init(&db->installed.files, &file_hash_ops, 10000); list_init(&db->installed.packages); db->cache_dir = apk_static_cache_dir; + db->permanent = 1; if (root != NULL) { fchdir(apk_cwd_fd); @@ -759,6 +850,8 @@ int apk_db_open(struct apk_database *db, const char *root, unsigned int flags) msg = "Unable to open root"; goto ret_errno; } + if (fstat(db->root_fd, &st) != 0 || major(st.st_dev) == 0) + db->permanent = 0; fchdir(db->root_fd); if (stat(apk_linked_cache_dir, &st) == 0 && S_ISDIR(st.st_mode)) @@ -834,6 +927,9 @@ int apk_db_open(struct apk_database *db, const char *root, unsigned int flags) if (!(flags & APK_OPENF_NO_REPOS)) { list_for_each_entry(repo, &apk_repository_list.list, list) apk_db_add_repository(db, APK_BLOB_STR(repo->url)); + + if (apk_flags & APK_UPDATE_CACHE) + apk_db_index_write_nr_cache(db); } fchdir(apk_cwd_fd); @@ -895,6 +991,7 @@ int apk_db_write_config(struct apk_database *db) return -errno; unlink("var/lib/apk/scripts"); + apk_db_index_write_nr_cache(db); return 0; } @@ -943,13 +1040,7 @@ int apk_db_cache_active(struct apk_database *db) int apk_db_permanent(struct apk_database *db) { - struct stat st; - - if (fstat(db->root_fd, &st) != 0) - return 0; - if (major(st.st_dev) == 0) - return 0; - return 1; + return db->permanent; } struct apk_package *apk_db_get_pkg(struct apk_database *db, @@ -978,56 +1069,6 @@ struct apk_package *apk_db_get_file_owner(struct apk_database *db, return dbf->diri->pkg; } -struct index_write_ctx { - struct apk_ostream *os; - int count; -}; - -static int write_index_entry(apk_hash_item item, void *ctx) -{ - struct index_write_ctx *iwctx = (struct index_write_ctx *) ctx; - struct apk_package *pkg = (struct apk_package *) item; - int r; - - if (pkg->filename == NULL) - return 0; - - r = apk_pkg_write_index_entry(pkg, iwctx->os); - if (r < 0) - return r; - - if (iwctx->os->write(iwctx->os, "\n", 1) != 1) - return -1; - - iwctx->count++; - return 0; -} - -int apk_db_index_write(struct apk_database *db, struct apk_ostream *os) -{ - struct index_write_ctx ctx = { os, 0 }; - - apk_hash_foreach(&db->available.packages, write_index_entry, &ctx); - - return ctx.count; -} - -static void apk_db_cache_get_name(char *buf, size_t bufsz, - struct apk_database *db, - struct apk_checksum *csum, - const char *file, int temp) -{ - char csumstr[APK_CACHE_CSUM_BYTES*2+1]; - apk_blob_t bbuf = APK_BLOB_BUF(csumstr); - - apk_blob_push_hexdump(&bbuf, - APK_BLOB_PTR_LEN((char *) csum->data, APK_CACHE_CSUM_BYTES)); - apk_blob_push_blob(&bbuf, APK_BLOB_PTR_LEN("", 1)); - - snprintf(buf, bufsz, "%s/%s/%s.%s%s", - db->root, db->cache_dir, csumstr, file, temp ? ".new" : ""); -} - static struct apk_bstream *apk_db_cache_open(struct apk_database *db, struct apk_checksum *csum, const char *file) -- cgit v1.2.3-60-g2f50