Merger razor_transaction_run() and destroy() as finish().
18 #include "razor-internal.h"
21 struct razor_set_section {
27 struct razor_set_header {
30 struct razor_set_section sections[0];
33 #define RAZOR_MAGIC 0x7a7a7a7a
34 #define RAZOR_VERSION 1
36 #define RAZOR_STRING_POOL 0
37 #define RAZOR_PACKAGES 1
38 #define RAZOR_PROPERTIES 2
40 #define RAZOR_PACKAGE_POOL 4
41 #define RAZOR_PROPERTY_POOL 5
42 #define RAZOR_FILE_POOL 6
44 struct razor_package {
49 struct list_head properties;
50 struct list_head files;
53 struct razor_property {
56 enum razor_property_type type : 2;
57 enum razor_version_relation relation : 32;
59 struct list_head packages;
66 struct list_head packages;
69 #define RAZOR_ENTRY_LAST 0x80
72 struct array string_pool;
73 struct array packages;
74 struct array properties;
76 struct array package_pool;
77 struct array property_pool;
78 struct array file_pool;
79 struct razor_set_header *header;
87 struct import_directory {
90 struct array packages;
91 struct import_directory *last;
94 struct razor_importer {
95 struct razor_set *set;
96 struct hashtable table;
97 struct razor_package *package;
98 struct array properties;
100 struct array file_requires;
114 struct razor_set_section razor_sections[] = {
115 { RAZOR_STRING_POOL, offsetof(struct razor_set, string_pool) },
116 { RAZOR_PACKAGES, offsetof(struct razor_set, packages) },
117 { RAZOR_PROPERTIES, offsetof(struct razor_set, properties) },
118 { RAZOR_FILES, offsetof(struct razor_set, files) },
119 { RAZOR_PACKAGE_POOL, offsetof(struct razor_set, package_pool) },
120 { RAZOR_PROPERTY_POOL, offsetof(struct razor_set, property_pool) },
121 { RAZOR_FILE_POOL, offsetof(struct razor_set, file_pool) },
125 razor_set_create(void)
127 struct razor_set *set;
128 struct razor_entry *e;
131 set = zalloc(sizeof *set);
133 e = array_add(&set->files, sizeof *e);
134 empty = array_add(&set->string_pool, 1);
137 e->flags = RAZOR_ENTRY_LAST;
139 list_set_empty(&e->packages);
145 razor_set_open(const char *filename)
147 struct razor_set *set;
148 struct razor_set_section *s;
153 set = zalloc(sizeof *set);
154 fd = open(filename, O_RDONLY);
155 if (fstat(fd, &stat) < 0)
157 set->header = mmap(NULL, stat.st_size, PROT_READ, MAP_PRIVATE, fd, 0);
158 if (set->header == MAP_FAILED) {
163 for (s = set->header->sections; ~s->type; s++) {
164 if (s->type >= ARRAY_SIZE(razor_sections))
166 if (s->type != razor_sections[s->type].type)
168 array = (void *) set + razor_sections[s->type].offset;
169 array->data = (void *) set->header + s->offset;
170 array->size = s->size;
171 array->alloc = s->size;
179 razor_set_destroy(struct razor_set *set)
186 for (i = 0; set->header->sections[i].type; i++)
188 size = set->header->sections[i].type;
189 munmap(set->header, size);
191 for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
192 a = (void *) set + razor_sections[i].offset;
201 razor_set_write(struct razor_set *set, const char *filename)
204 struct razor_set_header *header = (struct razor_set_header *) data;
209 memset(data, 0, sizeof data);
210 header->magic = RAZOR_MAGIC;
211 header->version = RAZOR_VERSION;
212 offset = sizeof data;
214 for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
215 if (razor_sections[i].type != i)
217 a = (void *) set + razor_sections[i].offset;
218 header->sections[i].type = i;
219 header->sections[i].offset = offset;
220 header->sections[i].size = a->size;
221 offset += ALIGN(a->size, 4096);
224 header->sections[i].type = ~0;
225 header->sections[i].offset = 0;
226 header->sections[i].size = 0;
228 fd = open(filename, O_CREAT | O_WRONLY | O_TRUNC, 0666);
232 razor_write(fd, data, sizeof data);
233 memset(data, 0, sizeof data);
234 for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
235 if (razor_sections[i].type != i)
237 a = (void *) set + razor_sections[i].offset;
238 razor_write(fd, a->data, a->size);
239 razor_write(fd, data, ALIGN(a->size, 4096) - a->size);
248 razor_build_evr(char *evr_buf, int size, const char *epoch,
249 const char *version, const char *release)
253 if (!version || !*version) {
258 if (epoch && *epoch && strcmp(epoch, "0") != 0) {
259 len = snprintf(evr_buf, size, "%s:", epoch);
263 len = snprintf(evr_buf, size, "%s", version);
266 if (release && *release)
267 snprintf(evr_buf, size, "-%s", release);
271 razor_importer_begin_package(struct razor_importer *importer,
276 struct razor_package *p;
278 p = array_add(&importer->set->packages, sizeof *p);
279 p->name = hashtable_tokenize(&importer->table, name);
281 p->version = hashtable_tokenize(&importer->table, version);
282 p->arch = hashtable_tokenize(&importer->table, arch);
284 importer->package = p;
285 array_init(&importer->properties);
289 razor_importer_finish_package(struct razor_importer *importer)
291 list_set_array(&importer->package->properties,
292 &importer->set->property_pool,
293 &importer->properties,
296 array_release(&importer->properties);
300 razor_importer_add_property(struct razor_importer *importer,
302 enum razor_version_relation relation,
304 enum razor_property_type type)
306 struct razor_property *p;
309 p = array_add(&importer->set->properties, sizeof *p);
310 p->name = hashtable_tokenize(&importer->table, name);
313 p->relation = relation;
314 p->version = hashtable_tokenize(&importer->table, version);
315 list_set_ptr(&p->packages, importer->package -
316 (struct razor_package *) importer->set->packages.data);
318 r = array_add(&importer->properties, sizeof *r);
319 *r = p - (struct razor_property *) importer->set->properties.data;
321 if (type == RAZOR_PROPERTY_REQUIRES && *name == '/') {
322 r = array_add(&importer->file_requires, sizeof *r);
328 razor_importer_add_file(struct razor_importer *importer, const char *name)
330 struct import_entry *e;
332 e = array_add(&importer->files, sizeof *e);
334 e->package = importer->package -
335 (struct razor_package *) importer->set->packages.data;
336 e->name = strdup(name);
339 struct razor_importer *
340 razor_importer_new(void)
342 struct razor_importer *importer;
344 importer = zalloc(sizeof *importer);
345 importer->set = razor_set_create();
346 hashtable_init(&importer->table, &importer->set->string_pool);
351 /* Destroy an importer without creating the set. */
353 razor_importer_destroy(struct razor_importer *importer)
355 /* FIXME: write this */
359 versioncmp(const char *s1, const char *s2)
365 n1 = strtol(s1, (char **) &p1, 10);
366 n2 = strtol(s2, (char **) &p2, 10);
368 /* Epoch; if one but not the other has an epoch set, default
369 * the epoch-less version to 0. */
370 res = (*p1 == ':') - (*p2 == ':');
375 } else if (res > 0) {
388 if (isdigit(*p1) && isdigit(*p2))
389 return versioncmp(p1, p2);
396 compare_packages(const void *p1, const void *p2, void *data)
398 const struct razor_package *pkg1 = p1, *pkg2 = p2;
399 struct razor_set *set = data;
400 char *pool = set->string_pool.data;
402 /* FIXME: what if the flags are different? */
403 if (pkg1->name == pkg2->name)
404 return versioncmp(&pool[pkg1->version], &pool[pkg2->version]);
406 return strcmp(&pool[pkg1->name], &pool[pkg2->name]);
410 compare_properties(const void *p1, const void *p2, void *data)
412 const struct razor_property *prop1 = p1, *prop2 = p2;
413 struct razor_set *set = data;
414 char *pool = set->string_pool.data;
416 if (prop1->name != prop2->name)
417 return strcmp(&pool[prop1->name], &pool[prop2->name]);
418 else if (prop1->type != prop2->type)
419 return prop1->type - prop2->type;
420 else if (prop1->relation != prop2->relation)
421 return prop1->relation - prop2->relation;
423 return versioncmp(&pool[prop1->version], &pool[prop2->version]);
427 uniqueify_properties(struct razor_set *set)
429 struct razor_property *rp, *up, *rp_end;
430 struct array *pkgs, *p;
432 uint32_t *map, *rmap;
433 int i, count, unique;
435 count = set->properties.size / sizeof(struct razor_property);
436 map = razor_qsort_with_data(set->properties.data,
438 sizeof(struct razor_property),
442 rp_end = set->properties.data + set->properties.size;
443 rmap = malloc(count * sizeof *map);
444 pkgs = zalloc(count * sizeof *pkgs);
445 for (rp = set->properties.data, up = rp, i = 0; rp < rp_end; rp++, i++) {
446 if (rp->name != up->name || rp->type != up->type ||
447 rp->relation != up->relation || rp->version != up->version) {
452 up->relation = rp->relation;
453 up->version = rp->version;
456 unique = up - (struct razor_property *) set->properties.data;
457 rmap[map[i]] = unique;
458 r = array_add(&pkgs[unique], sizeof *r);
465 set->properties.size = (void *) up - set->properties.data;
467 for (rp = set->properties.data, p = pkgs; rp < rp_end; rp++, p++) {
468 list_set_array(&rp->packages, &set->package_pool, p, 0);
478 compare_filenames(const void *p1, const void *p2, void *data)
480 const struct import_entry *e1 = p1;
481 const struct import_entry *e2 = p2;
482 const char *n1 = e1->name;
483 const char *n2 = e2->name;
485 /* Need to make sure that the contents of a directory
486 * are sorted immediately after it. So "foo/bar" has to
487 * sort before "foo.conf"
489 * FIXME: this is about 60% slower than strcmp
493 return *n2 == '/' ? 1 : -1;
495 return *n1 == '/' ? -1 : 1;
508 count_entries(struct import_directory *d)
510 struct import_directory *p, *end;
513 end = d->files.data + d->files.size;
517 d->count += p->count + 1;
523 serialize_files(struct razor_set *set,
524 struct import_directory *d, struct array *array)
526 struct import_directory *p, *end;
527 struct razor_entry *e = NULL;
531 end = d->files.data + d->files.size;
532 s = array->size / sizeof *e + d->files.size / sizeof *p;
534 e = array_add(array, sizeof *e);
537 e->start = p->count > 0 ? s : 0;
540 list_set_array(&e->packages, &set->package_pool, &p->packages, 0);
541 array_release(&p->packages);
545 e->flags |= RAZOR_ENTRY_LAST;
548 end = d->files.data + d->files.size;
550 serialize_files(set, p, array);
556 remap_property_package_links(struct array *properties, uint32_t *rmap)
558 struct razor_property *p, *end;
560 end = properties->data + properties->size;
561 for (p = properties->data; p < end; p++)
562 list_remap_head(&p->packages, rmap);
566 build_file_tree(struct razor_importer *importer)
568 int count, i, length;
569 struct import_entry *filenames;
573 struct import_directory *d, root;
574 struct razor_entry *e;
576 count = importer->files.size / sizeof (struct import_entry);
577 razor_qsort_with_data(importer->files.data,
579 sizeof (struct import_entry),
583 root.name = hashtable_tokenize(&importer->table, "");
584 array_init(&root.files);
585 array_init(&root.packages);
588 filenames = importer->files.data;
589 for (i = 0; i < count; i++) {
590 f = filenames[i].name;
597 end = strchr(f, '/');
601 memcpy(dirname, f, length);
602 dirname[length] ='\0';
603 name = hashtable_tokenize(&importer->table, dirname);
604 if (d->last == NULL || d->last->name != name) {
605 d->last = array_add(&d->files, sizeof *d);
606 d->last->name = name;
607 d->last->last = NULL;
608 array_init(&d->last->files);
609 array_init(&d->last->packages);
617 r = array_add(&d->packages, sizeof *r);
618 *r = filenames[i].package;
619 free(filenames[i].name);
622 count_entries(&root);
623 e = importer->set->files.data;
625 e->flags = RAZOR_ENTRY_LAST;
626 e->start = importer->files.size ? 1 : 0;
627 list_set_empty(&e->packages);
629 serialize_files(importer->set, &root, &importer->set->files);
631 array_release(&importer->files);
634 static struct razor_entry *
635 find_entry(struct razor_set *set, struct razor_entry *dir, const char *pattern);
638 list_to_array(struct list *list, struct array *array)
643 item = array_add(array, sizeof *item);
645 list = list_next(list);
650 compare_file_requires(const void *p1, const void *p2, void *data)
652 uint32_t *f1 = (void *)p1, *f2 = (void *)p2;
653 const char *pool = data;
655 return strcmp(&pool[*f1], &pool[*f2]);
659 find_file_provides(struct razor_importer *importer)
661 struct razor_property *prop;
662 struct razor_entry *top, *entry;
663 struct razor_package *packages;
664 struct array pkgprops;
666 uint32_t *req, *req_start, *req_end;
667 uint32_t *map, *newprop;
670 pool = importer->set->string_pool.data;
671 packages = importer->set->packages.data;
672 top = importer->set->files.data;
674 req = req_start = importer->file_requires.data;
675 req_end = importer->file_requires.data + importer->file_requires.size;
676 map = razor_qsort_with_data(req, req_end - req, sizeof *req,
677 compare_file_requires, pool);
680 for (req = req_start; req < req_end; req++) {
681 if (req > req_start && req[0] == req[-1])
683 entry = find_entry(importer->set, top, &pool[*req]);
687 for (pkg = list_first(&entry->packages, &importer->set->package_pool); pkg; pkg = list_next(pkg)) {
688 prop = array_add(&importer->set->properties, sizeof *prop);
690 prop->type = RAZOR_PROPERTY_PROVIDES;
691 prop->relation = RAZOR_VERSION_EQUAL;
692 prop->version = hashtable_tokenize(&importer->table, "");
693 list_set_ptr(&prop->packages, pkg->data);
695 /* Update property list of pkg */
696 array_init(&pkgprops);
697 list_to_array(list_first(&packages[pkg->data].properties, &importer->set->property_pool), &pkgprops);
698 newprop = array_add(&pkgprops, sizeof *newprop);
699 *newprop = prop - (struct razor_property *)importer->set->properties.data;
700 list_set_array(&packages[pkg->data].properties, &importer->set->property_pool, &pkgprops, 1);
701 array_release(&pkgprops);
705 array_release(&importer->file_requires);
709 build_package_file_lists(struct razor_set *set, uint32_t *rmap)
711 struct razor_package *p, *packages;
713 struct razor_entry *e, *end;
718 count = set->packages.size / sizeof *p;
719 pkgs = zalloc(count * sizeof *pkgs);
721 end = set->files.data + set->files.size;
722 for (e = set->files.data; e < end; e++) {
723 list_remap_head(&e->packages, rmap);
724 r = list_first(&e->packages, &set->package_pool);
726 q = array_add(&pkgs[r->data], sizeof *q);
727 *q = e - (struct razor_entry *) set->files.data;
732 packages = set->packages.data;
733 for (i = 0; i < count; i++) {
734 list_set_array(&packages[i].files, &set->file_pool, &pkgs[i], 0);
735 array_release(&pkgs[i]);
741 razor_importer_finish(struct razor_importer *importer)
743 struct razor_set *set;
744 uint32_t *map, *rmap;
747 build_file_tree(importer);
748 find_file_provides(importer);
750 map = uniqueify_properties(importer->set);
751 list_remap_pool(&importer->set->property_pool, map);
754 count = importer->set->packages.size / sizeof(struct razor_package);
755 map = razor_qsort_with_data(importer->set->packages.data,
757 sizeof(struct razor_package),
761 rmap = malloc(count * sizeof *rmap);
762 for (i = 0; i < count; i++)
766 list_remap_pool(&importer->set->package_pool, rmap);
767 build_package_file_lists(importer->set, rmap);
768 remap_property_package_links(&importer->set->properties, rmap);
772 hashtable_release(&importer->table);
778 struct razor_package_iterator {
779 struct razor_set *set;
780 struct razor_package *package, *end;
784 static struct razor_package_iterator *
785 razor_package_iterator_create_with_index(struct razor_set *set,
788 struct razor_package_iterator *pi;
790 pi = zalloc(sizeof *pi);
797 struct razor_package_iterator *
798 razor_package_iterator_create(struct razor_set *set)
800 struct razor_package_iterator *pi;
802 pi = zalloc(sizeof *pi);
804 pi->end = set->packages.data + set->packages.size;
805 pi->package = set->packages.data;
810 struct razor_package_iterator *
811 razor_package_iterator_create_for_property(struct razor_set *set,
812 struct razor_property *property)
816 index = list_first(&property->packages, &set->package_pool);
817 return razor_package_iterator_create_with_index(set, index);
821 razor_package_iterator_next(struct razor_package_iterator *pi,
822 struct razor_package **package,
824 const char **version,
829 struct razor_package *p, *packages;
834 } else if (pi->index) {
835 packages = pi->set->packages.data;
836 p = &packages[pi->index->data];
837 pi->index = list_next(pi->index);
843 pool = pi->set->string_pool.data;
845 *name = &pool[p->name];
846 *version = &pool[p->version];
847 *arch = &pool[p->arch];
856 razor_package_iterator_destroy(struct razor_package_iterator *pi)
861 struct razor_package *
862 razor_set_get_package(struct razor_set *set, const char *package)
864 struct razor_package_iterator *pi;
865 struct razor_package *p;
866 const char *name, *version, *arch;
868 pi = razor_package_iterator_create(set);
869 while (razor_package_iterator_next(pi, &p, &name, &version, &arch)) {
870 if (strcmp(package, name) == 0)
873 razor_package_iterator_destroy(pi);
878 struct razor_property_iterator {
879 struct razor_set *set;
880 struct razor_property *property, *end;
884 struct razor_property_iterator *
885 razor_property_iterator_create(struct razor_set *set,
886 struct razor_package *package)
888 struct razor_property_iterator *pi;
890 pi = zalloc(sizeof *pi);
894 pi->index = list_first(&package->properties,
895 &set->property_pool);
897 pi->property = set->properties.data;
898 pi->end = set->properties.data + set->properties.size;
905 razor_property_iterator_next(struct razor_property_iterator *pi,
906 struct razor_property **property,
908 enum razor_version_relation *relation,
909 const char **version,
910 enum razor_property_type *type)
914 struct razor_property *p, *properties;
919 } else if (pi->index) {
920 properties = pi->set->properties.data;
921 p = &properties[pi->index->data];
922 pi->index = list_next(pi->index);
928 pool = pi->set->string_pool.data;
930 *name = &pool[p->name];
931 *relation = p->relation;
932 *version = &pool[p->version];
942 razor_property_iterator_destroy(struct razor_property_iterator *pi)
947 static struct razor_entry *
948 find_entry(struct razor_set *set, struct razor_entry *dir, const char *pattern)
950 struct razor_entry *e;
951 const char *n, *pool = set->string_pool.data;
954 e = (struct razor_entry *) set->files.data + dir->start;
957 if (strcmp(pattern + 1, n) == 0)
960 if (e->start != 0 && strncmp(pattern + 1, n, len) == 0 &&
961 pattern[len + 1] == '/') {
962 return find_entry(set, e, pattern + len + 1);
964 } while (!((e++)->flags & RAZOR_ENTRY_LAST));
970 list_dir(struct razor_set *set, struct razor_entry *dir,
971 char *prefix, const char *pattern)
973 struct razor_entry *e;
974 const char *n, *pool = set->string_pool.data;
976 e = (struct razor_entry *) set->files.data + dir->start;
979 if (pattern && pattern[0] && fnmatch(pattern, n, 0) != 0)
981 printf("%s/%s\n", prefix, n);
983 char *sub = prefix + strlen (prefix);
986 list_dir(set, e, prefix, pattern);
989 } while (!((e++)->flags & RAZOR_ENTRY_LAST));
993 razor_set_list_files(struct razor_set *set, const char *pattern)
995 struct razor_entry *e;
996 char buffer[512], *p, *base;
998 if (pattern == NULL || !strcmp (pattern, "/")) {
1000 list_dir(set, set->files.data, buffer, NULL);
1004 strcpy(buffer, pattern);
1005 e = find_entry(set, set->files.data, buffer);
1006 if (e && e->start > 0) {
1009 p = strrchr(buffer, '/');
1017 e = find_entry(set, set->files.data, buffer);
1019 list_dir(set, e, buffer, base);
1022 struct razor_package_iterator *
1023 razor_package_iterator_create_for_file(struct razor_set *set,
1024 const char *filename)
1026 struct razor_entry *entry;
1029 entry = find_entry(set, set->files.data, filename);
1033 index = list_first(&entry->packages, &set->package_pool);
1034 return razor_package_iterator_create_with_index(set, index);
1037 static struct list *
1038 list_package_files(struct razor_set *set, struct list *r,
1039 struct razor_entry *dir, uint32_t end,
1042 struct razor_entry *e, *f, *entries;
1043 uint32_t next, file;
1047 entries = (struct razor_entry *) set->files.data;
1048 pool = set->string_pool.data;
1050 e = entries + dir->start;
1052 if (entries + r->data == e) {
1053 printf("%s/%s\n", prefix, pool + e->name);
1060 } while (!((e++)->flags & RAZOR_ENTRY_LAST));
1062 e = entries + dir->start;
1067 if (e->flags & RAZOR_ENTRY_LAST)
1071 while (f->start == 0 && !(f->flags & RAZOR_ENTRY_LAST))
1080 if (e->start <= file && file < next) {
1081 len = strlen(prefix);
1083 strcpy(prefix + len + 1, pool + e->name);
1084 r = list_package_files(set, r, e, next, prefix);
1087 } while (!((e++)->flags & RAZOR_ENTRY_LAST) && r != NULL);
1093 razor_set_list_package_files(struct razor_set *set, const char *name)
1095 struct razor_package *package;
1100 package = razor_set_get_package(set, name);
1102 r = list_first(&package->files, &set->file_pool);
1103 end = set->files.size / sizeof (struct razor_entry);
1105 list_package_files(set, r, set->files.data, end, buffer);
1109 razor_set_validate(struct razor_set *set, struct array *unsatisfied)
1111 struct razor_property *r, *p, *end;
1115 end = set->properties.data + set->properties.size;
1116 pool = set->string_pool.data;
1118 for (r = set->properties.data, p = r; r < end; r++) {
1119 if (r->type != RAZOR_PROPERTY_REQUIRES)
1123 while (p < end && p->name == r->name &&
1127 /* If there is more than one version of a provides,
1128 * seek to the end for the highest version. */
1129 /* FIXME: This doesn't work if we have a series of
1130 * requires a = 1, provides a = 1, requires a = 2,
1131 * provides a = 2, as the kernel and kernel-devel
1133 while (p + 1 < end && p->name == (p + 1)->name &&
1134 p->type == (p + 1)->type)
1137 /* FIXME: We need to track property flags (<, <=, =
1138 * etc) to properly determine if a requires is
1139 * satisfied. The current code doesn't track that the
1140 * requires a = 1 isn't satisfied by a = 2 provides. */
1143 p->type != RAZOR_PROPERTY_PROVIDES ||
1144 r->name != p->name ||
1145 versioncmp(&pool[r->version], &pool[p->version]) > 0) {
1146 /* FIXME: We ignore file requires for now. */
1147 if (pool[r->name] == '/')
1149 u = array_add(unsatisfied, sizeof *u);
1150 *u = r - (struct razor_property *) set->properties.data;
1156 razor_set_list_unsatisfied(struct razor_set *set)
1158 struct array unsatisfied;
1159 struct razor_property *properties, *r;
1163 array_init(&unsatisfied);
1164 razor_set_validate(set, &unsatisfied);
1166 end = unsatisfied.data + unsatisfied.size;
1167 properties = set->properties.data;
1168 pool = set->string_pool.data;
1170 for (u = unsatisfied.data; u < end; u++) {
1171 r = properties + *u;
1172 if (pool[r->version] == '\0')
1173 printf("%ss not satisfied\n",
1176 printf("%s-%s not satisfied\n",
1181 array_release(&unsatisfied);
1184 #define UPSTREAM_SOURCE 0x80
1187 struct razor_set *set;
1188 uint32_t *property_map;
1192 struct razor_merger {
1193 struct razor_set *set;
1194 struct hashtable table;
1195 struct source source1;
1196 struct source source2;
1199 static struct razor_merger *
1200 razor_merger_create(struct razor_set *set1, struct razor_set *set2)
1202 struct razor_merger *merger;
1206 merger = zalloc(sizeof *merger);
1207 merger->set = razor_set_create();
1208 hashtable_init(&merger->table, &merger->set->string_pool);
1210 merger->source1.set = set1;
1211 count = set1->properties.size / sizeof (struct razor_property);
1212 size = count * sizeof merger->source1.property_map[0];
1213 merger->source1.property_map = zalloc(size);
1214 count = set1->files.size / sizeof (struct razor_entry);
1215 size = count * sizeof merger->source1.file_map[0];
1216 merger->source1.file_map = zalloc(size);
1218 merger->source2.set = set2;
1219 count = set2->properties.size / sizeof (struct razor_property);
1220 size = count * sizeof merger->source2.property_map[0];
1221 merger->source2.property_map = zalloc(size);
1222 count = set2->files.size / sizeof (struct razor_entry);
1223 size = count * sizeof merger->source2.file_map[0];
1224 merger->source2.file_map = zalloc(size);
1230 add_package(struct razor_merger *merger,
1231 struct razor_package *package, struct source *source,
1236 struct razor_package *p;
1238 pool = source->set->string_pool.data;
1239 p = array_add(&merger->set->packages, sizeof *p);
1240 p->name = hashtable_tokenize(&merger->table, &pool[package->name]);
1242 p->version = hashtable_tokenize(&merger->table,
1243 &pool[package->version]);
1244 p->arch = hashtable_tokenize(&merger->table,
1245 &pool[package->arch]);
1247 p->properties = package->properties;
1248 r = list_first(&package->properties, &source->set->property_pool);
1250 source->property_map[r->data] = 1;
1254 p->files = package->files;
1255 r = list_first(&package->files, &source->set->file_pool);
1257 source->file_map[r->data] = 1;
1263 add_property(struct razor_merger *merger,
1264 const char *name, enum razor_version_relation relation,
1265 const char *version, int type)
1267 struct razor_property *p;
1269 p = array_add(&merger->set->properties, sizeof *p);
1270 p->name = hashtable_tokenize(&merger->table, name);
1273 p->relation = relation;
1274 p->version = hashtable_tokenize(&merger->table, version);
1276 return p - (struct razor_property *) merger->set->properties.data;
1280 merge_properties(struct razor_merger *merger)
1282 struct razor_property *p1, *p2;
1283 struct razor_set *set1, *set2;
1284 uint32_t *map1, *map2;
1285 int i, j, cmp, count1, count2;
1286 char *pool1, *pool2;
1288 set1 = merger->source1.set;
1289 set2 = merger->source2.set;
1290 map1 = merger->source1.property_map;
1291 map2 = merger->source2.property_map;
1295 pool1 = set1->string_pool.data;
1296 pool2 = set2->string_pool.data;
1298 count1 = set1->properties.size / sizeof *p1;
1299 count2 = set2->properties.size / sizeof *p2;
1300 while (i < count1 || j < count2) {
1301 if (i < count1 && map1[i] == 0) {
1305 if (j < count2 && map2[j] == 0) {
1309 p1 = (struct razor_property *) set1->properties.data + i;
1310 p2 = (struct razor_property *) set2->properties.data + j;
1311 if (i < count1 && j < count2)
1312 cmp = strcmp(&pool1[p1->name], &pool2[p2->name]);
1313 else if (i < count1)
1318 cmp = p1->type - p2->type;
1320 cmp = p1->relation - p2->relation;
1322 cmp = versioncmp(&pool1[p1->version],
1323 &pool2[p2->version]);
1325 map1[i++] = add_property(merger,
1328 &pool1[p1->version],
1330 } else if (cmp > 0) {
1331 map2[j++] = add_property(merger,
1334 &pool2[p2->version],
1337 map1[i++] = map2[j++] = add_property(merger,
1340 &pool1[p1->version],
1347 emit_properties(struct list_head *properties, struct array *source_pool,
1348 uint32_t *map, struct array *pool)
1353 r = pool->size / sizeof *q;
1354 p = list_first(properties, source_pool);
1356 q = array_add(pool, sizeof *q);
1357 q->data = map[p->data];
1358 q->flags = p->flags;
1362 list_set_ptr(properties, r);
1366 add_file(struct razor_merger *merger, const char *name)
1368 struct razor_entry *e;
1370 e = array_add(&merger->set->files, sizeof *e);
1371 e->name = hashtable_tokenize(&merger->table, name);
1375 return e - (struct razor_entry *)merger->set->files.data;
1380 fix_file_map(uint32_t *map,
1381 struct razor_entry *files,
1382 struct razor_entry *top)
1390 fix_file_map(map, files, &files[e]);
1393 } while (!(files[e++].flags & RAZOR_ENTRY_LAST));
1396 map[top - files] = 1;
1400 struct merge_directory {
1401 uint32_t merged, dir1, dir2;
1405 merge_one_directory(struct razor_merger *merger, struct merge_directory *md)
1407 struct razor_entry *root1, *root2, *mroot, *e1, *e2;
1408 struct razor_set *set1, *set2;
1409 struct array merge_stack;
1410 struct merge_directory *child_md, *end_md;
1411 uint32_t *map1, *map2, start, last;
1413 char *pool1, *pool2;
1415 set1 = merger->source1.set;
1416 set2 = merger->source2.set;
1417 map1 = merger->source1.file_map;
1418 map2 = merger->source2.file_map;
1419 pool1 = set1->string_pool.data;
1420 pool2 = set2->string_pool.data;
1421 root1 = (struct razor_entry *) set1->files.data;
1422 root2 = (struct razor_entry *) set2->files.data;
1424 array_init(&merge_stack);
1426 start = merger->set->files.size / sizeof (struct razor_entry);
1428 e1 = md->dir1 ? root1 + md->dir1 : NULL;
1429 e2 = md->dir2 ? root2 + md->dir2 : NULL;
1431 if (!e2 && !map1[e1 - root1]) {
1432 if ((e1++)->flags & RAZOR_ENTRY_LAST)
1436 if (!e1 && !map2[e2 - root2]) {
1437 if ((e2++)->flags & RAZOR_ENTRY_LAST)
1441 if (e1 && !map1[e1 - root1] &&
1442 e2 && !map1[e2 - root2]) {
1443 if ((e1++)->flags & RAZOR_ENTRY_LAST)
1445 if ((e2++)->flags & RAZOR_ENTRY_LAST)
1455 cmp = strcmp (&pool1[e1->name],
1460 if (map1[e1 - root1]) {
1461 map1[e1 - root1] = last =
1462 add_file(merger, &pool1[e1->name]);
1464 child_md = array_add(&merge_stack, sizeof (struct merge_directory));
1465 child_md->merged = last;
1466 child_md->dir1 = e1->start;
1470 if ((e1++)->flags & RAZOR_ENTRY_LAST)
1472 } else if (cmp > 0) {
1473 if (map2[e2 - root2]) {
1474 map2[e2 - root2] = last =
1475 add_file(merger, &pool2[e2->name]);
1477 child_md = array_add(&merge_stack, sizeof (struct merge_directory));
1478 child_md->merged = last;
1480 child_md->dir2 = e2->start;
1483 if ((e2++)->flags & RAZOR_ENTRY_LAST)
1486 map1[e1 - root1] = map2[e2- root2] = last =
1487 add_file(merger, &pool1[e1->name]);
1488 if (e1->start || e2->start) {
1489 child_md = array_add(&merge_stack, sizeof (struct merge_directory));
1490 child_md->merged = last;
1491 child_md->dir1 = e1->start;
1492 child_md->dir2 = e2->start;
1494 if ((e1++)->flags & RAZOR_ENTRY_LAST)
1496 if ((e2++)->flags & RAZOR_ENTRY_LAST)
1501 mroot = (struct razor_entry *)merger->set->files.data;
1503 mroot[last].flags = RAZOR_ENTRY_LAST;
1504 mroot[md->merged].start = start;
1506 mroot[md->merged].start = 0;
1508 end_md = merge_stack.data + merge_stack.size;
1509 for (child_md = merge_stack.data; child_md < end_md; child_md++)
1510 merge_one_directory(merger, child_md);
1511 array_release(&merge_stack);
1515 merge_files(struct razor_merger *merger)
1517 struct razor_entry *root;
1518 struct merge_directory md;
1519 uint32_t *map1, *map2;
1521 map1 = merger->source1.file_map;
1522 map2 = merger->source2.file_map;
1526 if (merger->source1.set->files.size) {
1527 root = (struct razor_entry *) merger->source1.set->files.data;
1529 fix_file_map(map1, root, root);
1530 md.dir1 = root->start;
1534 if (merger->source2.set->files.size) {
1535 root = (struct razor_entry *) merger->source2.set->files.data;
1537 fix_file_map(map2, root, root);
1538 md.dir2 = root->start;
1542 merge_one_directory(merger, &md);
1546 emit_files(struct list_head *files, struct array *source_pool,
1547 uint32_t *map, struct array *pool)
1552 r = pool->size / sizeof *q;
1553 p = list_first(files, source_pool);
1555 q = array_add(pool, sizeof *q);
1556 q->data = map[p->data];
1557 q->flags = p->flags;
1561 list_set_ptr(files, r);
1564 /* Rebuild property->packages maps. We can't just remap these, as a
1565 * property may have lost or gained a number of packages. Allocate an
1566 * array per property and loop through the packages and add them to
1567 * the arrays for their properties. */
1569 rebuild_property_package_lists(struct razor_set *set)
1571 struct array *pkgs, *a;
1572 struct razor_package *pkg, *pkg_end;
1573 struct razor_property *prop, *prop_end;
1578 count = set->properties.size / sizeof (struct razor_property);
1579 pkgs = zalloc(count * sizeof *pkgs);
1580 pkg_end = set->packages.data + set->packages.size;
1582 for (pkg = set->packages.data; pkg < pkg_end; pkg++) {
1583 r = list_first(&pkg->properties, &set->property_pool);
1585 q = array_add(&pkgs[r->data], sizeof *q);
1586 *q = pkg - (struct razor_package *) set->packages.data;
1591 prop_end = set->properties.data + set->properties.size;
1593 for (prop = set->properties.data; prop < prop_end; prop++, a++) {
1594 list_set_array(&prop->packages, &set->package_pool, a, 0);
1601 rebuild_file_package_lists(struct razor_set *set)
1603 struct array *pkgs, *a;
1604 struct razor_package *pkg, *pkg_end;
1605 struct razor_entry *entry, *entry_end;
1610 count = set->files.size / sizeof (struct razor_entry);
1611 pkgs = zalloc(count * sizeof *pkgs);
1612 pkg_end = set->packages.data + set->packages.size;
1614 for (pkg = set->packages.data; pkg < pkg_end; pkg++) {
1615 r = list_first(&pkg->files, &set->file_pool);
1617 q = array_add(&pkgs[r->data], sizeof *q);
1618 *q = pkg - (struct razor_package *) set->packages.data;
1623 entry_end = set->files.data + set->files.size;
1625 for (entry = set->files.data; entry < entry_end; entry++, a++) {
1626 list_set_array(&entry->packages, &set->package_pool, a, 0);
1632 static struct razor_set *
1633 razor_merger_finish(struct razor_merger *merger)
1635 struct razor_set *result;
1636 struct razor_package *p, *pend;
1638 /* As we built the package list, we filled out a bitvector of
1639 * the properties that are referenced by the packages in the
1640 * new set. Now we do a parallel loop through the properties
1641 * and emit those marked in the bit vector to the new set. In
1642 * the process, we update the bit vector to actually map from
1643 * indices in the old property list to indices in the new
1644 * property list for both sets. */
1646 merge_properties(merger);
1647 merge_files(merger);
1649 /* Now we loop through the packages again and emit the
1650 * property lists, remapped to point to the new properties. */
1652 pend = merger->set->packages.data + merger->set->packages.size;
1653 for (p = merger->set->packages.data; p < pend; p++) {
1656 if (p->flags & UPSTREAM_SOURCE)
1657 src = &merger->source2;
1659 src = &merger->source1;
1661 emit_properties(&p->properties,
1662 &src->set->property_pool,
1664 &merger->set->property_pool);
1665 emit_files(&p->files,
1666 &src->set->file_pool,
1668 &merger->set->file_pool);
1669 p->flags &= ~UPSTREAM_SOURCE;
1672 rebuild_property_package_lists(merger->set);
1673 rebuild_file_package_lists(merger->set);
1675 result = merger->set;
1676 hashtable_release(&merger->table);
1682 /* The diff order matters. We should sort the packages so that a
1683 * REMOVE of a package comes before the INSTALL, and so that all
1684 * requires for a package have been installed before the package.
1688 razor_set_diff(struct razor_set *set, struct razor_set *upstream,
1689 razor_package_callback_t callback, void *data)
1691 struct razor_package_iterator *pi1, *pi2;
1692 struct razor_package *p1, *p2;
1693 const char *name1, *name2, *version1, *version2, *arch1, *arch2;
1696 pi1 = razor_package_iterator_create(set);
1697 pi2 = razor_package_iterator_create(upstream);
1699 razor_package_iterator_next(pi1, &p1, &name1, &version1, &arch1);
1700 razor_package_iterator_next(pi2, &p2, &name2, &version2, &arch2);
1704 res = strcmp(name1, name2);
1706 res = versioncmp(version1, version2);
1711 if (p2 == NULL || res < 0)
1712 callback(name1, version1, NULL, arch1, data);
1713 else if (p1 == NULL || res > 0)
1714 callback(name2, NULL, version2, arch2, data);
1716 if (p1 != NULL && res <= 0)
1717 razor_package_iterator_next(pi1, &p1,
1718 &name1, &version1, &arch1);
1719 if (p2 != NULL && res >= 0)
1720 razor_package_iterator_next(pi2, &p2,
1721 &name2, &version2, &arch2);
1724 razor_package_iterator_destroy(pi1);
1725 razor_package_iterator_destroy(pi2);
1728 struct razor_transaction;
1729 struct razor_transaction_package;
1730 struct razor_transaction_resolver;
1732 struct razor_transaction {
1733 int package_count, errors;
1734 struct razor_set *system, *upstream;
1736 struct bitarray syspkgs, uppkgs;
1737 struct array packages;
1740 struct razor_transaction_package {
1741 const char *name, *old_version, *new_version;
1742 struct razor_package *old_package, *new_package;
1743 enum razor_transaction_package_state state;
1745 /* dep_package is the name of the package that resulted in
1746 * this entry being created (or NULL if the user requested the
1747 * install/remove), with the other dep_ fields providing
1748 * additional information.
1750 * For INSTALL, if dep_type is REQUIRES, then dep_package
1751 * required something that this package provides. If dep_type
1752 * is CONFLICTS, then dep_package is a package that conflicted
1753 * with an older version of this package, forcing an upgrade.
1755 * For REMOVE, if dep_type is REQUIRES, then dep_package is a
1756 * package that is being removed. If dep_type is OBSOLETES,
1757 * then dep_package is a package that obsoletes this one.
1759 * For OLD_CONFLICT or NEW_CONFLICT, dep_package is an
1760 * existing package that conflicts with this one. The
1761 * conflicting property comes from the already-installed
1762 * package for OLD_CONFLICT, or the to-be-installed package
1765 * For UNSATISFIABLE, the dep_ fields are as for an INSTALL,
1766 * but the name field will be NULL.
1768 const char *dep_package;
1769 enum razor_property_type dep_type;
1770 const char *dep_property;
1771 enum razor_version_relation dep_relation;
1772 const char *dep_version;
1776 package_in_set(void *package, struct razor_set *set)
1778 return package >= set->packages.data &&
1779 package < set->packages.data + set->packages.size;
1783 property_in_set(void *property, struct razor_set *set)
1785 return property >= set->properties.data &&
1786 property < set->properties.data + set->properties.size;
1789 static struct razor_package *
1790 property_provider_package(struct razor_transaction *trans,
1791 struct razor_property *prop,
1794 struct razor_set *set;
1795 struct bitarray *pkgbits;
1796 struct razor_package *pkgs;
1799 if (installed && prop->type != RAZOR_PROPERTY_PROVIDES)
1801 else if (!installed &&
1802 prop->type != RAZOR_PROPERTY_PROVIDES &&
1803 prop->type != RAZOR_PROPERTY_OBSOLETES)
1806 if (property_in_set(prop, trans->system)) {
1807 set = trans->system;
1808 pkgbits = &trans->syspkgs;
1810 set = trans->upstream;
1811 pkgbits = &trans->uppkgs;
1813 pkgs = set->packages.data;
1815 for (p = list_first(&prop->packages, &set->package_pool); p; p = list_next(p)) {
1816 if (bitarray_get(pkgbits, p->data) != installed)
1818 if (prop->type == RAZOR_PROPERTY_OBSOLETES ||
1819 pkgs[p->data].name == prop->name)
1820 return &pkgs[p->data];
1826 compare_transaction_packages(const void *one, const void *two)
1828 struct razor_transaction_package **tp1 = (void *)one;
1829 struct razor_transaction_package **tp2 = (void *)two;
1833 else if (!(*tp2)->name)
1836 return strcmp((*tp1)->name, (*tp2)->name);
1839 /* FIXME: merge this into the other property loop in razor_transaction_satisfy */
1841 resolve_new_packages(struct razor_transaction *trans,
1844 struct razor_property *sp, *up, *sp_end, *up_end;
1845 struct razor_package *spkg, *spkgs, *upkg, *upkgs;
1846 struct razor_transaction_package **packages;
1847 const char *spool, *upool;
1850 sp_end = trans->system->properties.data + trans->system->properties.size;
1851 spool = trans->system->string_pool.data;
1852 spkgs = trans->system->packages.data;
1853 up_end = trans->upstream->properties.data + trans->upstream->properties.size;
1854 upool = trans->upstream->string_pool.data;
1855 upkgs = trans->upstream->packages.data;
1857 /* FIXME, check if sorting the packages directly (rather than
1858 * sorting pointers-to-packages) still results in confusing
1861 packages = calloc(end - start, sizeof *packages);
1862 for (i = start; i < end; i++)
1863 packages[i - start] = ((struct razor_transaction_package *)trans->packages.data) + i;
1864 qsort(packages, end - start, sizeof *packages,
1865 compare_transaction_packages);
1867 sp = trans->system->properties.data;
1868 up = trans->upstream->properties.data;
1869 for (i = 0; i < end - start; i++) {
1870 if (!packages[i]->name ||
1871 packages[i]->state >= RAZOR_PACKAGE_FIRST_ERROR_STATE)
1875 while (sp < sp_end &&
1876 strcmp(&spool[sp->name], packages[i]->name) < 0)
1878 while (sp < sp_end &&
1879 strcmp(&spool[sp->name], packages[i]->name) == 0 &&
1880 !(spkg = property_provider_package(trans, sp, 1)))
1884 while (up < up_end &&
1885 strcmp(&upool[up->name], packages[i]->name) < 0)
1887 while (up < up_end &&
1888 strcmp(&upool[up->name], packages[i]->name) == 0 &&
1889 !(upkg = property_provider_package(trans, up, 0)))
1892 if (packages[i]->state == RAZOR_PACKAGE_REMOVE ||
1893 packages[i]->state == RAZOR_PACKAGE_OBSOLETED) {
1895 packages[i]->old_package = spkg;
1896 packages[i]->name = &spool[spkg->name];
1897 packages[i]->old_version = &spool[spkg->version];
1898 bitarray_set(&trans->syspkgs, spkg - spkgs, 0);
1900 if (!packages[i]->old_package) {
1901 packages[i]->name = strdup(packages[i]->name);
1902 packages[i]->state |= RAZOR_PACKAGE_UNAVAILABLE_FLAG;
1907 packages[i]->new_package = upkg;
1908 packages[i]->name = &upool[upkg->name];
1909 packages[i]->new_version = &upool[upkg->version];
1911 if (up->name != upkg->name) {
1912 packages[i]->dep_package = &upool[upkg->name];
1913 packages[i]->dep_type = up->type;
1914 packages[i]->dep_property = &upool[up->name];
1915 packages[i]->dep_relation = up->relation;
1916 packages[i]->dep_version = &upool[up->version];
1920 packages[i]->old_package = spkg;
1921 packages[i]->old_version = &spool[spkg->version];
1922 if (versioncmp(&spool[spkg->version], &upool[up->version]) >= 0) {
1923 packages[i]->state = RAZOR_PACKAGE_UP_TO_DATE;
1927 bitarray_set(&trans->syspkgs, spkg - spkgs, 0);
1929 bitarray_set(&trans->uppkgs, upkg - upkgs, 1);
1931 if (!packages[i]->new_package) {
1932 packages[i]->name = strdup(packages[i]->name);
1933 packages[i]->state |= RAZOR_PACKAGE_UNAVAILABLE_FLAG;
1941 find_all_packages(struct razor_transaction *trans)
1943 struct razor_transaction_package *tp;
1944 struct razor_package *sp, *spkgs, *send, *up, *upkgs, *uend;
1945 const char *spool, *upool;
1947 spkgs = trans->system->packages.data;
1948 send = trans->system->packages.data + trans->system->packages.size;
1949 spool = trans->system->string_pool.data;
1950 up = upkgs = trans->upstream->packages.data;
1951 uend = trans->upstream->packages.data + trans->upstream->packages.size;
1952 upool = trans->upstream->string_pool.data;
1954 for (sp = spkgs; sp < send; sp++) {
1955 while (up < uend && strcmp(&spool[sp->name], &upool[up->name]) > 0)
1957 if (strcmp(&spool[sp->name], &upool[up->name]) == 0 &&
1958 versioncmp(&spool[sp->version], &upool[up->version]) < 0) {
1959 tp = array_add(&trans->packages, sizeof *tp);
1960 memset(tp, 0, sizeof *tp);
1961 tp->old_package = sp;
1962 tp->new_package = up;
1963 tp->name = &upool[up->name];
1964 tp->old_version = &spool[sp->version];
1965 tp->new_version = &upool[up->version];
1966 tp->state = RAZOR_PACKAGE_INSTALL;
1967 bitarray_set(&trans->uppkgs, up - upkgs, 1);
1968 bitarray_set(&trans->syspkgs, sp - spkgs, 0);
1974 provider_satisfies_requirement(struct razor_property *provider,
1975 const char *provider_strings,
1976 struct razor_property *requirement,
1977 const char *requirement_strings)
1980 const char *provided = &provider_strings[provider->version];
1981 const char *required = &requirement_strings[requirement->version];
1986 if (requirement->relation >= RAZOR_VERSION_EQUAL)
1992 cmp = versioncmp(provided, required);
1994 switch (requirement->relation) {
1995 case RAZOR_VERSION_LESS:
1998 case RAZOR_VERSION_LESS_OR_EQUAL:
2001 /* fall through: FIXME, make sure this is correct */
2003 case RAZOR_VERSION_EQUAL:
2007 /* "foo == 1.1" is satisfied by "foo 1.1-2" */
2008 len = strlen(required);
2009 if (!strncmp(required, provided, len) && provided[len] == '-')
2013 case RAZOR_VERSION_GREATER_OR_EQUAL:
2016 case RAZOR_VERSION_GREATER:
2020 /* shouldn't happen */
2024 static struct razor_package *
2025 find_package_for_file(struct razor_set *set, struct bitarray *pkgbits,
2026 const char *filename, int installed)
2028 struct razor_package *pkgs = set->packages.data;
2029 struct razor_entry *entry;
2032 if (filename[0] != '/')
2035 entry = find_entry(set, set->files.data, filename);
2039 for (p = list_first(&entry->packages, &set->package_pool); p; p = list_next(p)) {
2040 if (bitarray_get(pkgbits, p->data) == installed)
2041 return &pkgs[p->data];
2046 static struct razor_package *
2047 find_installed_package_for_file(struct razor_transaction *trans,
2048 const char *filename)
2050 struct razor_package *pkg;
2052 pkg = find_package_for_file(trans->system, &trans->syspkgs,
2055 pkg = find_package_for_file(trans->upstream, &trans->uppkgs,
2060 static struct razor_package *
2061 find_uninstalled_package_for_file(struct razor_transaction *trans,
2062 const char *filename)
2064 struct razor_package *pkg;
2066 pkg = find_package_for_file(trans->upstream, &trans->uppkgs,
2069 pkg = find_package_for_file(trans->system, &trans->syspkgs,
2074 static struct razor_property *
2075 skip_to_matching_property(struct razor_transaction *trans,
2076 struct razor_property *match,
2077 struct razor_property *prop)
2079 struct razor_set *mset, *pset;
2080 const char *ppool, *mpool;
2081 struct razor_property *prop_end;
2083 if (property_in_set(match, trans->system))
2084 mset = trans->system;
2086 mset = trans->upstream;
2088 if (property_in_set(prop, trans->system))
2089 pset = trans->system;
2090 else if (property_in_set(prop, trans->upstream))
2091 pset = trans->upstream;
2095 prop_end = pset->properties.data + pset->properties.size;
2096 ppool = pset->string_pool.data;
2097 mpool = mset->string_pool.data;
2099 while (prop < prop_end &&
2100 strcmp(&ppool[prop->name], &mpool[match->name]) < 0)
2105 static struct razor_package *
2106 find_package_matching(struct razor_transaction *trans, int installed,
2107 struct razor_property *prop,
2108 struct razor_property *req,
2109 struct razor_set *req_set)
2111 struct razor_set *set;
2112 struct bitarray *pkgbits;
2113 struct razor_package *pkgs;
2114 struct razor_property *props, *prop_end;
2115 enum razor_property_type match_type;
2118 int match_name = (req->type == RAZOR_PROPERTY_OBSOLETES);
2121 if (property_in_set(prop, trans->system)) {
2122 set = trans->system;
2123 pkgbits = &trans->syspkgs;
2124 } else if (property_in_set(prop, trans->upstream)) {
2125 set = trans->upstream;
2126 pkgbits = &trans->uppkgs;
2131 if (property_in_set(req, trans->system))
2132 req_set = trans->system;
2134 req_set = trans->upstream;
2136 rpool = req_set->string_pool.data;
2138 if (req->type == RAZOR_PROPERTY_PROVIDES)
2139 match_type = RAZOR_PROPERTY_CONFLICTS;
2141 match_type = RAZOR_PROPERTY_PROVIDES;
2143 pkgs = set->packages.data;
2144 props = set->properties.data;
2145 prop_end = set->properties.data + set->properties.size;
2146 pool = set->string_pool.data;
2148 /* Find first matching property */
2149 while (prop < prop_end &&
2150 strcmp(&pool[prop->name], &rpool[req->name]) < 0)
2152 if (prop == prop_end ||
2153 strcmp(&pool[prop->name], &rpool[req->name]) > 0)
2156 if (prop->type < match_type) {
2157 while (prop < prop_end && prop->type != match_type)
2160 while (prop >= props && prop->type != match_type)
2162 while (prop > props + 1 && (prop - 1)->name == prop->name &&
2163 (prop - 1)->type == match_type)
2167 /* Scan matching properties */
2168 while (prop < prop_end && prop->type == match_type &&
2169 strcmp(&pool[prop->name], &rpool[req->name]) == 0) {
2170 if (match_type == RAZOR_PROPERTY_PROVIDES)
2171 match = provider_satisfies_requirement(prop, pool, req, rpool);
2173 match = provider_satisfies_requirement(req, rpool, prop, pool);
2177 for (pkg = list_first(&prop->packages, &set->package_pool); pkg; pkg = list_next(pkg)) {
2178 if (bitarray_get(pkgbits, pkg->data) != installed)
2181 strcmp(&pool[pkgs[pkg->data].name],
2182 &rpool[req->name]) == 0)
2183 return &pkgs[pkg->data];
2192 static struct razor_package *
2193 find_installed_package_for_property(struct razor_transaction *trans,
2194 struct razor_property *sys_start,
2195 struct razor_property *up_start,
2196 struct razor_property *req)
2198 struct razor_package *pkg;
2200 pkg = find_package_matching(trans, 1, sys_start, req, NULL);
2202 pkg = find_package_matching(trans, 1, up_start, req, NULL);
2206 static struct razor_package *
2207 find_uninstalled_package_for_property(struct razor_transaction *trans,
2208 struct razor_property *sys_start,
2209 struct razor_property *up_start,
2210 struct razor_property *req)
2212 struct razor_package *pkg;
2214 pkg = find_package_matching(trans, 0, up_start, req, NULL);
2216 pkg = find_package_matching(trans, 0, sys_start, req, NULL);
2220 static struct razor_transaction_package *
2221 find_transaction_package(struct razor_transaction *trans, const char *name)
2223 struct razor_transaction_package *packages;
2226 packages = trans->packages.data;
2227 count = trans->packages.size / sizeof *packages;
2228 for (i = 0; i < count; i++) {
2229 if (packages[i].name && !strcmp(packages[i].name, name))
2230 return &packages[i];
2237 prop_is_being_installed(struct razor_transaction *trans,
2238 struct razor_property *prop)
2242 for (pkg = list_first(&prop->packages, &trans->upstream->package_pool); pkg; pkg = list_next(pkg)) {
2243 if (bitarray_get(&trans->uppkgs, pkg->data))
2250 prop_is_being_removed(struct razor_transaction *trans,
2251 struct razor_property *prop)
2255 for (pkg = list_first(&prop->packages, &trans->system->package_pool); pkg; pkg = list_next(pkg)) {
2256 if (bitarray_get(&trans->syspkgs, pkg->data))
2263 prop_is_being_updated(struct razor_transaction *trans,
2264 struct razor_property *prop)
2266 struct razor_package *packages = trans->system->packages.data;
2267 const char *pool = trans->system->string_pool.data;
2268 struct razor_transaction_package *tp;
2271 /* Assumes prop_is_being_removed returns true */
2273 for (pkg = list_first(&prop->packages, &trans->system->package_pool); pkg; pkg = list_next(pkg)) {
2274 tp = find_transaction_package(trans, &pool[packages[pkg->data].name]);
2275 if (tp && tp->state == RAZOR_PACKAGE_REMOVE)
2282 add_transaction_package(struct razor_transaction *trans,
2283 struct razor_package *new_package,
2284 struct razor_package *old_package,
2285 enum razor_transaction_package_state state,
2286 const char *req_package,
2287 struct razor_property *req_prop)
2289 struct razor_set *new_package_set, *old_package_set, *req_set;
2290 struct bitarray *reqpkgbits;
2291 struct razor_transaction_package *tp, *already;
2293 struct razor_package *pkgs;
2295 int contradiction = 0;
2297 if (package_in_set(new_package, trans->system))
2298 new_package_set = trans->system;
2300 new_package_set = trans->upstream;
2301 if (package_in_set(old_package, trans->system))
2302 old_package_set = trans->system;
2304 old_package_set = trans->upstream;
2305 if (property_in_set(req_prop, trans->system)) {
2306 req_set = trans->system;
2307 reqpkgbits = &trans->syspkgs;
2309 req_set = trans->upstream;
2310 reqpkgbits = &trans->uppkgs;
2314 pool = new_package_set->string_pool.data;
2315 already = find_transaction_package(trans, &pool[new_package->name]);
2317 if (already->new_package == new_package) {
2318 /* Already taken care of */
2320 } else if (new_package_set == trans->upstream &&
2321 already->state == RAZOR_PACKAGE_FORCED_UPDATE) {
2322 already->new_package = new_package;
2327 if (state != RAZOR_PACKAGE_CONTRADICTION)
2330 } else if (old_package) {
2331 pool = old_package_set->string_pool.data;
2332 already = find_transaction_package(trans, &pool[old_package->name]);
2334 if (already->old_package == old_package) {
2335 /* Already taken care of */
2337 } else if (old_package_set == trans->system) {
2338 already->old_package = old_package;
2343 if (state != RAZOR_PACKAGE_CONTRADICTION)
2347 state = RAZOR_PACKAGE_UNSATISFIABLE;
2349 tp = array_add(&trans->packages, sizeof *tp);
2350 memset(tp, 0, sizeof *tp);
2353 pool = new_package_set->string_pool.data;
2354 tp->new_package = new_package;
2355 tp->name = &pool[new_package->name];
2356 tp->new_version = &pool[new_package->version];
2358 pkgs = new_package_set->packages.data;
2361 pool = old_package_set->string_pool.data;
2362 tp->old_package = old_package;
2363 tp->name = &pool[old_package->name];
2364 tp->old_version = &pool[old_package->version];
2366 pkgs = old_package_set->packages.data;
2370 if (state != RAZOR_PACKAGE_INSTALL &&
2371 state != RAZOR_PACKAGE_FORCED_UPDATE &&
2372 state != RAZOR_PACKAGE_REMOVE &&
2373 state != RAZOR_PACKAGE_OBSOLETED)
2376 if (contradiction) {
2377 /* Do this now, after adding tp, so that it ends up
2378 * after both the INSTALL and the REMOVE in the array.
2380 add_transaction_package(trans, new_package, old_package,
2381 RAZOR_PACKAGE_CONTRADICTION,
2386 tp->dep_package = req_package;
2390 pool = req_set->string_pool.data;
2391 pkgs = req_set->packages.data;
2393 for (pkg = list_first(&req_prop->packages, &req_set->package_pool); pkg; pkg = list_next(pkg)) {
2394 if (bitarray_get(reqpkgbits, pkg->data))
2398 tp->dep_package = &pool[pkgs[pkg->data].name];
2401 tp->dep_type = req_prop->type;
2402 tp->dep_property = &pool[req_prop->name];
2403 tp->dep_relation = req_prop->relation;
2404 tp->dep_version = &pool[req_prop->version];
2408 razor_transaction_satisfy(struct razor_transaction *trans)
2410 struct razor_package *spkgs, *upkgs, *pkg;
2411 struct razor_property *sp, *sprops, *sprop_end;
2412 struct razor_property *up, *uprops, *uprop_end;
2413 struct razor_property *sr, *ur, *first_up;
2414 const char *spool, *upool, *removed_package;
2415 struct list *reqpkg;
2417 spkgs = trans->system->packages.data;
2418 sprops = trans->system->properties.data;
2419 sprop_end = trans->system->properties.data + trans->system->properties.size;
2420 spool = trans->system->string_pool.data;
2421 upkgs = trans->upstream->packages.data;
2422 uprops = trans->upstream->properties.data;
2423 uprop_end = trans->upstream->properties.data + trans->upstream->properties.size;
2424 upool = trans->upstream->string_pool.data;
2427 for (up = uprops; up < uprop_end; up++) {
2428 /* Skip 'up' ahead to a property of a package which is
2431 while (up < uprop_end &&
2432 !prop_is_being_installed(trans, up))
2434 if (up == uprop_end)
2436 sp = skip_to_matching_property(trans, up, sp);
2439 case RAZOR_PROPERTY_REQUIRES:
2440 if (!strncmp(&upool[up->name], "rpmlib(", 7))
2443 if (find_installed_package_for_property(trans, sp, up, up) ||
2444 find_installed_package_for_file(trans, &upool[up->name])) {
2445 /* Requires something that is either installed
2446 * or to-be-installed.
2451 /* See if we can install a new upstream provider */
2452 pkg = find_uninstalled_package_for_property(trans, sp, up, up);
2454 pkg = find_uninstalled_package_for_file(trans, &upool[up->name]);
2455 add_transaction_package(trans, pkg, NULL,
2456 RAZOR_PACKAGE_INSTALL,
2460 case RAZOR_PROPERTY_PROVIDES:
2461 /* find_installed_package_for_property works backwards
2462 * here, finding a *conflicting* installed package.
2464 pkg = find_installed_package_for_property(trans, sp, up, up);
2468 if (package_in_set(pkg, trans->system)) {
2469 /* pkg CONFLICTS with what 'up' PROVIDES. Try
2470 * finding an upgrade
2472 add_transaction_package(trans, NULL, pkg,
2473 RAZOR_PACKAGE_FORCED_UPDATE,
2474 &upool[up->name], sp);
2476 add_transaction_package(trans, NULL, pkg,
2477 RAZOR_PACKAGE_CONTRADICTION,
2482 case RAZOR_PROPERTY_CONFLICTS:
2483 pkg = find_installed_package_for_property(trans, sp, up, up);
2487 if (package_in_set(pkg, trans->system)) {
2488 /* Conflicts with something already installed.
2489 * Try to upgrade out.
2491 add_transaction_package(trans, NULL, pkg,
2492 RAZOR_PACKAGE_FORCED_UPDATE,
2495 add_transaction_package(trans, pkg, NULL,
2496 RAZOR_PACKAGE_CONTRADICTION,
2501 case RAZOR_PROPERTY_OBSOLETES:
2502 pkg = find_installed_package_for_property(trans, sp, up, up);
2504 /* If pkg is to-be-installed, this
2505 * will add a CONTRADICTION error as well.
2507 add_transaction_package(trans, NULL, pkg,
2508 RAZOR_PACKAGE_OBSOLETED,
2520 for (sp = sprops; sp < sprop_end; sp++) {
2521 /* Skip 'sp' ahead to a PROVIDES of a package which is
2524 while (sp < sprop_end &&
2525 (sp->type != RAZOR_PROPERTY_PROVIDES ||
2526 !prop_is_being_removed(trans, sp)))
2528 if (sp == sprop_end)
2531 removed_package = &spool[spkgs[list_first(&sp->packages, &trans->system->package_pool)->data].name];
2533 /* Skip 'up' to match */
2534 up = skip_to_matching_property(trans, sp, up);
2537 /* If the package is just being upgraded, we may
2538 * already be installing an identical PROVIDES, so
2541 while (up < uprop_end &&
2542 strcmp(&spool[sp->name], &upool[up->name]) == 0 &&
2543 (up->type != RAZOR_PROPERTY_PROVIDES ||
2544 sp->relation != up->relation ||
2545 strcmp(&spool[sp->name], &upool[up->name]) != 0))
2547 if (up < uprop_end &&
2548 up->type == RAZOR_PROPERTY_PROVIDES &&
2549 strcmp(&spool[sp->name], &upool[up->name]) == 0 &&
2550 sp->relation == up->relation &&
2551 strcmp(&spool[sp->version], &upool[up->version]) == 0 &&
2552 prop_is_being_installed(trans, up)) {
2558 /* For all still-installed packages that require
2559 * sp->name, see if they are satisfied by any other
2560 * still-installed or to-be-installed property. If
2561 * not, either remove or attempt to update the
2562 * package, depending on why the required property has
2566 while (sr > sprops + 1 && (sr - 1)->name == sr->name)
2568 for (; sr->type == RAZOR_PROPERTY_REQUIRES; sr++) {
2569 if (prop_is_being_removed(trans, sr))
2571 if (find_installed_package_for_property(trans, sp, up, sr))
2574 for (reqpkg = list_first(&sr->packages, &trans->system->package_pool); reqpkg; reqpkg = list_next(reqpkg)) {
2575 if (!bitarray_get(&trans->syspkgs, reqpkg->data))
2577 pkg = &spkgs[reqpkg->data];
2578 if (prop_is_being_updated(trans, sp)) {
2579 add_transaction_package(trans, NULL, pkg,
2580 RAZOR_PACKAGE_FORCED_UPDATE,
2581 removed_package, NULL);
2583 add_transaction_package(trans, NULL, pkg,
2584 RAZOR_PACKAGE_REMOVE,
2585 removed_package, sr);
2592 struct razor_transaction *
2593 razor_transaction_create(struct razor_set *system, struct razor_set *upstream,
2594 int update_count, const char **update_packages,
2595 int remove_count, const char **remove_packages)
2597 struct razor_transaction *trans;
2598 struct razor_transaction_package *tp;
2601 trans = zalloc(sizeof *trans);
2603 trans->system = system;
2604 trans->upstream = upstream ? upstream : razor_set_create();
2605 array_init(&trans->packages);
2606 bitarray_init(&trans->syspkgs, trans->system->packages.size / sizeof (struct razor_package), 1);
2607 bitarray_init(&trans->uppkgs, trans->upstream->packages.size / sizeof (struct razor_package), 0);
2610 if (update_count > 0 || remove_count > 0) {
2611 for (i = 0; i < update_count; i++) {
2612 tp = array_add(&trans->packages, sizeof *tp);
2613 memset(tp, 0, sizeof *tp);
2614 tp->name = update_packages[i];
2615 tp->state = RAZOR_PACKAGE_INSTALL;
2617 for (i = 0; i < remove_count; i++) {
2618 tp = array_add(&trans->packages, sizeof *tp);
2619 memset(tp, 0, sizeof *tp);
2620 tp->name = remove_packages[i];
2621 tp->state = RAZOR_PACKAGE_REMOVE;
2624 find_all_packages(trans);
2627 end = trans->packages.size / sizeof (struct razor_transaction_package);
2629 while (start != end) {
2630 resolve_new_packages(trans, start, end);
2634 razor_transaction_satisfy(trans);
2637 end = trans->packages.size / sizeof (struct razor_transaction_package);
2640 trans->package_count = end;
2645 const char * const razor_version_relations[] = {
2646 /* same order as enum razor_version_relation */
2647 "<", "<=", "=", ">=", ">"
2650 const char * const razor_property_types[] = {
2651 /* same order as enum razor_property_type */
2652 "requires", "provides", "conflicts with", "obsoletes"
2656 print_requirement(struct razor_transaction_package *p)
2658 if (p->dep_type == RAZOR_PROPERTY_CONFLICTS &&
2659 !strcmp(p->dep_package, p->name)) {
2660 printf(" because %s %s conflicts with %s",
2661 p->name, p->old_version, p->dep_property);
2662 if (*p->dep_version) {
2664 razor_version_relations[p->dep_relation],
2668 if (strcmp(p->name, p->dep_package) != 0)
2669 printf(" for %s", p->dep_package);
2670 if (*p->dep_version) {
2671 printf(", which %s %s %s %s",
2672 razor_property_types[p->dep_type],
2674 razor_version_relations[p->dep_relation],
2676 } else if (strcmp(p->dep_property, p->name) != 0) {
2677 printf(", which %s %s",
2678 razor_property_types[p->dep_type],
2685 razor_transaction_describe(struct razor_transaction *trans)
2687 struct razor_transaction_package *p, *pend, *tps;
2688 int errors_only = 0;
2690 tps = trans->packages.data;
2691 pend = trans->packages.data + trans->packages.size;
2692 for (p = trans->packages.data; p < pend; p++) {
2694 case RAZOR_PACKAGE_INSTALL:
2698 printf("Installing %s %s", p->name, p->new_version);
2700 print_requirement(p);
2704 case RAZOR_PACKAGE_FORCED_UPDATE:
2708 printf("Updating %s to %s due to update of %s\n",
2709 p->name, p->new_version, p->dep_package);
2712 case RAZOR_PACKAGE_REMOVE:
2715 printf("Removing %s %s", p->name, p->old_version);
2716 if (p->dep_package) {
2717 printf(" which required %s",
2719 if (strcmp(p->dep_property, p->dep_package) != 0)
2720 printf(" for %s", p->dep_property);
2725 case RAZOR_PACKAGE_OBSOLETED:
2728 printf("Removing %s %s", p->name, p->old_version);
2729 if (p->dep_package) {
2730 printf(" which is obsoleted by %s",
2736 case RAZOR_PACKAGE_INSTALL_UNAVAILABLE:
2737 printf("Error: can't find %s", p->name);
2738 if (p->dep_package) {
2739 printf(" (which is required");
2740 print_requirement(p);
2747 case RAZOR_PACKAGE_UPDATE_UNAVAILABLE:
2748 printf("Error: can't find an updated version of %s (which must be updated due to update of %s)\n",
2749 p->name, p->dep_package);
2753 case RAZOR_PACKAGE_REMOVE_NOT_INSTALLED:
2754 printf("Error: can't remove %s: not installed\n", p->name);
2758 case RAZOR_PACKAGE_UP_TO_DATE:
2759 printf("Error: can't update %s", p->name);
2761 printf(" (which must be updated due to update of %s)", p->dep_package);
2762 printf(": %s is most recent version\n", p->old_version);
2766 case RAZOR_PACKAGE_CONTRADICTION:
2767 printf("Error: package %s is marked for both installation and removal\n", p->name);
2771 case RAZOR_PACKAGE_OLD_CONFLICT:
2772 printf("Error: can't install %s, because installed package %s conflicts with ",
2773 p->name, p->dep_package);
2774 if (*p->dep_version) {
2777 razor_version_relations[p->dep_relation],
2786 case RAZOR_PACKAGE_NEW_CONFLICT:
2787 printf("Error: can't install %s, because it conflicts with %s",
2788 p->name, p->dep_package);
2789 if (*p->dep_version) {
2791 razor_version_relations[p->dep_relation],
2799 case RAZOR_PACKAGE_UNSATISFIABLE:
2800 printf("Error: can't find package for %s", p->dep_property);
2801 if (*p->dep_version) {
2803 razor_version_relations[p->dep_relation],
2806 printf(" which is required by %s\n",
2812 /* Shouldn't actually happen */
2817 return trans->errors;
2821 razor_transaction_unsatisfied_property(struct razor_transaction *trans,
2823 enum razor_version_relation rel,
2824 const char *version)
2826 struct razor_transaction_package *p, *end;
2828 end = trans->packages.data + trans->packages.size;
2829 for (p = trans->packages.data; p < end; p++) {
2830 if (p->state != RAZOR_PACKAGE_UNSATISFIABLE)
2832 if (strcmp(name, p->dep_property) != 0 ||
2833 rel != p->dep_relation ||
2834 strcmp(version, p->dep_version) != 0)
2844 razor_transaction_finish(struct razor_transaction *trans)
2846 struct array install_packages, remove_packages;
2847 struct razor_merger *merger;
2848 struct razor_package *pkg, *i, *iend, *r, *rend, *s, *send;
2849 struct razor_set *set;
2850 struct source *source1, *source2;
2851 char *spool, *ipool, *rpool;
2853 struct razor_transaction_package *p, *end;
2860 /* Sort the transaction packages into two arrays */
2861 array_init(&install_packages);
2862 array_init(&remove_packages);
2864 end = trans->packages.data + trans->packages.size;
2865 for (p = trans->packages.data; p < end; p++) {
2866 if (p->new_package) {
2867 pkg = array_add(&install_packages, sizeof *pkg);
2868 *pkg = *p->new_package;
2870 pkg = array_add(&remove_packages, sizeof *pkg);
2871 *pkg = *p->old_package;
2874 map = razor_qsort_with_data(install_packages.data,
2875 install_packages.size / sizeof *pkg,
2880 map = razor_qsort_with_data(remove_packages.data,
2881 remove_packages.size / sizeof *pkg,
2887 merger = razor_merger_create(trans->system, trans->upstream);
2889 source1 = &merger->source1;
2890 source2 = &merger->source2;
2892 i = install_packages.data;
2893 iend = install_packages.data + install_packages.size;
2894 ipool = trans->upstream->string_pool.data;
2896 r = remove_packages.data;
2897 rend = remove_packages.data + remove_packages.size;
2898 rpool = trans->system->string_pool.data;
2900 s = trans->system->packages.data;
2901 send = trans->system->packages.data + trans->system->packages.size;
2902 spool = trans->system->string_pool.data;
2904 while (s < send || i < iend) {
2905 /* Check if s is being removed */
2906 if (s < send && r < rend &&
2907 s->name == r->name && s->version && r->version) {
2913 if (s < send && i < iend)
2914 cmp = strcmp(&spool[s->name], &ipool[i->name]);
2920 add_package(merger, s, source1, 0);
2922 } else if (cmp == 0) {
2923 add_package(merger, i, source2, UPSTREAM_SOURCE);
2927 add_package(merger, i, source2, UPSTREAM_SOURCE);
2932 array_release(&install_packages);
2933 array_release(&remove_packages);
2935 set = razor_merger_finish(merger);
2936 razor_transaction_destroy(trans);
2942 razor_transaction_destroy(struct razor_transaction *trans)
2944 struct razor_transaction_package *p, *end;
2946 end = trans->packages.data + trans->packages.size;
2947 for (p = trans->packages.data; p < end; p++) {
2948 if (!p->dep_package &&
2949 (p->state == RAZOR_PACKAGE_INSTALL_UNAVAILABLE ||
2950 p->state == RAZOR_PACKAGE_REMOVE_NOT_INSTALLED))
2951 free((char *)p->name);
2954 array_release(&trans->packages);
2955 bitarray_release(&trans->syspkgs);
2956 bitarray_release(&trans->uppkgs);
2959 /* FIXME: free upstream if it was created as an empty set */