summaryrefslogtreecommitdiffstats
path: root/src/pacman/sync.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/pacman/sync.c')
-rw-r--r--src/pacman/sync.c179
1 files changed, 93 insertions, 86 deletions
diff --git a/src/pacman/sync.c b/src/pacman/sync.c
index 35e8513b..fb00c78d 100644
--- a/src/pacman/sync.c
+++ b/src/pacman/sync.c
@@ -63,97 +63,98 @@ static int sync_cleancache(int level)
alpm_get_option(PM_OPT_ROOT, (long *)&root);
- if(level == 1) {
- /* incomplete cleanup: we keep latest packages and partial downloads */
- DIR *dir;
- struct dirent *ent;
- list_t *cache = NULL;
- list_t *clean = NULL;
- list_t *i, *j;
- char dirpath[PATH_MAX];
-
- snprintf(dirpath, PATH_MAX, "%s"CACHEDIR, root);
-
- MSG(NL, "removing old packages from cache... ");
- dir = opendir(dirpath);
- if(dir == NULL) {
- ERR(NL, "could not access cache directory\n");
- return(1);
- }
- rewinddir(dir);
- while((ent = readdir(dir)) != NULL) {
- if(!strcmp(ent->d_name, ".") || !strcmp(ent->d_name, "..")) {
- continue;
- }
- cache = list_add(cache, strdup(ent->d_name));
+ if(level == 1) {
+ /* incomplete cleanup: we keep latest packages and partial downloads */
+ DIR *dir;
+ struct dirent *ent;
+ list_t *cache = NULL;
+ list_t *clean = NULL;
+ list_t *i, *j;
+ char dirpath[PATH_MAX];
+
+ snprintf(dirpath, PATH_MAX, "%s" CACHEDIR, root);
+
+ MSG(NL, "removing old packages from cache... ");
+ dir = opendir(dirpath);
+ if(dir == NULL) {
+ ERR(NL, "could not access cache directory\n");
+ return(1);
+ }
+ rewinddir(dir);
+ while((ent = readdir(dir)) != NULL) {
+ if(!strcmp(ent->d_name, ".") || !strcmp(ent->d_name, "..")) {
+ continue;
}
- closedir(dir);
+ cache = list_add(cache, strdup(ent->d_name));
+ }
+ closedir(dir);
+
+ for(i = cache; i; i = i->next) {
+ char *str = i->data;
+ char name[256], version[64];
- for(i = cache; i; i = i->next) {
- char *str = i->data;
- char name[256], version[64];
+ if(strstr(str, PM_EXT_PKG) == NULL) {
+ clean = list_add(clean, strdup(str));
+ continue;
+ }
+ /* we keep partially downloaded files */
+ if(strstr(str, PM_EXT_PKG ".part")) {
+ continue;
+ }
+ if(split_pkgname(str, name, version) != 0) {
+ clean = list_add(clean, strdup(str));
+ continue;
+ }
+ for(j = i->next; j; j = j->next) {
+ char *s = j->data;
+ char n[256], v[64];
- if(strstr(str, PM_EXT_PKG) == NULL) {
- clean = list_add(clean, strdup(str));
+ if(strstr(s, PM_EXT_PKG) == NULL) {
continue;
}
- /* we keep partially downloaded files */
- if(strstr(str, PM_EXT_PKG".part")) {
+ if(strstr(s, PM_EXT_PKG ".part")) {
continue;
}
- if(split_pkgname(str, name, version) != 0) {
- clean = list_add(clean, strdup(str));
+ if(split_pkgname(s, n, v) != 0) {
continue;
}
- for(j = i->next; j; j = j->next) {
- char *s = j->data;
- char n[256], v[64];
-
- if(strstr(s, PM_EXT_PKG) == NULL) {
- continue;
- }
- if(strstr(s, PM_EXT_PKG".part")) {
- continue;
- }
- if(split_pkgname(s, n, v) != 0) {
- continue;
- }
- if(!strcmp(name, n)) {
- char *ptr = (alpm_pkg_vercmp(version, v) < 0) ? str : s;
- if(!list_is_strin(ptr, clean)) {
- clean = list_add(clean, strdup(ptr));
- }
+ if(!strcmp(name, n)) {
+ char *ptr = (alpm_pkg_vercmp(version, v) < 0) ? str : s;
+ if(!list_is_strin(ptr, clean)) {
+ clean = list_add(clean, strdup(ptr));
}
}
}
- FREELIST(cache);
-
- for(i = clean; i; i = i->next) {
- char path[PATH_MAX];
+ }
+ FREELIST(cache);
- snprintf(path, PATH_MAX, "%s"CACHEDIR"/%s", root, (char *)i->data);
- unlink(path);
- }
- FREELIST(clean);
- } else {
- /* full cleanup */
+ for(i = clean; i; i = i->next) {
char path[PATH_MAX];
- snprintf(path, PATH_MAX, "%s"CACHEDIR, root);
+ snprintf(path, PATH_MAX, "%s" CACHEDIR "/%s", root, (char *)i->data);
+ unlink(path);
+ }
+ FREELIST(clean);
+ } else {
+ /* full cleanup */
+ char path[PATH_MAX];
- MSG(NL, "removing all packages from cache... ");
- if(rmrf(path)) {
- ERR(NL, "could not remove cache directory\n");
- return(1);
- }
+ snprintf(path, PATH_MAX, "%s" CACHEDIR, root);
- if(makepath(path)) {
- ERR(NL, "could not create new cache directory\n");
- return(1);
- }
+ MSG(NL, "removing all packages from cache... ");
+ if(rmrf(path)) {
+ ERR(NL, "could not remove cache directory\n");
+ return(1);
+ }
+
+ if(makepath(path)) {
+ ERR(NL, "could not create new cache directory\n");
+ return(1);
}
- MSG(CL, "done.\n");
- return(0);
+ }
+
+ MSG(CL, "done.\n");
+ return(0);
}
static int sync_synctree(list_t *syncs)
@@ -181,7 +182,7 @@ static int sync_synctree(list_t *syncs)
mtime = lastupdate;
/* build a one-element list */
- snprintf(path, PATH_MAX, "%s"PM_EXT_DB, sync->treename);
+ snprintf(path, PATH_MAX, "%s" PM_EXT_DB, sync->treename);
files = list_add(files, strdup(path));
snprintf(path, PATH_MAX, "%s%s", root, dbpath);
@@ -193,9 +194,9 @@ static int sync_synctree(list_t *syncs)
ERR(NL, "failed to synchronize %s\n", sync->treename);
success--;
} else if(ret < 0) {
- MSG(NL, ":: %s is up to date\n", sync->treename);
+ MSG(NL, " %s is up to date\n", sync->treename);
} else {
- snprintf(path, PATH_MAX, "%s%s/%s"PM_EXT_DB, root, dbpath, sync->treename);
+ snprintf(path, PATH_MAX, "%s%s/%s" PM_EXT_DB, root, dbpath, sync->treename);
if(alpm_db_update(sync->db, path, newmtime) == -1) {
ERR(NL, "failed to synchronize %s (%s)\n", sync->treename, alpm_strerror(pm_errno));
success--;
@@ -313,36 +314,38 @@ static int sync_info(list_t *syncs, list_t *targets)
static int sync_list(list_t *syncs, list_t *targets)
{
- list_t *i, *treenames = NULL;
+ list_t *i;
+ list_t *ls = NULL;
if(targets) {
for(i = targets; i; i = i->next) {
list_t *j;
sync_t *sync = NULL;
- for(j = syncs; j; j = j->next) {
+ for(j = syncs; j && !sync; j = j->next) {
sync_t *s = j->data;
if(strcmp(i->data, s->treename) == 0) {
- MALLOC(sync, sizeof(sync_t));
- sync->treename = i->data;
- sync->db = s->db;
+ sync = s;
}
}
if(sync == NULL) {
ERR(NL, "repository \"%s\" was not found.\n", (char *)i->data);
- list_free(treenames);
+ for(j = ls; j; j = j->next) {
+ j->data = NULL;
+ }
+ list_free(ls);
return(1);
}
- treenames = list_add(treenames, sync);
+ ls = list_add(ls, sync);
}
} else {
- treenames = syncs;
+ ls = syncs;
}
- for(i = treenames; i; i = i->next) {
+ for(i = ls; i; i = i->next) {
PM_LIST *lp;
sync_t *sync = i->data;
@@ -354,7 +357,10 @@ static int sync_list(list_t *syncs, list_t *targets)
}
if(targets) {
- list_free(treenames);
+ for(i = ls; i; i = i->next) {
+ i->data = NULL;
+ }
+ list_free(ls);
}
return(0);
@@ -424,6 +430,7 @@ int pacman_sync(list_t *targets)
}
if(pmo_s_upgrade) {
+ MSG(NL, ":: Starting local database upgrade...\n");
alpm_logaction("starting full system upgrade");
if(alpm_trans_sysupgrade() == -1) {
ERR(NL, "%s\n", alpm_strerror(pm_errno));
generated by cgit v1.2.3-24-g4f1b (git 2.32.0) at 2024-12-04 22:55:27 +0100