summaryrefslogtreecommitdiffstats
path: root/sourcecheck.c
diff options
context:
space:
mode:
Diffstat (limited to 'sourcecheck.c')
-rw-r--r--sourcecheck.c482
1 files changed, 482 insertions, 0 deletions
diff --git a/sourcecheck.c b/sourcecheck.c
new file mode 100644
index 0000000..8182639
--- /dev/null
+++ b/sourcecheck.c
@@ -0,0 +1,482 @@
+/* This file is part of "reprepro"
+ * Copyright (C) 2010,2011,2016 Bernhard R. Link
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License version 2 as
+ * published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02111-1301 USA
+ */
+#include <config.h>
+
+#include <sys/types.h>
+#include <assert.h>
+#include <string.h>
+#include <stdlib.h>
+#include <stdio.h>
+
+#include "error.h"
+#include "distribution.h"
+#include "trackingt.h"
+#include "package.h"
+#include "sourcecheck.h"
+
+/* This is / will be the implementation of the
+ * unusedsources
+ * withoutsource
+ * reportcruft
+ * removecruft (to be implemented)
+ * commands.
+ *
+ * Currently those only work with tracking enabled, but
+ * are in this file as the implementation without tracking
+ * will need similar infrastructure */
+
+
+/* TODO: some tree might be more efficient, check how bad the comparisons are here */
+struct info_source {
+ struct info_source *next;
+ char *name;
+ struct info_source_version {
+ struct info_source_version *next;
+ char *version;
+ bool used;
+ } version;
+};
+
+static void free_source_info(struct info_source *s) {
+ while (s != NULL) {
+ struct info_source *h = s;
+ s = s->next;
+
+ while (h->version.next != NULL) {
+ struct info_source_version *v = h->version.next;
+ h->version.next = v->next;
+ free(v->version);
+ free(v);
+ }
+ free(h->version.version);
+ free(h->name);
+ free(h);
+ }
+}
+
+static retvalue collect_source_versions(struct distribution *d, struct info_source **out) {
+ struct info_source *root = NULL, *last = NULL;
+ struct target *t;
+ struct package_cursor cursor;
+ retvalue result = RET_NOTHING, r;
+
+ for (t = d->targets ; t != NULL ; t = t->next) {
+ if (t->architecture != architecture_source)
+ continue;
+ r = package_openiterator(t, true, true, &cursor);
+ if (RET_WAS_ERROR(r)) {
+ RET_UPDATE(result, r);
+ break;
+ }
+ while (package_next(&cursor)) {
+ struct info_source **into = NULL;
+ struct info_source_version *v;
+
+ r = package_getversion(&cursor.current);
+ if (!RET_IS_OK(r)) {
+ RET_UPDATE(result, r);
+ continue;
+ }
+ if (last != NULL) {
+ int c;
+ c = strcmp(cursor.current.name, last->name);
+ if (c < 0) {
+ /* start at the beginning */
+ last = NULL;
+ } else while (c > 0) {
+ into = &last->next;
+ if (last->next == NULL)
+ break;
+ last = last->next;
+ c = strcmp(cursor.current.name, last->name);
+ if (c == 0) {
+ into = NULL;
+ break;
+ }
+ }
+ }
+ /* if into != NULL, place there,
+ * if last != NULL, already found */
+ if (last == NULL) {
+ into = &root;
+ while ((last = *into) != NULL) {
+ int c;
+ c = strcmp(cursor.current.name, last->name);
+ if (c == 0) {
+ into = NULL;
+ break;
+ }
+ if (c < 0)
+ break;
+ into = &last->next;
+ }
+ }
+ if (into != NULL) {
+ last = zNEW(struct info_source);
+ if (FAILEDTOALLOC(last)) {
+ result = RET_ERROR_OOM;
+ break;
+ }
+ last->name = strdup(cursor.current.name);
+ if (FAILEDTOALLOC(last->name)) {
+ free(last);
+ result = RET_ERROR_OOM;
+ break;
+ }
+ last->version.version = package_dupversion(
+ &cursor.current);
+ if (FAILEDTOALLOC(last->version.version)) {
+ result = RET_ERROR_OOM;
+ free(last->name);
+ free(last);
+ break;
+ }
+ last->next = *into;
+ *into = last;
+ RET_UPDATE(result, RET_OK);
+ continue;
+ }
+ assert (last != NULL);
+ assert (strcmp(cursor.current.name, last->name)==0);
+
+ v = &last->version;
+ while (strcmp(v->version, cursor.current.version) != 0) {
+ if (v->next == NULL) {
+ v->next = zNEW(struct info_source_version);
+ if (FAILEDTOALLOC(v->next)) {
+ result = RET_ERROR_OOM;
+ break;
+ }
+ v = v->next;
+ v->version = package_dupversion(
+ &cursor.current);
+ if (FAILEDTOALLOC(v->version)) {
+ result = RET_ERROR_OOM;
+ break;
+ }
+ RET_UPDATE(result, RET_OK);
+ break;
+ }
+ v = v->next;
+ }
+ }
+ r = package_closeiterator(&cursor);
+ if (RET_WAS_ERROR(r)) {
+ RET_UPDATE(result, r);
+ break;
+ }
+ }
+ if (RET_IS_OK(result))
+ *out = root;
+ else {
+ assert (result != RET_NOTHING || root == NULL);
+ free_source_info(root);
+ }
+ return result;
+}
+
+static retvalue process_binaries(struct distribution *d, struct info_source *sources, retvalue (*action)(struct package *, void *), void *privdata) {
+ struct target *t;
+ struct package_cursor cursor;
+ retvalue result = RET_NOTHING, r;
+
+ for (t = d->targets ; t != NULL ; t = t->next) {
+ if (t->architecture == architecture_source)
+ continue;
+ r = package_openiterator(t, true, true, &cursor);
+ if (RET_WAS_ERROR(r)) {
+ RET_UPDATE(result, r);
+ break;
+ }
+ while (package_next(&cursor)) {
+ struct info_source *s;
+ struct info_source_version *v;
+
+ r = package_getsource(&cursor.current);
+ if (!RET_IS_OK(r)) {
+ RET_UPDATE(result, r);
+ continue;
+ }
+ const char *source = cursor.current.source;
+ const char *version = cursor.current.sourceversion;
+
+ s = sources;
+ while (s != NULL && strcmp(s->name, source) < 0) {
+ s = s->next;
+ }
+ if (s != NULL && strcmp(source, s->name) == 0) {
+ v = &s->version;
+ while (v != NULL && strcmp(version, v->version) != 0)
+ v = v->next;
+ } else
+ v = NULL;
+ if (v != NULL) {
+ v->used = true;
+ } else if (action != NULL) {
+ r = action(&cursor.current, privdata);
+ RET_UPDATE(result, r);
+ }
+ }
+ r = package_closeiterator(&cursor);
+ if (RET_WAS_ERROR(r)) {
+ RET_UPDATE(result, r);
+ break;
+ }
+ }
+ return result;
+}
+
+static retvalue listunusedsources(struct distribution *d, const struct trackedpackage *pkg) {
+ bool hasbinary = false, hassource = false;
+ int i;
+
+ for (i = 0 ; i < pkg->filekeys.count ; i++) {
+ if (pkg->refcounts[i] == 0)
+ continue;
+ if (pkg->filetypes[i] == 's')
+ hassource = true;
+ if (pkg->filetypes[i] == 'b')
+ hasbinary = true;
+ if (pkg->filetypes[i] == 'a')
+ hasbinary = true;
+ }
+ if (hassource && ! hasbinary) {
+ printf("%s %s %s\n", d->codename, pkg->sourcename,
+ pkg->sourceversion);
+ return RET_OK;
+ }
+ return RET_NOTHING;
+}
+
+retvalue unusedsources(struct distribution *alldistributions) {
+ struct distribution *d;
+ retvalue result = RET_NOTHING, r;
+
+ for (d = alldistributions ; d != NULL ; d = d->next) {
+ if (!d->selected)
+ continue;
+ if (!atomlist_in(&d->architectures, architecture_source))
+ continue;
+ if (d->tracking != dt_NONE) {
+ r = tracking_foreach_ro(d, listunusedsources);
+ RET_UPDATE(result, r);
+ if (RET_WAS_ERROR(r))
+ return r;
+ continue;
+ }
+ struct info_source *sources = NULL;
+ const struct info_source *s;
+ const struct info_source_version *v;
+
+ r = collect_source_versions(d, &sources);
+ if (!RET_IS_OK(r))
+ continue;
+
+ r = process_binaries(d, sources, NULL, NULL);
+ RET_UPDATE(result, r);
+ for (s = sources ; s != NULL ; s = s->next) {
+ for (v = &s->version ; v != NULL ; v = v->next) {
+ if (v->used)
+ continue;
+ printf("%s %s %s\n", d->codename,
+ s->name, v->version);
+ }
+ }
+ free_source_info(sources);
+ }
+ return result;
+}
+
+static retvalue listsourcemissing(struct distribution *d, const struct trackedpackage *pkg) {
+ bool hasbinary = false, hassource = false;
+ int i;
+
+ for (i = 0 ; i < pkg->filekeys.count ; i++) {
+ if (pkg->refcounts[i] == 0)
+ continue;
+ if (pkg->filetypes[i] == 's')
+ hassource = true;
+ if (pkg->filetypes[i] == 'b')
+ hasbinary = true;
+ if (pkg->filetypes[i] == 'a')
+ hasbinary = true;
+ }
+ if (hasbinary && ! hassource) {
+ for (i = 0 ; i < pkg->filekeys.count ; i++) {
+ if (pkg->refcounts[i] == 0)
+ continue;
+ if (pkg->filetypes[i] != 'b' && pkg->filetypes[i] != 'a')
+ continue;
+ printf("%s %s %s %s\n", d->codename, pkg->sourcename,
+ pkg->sourceversion,
+ pkg->filekeys.values[i]);
+ }
+ return RET_OK;
+ }
+ return RET_NOTHING;
+}
+
+static retvalue listmissing(struct package *package, UNUSED(void*data)) {
+ retvalue r;
+ struct strlist list;
+
+ r = package->target->getfilekeys(package->control, &list);
+ if (!RET_IS_OK(r))
+ return r;
+ assert (list.count == 1);
+ printf("%s %s %s %s\n", package->target->distribution->codename,
+ package->source, package->sourceversion, list.values[0]);
+ strlist_done(&list);
+ return RET_OK;
+}
+
+retvalue sourcemissing(struct distribution *alldistributions) {
+ struct distribution *d;
+ retvalue result = RET_NOTHING, r;
+
+ for (d = alldistributions ; d != NULL ; d = d->next) {
+ if (!d->selected)
+ continue;
+ if (!atomlist_in(&d->architectures, architecture_source)) {
+ if (verbose >= 0)
+ fprintf(stderr,
+"Not processing distribution '%s', as it has no source packages.\n",
+ d->codename);
+ continue;
+ }
+ if (d->tracking != dt_NONE) {
+ r = tracking_foreach_ro(d, listsourcemissing);
+ RET_UPDATE(result, r);
+ if (RET_WAS_ERROR(r))
+ return r;
+ } else {
+ struct info_source *sources = NULL;
+
+ r = collect_source_versions(d, &sources);
+ if (!RET_IS_OK(r))
+ continue;
+
+ r = process_binaries(d, sources, listmissing, NULL);
+ RET_UPDATE(result, r);
+ free_source_info(sources);
+ }
+
+ }
+ return result;
+}
+
+static retvalue listcruft(struct distribution *d, const struct trackedpackage *pkg) {
+ bool hasbinary = false, hassource = false;
+ int i;
+
+ for (i = 0 ; i < pkg->filekeys.count ; i++) {
+ if (pkg->refcounts[i] == 0)
+ continue;
+ if (pkg->filetypes[i] == 's')
+ hassource = true;
+ if (pkg->filetypes[i] == 'b')
+ hasbinary = true;
+ if (pkg->filetypes[i] == 'a')
+ hasbinary = true;
+ }
+ if (hasbinary && ! hassource) {
+ printf("binaries-without-source %s %s %s\n", d->codename,
+ pkg->sourcename, pkg->sourceversion);
+ return RET_OK;
+ } else if (hassource && ! hasbinary) {
+ printf("source-without-binaries %s %s %s\n", d->codename,
+ pkg->sourcename, pkg->sourceversion);
+ return RET_OK;
+ }
+ return RET_NOTHING;
+}
+
+static retvalue listmissingonce(struct package *package, void *data) {
+ struct info_source **already = data;
+ struct info_source *s;
+
+ for (s = *already ; s != NULL ; s = s->next) {
+ if (strcmp(s->name, package->source) != 0)
+ continue;
+ if (strcmp(s->version.version, package->sourceversion) != 0)
+ continue;
+ return RET_NOTHING;
+ }
+ s = zNEW(struct info_source);
+ if (FAILEDTOALLOC(s))
+ return RET_ERROR_OOM;
+ s->name = strdup(package->source);
+ s->version.version = strdup(package->sourceversion);
+ if (FAILEDTOALLOC(s->name) || FAILEDTOALLOC(s->version.version)) {
+ free(s->name);
+ free(s->version.version);
+ free(s);
+ return RET_ERROR_OOM;
+ }
+ s->next = *already;
+ *already = s;
+ printf("binaries-without-source %s %s %s\n",
+ package->target->distribution->codename,
+ package->source, package->sourceversion);
+ return RET_OK;
+}
+
+retvalue reportcruft(struct distribution *alldistributions) {
+ struct distribution *d;
+ retvalue result = RET_NOTHING, r;
+
+ for (d = alldistributions ; d != NULL ; d = d->next) {
+ if (!d->selected)
+ continue;
+ if (!atomlist_in(&d->architectures, architecture_source)) {
+ if (verbose >= 0)
+ fprintf(stderr,
+"Not processing distribution '%s', as it has no source packages.\n",
+ d->codename);
+ continue;
+ }
+ if (d->tracking != dt_NONE) {
+ r = tracking_foreach_ro(d, listcruft);
+ RET_UPDATE(result, r);
+ if (RET_WAS_ERROR(r))
+ return r;
+ continue;
+ }
+ struct info_source *sources = NULL;
+ struct info_source *list = NULL;
+ const struct info_source *s;
+ const struct info_source_version *v;
+
+ r = collect_source_versions( d, &sources);
+ if (!RET_IS_OK(r))
+ continue;
+
+ r = process_binaries( d, sources,
+ listmissingonce, &list);
+ RET_UPDATE(result, r);
+ for (s = sources ; s != NULL ; s = s->next) {
+ for (v = &s->version ; v != NULL ; v = v->next) {
+ if (v->used)
+ continue;
+ printf("source-without-binaries %s %s %s\n",
+ d->codename, s->name, v->version);
+ }
+ }
+ free_source_info(list);
+ free_source_info(sources);
+ }
+ return result;
+}
generated by cgit v1.2.3 (git 2.39.1) at 2024-05-05 05:05:29 +0000