razor.c
author Kristian H?gsberg <krh@redhat.com>
Mon Oct 22 22:53:55 2007 -0400 (2007-10-22)
changeset 52 8cb4c45dc86f
parent 49 c66fd9a1eabe
child 54 9e3907688d78
permissions -rw-r--r--
Track file owner ship.
     1 #define _GNU_SOURCE
     2 
     3 #include <stdlib.h>
     4 #include <stddef.h>
     5 #include <stdio.h>
     6 #include <string.h>
     7 #include <sys/types.h>
     8 #include <sys/stat.h>
     9 #include <sys/mman.h>
    10 #include <unistd.h>
    11 #include <fcntl.h>
    12 #include <errno.h>
    13 #include <ctype.h>
    14 
    15 #include "razor.h"
    16 
    17 struct array {
    18 	void *data;
    19 	int size, alloc;
    20 };
    21 
    22 struct razor_set_section {
    23 	unsigned int type;
    24 	unsigned int offset;
    25 	unsigned int size;
    26 };
    27 
    28 struct razor_set_header {
    29 	unsigned int magic;
    30 	unsigned int version;
    31 	struct razor_set_section sections[0];
    32 };
    33 
    34 #define RAZOR_MAGIC 0x7a7a7a7a
    35 #define RAZOR_VERSION 1
    36 
    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
    45 
    46 struct razor_package {
    47 	unsigned long name;
    48 	unsigned long version;
    49 	unsigned long requires;
    50 	unsigned long provides;
    51 };
    52 
    53 struct razor_property {
    54 	unsigned long name;
    55 	unsigned long version;
    56 	unsigned long packages;
    57 };
    58 
    59 struct razor_entry {
    60 	unsigned long name;
    61 	unsigned long count;
    62 	unsigned long start;
    63 	unsigned long packages;
    64 };
    65 
    66 struct razor_set {
    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;
    76 };
    77 
    78 struct import_entry {
    79 	unsigned long package;
    80 	char *name;
    81 };
    82 
    83 struct import_directory {
    84 	unsigned long name, count;
    85 	struct array files;
    86 	struct array packages;
    87 	struct import_directory *last;
    88 };
    89 
    90 struct import_property_context {
    91 	struct array *all;
    92 	struct array package;
    93 };
    94 
    95 struct razor_importer {
    96 	struct razor_set *set;
    97 	struct array buckets;
    98 	struct import_property_context requires;
    99 	struct import_property_context provides;
   100 	struct razor_package *package;
   101 	struct array files;
   102 };
   103 
   104 static void
   105 array_init(struct array *array)
   106 {
   107 	memset(array, 0, sizeof *array);
   108 }
   109 
   110 static void
   111 array_release(struct array *array)
   112 {
   113 	free(array->data);
   114 }
   115 
   116 static void *
   117 array_add(struct array *array, int size)
   118 {
   119 	int alloc;
   120 	void *data, *p;
   121 
   122 	if (array->alloc > 0)
   123 		alloc = array->alloc;
   124 	else
   125 		alloc = 16;
   126 
   127 	while (alloc < array->size + size)
   128 		alloc *= 2;
   129 
   130 	if (array->alloc < alloc) {
   131 		data = realloc(array->data, alloc);
   132 		if (data == NULL)
   133 			return 0;
   134 		array->data = data;
   135 		array->alloc = alloc;
   136 	}
   137 
   138 	p = array->data + array->size;
   139 	array->size += size;
   140 
   141 	return p;
   142 }
   143 
   144 static int
   145 write_to_fd(int fd, void *p, size_t size)
   146 {
   147 	int rest, len;
   148 
   149 	rest = size;
   150 	while (rest > 0) {
   151 		len = write(fd, p, rest);
   152 		if (len < 0)
   153 			return -1;
   154 		rest -= len;
   155 	}
   156 
   157 	return 0;
   158 }
   159 
   160 static void *
   161 zalloc(size_t size)
   162 {
   163 	void *p;
   164 
   165 	p = malloc(size);
   166 	memset(p, 0, size);
   167 
   168 	return p;
   169 }
   170 
   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) },
   180 };
   181 
   182 struct razor_set *
   183 razor_set_create(void)
   184 {
   185 	return zalloc(sizeof(struct razor_set));
   186 }
   187 
   188 struct razor_set *
   189 razor_set_open(const char *filename)
   190 {
   191 	struct razor_set *set;
   192 	struct razor_set_section *s;
   193 	struct stat stat;
   194 	struct array *array;
   195 	int fd;
   196 
   197 	set = zalloc(sizeof *set);
   198 	fd = open(filename, O_RDONLY);
   199 	if (fstat(fd, &stat) < 0)
   200 		return NULL;
   201 	set->header = mmap(NULL, stat.st_size, PROT_READ, MAP_PRIVATE, fd, 0);
   202 	if (set->header == MAP_FAILED) {
   203 		free(set);
   204 		return NULL;
   205 	}
   206 
   207 	for (s = set->header->sections; ~s->type; s++) {
   208 		if (s->type >= ARRAY_SIZE(razor_sections))
   209 			continue;
   210 		if (s->type != razor_sections[s->type].type)
   211 			continue;
   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;
   216 	}
   217 	close(fd);
   218 
   219 	return set;
   220 }
   221 
   222 void
   223 razor_set_destroy(struct razor_set *set)
   224 {
   225 	unsigned int size;
   226 	struct array *a;
   227 	int i;
   228 
   229 	if (set->header) {
   230 		for (i = 0; set->header->sections[i].type; i++)
   231 			;
   232 		size = set->header->sections[i].type;
   233 		munmap(set->header, size);
   234 	} else {
   235 		for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
   236 			a = (void *) set + razor_sections[i].offset;
   237 			free(a->data);
   238 		}
   239 	}
   240 
   241 	free(set);
   242 }
   243 
   244 int
   245 razor_set_write(struct razor_set *set, const char *filename)
   246 {
   247 	char data[4096];
   248 	struct razor_set_header *header = (struct razor_set_header *) data;
   249 	struct array *a;
   250 	unsigned long offset;
   251 	int i, fd;
   252 
   253 	memset(data, 0, sizeof data);
   254 	header->magic = RAZOR_MAGIC;
   255 	header->version = RAZOR_VERSION;
   256 	offset = sizeof data;
   257 
   258 	for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
   259 		if (razor_sections[i].type != i)
   260 			continue;
   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;
   266 	}
   267 
   268 	header->sections[i].type = ~0;
   269 	header->sections[i].offset = 0;
   270 	header->sections[i].size = 0;
   271 
   272 	fd = open(filename, O_CREAT | O_WRONLY | O_TRUNC, 0666);
   273 	if (fd < 0)
   274 		return -1;
   275 
   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)
   279 			continue;
   280 		a = (void *) set + razor_sections[i].offset;
   281 		write_to_fd(fd, a->data, (a->size + 4095) & ~4095);
   282 	}
   283 
   284 	close(fd);
   285 
   286 	return 0;
   287 }
   288 
   289 static unsigned int
   290 hash_string(const char *key)
   291 {
   292 	const char *p;
   293 	unsigned int hash = 0;
   294 
   295 	for (p = key; *p; p++)
   296 		hash = (hash * 617) ^ *p;
   297 
   298 	return hash;
   299 }
   300 
   301 static unsigned long
   302 razor_importer_lookup(struct razor_importer *importer, const char *key)
   303 {
   304 	unsigned int mask, start, i;
   305 	unsigned long *b;
   306 	char *pool;
   307 
   308 	pool = importer->set->string_pool.data;
   309 	mask = importer->buckets.alloc - 1;
   310 	start = hash_string(key) * sizeof(unsigned long);
   311 
   312 	for (i = 0; i < importer->buckets.alloc; i += sizeof *b) {
   313 		b = importer->buckets.data + ((start + i) & mask);
   314 
   315 		if (*b == 0)
   316 			return 0;
   317 
   318 		if (strcmp(key, &pool[*b]) == 0)
   319 			return *b;
   320 	}
   321 
   322 	return 0;
   323 }
   324 
   325 static unsigned long
   326 add_to_string_pool(struct razor_set *set, const char *key)
   327 {
   328 	int len;
   329 	char *p;
   330 
   331 	len = strlen(key) + 1;
   332 	p = array_add(&set->string_pool, len);
   333 	memcpy(p, key, len);
   334 
   335 	return p - (char *) set->string_pool.data;
   336 }
   337 
   338 static unsigned long
   339 add_to_property_pool(struct array *pool, struct array *properties)
   340 {
   341 	unsigned long  *p;
   342 
   343 	p = array_add(properties, sizeof *p);
   344 	*p = ~0ul;
   345 	p = array_add(pool, properties->size);
   346 	memcpy(p, properties->data, properties->size);
   347 
   348 	return p - (unsigned long *) pool->data;
   349 }
   350 
   351 static void
   352 do_insert(struct razor_importer *importer, unsigned long value)
   353 {
   354 	unsigned int mask, start, i;
   355 	unsigned long *b;
   356 	const char *key;
   357 
   358 	key = (char *) importer->set->string_pool.data + value;
   359 	mask = importer->buckets.alloc - 1;
   360 	start = hash_string(key) * sizeof(unsigned long);
   361 
   362 	for (i = 0; i < importer->buckets.alloc; i += sizeof *b) {
   363 		b = importer->buckets.data + ((start + i) & mask);
   364 		if (*b == 0) {
   365 			*b = value;
   366 			break;
   367 		}
   368 	}
   369 }
   370 
   371 static unsigned long
   372 razor_importer_insert(struct razor_importer *importer, const char *key)
   373 {
   374 	unsigned long value, *buckets, *b, *end;
   375 	int alloc;
   376 
   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++) {
   383 			value = *b;
   384 			if (value != 0) {
   385 				*b = 0;
   386 				do_insert(importer, value);
   387 			}
   388 		}
   389 	}
   390 
   391 	value = add_to_string_pool(importer->set, key);
   392 	do_insert (importer, value);
   393 
   394 	return value;
   395 }
   396 
   397 static unsigned long
   398 razor_importer_tokenize(struct razor_importer *importer, const char *string)
   399 {
   400 	unsigned long token;
   401 
   402 	if (string == NULL)
   403 		return razor_importer_tokenize(importer, "");
   404 
   405 	token = razor_importer_lookup(importer, string);
   406 	if (token != 0)
   407 		return token;
   408 
   409 	return razor_importer_insert(importer, string);
   410 }
   411 
   412 void
   413 razor_importer_begin_package(struct razor_importer *importer,
   414 			     const char *name, const char *version)
   415 {
   416 	struct razor_package *p;
   417 
   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);
   421 
   422 	importer->package = p;
   423 	array_init(&importer->requires.package);
   424 	array_init(&importer->provides.package);
   425 }
   426 
   427 void
   428 razor_importer_finish_package(struct razor_importer *importer)
   429 {
   430 	struct razor_package *p;
   431 
   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);
   437 
   438 	array_release(&importer->requires.package);
   439 	array_release(&importer->provides.package);
   440 }
   441 
   442 static void
   443 razor_importer_add_property(struct razor_importer *importer,
   444 			    struct import_property_context *pctx,
   445 			    const char *name, const char *version)
   446 {
   447 	struct razor_property *p;
   448 	unsigned long *r;
   449 
   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;
   455 
   456 	r = array_add(&pctx->package, sizeof *r);
   457 	*r = p - (struct razor_property *) pctx->all->data;
   458 }
   459 
   460 void
   461 razor_importer_add_requires(struct razor_importer *importer,
   462 			    const char *name, const char *version)
   463 {
   464 	razor_importer_add_property(importer,
   465 				    &importer->requires, name, version);
   466 }
   467 
   468 void
   469 razor_importer_add_provides(struct razor_importer *importer,
   470 			    const char *name, const char *version)
   471 {
   472 	razor_importer_add_property(importer,
   473 				    &importer->provides, name, version);
   474 }
   475 
   476 void
   477 razor_importer_add_file(struct razor_importer *importer, const char *name)
   478 {
   479 	struct import_entry *e;
   480 
   481 	e = array_add(&importer->files, sizeof *e);
   482 
   483 	e->package = importer->package -
   484 		(struct razor_package *) importer->set->packages.data;
   485 	e->name = strdup(name);
   486 }
   487 
   488 struct razor_importer *
   489 razor_importer_new(void)
   490 {
   491 	struct razor_importer *importer;
   492 
   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;
   497 
   498 	return importer;
   499 }
   500 
   501 typedef int (*compare_with_data_func_t)(const void *p1,
   502 					const void *p,
   503 					void *data);
   504 
   505 struct qsort_context {
   506 	size_t size;
   507 	compare_with_data_func_t compare;
   508 	void *data;
   509 };
   510 
   511 static void
   512 qsort_swap(void *p1, void *p2, size_t size)
   513 {
   514 	char buffer[size];
   515 
   516 	memcpy(buffer, p1, size);
   517 	memcpy(p1, p2, size);
   518 	memcpy(p2, buffer, size);
   519 }
   520 
   521 static void
   522 __qsort_with_data(void *base, size_t nelem, unsigned long *map,
   523 		  struct qsort_context *ctx)
   524 {
   525 	void *p, *start, *end, *pivot;
   526 	unsigned long *mp, *mstart, *mend, tmp;
   527 	int left, right, result;
   528 	size_t size = ctx->size;
   529 
   530 	p = base;
   531 	start = base;
   532 	end = base + nelem * size;
   533 	mp = map;
   534 	mstart = map;
   535 	mend = map + nelem;
   536 	pivot = base + (random() % nelem) * size;
   537 
   538 	while (p < end) {
   539 		result = ctx->compare(p, pivot, ctx->data);
   540 		if (result < 0) {
   541 			qsort_swap(p, start, size);
   542 			tmp = *mp;
   543 			*mp = *mstart;
   544 			*mstart = tmp;
   545 			if (start == pivot)
   546 				pivot = p;
   547 			start += size;
   548 			mstart++;
   549 			p += size;
   550 			mp++;
   551 		} else if (result == 0) {
   552 			p += size;
   553 			mp++;
   554 		} else {
   555  			end -= size;
   556 			mend--;
   557 			qsort_swap(p, end, size);
   558 			tmp = *mp;
   559 			*mp = *mend;
   560 			*mend = tmp;
   561 			if (end == pivot)
   562 				pivot = p;
   563 		}
   564 	}
   565 
   566 	left = (start - base) / size;
   567 	right = (base + nelem * size - end) / size;
   568 	if (left > 1)
   569 		__qsort_with_data(base, left, map, ctx);
   570 	if (right > 1)
   571 		__qsort_with_data(end, right, mend, ctx);
   572 }
   573 
   574 unsigned long *
   575 qsort_with_data(void *base, size_t nelem, size_t size,
   576 		compare_with_data_func_t compare, void *data)
   577 {
   578 	struct qsort_context ctx;
   579 	unsigned long *map;
   580 	int i;
   581 
   582 	ctx.size = size;
   583 	ctx.compare = compare;
   584 	ctx.data = data;
   585 
   586 	map = malloc(nelem * sizeof (unsigned long));
   587 	for (i = 0; i < nelem; i++)
   588 		map[i] = i;
   589 
   590 	__qsort_with_data(base, nelem, map, &ctx);
   591 
   592 	return map;
   593 }
   594 
   595 static int
   596 versioncmp(const char *s1, const char *s2)
   597 {
   598 	const char *p1, *p2;
   599 	long n1, n2;
   600 	int res;
   601 
   602 	n1 = strtol(s1, (char **) &p1, 0);
   603 	n2 = strtol(s2, (char **) &p2, 0);
   604 
   605 	/* Epoch; if one but not the other has an epoch set, default
   606 	 * the epoch-less version to 0. */
   607 	res = (*p1 == ':') - (*p2 == ':');
   608 	if (res < 0) {
   609 		n1 = 0;
   610 		p1 = s1;
   611 		p2++;
   612 	} else if (res > 0) {
   613 		p1++;
   614 		n2 = 0;
   615 		p2 = s2;
   616 	}
   617 
   618 	if (n1 != n2)
   619 		return n1 - n2;
   620 	while (*p1 && *p2) {
   621 		if (*p1 != *p2)
   622 			return *p1 - *p2;
   623 		p1++;
   624 		p2++;
   625 		if (isdigit(*p1) && isdigit(*p2))
   626 			return versioncmp(p1, p2);
   627 	}
   628 
   629 	return *p1 - *p2;
   630 }
   631 
   632 
   633 static int
   634 compare_packages(const void *p1, const void *p2, void *data)
   635 {
   636 	const struct razor_package *pkg1 = p1, *pkg2 = p2;
   637 	struct razor_set *set = data;
   638 	char *pool = set->string_pool.data;
   639 
   640 	if (pkg1->name == pkg2->name)
   641 		return versioncmp(&pool[pkg1->version], &pool[pkg2->version]);
   642 	else
   643 		return strcmp(&pool[pkg1->name], &pool[pkg2->name]);
   644 }
   645 
   646 static int
   647 compare_properties(const void *p1, const void *p2, void *data)
   648 {
   649 	const struct razor_property *prop1 = p1, *prop2 = p2;
   650 	struct razor_set *set = data;
   651 	char *pool = set->string_pool.data;
   652 
   653 	if (prop1->name == prop2->name)
   654 		return versioncmp(&pool[prop1->version], &pool[prop2->version]);
   655 	else
   656 		return strcmp(&pool[prop1->name], &pool[prop2->name]);
   657 }
   658 
   659 static unsigned long *
   660 uniqueify_properties(struct razor_set *set, struct array *properties)
   661 {
   662 	struct razor_property *rp, *up, *rp_end;
   663 	struct array *pkgs, *p;
   664 	unsigned long *map, *rmap, *r;
   665 	int i, count, unique;
   666 
   667 	count = properties->size / sizeof(struct razor_property);
   668 	map = qsort_with_data(properties->data,
   669 			      count,
   670 			      sizeof(struct razor_property),
   671 			      compare_properties,
   672 			      set);
   673 
   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) {
   679 			up++;
   680 			up->name = rp->name;
   681 			up->version = rp->version;
   682 		}
   683 
   684 		unique = up - (struct razor_property *) properties->data;
   685 		rmap[map[i]] = unique;
   686 		r = array_add(&pkgs[unique], sizeof *r);
   687 		*r = rp->packages;
   688 	}
   689 	free(map);
   690 
   691 	up++;
   692 	properties->size = (void *) up - properties->data;
   693 	rp_end = up;
   694 	for (rp = properties->data, p = pkgs; rp < rp_end; rp++, p++) {
   695 		rp->packages = add_to_property_pool(&set->package_pool, p);
   696 		array_release(p);
   697 	}
   698 
   699 	free(pkgs);
   700 
   701 	return rmap;
   702 }
   703 
   704 static void
   705 remap_links(struct array *links, unsigned long *map)
   706 {
   707 	unsigned long *p, *end;
   708 
   709 	end = links->data + links->size;
   710 	for (p = links->data; p < end; p++)
   711 		if (*p != ~0)
   712 			*p = map[*p];
   713 }
   714 
   715 static int
   716 compare_filenames(const void *p1, const void *p2, void *data)
   717 {
   718 	const struct import_entry *e1 = p1;
   719 	const struct import_entry *e2 = p2;
   720 
   721 	return strcmp(e1->name, e2->name);
   722 }
   723 
   724 static void
   725 count_entries(struct import_directory *d)
   726 {
   727 	struct import_directory *p, *end;
   728 
   729 	p = d->files.data;
   730 	end = d->files.data + d->files.size;
   731 	d->count = 0;
   732 	while (p < end) {
   733 		count_entries(p);
   734 		d->count += p->count + 1;
   735 		p++;
   736 	}		
   737 }
   738 
   739 static void
   740 serialize_files(struct razor_set *set,
   741 		struct import_directory *d, struct array *array)
   742 {
   743 	struct import_directory *p, *end;
   744 	struct razor_entry *e;
   745 	unsigned long s;
   746 
   747 	p = d->files.data;
   748 	end = d->files.data + d->files.size;
   749 	s = array->size / sizeof *e + d->files.size / sizeof *p;
   750 	while (p < end) {
   751 		e = array_add(array, sizeof *e);
   752 		e->name = p->name;
   753 		e->count = p->files.size / sizeof *p;
   754 		e->start = s;
   755 		s += p->count;
   756 		e->packages = add_to_property_pool(&set->package_pool,
   757 						   &p->packages);
   758 		array_release(&p->packages);
   759 		p++;
   760 	}		
   761 
   762 	p = d->files.data;
   763 	end = d->files.data + d->files.size;
   764 	while (p < end) {
   765 		serialize_files(set, p, array);
   766 		p++;
   767 	}
   768 }
   769 
   770 static void
   771 build_file_tree(struct razor_importer *importer)
   772 {
   773 	int count, i, length;
   774 	struct import_entry *filenames;
   775 	char *f, *end;
   776 	unsigned long name, *r;
   777 	char dirname[256];
   778 	struct import_directory *d, root;
   779 	struct razor_entry *e;
   780 
   781 	count = importer->files.size / sizeof (struct import_entry);
   782 	qsort_with_data(importer->files.data,
   783 			count,
   784 			sizeof (struct import_entry),
   785 			compare_filenames,
   786 			NULL);
   787 
   788 	root.name = razor_importer_tokenize(importer, "");
   789 	array_init(&root.files);
   790 	array_init(&root.packages);
   791 	root.last = NULL;
   792 
   793 	filenames = importer->files.data;
   794 	for (i = 0; i < count; i++) {
   795 		f = filenames[i].name;
   796 		if (*f != '/')
   797 			continue;
   798 
   799 		d = &root;
   800 		while (*f) {
   801 			end = strchr(f + 1, '/');
   802 			if (end == NULL)
   803 				end = f + strlen(f);
   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);
   814 			}
   815 			d = d->last;				
   816 			f = end;
   817 		}
   818 
   819 		r = array_add(&d->packages, sizeof *r);
   820 		*r = filenames[i].package;
   821 		free(filenames[i].name);
   822 	}
   823 
   824 	count_entries(&root);
   825 	array_init(&importer->set->file_tree);
   826 
   827 	e = array_add(&importer->set->file_tree, sizeof *e);
   828 	e->name = root.name;
   829 	e->count = root.files.size / sizeof *d;
   830 	e->start = 1;
   831 
   832 	serialize_files(importer->set, &root, &importer->set->file_tree);
   833 
   834 	array_release(&importer->files);
   835 }
   836 
   837 static struct razor_entry *
   838 find_entry(struct razor_set *set, struct razor_entry *dir, const char *name)
   839 {
   840 	struct razor_entry *e, *end;
   841 	char *pool = set->string_pool.data;
   842 	char *p, *n;
   843 
   844 	if (name == NULL)
   845 		return dir;
   846 
   847 	p = strchr(name + 1, '/');
   848 	e = (struct razor_entry *) set->file_tree.data + dir->start;
   849 	end = e + dir->count;
   850 
   851 	while (e < end) {
   852 		n = pool + e->name;
   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);
   856 		e++;
   857 	}
   858 
   859 	return NULL;
   860 }
   861 
   862 static void
   863 list_dir(struct razor_set *set, struct razor_entry *e, int indent)
   864 {
   865 	struct razor_entry *c;
   866 	char *pool = set->string_pool.data;
   867 	int i;
   868 
   869 	for (i = 0; i < indent; i++)
   870 		putchar(' ');
   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);
   875 	}
   876 }
   877 
   878 void
   879 razor_set_list_files(struct razor_set *set, const char *prefix)
   880 {
   881 	struct razor_entry *e;
   882 
   883 	e = find_entry(set, set->file_tree.data, prefix);
   884 	if (e == NULL)
   885 		return;
   886 	list_dir(set, e, 2);
   887 }
   888 
   889 void
   890 razor_set_list_file_packages(struct razor_set *set, const char *filename)
   891 {
   892 	struct razor_entry *e;
   893 	struct razor_package *packages, *p;
   894 	const char *pool;
   895 	unsigned long *r;
   896 
   897 	e = find_entry(set, set->file_tree.data, filename);
   898 	if (e == NULL)
   899 		return;
   900 	
   901 	r = (unsigned long *) set->package_pool.data + e->packages;
   902 	packages = set->packages.data;
   903 	pool = set->string_pool.data;
   904 	while (~*r) {
   905 		p = &packages[*r++];
   906 		printf("%s %s\n", &pool[p->name], &pool[p->version]);
   907 	}
   908 }
   909 
   910 struct razor_set *
   911 razor_importer_finish(struct razor_importer *importer)
   912 {
   913 	struct razor_set *set;
   914 	unsigned long *map, *rmap;
   915 	int i, count;
   916 
   917 	map = uniqueify_properties(importer->set, &importer->set->requires);
   918 	remap_links(&importer->set->requires_pool, map);
   919 	free(map);
   920 
   921 	map = uniqueify_properties(importer->set, &importer->set->provides);
   922 	remap_links(&importer->set->provides_pool, map);
   923 	free(map);
   924 
   925 	count = importer->set->packages.size / sizeof(struct razor_package);
   926 	map = qsort_with_data(importer->set->packages.data,
   927 			      count,
   928 			      sizeof(struct razor_package),
   929 			      compare_packages,
   930 			      importer->set);
   931 
   932 	rmap = malloc(count * sizeof *rmap);
   933 	for (i = 0; i < count; i++)
   934 		rmap[map[i]] = i;
   935 	free(map);
   936 
   937 	build_file_tree(importer);
   938 	remap_links(&importer->set->package_pool, rmap);
   939 	free(rmap);
   940 
   941 	set = importer->set;
   942 	array_release(&importer->buckets);
   943 	free(importer);
   944 
   945 	return set;
   946 }
   947 
   948 void
   949 razor_set_list(struct razor_set *set)
   950 {
   951 	struct razor_package *p, *end;
   952 	char *pool;
   953 
   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]);
   958 }
   959 
   960 struct razor_set *bsearch_set;
   961 
   962 static int
   963 compare_package_name(const void *key, const void *data)
   964 {
   965 	const struct razor_package *p = data;
   966 	char *pool;
   967 
   968 	pool = bsearch_set->string_pool.data;
   969 
   970 	return strcmp(key, &pool[p->name]);
   971 }
   972 
   973 struct razor_package *
   974 razor_set_get_package(struct razor_set *set, const char *package)
   975 {
   976 	bsearch_set = set;
   977 	return bsearch(package, set->packages.data,
   978 		       set->packages.size / sizeof(struct razor_package),
   979 		       sizeof(struct razor_package), compare_package_name);
   980 }
   981 
   982 static int
   983 compare_property_name(const void *key, const void *data)
   984 {
   985 	const struct razor_property *p = data;
   986 	char *pool;
   987 
   988 	pool = bsearch_set->string_pool.data;
   989 
   990 	return strcmp(key, &pool[p->name]);
   991 }
   992 
   993 struct razor_property *
   994 razor_set_get_property(struct razor_set *set,
   995 		       struct array *properties,
   996 		       const char *property)
   997 {
   998 	struct razor_property *p, *start;
   999 
  1000 	bsearch_set = set;
  1001 	p = bsearch(property, properties->data,
  1002 		    properties->size / sizeof(struct razor_property),
  1003 		    sizeof(struct razor_property), compare_property_name);
  1004 
  1005 	start = properties->data;
  1006 	while (p > start && (p - 1)->name == p->name)
  1007 		p--;
  1008 
  1009 	return p;
  1010 }
  1011 
  1012 static void
  1013 razor_set_list_all_properties(struct razor_set *set, struct array *properties)
  1014 {
  1015 	struct razor_property *p, *end;
  1016 	char *pool;
  1017 
  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]);
  1022 }
  1023 
  1024 void
  1025 razor_set_list_requires(struct razor_set *set, const char *name)
  1026 {
  1027 	struct razor_property *p, *requires;
  1028 	struct razor_package *package;
  1029 	unsigned long *r;
  1030 	char *pool;
  1031 
  1032 	if (name) {
  1033 		package = razor_set_get_package(set, name);
  1034 		r = (unsigned long *) set->requires_pool.data +
  1035 			package->requires;
  1036 		requires = set->requires.data;
  1037 		pool = set->string_pool.data;
  1038 		while (~*r) {
  1039 			p = &requires[*r++];
  1040 			printf("%s %s\n", &pool[p->name], &pool[p->version]);
  1041 		}
  1042 	} else
  1043 		razor_set_list_all_properties(set, &set->requires);
  1044 }
  1045 
  1046 void
  1047 razor_set_list_provides(struct razor_set *set, const char *name)
  1048 {
  1049 	struct razor_property *p, *provides;
  1050 	struct razor_package *package;
  1051 	unsigned long *r;
  1052 	char *pool;
  1053 
  1054 	if (name) {
  1055 		package = razor_set_get_package(set, name);
  1056 		r = (unsigned long *) set->provides_pool.data +
  1057 			package->provides;
  1058 		provides = set->provides.data;
  1059 		pool = set->string_pool.data;
  1060 		while (~*r) {
  1061 			p = &provides[*r++];
  1062 			printf("%s %s\n", &pool[p->name], &pool[p->version]);
  1063 		}
  1064 	} else 
  1065 		razor_set_list_all_properties(set, &set->provides);
  1066 }
  1067 
  1068 static void
  1069 razor_set_list_property_packages(struct razor_set *set,
  1070 				 struct array *properties,
  1071 				 const char *name,
  1072 				 const char *version)
  1073 {
  1074 	struct razor_property *property, *end;
  1075 	struct razor_package *p, *packages;
  1076 	unsigned long *r;
  1077 	char *pool;
  1078 
  1079 	if (name == NULL)
  1080 		return;
  1081 
  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)
  1088 			goto next;
  1089 		r = (unsigned long *)
  1090 			set->package_pool.data + property->packages;
  1091 		while (~*r) {
  1092 			p = &packages[*r++];
  1093 			printf("%s %s\n",
  1094 			       &pool[p->name], &pool[p->version]);
  1095 		}
  1096 	next:
  1097 		property++;
  1098 	}
  1099 }
  1100 
  1101 void
  1102 razor_set_list_requires_packages(struct razor_set *set,
  1103 				 const char *name,
  1104 				 const char *version)
  1105 {
  1106 	razor_set_list_property_packages(set, &set->requires, name, version);
  1107 }
  1108 
  1109 void
  1110 razor_set_list_provides_packages(struct razor_set *set,
  1111 				 const char *name,
  1112 				 const char *version)
  1113 {
  1114 	razor_set_list_property_packages(set, &set->provides, name, version);
  1115 }
  1116 
  1117 static void
  1118 razor_set_validate(struct razor_set *set, struct array *unsatisfied)
  1119 {
  1120 	struct razor_property *r, *p, *rend, *pend;
  1121 	unsigned long *u;
  1122 	char *pool;
  1123 
  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;
  1128 	
  1129 	for (r = set->requires.data; r < rend; r++) {
  1130 		while (p < pend && strcmp(&pool[r->name], &pool[p->name]) > 0)
  1131 			p++;
  1132 
  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)
  1136 			p++;
  1137 
  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. */
  1142 
  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] == '/')
  1147 				continue;
  1148 			u = array_add(unsatisfied, sizeof *u);
  1149 			*u = r - (struct razor_property *) set->requires.data;
  1150 		}
  1151 	}
  1152 }
  1153 
  1154 void
  1155 razor_set_list_unsatisfied(struct razor_set *set)
  1156 {
  1157 	struct array unsatisfied;
  1158 	struct razor_property *requires, *r;
  1159 	unsigned long *u, *end;
  1160 	char *pool;
  1161 
  1162 	array_init(&unsatisfied);
  1163 	razor_set_validate(set, &unsatisfied);
  1164 
  1165 	end = unsatisfied.data + unsatisfied.size;
  1166 	requires = set->requires.data;
  1167 	pool = set->string_pool.data;
  1168 
  1169 	for (u = unsatisfied.data; u < end; u++) {
  1170 		r = requires + *u;
  1171 		printf("%s %s not satisfied\n",
  1172 		       &pool[r->name], &pool[r->version]);
  1173 	}
  1174 
  1175 	array_release(&unsatisfied);
  1176 }
  1177 
  1178 #define UPSTREAM_SOURCE 0x80000000ul
  1179 #define INDEX_MASK 0x00fffffful
  1180 
  1181 struct source {
  1182 	struct razor_set *set;
  1183 	unsigned long *requires_map;
  1184 	unsigned long *provides_map;
  1185 };
  1186 
  1187 static void
  1188 prepare_source(struct source *source, struct razor_set *set)
  1189 {
  1190 	int count;
  1191 	size_t size;
  1192 
  1193 	source->set = set;
  1194 
  1195 	count = set->requires.size / sizeof (struct razor_property);
  1196 	size = count * sizeof *source->requires_map;
  1197 	source->requires_map = zalloc(size);
  1198 
  1199 	count = set->provides.size / sizeof (struct razor_property);
  1200 	size = count * sizeof *source->provides_map;
  1201 	source->provides_map = zalloc(size);
  1202 }
  1203 
  1204 static void
  1205 add_package(struct razor_importer *importer,
  1206 	    struct razor_package *package, struct source *source,
  1207 	    unsigned long flags)
  1208 {
  1209 	char *pool;
  1210 	unsigned long *r;
  1211 	struct razor_package *p;
  1212 
  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]);
  1216 	p->name |= flags;
  1217 	p->version = razor_importer_tokenize(importer,
  1218 					     &pool[package->version]);
  1219 	p->requires = package->requires;
  1220 	p->provides = package->provides;
  1221 
  1222 	r = (unsigned long *)
  1223 		source->set->requires_pool.data + package->requires;
  1224 	while (*r != ~0)
  1225 		source->requires_map[*r++] = 1;
  1226 
  1227 	r = (unsigned long *)
  1228 		source->set->provides_pool.data + package->provides;
  1229 	while (*r != ~0)
  1230 		source->provides_map[*r++] = 1;
  1231 }
  1232 
  1233 
  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
  1236  * the importer). */
  1237 static void
  1238 merge_packages(struct razor_importer *importer,
  1239 	       struct source *source1, struct source *source2,
  1240 	       struct array *packages)
  1241 {
  1242 	struct razor_package *upstream_packages, *p, *s, *send;
  1243 	char *spool, *upool;
  1244 	unsigned long *u, *uend;
  1245 	int cmp;
  1246 
  1247 	upstream_packages = source2->set->packages.data;
  1248 
  1249 	u = packages->data;
  1250 	uend = packages->data + packages->size;
  1251 	upool = source2->set->string_pool.data;
  1252 
  1253 	s = source1->set->packages.data;
  1254 	send = source1->set->packages.data + source1->set->packages.size;
  1255 	spool = source1->set->string_pool.data;
  1256 
  1257 	while (s < send) {
  1258 		p = upstream_packages + *u;
  1259 
  1260 		if (u < uend)
  1261 			cmp = strcmp(&spool[s->name], &upool[p->name]);
  1262 		if (u >= uend || cmp < 0) {
  1263 			add_package(importer, s, source1, 0);
  1264 			s++;
  1265 		} else if (cmp == 0) {
  1266 			add_package(importer, p, source2, UPSTREAM_SOURCE);
  1267 			s++;
  1268 			u++;
  1269 		} else {
  1270 			add_package(importer, p, source2, UPSTREAM_SOURCE);
  1271 			u++;
  1272 		}
  1273 	}
  1274 }
  1275 
  1276 static unsigned long
  1277 add_property(struct razor_importer *importer, struct array *properties,
  1278 	     const char *name, const char *version)
  1279 {
  1280 	struct razor_property *p;
  1281 
  1282 	p = array_add(properties, sizeof *p);
  1283 	p->name = razor_importer_tokenize(importer, name);
  1284 	p->version = razor_importer_tokenize(importer, version);
  1285 
  1286 	return p - (struct razor_property *) properties->data;
  1287 }
  1288 
  1289 static void
  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)
  1298 {
  1299 	struct razor_property *p1, *p2;
  1300 	int i, j, cmp, count1, count2;
  1301 	char *pool1, *pool2;
  1302 
  1303 	i = 0;
  1304 	j = 0;
  1305 	pool1 = set1->string_pool.data;
  1306 	pool2 = set2->string_pool.data;
  1307 
  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) {
  1312 			i++;
  1313 			continue;
  1314 		}
  1315 		if (j < count2 && map2[j] == 0) {
  1316 			j++;
  1317 			continue;
  1318 		}
  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)
  1324 			cmp = -1;
  1325 		else
  1326 			cmp = 1;
  1327 		if (cmp == 0)
  1328 			cmp = versioncmp(&pool1[p1->version],
  1329 					 &pool2[p2->version]);
  1330 		if (cmp < 0) {
  1331 			map1[i++] = add_property(importer,
  1332 						 properties,
  1333 						 &pool1[p1->name],
  1334 						 &pool1[p1->version]);
  1335 		} else if (cmp > 0) {
  1336 			map2[j++] = add_property(importer,
  1337 						 properties,
  1338 						 &pool2[p2->name],
  1339 						 &pool2[p2->version]);
  1340 		} else  {
  1341 			map1[i++] = map2[j++] = add_property(importer,
  1342 							     properties,
  1343 							     &pool1[p1->name],
  1344 							     &pool1[p1->version]);
  1345 		}
  1346 	}
  1347 }
  1348 
  1349 static unsigned long
  1350 emit_properties(struct array *source_pool, unsigned long index,
  1351 		unsigned long *map, struct array *pool)
  1352 {
  1353 	unsigned long r, *p, *q;
  1354 
  1355 	r = pool->size / sizeof *q;
  1356 	p = (unsigned long *) source_pool->data + index;
  1357 	while (*p != ~0) {
  1358 		q = array_add(pool, sizeof *q);
  1359 		*q = map[*p++];
  1360 	}
  1361 
  1362 	q = array_add(pool, sizeof *q);
  1363 	*q = ~0;
  1364 
  1365 	return r;
  1366 }
  1367 	
  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. */
  1372 static void
  1373 rebuild_package_lists(struct razor_set *set)
  1374 {
  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;
  1380 
  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;
  1388 
  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;
  1393 		}
  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;
  1397 		}
  1398 	}
  1399 
  1400 	prop_end = set->requires.data + set->requires.size;
  1401 	a = requires_pkgs;
  1402 	for (prop = set->requires.data; prop < prop_end; prop++, a++) {
  1403 		prop->packages = add_to_property_pool(&set->requires_pool, a);
  1404 		array_release(a);
  1405 	}
  1406 	free(requires_pkgs);
  1407 
  1408 	prop_end = set->provides.data + set->provides.size;
  1409 	a = provides_pkgs;
  1410 	for (prop = set->provides.data; prop < prop_end; prop++, a++) {
  1411 		prop->packages = add_to_property_pool(&set->provides_pool, a);
  1412 		array_release(a);
  1413 	}
  1414 	free(provides_pkgs);
  1415 }
  1416 
  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.
  1421  *
  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.
  1426  */
  1427 struct razor_set *
  1428 razor_set_add(struct razor_set *set, struct razor_set *upstream,
  1429 	      struct array *packages)
  1430 {
  1431 	struct razor_set *result;
  1432 	struct razor_importer *importer;
  1433 	struct razor_package *p, *pend;
  1434 	struct source source, upstream_source;
  1435 
  1436 	importer = razor_importer_new();
  1437 
  1438 	prepare_source(&upstream_source, upstream);
  1439 	prepare_source(&source, set);
  1440 
  1441 	merge_packages(importer, &source, &upstream_source, packages);
  1442 
  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. */
  1450 
  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);
  1459 
  1460 	/* Now we loop through the packages again and emit the
  1461 	 * property lists, remapped to point to the new properties. */
  1462 
  1463 	pend = importer->set->packages.data + importer->set->packages.size;
  1464 	for (p = importer->set->packages.data; p < pend; p++) {
  1465 		struct source *src;
  1466 
  1467 		if (p->name & UPSTREAM_SOURCE)
  1468 			src = &upstream_source;
  1469 		else
  1470 			src = &source;
  1471 
  1472 		p->requires = emit_properties(&src->set->requires_pool,
  1473 					      p->requires,
  1474 					      src->requires_map,
  1475 					      &importer->set->requires_pool);
  1476 		p->provides = emit_properties(&src->set->provides_pool,
  1477 					      p->provides,
  1478 					      src->provides_map,
  1479 					      &importer->set->provides_pool);
  1480 		p->name &= INDEX_MASK;
  1481 	}
  1482 
  1483 	rebuild_package_lists(importer->set);
  1484 
  1485 	result = importer->set;
  1486 	array_release(&importer->buckets);
  1487 	free(importer);
  1488 
  1489 	return result;
  1490 }
  1491 
  1492 void
  1493 razor_set_satisfy(struct razor_set *set, struct array *unsatisfied,
  1494 		  struct razor_set *upstream, struct array *list)
  1495 {
  1496 	struct razor_property *requires, *r;
  1497 	struct razor_property *p, *pend;
  1498 	unsigned long *u, *end, *pkg, *package_pool;
  1499 	char *pool, *upool;
  1500 
  1501 	end = unsatisfied->data + unsatisfied->size;
  1502 	requires = set->requires.data;
  1503 	pool = set->string_pool.data;
  1504 
  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;
  1509 
  1510 	for (u = unsatisfied->data; u < end; u++) {
  1511 		r = requires + *u;
  1512 
  1513 		while (p < pend && strcmp(&pool[r->name], &upool[p->name]) > 0)
  1514 			p++;
  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)
  1518 			p++;
  1519 
  1520 		if (p == pend ||
  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? */
  1526 		} else {
  1527 			pkg = array_add(list, sizeof *pkg);
  1528 			/* We just pull in the first package that provides */
  1529 			*pkg = package_pool[p->packages];
  1530 		}
  1531 	}	
  1532 }
  1533 
  1534 static void
  1535 find_packages(struct razor_set *set,
  1536 	      int count, const char **packages, struct array *list)
  1537 {
  1538 	struct razor_package *p;
  1539 	unsigned long *r;
  1540 	int i;
  1541 
  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;
  1547 	}
  1548 }
  1549 
  1550 static void
  1551 find_all_packages(struct razor_set *set,
  1552 		  struct razor_set *upstream, struct array *list)
  1553 {
  1554 	struct razor_package *p, *u, *pend, *uend;
  1555 	unsigned long *r;
  1556 	char *pool, *upool;
  1557 
  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;
  1563 
  1564 	for (p = set->packages.data; p < pend; p++) {
  1565 		while (u < uend && strcmp(&pool[p->name], &upool[u->name]) > 0)
  1566 			u++;
  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;
  1570 		}
  1571 	}
  1572 }
  1573 
  1574 struct razor_set *
  1575 razor_set_update(struct razor_set *set, struct razor_set *upstream,
  1576 		 int count, const char **packages)
  1577 {
  1578 	struct razor_set *new;
  1579 	struct razor_package *upackages;
  1580 	struct array list, unsatisfied;
  1581 	char *pool;
  1582 	unsigned long *u, *end;
  1583 	int total = 0;
  1584 
  1585 	array_init(&list);
  1586 	if (count > 0)
  1587 		find_packages(upstream, count, packages, &list);
  1588 	else
  1589 		find_all_packages(set, upstream, &list);
  1590 
  1591 	end = list.data + list.size;
  1592 	upackages = upstream->packages.data;
  1593 	pool = upstream->string_pool.data;
  1594 	total += list.size / sizeof *u;
  1595 
  1596 	while (list.size > 0) {
  1597 		new = razor_set_add(set, upstream, &list);
  1598 		array_release(&list);
  1599 		razor_set_destroy(set);
  1600 		set = new;
  1601 
  1602 		array_init(&unsatisfied);
  1603 		razor_set_validate(new, &unsatisfied);
  1604 		array_init(&list);
  1605 		razor_set_satisfy(new, &unsatisfied, upstream, &list);
  1606 		array_release(&unsatisfied);
  1607 
  1608 		end = list.data + list.size;
  1609 		upackages = upstream->packages.data;
  1610 		pool = upstream->string_pool.data;
  1611 		total += list.size / sizeof *u;
  1612 	}
  1613 
  1614 	array_release(&list);
  1615 
  1616 	return set;
  1617 }
  1618 
  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.
  1622  **/
  1623 
  1624 void
  1625 razor_set_diff(struct razor_set *set, struct razor_set *upstream,
  1626 	       razor_package_callback_t callback, void *data)
  1627 {
  1628 	struct razor_package *p, *pend, *u, *uend;
  1629 	char *ppool, *upool;
  1630 	int res = 0;
  1631 
  1632 	p = set->packages.data;
  1633 	pend = set->packages.data + set->packages.size;
  1634 	ppool = set->string_pool.data;
  1635 
  1636 	u = upstream->packages.data;
  1637 	uend = upstream->packages.data + upstream->packages.size;
  1638 	upool = upstream->string_pool.data;
  1639 
  1640 	while (p < pend || u < uend) {
  1641 		if (p < pend && u < uend) {
  1642 			res = strcmp(&ppool[p->name], &upool[u->name]);
  1643 			if (res == 0)
  1644 				res = versioncmp(&ppool[p->version],
  1645 						 &upool[u->version]);
  1646 		}
  1647 
  1648 		if (u == uend || res < 0) {
  1649 			callback(&ppool[p->name], &ppool[p->version],
  1650 				 NULL, data);
  1651 			p++;
  1652 			continue;
  1653 		} else if (p == pend || res > 0) {
  1654 			callback(&upool[u->name], NULL, &upool[u->version],
  1655 				 data);
  1656 			u++;
  1657 			continue;
  1658 		} else {
  1659 			p++;
  1660 			u++;
  1661 		}
  1662 	}
  1663 }