Improve xbps_end() and use it before exit(3)ing.

- Simplify xbps_repo_open::repo_get_dict().
- Use xbps_end() in the utils where necessary.
- Make xbps_end() call xbps_pkgdb_unlock() if necessary.
- Make xbps_end() release rpool resources.
- Make xbps_end() release resources from xbps_handle.
- Fixed 90% of reported leaks (still reachable at exit) from valgrind.

That was to silence valgrind's memcheck with --leak-check=full.

lib/initend.c

@@ -502,6 +502,7 @@ xbps_end(struct xbps_handle *xhp)
 	assert(xhp);
 
 	xbps_pkgdb_release(xhp);
+	xbps_rpool_release(xhp);
 	xbps_fetch_unset_cache_connection();
 }
 

lib/pkgdb.c

@@ -109,11 +109,13 @@ xbps_pkgdb_unlock(struct xbps_handle *xhp)
 {
 	(void)xbps_pkgdb_update(xhp, true);
 
-	if (lockf(pkgdb_fd, F_ULOCK, 0) == -1)
-		xbps_dbg_printf(xhp, "[pkgdb] failed to unlock pkgdb: %s\n", strerror(errno));
+	if (pkgdb_fd != -1) {
+		if (lockf(pkgdb_fd, F_ULOCK, 0) == -1)
+			xbps_dbg_printf(xhp, "[pkgdb] failed to unlock pkgdb: %s\n", strerror(errno));
 
-	(void)close(pkgdb_fd);
-	pkgdb_fd = -1;
+		(void)close(pkgdb_fd);
+		pkgdb_fd = -1;
+	}
 }
 
 static int
@@ -247,8 +249,15 @@ xbps_pkgdb_release(struct xbps_handle *xhp)
 	if (xhp->pkgdb == NULL)
 		return;
 
+	if (xhp->pkgdb_revdeps)
+		xbps_object_release(xhp->pkgdb_revdeps);
+	if (xhp->vpkgd)
+		xbps_object_release(xhp->vpkgd);
+	if (xhp->preserved_files)
+		xbps_object_release(xhp->preserved_files);
+
+	xbps_pkgdb_unlock(xhp);
 	xbps_object_release(xhp->pkgdb);
-	xhp->pkgdb = NULL;
 	xbps_dbg_printf(xhp, "[pkgdb] released ok.\n");
 }
 

lib/repo.c

@@ -57,12 +57,7 @@ xbps_repo_path(struct xbps_handle *xhp, const char *url)
 static xbps_dictionary_t
 repo_get_dict(struct xbps_repo *repo)
 {
-	xbps_dictionary_t d = NULL;
 	struct archive_entry *entry;
-	char *adata = NULL;
-	const void *buf;
-	off_t offset;
-	size_t size;
 	int rv;
 
 	if (repo->ar == NULL)
@@ -75,35 +70,7 @@ repo_get_dict(struct xbps_repo *repo)
 		    archive_error_string(repo->ar));
 		return NULL;
 	}
-	for (;;) {
-		rv = archive_read_data_block(repo->ar, &buf, &size, &offset);
-		if (rv == ARCHIVE_EOF)
-			break;
-		if (rv != ARCHIVE_OK) {
-			if (adata != NULL)
-				free(adata);
-
-			xbps_dbg_printf(repo->xhp,
-			    "%s: read_data_block %s\n", repo->uri,
-			    archive_error_string(repo->ar));
-			return NULL;
-		}
-		if (adata == NULL) {
-			adata = malloc(size);
-		} else {
-			adata = realloc(adata, size+offset);
-			if (adata == NULL) {
-				free(adata);
-				return NULL;
-			}
-		}
-		memcpy(adata+offset, buf, size);
-	}
-	if (adata != NULL) {
-		d = xbps_dictionary_internalize(adata);
-		free(adata);
-	}
-	return d;
+	return xbps_archive_get_dictionary(repo->ar, entry);
 }
 
 static bool
@@ -304,7 +271,6 @@ xbps_repo_close(struct xbps_repo *repo, bool lock)
 		xbps_dbg_printf(repo->xhp, "[repo] failed to unlock %s: %s\n", repo->uri, strerror(errno));
 
 	close(repo->fd);
-	free(repo);
 }
 
 xbps_dictionary_t

lib/rpool.c

@@ -1,5 +1,5 @@
 /*-
- * Copyright (c) 2009-2014 Juan Romero Pardines.
+ * Copyright (c) 2009-2015 Juan Romero Pardines.
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
@@ -91,6 +91,20 @@ xbps_rpool_get_repo(const char *url)
 	return NULL;
 }
 
+void
+xbps_rpool_release(struct xbps_handle *xhp _unused)
+{
+	struct xbps_repo *repo;
+
+	while ((repo = SIMPLEQ_FIRST(&rpool_queue))) {
+	       SIMPLEQ_REMOVE(&rpool_queue, repo, xbps_repo, entries);
+	       xbps_repo_close(repo, true);
+	       free(repo);
+	}
+	if (xhp->repositories)
+		xbps_object_release(xhp->repositories);
+}
+
 int
 xbps_rpool_foreach(struct xbps_handle *xhp,
 	int (*fn)(struct xbps_repo *, void *, bool *),