Radish alpha
H
rad:z3QDZAW2FAfuLvihrhiyDC9fAD8G9
HardenedBSD Package Manager
Radicle
Git
Refactor names.
Vsevolod Stakhov committed 11 years ago
commit 1a2e31088172d46415c1914207206e62dd468620
parent f320df5
4 files changed +38 -40
modified libpkg/pkg_jobs.c
@@ -387,7 +387,7 @@ pkg_jobs_test_automatic(struct pkg_jobs *j, struct pkg *p)
			npkg = unit->pkg;
		}
		else {
-
			npkg = pkg_universe_get_local_pkg(j->universe, d->uid,
+
			npkg = pkg_jobs_universe_get_local(j->universe, d->uid,
					PKG_LOAD_BASIC|PKG_LOAD_RDEPS|PKG_LOAD_ANNOTATIONS);
			pkg_get(npkg, PKG_AUTOMATIC, &automatic);
			if (npkg == NULL)
@@ -399,7 +399,7 @@ pkg_jobs_test_automatic(struct pkg_jobs *j, struct pkg *p)
				pkg_free(npkg);
				return (false);
			}
-
			if (pkg_jobs_universe_process_package(j->universe, npkg) != EPKG_OK)
+
			if (pkg_jobs_universe_process(j->universe, npkg) != EPKG_OK)
				return (false);
		}

@@ -424,11 +424,11 @@ new_pkg_version(struct pkg_jobs *j)
	j->flags &= ~(PKG_FLAG_FORCE|PKG_FLAG_RECURSIVE);

	/* determine local pkgng */
-
	p = pkg_universe_get_local_pkg(j->universe, uid, 0);
+
	p = pkg_jobs_universe_get_local(j->universe, uid, 0);

	if (p == NULL) {
		uid = "pkg~ports-mgmt/pkg-devel";
-
		p = pkg_universe_get_local_pkg(j->universe, uid, 0);
+
		p = pkg_jobs_universe_get_local(j->universe, uid, 0);
	}

	/* you are using git version skip */
@@ -437,7 +437,7 @@ new_pkg_version(struct pkg_jobs *j)
		goto end;
	}

-
	pkg_jobs_universe_process_package(j->universe, p);
+
	pkg_jobs_universe_process(j->universe, p);

	/* Use maximum priority for pkg */
	if (pkg_jobs_find_upgrade(j, uid, MATCH_EXACT) == EPKG_OK) {
@@ -496,7 +496,7 @@ pkg_jobs_process_remote_pkg(struct pkg_jobs *j, struct pkg *p,
	jit = pkg_jobs_universe_find(j->universe, uid);
	if (jit != NULL) {
		/* We have a more recent package */
-
		if (!force && !pkg_need_upgrade(p, jit->pkg)) {
+
		if (!force && !pkg_jobs_need_upgrade(p, jit->pkg)) {
			/*
			 * We can have package from another repo in the
			 * universe, but if it is older than this one we just
@@ -526,7 +526,7 @@ pkg_jobs_process_remote_pkg(struct pkg_jobs *j, struct pkg *p,

	rc = EPKG_OK;
	/* Add a package to request chain and populate universe */
-
	rc = pkg_jobs_process_universe(j->universe, p, &jit);
+
	rc = pkg_jobs_universe_process_item(j->universe, p, &jit);

	if (rc == EPKG_OK)
		if (unit != NULL)
@@ -677,19 +677,19 @@ pkg_jobs_find_upgrade(struct pkg_jobs *j, const char *pattern, match_t m)
		 * Here we need to ensure that this package has no
		 * reverse deps installed
		 */
-
		p = pkg_universe_get_local_pkg(j->universe, pattern, PKG_LOAD_BASIC|PKG_LOAD_RDEPS);
+
		p = pkg_jobs_universe_get_local(j->universe, pattern, PKG_LOAD_BASIC|PKG_LOAD_RDEPS);
		if (p == NULL)
			return (EPKG_FATAL);

-
		pkg_jobs_universe_process_package(j->universe, p);
+
		pkg_jobs_universe_process(j->universe, p);

		while(pkg_rdeps(p, &rdep) == EPKG_OK) {
			struct pkg *rdep_package;

-
			rdep_package = pkg_universe_get_local_pkg(j->universe, rdep->uid,
+
			rdep_package = pkg_jobs_universe_get_local(j->universe, rdep->uid,
					PKG_LOAD_BASIC);
			if (rdep_package != NULL) {
-
				pkg_jobs_universe_process_package(j->universe, rdep_package);
+
				pkg_jobs_universe_process(j->universe, rdep_package);
				/* It is not a top level package */
				return (EPKG_END);
			}
@@ -789,7 +789,7 @@ pkg_jobs_find_remote_pattern(struct pkg_jobs *j, struct job_pattern *jp,
}

bool
-
pkg_need_upgrade(struct pkg *rp, struct pkg *lp)
+
pkg_jobs_need_upgrade(struct pkg *rp, struct pkg *lp)
{
	int ret, ret1, ret2;
	const char *lversion, *rversion, *larch, *rarch, *reponame, *origin;
@@ -1097,7 +1097,7 @@ jobs_solve_deinstall(struct pkg_jobs *j)
				PKG_LOAD_BASIC|PKG_LOAD_RDEPS|PKG_LOAD_DEPS|PKG_LOAD_ANNOTATIONS) == EPKG_OK) {
			// Check if the pkg is locked
			pkg_get(pkg, PKG_UNIQUEID, &uid);
-
			pkg_jobs_process_universe(j->universe, pkg, &unit);
+
			pkg_jobs_universe_process_item(j->universe, pkg, &unit);
			if(pkg_is_locked(pkg)) {
				pkg_emit_locked(pkg);
			}
@@ -1135,7 +1135,7 @@ jobs_solve_autoremove(struct pkg_jobs *j)
		pkg_get(pkg, PKG_UNIQUEID, &uid);
		unit = pkg_jobs_universe_find(j->universe, uid);
		if (unit == NULL) {
-
			pkg_jobs_process_universe(j->universe, pkg, &unit);
+
			pkg_jobs_universe_process_item(j->universe, pkg, &unit);
			if(pkg_is_locked(pkg)) {
				pkg_emit_locked(pkg);
			}
@@ -1286,7 +1286,7 @@ jobs_solve_install_upgrade(struct pkg_jobs *j)

				while (pkgdb_it_next(it, &pkg, flags) == EPKG_OK) {
					/* TODO: use repository priority here */
-
					pkg_jobs_universe_process_package(j->universe, pkg);
+
					pkg_jobs_universe_process(j->universe, pkg);
					pkg_get(pkg, PKG_UNIQUEID, &uid, PKG_AUTOMATIC, &automatic);
					/* Do not test we ignore what doesn't exists remotely */
					pkg_jobs_find_upgrade(j, uid, MATCH_EXACT);
@@ -1313,7 +1313,7 @@ jobs_solve_install_upgrade(struct pkg_jobs *j)
				 * Need to iterate request one more time to recurse depends
				 */
				HASH_ITER(hh, j->request_add, req, rtmp) {
-
					pkg_jobs_universe_process_package(j->universe, req->item->pkg);
+
					pkg_jobs_universe_process(j->universe, req->item->pkg);
				}
			}
		}
@@ -1324,7 +1324,7 @@ jobs_solve_install_upgrade(struct pkg_jobs *j)
		 * request packages to the universe to find out any potential conflicts
		 */
		HASH_ITER(hh, j->request_add, req, rtmp) {
-
			pkg_jobs_universe_process_package(j->universe, req->item->pkg);
+
			pkg_jobs_universe_process(j->universe, req->item->pkg);
		}
	}

modified libpkg/pkg_jobs_conflicts.c
@@ -181,9 +181,9 @@ pkg_conflicts_add_missing(struct pkg_jobs *j, const char *uid)
	struct pkg *npkg;


-
	npkg = pkg_universe_get_local_pkg(j->universe, uid, 0);
+
	npkg = pkg_jobs_universe_get_local(j->universe, uid, 0);
	if (npkg == NULL) {
-
		npkg = pkg_universe_get_remote_pkg(j->universe, uid, 0);
+
		npkg = pkg_jobs_universe_get_remote(j->universe, uid, 0);
		pkg_debug(2, "conflicts: add missing remote %s(%d)", uid);
	}
	else {
@@ -196,7 +196,7 @@ pkg_conflicts_add_missing(struct pkg_jobs *j, const char *uid)
		return (EPKG_FATAL);
	}

-
	return pkg_jobs_universe_process_package(j->universe, npkg);
+
	return pkg_jobs_universe_process(j->universe, npkg);
}


modified libpkg/pkg_jobs_universe.c
@@ -41,7 +41,7 @@
#define IS_DELETE(j) ((j)->type == PKG_JOBS_DEINSTALL || (j)->type == PKG_JOBS_AUTOREMOVE)

struct pkg *
-
pkg_universe_get_local_pkg(struct pkg_jobs_universe *universe,
+
pkg_jobs_universe_get_local(struct pkg_jobs_universe *universe,
	const char *uid, unsigned flag)
{
	struct pkg *pkg = NULL;
@@ -75,7 +75,7 @@ pkg_universe_get_local_pkg(struct pkg_jobs_universe *universe,
}

struct pkg *
-
pkg_universe_get_remote_pkg(struct pkg_jobs_universe *universe,
+
pkg_jobs_universe_get_remote(struct pkg_jobs_universe *universe,
	const char *uid, unsigned flag)
{
	struct pkg *pkg = NULL;
@@ -208,14 +208,14 @@ pkg_jobs_universe_process_deps(struct pkg_jobs_universe *universe,
		rpkg = NULL;
		npkg = NULL;
		if (!(flags & DEPS_FLAG_MIRROR))
-
			npkg = pkg_universe_get_local_pkg(universe, d->uid, 0);
+
			npkg = pkg_jobs_universe_get_local(universe, d->uid, 0);

		if (!(flags & DEPS_FLAG_FORCE_LOCAL)) {

			/* Check for remote dependencies */
-
			rpkg = pkg_universe_get_remote_pkg(universe, d->uid, 0);
+
			rpkg = pkg_jobs_universe_get_remote(universe, d->uid, 0);
			if (rpkg != NULL && !(flags & DEPS_FLAG_FORCE_UPGRADE)) {
-
				if (!pkg_need_upgrade(rpkg, npkg, false)) {
+
				if (!pkg_jobs_need_upgrade(rpkg, npkg, false)) {
					/*
					 * We can do it safely here, as rpkg is definitely NOT in
					 * the universe
@@ -273,7 +273,7 @@ pkg_jobs_universe_process_conflicts(struct pkg_jobs_universe *universe,
		/* Check local and remote conflicts */
		if (pkg->type == PKG_INSTALLED) {
			/* Installed packages can conflict with remote ones */
-
			npkg = pkg_universe_get_remote_pkg(universe, pkg_conflict_uniqueid(c), 0);
+
			npkg = pkg_jobs_universe_get_remote(universe, pkg_conflict_uniqueid(c), 0);
			if (npkg == NULL)
				continue;

@@ -281,13 +281,13 @@ pkg_jobs_universe_process_conflicts(struct pkg_jobs_universe *universe,
		}
		else {
			/* Remote packages can conflict with remote and local */
-
			npkg = pkg_universe_get_local_pkg(universe, pkg_conflict_uniqueid(c), 0);
+
			npkg = pkg_jobs_universe_get_local(universe, pkg_conflict_uniqueid(c), 0);
			if (npkg != NULL) {
				if (pkg_jobs_process_universe_local(universe, npkg, NULL) != EPKG_OK)
					continue;

				if (c->type != PKG_CONFLICT_REMOTE_LOCAL) {
-
					npkg = pkg_universe_get_remote_pkg(universe,
+
					npkg = pkg_jobs_universe_get_remote(universe,
						pkg_conflict_uniqueid(c), 0);
					if (npkg == NULL)
						continue;
@@ -333,7 +333,7 @@ pkg_jobs_universe_process_shlibs(struct pkg_jobs_universe *universe,
				/* Check for local packages */
				HASH_FIND_STR(universe->items, uid, unit);
				if (unit != NULL) {
-
					if (pkg_need_upgrade (rpkg, unit->pkg, false)) {
+
					if (pkg_jobs_need_upgrade (rpkg, unit->pkg, false)) {
						/* Remote provide is newer, so we can add it */
						if (pkg_jobs_process_universe(universe, rpkg,
							&unit) != EPKG_OK)
@@ -344,12 +344,12 @@ pkg_jobs_universe_process_shlibs(struct pkg_jobs_universe *universe,
				}
				else {
					/* Maybe local package has just been not added */
-
					npkg = pkg_universe_get_local_pkg(universe, uid, 0);
+
					npkg = pkg_jobs_universe_get_local(universe, uid, 0);
					if (npkg != NULL) {
						if (pkg_jobs_add_universe_local(universe, npkg,
							&unit) != EPKG_OK)
							return (EPKG_FATAL);
-
						if (pkg_need_upgrade (rpkg, npkg, false)) {
+
						if (pkg_jobs_need_upgrade (rpkg, npkg, false)) {
							/* Remote provide is newer, so we can add it */
							if (pkg_jobs_process_universe(universe, rpkg,
								&unit) != EPKG_OK)
@@ -485,7 +485,7 @@ pkg_jobs_process_universe(struct pkg_jobs_universe *universe, struct pkg *pkg,
}

int
-
pkg_jobs_universe_process_package(struct pkg_jobs_universe *universe,
+
pkg_jobs_universe_process(struct pkg_jobs_universe *universe,
	struct pkg *pkg)
{
	return (pkg_jobs_process_universe(universe, pkg, NULL));
@@ -734,7 +734,7 @@ pkg_jobs_universe_change_uid(struct pkg_jobs_universe *universe,
		while (pkg_rdeps(unit->pkg, &rd) == EPKG_OK) {
			found = pkg_jobs_universe_find(universe, rd->uid);
			if (found == NULL) {
-
				lp = pkg_universe_get_local_pkg(universe, rd->uid, 0);
+
				lp = pkg_jobs_universe_get_local(universe, rd->uid, 0);
				pkg_jobs_process_universe(universe, lp, &found);
			}

modified libpkg/private/pkg_jobs.h
@@ -146,13 +146,13 @@ struct pkg_jobs_universe * pkg_jobs_universe_new(struct pkg_jobs *j);
/*
 * Add a package to the universe
 */
-
int pkg_jobs_universe_process_package(struct pkg_jobs_universe *universe,
+
int pkg_jobs_universe_process(struct pkg_jobs_universe *universe,
	struct pkg *pkg);

/*
 * Add a package to the universe and store resulting item in `result`
 */
-
int pkg_jobs_process_universe(struct pkg_jobs_universe *universe,
+
int pkg_jobs_universe_process_item(struct pkg_jobs_universe *universe,
	struct pkg *pkg, struct pkg_job_universe_item **result);

/*
@@ -189,15 +189,13 @@ void pkg_jobs_universe_change_uid(struct pkg_jobs_universe *universe,
/*
 * Find remote package in db or universe
 */
-
struct pkg *
-
pkg_universe_get_remote_pkg(struct pkg_jobs_universe *universe,
+
struct pkg* pkg_jobs_universe_get_remote(struct pkg_jobs_universe *universe,
	const char *uid, unsigned flag);

/*
 * Find local package in db or universe
 */
-
struct pkg *
-
pkg_universe_get_local_pkg(struct pkg_jobs_universe *universe,
+
struct pkg* pkg_jobs_universe_get_local(struct pkg_jobs_universe *universe,
	const char *uid, unsigned flag);

/*
@@ -222,6 +220,6 @@ void pkg_conflicts_register(struct pkg *p1, struct pkg *p2,
/*
 * Check whether `rp` is an upgrade for `lp`
 */
-
bool pkg_need_upgrade(struct pkg *rp, struct pkg *lp);
+
bool pkg_jobs_need_upgrade(struct pkg *rp, struct pkg *lp);

#endif /* PKG_JOBS_H_ */