razor.c
author Kristian H?gsberg <krh@redhat.com>
Thu Jan 10 23:42:42 2008 -0500 (2008-01-10)
changeset 100 27aada326858
parent 99 7e5f2050db0e
child 101 9708f6d5db8c
permissions -rw-r--r--
Move more front-end logic from razor_set_list_property_packages() to main.c.
     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 #include <fnmatch.h>
    15 
    16 #include "razor.h"
    17 #include "razor-internal.h"
    18 
    19 struct array {
    20 	void *data;
    21 	int size, alloc;
    22 };
    23 
    24 struct razor_set_section {
    25 	unsigned int type;
    26 	unsigned int offset;
    27 	unsigned int size;
    28 };
    29 
    30 struct razor_set_header {
    31 	unsigned int magic;
    32 	unsigned int version;
    33 	struct razor_set_section sections[0];
    34 };
    35 
    36 #define RAZOR_MAGIC 0x7a7a7a7a
    37 #define RAZOR_VERSION 1
    38 
    39 #define RAZOR_ENTRY_LAST	0x80000000ul
    40 #define RAZOR_IMMEDIATE		0x80000000ul
    41 #define RAZOR_ENTRY_MASK	0x00fffffful
    42 
    43 #define RAZOR_STRING_POOL	0
    44 #define RAZOR_PACKAGES		1
    45 #define RAZOR_PROPERTIES	2
    46 #define RAZOR_FILES		3
    47 #define RAZOR_PACKAGE_POOL	4
    48 #define RAZOR_PROPERTY_POOL	5
    49 #define RAZOR_FILE_POOL		6
    50 
    51 struct razor_package {
    52 	unsigned long name;
    53 	unsigned long version;
    54 	unsigned long properties;
    55 	unsigned long files;
    56 };
    57 
    58 struct razor_property {
    59 	unsigned long name;
    60 	unsigned long version;
    61 	unsigned long packages;
    62 };
    63 
    64 struct razor_entry {
    65 	unsigned long name;
    66 	unsigned long start;
    67 	unsigned long packages;
    68 };
    69 
    70 struct razor_set {
    71 	struct array string_pool;
    72  	struct array packages;
    73  	struct array properties;
    74  	struct array files;
    75 	struct array package_pool;
    76  	struct array property_pool;
    77  	struct array file_pool;
    78 	struct razor_set_header *header;
    79 };
    80 
    81 struct import_entry {
    82 	unsigned long package;
    83 	char *name;
    84 };
    85 
    86 struct import_directory {
    87 	unsigned long name, count;
    88 	struct array files;
    89 	struct array packages;
    90 	struct import_directory *last;
    91 };
    92 
    93 struct hashtable {
    94 	struct array buckets;
    95 	struct array *pool;
    96 };
    97 
    98 struct razor_importer {
    99 	struct razor_set *set;
   100 	struct hashtable table;
   101 	struct razor_package *package;
   102 	struct array properties;
   103 	struct array files;
   104 };
   105 
   106 static void
   107 array_init(struct array *array)
   108 {
   109 	memset(array, 0, sizeof *array);
   110 }
   111 
   112 static void
   113 array_release(struct array *array)
   114 {
   115 	free(array->data);
   116 }
   117 
   118 static void *
   119 array_add(struct array *array, int size)
   120 {
   121 	int alloc;
   122 	void *data, *p;
   123 
   124 	if (array->alloc > 0)
   125 		alloc = array->alloc;
   126 	else
   127 		alloc = 16;
   128 
   129 	while (alloc < array->size + size)
   130 		alloc *= 2;
   131 
   132 	if (array->alloc < alloc) {
   133 		data = realloc(array->data, alloc);
   134 		if (data == NULL)
   135 			return 0;
   136 		array->data = data;
   137 		array->alloc = alloc;
   138 	}
   139 
   140 	p = array->data + array->size;
   141 	array->size += size;
   142 
   143 	return p;
   144 }
   145 
   146 static void *
   147 zalloc(size_t size)
   148 {
   149 	void *p;
   150 
   151 	p = malloc(size);
   152 	memset(p, 0, size);
   153 
   154 	return p;
   155 }
   156 
   157 struct razor_set_section razor_sections[] = {
   158 	{ RAZOR_STRING_POOL,	offsetof(struct razor_set, string_pool) },
   159 	{ RAZOR_PACKAGES,	offsetof(struct razor_set, packages) },
   160 	{ RAZOR_PROPERTIES,	offsetof(struct razor_set, properties) },
   161 	{ RAZOR_FILES,		offsetof(struct razor_set, files) },
   162 	{ RAZOR_PACKAGE_POOL,	offsetof(struct razor_set, package_pool) },
   163 	{ RAZOR_PROPERTY_POOL,	offsetof(struct razor_set, property_pool) },
   164 	{ RAZOR_FILE_POOL,	offsetof(struct razor_set, file_pool) },
   165 };
   166 
   167 struct razor_set *
   168 razor_set_create(void)
   169 {
   170 	return zalloc(sizeof(struct razor_set));
   171 }
   172 
   173 struct razor_set *
   174 razor_set_open(const char *filename)
   175 {
   176 	struct razor_set *set;
   177 	struct razor_set_section *s;
   178 	struct stat stat;
   179 	struct array *array;
   180 	int fd;
   181 
   182 	set = zalloc(sizeof *set);
   183 	fd = open(filename, O_RDONLY);
   184 	if (fstat(fd, &stat) < 0)
   185 		return NULL;
   186 	set->header = mmap(NULL, stat.st_size, PROT_READ, MAP_PRIVATE, fd, 0);
   187 	if (set->header == MAP_FAILED) {
   188 		free(set);
   189 		return NULL;
   190 	}
   191 
   192 	for (s = set->header->sections; ~s->type; s++) {
   193 		if (s->type >= ARRAY_SIZE(razor_sections))
   194 			continue;
   195 		if (s->type != razor_sections[s->type].type)
   196 			continue;
   197 		array = (void *) set + razor_sections[s->type].offset;
   198 		array->data = (void *) set->header + s->offset;
   199 		array->size = s->size;
   200 		array->alloc = s->size;
   201 	}
   202 	close(fd);
   203 
   204 	return set;
   205 }
   206 
   207 void
   208 razor_set_destroy(struct razor_set *set)
   209 {
   210 	unsigned int size;
   211 	struct array *a;
   212 	int i;
   213 
   214 	if (set->header) {
   215 		for (i = 0; set->header->sections[i].type; i++)
   216 			;
   217 		size = set->header->sections[i].type;
   218 		munmap(set->header, size);
   219 	} else {
   220 		for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
   221 			a = (void *) set + razor_sections[i].offset;
   222 			free(a->data);
   223 		}
   224 	}
   225 
   226 	free(set);
   227 }
   228 
   229 int
   230 razor_set_write(struct razor_set *set, const char *filename)
   231 {
   232 	char data[4096];
   233 	struct razor_set_header *header = (struct razor_set_header *) data;
   234 	struct array *a;
   235 	unsigned long offset;
   236 	int i, fd;
   237 
   238 	memset(data, 0, sizeof data);
   239 	header->magic = RAZOR_MAGIC;
   240 	header->version = RAZOR_VERSION;
   241 	offset = sizeof data;
   242 
   243 	for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
   244 		if (razor_sections[i].type != i)
   245 			continue;
   246 		a = (void *) set + razor_sections[i].offset;
   247 		header->sections[i].type = i;
   248 		header->sections[i].offset = offset;
   249 		header->sections[i].size = a->size;
   250 		offset += ALIGN(a->size, 4096);
   251 	}
   252 
   253 	header->sections[i].type = ~0;
   254 	header->sections[i].offset = 0;
   255 	header->sections[i].size = 0;
   256 
   257 	fd = open(filename, O_CREAT | O_WRONLY | O_TRUNC, 0666);
   258 	if (fd < 0)
   259 		return -1;
   260 
   261 	razor_write(fd, data, sizeof data);
   262 	for (i = 0; i < ARRAY_SIZE(razor_sections); i++) {
   263 		if (razor_sections[i].type != i)
   264 			continue;
   265 		a = (void *) set + razor_sections[i].offset;
   266 		razor_write(fd, a->data, ALIGN(a->size, 4096));
   267 	}
   268 
   269 	close(fd);
   270 
   271 	return 0;
   272 }
   273 
   274 static unsigned int
   275 hash_string(const char *key)
   276 {
   277 	const char *p;
   278 	unsigned int hash = 0;
   279 
   280 	for (p = key; *p; p++)
   281 		hash = (hash * 617) ^ *p;
   282 
   283 	return hash;
   284 }
   285 
   286 static unsigned long
   287 hashtable_lookup(struct hashtable *table, const char *key)
   288 {
   289 	unsigned int mask, start, i;
   290 	unsigned long *b;
   291 	char *pool;
   292 
   293 	pool = table->pool->data;
   294 	mask = table->buckets.alloc - 1;
   295 	start = hash_string(key) * sizeof(unsigned long);
   296 
   297 	for (i = 0; i < table->buckets.alloc; i += sizeof *b) {
   298 		b = table->buckets.data + ((start + i) & mask);
   299 
   300 		if (*b == 0)
   301 			return 0;
   302 
   303 		if (strcmp(key, &pool[*b]) == 0)
   304 			return *b;
   305 	}
   306 
   307 	return 0;
   308 }
   309 
   310 static unsigned long
   311 add_to_string_pool(struct hashtable *table, const char *key)
   312 {
   313 	int len;
   314 	char *p;
   315 
   316 	len = strlen(key) + 1;
   317 	p = array_add(table->pool, len);
   318 	memcpy(p, key, len);
   319 
   320 	return p - (char *) table->pool->data;
   321 }
   322 
   323 static unsigned long
   324 add_to_property_pool(struct array *pool, struct array *properties)
   325 {
   326 	unsigned long *p;
   327 
   328 	if (properties->size == 0)
   329 		return ~0;
   330 	else if (properties->size == sizeof *p)
   331 		return *(unsigned long *) properties->data | RAZOR_IMMEDIATE;
   332 
   333 	p = array_add(pool, properties->size);
   334 	memcpy(p, properties->data, properties->size);
   335 	p[properties->size / sizeof *p - 1] |= RAZOR_IMMEDIATE;
   336 
   337 	return p - (unsigned long *) pool->data;
   338 }
   339 
   340 static void
   341 do_insert(struct hashtable *table, unsigned long value)
   342 {
   343 	unsigned int mask, start, i;
   344 	unsigned long *b;
   345 	const char *key;
   346 
   347 	key = (char *) table->pool->data + value;
   348 	mask = table->buckets.alloc - 1;
   349 	start = hash_string(key) * sizeof(unsigned long);
   350 
   351 	for (i = 0; i < table->buckets.alloc; i += sizeof *b) {
   352 		b = table->buckets.data + ((start + i) & mask);
   353 		if (*b == 0) {
   354 			*b = value;
   355 			break;
   356 		}
   357 	}
   358 }
   359 
   360 static unsigned long
   361 hashtable_insert(struct hashtable *table, const char *key)
   362 {
   363 	unsigned long value, *buckets, *b, *end;
   364 	int alloc;
   365 
   366 	alloc = table->buckets.alloc;
   367 	array_add(&table->buckets, 4 * sizeof *buckets);
   368 	if (alloc != table->buckets.alloc) {
   369 		end = table->buckets.data + alloc;
   370 		memset(end, 0, table->buckets.alloc - alloc);
   371 		for (b = table->buckets.data; b < end; b++) {
   372 			value = *b;
   373 			if (value != 0) {
   374 				*b = 0;
   375 				do_insert(table, value);
   376 			}
   377 		}
   378 	}
   379 
   380 	value = add_to_string_pool(table, key);
   381 	do_insert (table, value);
   382 
   383 	return value;
   384 }
   385 
   386 static void
   387 hashtable_init(struct hashtable *table, struct array *pool)
   388 {
   389 	array_init(&table->buckets);
   390 	table->pool = pool;
   391 }
   392 
   393 static void
   394 hashtable_release(struct hashtable *table)
   395 {
   396 	array_release(&table->buckets);
   397 }
   398 
   399 static unsigned long
   400 hashtable_tokenize(struct hashtable *table, const char *string)
   401 {
   402 	unsigned long token;
   403 
   404 	if (string == NULL)
   405 		string = "";
   406 
   407 	token = hashtable_lookup(table, string);
   408 	if (token != 0)
   409 		return token;
   410 
   411 	return hashtable_insert(table, string);
   412 }
   413 
   414 void
   415 razor_importer_begin_package(struct razor_importer *importer,
   416 			     const char *name, const char *version)
   417 {
   418 	struct razor_package *p;
   419 
   420 	p = array_add(&importer->set->packages, sizeof *p);
   421 	p->name = hashtable_tokenize(&importer->table, name);
   422 	p->version = hashtable_tokenize(&importer->table, version);
   423 
   424 	importer->package = p;
   425 	array_init(&importer->properties);
   426 }
   427 
   428 void
   429 razor_importer_finish_package(struct razor_importer *importer)
   430 {
   431 	struct razor_package *p;
   432 
   433 	p = importer->package;
   434 	p->properties = add_to_property_pool(&importer->set->property_pool,
   435 					     &importer->properties);
   436 
   437 	array_release(&importer->properties);
   438 }
   439 
   440 void
   441 razor_importer_add_property(struct razor_importer *importer,
   442 			    const char *name, const char *version,
   443 			    enum razor_property_type type)
   444 {
   445 	struct razor_property *p;
   446 	unsigned long *r;
   447 
   448 	p = array_add(&importer->set->properties, sizeof *p);
   449 	p->name = hashtable_tokenize(&importer->table, name) | (type << 30);
   450 	p->version = hashtable_tokenize(&importer->table, version);
   451 	p->packages = importer->package -
   452 		(struct razor_package *) importer->set->packages.data;
   453 
   454 	r = array_add(&importer->properties, sizeof *r);
   455 	*r = p - (struct razor_property *) importer->set->properties.data;
   456 }
   457 
   458 void
   459 razor_importer_add_file(struct razor_importer *importer, const char *name)
   460 {
   461 	struct import_entry *e;
   462 
   463 	e = array_add(&importer->files, sizeof *e);
   464 
   465 	e->package = importer->package -
   466 		(struct razor_package *) importer->set->packages.data;
   467 	e->name = strdup(name);
   468 }
   469 
   470 struct razor_importer *
   471 razor_importer_new(void)
   472 {
   473 	struct razor_importer *importer;
   474 
   475 	importer = zalloc(sizeof *importer);
   476 	importer->set = razor_set_create();
   477 	hashtable_init(&importer->table, &importer->set->string_pool);
   478 
   479 	return importer;
   480 }
   481 
   482 /* Destroy an importer without creating the set. */
   483 void
   484 razor_importer_destroy(struct razor_importer *importer)
   485 {
   486 	/* FIXME: write this */
   487 }
   488 
   489 
   490 typedef int (*compare_with_data_func_t)(const void *p1,
   491 					const void *p,
   492 					void *data);
   493 
   494 struct qsort_context {
   495 	size_t size;
   496 	compare_with_data_func_t compare;
   497 	void *data;
   498 };
   499 
   500 static void
   501 qsort_swap(void *p1, void *p2, size_t size)
   502 {
   503 	char buffer[size];
   504 
   505 	memcpy(buffer, p1, size);
   506 	memcpy(p1, p2, size);
   507 	memcpy(p2, buffer, size);
   508 }
   509 
   510 static void
   511 __qsort_with_data(void *base, size_t nelem, unsigned long *map,
   512 		  struct qsort_context *ctx)
   513 {
   514 	void *p, *start, *end, *pivot;
   515 	unsigned long *mp, *mstart, *mend, tmp;
   516 	int left, right, result;
   517 	size_t size = ctx->size;
   518 
   519 	p = base;
   520 	start = base;
   521 	end = base + nelem * size;
   522 	mp = map;
   523 	mstart = map;
   524 	mend = map + nelem;
   525 	pivot = base + (random() % nelem) * size;
   526 
   527 	while (p < end) {
   528 		result = ctx->compare(p, pivot, ctx->data);
   529 		if (result < 0) {
   530 			qsort_swap(p, start, size);
   531 			tmp = *mp;
   532 			*mp = *mstart;
   533 			*mstart = tmp;
   534 			if (start == pivot)
   535 				pivot = p;
   536 			start += size;
   537 			mstart++;
   538 			p += size;
   539 			mp++;
   540 		} else if (result == 0) {
   541 			p += size;
   542 			mp++;
   543 		} else {
   544  			end -= size;
   545 			mend--;
   546 			qsort_swap(p, end, size);
   547 			tmp = *mp;
   548 			*mp = *mend;
   549 			*mend = tmp;
   550 			if (end == pivot)
   551 				pivot = p;
   552 		}
   553 	}
   554 
   555 	left = (start - base) / size;
   556 	right = (base + nelem * size - end) / size;
   557 	if (left > 1)
   558 		__qsort_with_data(base, left, map, ctx);
   559 	if (right > 1)
   560 		__qsort_with_data(end, right, mend, ctx);
   561 }
   562 
   563 unsigned long *
   564 qsort_with_data(void *base, size_t nelem, size_t size,
   565 		compare_with_data_func_t compare, void *data)
   566 {
   567 	struct qsort_context ctx;
   568 	unsigned long *map;
   569 	int i;
   570 
   571 	if (nelem == 0)
   572 		return NULL;
   573 
   574 	ctx.size = size;
   575 	ctx.compare = compare;
   576 	ctx.data = data;
   577 
   578 	map = malloc(nelem * sizeof (unsigned long));
   579 	for (i = 0; i < nelem; i++)
   580 		map[i] = i;
   581 
   582 	__qsort_with_data(base, nelem, map, &ctx);
   583 
   584 	return map;
   585 }
   586 
   587 static int
   588 versioncmp(const char *s1, const char *s2)
   589 {
   590 	const char *p1, *p2;
   591 	long n1, n2;
   592 	int res;
   593 
   594 	n1 = strtol(s1, (char **) &p1, 0);
   595 	n2 = strtol(s2, (char **) &p2, 0);
   596 
   597 	/* Epoch; if one but not the other has an epoch set, default
   598 	 * the epoch-less version to 0. */
   599 	res = (*p1 == ':') - (*p2 == ':');
   600 	if (res < 0) {
   601 		n1 = 0;
   602 		p1 = s1;
   603 		p2++;
   604 	} else if (res > 0) {
   605 		p1++;
   606 		n2 = 0;
   607 		p2 = s2;
   608 	}
   609 
   610 	if (n1 != n2)
   611 		return n1 - n2;
   612 	while (*p1 && *p2) {
   613 		if (*p1 != *p2)
   614 			return *p1 - *p2;
   615 		p1++;
   616 		p2++;
   617 		if (isdigit(*p1) && isdigit(*p2))
   618 			return versioncmp(p1, p2);
   619 	}
   620 
   621 	return *p1 - *p2;
   622 }
   623 
   624 static int
   625 compare_packages(const void *p1, const void *p2, void *data)
   626 {
   627 	const struct razor_package *pkg1 = p1, *pkg2 = p2;
   628 	struct razor_set *set = data;
   629 	char *pool = set->string_pool.data;
   630 
   631 	if (pkg1->name == pkg2->name)
   632 		return versioncmp(&pool[pkg1->version], &pool[pkg2->version]);
   633 	else
   634 		return strcmp(&pool[pkg1->name], &pool[pkg2->name]);
   635 }
   636 
   637 static int
   638 compare_properties(const void *p1, const void *p2, void *data)
   639 {
   640 	const struct razor_property *prop1 = p1, *prop2 = p2;
   641 	struct razor_set *set = data;
   642 	char *pool = set->string_pool.data;
   643 
   644 	if (prop1->name == prop2->name)
   645 		return versioncmp(&pool[prop1->version],
   646 				  &pool[prop2->version]);
   647 	else if ((prop1->name & RAZOR_ENTRY_MASK) == (prop2->name & RAZOR_ENTRY_MASK))
   648 		return (prop1->name >> 30) - (prop2->name >> 30);
   649 	else
   650 		return strcmp(&pool[prop1->name & RAZOR_ENTRY_MASK],
   651 			      &pool[prop2->name & RAZOR_ENTRY_MASK]);
   652 }
   653 
   654 static unsigned long *
   655 uniqueify_properties(struct razor_set *set)
   656 {
   657 	struct razor_property *rp, *up, *rp_end;
   658 	struct array *pkgs, *p;
   659 	unsigned long *map, *rmap, *r;
   660 	int i, count, unique;
   661 
   662 	count = set->properties.size / sizeof(struct razor_property);
   663 	map = qsort_with_data(set->properties.data,
   664 			      count,
   665 			      sizeof(struct razor_property),
   666 			      compare_properties,
   667 			      set);
   668 
   669 	rp_end = set->properties.data + set->properties.size;
   670 	rmap = malloc(count * sizeof *map);
   671 	pkgs = zalloc(count * sizeof *pkgs);
   672 	for (rp = set->properties.data, up = rp, i = 0; rp < rp_end; rp++, i++) {
   673 		if (rp->name != up->name || rp->version != up->version) {
   674 			up++;
   675 			up->name = rp->name;
   676 			up->version = rp->version;
   677 		}
   678 
   679 		unique = up - (struct razor_property *) set->properties.data;
   680 		rmap[map[i]] = unique;
   681 		r = array_add(&pkgs[unique], sizeof *r);
   682 		*r = rp->packages;
   683 	}
   684 	free(map);
   685 
   686 	up++;
   687 	set->properties.size = (void *) up - set->properties.data;
   688 	rp_end = up;
   689 	for (rp = set->properties.data, p = pkgs; rp < rp_end; rp++, p++) {
   690 		if (p->size / sizeof *r == 1) {
   691 			r = p->data;
   692 			rp->packages = *r | RAZOR_IMMEDIATE;
   693 		} else {
   694 			rp->packages =
   695 				add_to_property_pool(&set->package_pool, p);
   696 		}
   697 		array_release(p);
   698 	}
   699 
   700 	free(pkgs);
   701 
   702 	return rmap;
   703 }
   704 
   705 static void
   706 remap_links(struct array *links, unsigned long *map)
   707 {
   708 	unsigned long *p, *end;
   709 
   710 	end = links->data + links->size;
   711 	for (p = links->data; p < end; p++)
   712 		*p = map[*p & RAZOR_ENTRY_MASK] | (*p & ~RAZOR_ENTRY_MASK);
   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 = NULL;
   745 	unsigned long s, *r;
   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->start = p->count > 0 ? s : 0;
   754 		s += p->count;
   755 
   756 		if (p->packages.size == 0) {
   757 			e->packages = ~0;
   758 		} else if (p->packages.size / sizeof *r == 1) {
   759 			r = p->packages.data;
   760 			e->packages = *r | RAZOR_IMMEDIATE;
   761 		} else {
   762 			e->packages = add_to_property_pool(&set->package_pool,
   763 							   &p->packages);
   764 		}
   765 		array_release(&p->packages);
   766 		p++;
   767 	}		
   768 	if (e != NULL)
   769 		e->name |= RAZOR_ENTRY_LAST;
   770 
   771 	p = d->files.data;
   772 	end = d->files.data + d->files.size;
   773 	while (p < end) {
   774 		serialize_files(set, p, array);
   775 		p++;
   776 	}
   777 }
   778 
   779 static void
   780 remap_property_package_links(struct array *properties, unsigned long *rmap)
   781 {
   782 	struct razor_property *p, *end;
   783 
   784 	end = properties->data + properties->size;
   785 	for (p = properties->data; p < end; p++)
   786 		if (p->packages & RAZOR_IMMEDIATE)
   787 			p->packages = rmap[p->packages & RAZOR_ENTRY_MASK] |
   788 				RAZOR_IMMEDIATE;
   789 }
   790 
   791 static void
   792 build_file_tree(struct razor_importer *importer)
   793 {
   794 	int count, i, length;
   795 	struct import_entry *filenames;
   796 	char *f, *end;
   797 	unsigned long name, *r;
   798 	char dirname[256];
   799 	struct import_directory *d, root;
   800 	struct razor_entry *e;
   801 
   802 	count = importer->files.size / sizeof (struct import_entry);
   803 	qsort_with_data(importer->files.data,
   804 			count,
   805 			sizeof (struct import_entry),
   806 			compare_filenames,
   807 			NULL);
   808 
   809 	root.name = hashtable_tokenize(&importer->table, "");
   810 	array_init(&root.files);
   811 	array_init(&root.packages);
   812 	root.last = NULL;
   813 
   814 	filenames = importer->files.data;
   815 	for (i = 0; i < count; i++) {
   816 		f = filenames[i].name;
   817 		if (*f != '/')
   818 			continue;
   819 		f++;
   820 
   821 		d = &root;
   822 		while (*f) {
   823 			end = strchr(f, '/');
   824 			if (end == NULL)
   825 				end = f + strlen(f);
   826 			length = end - f;
   827 			memcpy(dirname, f, length);
   828 			dirname[length] ='\0';
   829 			name = hashtable_tokenize(&importer->table, dirname);
   830 			if (d->last == NULL || d->last->name != name) {
   831 				d->last = array_add(&d->files, sizeof *d);
   832 				d->last->name = name;
   833 				d->last->last = NULL;
   834 				array_init(&d->last->files);
   835 				array_init(&d->last->packages);
   836 			}
   837 			d = d->last;				
   838 			f = end + 1;
   839 			if (*end == '\0')
   840 				break;
   841 		}
   842 
   843 		r = array_add(&d->packages, sizeof *r);
   844 		*r = filenames[i].package;
   845 		free(filenames[i].name);
   846 	}
   847 
   848 	count_entries(&root);
   849 	array_init(&importer->set->files);
   850 
   851 	e = array_add(&importer->set->files, sizeof *e);
   852 	e->name = root.name | RAZOR_ENTRY_LAST;
   853 	e->start = 1;
   854 	e->packages = ~0;
   855 
   856 	serialize_files(importer->set, &root, &importer->set->files);
   857 
   858 	array_release(&importer->files);
   859 }
   860 
   861 static void
   862 build_package_file_lists(struct razor_set *set, unsigned long *rmap)
   863 {
   864 	struct razor_package *p, *packages;
   865 	struct array *pkgs;
   866 	struct razor_entry *e, *end;
   867 	unsigned long *r, *q;
   868 	int i, count;
   869 
   870 	count = set->packages.size / sizeof *p;
   871 	pkgs = zalloc(count * sizeof *pkgs);
   872 
   873 	end = set->files.data + set->files.size;
   874 	for (e = set->files.data; e < end; e++) {
   875 		if (e->packages == ~0) {
   876 			continue;
   877 		} else if (e->packages & RAZOR_IMMEDIATE) {
   878 			e->packages = rmap[e->packages & RAZOR_ENTRY_MASK] |
   879 				RAZOR_IMMEDIATE;
   880 			r = &e->packages;
   881 		} else {
   882 			r = (unsigned long *) set->package_pool.data + e->packages;
   883 		}
   884 
   885 		while (1) {
   886 			q = array_add(&pkgs[*r & RAZOR_ENTRY_MASK], sizeof *q);
   887 			*q = e - (struct razor_entry *) set->files.data;
   888 			if (*r++ & RAZOR_IMMEDIATE)
   889 				break;
   890 		}
   891 	}
   892 
   893 	packages = set->packages.data;
   894 	for (i = 0; i < count; i++) {
   895 		packages[i].files =
   896 			add_to_property_pool(&set->file_pool, &pkgs[i]);
   897 		array_release(&pkgs[i]);
   898 	}
   899 	free(pkgs);
   900 }
   901 
   902 struct razor_set *
   903 razor_importer_finish(struct razor_importer *importer)
   904 {
   905 	struct razor_set *set;
   906 	unsigned long *map, *rmap;
   907 	int i, count;
   908 
   909 	map = uniqueify_properties(importer->set);
   910 	remap_links(&importer->set->property_pool, map);
   911 	free(map);
   912 
   913 	count = importer->set->packages.size / sizeof(struct razor_package);
   914 	map = qsort_with_data(importer->set->packages.data,
   915 			      count,
   916 			      sizeof(struct razor_package),
   917 			      compare_packages,
   918 			      importer->set);
   919 
   920 	rmap = malloc(count * sizeof *rmap);
   921 	for (i = 0; i < count; i++)
   922 		rmap[map[i]] = i;
   923 	free(map);
   924 
   925 	build_file_tree(importer);
   926 	remap_links(&importer->set->package_pool, rmap);
   927 	build_package_file_lists(importer->set, rmap);
   928 	remap_property_package_links(&importer->set->properties, rmap);
   929 	free(rmap);
   930 
   931 	set = importer->set;
   932 	hashtable_release(&importer->table);
   933 	free(importer);
   934 
   935 	return set;
   936 }
   937 
   938 struct razor_package_iterator {
   939 	struct razor_set *set;
   940 	struct razor_package *package, *end;
   941 };
   942 
   943 struct razor_package_iterator *
   944 razor_package_iterator_create(struct razor_set *set)
   945 {
   946 	struct razor_package_iterator *pi;
   947 
   948 	pi = zalloc(sizeof *pi);
   949 	pi->set = set;
   950 	pi->package = set->packages.data;
   951 	pi->end = set->packages.data + set->packages.size;
   952 
   953 	return pi;
   954 }
   955 
   956 int
   957 razor_package_iterator_next(struct razor_package_iterator *pi,
   958 			    struct razor_package **package,
   959 			    const char **name, const char **version)
   960 {
   961 	char *pool;
   962 
   963 	pool = pi->set->string_pool.data;
   964 	*package = pi->package;
   965 	*name = &pool[pi->package->name];
   966 	*version = &pool[pi->package->version];
   967 
   968 	return pi->package++ < pi->end;
   969 }
   970 
   971 void
   972 razor_package_iterator_destroy(struct razor_package_iterator *pi)
   973 {
   974 	free(pi);
   975 }
   976 
   977 struct razor_package *
   978 razor_set_get_package(struct razor_set *set, const char *package)
   979 {
   980 	struct razor_package_iterator *pi;
   981 	struct razor_package *p;
   982 	const char *name, *version;
   983 
   984 	pi = razor_package_iterator_create(set);
   985 	while (razor_package_iterator_next(pi, &p, &name, &version)) {
   986 		if (strcmp(package, name) == 0)
   987 			break;
   988 	}
   989 	razor_package_iterator_destroy(pi);
   990 
   991 	return p;
   992 }
   993 
   994 struct razor_property_iterator {
   995 	struct razor_set *set;
   996 	struct razor_property *property, *end;
   997 	unsigned long *index;
   998 	int last;
   999 };
  1000 
  1001 struct razor_property_iterator *
  1002 razor_property_iterator_create(struct razor_set *set,
  1003 			       struct razor_package *package)
  1004 {
  1005 	struct razor_property_iterator *pi;
  1006 
  1007 	pi = zalloc(sizeof *pi);
  1008 	pi->set = set;
  1009 	pi->end = set->properties.data + set->properties.size;
  1010 
  1011 	if (package)
  1012 		pi->index = (unsigned long *)
  1013 			set->property_pool.data + package->properties;
  1014 	else
  1015 		pi->property = set->properties.data;
  1016 
  1017 	return pi;
  1018 }
  1019 
  1020 int
  1021 razor_property_iterator_next(struct razor_property_iterator *pi,
  1022 			     struct razor_property **property,
  1023 			     const char **name, const char **version,
  1024 			     enum razor_property_type *type)
  1025 {
  1026 	char *pool;
  1027 	int valid;
  1028 	struct razor_property *p, *properties;
  1029 
  1030 	if (pi->index) {
  1031 		properties = pi->set->properties.data;
  1032 		p = &properties[*pi->index & RAZOR_ENTRY_MASK];
  1033 		valid = !pi->last;
  1034 		pi->last = (*pi->index++ & RAZOR_IMMEDIATE) != 0;
  1035 	} else {
  1036 		p = pi->property++;
  1037 		valid = p < pi->end;
  1038 	}			
  1039 
  1040 	if (valid) {
  1041 		pool = pi->set->string_pool.data;
  1042 		*property = p;
  1043 		*name = &pool[p->name & RAZOR_ENTRY_MASK];
  1044 		*version = &pool[p->version];
  1045 		*type = p->name >> 30;
  1046 	} else {
  1047 		*property = NULL;
  1048 	}
  1049 
  1050 	return valid;
  1051 }
  1052 
  1053 void
  1054 razor_property_iterator_destroy(struct razor_property_iterator *pi)
  1055 {
  1056 	free(pi);
  1057 }
  1058 
  1059 void
  1060 razor_set_list_property_packages(struct razor_set *set,
  1061 				 struct razor_property *property)
  1062 {
  1063 	struct razor_package *p, *packages;
  1064 	const char *pool;
  1065 	unsigned long *r;
  1066 
  1067 	packages = set->packages.data;
  1068 	pool = set->string_pool.data;
  1069 
  1070 	if (property->packages & RAZOR_IMMEDIATE)
  1071 		r = &property->packages;
  1072 	else
  1073 		r = (unsigned long *)
  1074 			set->package_pool.data + property->packages;
  1075 	while (1) {
  1076 		p = &packages[*r & RAZOR_ENTRY_MASK];
  1077 		printf("%s-%s\n",
  1078 		       &pool[p->name & RAZOR_ENTRY_MASK],
  1079 		       &pool[p->version]);
  1080 		if (*r++ & RAZOR_IMMEDIATE)
  1081 			break;
  1082 	}
  1083 }
  1084 
  1085 static struct razor_entry *
  1086 find_entry(struct razor_set *set, struct razor_entry *dir, const char *pattern)
  1087 {
  1088 	struct razor_entry *e;
  1089 	const char *n, *pool = set->string_pool.data;
  1090 	int len;
  1091 
  1092 	e = (struct razor_entry *) set->files.data + dir->start;
  1093 	do {
  1094 		n = pool + (e->name & RAZOR_ENTRY_MASK);
  1095 		if (strcmp(pattern + 1, n) == 0)
  1096 			return e;
  1097 		len = strlen(n);
  1098 		if (e->start != 0 && strncmp(pattern + 1, n, len) == 0 &&
  1099 		    pattern[len + 1] == '/') {
  1100 			return find_entry(set, e, pattern + len + 1);
  1101 		}
  1102 	} while (((e++)->name & RAZOR_ENTRY_LAST) == 0);
  1103 
  1104 	return NULL;
  1105 }
  1106 
  1107 static void
  1108 list_dir(struct razor_set *set, struct razor_entry *dir,
  1109 	 const char *prefix, const char *pattern)
  1110 {
  1111 	struct razor_entry *e;
  1112 	const char *n, *pool = set->string_pool.data;
  1113 
  1114 	e = (struct razor_entry *) set->files.data + dir->start;
  1115 	do {
  1116 		n = pool + (e->name & RAZOR_ENTRY_MASK);
  1117 		if (pattern && pattern[0] && fnmatch(pattern, n, 0) != 0)
  1118 			continue;
  1119 		printf("%s/%s%s\n", prefix, n, e->start > 0 ? "/" : "");
  1120 	} while (((e++)->name & RAZOR_ENTRY_LAST) == 0);
  1121 }
  1122 
  1123 void
  1124 razor_set_list_files(struct razor_set *set, const char *pattern)
  1125 {
  1126 	struct razor_entry *e;
  1127 	char buffer[512], *p, *base;
  1128 
  1129 	if (pattern == NULL)
  1130 		pattern = "/";
  1131 
  1132 	strcpy(buffer, pattern);
  1133 	e = find_entry(set, set->files.data, buffer);
  1134 	if (e && e->start > 0) {
  1135 		base = NULL;
  1136 	} else {
  1137 		p = strrchr(buffer, '/');
  1138 		if (p) {
  1139 			*p = '\0';
  1140 			base = p + 1;
  1141 		} else {
  1142 			base = NULL;
  1143 		}
  1144 	}
  1145 	e = find_entry(set, set->files.data, buffer);
  1146 	if (e->start != 0)
  1147 		list_dir(set, e, buffer, base);
  1148 }
  1149 
  1150 void
  1151 razor_set_list_file_packages(struct razor_set *set, const char *filename)
  1152 {
  1153 	struct razor_entry *e;
  1154 	struct razor_package *packages, *p;
  1155 	const char *pool;
  1156 	unsigned long *r;
  1157 
  1158 	e = find_entry(set, set->files.data, filename);
  1159 	if (e == NULL)
  1160 		return;
  1161 	
  1162 	if (e->packages & RAZOR_IMMEDIATE)
  1163 		r = &e->packages;
  1164 	else
  1165 		r = (unsigned long *) set->package_pool.data + e->packages;
  1166 
  1167 	packages = set->packages.data;
  1168 	pool = set->string_pool.data;
  1169 	while (1) {
  1170 		p = &packages[*r & RAZOR_ENTRY_MASK];
  1171 		printf("%s-%s\n", &pool[p->name], &pool[p->version]);
  1172 		if (*r++ & RAZOR_IMMEDIATE)
  1173 			break;
  1174 	}
  1175 }
  1176 
  1177 static unsigned long *
  1178 list_package_files(struct razor_set *set, unsigned long *r,
  1179 		   struct razor_entry *dir, unsigned long end,
  1180 		   char *prefix)
  1181 {
  1182 	struct razor_entry *e, *f, *entries;
  1183 	unsigned long next, file;
  1184 	char *pool;
  1185 	int len;
  1186 	
  1187 	entries = (struct razor_entry *) set->files.data;
  1188 	pool = set->string_pool.data;
  1189 
  1190 	e = entries + dir->start;
  1191 	do {
  1192 		if (entries + (*r & RAZOR_ENTRY_MASK) == e) {
  1193 			printf("%s/%s\n", prefix,
  1194 			       pool + (e->name & RAZOR_ENTRY_MASK));
  1195 			if (*r & RAZOR_ENTRY_LAST)
  1196 				return NULL;
  1197 			r++;
  1198 			if ((*r & RAZOR_ENTRY_MASK) >= end)
  1199 				return r;
  1200 		}
  1201 	} while (!((e++)->name & RAZOR_ENTRY_LAST));
  1202 
  1203 	e = entries + dir->start;
  1204 	do {
  1205 		if (e->start == 0)
  1206 			continue;
  1207 
  1208 		if (e->name & RAZOR_ENTRY_LAST)
  1209 			next = end;
  1210 		else {
  1211 			f = e + 1; 
  1212 			while (f->start == 0 && !(f->name & RAZOR_ENTRY_LAST))
  1213 				f++;
  1214 			if (f->start == 0)
  1215 				next = end;
  1216 			else
  1217 				next = f->start;
  1218 		}
  1219 
  1220 		file = *r & RAZOR_ENTRY_MASK;
  1221 		if (e->start <= file && file < next) {
  1222 			len = strlen(prefix);
  1223 			prefix[len] = '/';
  1224 			strcpy(prefix + len + 1,
  1225 			       pool + (e->name & RAZOR_ENTRY_MASK));
  1226 			r = list_package_files(set, r, e, next, prefix);
  1227 			prefix[len] = '\0';
  1228 		}
  1229 	} while (!((e++)->name & RAZOR_ENTRY_LAST) && r != NULL);
  1230 
  1231 	return r;
  1232 }
  1233 
  1234 void
  1235 razor_set_list_package_files(struct razor_set *set, const char *name)
  1236 {
  1237 	struct razor_package *package;
  1238 	unsigned long *r, end;
  1239 	char buffer[512];
  1240 
  1241 	package = razor_set_get_package(set, name);
  1242 
  1243 	r = (unsigned long *) set->file_pool.data + package->files;
  1244 	end = set->files.size / sizeof (struct razor_entry);
  1245 	buffer[0] = '\0';
  1246 	list_package_files(set, r, set->files.data, end, buffer);
  1247 }
  1248 
  1249 static void
  1250 razor_set_validate(struct razor_set *set, struct array *unsatisfied)
  1251 {
  1252 	struct razor_property *r, *p, *end;
  1253 	unsigned long *u;
  1254 	char *pool;
  1255 
  1256 	end = set->properties.data + set->properties.size;
  1257 	pool = set->string_pool.data;
  1258 	
  1259 	for (r = set->properties.data, p = r; r < end; r++) {
  1260 		if (r->name >> 30 != RAZOR_PROPERTY_REQUIRES)
  1261 			continue;
  1262 
  1263 		if ((r->name & RAZOR_ENTRY_MASK) != (p->name & RAZOR_ENTRY_MASK)) {
  1264 			p = r;
  1265 			while (p < end && p->name == r->name)
  1266 				p++;
  1267 		}
  1268 
  1269 		/* If there is more than one version of a provides,
  1270 		 * seek to the end for the highest version. */
  1271 		/* FIXME: This doesn't work if we have a series of
  1272 		 * requires a = 1, provides a = 1, requires a = 2,
  1273 		 * provides a = 2, as the kernel and kernel-devel
  1274 		 * does.*/
  1275 		while (p + 1 < end && p->name == (p + 1)->name)
  1276 			p++;
  1277 
  1278 		/* FIXME: We need to track property flags (<, <=, =
  1279 		 * etc) to properly determine if a requires is
  1280 		 * satisfied.  The current code doesn't track that the
  1281 		 * requires a = 1 isn't satisfied by a = 2 provides. */
  1282 
  1283 		if (p == end ||
  1284 		    (p->name >> 30) != RAZOR_PROPERTY_PROVIDES ||
  1285 		    (r->name & RAZOR_ENTRY_MASK) != (p->name & RAZOR_ENTRY_MASK) ||
  1286 		    versioncmp(&pool[r->version], &pool[p->version]) > 0) {
  1287 			/* FIXME: We ignore file requires for now. */
  1288 			if (pool[r->name & RAZOR_ENTRY_MASK] == '/')
  1289 				continue;
  1290 			u = array_add(unsatisfied, sizeof *u);
  1291 			*u = r - (struct razor_property *) set->properties.data;
  1292 		}
  1293 	}
  1294 }
  1295 
  1296 void
  1297 razor_set_list_unsatisfied(struct razor_set *set)
  1298 {
  1299 	struct array unsatisfied;
  1300 	struct razor_property *properties, *r;
  1301 	unsigned long *u, *end;
  1302 	char *pool;
  1303 
  1304 	array_init(&unsatisfied);
  1305 	razor_set_validate(set, &unsatisfied);
  1306 
  1307 	end = unsatisfied.data + unsatisfied.size;
  1308 	properties = set->properties.data;
  1309 	pool = set->string_pool.data;
  1310 
  1311 	for (u = unsatisfied.data; u < end; u++) {
  1312 		r = properties + *u;
  1313 		if (pool[r->version] == '\0')
  1314 			printf("%ss not satisfied\n",
  1315 			       &pool[r->name & RAZOR_ENTRY_MASK]);
  1316 		else
  1317 			printf("%s-%s not satisfied\n",
  1318 			       &pool[r->name & RAZOR_ENTRY_MASK],
  1319 			       &pool[r->version]);
  1320 	}
  1321 
  1322 	array_release(&unsatisfied);
  1323 }
  1324 
  1325 #define UPSTREAM_SOURCE 0x80000000ul
  1326 #define INDEX_MASK 0x00fffffful
  1327 
  1328 struct source {
  1329 	struct razor_set *set;
  1330 	unsigned long *property_map;
  1331 };
  1332 
  1333 struct razor_merger {
  1334 	struct razor_set *set;
  1335 	struct hashtable table;
  1336 	struct source source1;
  1337 	struct source source2;
  1338 };
  1339 
  1340 static struct razor_merger *
  1341 razor_merger_create(struct razor_set *set1, struct razor_set *set2)
  1342 {
  1343 	struct razor_merger *merger;
  1344 	int count;
  1345 	size_t size;
  1346 
  1347 	merger = zalloc(sizeof *merger);
  1348 	merger->set = razor_set_create();
  1349 	hashtable_init(&merger->table, &merger->set->string_pool);
  1350 
  1351 	count = set1->properties.size / sizeof (struct razor_property);
  1352 	size = count * sizeof merger->source1.property_map[0];
  1353 	merger->source1.property_map = zalloc(size);
  1354 	merger->source1.set = set1;
  1355 
  1356 	count = set2->properties.size / sizeof (struct razor_property);
  1357 	size = count * sizeof merger->source2.property_map[0];
  1358 	merger->source2.property_map = zalloc(size);
  1359 	merger->source2.set = set2;
  1360 
  1361 	return merger;
  1362 }
  1363 
  1364 static void
  1365 add_package(struct razor_merger *merger,
  1366 	    struct razor_package *package, struct source *source,
  1367 	    unsigned long flags)
  1368 {
  1369 	char *pool;
  1370 	unsigned long *r;
  1371 	struct razor_package *p;
  1372 
  1373 	pool = source->set->string_pool.data;
  1374 	p = array_add(&merger->set->packages, sizeof *p);
  1375 	p->name = hashtable_tokenize(&merger->table, &pool[package->name]);
  1376 	p->name |= flags;
  1377 	p->version = hashtable_tokenize(&merger->table,
  1378 					&pool[package->version]);
  1379 	p->properties = package->properties;
  1380 
  1381 	if (package->properties & RAZOR_IMMEDIATE)
  1382 		r = &package->properties;
  1383 	else
  1384 		r = (unsigned long *)
  1385 			source->set->property_pool.data + package->properties;
  1386 	while (1) {
  1387 		source->property_map[*r & RAZOR_ENTRY_MASK] = 1;
  1388 		if (*r++ & RAZOR_IMMEDIATE)
  1389 			break;
  1390 	}
  1391 }
  1392 
  1393 
  1394 /* Build the new package list sorted by merging the two package lists.
  1395  * Build new string pool as we go. */
  1396 static void
  1397 merge_packages(struct razor_merger *merger, struct array *packages)
  1398 {
  1399 	struct razor_package *upstream_packages, *p, *s, *send;
  1400 	struct source *source1, *source2;
  1401 	char *spool, *upool;
  1402 	unsigned long *u, *uend;
  1403 	int cmp;
  1404 
  1405 	source1 = &merger->source1;
  1406 	source2 = &merger->source2;
  1407 	upstream_packages = source2->set->packages.data;
  1408 
  1409 	u = packages->data;
  1410 	uend = packages->data + packages->size;
  1411 	upool = source2->set->string_pool.data;
  1412 
  1413 	s = source1->set->packages.data;
  1414 	send = source1->set->packages.data + source1->set->packages.size;
  1415 	spool = source1->set->string_pool.data;
  1416 
  1417 	while (s < send) {
  1418 		p = upstream_packages + *u;
  1419 
  1420 		if (u < uend)
  1421 			cmp = strcmp(&spool[s->name], &upool[p->name]);
  1422 		if (u >= uend || cmp < 0) {
  1423 			add_package(merger, s, source1, 0);
  1424 			s++;
  1425 		} else if (cmp == 0) {
  1426 			add_package(merger, p, source2, UPSTREAM_SOURCE);
  1427 			s++;
  1428 			u++;
  1429 		} else {
  1430 			add_package(merger, p, source2, UPSTREAM_SOURCE);
  1431 			u++;
  1432 		}
  1433 	}
  1434 }
  1435 
  1436 static unsigned long
  1437 add_property(struct razor_merger *merger,
  1438 	     const char *name, const char *version, int type)
  1439 {
  1440 	struct razor_property *p;
  1441 
  1442 	p = array_add(&merger->set->properties, sizeof *p);
  1443 	p->name = hashtable_tokenize(&merger->table, name) | (type << 30);
  1444 	p->version = hashtable_tokenize(&merger->table, version);
  1445 
  1446 	return p - (struct razor_property *) merger->set->properties.data;
  1447 }
  1448 
  1449 static void
  1450 merge_properties(struct razor_merger *merger)
  1451 {
  1452 	struct razor_property *p1, *p2;
  1453 	struct razor_set *set1, *set2;
  1454 	unsigned long *map1, *map2;
  1455 	int i, j, cmp, count1, count2;
  1456 	char *pool1, *pool2;
  1457 
  1458 	set1 = merger->source1.set;
  1459 	set2 = merger->source2.set;
  1460 	map1 = merger->source1.property_map;
  1461 	map2 = merger->source2.property_map;
  1462 
  1463 	i = 0;
  1464 	j = 0;
  1465 	pool1 = set1->string_pool.data;
  1466 	pool2 = set2->string_pool.data;
  1467 
  1468 	count1 = set1->properties.size / sizeof *p1;
  1469 	count2 = set2->properties.size / sizeof *p2;
  1470 	while (i < count1 || j < count2) {
  1471 		if (i < count1 && map1[i] == 0) {
  1472 			i++;
  1473 			continue;
  1474 		}
  1475 		if (j < count2 && map2[j] == 0) {
  1476 			j++;
  1477 			continue;
  1478 		}
  1479 		p1 = (struct razor_property *) set1->properties.data + i;
  1480 		p2 = (struct razor_property *) set2->properties.data + j;
  1481 		if (i < count1 && j < count2)
  1482 			cmp = strcmp(&pool1[p1->name & RAZOR_ENTRY_MASK],
  1483 				     &pool2[p2->name & RAZOR_ENTRY_MASK]);
  1484 		else if (i < count1)
  1485 			cmp = -1;
  1486 		else
  1487 			cmp = 1;
  1488 		if (cmp == 0)
  1489 			cmp = versioncmp(&pool1[p1->version],
  1490 					 &pool2[p2->version]);
  1491 		if (cmp < 0) {
  1492 			map1[i++] = add_property(merger,
  1493 						 &pool1[p1->name & RAZOR_ENTRY_MASK],
  1494 						 &pool1[p1->version],
  1495 						 (p1->name >> 30));
  1496 		} else if (cmp > 0) {
  1497 			map2[j++] = add_property(merger,
  1498 						 &pool2[p2->name & RAZOR_ENTRY_MASK],
  1499 						 &pool2[p2->version],
  1500 						 (p2->name >> 30));
  1501 		} else  {
  1502 			map1[i++] = map2[j++] = add_property(merger,
  1503 							     &pool1[p1->name & RAZOR_ENTRY_MASK],
  1504 							     &pool1[p1->version],
  1505 							     (p1->name >> 30));
  1506 		}
  1507 	}
  1508 }
  1509 
  1510 static unsigned long
  1511 emit_properties(struct array *source_pool, unsigned long index,
  1512 		unsigned long *map, struct array *pool)
  1513 {
  1514 	unsigned long r, *p, *q;
  1515 
  1516 	r = pool->size / sizeof *q;
  1517 	p = (unsigned long *) source_pool->data + index;
  1518 	while (1) {
  1519 		q = array_add(pool, sizeof *q);
  1520 		*q = map[*p & RAZOR_ENTRY_MASK] | (*p & ~RAZOR_ENTRY_MASK);
  1521 		if (*p++ & RAZOR_ENTRY_LAST)
  1522 			break;
  1523 	}
  1524 
  1525 	return r;
  1526 }
  1527 	
  1528 /* Rebuild property->packages maps.  We can't just remap these, as a
  1529  * property may have lost or gained a number of packages.  Allocate an
  1530  * array per property and loop through the packages and add them to
  1531  * the arrays for their properties. */
  1532 static void
  1533 rebuild_package_lists(struct razor_set *set)
  1534 {
  1535 	struct array *pkgs, *a;
  1536 	struct razor_package *pkg, *pkg_end;
  1537 	struct razor_property *prop, *prop_end;
  1538 	unsigned long *r, *q, *pool;
  1539 	int count;
  1540 
  1541 	count = set->properties.size / sizeof (struct razor_property);
  1542 	pkgs = zalloc(count * sizeof *pkgs);
  1543 	pkg_end = set->packages.data + set->packages.size;
  1544 	pool = set->property_pool.data;
  1545 
  1546 	for (pkg = set->packages.data; pkg < pkg_end; pkg++) {
  1547 		for (r = &pool[pkg->properties]; ; r++) {
  1548 			q = array_add(&pkgs[*r & RAZOR_ENTRY_MASK], sizeof *q);
  1549 			*q = pkg - (struct razor_package *) set->packages.data;
  1550 			if (*r & RAZOR_IMMEDIATE)
  1551 				break;
  1552 		}
  1553 	}
  1554 
  1555 	prop_end = set->properties.data + set->properties.size;
  1556 	a = pkgs;
  1557 	for (prop = set->properties.data; prop < prop_end; prop++, a++) {
  1558 		if (a->size / sizeof *r == 1) {
  1559 			r = a->data;
  1560 			prop->packages = *r | RAZOR_IMMEDIATE;
  1561 		} else {
  1562 			prop->packages =
  1563 				add_to_property_pool(&set->property_pool, a);
  1564 		}
  1565 		array_release(a);
  1566 	}
  1567 	free(pkgs);
  1568 }
  1569 
  1570 struct razor_set *
  1571 razor_merger_finish(struct razor_merger *merger)
  1572 {
  1573 	struct razor_set *result;
  1574 
  1575 	result = merger->set;
  1576 	hashtable_release(&merger->table);
  1577 	free(merger);
  1578 
  1579 	return result;
  1580 }
  1581 
  1582 /* Add packages from 'upstream' to 'set'.  The packages to add are
  1583  * specified by the 'packages' array, which is a sorted list of
  1584  * package indexes.  Returns a newly allocated package set.  Does not
  1585  * enforce validity of the resulting package set.
  1586  *
  1587  * This looks more complicated than it is.  An easy way to merge two
  1588  * package sets would be to just use a razor_importer, but that
  1589  * requires resorting, and is thus O(n log n).  We can do this in a
  1590  * linear sweep, but it gets a little more complicated.
  1591  */
  1592 struct razor_set *
  1593 razor_set_add(struct razor_set *set, struct razor_set *upstream,
  1594 	      struct array *packages)
  1595 {
  1596 	struct razor_merger *merger;
  1597 	struct razor_package *p, *pend;
  1598 
  1599 	merger = razor_merger_create(set, upstream);
  1600 
  1601 	merge_packages(merger, packages);
  1602 
  1603 	/* As we built the package list, we filled out a bitvector of
  1604 	 * the properties that are referenced by the packages in the
  1605 	 * new set.  Now we do a parallel loop through the properties
  1606 	 * and emit those marked in the bit vector to the new set.  In
  1607 	 * the process, we update the bit vector to actually map from
  1608 	 * indices in the old property list to indices in the new
  1609 	 * property list for both sets. */
  1610 
  1611 	merge_properties(merger);
  1612 
  1613 	/* Now we loop through the packages again and emit the
  1614 	 * property lists, remapped to point to the new properties. */
  1615 
  1616 	pend = merger->set->packages.data + merger->set->packages.size;
  1617 	for (p = merger->set->packages.data; p < pend; p++) {
  1618 		struct source *src;
  1619 
  1620 		if (p->name & UPSTREAM_SOURCE)
  1621 			src = &merger->source2;
  1622 		else
  1623 			src = &merger->source1;
  1624 
  1625 		p->properties = emit_properties(&src->set->property_pool,
  1626 						p->properties,
  1627 						src->property_map,
  1628 						&merger->set->property_pool);
  1629 		p->name &= INDEX_MASK;
  1630 	}
  1631 
  1632 	rebuild_package_lists(merger->set);
  1633 
  1634 	return razor_merger_finish(merger);
  1635 }
  1636 
  1637 void
  1638 razor_set_satisfy(struct razor_set *set, struct array *unsatisfied,
  1639 		  struct razor_set *upstream, struct array *list)
  1640 {
  1641 	struct razor_property *requires, *r;
  1642 	struct razor_property *p, *pend;
  1643 	unsigned long *u, *end, *pkg, *package_pool;
  1644 	char *pool, *upool;
  1645 
  1646 	end = unsatisfied->data + unsatisfied->size;
  1647 	requires = set->properties.data;
  1648 	pool = set->string_pool.data;
  1649 
  1650 	p = upstream->properties.data;
  1651 	pend = upstream->properties.data + upstream->properties.size;
  1652 	upool = upstream->string_pool.data;
  1653 	package_pool = upstream->package_pool.data;
  1654 
  1655 	for (u = unsatisfied->data; u < end; u++) {
  1656 		r = requires + *u;
  1657 
  1658 		while (p < pend &&
  1659 		       strcmp(&pool[r->name & RAZOR_ENTRY_MASK],
  1660 			      &upool[p->name & RAZOR_ENTRY_MASK]) > 0 &&
  1661 		       (p->name >> 30) != RAZOR_PROPERTY_PROVIDES)
  1662 			p++;
  1663 		/* If there is more than one version of a provides,
  1664 		 * seek to the end for the highest version. */
  1665 		while (p + 1 < pend && p->name == (p + 1)->name)
  1666 			p++;
  1667 
  1668 		if (p == pend ||
  1669 		    strcmp(&pool[r->name & RAZOR_ENTRY_MASK],
  1670 			   &upool[p->name & RAZOR_ENTRY_MASK]) != 0 ||
  1671 		    versioncmp(&pool[r->version], &upool[p->version]) > 0) {
  1672 			/* Do we need to track unsatisfiable requires
  1673 			 * as we go, or should we just do a
  1674 			 * razor_set_validate() at the end? */
  1675 		} else {
  1676 			pkg = array_add(list, sizeof *pkg);
  1677 			/* We just pull in the first package that provides */
  1678 			if (p->packages & RAZOR_IMMEDIATE)
  1679 				*pkg = p->packages & RAZOR_ENTRY_MASK;
  1680 			else
  1681 				*pkg = package_pool[p->packages];
  1682 		}
  1683 	}	
  1684 }
  1685 
  1686 static void
  1687 find_packages(struct razor_set *set,
  1688 	      int count, const char **packages, struct array *list)
  1689 {
  1690 	struct razor_package *p;
  1691 	unsigned long *r;
  1692 	int i;
  1693 
  1694 	/* FIXME: Sort the packages. */
  1695 	for (i = 0; i < count; i++) {
  1696 		p = razor_set_get_package(set, packages[i]);
  1697 		r = array_add(list, sizeof *r);
  1698 		*r = p - (struct razor_package *) set->packages.data;
  1699 	}
  1700 }
  1701 
  1702 static void
  1703 find_all_packages(struct razor_set *set,
  1704 		  struct razor_set *upstream, struct array *list)
  1705 {
  1706 	struct razor_package *p, *u, *pend, *uend;
  1707 	unsigned long *r;
  1708 	char *pool, *upool;
  1709 
  1710 	pend = set->packages.data + set->packages.size;
  1711 	pool = set->string_pool.data;
  1712 	u = upstream->packages.data;
  1713 	uend = upstream->packages.data + upstream->packages.size;
  1714 	upool = upstream->string_pool.data;
  1715 
  1716 	for (p = set->packages.data; p < pend; p++) {
  1717 		while (u < uend && strcmp(&pool[p->name], &upool[u->name]) > 0)
  1718 			u++;
  1719 		if (strcmp(&pool[p->name], &upool[u->name]) == 0) {
  1720 			r = array_add(list, sizeof *r);
  1721 			*r = u - (struct razor_package *) upstream->packages.data;
  1722 		}
  1723 	}
  1724 }
  1725 
  1726 struct razor_set *
  1727 razor_set_update(struct razor_set *set, struct razor_set *upstream,
  1728 		 int count, const char **packages)
  1729 {
  1730 	struct razor_set *new;
  1731 	struct razor_package *upackages;
  1732 	struct array list, unsatisfied;
  1733 	char *pool;
  1734 	unsigned long *u, *end;
  1735 	int total = 0;
  1736 
  1737 	array_init(&list);
  1738 	if (count > 0)
  1739 		find_packages(upstream, count, packages, &list);
  1740 	else
  1741 		find_all_packages(set, upstream, &list);
  1742 
  1743 	end = list.data + list.size;
  1744 	upackages = upstream->packages.data;
  1745 	pool = upstream->string_pool.data;
  1746 	total += list.size / sizeof *u;
  1747 
  1748 	while (list.size > 0) {
  1749 		new = razor_set_add(set, upstream, &list);
  1750 		array_release(&list);
  1751 		razor_set_destroy(set);
  1752 		set = new;
  1753 
  1754 		array_init(&unsatisfied);
  1755 		razor_set_validate(new, &unsatisfied);
  1756 		array_init(&list);
  1757 		razor_set_satisfy(new, &unsatisfied, upstream, &list);
  1758 		array_release(&unsatisfied);
  1759 
  1760 		end = list.data + list.size;
  1761 		upackages = upstream->packages.data;
  1762 		pool = upstream->string_pool.data;
  1763 		total += list.size / sizeof *u;
  1764 	}
  1765 
  1766 	array_release(&list);
  1767 
  1768 	return set;
  1769 }
  1770 
  1771 /* The diff order matters.  We should sort the packages so that a
  1772  * REMOVE of a package comes before the INSTALL, and so that all
  1773  * requires for a package have been installed before the package.
  1774  **/
  1775 
  1776 void
  1777 razor_set_diff(struct razor_set *set, struct razor_set *upstream,
  1778 	       razor_package_callback_t callback, void *data)
  1779 {
  1780 	struct razor_package *p, *pend, *u, *uend;
  1781 	char *ppool, *upool;
  1782 	int res = 0;
  1783 
  1784 	p = set->packages.data;
  1785 	pend = set->packages.data + set->packages.size;
  1786 	ppool = set->string_pool.data;
  1787 
  1788 	u = upstream->packages.data;
  1789 	uend = upstream->packages.data + upstream->packages.size;
  1790 	upool = upstream->string_pool.data;
  1791 
  1792 	while (p < pend || u < uend) {
  1793 		if (p < pend && u < uend) {
  1794 			res = strcmp(&ppool[p->name], &upool[u->name]);
  1795 			if (res == 0)
  1796 				res = versioncmp(&ppool[p->version],
  1797 						 &upool[u->version]);
  1798 		}
  1799 
  1800 		if (u == uend || res < 0) {
  1801 			callback(&ppool[p->name], &ppool[p->version],
  1802 				 NULL, data);
  1803 			p++;
  1804 			continue;
  1805 		} else if (p == pend || res > 0) {
  1806 			callback(&upool[u->name], NULL, &upool[u->version],
  1807 				 data);
  1808 			u++;
  1809 			continue;
  1810 		} else {
  1811 			p++;
  1812 			u++;
  1813 		}
  1814 	}
  1815 }