Track file owner ship.
22 struct razor_set_section {
28 struct razor_set_header {
31 struct razor_set_section sections[0];
34 #define RAZOR_MAGIC 0x7a7a7a7a
35 #define RAZOR_VERSION 1
37 #define RAZOR_PACKAGES 0
38 #define RAZOR_REQUIRES 1
39 #define RAZOR_PROVIDES 2
40 #define RAZOR_STRING_POOL 3
41 #define RAZOR_PACKAGE_POOL 4
42 #define RAZOR_REQUIRES_POOL 5
43 #define RAZOR_PROVIDES_POOL 6
44 #define RAZOR_FILE_TREE 7
46 struct razor_package {
48 unsigned long version;
49 unsigned long requires;
50 unsigned long provides;
53 struct razor_property {
55 unsigned long version;
56 unsigned long packages;
63 unsigned long packages;
67 struct array string_pool;
68 struct array packages;
69 struct array package_pool;
70 struct array requires;
71 struct array provides;
72 struct array requires_pool;
73 struct array provides_pool;
74 struct array file_tree;
75 struct razor_set_header *header;
79 unsigned long package;
83 struct import_directory {
84 unsigned long name, count;
86 struct array packages;
87 struct import_directory *last;
90 struct import_property_context {
95 struct razor_importer {
96 struct razor_set *set;
98 struct import_property_context requires;
99 struct import_property_context provides;
100 struct razor_package *package;
105 array_init(struct array *array)
107 memset(array, 0, sizeof *array);
111 array_release(struct array *array)
117 array_add(struct array *array, int size)
122 if (array->alloc > 0)
123 alloc = array->alloc;
127 while (alloc < array->size + size)
130 if (array->alloc < alloc) {
131 data = realloc(array->data, alloc);
135 array->alloc = alloc;
138 p = array->data + array->size;
145 write_to_fd(int fd, void *p, size_t size)
151 len = write(fd, p, rest);
171 struct razor_set_section razor_sections[] = {
172 { RAZOR_PACKAGES, offsetof(struct razor_set, packages) },
173 { RAZOR_REQUIRES, offsetof(struct razor_set, requires) },
174 { RAZOR_PROVIDES, offsetof(struct razor_set, provides) },
175 { RAZOR_STRING_POOL, offsetof(struct razor_set, string_pool) },
176 { RAZOR_PACKAGE_POOL, offsetof(struct razor_set, package_pool) },
177 { RAZOR_REQUIRES_POOL, offsetof(struct razor_set, requires_pool) },
178 { RAZOR_PROVIDES_POOL, offsetof(struct razor_set, provides_pool) },
179 { RAZOR_FILE_TREE, offsetof(struct razor_set, file_tree) },
183 razor_set_create(void)
185 return zalloc(sizeof(struct razor_set));
189 razor_set_open(const char *filename)
191 struct razor_set *set;
192 struct razor_set_section *s;
197 set = zalloc(sizeof *set);
198 fd = open(filename, O_RDONLY);
199 if (fstat(fd, &stat) < 0)
201 set->header = mmap(NULL, stat.st_size, PROT_READ, MAP_PRIVATE, fd, 0);
202 if (set->header == MAP_FAILED) {
207 for (s = set->header->sections; ~s->type; s++) {
208 if (s->type >= ARRAY_SIZE(razor_sections))
210 if (s->type != razor_sections[s->type].type)
212 array = (void *) set + razor_sections[s->type].offset;
213 array->data = (void *) set->header + s->offset;
214 array->size = s->size;
215 array->alloc = s->size;
223 razor_set_destroy(struct razor_set *set)
230 for (i = 0; set->header->sections[i].type; i++)
232 size = set->header->sections[i].type;
233 munmap(set->header, size);
235 for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
236 a = (void *) set + razor_sections[i].offset;
245 razor_set_write(struct razor_set *set, const char *filename)
248 struct razor_set_header *header = (struct razor_set_header *) data;
250 unsigned long offset;
253 memset(data, 0, sizeof data);
254 header->magic = RAZOR_MAGIC;
255 header->version = RAZOR_VERSION;
256 offset = sizeof data;
258 for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
259 if (razor_sections[i].type != i)
261 a = (void *) set + razor_sections[i].offset;
262 header->sections[i].type = i;
263 header->sections[i].offset = offset;
264 header->sections[i].size = a->size;
265 offset += (a->size + 4095) & ~4095;
268 header->sections[i].type = ~0;
269 header->sections[i].offset = 0;
270 header->sections[i].size = 0;
272 fd = open(filename, O_CREAT | O_WRONLY | O_TRUNC, 0666);
276 write_to_fd(fd, data, sizeof data);
277 for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
278 if (razor_sections[i].type != i)
280 a = (void *) set + razor_sections[i].offset;
281 write_to_fd(fd, a->data, (a->size + 4095) & ~4095);
290 hash_string(const char *key)
293 unsigned int hash = 0;
295 for (p = key; *p; p++)
296 hash = (hash * 617) ^ *p;
302 razor_importer_lookup(struct razor_importer *importer, const char *key)
304 unsigned int mask, start, i;
308 pool = importer->set->string_pool.data;
309 mask = importer->buckets.alloc - 1;
310 start = hash_string(key) * sizeof(unsigned long);
312 for (i = 0; i < importer->buckets.alloc; i += sizeof *b) {
313 b = importer->buckets.data + ((start + i) & mask);
318 if (strcmp(key, &pool[*b]) == 0)
326 add_to_string_pool(struct razor_set *set, const char *key)
331 len = strlen(key) + 1;
332 p = array_add(&set->string_pool, len);
335 return p - (char *) set->string_pool.data;
339 add_to_property_pool(struct array *pool, struct array *properties)
343 p = array_add(properties, sizeof *p);
345 p = array_add(pool, properties->size);
346 memcpy(p, properties->data, properties->size);
348 return p - (unsigned long *) pool->data;
352 do_insert(struct razor_importer *importer, unsigned long value)
354 unsigned int mask, start, i;
358 key = (char *) importer->set->string_pool.data + value;
359 mask = importer->buckets.alloc - 1;
360 start = hash_string(key) * sizeof(unsigned long);
362 for (i = 0; i < importer->buckets.alloc; i += sizeof *b) {
363 b = importer->buckets.data + ((start + i) & mask);
372 razor_importer_insert(struct razor_importer *importer, const char *key)
374 unsigned long value, *buckets, *b, *end;
377 alloc = importer->buckets.alloc;
378 array_add(&importer->buckets, 4 * sizeof *buckets);
379 if (alloc != importer->buckets.alloc) {
380 end = importer->buckets.data + alloc;
381 memset(end, 0, importer->buckets.alloc - alloc);
382 for (b = importer->buckets.data; b < end; b++) {
386 do_insert(importer, value);
391 value = add_to_string_pool(importer->set, key);
392 do_insert (importer, value);
398 razor_importer_tokenize(struct razor_importer *importer, const char *string)
403 return razor_importer_tokenize(importer, "");
405 token = razor_importer_lookup(importer, string);
409 return razor_importer_insert(importer, string);
413 razor_importer_begin_package(struct razor_importer *importer,
414 const char *name, const char *version)
416 struct razor_package *p;
418 p = array_add(&importer->set->packages, sizeof *p);
419 p->name = razor_importer_tokenize(importer, name);
420 p->version = razor_importer_tokenize(importer, version);
422 importer->package = p;
423 array_init(&importer->requires.package);
424 array_init(&importer->provides.package);
428 razor_importer_finish_package(struct razor_importer *importer)
430 struct razor_package *p;
432 p = importer->package;
433 p->requires = add_to_property_pool(&importer->set->requires_pool,
434 &importer->requires.package);
435 p->provides = add_to_property_pool(&importer->set->provides_pool,
436 &importer->provides.package);
438 array_release(&importer->requires.package);
439 array_release(&importer->provides.package);
443 razor_importer_add_property(struct razor_importer *importer,
444 struct import_property_context *pctx,
445 const char *name, const char *version)
447 struct razor_property *p;
450 p = array_add(pctx->all, sizeof *p);
451 p->name = razor_importer_tokenize(importer, name);
452 p->version = razor_importer_tokenize(importer, version);
453 p->packages = importer->package -
454 (struct razor_package *) importer->set->packages.data;
456 r = array_add(&pctx->package, sizeof *r);
457 *r = p - (struct razor_property *) pctx->all->data;
461 razor_importer_add_requires(struct razor_importer *importer,
462 const char *name, const char *version)
464 razor_importer_add_property(importer,
465 &importer->requires, name, version);
469 razor_importer_add_provides(struct razor_importer *importer,
470 const char *name, const char *version)
472 razor_importer_add_property(importer,
473 &importer->provides, name, version);
477 razor_importer_add_file(struct razor_importer *importer, const char *name)
479 struct import_entry *e;
481 e = array_add(&importer->files, sizeof *e);
483 e->package = importer->package -
484 (struct razor_package *) importer->set->packages.data;
485 e->name = strdup(name);
488 struct razor_importer *
489 razor_importer_new(void)
491 struct razor_importer *importer;
493 importer = zalloc(sizeof *importer);
494 importer->set = razor_set_create();
495 importer->requires.all = &importer->set->requires;
496 importer->provides.all = &importer->set->provides;
501 typedef int (*compare_with_data_func_t)(const void *p1,
505 struct qsort_context {
507 compare_with_data_func_t compare;
512 qsort_swap(void *p1, void *p2, size_t size)
516 memcpy(buffer, p1, size);
517 memcpy(p1, p2, size);
518 memcpy(p2, buffer, size);
522 __qsort_with_data(void *base, size_t nelem, unsigned long *map,
523 struct qsort_context *ctx)
525 void *p, *start, *end, *pivot;
526 unsigned long *mp, *mstart, *mend, tmp;
527 int left, right, result;
528 size_t size = ctx->size;
532 end = base + nelem * size;
536 pivot = base + (random() % nelem) * size;
539 result = ctx->compare(p, pivot, ctx->data);
541 qsort_swap(p, start, size);
551 } else if (result == 0) {
557 qsort_swap(p, end, size);
566 left = (start - base) / size;
567 right = (base + nelem * size - end) / size;
569 __qsort_with_data(base, left, map, ctx);
571 __qsort_with_data(end, right, mend, ctx);
575 qsort_with_data(void *base, size_t nelem, size_t size,
576 compare_with_data_func_t compare, void *data)
578 struct qsort_context ctx;
583 ctx.compare = compare;
586 map = malloc(nelem * sizeof (unsigned long));
587 for (i = 0; i < nelem; i++)
590 __qsort_with_data(base, nelem, map, &ctx);
596 versioncmp(const char *s1, const char *s2)
602 n1 = strtol(s1, (char **) &p1, 0);
603 n2 = strtol(s2, (char **) &p2, 0);
605 /* Epoch; if one but not the other has an epoch set, default
606 * the epoch-less version to 0. */
607 res = (*p1 == ':') - (*p2 == ':');
612 } else if (res > 0) {
625 if (isdigit(*p1) && isdigit(*p2))
626 return versioncmp(p1, p2);
634 compare_packages(const void *p1, const void *p2, void *data)
636 const struct razor_package *pkg1 = p1, *pkg2 = p2;
637 struct razor_set *set = data;
638 char *pool = set->string_pool.data;
640 if (pkg1->name == pkg2->name)
641 return versioncmp(&pool[pkg1->version], &pool[pkg2->version]);
643 return strcmp(&pool[pkg1->name], &pool[pkg2->name]);
647 compare_properties(const void *p1, const void *p2, void *data)
649 const struct razor_property *prop1 = p1, *prop2 = p2;
650 struct razor_set *set = data;
651 char *pool = set->string_pool.data;
653 if (prop1->name == prop2->name)
654 return versioncmp(&pool[prop1->version], &pool[prop2->version]);
656 return strcmp(&pool[prop1->name], &pool[prop2->name]);
659 static unsigned long *
660 uniqueify_properties(struct razor_set *set, struct array *properties)
662 struct razor_property *rp, *up, *rp_end;
663 struct array *pkgs, *p;
664 unsigned long *map, *rmap, *r;
665 int i, count, unique;
667 count = properties->size / sizeof(struct razor_property);
668 map = qsort_with_data(properties->data,
670 sizeof(struct razor_property),
674 rp_end = properties->data + properties->size;
675 rmap = malloc(count * sizeof *map);
676 pkgs = zalloc(count * sizeof *pkgs);
677 for (rp = properties->data, up = rp, i = 0; rp < rp_end; rp++, i++) {
678 if (rp->name != up->name || rp->version != up->version) {
681 up->version = rp->version;
684 unique = up - (struct razor_property *) properties->data;
685 rmap[map[i]] = unique;
686 r = array_add(&pkgs[unique], sizeof *r);
692 properties->size = (void *) up - properties->data;
694 for (rp = properties->data, p = pkgs; rp < rp_end; rp++, p++) {
695 rp->packages = add_to_property_pool(&set->package_pool, p);
705 remap_links(struct array *links, unsigned long *map)
707 unsigned long *p, *end;
709 end = links->data + links->size;
710 for (p = links->data; p < end; p++)
716 compare_filenames(const void *p1, const void *p2, void *data)
718 const struct import_entry *e1 = p1;
719 const struct import_entry *e2 = p2;
721 return strcmp(e1->name, e2->name);
725 count_entries(struct import_directory *d)
727 struct import_directory *p, *end;
730 end = d->files.data + d->files.size;
734 d->count += p->count + 1;
740 serialize_files(struct razor_set *set,
741 struct import_directory *d, struct array *array)
743 struct import_directory *p, *end;
744 struct razor_entry *e;
748 end = d->files.data + d->files.size;
749 s = array->size / sizeof *e + d->files.size / sizeof *p;
751 e = array_add(array, sizeof *e);
753 e->count = p->files.size / sizeof *p;
756 e->packages = add_to_property_pool(&set->package_pool,
758 array_release(&p->packages);
763 end = d->files.data + d->files.size;
765 serialize_files(set, p, array);
771 build_file_tree(struct razor_importer *importer)
773 int count, i, length;
774 struct import_entry *filenames;
776 unsigned long name, *r;
778 struct import_directory *d, root;
779 struct razor_entry *e;
781 count = importer->files.size / sizeof (struct import_entry);
782 qsort_with_data(importer->files.data,
784 sizeof (struct import_entry),
788 root.name = razor_importer_tokenize(importer, "");
789 array_init(&root.files);
790 array_init(&root.packages);
793 filenames = importer->files.data;
794 for (i = 0; i < count; i++) {
795 f = filenames[i].name;
801 end = strchr(f + 1, '/');
804 length = end - (f + 1);
805 memcpy(dirname, f + 1, length);
806 dirname[length] ='\0';
807 name = razor_importer_tokenize(importer, dirname);
808 if (d->last == NULL || d->last->name != name) {
809 d->last = array_add(&d->files, sizeof *d);
810 d->last->name = name;
811 d->last->last = NULL;
812 array_init(&d->last->files);
813 array_init(&d->last->packages);
819 r = array_add(&d->packages, sizeof *r);
820 *r = filenames[i].package;
821 free(filenames[i].name);
824 count_entries(&root);
825 array_init(&importer->set->file_tree);
827 e = array_add(&importer->set->file_tree, sizeof *e);
829 e->count = root.files.size / sizeof *d;
832 serialize_files(importer->set, &root, &importer->set->file_tree);
834 array_release(&importer->files);
837 static struct razor_entry *
838 find_entry(struct razor_set *set, struct razor_entry *dir, const char *name)
840 struct razor_entry *e, *end;
841 char *pool = set->string_pool.data;
847 p = strchr(name + 1, '/');
848 e = (struct razor_entry *) set->file_tree.data + dir->start;
849 end = e + dir->count;
853 if ((p != NULL && strncmp(n, name + 1, p - (name + 1)) == 0) ||
854 (p == NULL && strcmp(n, name + 1) == 0))
855 return find_entry(set, e, p);
863 list_dir(struct razor_set *set, struct razor_entry *e, int indent)
865 struct razor_entry *c;
866 char *pool = set->string_pool.data;
869 for (i = 0; i < indent; i++)
871 printf("%s\n", pool + e->name);
872 for (i = 0; i < e->count; i++) {
873 c = (struct razor_entry *) set->file_tree.data + e->start + i;
874 list_dir(set, c, indent + 2);
879 razor_set_list_files(struct razor_set *set, const char *prefix)
881 struct razor_entry *e;
883 e = find_entry(set, set->file_tree.data, prefix);
890 razor_set_list_file_packages(struct razor_set *set, const char *filename)
892 struct razor_entry *e;
893 struct razor_package *packages, *p;
897 e = find_entry(set, set->file_tree.data, filename);
901 r = (unsigned long *) set->package_pool.data + e->packages;
902 packages = set->packages.data;
903 pool = set->string_pool.data;
906 printf("%s %s\n", &pool[p->name], &pool[p->version]);
911 razor_importer_finish(struct razor_importer *importer)
913 struct razor_set *set;
914 unsigned long *map, *rmap;
917 map = uniqueify_properties(importer->set, &importer->set->requires);
918 remap_links(&importer->set->requires_pool, map);
921 map = uniqueify_properties(importer->set, &importer->set->provides);
922 remap_links(&importer->set->provides_pool, map);
925 count = importer->set->packages.size / sizeof(struct razor_package);
926 map = qsort_with_data(importer->set->packages.data,
928 sizeof(struct razor_package),
932 rmap = malloc(count * sizeof *rmap);
933 for (i = 0; i < count; i++)
937 build_file_tree(importer);
938 remap_links(&importer->set->package_pool, rmap);
942 array_release(&importer->buckets);
949 razor_set_list(struct razor_set *set)
951 struct razor_package *p, *end;
954 pool = set->string_pool.data;
955 end = set->packages.data + set->packages.size;
956 for (p = set->packages.data; p < end; p++)
957 printf("%s %s\n", &pool[p->name], &pool[p->version]);
960 struct razor_set *bsearch_set;
963 compare_package_name(const void *key, const void *data)
965 const struct razor_package *p = data;
968 pool = bsearch_set->string_pool.data;
970 return strcmp(key, &pool[p->name]);
973 struct razor_package *
974 razor_set_get_package(struct razor_set *set, const char *package)
977 return bsearch(package, set->packages.data,
978 set->packages.size / sizeof(struct razor_package),
979 sizeof(struct razor_package), compare_package_name);
983 compare_property_name(const void *key, const void *data)
985 const struct razor_property *p = data;
988 pool = bsearch_set->string_pool.data;
990 return strcmp(key, &pool[p->name]);
993 struct razor_property *
994 razor_set_get_property(struct razor_set *set,
995 struct array *properties,
996 const char *property)
998 struct razor_property *p, *start;
1001 p = bsearch(property, properties->data,
1002 properties->size / sizeof(struct razor_property),
1003 sizeof(struct razor_property), compare_property_name);
1005 start = properties->data;
1006 while (p > start && (p - 1)->name == p->name)
1013 razor_set_list_all_properties(struct razor_set *set, struct array *properties)
1015 struct razor_property *p, *end;
1018 pool = set->string_pool.data;
1019 end = properties->data + properties->size;
1020 for (p = properties->data; p < end; p++)
1021 printf("%s %s\n", &pool[p->name], &pool[p->version]);
1025 razor_set_list_requires(struct razor_set *set, const char *name)
1027 struct razor_property *p, *requires;
1028 struct razor_package *package;
1033 package = razor_set_get_package(set, name);
1034 r = (unsigned long *) set->requires_pool.data +
1036 requires = set->requires.data;
1037 pool = set->string_pool.data;
1039 p = &requires[*r++];
1040 printf("%s %s\n", &pool[p->name], &pool[p->version]);
1043 razor_set_list_all_properties(set, &set->requires);
1047 razor_set_list_provides(struct razor_set *set, const char *name)
1049 struct razor_property *p, *provides;
1050 struct razor_package *package;
1055 package = razor_set_get_package(set, name);
1056 r = (unsigned long *) set->provides_pool.data +
1058 provides = set->provides.data;
1059 pool = set->string_pool.data;
1061 p = &provides[*r++];
1062 printf("%s %s\n", &pool[p->name], &pool[p->version]);
1065 razor_set_list_all_properties(set, &set->provides);
1069 razor_set_list_property_packages(struct razor_set *set,
1070 struct array *properties,
1072 const char *version)
1074 struct razor_property *property, *end;
1075 struct razor_package *p, *packages;
1082 property = razor_set_get_property(set, properties, name);
1083 packages = set->packages.data;
1084 pool = set->string_pool.data;
1085 end = properties->data + properties->size;
1086 while (property < end && strcmp(name, &pool[property->name]) == 0) {
1087 if (version && versioncmp(version, &pool[property->version]) != 0)
1089 r = (unsigned long *)
1090 set->package_pool.data + property->packages;
1092 p = &packages[*r++];
1094 &pool[p->name], &pool[p->version]);
1102 razor_set_list_requires_packages(struct razor_set *set,
1104 const char *version)
1106 razor_set_list_property_packages(set, &set->requires, name, version);
1110 razor_set_list_provides_packages(struct razor_set *set,
1112 const char *version)
1114 razor_set_list_property_packages(set, &set->provides, name, version);
1118 razor_set_validate(struct razor_set *set, struct array *unsatisfied)
1120 struct razor_property *r, *p, *rend, *pend;
1124 p = set->provides.data;
1125 rend = set->requires.data + set->requires.size;
1126 pend = set->provides.data + set->provides.size;
1127 pool = set->string_pool.data;
1129 for (r = set->requires.data; r < rend; r++) {
1130 while (p < pend && strcmp(&pool[r->name], &pool[p->name]) > 0)
1133 /* If there is more than one version of a provides,
1134 * seek to the end for the highest version. */
1135 while (p + 1 < pend && p->name == (p + 1)->name)
1138 /* FIXME: We need to track property flags (<, <=, =
1139 * etc) to properly determine if a requires is
1140 * satisfied. The current code doesn't track that the
1141 * requires a = 1 isn't satisfied by a = 2 provides. */
1143 if (p == pend || strcmp(&pool[r->name], &pool[p->name]) != 0 ||
1144 versioncmp(&pool[r->version], &pool[p->version]) > 0) {
1145 /* FIXME: We ignore file requires for now. */
1146 if (pool[r->name] == '/')
1148 u = array_add(unsatisfied, sizeof *u);
1149 *u = r - (struct razor_property *) set->requires.data;
1155 razor_set_list_unsatisfied(struct razor_set *set)
1157 struct array unsatisfied;
1158 struct razor_property *requires, *r;
1159 unsigned long *u, *end;
1162 array_init(&unsatisfied);
1163 razor_set_validate(set, &unsatisfied);
1165 end = unsatisfied.data + unsatisfied.size;
1166 requires = set->requires.data;
1167 pool = set->string_pool.data;
1169 for (u = unsatisfied.data; u < end; u++) {
1171 printf("%s %s not satisfied\n",
1172 &pool[r->name], &pool[r->version]);
1175 array_release(&unsatisfied);
1178 #define UPSTREAM_SOURCE 0x80000000ul
1179 #define INDEX_MASK 0x00fffffful
1182 struct razor_set *set;
1183 unsigned long *requires_map;
1184 unsigned long *provides_map;
1188 prepare_source(struct source *source, struct razor_set *set)
1195 count = set->requires.size / sizeof (struct razor_property);
1196 size = count * sizeof *source->requires_map;
1197 source->requires_map = zalloc(size);
1199 count = set->provides.size / sizeof (struct razor_property);
1200 size = count * sizeof *source->provides_map;
1201 source->provides_map = zalloc(size);
1205 add_package(struct razor_importer *importer,
1206 struct razor_package *package, struct source *source,
1207 unsigned long flags)
1211 struct razor_package *p;
1213 pool = source->set->string_pool.data;
1214 p = array_add(&importer->set->packages, sizeof *p);
1215 p->name = razor_importer_tokenize(importer, &pool[package->name]);
1217 p->version = razor_importer_tokenize(importer,
1218 &pool[package->version]);
1219 p->requires = package->requires;
1220 p->provides = package->provides;
1222 r = (unsigned long *)
1223 source->set->requires_pool.data + package->requires;
1225 source->requires_map[*r++] = 1;
1227 r = (unsigned long *)
1228 source->set->provides_pool.data + package->provides;
1230 source->provides_map[*r++] = 1;
1234 /* Build the new package list sorted by merging the two package lists.
1235 * Build new string pool as we go. (for now we just re-use that part of
1238 merge_packages(struct razor_importer *importer,
1239 struct source *source1, struct source *source2,
1240 struct array *packages)
1242 struct razor_package *upstream_packages, *p, *s, *send;
1243 char *spool, *upool;
1244 unsigned long *u, *uend;
1247 upstream_packages = source2->set->packages.data;
1250 uend = packages->data + packages->size;
1251 upool = source2->set->string_pool.data;
1253 s = source1->set->packages.data;
1254 send = source1->set->packages.data + source1->set->packages.size;
1255 spool = source1->set->string_pool.data;
1258 p = upstream_packages + *u;
1261 cmp = strcmp(&spool[s->name], &upool[p->name]);
1262 if (u >= uend || cmp < 0) {
1263 add_package(importer, s, source1, 0);
1265 } else if (cmp == 0) {
1266 add_package(importer, p, source2, UPSTREAM_SOURCE);
1270 add_package(importer, p, source2, UPSTREAM_SOURCE);
1276 static unsigned long
1277 add_property(struct razor_importer *importer, struct array *properties,
1278 const char *name, const char *version)
1280 struct razor_property *p;
1282 p = array_add(properties, sizeof *p);
1283 p->name = razor_importer_tokenize(importer, name);
1284 p->version = razor_importer_tokenize(importer, version);
1286 return p - (struct razor_property *) properties->data;
1290 merge_properties(struct array *properties,
1291 struct razor_importer *importer,
1292 struct razor_set *set1,
1293 struct array *properties1,
1294 unsigned long *map1,
1295 struct razor_set *set2,
1296 struct array *properties2,
1297 unsigned long *map2)
1299 struct razor_property *p1, *p2;
1300 int i, j, cmp, count1, count2;
1301 char *pool1, *pool2;
1305 pool1 = set1->string_pool.data;
1306 pool2 = set2->string_pool.data;
1308 count1 = properties1->size / sizeof *p1;
1309 count2 = properties2->size / sizeof *p2;
1310 while (i < count1 || j < count2) {
1311 if (i < count1 && map1[i] == 0) {
1315 if (j < count2 && map2[j] == 0) {
1319 p1 = (struct razor_property *) properties1->data + i;
1320 p2 = (struct razor_property *) properties2->data + j;
1321 if (i < count1 && j < count2)
1322 cmp = strcmp(&pool1[p1->name], &pool2[p2->name]);
1323 else if (i < count1)
1328 cmp = versioncmp(&pool1[p1->version],
1329 &pool2[p2->version]);
1331 map1[i++] = add_property(importer,
1334 &pool1[p1->version]);
1335 } else if (cmp > 0) {
1336 map2[j++] = add_property(importer,
1339 &pool2[p2->version]);
1341 map1[i++] = map2[j++] = add_property(importer,
1344 &pool1[p1->version]);
1349 static unsigned long
1350 emit_properties(struct array *source_pool, unsigned long index,
1351 unsigned long *map, struct array *pool)
1353 unsigned long r, *p, *q;
1355 r = pool->size / sizeof *q;
1356 p = (unsigned long *) source_pool->data + index;
1358 q = array_add(pool, sizeof *q);
1362 q = array_add(pool, sizeof *q);
1368 /* Rebuild property->packages maps. We can't just remap these, as a
1369 * property may have lost or gained a number of packages. Allocate an
1370 * array per property and loop through the packages and add them to
1371 * the arrays for their properties. */
1373 rebuild_package_lists(struct razor_set *set)
1375 int requires_count, provides_count;
1376 struct array *requires_pkgs, *provides_pkgs, *a;
1377 struct razor_package *pkg, *pkg_end;
1378 struct razor_property *prop, *prop_end;
1379 unsigned long *r, *q, *rpool, *ppool;
1381 requires_count = set->requires.size / sizeof (struct razor_property);
1382 provides_count = set->provides.size / sizeof (struct razor_property);
1383 requires_pkgs = zalloc(requires_count * sizeof *requires_pkgs);
1384 provides_pkgs = zalloc(provides_count * sizeof *provides_pkgs);
1385 pkg_end = set->packages.data + set->packages.size;
1386 rpool = set->requires_pool.data;
1387 ppool = set->provides_pool.data;
1389 for (pkg = set->packages.data; pkg < pkg_end; pkg++) {
1390 for (r = &rpool[pkg->requires]; *r != ~0; r++) {
1391 q = array_add(&requires_pkgs[*r], sizeof *q);
1392 *q = pkg - (struct razor_package *) set->packages.data;
1394 for (r = &ppool[pkg->provides]; *r != ~0; r++) {
1395 q = array_add(&provides_pkgs[*r], sizeof *q);
1396 *q = pkg - (struct razor_package *) set->packages.data;
1400 prop_end = set->requires.data + set->requires.size;
1402 for (prop = set->requires.data; prop < prop_end; prop++, a++) {
1403 prop->packages = add_to_property_pool(&set->requires_pool, a);
1406 free(requires_pkgs);
1408 prop_end = set->provides.data + set->provides.size;
1410 for (prop = set->provides.data; prop < prop_end; prop++, a++) {
1411 prop->packages = add_to_property_pool(&set->provides_pool, a);
1414 free(provides_pkgs);
1417 /* Add packages from 'upstream' to 'set'. The packages to add are
1418 * specified by the 'packages' array, which is a sorted list of
1419 * package indexes. Returns a newly allocated package set. Does not
1420 * enforce validity of the resulting package set.
1422 * This looks more complicated than it is. An easy way to merge two
1423 * package sets would be to just use a razor_importer, but that
1424 * requires resorting, and is thus O(n log n). We can do this in a
1425 * linear sweep, but it gets a little more complicated.
1428 razor_set_add(struct razor_set *set, struct razor_set *upstream,
1429 struct array *packages)
1431 struct razor_set *result;
1432 struct razor_importer *importer;
1433 struct razor_package *p, *pend;
1434 struct source source, upstream_source;
1436 importer = razor_importer_new();
1438 prepare_source(&upstream_source, upstream);
1439 prepare_source(&source, set);
1441 merge_packages(importer, &source, &upstream_source, packages);
1443 /* As we built the package list, we filled out a bitvector of
1444 * the properties that are referenced by the packages in the
1445 * new set. Now we do a parallel loop through the properties
1446 * and emit those marked in the bit vector to the new set. In
1447 * the process, we update the bit vector to actually map from
1448 * indices in the old property list to indices in the new
1449 * property list for both sets. */
1451 merge_properties(&importer->set->requires, importer,
1452 set, &set->requires, source.requires_map,
1453 upstream, &upstream->requires,
1454 upstream_source.requires_map);
1455 merge_properties(&importer->set->provides, importer,
1456 set, &set->provides, source.provides_map,
1457 upstream, &upstream->provides,
1458 upstream_source.provides_map);
1460 /* Now we loop through the packages again and emit the
1461 * property lists, remapped to point to the new properties. */
1463 pend = importer->set->packages.data + importer->set->packages.size;
1464 for (p = importer->set->packages.data; p < pend; p++) {
1467 if (p->name & UPSTREAM_SOURCE)
1468 src = &upstream_source;
1472 p->requires = emit_properties(&src->set->requires_pool,
1475 &importer->set->requires_pool);
1476 p->provides = emit_properties(&src->set->provides_pool,
1479 &importer->set->provides_pool);
1480 p->name &= INDEX_MASK;
1483 rebuild_package_lists(importer->set);
1485 result = importer->set;
1486 array_release(&importer->buckets);
1493 razor_set_satisfy(struct razor_set *set, struct array *unsatisfied,
1494 struct razor_set *upstream, struct array *list)
1496 struct razor_property *requires, *r;
1497 struct razor_property *p, *pend;
1498 unsigned long *u, *end, *pkg, *package_pool;
1501 end = unsatisfied->data + unsatisfied->size;
1502 requires = set->requires.data;
1503 pool = set->string_pool.data;
1505 p = upstream->provides.data;
1506 pend = upstream->provides.data + upstream->provides.size;
1507 upool = upstream->string_pool.data;
1508 package_pool = upstream->package_pool.data;
1510 for (u = unsatisfied->data; u < end; u++) {
1513 while (p < pend && strcmp(&pool[r->name], &upool[p->name]) > 0)
1515 /* If there is more than one version of a provides,
1516 * seek to the end for the highest version. */
1517 while (p + 1 < pend && p->name == (p + 1)->name)
1521 strcmp(&pool[r->name], &upool[p->name]) != 0 ||
1522 versioncmp(&pool[r->version], &upool[p->version]) > 0) {
1523 /* Do we need to track unsatisfiable requires
1524 * as we go, or should we just do a
1525 * razor_set_validate() at the end? */
1527 pkg = array_add(list, sizeof *pkg);
1528 /* We just pull in the first package that provides */
1529 *pkg = package_pool[p->packages];
1535 find_packages(struct razor_set *set,
1536 int count, const char **packages, struct array *list)
1538 struct razor_package *p;
1542 /* FIXME: Sort the packages. */
1543 for (i = 0; i < count; i++) {
1544 p = razor_set_get_package(set, packages[i]);
1545 r = array_add(list, sizeof *r);
1546 *r = p - (struct razor_package *) set->packages.data;
1551 find_all_packages(struct razor_set *set,
1552 struct razor_set *upstream, struct array *list)
1554 struct razor_package *p, *u, *pend, *uend;
1558 pend = set->packages.data + set->packages.size;
1559 pool = set->string_pool.data;
1560 u = upstream->packages.data;
1561 uend = upstream->packages.data + upstream->packages.size;
1562 upool = upstream->string_pool.data;
1564 for (p = set->packages.data; p < pend; p++) {
1565 while (u < uend && strcmp(&pool[p->name], &upool[u->name]) > 0)
1567 if (strcmp(&pool[p->name], &upool[u->name]) == 0) {
1568 r = array_add(list, sizeof *r);
1569 *r = u - (struct razor_package *) upstream->packages.data;
1575 razor_set_update(struct razor_set *set, struct razor_set *upstream,
1576 int count, const char **packages)
1578 struct razor_set *new;
1579 struct razor_package *upackages;
1580 struct array list, unsatisfied;
1582 unsigned long *u, *end;
1587 find_packages(upstream, count, packages, &list);
1589 find_all_packages(set, upstream, &list);
1591 end = list.data + list.size;
1592 upackages = upstream->packages.data;
1593 pool = upstream->string_pool.data;
1594 total += list.size / sizeof *u;
1596 while (list.size > 0) {
1597 new = razor_set_add(set, upstream, &list);
1598 array_release(&list);
1599 razor_set_destroy(set);
1602 array_init(&unsatisfied);
1603 razor_set_validate(new, &unsatisfied);
1605 razor_set_satisfy(new, &unsatisfied, upstream, &list);
1606 array_release(&unsatisfied);
1608 end = list.data + list.size;
1609 upackages = upstream->packages.data;
1610 pool = upstream->string_pool.data;
1611 total += list.size / sizeof *u;
1614 array_release(&list);
1619 /* The diff order matters. We should sort the packages so that a
1620 * REMOVE of a package comes before the INSTALL, and so that all
1621 * requires for a package have been installed before the package.
1625 razor_set_diff(struct razor_set *set, struct razor_set *upstream,
1626 razor_package_callback_t callback, void *data)
1628 struct razor_package *p, *pend, *u, *uend;
1629 char *ppool, *upool;
1632 p = set->packages.data;
1633 pend = set->packages.data + set->packages.size;
1634 ppool = set->string_pool.data;
1636 u = upstream->packages.data;
1637 uend = upstream->packages.data + upstream->packages.size;
1638 upool = upstream->string_pool.data;
1640 while (p < pend || u < uend) {
1641 if (p < pend && u < uend) {
1642 res = strcmp(&ppool[p->name], &upool[u->name]);
1644 res = versioncmp(&ppool[p->version],
1645 &upool[u->version]);
1648 if (u == uend || res < 0) {
1649 callback(&ppool[p->name], &ppool[p->version],
1653 } else if (p == pend || res > 0) {
1654 callback(&upool[u->name], NULL, &upool[u->version],