razor.c
author Kristian H?gsberg <krh@redhat.com>
Mon Jan 21 23:02:47 2008 -0500 (2008-01-21)
changeset 104 705f6dbf0a7e
parent 102 337a7a55e2c6
child 105 2ddc6448762e
permissions -rw-r--r--
Factor out property importing for rpm importer.
     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 	unsigned long *index;
   942 	int last;
   943 };
   944 
   945 struct razor_package_iterator *
   946 razor_package_iterator_create_with_index(struct razor_set *set,
   947 					 unsigned long *index)
   948 {
   949 	struct razor_package_iterator *pi;
   950 
   951 	pi = zalloc(sizeof *pi);
   952 	pi->set = set;
   953 	pi->end = set->packages.data + set->packages.size;
   954 	pi->package = set->packages.data;
   955 	pi->index = index;
   956 
   957 	return pi;
   958 }
   959 
   960 struct razor_package_iterator *
   961 razor_package_iterator_create(struct razor_set *set)
   962 {
   963 	return razor_package_iterator_create_with_index(set, NULL);
   964 }
   965 
   966 struct razor_package_iterator *
   967 razor_package_iterator_create_for_property(struct razor_set *set,
   968 					   struct razor_property *property)
   969 {
   970 	unsigned long *index;
   971 
   972 	if (property->packages & RAZOR_IMMEDIATE)
   973 		index = &property->packages;
   974 	else
   975 		index = (unsigned long *)
   976 			set->package_pool.data + property->packages;
   977 
   978 	return razor_package_iterator_create_with_index(set, index);
   979 }
   980 
   981 int
   982 razor_package_iterator_next(struct razor_package_iterator *pi,
   983 			    struct razor_package **package,
   984 			    const char **name, const char **version)
   985 {
   986 	char *pool;
   987 	int valid;
   988 	struct razor_package *p, *packages;
   989 
   990 	if (pi->index) {
   991 		packages = pi->set->packages.data;
   992 		p = &packages[*pi->index & RAZOR_ENTRY_MASK];
   993 		valid = !pi->last;
   994 		pi->last = (*pi->index++ & RAZOR_IMMEDIATE) != 0;
   995 	} else {
   996 		p = pi->package++;
   997 		valid = p < pi->end;
   998 	}			
   999 
  1000 	if (valid) {
  1001 		pool = pi->set->string_pool.data;
  1002 		*package = p;
  1003 		*name = &pool[p->name & RAZOR_ENTRY_MASK];
  1004 		*version = &pool[p->version];
  1005 	} else {
  1006 		*package = NULL;
  1007 	}
  1008 
  1009 	return valid;
  1010 }
  1011 
  1012 void
  1013 razor_package_iterator_destroy(struct razor_package_iterator *pi)
  1014 {
  1015 	free(pi);
  1016 }
  1017 
  1018 struct razor_package *
  1019 razor_set_get_package(struct razor_set *set, const char *package)
  1020 {
  1021 	struct razor_package_iterator *pi;
  1022 	struct razor_package *p;
  1023 	const char *name, *version;
  1024 
  1025 	pi = razor_package_iterator_create(set);
  1026 	while (razor_package_iterator_next(pi, &p, &name, &version)) {
  1027 		if (strcmp(package, name) == 0)
  1028 			break;
  1029 	}
  1030 	razor_package_iterator_destroy(pi);
  1031 
  1032 	return p;
  1033 }
  1034 
  1035 struct razor_property_iterator {
  1036 	struct razor_set *set;
  1037 	struct razor_property *property, *end;
  1038 	unsigned long *index;
  1039 	int last;
  1040 };
  1041 
  1042 struct razor_property_iterator *
  1043 razor_property_iterator_create(struct razor_set *set,
  1044 			       struct razor_package *package)
  1045 {
  1046 	struct razor_property_iterator *pi;
  1047 
  1048 	pi = zalloc(sizeof *pi);
  1049 	pi->set = set;
  1050 	pi->end = set->properties.data + set->properties.size;
  1051 	pi->property = set->properties.data;
  1052 
  1053 	if (package)
  1054 		pi->index = (unsigned long *)
  1055 			set->property_pool.data + package->properties;
  1056 
  1057 	return pi;
  1058 }
  1059 
  1060 int
  1061 razor_property_iterator_next(struct razor_property_iterator *pi,
  1062 			     struct razor_property **property,
  1063 			     const char **name, const char **version,
  1064 			     enum razor_property_type *type)
  1065 {
  1066 	char *pool;
  1067 	int valid;
  1068 	struct razor_property *p, *properties;
  1069 
  1070 	if (pi->index) {
  1071 		properties = pi->set->properties.data;
  1072 		p = &properties[*pi->index & RAZOR_ENTRY_MASK];
  1073 		valid = !pi->last;
  1074 		pi->last = (*pi->index++ & RAZOR_IMMEDIATE) != 0;
  1075 	} else {
  1076 		p = pi->property++;
  1077 		valid = p < pi->end;
  1078 	}			
  1079 
  1080 	if (valid) {
  1081 		pool = pi->set->string_pool.data;
  1082 		*property = p;
  1083 		*name = &pool[p->name & RAZOR_ENTRY_MASK];
  1084 		*version = &pool[p->version];
  1085 		*type = p->name >> 30;
  1086 	} else {
  1087 		*property = NULL;
  1088 	}
  1089 
  1090 	return valid;
  1091 }
  1092 
  1093 void
  1094 razor_property_iterator_destroy(struct razor_property_iterator *pi)
  1095 {
  1096 	free(pi);
  1097 }
  1098 
  1099 static struct razor_entry *
  1100 find_entry(struct razor_set *set, struct razor_entry *dir, const char *pattern)
  1101 {
  1102 	struct razor_entry *e;
  1103 	const char *n, *pool = set->string_pool.data;
  1104 	int len;
  1105 
  1106 	e = (struct razor_entry *) set->files.data + dir->start;
  1107 	do {
  1108 		n = pool + (e->name & RAZOR_ENTRY_MASK);
  1109 		if (strcmp(pattern + 1, n) == 0)
  1110 			return e;
  1111 		len = strlen(n);
  1112 		if (e->start != 0 && strncmp(pattern + 1, n, len) == 0 &&
  1113 		    pattern[len + 1] == '/') {
  1114 			return find_entry(set, e, pattern + len + 1);
  1115 		}
  1116 	} while (((e++)->name & RAZOR_ENTRY_LAST) == 0);
  1117 
  1118 	return NULL;
  1119 }
  1120 
  1121 static void
  1122 list_dir(struct razor_set *set, struct razor_entry *dir,
  1123 	 const char *prefix, const char *pattern)
  1124 {
  1125 	struct razor_entry *e;
  1126 	const char *n, *pool = set->string_pool.data;
  1127 
  1128 	e = (struct razor_entry *) set->files.data + dir->start;
  1129 	do {
  1130 		n = pool + (e->name & RAZOR_ENTRY_MASK);
  1131 		if (pattern && pattern[0] && fnmatch(pattern, n, 0) != 0)
  1132 			continue;
  1133 		printf("%s/%s%s\n", prefix, n, e->start > 0 ? "/" : "");
  1134 	} while (((e++)->name & RAZOR_ENTRY_LAST) == 0);
  1135 }
  1136 
  1137 void
  1138 razor_set_list_files(struct razor_set *set, const char *pattern)
  1139 {
  1140 	struct razor_entry *e;
  1141 	char buffer[512], *p, *base;
  1142 
  1143 	if (pattern == NULL)
  1144 		pattern = "/";
  1145 
  1146 	strcpy(buffer, pattern);
  1147 	e = find_entry(set, set->files.data, buffer);
  1148 	if (e && e->start > 0) {
  1149 		base = NULL;
  1150 	} else {
  1151 		p = strrchr(buffer, '/');
  1152 		if (p) {
  1153 			*p = '\0';
  1154 			base = p + 1;
  1155 		} else {
  1156 			base = NULL;
  1157 		}
  1158 	}
  1159 	e = find_entry(set, set->files.data, buffer);
  1160 	if (e->start != 0)
  1161 		list_dir(set, e, buffer, base);
  1162 }
  1163 
  1164 struct razor_package_iterator *
  1165 razor_package_iterator_create_for_file(struct razor_set *set,
  1166 				       const char *filename)
  1167 {
  1168 	struct razor_entry *entry;
  1169 	unsigned long *index;
  1170 
  1171 	entry = find_entry(set, set->files.data, filename);
  1172 	if (entry == NULL)
  1173 		return NULL;
  1174 	
  1175 	if (entry->packages & RAZOR_IMMEDIATE)
  1176 		index = &entry->packages;
  1177 	else
  1178 		index = (unsigned long *)
  1179 			set->package_pool.data + entry->packages;
  1180 
  1181 	return razor_package_iterator_create_with_index(set, index);
  1182 }
  1183 
  1184 static unsigned long *
  1185 list_package_files(struct razor_set *set, unsigned long *r,
  1186 		   struct razor_entry *dir, unsigned long end,
  1187 		   char *prefix)
  1188 {
  1189 	struct razor_entry *e, *f, *entries;
  1190 	unsigned long next, file;
  1191 	char *pool;
  1192 	int len;
  1193 	
  1194 	entries = (struct razor_entry *) set->files.data;
  1195 	pool = set->string_pool.data;
  1196 
  1197 	e = entries + dir->start;
  1198 	do {
  1199 		if (entries + (*r & RAZOR_ENTRY_MASK) == e) {
  1200 			printf("%s/%s\n", prefix,
  1201 			       pool + (e->name & RAZOR_ENTRY_MASK));
  1202 			if (*r & RAZOR_ENTRY_LAST)
  1203 				return NULL;
  1204 			r++;
  1205 			if ((*r & RAZOR_ENTRY_MASK) >= end)
  1206 				return r;
  1207 		}
  1208 	} while (!((e++)->name & RAZOR_ENTRY_LAST));
  1209 
  1210 	e = entries + dir->start;
  1211 	do {
  1212 		if (e->start == 0)
  1213 			continue;
  1214 
  1215 		if (e->name & RAZOR_ENTRY_LAST)
  1216 			next = end;
  1217 		else {
  1218 			f = e + 1; 
  1219 			while (f->start == 0 && !(f->name & RAZOR_ENTRY_LAST))
  1220 				f++;
  1221 			if (f->start == 0)
  1222 				next = end;
  1223 			else
  1224 				next = f->start;
  1225 		}
  1226 
  1227 		file = *r & RAZOR_ENTRY_MASK;
  1228 		if (e->start <= file && file < next) {
  1229 			len = strlen(prefix);
  1230 			prefix[len] = '/';
  1231 			strcpy(prefix + len + 1,
  1232 			       pool + (e->name & RAZOR_ENTRY_MASK));
  1233 			r = list_package_files(set, r, e, next, prefix);
  1234 			prefix[len] = '\0';
  1235 		}
  1236 	} while (!((e++)->name & RAZOR_ENTRY_LAST) && r != NULL);
  1237 
  1238 	return r;
  1239 }
  1240 
  1241 void
  1242 razor_set_list_package_files(struct razor_set *set, const char *name)
  1243 {
  1244 	struct razor_package *package;
  1245 	unsigned long *r, end;
  1246 	char buffer[512];
  1247 
  1248 	package = razor_set_get_package(set, name);
  1249 
  1250 	r = (unsigned long *) set->file_pool.data + package->files;
  1251 	end = set->files.size / sizeof (struct razor_entry);
  1252 	buffer[0] = '\0';
  1253 	list_package_files(set, r, set->files.data, end, buffer);
  1254 }
  1255 
  1256 static void
  1257 razor_set_validate(struct razor_set *set, struct array *unsatisfied)
  1258 {
  1259 	struct razor_property *r, *p, *end;
  1260 	unsigned long *u;
  1261 	char *pool;
  1262 
  1263 	end = set->properties.data + set->properties.size;
  1264 	pool = set->string_pool.data;
  1265 	
  1266 	for (r = set->properties.data, p = r; r < end; r++) {
  1267 		if (r->name >> 30 != RAZOR_PROPERTY_REQUIRES)
  1268 			continue;
  1269 
  1270 		if ((r->name & RAZOR_ENTRY_MASK) != (p->name & RAZOR_ENTRY_MASK)) {
  1271 			p = r;
  1272 			while (p < end && p->name == r->name)
  1273 				p++;
  1274 		}
  1275 
  1276 		/* If there is more than one version of a provides,
  1277 		 * seek to the end for the highest version. */
  1278 		/* FIXME: This doesn't work if we have a series of
  1279 		 * requires a = 1, provides a = 1, requires a = 2,
  1280 		 * provides a = 2, as the kernel and kernel-devel
  1281 		 * does.*/
  1282 		while (p + 1 < end && p->name == (p + 1)->name)
  1283 			p++;
  1284 
  1285 		/* FIXME: We need to track property flags (<, <=, =
  1286 		 * etc) to properly determine if a requires is
  1287 		 * satisfied.  The current code doesn't track that the
  1288 		 * requires a = 1 isn't satisfied by a = 2 provides. */
  1289 
  1290 		if (p == end ||
  1291 		    (p->name >> 30) != RAZOR_PROPERTY_PROVIDES ||
  1292 		    (r->name & RAZOR_ENTRY_MASK) != (p->name & RAZOR_ENTRY_MASK) ||
  1293 		    versioncmp(&pool[r->version], &pool[p->version]) > 0) {
  1294 			/* FIXME: We ignore file requires for now. */
  1295 			if (pool[r->name & RAZOR_ENTRY_MASK] == '/')
  1296 				continue;
  1297 			u = array_add(unsatisfied, sizeof *u);
  1298 			*u = r - (struct razor_property *) set->properties.data;
  1299 		}
  1300 	}
  1301 }
  1302 
  1303 void
  1304 razor_set_list_unsatisfied(struct razor_set *set)
  1305 {
  1306 	struct array unsatisfied;
  1307 	struct razor_property *properties, *r;
  1308 	unsigned long *u, *end;
  1309 	char *pool;
  1310 
  1311 	array_init(&unsatisfied);
  1312 	razor_set_validate(set, &unsatisfied);
  1313 
  1314 	end = unsatisfied.data + unsatisfied.size;
  1315 	properties = set->properties.data;
  1316 	pool = set->string_pool.data;
  1317 
  1318 	for (u = unsatisfied.data; u < end; u++) {
  1319 		r = properties + *u;
  1320 		if (pool[r->version] == '\0')
  1321 			printf("%ss not satisfied\n",
  1322 			       &pool[r->name & RAZOR_ENTRY_MASK]);
  1323 		else
  1324 			printf("%s-%s not satisfied\n",
  1325 			       &pool[r->name & RAZOR_ENTRY_MASK],
  1326 			       &pool[r->version]);
  1327 	}
  1328 
  1329 	array_release(&unsatisfied);
  1330 }
  1331 
  1332 #define UPSTREAM_SOURCE 0x80000000ul
  1333 #define INDEX_MASK 0x00fffffful
  1334 
  1335 struct source {
  1336 	struct razor_set *set;
  1337 	unsigned long *property_map;
  1338 };
  1339 
  1340 struct razor_merger {
  1341 	struct razor_set *set;
  1342 	struct hashtable table;
  1343 	struct source source1;
  1344 	struct source source2;
  1345 };
  1346 
  1347 static struct razor_merger *
  1348 razor_merger_create(struct razor_set *set1, struct razor_set *set2)
  1349 {
  1350 	struct razor_merger *merger;
  1351 	int count;
  1352 	size_t size;
  1353 
  1354 	merger = zalloc(sizeof *merger);
  1355 	merger->set = razor_set_create();
  1356 	hashtable_init(&merger->table, &merger->set->string_pool);
  1357 
  1358 	count = set1->properties.size / sizeof (struct razor_property);
  1359 	size = count * sizeof merger->source1.property_map[0];
  1360 	merger->source1.property_map = zalloc(size);
  1361 	merger->source1.set = set1;
  1362 
  1363 	count = set2->properties.size / sizeof (struct razor_property);
  1364 	size = count * sizeof merger->source2.property_map[0];
  1365 	merger->source2.property_map = zalloc(size);
  1366 	merger->source2.set = set2;
  1367 
  1368 	return merger;
  1369 }
  1370 
  1371 static void
  1372 add_package(struct razor_merger *merger,
  1373 	    struct razor_package *package, struct source *source,
  1374 	    unsigned long flags)
  1375 {
  1376 	char *pool;
  1377 	unsigned long *r;
  1378 	struct razor_package *p;
  1379 
  1380 	pool = source->set->string_pool.data;
  1381 	p = array_add(&merger->set->packages, sizeof *p);
  1382 	p->name = hashtable_tokenize(&merger->table, &pool[package->name]);
  1383 	p->name |= flags;
  1384 	p->version = hashtable_tokenize(&merger->table,
  1385 					&pool[package->version]);
  1386 	p->properties = package->properties;
  1387 
  1388 	if (package->properties & RAZOR_IMMEDIATE)
  1389 		r = &package->properties;
  1390 	else
  1391 		r = (unsigned long *)
  1392 			source->set->property_pool.data + package->properties;
  1393 	while (1) {
  1394 		source->property_map[*r & RAZOR_ENTRY_MASK] = 1;
  1395 		if (*r++ & RAZOR_IMMEDIATE)
  1396 			break;
  1397 	}
  1398 }
  1399 
  1400 
  1401 /* Build the new package list sorted by merging the two package lists.
  1402  * Build new string pool as we go. */
  1403 static void
  1404 merge_packages(struct razor_merger *merger, struct array *packages)
  1405 {
  1406 	struct razor_package *upstream_packages, *p, *s, *send;
  1407 	struct source *source1, *source2;
  1408 	char *spool, *upool;
  1409 	unsigned long *u, *uend;
  1410 	int cmp;
  1411 
  1412 	source1 = &merger->source1;
  1413 	source2 = &merger->source2;
  1414 	upstream_packages = source2->set->packages.data;
  1415 
  1416 	u = packages->data;
  1417 	uend = packages->data + packages->size;
  1418 	upool = source2->set->string_pool.data;
  1419 
  1420 	s = source1->set->packages.data;
  1421 	send = source1->set->packages.data + source1->set->packages.size;
  1422 	spool = source1->set->string_pool.data;
  1423 
  1424 	while (s < send) {
  1425 		p = upstream_packages + *u;
  1426 
  1427 		if (u < uend)
  1428 			cmp = strcmp(&spool[s->name], &upool[p->name]);
  1429 		if (u >= uend || cmp < 0) {
  1430 			add_package(merger, s, source1, 0);
  1431 			s++;
  1432 		} else if (cmp == 0) {
  1433 			add_package(merger, p, source2, UPSTREAM_SOURCE);
  1434 			s++;
  1435 			u++;
  1436 		} else {
  1437 			add_package(merger, p, source2, UPSTREAM_SOURCE);
  1438 			u++;
  1439 		}
  1440 	}
  1441 }
  1442 
  1443 static unsigned long
  1444 add_property(struct razor_merger *merger,
  1445 	     const char *name, const char *version, int type)
  1446 {
  1447 	struct razor_property *p;
  1448 
  1449 	p = array_add(&merger->set->properties, sizeof *p);
  1450 	p->name = hashtable_tokenize(&merger->table, name) | (type << 30);
  1451 	p->version = hashtable_tokenize(&merger->table, version);
  1452 
  1453 	return p - (struct razor_property *) merger->set->properties.data;
  1454 }
  1455 
  1456 static void
  1457 merge_properties(struct razor_merger *merger)
  1458 {
  1459 	struct razor_property *p1, *p2;
  1460 	struct razor_set *set1, *set2;
  1461 	unsigned long *map1, *map2;
  1462 	int i, j, cmp, count1, count2;
  1463 	char *pool1, *pool2;
  1464 
  1465 	set1 = merger->source1.set;
  1466 	set2 = merger->source2.set;
  1467 	map1 = merger->source1.property_map;
  1468 	map2 = merger->source2.property_map;
  1469 
  1470 	i = 0;
  1471 	j = 0;
  1472 	pool1 = set1->string_pool.data;
  1473 	pool2 = set2->string_pool.data;
  1474 
  1475 	count1 = set1->properties.size / sizeof *p1;
  1476 	count2 = set2->properties.size / sizeof *p2;
  1477 	while (i < count1 || j < count2) {
  1478 		if (i < count1 && map1[i] == 0) {
  1479 			i++;
  1480 			continue;
  1481 		}
  1482 		if (j < count2 && map2[j] == 0) {
  1483 			j++;
  1484 			continue;
  1485 		}
  1486 		p1 = (struct razor_property *) set1->properties.data + i;
  1487 		p2 = (struct razor_property *) set2->properties.data + j;
  1488 		if (i < count1 && j < count2)
  1489 			cmp = strcmp(&pool1[p1->name & RAZOR_ENTRY_MASK],
  1490 				     &pool2[p2->name & RAZOR_ENTRY_MASK]);
  1491 		else if (i < count1)
  1492 			cmp = -1;
  1493 		else
  1494 			cmp = 1;
  1495 		if (cmp == 0)
  1496 			cmp = versioncmp(&pool1[p1->version],
  1497 					 &pool2[p2->version]);
  1498 		if (cmp < 0) {
  1499 			map1[i++] = add_property(merger,
  1500 						 &pool1[p1->name & RAZOR_ENTRY_MASK],
  1501 						 &pool1[p1->version],
  1502 						 (p1->name >> 30));
  1503 		} else if (cmp > 0) {
  1504 			map2[j++] = add_property(merger,
  1505 						 &pool2[p2->name & RAZOR_ENTRY_MASK],
  1506 						 &pool2[p2->version],
  1507 						 (p2->name >> 30));
  1508 		} else  {
  1509 			map1[i++] = map2[j++] = add_property(merger,
  1510 							     &pool1[p1->name & RAZOR_ENTRY_MASK],
  1511 							     &pool1[p1->version],
  1512 							     (p1->name >> 30));
  1513 		}
  1514 	}
  1515 }
  1516 
  1517 static unsigned long
  1518 emit_properties(struct array *source_pool, unsigned long index,
  1519 		unsigned long *map, struct array *pool)
  1520 {
  1521 	unsigned long r, *p, *q;
  1522 
  1523 	r = pool->size / sizeof *q;
  1524 	p = (unsigned long *) source_pool->data + index;
  1525 	while (1) {
  1526 		q = array_add(pool, sizeof *q);
  1527 		*q = map[*p & RAZOR_ENTRY_MASK] | (*p & ~RAZOR_ENTRY_MASK);
  1528 		if (*p++ & RAZOR_ENTRY_LAST)
  1529 			break;
  1530 	}
  1531 
  1532 	return r;
  1533 }
  1534 	
  1535 /* Rebuild property->packages maps.  We can't just remap these, as a
  1536  * property may have lost or gained a number of packages.  Allocate an
  1537  * array per property and loop through the packages and add them to
  1538  * the arrays for their properties. */
  1539 static void
  1540 rebuild_package_lists(struct razor_set *set)
  1541 {
  1542 	struct array *pkgs, *a;
  1543 	struct razor_package *pkg, *pkg_end;
  1544 	struct razor_property *prop, *prop_end;
  1545 	unsigned long *r, *q, *pool;
  1546 	int count;
  1547 
  1548 	count = set->properties.size / sizeof (struct razor_property);
  1549 	pkgs = zalloc(count * sizeof *pkgs);
  1550 	pkg_end = set->packages.data + set->packages.size;
  1551 	pool = set->property_pool.data;
  1552 
  1553 	for (pkg = set->packages.data; pkg < pkg_end; pkg++) {
  1554 		for (r = &pool[pkg->properties]; ; r++) {
  1555 			q = array_add(&pkgs[*r & RAZOR_ENTRY_MASK], sizeof *q);
  1556 			*q = pkg - (struct razor_package *) set->packages.data;
  1557 			if (*r & RAZOR_IMMEDIATE)
  1558 				break;
  1559 		}
  1560 	}
  1561 
  1562 	prop_end = set->properties.data + set->properties.size;
  1563 	a = pkgs;
  1564 	for (prop = set->properties.data; prop < prop_end; prop++, a++) {
  1565 		if (a->size / sizeof *r == 1) {
  1566 			r = a->data;
  1567 			prop->packages = *r | RAZOR_IMMEDIATE;
  1568 		} else {
  1569 			prop->packages =
  1570 				add_to_property_pool(&set->property_pool, a);
  1571 		}
  1572 		array_release(a);
  1573 	}
  1574 	free(pkgs);
  1575 }
  1576 
  1577 struct razor_set *
  1578 razor_merger_finish(struct razor_merger *merger)
  1579 {
  1580 	struct razor_set *result;
  1581 
  1582 	result = merger->set;
  1583 	hashtable_release(&merger->table);
  1584 	free(merger);
  1585 
  1586 	return result;
  1587 }
  1588 
  1589 /* Add packages from 'upstream' to 'set'.  The packages to add are
  1590  * specified by the 'packages' array, which is a sorted list of
  1591  * package indexes.  Returns a newly allocated package set.  Does not
  1592  * enforce validity of the resulting package set.
  1593  *
  1594  * This looks more complicated than it is.  An easy way to merge two
  1595  * package sets would be to just use a razor_importer, but that
  1596  * requires resorting, and is thus O(n log n).  We can do this in a
  1597  * linear sweep, but it gets a little more complicated.
  1598  */
  1599 struct razor_set *
  1600 razor_set_add(struct razor_set *set, struct razor_set *upstream,
  1601 	      struct array *packages)
  1602 {
  1603 	struct razor_merger *merger;
  1604 	struct razor_package *p, *pend;
  1605 
  1606 	merger = razor_merger_create(set, upstream);
  1607 
  1608 	merge_packages(merger, packages);
  1609 
  1610 	/* As we built the package list, we filled out a bitvector of
  1611 	 * the properties that are referenced by the packages in the
  1612 	 * new set.  Now we do a parallel loop through the properties
  1613 	 * and emit those marked in the bit vector to the new set.  In
  1614 	 * the process, we update the bit vector to actually map from
  1615 	 * indices in the old property list to indices in the new
  1616 	 * property list for both sets. */
  1617 
  1618 	merge_properties(merger);
  1619 
  1620 	/* Now we loop through the packages again and emit the
  1621 	 * property lists, remapped to point to the new properties. */
  1622 
  1623 	pend = merger->set->packages.data + merger->set->packages.size;
  1624 	for (p = merger->set->packages.data; p < pend; p++) {
  1625 		struct source *src;
  1626 
  1627 		if (p->name & UPSTREAM_SOURCE)
  1628 			src = &merger->source2;
  1629 		else
  1630 			src = &merger->source1;
  1631 
  1632 		p->properties = emit_properties(&src->set->property_pool,
  1633 						p->properties,
  1634 						src->property_map,
  1635 						&merger->set->property_pool);
  1636 		p->name &= INDEX_MASK;
  1637 	}
  1638 
  1639 	rebuild_package_lists(merger->set);
  1640 
  1641 	return razor_merger_finish(merger);
  1642 }
  1643 
  1644 void
  1645 razor_set_satisfy(struct razor_set *set, struct array *unsatisfied,
  1646 		  struct razor_set *upstream, struct array *list)
  1647 {
  1648 	struct razor_property *requires, *r;
  1649 	struct razor_property *p, *pend;
  1650 	unsigned long *u, *end, *pkg, *package_pool;
  1651 	char *pool, *upool;
  1652 
  1653 	end = unsatisfied->data + unsatisfied->size;
  1654 	requires = set->properties.data;
  1655 	pool = set->string_pool.data;
  1656 
  1657 	p = upstream->properties.data;
  1658 	pend = upstream->properties.data + upstream->properties.size;
  1659 	upool = upstream->string_pool.data;
  1660 	package_pool = upstream->package_pool.data;
  1661 
  1662 	for (u = unsatisfied->data; u < end; u++) {
  1663 		r = requires + *u;
  1664 
  1665 		while (p < pend &&
  1666 		       strcmp(&pool[r->name & RAZOR_ENTRY_MASK],
  1667 			      &upool[p->name & RAZOR_ENTRY_MASK]) > 0 &&
  1668 		       (p->name >> 30) != RAZOR_PROPERTY_PROVIDES)
  1669 			p++;
  1670 		/* If there is more than one version of a provides,
  1671 		 * seek to the end for the highest version. */
  1672 		while (p + 1 < pend && p->name == (p + 1)->name)
  1673 			p++;
  1674 
  1675 		if (p == pend ||
  1676 		    strcmp(&pool[r->name & RAZOR_ENTRY_MASK],
  1677 			   &upool[p->name & RAZOR_ENTRY_MASK]) != 0 ||
  1678 		    versioncmp(&pool[r->version], &upool[p->version]) > 0) {
  1679 			/* Do we need to track unsatisfiable requires
  1680 			 * as we go, or should we just do a
  1681 			 * razor_set_validate() at the end? */
  1682 		} else {
  1683 			pkg = array_add(list, sizeof *pkg);
  1684 			/* We just pull in the first package that provides */
  1685 			if (p->packages & RAZOR_IMMEDIATE)
  1686 				*pkg = p->packages & RAZOR_ENTRY_MASK;
  1687 			else
  1688 				*pkg = package_pool[p->packages];
  1689 		}
  1690 	}	
  1691 }
  1692 
  1693 static void
  1694 find_packages(struct razor_set *set,
  1695 	      int count, const char **packages, struct array *list)
  1696 {
  1697 	struct razor_package *p;
  1698 	unsigned long *r;
  1699 	int i;
  1700 
  1701 	/* FIXME: Sort the packages. */
  1702 	for (i = 0; i < count; i++) {
  1703 		p = razor_set_get_package(set, packages[i]);
  1704 		r = array_add(list, sizeof *r);
  1705 		*r = p - (struct razor_package *) set->packages.data;
  1706 	}
  1707 }
  1708 
  1709 static void
  1710 find_all_packages(struct razor_set *set,
  1711 		  struct razor_set *upstream, struct array *list)
  1712 {
  1713 	struct razor_package *p, *u, *pend, *uend;
  1714 	unsigned long *r;
  1715 	char *pool, *upool;
  1716 
  1717 	pend = set->packages.data + set->packages.size;
  1718 	pool = set->string_pool.data;
  1719 	u = upstream->packages.data;
  1720 	uend = upstream->packages.data + upstream->packages.size;
  1721 	upool = upstream->string_pool.data;
  1722 
  1723 	for (p = set->packages.data; p < pend; p++) {
  1724 		while (u < uend && strcmp(&pool[p->name], &upool[u->name]) > 0)
  1725 			u++;
  1726 		if (strcmp(&pool[p->name], &upool[u->name]) == 0) {
  1727 			r = array_add(list, sizeof *r);
  1728 			*r = u - (struct razor_package *) upstream->packages.data;
  1729 		}
  1730 	}
  1731 }
  1732 
  1733 struct razor_set *
  1734 razor_set_update(struct razor_set *set, struct razor_set *upstream,
  1735 		 int count, const char **packages)
  1736 {
  1737 	struct razor_set *new;
  1738 	struct razor_package *upackages;
  1739 	struct array list, unsatisfied;
  1740 	char *pool;
  1741 	unsigned long *u, *end;
  1742 	int total = 0;
  1743 
  1744 	array_init(&list);
  1745 	if (count > 0)
  1746 		find_packages(upstream, count, packages, &list);
  1747 	else
  1748 		find_all_packages(set, upstream, &list);
  1749 
  1750 	end = list.data + list.size;
  1751 	upackages = upstream->packages.data;
  1752 	pool = upstream->string_pool.data;
  1753 	total += list.size / sizeof *u;
  1754 
  1755 	while (list.size > 0) {
  1756 		new = razor_set_add(set, upstream, &list);
  1757 		array_release(&list);
  1758 		razor_set_destroy(set);
  1759 		set = new;
  1760 
  1761 		array_init(&unsatisfied);
  1762 		razor_set_validate(new, &unsatisfied);
  1763 		array_init(&list);
  1764 		razor_set_satisfy(new, &unsatisfied, upstream, &list);
  1765 		array_release(&unsatisfied);
  1766 
  1767 		end = list.data + list.size;
  1768 		upackages = upstream->packages.data;
  1769 		pool = upstream->string_pool.data;
  1770 		total += list.size / sizeof *u;
  1771 	}
  1772 
  1773 	array_release(&list);
  1774 
  1775 	return set;
  1776 }
  1777 
  1778 /* The diff order matters.  We should sort the packages so that a
  1779  * REMOVE of a package comes before the INSTALL, and so that all
  1780  * requires for a package have been installed before the package.
  1781  **/
  1782 
  1783 void
  1784 razor_set_diff(struct razor_set *set, struct razor_set *upstream,
  1785 	       razor_package_callback_t callback, void *data)
  1786 {
  1787 	struct razor_package_iterator *pi1, *pi2;
  1788 	struct razor_package *p1, *p2;
  1789 	const char *name1, *name2, *version1, *version2;
  1790 	int res = 0;
  1791 
  1792 	pi1 = razor_package_iterator_create(set);
  1793 	pi2 = razor_package_iterator_create(upstream);
  1794 
  1795 	razor_package_iterator_next(pi1, &p1, &name1, &version1);
  1796 	razor_package_iterator_next(pi2, &p2, &name2, &version2);
  1797 
  1798 	while (p1 || p2) {
  1799 		if (p1 && p2) {
  1800 			res = strcmp(name1, name2);
  1801 			if (res == 0)
  1802 				res = versioncmp(version1, version2);
  1803 		}
  1804 
  1805 		if (p2 == NULL || res < 0)
  1806 			callback(name1, version1, NULL, data);
  1807 		else if (p1 == NULL || res > 0)
  1808 			callback(name2, NULL, version2, data);
  1809 
  1810 		if (p1 != NULL && res <= 0)
  1811 			razor_package_iterator_next(pi1, &p1,
  1812 						    &name1, &version1);
  1813 		if (p2 != NULL && res >= 0)
  1814 			razor_package_iterator_next(pi2, &p2,
  1815 						    &name2, &version2);
  1816 	}
  1817 
  1818 	razor_package_iterator_destroy(pi1);
  1819 	razor_package_iterator_destroy(pi2);
  1820 }