Imported Upstream version 0.7.4
[platform/upstream/libsolv.git] / src / policy.c
1 /*
2  * Copyright (c) 2007, Novell Inc.
3  *
4  * This program is licensed under the BSD license, read LICENSE.BSD
5  * for further information
6  */
7
8 /*
9  * Generic policy interface for SAT solver
10  *
11  */
12
13 #include <stdio.h>
14 #include <stdlib.h>
15 #include <unistd.h>
16 #include <string.h>
17
18 #include "solver.h"
19 #include "solver_private.h"
20 #include "evr.h"
21 #include "policy.h"
22 #include "poolvendor.h"
23 #include "poolarch.h"
24 #include "linkedpkg.h"
25 #include "cplxdeps.h"
26
27
28
29 /*-----------------------------------------------------------------*/
30
31 /*
32  * prep for prune_best_version
33  *   sort by name
34  */
35
36 static int
37 prune_to_best_version_sortcmp(const void *ap, const void *bp, void *dp)
38 {
39   Pool *pool = dp;
40   int r;
41   Id a = *(Id *)ap;
42   Id b = *(Id *)bp;
43   Solvable *sa, *sb;
44
45   sa = pool->solvables + a;
46   sb = pool->solvables + b;
47   r = sa->name - sb->name;
48   if (r)
49     {
50       const char *na, *nb;
51       /* different names. We use real strcmp here so that the result
52        * is not depending on some random solvable order */
53       na = pool_id2str(pool, sa->name);
54       nb = pool_id2str(pool, sb->name);
55       return strcmp(na, nb);
56     }
57   if (sa->arch != sb->arch)
58     {
59       unsigned int aa, ab;
60       aa = pool_arch2score(pool, sa->arch);
61       ab = pool_arch2score(pool, sb->arch);
62       if (aa != ab && aa > 1 && ab > 1)
63         return aa < ab ? -1 : 1;        /* lowest score first */
64     }
65
66   /* the same name, bring installed solvables to the front */
67   if (pool->installed)
68     {
69       if (sa->repo == pool->installed)
70         {
71           if (sb->repo != pool->installed)
72             return -1;
73         }
74       else if (sb->repo == pool->installed)
75         return 1;       
76     }
77   /* sort by repository sub-prio (installed repo handled above) */
78   r = (sb->repo ? sb->repo->subpriority : 0) - (sa->repo ? sa->repo->subpriority : 0);
79   if (r)
80     return r;
81   /* no idea about the order, sort by id */
82   return a - b;
83 }
84
85
86 /*
87  * prune to repository with highest priority.
88  * does not prune installed solvables.
89  */
90
91 static void
92 prune_to_highest_prio(Pool *pool, Queue *plist)
93 {
94   int i, j;
95   Solvable *s;
96   int bestprio = 0, bestprioset = 0;
97
98   /* prune to highest priority */
99   for (i = 0; i < plist->count; i++)  /* find highest prio in queue */
100     {
101       s = pool->solvables + plist->elements[i];
102       if (pool->installed && s->repo == pool->installed)
103         continue;
104       if (!bestprioset || s->repo->priority > bestprio)
105         {
106           bestprio = s->repo->priority;
107           bestprioset = 1;
108         }
109     }
110   if (!bestprioset)
111     return;
112   for (i = j = 0; i < plist->count; i++) /* remove all with lower prio */
113     {
114       s = pool->solvables + plist->elements[i];
115       if (s->repo->priority == bestprio || (pool->installed && s->repo == pool->installed))
116         plist->elements[j++] = plist->elements[i];
117     }
118   plist->count = j;
119 }
120
121
122 /* installed packages involed in a dup operation can only be kept
123  * if they are identical to a non-installed one */
124 static void
125 solver_prune_installed_dup_packages(Solver *solv, Queue *plist)
126 {
127   Pool *pool = solv->pool;
128   int i, j, bestprio = 0;
129
130   /* find bestprio (again) */
131   for (i = 0; i < plist->count; i++)
132     {
133       Solvable *s = pool->solvables + plist->elements[i];
134       if (s->repo != pool->installed)
135         {
136           bestprio = s->repo->priority;
137           break;
138         }
139     }
140   if (i == plist->count)
141     return;     /* only installed packages, could not find prio */
142   for (i = j = 0; i < plist->count; i++)
143     {
144       Id p = plist->elements[i];
145       Solvable *s = pool->solvables + p;
146       if (s->repo != pool->installed && s->repo->priority < bestprio)
147         continue;
148       if (s->repo == pool->installed && (solv->dupinvolvedmap_all || (solv->dupinvolvedmap.size && MAPTST(&solv->dupinvolvedmap, p))))
149         {
150           Id p2, pp2;
151           int keepit = 0;
152           FOR_PROVIDES(p2, pp2, s->name)
153             {
154               Solvable *s2 = pool->solvables + p2;
155               if (s2->repo == pool->installed || s2->evr != s->evr || s2->repo->priority < bestprio)
156                 continue;
157               if (!solvable_identical(s, s2))
158                 continue;
159               keepit = 1;
160               if (s2->repo->priority > bestprio)
161                 {
162                   /* new max prio! */
163                   bestprio = s2->repo->priority;
164                   j = 0;
165                 }
166             }
167           if (!keepit)
168             continue;   /* no identical package found, ignore installed package */
169         }
170       plist->elements[j++] = p;
171     }
172   if (j)
173     plist->count = j;
174 }
175
176 /*
177  * like prune_to_highest_prio, but calls solver prune_installed_dup_packages
178  * when there are dup packages
179  */
180 static inline void
181 solver_prune_to_highest_prio(Solver *solv, Queue *plist)
182 {
183   prune_to_highest_prio(solv->pool, plist);
184   if (plist->count > 1 && solv->pool->installed && (solv->dupinvolvedmap_all || solv->dupinvolvedmap.size))
185     solver_prune_installed_dup_packages(solv, plist);
186 }
187
188
189 static void
190 solver_prune_to_highest_prio_per_name(Solver *solv, Queue *plist)
191 {
192   Pool *pool = solv->pool;
193   Queue pq;
194   int i, j, k;
195   Id name;
196
197   queue_init(&pq);
198   solv_sort(plist->elements, plist->count, sizeof(Id), prune_to_best_version_sortcmp, pool);
199   queue_push(&pq, plist->elements[0]);
200   name = pool->solvables[pq.elements[0]].name;
201   for (i = 1, j = 0; i < plist->count; i++)
202     {
203       if (pool->solvables[plist->elements[i]].name != name)
204         {
205           name = pool->solvables[plist->elements[i]].name;
206           if (pq.count > 2)
207             solver_prune_to_highest_prio(solv, &pq);
208           for (k = 0; k < pq.count; k++)
209             plist->elements[j++] = pq.elements[k];
210           queue_empty(&pq);
211         }
212       queue_push(&pq, plist->elements[i]);
213     }
214   if (pq.count > 2)
215     solver_prune_to_highest_prio(solv, &pq);
216   for (k = 0; k < pq.count; k++)
217     plist->elements[j++] = pq.elements[k];
218   queue_free(&pq);
219   plist->count = j;
220 }
221
222
223 #ifdef ENABLE_COMPLEX_DEPS
224
225 /* simple fixed-size hash for package ids */
226 #define CPLXDEPHASH_EMPTY(elements) (memset(elements, 0, sizeof(Id) * 256))
227 #define CPLXDEPHASH_SET(elements, p) (elements[(p) & 255] |= (1 << ((p) >> 8 & 31)))
228 #define CPLXDEPHASH_TST(elements, p) (elements[(p) & 255] && (elements[(p) & 255] & (1 << ((p) >> 8 & 31))))
229
230 static void
231 check_complex_dep(Solver *solv, Id dep, Map *m, Queue **cqp)
232 {
233   Pool *pool = solv->pool;
234   Queue q;
235   queue_init(&q);
236   Id p;
237   int i, qcnt;
238
239 #if 0
240   printf("check_complex_dep %s\n", pool_dep2str(pool, dep));
241 #endif
242   i = pool_normalize_complex_dep(pool, dep, &q, CPLXDEPS_EXPAND);
243   if (i == 0 || i == 1)
244     {
245       queue_free(&q);
246       return;
247     }
248   qcnt = q.count;
249   for (i = 0; i < qcnt; i++)
250     {
251       /* we rely on the fact that blocks are ordered here.
252        * if we reach a positive element, we know that we
253        * saw all negative ones */
254       for (; (p = q.elements[i]) < 0; i++)
255         {
256           if (solv->decisionmap[-p] < 0)
257             break;
258           if (solv->decisionmap[-p] == 0)
259             queue_push(&q, -p);         /* undecided negative literal */
260         }
261       if (p <= 0)
262         {
263 #if 0
264           printf("complex dep block cannot be true or no pos literals\n");
265 #endif
266           while (q.elements[i])
267             i++;
268           if (qcnt != q.count)
269             queue_truncate(&q, qcnt);
270           continue;
271         }
272       if (qcnt == q.count)
273         {
274           /* all negative literals installed, add positive literals to map */
275           for (; (p = q.elements[i]) != 0; i++)
276             MAPSET(m, p);
277         }
278       else
279         {
280           /* at least one undecided negative literal, postpone */
281           int j, k;
282           Queue *cq;
283 #if 0
284           printf("add new complex dep block\n");
285           for (j = qcnt; j < q.count; j++)
286             printf("  - %s\n", pool_solvid2str(pool, q.elements[j]));
287 #endif
288           while (q.elements[i])
289             i++;
290           if (!(cq = *cqp))
291             {
292               cq = solv_calloc(1, sizeof(Queue));
293               queue_init(cq);
294               queue_insertn(cq, 0, 256, 0);     /* allocate hash area */
295               *cqp = cq;
296             }
297           for (j = qcnt; j < q.count; j++)
298             {
299               p = q.elements[j];
300               /* check if we already have this (dep, p) entry */
301               for (k = 256; k < cq->count; k += 2)
302                 if (cq->elements[k + 1] == dep && cq->elements[k] == p)
303                   break;
304               if (k == cq->count)
305                 {
306                   /* a new one. add to cq and hash */
307                   queue_push2(cq, p, dep);
308                   CPLXDEPHASH_SET(cq->elements, p);
309                 }
310             }
311           queue_truncate(&q, qcnt);
312         }
313     }
314   queue_free(&q);
315 }
316
317 static void
318 recheck_complex_deps(Solver *solv, Id p, Map *m, Queue **cqp)
319 {
320   Queue *cq = *cqp;
321   Id pp;
322   int i;
323 #if 0
324   printf("recheck_complex_deps for package %s\n", pool_solvid2str(solv->pool, p));
325 #endif
326   /* make sure that we don't have a false hit */
327   for (i = 256; i < cq->count; i += 2)
328     if (cq->elements[i] == p)
329       break;
330   if (i == cq->count)
331     return;     /* false alert */
332   if (solv->decisionmap[p] <= 0)
333     return;     /* just in case... */
334
335   /* rebuild the hash, call check_complex_dep for our package */
336   CPLXDEPHASH_EMPTY(cq->elements);
337   for (i = 256; i < cq->count; i += 2)
338     if ((pp = cq->elements[i]) == p)
339       {
340         Id dep = cq->elements[i + 1];
341         queue_deleten(cq, i, 2);
342         i -= 2;
343         check_complex_dep(solv, dep, m, &cq);
344       }
345     else
346       CPLXDEPHASH_SET(cq->elements, pp);
347 }
348
349 #endif
350
351
352 void
353 policy_update_recommendsmap(Solver *solv)
354 {
355   Pool *pool = solv->pool;
356   Solvable *s;
357   Id p, pp, rec, *recp, sug, *sugp;
358
359   if (solv->recommends_index < 0)
360     {
361       MAPZERO(&solv->recommendsmap);
362       MAPZERO(&solv->suggestsmap);
363 #ifdef ENABLE_COMPLEX_DEPS
364       if (solv->recommendscplxq)
365         {
366           queue_free(solv->recommendscplxq);
367           solv->recommendscplxq = solv_free(solv->recommendscplxq);
368         }
369       if (solv->suggestscplxq)
370         {
371           queue_free(solv->suggestscplxq);
372           solv->suggestscplxq = solv_free(solv->suggestscplxq);
373         }
374 #endif
375       solv->recommends_index = 0;
376     }
377   while (solv->recommends_index < solv->decisionq.count)
378     {
379       p = solv->decisionq.elements[solv->recommends_index++];
380       if (p < 0)
381         continue;
382       s = pool->solvables + p;
383 #ifdef ENABLE_COMPLEX_DEPS
384       /* re-check postponed complex blocks */
385       if (solv->recommendscplxq && CPLXDEPHASH_TST(solv->recommendscplxq->elements, p))
386         recheck_complex_deps(solv, p, &solv->recommendsmap, &solv->recommendscplxq);
387       if (solv->suggestscplxq && CPLXDEPHASH_TST(solv->suggestscplxq->elements, p))
388         recheck_complex_deps(solv, p, &solv->suggestsmap, &solv->suggestscplxq);
389 #endif
390       if (s->recommends)
391         {
392           recp = s->repo->idarraydata + s->recommends;
393           while ((rec = *recp++) != 0)
394             {
395 #ifdef ENABLE_COMPLEX_DEPS
396               if (pool_is_complex_dep(pool, rec))
397                 {
398                   check_complex_dep(solv, rec, &solv->recommendsmap, &solv->recommendscplxq);
399                   continue;
400                 }
401 #endif
402               FOR_PROVIDES(p, pp, rec)
403                 MAPSET(&solv->recommendsmap, p);
404             }
405         }
406       if (s->suggests)
407         {
408           sugp = s->repo->idarraydata + s->suggests;
409           while ((sug = *sugp++) != 0)
410             {
411 #ifdef ENABLE_COMPLEX_DEPS
412               if (pool_is_complex_dep(pool, sug))
413                 {
414                   check_complex_dep(solv, sug, &solv->suggestsmap, &solv->suggestscplxq);
415                   continue;
416                 }
417 #endif
418               FOR_PROVIDES(p, pp, sug)
419                 MAPSET(&solv->suggestsmap, p);
420             }
421         }
422     }
423 }
424
425 /* bring suggested/enhanced packages to front
426  * installed packages count as suggested */
427 static void
428 prefer_suggested(Solver *solv, Queue *plist)
429 {
430   Pool *pool = solv->pool;
431   int i, count;
432
433   /* update our recommendsmap/suggestsmap */
434   if (solv->recommends_index < solv->decisionq.count)
435     policy_update_recommendsmap(solv);
436
437   for (i = 0, count = plist->count; i < count; i++)
438     {
439       Id p = plist->elements[i];
440       Solvable *s = pool->solvables + p;
441       if ((pool->installed && s->repo == pool->installed) ||
442           MAPTST(&solv->suggestsmap, p) ||
443           solver_is_enhancing(solv, s))
444         continue;       /* good package */
445       /* bring to back */
446      if (i < plist->count - 1)
447         {
448           memmove(plist->elements + i, plist->elements + i + 1, (plist->count - 1 - i) * sizeof(Id));
449           plist->elements[plist->count - 1] = p;
450         }
451       i--;
452       count--;
453     }
454 }
455
456 static int
457 sort_by_favor_cmp(const void *ap, const void *bp, void *dp)
458 {
459   const Id *a = ap, *b = bp, *d = dp;
460   return d[b[0]] - d[a[0]];
461 }
462
463 /* bring favored packages to front and disfavored packages to back */
464 void
465 policy_prefer_favored(Solver *solv, Queue *plist)
466 {
467   if (solv->favormap && plist->count > 1)
468     solv_sort(plist->elements, plist->count, sizeof(Id), sort_by_favor_cmp, solv->favormap);
469 }
470
471 /*
472  * prune to recommended/suggested packages.
473  * does not prune installed packages (they are also somewhat recommended).
474  */
475 static void
476 prune_to_recommended(Solver *solv, Queue *plist)
477 {
478   Pool *pool = solv->pool;
479   int i, j, k, ninst;
480   Solvable *s;
481   Id p;
482
483   ninst = 0;
484   if (pool->installed)
485     {
486       for (i = 0; i < plist->count; i++)
487         {
488           p = plist->elements[i];
489           s = pool->solvables + p;
490           if (pool->installed && s->repo == pool->installed)
491             ninst++;
492         }
493     }
494   if (plist->count - ninst < 2)
495     return;
496
497   /* update our recommendsmap/suggestsmap */
498   if (solv->recommends_index < solv->decisionq.count)
499     policy_update_recommendsmap(solv);
500
501   /* prune to recommended/supplemented */
502   ninst = 0;
503   for (i = j = 0; i < plist->count; i++)
504     {
505       p = plist->elements[i];
506       s = pool->solvables + p;
507       if (pool->installed && s->repo == pool->installed)
508         {
509           ninst++;
510           if (j)
511             plist->elements[j++] = p;
512           continue;
513         }
514       if (!MAPTST(&solv->recommendsmap, p))
515         if (!solver_is_supplementing(solv, s))
516           continue;
517       if (!j && ninst)
518         {
519           for (k = 0; j < ninst; k++)
520             {
521               s = pool->solvables + plist->elements[k];
522               if (pool->installed && s->repo == pool->installed)
523                 plist->elements[j++] = plist->elements[k];
524             }
525         }
526       plist->elements[j++] = p;
527     }
528   if (j)
529     plist->count = j;
530
531 #if 0
532   /* anything left to prune? */
533   if (plist->count - ninst < 2)
534     return;
535
536   /* prune to suggested/enhanced */
537   ninst = 0;
538   for (i = j = 0; i < plist->count; i++)
539     {
540       p = plist->elements[i];
541       s = pool->solvables + p;
542       if (pool->installed && s->repo == pool->installed)
543         {
544           ninst++;
545           if (j)
546             plist->elements[j++] = p;
547           continue;
548         }
549       if (!MAPTST(&solv->suggestsmap, p))
550         if (!solver_is_enhancing(solv, s))
551           continue;
552       if (!j && ninst)
553         {
554           for (k = 0; j < ninst; k++)
555             {
556               s = pool->solvables + plist->elements[k];
557               if (pool->installed && s->repo == pool->installed)
558                 plist->elements[j++] = plist->elements[k];
559             }
560         }
561       plist->elements[j++] = p;
562     }
563   if (j)
564     plist->count = j;
565 #endif
566 }
567
568 static void
569 prune_to_best_arch(const Pool *pool, Queue *plist)
570 {
571   Id a, bestscore;
572   Solvable *s;
573   int i, j;
574
575   if (!pool->id2arch || plist->count < 2)
576     return;
577   bestscore = 0;
578   for (i = 0; i < plist->count; i++)
579     {
580       s = pool->solvables + plist->elements[i];
581       a = pool_arch2score(pool, s->arch);
582       if (a && a != 1 && (!bestscore || a < bestscore))
583         bestscore = a;
584     }
585   if (!bestscore)
586     return;
587   for (i = j = 0; i < plist->count; i++)
588     {
589       s = pool->solvables + plist->elements[i];
590       a = pool_arch2score(pool, s->arch);
591       if (!a)
592         continue;
593       /* a == 1 -> noarch */
594       if (a != 1 && ((a ^ bestscore) & 0xffff0000) != 0)
595         continue;
596       plist->elements[j++] = plist->elements[i];
597     }
598   if (j)
599     plist->count = j;
600 }
601
602
603 struct trj_data {
604   Pool *pool;
605   Queue *plist;
606   Id *stack;
607   Id nstack;
608   Id *low;
609   Id firstidx;
610   Id idx;
611 };
612
613 /* This is Tarjan's SCC algorithm, slightly modified */
614 static void
615 trj_visit(struct trj_data *trj, Id node)
616 {
617   Id *low = trj->low;
618   Pool *pool = trj->pool;
619   Queue *plist = trj->plist;
620   Id myidx, stackstart;
621   Solvable *s;
622   int i;
623   Id p, pp, obs, *obsp;
624
625   low[node] = myidx = trj->idx++;
626   trj->stack[(stackstart = trj->nstack++)] = node;
627
628   s = pool->solvables + plist->elements[node];
629   if (s->obsoletes)
630     {
631       obsp = s->repo->idarraydata + s->obsoletes;
632       while ((obs = *obsp++) != 0)
633         {
634           FOR_PROVIDES(p, pp, obs)
635             {
636               Solvable *ps = pool->solvables + p;
637               if (ps->name == s->name)
638                 continue;
639               if (!pool->obsoleteusesprovides && !pool_match_nevr(pool, ps, obs))
640                 continue;
641               if (pool->obsoleteusescolors && !pool_colormatch(pool, s, ps))
642                 continue;
643               /* hmm, expensive. should use hash if plist is big */
644               for (i = 0; i < plist->count; i++)
645                 {
646                   if (node != i && plist->elements[i] == p)
647                     {
648                       Id l = low[i];
649                       if (!l)
650                         {
651                           if (!ps->obsoletes)
652                             {
653                               /* don't bother */
654                               trj->idx++;
655                               low[i] = -1;
656                               continue;
657                             }
658                           trj_visit(trj, i);
659                           l = low[i];
660                         }
661                       if (l < 0)
662                         continue;
663                       if (l < trj->firstidx)
664                         {
665                           int k;
666                           /* this means we have reached an old SCC found earlier.
667                            * delete it as we obsolete it */
668                           for (k = l; ; k++)
669                             {
670                               if (low[trj->stack[k]] == l)
671                                 low[trj->stack[k]] = -1;
672                               else
673                                 break;
674                             }
675                         }
676                       else if (l < low[node])
677                         low[node] = l;
678                     }
679                 }
680             }
681         }
682     }
683   if (low[node] == myidx)       /* found a SCC? */
684     {
685       /* we're only interested in SCCs that contain the first node,
686        * as all others are "obsoleted" */
687       if (myidx != trj->firstidx)
688         myidx = -1;
689       for (i = stackstart; i < trj->nstack; i++)
690         low[trj->stack[i]] = myidx;
691       trj->nstack = stackstart; /* empty stack */
692     }
693 }
694
695 /*
696  * remove entries from plist that are obsoleted by other entries
697  * with different name.
698  */
699 static void
700 prune_obsoleted(Pool *pool, Queue *plist)
701 {
702   Id data_buf[2 * 16], *data;
703   struct trj_data trj;
704   int i, j;
705   Solvable *s;
706
707   if (plist->count <= 16)
708     {
709       memset(data_buf, 0, sizeof(data_buf));
710       data = data_buf;
711     }
712   else
713     data = solv_calloc(plist->count, 2 * sizeof(Id));
714   trj.pool = pool;
715   trj.plist = plist;
716   trj.low = data;
717   trj.idx = 1;
718   trj.stack = data + plist->count - 1;  /* -1 so we can index with idx (which starts with 1) */
719   for (i = 0; i < plist->count; i++)
720     {
721       if (trj.low[i])
722         continue;
723       s = pool->solvables + plist->elements[i];
724       if (s->obsoletes)
725         {
726           trj.firstidx = trj.nstack = trj.idx;
727           trj_visit(&trj, i);
728         }
729       else
730         {
731           Id myidx = trj.idx++;
732           trj.low[i] = myidx;
733           trj.stack[myidx] = i;
734         }
735     }
736   for (i = j = 0; i < plist->count; i++)
737     if (trj.low[i] >= 0)
738       plist->elements[j++] = plist->elements[i];
739   plist->count = j;
740   if (data != data_buf)
741     solv_free(data);
742 }
743
744 /* this is prune_obsoleted special-cased for two elements */
745 static void
746 prune_obsoleted_2(Pool *pool, Queue *plist)
747 {
748   int i;
749   Solvable *s;
750   Id p, pp, obs, *obsp;
751   Id other;
752   int obmap = 0;
753
754   for (i = 0; i < 2; i++)
755     {
756       s = pool->solvables + plist->elements[i];
757       other = plist->elements[1 - i];
758       if (s->obsoletes)
759         {
760           obsp = s->repo->idarraydata + s->obsoletes;
761           while ((obs = *obsp++) != 0)
762             {
763               FOR_PROVIDES(p, pp, obs)
764                 {
765                   Solvable *ps;
766                   if (p != other)
767                     continue;
768                   ps = pool->solvables + p;
769                   if (ps->name == s->name)
770                     continue;
771                   if (!pool->obsoleteusesprovides && !pool_match_nevr(pool, ps, obs))
772                     continue;
773                   if (pool->obsoleteusescolors && !pool_colormatch(pool, s, ps))
774                     continue;
775                   obmap |= 1 << i;
776                   break;
777                 }
778               if (p)
779                 break;
780             }
781         }
782     }
783   if (obmap == 0 || obmap == 3)
784     return;
785   if (obmap == 2)
786     plist->elements[0] = plist->elements[1];
787   plist->count = 1;
788 }
789
790 /*
791  * bring those elements to the front of the queue that
792  * have a installed solvable with the same name
793  */
794 static void
795 move_installed_to_front(Pool *pool, Queue *plist)
796 {
797   int i, j;
798   Solvable *s;
799   Id p, pp;
800
801   for (i = j = 0; i < plist->count; i++)
802     {
803       s = pool->solvables + plist->elements[i];
804       if (s->repo != pool->installed)
805         {
806           FOR_PROVIDES(p, pp, s->name)
807             {
808               Solvable *ps = pool->solvables + p;
809               if (s->name == ps->name && ps->repo == pool->installed)
810                 {
811                   s = ps;
812                   break;
813                 }
814             }
815         }
816       if (s->repo == pool->installed)
817         {
818           if (i != j)
819             {
820               p = plist->elements[i];
821               if (i - j == 1)
822                 plist->elements[i] = plist->elements[j];
823               else
824                 memmove(plist->elements + j + 1, plist->elements + j, (i - j) * sizeof(Id));
825               plist->elements[j] = p;
826             }
827           else if (j + 2 == plist->count)
828             break;      /* no need to check last element if all prev ones are installed */
829           j++;
830         }
831     }
832 }
833
834 /*
835  * prune_to_best_version
836  *
837  * sort list of packages (given through plist) by name and evr
838  * return result through plist
839  */
840 void
841 prune_to_best_version(Pool *pool, Queue *plist)
842 {
843   int i, j, r;
844   Solvable *s, *best;
845
846   if (plist->count < 2)         /* no need to prune for a single entry */
847     return;
848   POOL_DEBUG(SOLV_DEBUG_POLICY, "prune_to_best_version %d\n", plist->count);
849
850   /* sort by name first, prefer installed */
851   solv_sort(plist->elements, plist->count, sizeof(Id), prune_to_best_version_sortcmp, pool);
852
853   /* now find best 'per name' */
854   best = 0;
855   for (i = j = 0; i < plist->count; i++)
856     {
857       s = pool->solvables + plist->elements[i];
858
859       POOL_DEBUG(SOLV_DEBUG_POLICY, "- %s [%d]%s\n",
860                  pool_solvable2str(pool, s), plist->elements[i], 
861                  (pool->installed && s->repo == pool->installed) ? "I" : "");
862
863       if (!best)                /* if no best yet, the current is best */
864         {
865           best = s;
866           continue;
867         }
868
869       /* name switch: finish group, re-init */
870       if (best->name != s->name)   /* new name */
871         {
872           plist->elements[j++] = best - pool->solvables; /* move old best to front */
873           best = s;             /* take current as new best */
874           continue;
875         }
876       r = best->evr != s->evr ? pool_evrcmp(pool, best->evr, s->evr, EVRCMP_COMPARE) : 0;
877 #ifdef ENABLE_LINKED_PKGS
878       if (r == 0 && has_package_link(pool, s))
879         r = pool_link_evrcmp(pool, best, s);
880 #endif
881       if (r < 0)
882         best = s;
883     }
884   plist->elements[j++] = best - pool->solvables;        /* finish last group */
885   plist->count = j;
886
887   /* we reduced the list to one package per name, now look at
888    * package obsoletes */
889   if (plist->count > 1)
890     {
891       if (plist->count == 2)
892         prune_obsoleted_2(pool, plist);
893       else
894         prune_obsoleted(pool, plist);
895     }
896   if (plist->count > 1 && pool->installed)
897     move_installed_to_front(pool, plist);
898 }
899
900
901 static int
902 sort_by_name_evr_sortcmp(const void *ap, const void *bp, void *dp)
903 {
904   Pool *pool = dp;
905   Id a, *aa = (Id *)ap;
906   Id b, *bb = (Id *)bp;
907   Id r = aa[1] - bb[1];
908   if (r)
909     return r < 0 ? -1 : 1;
910   if (aa[2] == bb[2])
911     return 0;
912   a = aa[2] < 0 ? -aa[2] : aa[2];
913   b = bb[2] < 0 ? -bb[2] : bb[2];
914   r = pool_evrcmp(pool, b, a, pool->disttype != DISTTYPE_DEB ? EVRCMP_MATCH_RELEASE : EVRCMP_COMPARE);
915   if (!r && (aa[2] < 0 || bb[2] < 0))
916     {
917       if (bb[2] >= 0)
918         return 1;
919       if (aa[2] >= 0)
920         return -1;
921     }
922   return r;
923 }
924
925 /* common end of sort_by_srcversion and sort_by_common_dep */
926 static void
927 sort_by_name_evr_array(Pool *pool, Queue *plist, int count, int ent)
928 {
929   Id lastname;
930   int i, j, bad, havebad;
931   Id *pp, *elements = plist->elements;
932
933   if (ent < 2)
934     {
935       queue_truncate(plist, count);
936       return;
937     }
938   solv_sort(elements + count * 2, ent, sizeof(Id) * 3, sort_by_name_evr_sortcmp, pool);
939   lastname = 0;
940   bad = havebad = 0;
941   for (i = 0, pp = elements + count * 2; i < ent; i++, pp += 3)
942     {
943       if (lastname && pp[1] == lastname)
944         {
945           if (pp[0] != pp[-3] && sort_by_name_evr_sortcmp(pp - 3, pp, pool) == -1)
946             {
947 #if 0
948               printf("%s - %s: bad %s %s - %s\n", pool_solvid2str(pool, elements[pp[-3]]), pool_solvid2str(pool, elements[pp[0]]), pool_dep2str(pool, lastname), pool_id2str(pool, pp[-1] < 0 ? -pp[-1] : pp[-1]), pool_id2str(pool, pp[2] < 0 ? -pp[2] : pp[2]));
949 #endif
950               bad++;
951               havebad = 1;
952             }
953         }
954       else
955         {
956           bad = 0;
957           lastname = pp[1];
958         }
959       elements[count + pp[0]] += bad;
960     }
961
962 #if 0
963 for (i = 0; i < count; i++)
964   printf("%s badness %d\n", pool_solvid2str(pool, elements[i]), elements[count + i]);
965 #endif
966
967   if (havebad)
968     {
969       /* simple stable insertion sort */
970       if (pool->installed)
971         for (i = 0; i < count; i++)
972           if (pool->solvables[elements[i]].repo == pool->installed)
973             elements[i + count] = 0;
974       for (i = 1; i < count; i++)
975         for (j = i, pp = elements + count + j; j > 0; j--, pp--)
976           if (pp[-1] > pp[0])
977             {
978               Id *pp2 = pp - count;
979               Id p = pp[-1];
980               pp[-1] = pp[0];
981               pp[0] = p;
982               p = pp2[-1];
983               pp2[-1] = pp2[0];
984               pp2[0] = p;
985             }
986           else
987             break;
988     }
989   queue_truncate(plist, count);
990 }
991
992 #if 0
993 static void
994 sort_by_srcversion(Pool *pool, Queue *plist)
995 {
996   int i, count = plist->count, ent = 0;
997   queue_insertn(plist, count, count, 0);
998   for (i = 0; i < count; i++)
999     {
1000       Id name, evr, p = plist->elements[i];
1001       Solvable *s = pool->solvables + p;
1002       if (solvable_lookup_void(s, SOLVABLE_SOURCENAME))
1003         name = s->name;
1004       else
1005         name = solvable_lookup_id(s, SOLVABLE_SOURCENAME);
1006       if (solvable_lookup_void(s, SOLVABLE_SOURCEEVR))
1007         evr = s->evr;
1008       else
1009         evr = solvable_lookup_id(s, SOLVABLE_SOURCEEVR);
1010       if (!name || !evr || ISRELDEP(evr))
1011         continue;
1012       queue_push(plist, i);
1013       queue_push2(plist, name, evr);
1014       ent++;
1015     }
1016   sort_by_name_evr_array(pool, plist, count, ent);
1017 }
1018 #endif
1019
1020 static void
1021 sort_by_common_dep(Pool *pool, Queue *plist)
1022 {
1023   int i, count = plist->count, ent = 0;
1024   Id id, *dp;
1025   queue_insertn(plist, count, count, 0);
1026   for (i = 0; i < count; i++)
1027     {
1028       Id p = plist->elements[i];
1029       Solvable *s = pool->solvables + p;
1030       if (!s->provides)
1031         continue;
1032       for (dp = s->repo->idarraydata + s->provides; (id = *dp++) != 0; )
1033         {
1034           Reldep *rd;
1035           if (!ISRELDEP(id))
1036             continue;
1037           rd = GETRELDEP(pool, id);
1038           if ((rd->flags == REL_EQ || rd->flags == (REL_EQ | REL_LT) || rd->flags == REL_LT) && !ISRELDEP(rd->evr))
1039             {
1040               if (rd->flags == REL_EQ)
1041                 {
1042                   /* ignore hashes */
1043                   const char *s = pool_id2str(pool, rd->evr);
1044                   if (strlen(s) >= 4)
1045                     {
1046                       while ((*s >= 'a' && *s <= 'f') || (*s >= '0' && *s <= '9'))
1047                         s++;
1048                       if (!*s)
1049                         continue;
1050                     }
1051                 }
1052               queue_push(plist, i);
1053               queue_push2(plist, rd->name, rd->flags == REL_LT ? -rd->evr : rd->evr);
1054               ent++;
1055             }
1056         }
1057     }
1058   sort_by_name_evr_array(pool, plist, count, ent);
1059 }
1060
1061 /* check if we have an update candidate */
1062 static void
1063 dislike_old_versions(Pool *pool, Queue *plist)
1064 {
1065   int i, count;
1066
1067   for (i = 0, count = plist->count; i < count; i++)
1068     {
1069       Id p = plist->elements[i];
1070       Solvable *s = pool->solvables + p;
1071       Repo *repo = s->repo;
1072       Id q, qq;
1073       int bad = 0;
1074
1075       if (!repo || repo == pool->installed)
1076         continue;
1077       FOR_PROVIDES(q, qq, s->name)
1078         {
1079           Solvable *qs = pool->solvables + q;
1080           if (q == p)
1081             continue;
1082           if (s->name != qs->name || s->arch != qs->arch)
1083             continue;
1084           if (repo->priority != qs->repo->priority)
1085             {
1086               if (repo->priority > qs->repo->priority)
1087                 continue;
1088               bad = 1;
1089               break;
1090             }
1091           if (pool_evrcmp(pool, qs->evr, s->evr, EVRCMP_COMPARE) > 0)
1092             {
1093               bad = 1;
1094               break;
1095             }
1096         }
1097       if (!bad)
1098         continue;
1099       /* bring to back */
1100       if (i < plist->count - 1)
1101         {
1102           memmove(plist->elements + i, plist->elements + i + 1, (plist->count - 1 - i) * sizeof(Id));
1103           plist->elements[plist->count - 1] = p;
1104         }
1105       i--;
1106       count--;
1107     }
1108 }
1109
1110
1111 /* special lang package handling for urpm */
1112 /* see https://bugs.mageia.org/show_bug.cgi?id=18315 */
1113
1114 static int
1115 urpm_reorder_cmp(const void *ap, const void *bp, void *dp)
1116 {
1117   return ((Id *)bp)[1] - ((Id *)ap)[1];
1118 }
1119
1120 static void
1121 urpm_reorder(Solver *solv, Queue *plist)
1122 {
1123   Pool *pool = solv->pool;
1124   int i, count = plist->count;
1125   /* add locale score to packages */
1126   queue_insertn(plist, count, count, 0);
1127   for (i = count - 1; i >= 0; i--)
1128     {
1129       Solvable *s = pool->solvables + plist->elements[i];
1130       int score = 1;
1131       const char *sn = pool_id2str(pool, s->name);
1132
1133       if (!strncmp(sn, "kernel-", 7))
1134         {
1135           const char *devel = strstr(sn, "-devel-");
1136           if (devel && strlen(sn) < 256)
1137             {
1138               char kn[256];
1139               Id p, pp, knid;
1140               memcpy(kn, sn, devel - sn);
1141               strcpy(kn + (devel - sn), devel + 6);
1142               knid = pool_str2id(pool, kn, 0);
1143               if (knid)
1144                 {
1145                   FOR_PROVIDES(p, pp, knid)
1146                     {
1147                       if (solv->decisionmap[p] > 0)
1148                         {
1149                           score = 4;
1150                           break;
1151                         }
1152                       else if (pool->installed && pool->solvables[p].repo == pool->installed)
1153                         score = 3;
1154                     }
1155                 }
1156             }
1157         }
1158       else if ((sn = strstr(sn, "-kernel-")) != 0)
1159         {
1160           sn += 8;
1161           if (strlen(sn) < 256 - 8 && *sn >= '0' && *sn <= '9' && sn[1] == '.')
1162             {
1163               const char *flavor = strchr(sn, '-');
1164               if (flavor)
1165                 {
1166                   const char *release = strchr(flavor + 1, '-');
1167                   if (release)
1168                     {
1169                       char kn[256];
1170                       Id p, pp, knid;
1171                       memcpy(kn, "kernel", 7);
1172                       memcpy(kn + 6, flavor, release - flavor + 1);
1173                       memcpy(kn + 6 + (release - flavor) + 1, sn, flavor - sn);
1174                       strcpy(kn + 6 + (release + 1 - sn), release);
1175                       knid = pool_str2id(pool, kn, 0);
1176                       if (knid)
1177                         {
1178                           FOR_PROVIDES(p, pp, knid)
1179                             {
1180                               if (solv->decisionmap[p] > 0)
1181                                 {
1182                                   score = 4;
1183                                   break;
1184                                 }
1185                               if (pool->installed && pool->solvables[p].repo == pool->installed)
1186                                 score = 3;
1187                             }
1188                         }
1189                     }
1190                 }
1191             }
1192         }
1193       if (score == 1 && s->requires)
1194         {
1195           Id id, *idp, p, pp;
1196           const char *deps;
1197           for (idp = s->repo->idarraydata + s->requires; (id = *idp) != 0; idp++)
1198             {
1199               while (ISRELDEP(id))
1200                 {
1201                   Reldep *rd = GETRELDEP(pool, id);
1202                   id = rd->name;
1203                 }
1204               deps = strstr(pool_id2str(pool, id), "locales-");
1205               if (!deps)
1206                 continue;
1207               if (!strncmp(deps + 8, "en", 2))
1208                 score = 2;
1209               else
1210                 {
1211                   score = 0;
1212                   FOR_PROVIDES(p, pp, id)
1213                     {
1214                       if (solv->decisionmap[p] > 0)
1215                         {
1216                           score = 4;
1217                           break;
1218                         }
1219                       if (pool->installed && pool->solvables[p].repo == pool->installed)
1220                         score = 3;
1221                     }
1222                   break;
1223                 }
1224             }
1225         }
1226       plist->elements[i * 2] = plist->elements[i];
1227       plist->elements[i * 2 + 1] = score;
1228     }
1229   solv_sort(plist->elements, count, sizeof(Id) * 2, urpm_reorder_cmp, pool);
1230   for (i = 0; i < count; i++)
1231     plist->elements[i] = plist->elements[2 * i];
1232   queue_truncate(plist, count);
1233 }
1234
1235 /* support multiple favor groups by calling policy_filter_unwanted on
1236  * each of them and combining the result */
1237 static void
1238 policy_filter_unwanted_favored(Solver *solv, Queue *plist, int mode)
1239 {
1240   int i, j, f;
1241   Queue qin, qprune;
1242   queue_init_clone(&qin, plist);
1243   queue_empty(plist);
1244   /* sort by favor group */
1245   solv_sort(qin.elements, qin.count, sizeof(Id), sort_by_favor_cmp, solv->favormap);
1246   /* go over groups */
1247   queue_init(&qprune);
1248   for (i = 0; i < qin.count; i = j)
1249     {
1250       /* find end of group */
1251       f = solv->favormap[qin.elements[i]];
1252       for (j = i + 1; j < qin.count; j++)
1253         if (solv->favormap[qin.elements[j]] != f)
1254           break;
1255       /* prune this group */
1256       queue_empty(&qprune);
1257       queue_insertn(&qprune, 0, j, qin.elements);
1258       policy_filter_unwanted(solv, &qprune, mode | POLICY_MODE_FAVOR_REC);
1259       for (i = 0; i < qprune.count; i++)
1260         if (solv->favormap[qprune.elements[i]] == f)
1261           queue_push(plist, qprune.elements[i]);
1262     }
1263   queue_free(&qprune);
1264   queue_free(&qin);
1265 }
1266
1267 /*
1268  *  POLICY_MODE_CHOOSE:     default, do all pruning steps
1269  *  POLICY_MODE_RECOMMEND:  leave out prune_to_recommended
1270  *  POLICY_MODE_SUGGEST:    leave out prune_to_recommended, do prio pruning just per name
1271  */
1272 void
1273 policy_filter_unwanted(Solver *solv, Queue *plist, int mode)
1274 {
1275   Pool *pool = solv->pool;
1276   if (mode == POLICY_MODE_SUPPLEMENT)
1277     {
1278       /* reorder only */
1279       dislike_old_versions(pool, plist);
1280       sort_by_common_dep(pool, plist);
1281       if (solv->urpmreorder)
1282         urpm_reorder(solv, plist);
1283       prefer_suggested(solv, plist);
1284       policy_prefer_favored(solv, plist);
1285       return;
1286     }
1287   if (mode & POLICY_MODE_FAVOR_REC)
1288     mode ^= POLICY_MODE_FAVOR_REC;
1289   else if (solv->favormap && plist->count > 1)
1290     {
1291       /* check if we have multiple favor groups */
1292       int i, f = solv->favormap[plist->elements[0]];
1293       for (i = 1; i < plist->count; i++)
1294         if (solv->favormap[plist->elements[i]] != f)
1295           break;
1296       if (i < plist->count)
1297         {
1298           policy_filter_unwanted_favored(solv, plist, mode);
1299           return;
1300         }
1301     }
1302   if (plist->count > 1)
1303     {
1304       if (mode != POLICY_MODE_SUGGEST)
1305         solver_prune_to_highest_prio(solv, plist);
1306       else
1307         solver_prune_to_highest_prio_per_name(solv, plist);
1308     }
1309   if (plist->count > 1)
1310     prune_to_best_arch(pool, plist);
1311   if (plist->count > 1)
1312     prune_to_best_version(pool, plist);
1313   if (plist->count > 1 && (mode == POLICY_MODE_CHOOSE || mode == POLICY_MODE_CHOOSE_NOREORDER))
1314     {
1315       prune_to_recommended(solv, plist);
1316       if (plist->count > 1 && mode != POLICY_MODE_CHOOSE_NOREORDER)
1317         {
1318           /* do some fancy reordering */
1319 #if 0
1320           sort_by_srcversion(pool, plist);
1321 #endif
1322           dislike_old_versions(pool, plist);
1323           sort_by_common_dep(pool, plist);
1324           if (solv->urpmreorder)
1325             urpm_reorder(solv, plist);
1326           prefer_suggested(solv, plist);
1327           policy_prefer_favored(solv, plist);
1328         }
1329     }
1330 }
1331
1332 void
1333 pool_best_solvables(Pool *pool, Queue *plist, int flags)
1334 {
1335   if (plist->count > 1)
1336     prune_to_highest_prio(pool, plist);
1337   if (plist->count > 1)
1338     prune_to_best_arch(pool, plist);
1339   if (plist->count > 1)
1340     prune_to_best_version(pool, plist);
1341   if (plist->count > 1)
1342     {
1343       dislike_old_versions(pool, plist);
1344       sort_by_common_dep(pool, plist);
1345     }
1346 }
1347
1348
1349 /* check if there is an illegal architecture change if
1350  * installed solvable s1 is replaced by s2 */
1351 int
1352 policy_illegal_archchange(Solver *solv, Solvable *s1, Solvable *s2)
1353 {
1354   Pool *pool = solv->pool;
1355   Id a1 = s1->arch, a2 = s2->arch;
1356
1357   /* we allow changes to/from noarch */
1358   if (a1 == a2 || a1 == pool->noarchid || a2 == pool->noarchid)
1359     return 0;
1360   if (!pool->id2arch)
1361     return 0;
1362   a1 = pool_arch2score(pool, a1);
1363   a2 = pool_arch2score(pool, a2);
1364   if (((a1 ^ a2) & 0xffff0000) != 0)
1365     return 1;
1366   return 0;
1367 }
1368
1369 /* check if there is an illegal vendor change if
1370  * installed solvable s1 is replaced by s2 */
1371 int
1372 policy_illegal_vendorchange(Solver *solv, Solvable *s1, Solvable *s2)
1373 {
1374   Pool *pool = solv->pool;
1375   Id v1, v2;
1376   Id vendormask1, vendormask2;
1377
1378   if (pool->custom_vendorcheck)
1379      return pool->custom_vendorcheck(pool, s1, s2);
1380
1381   /* treat a missing vendor as empty string */
1382   v1 = s1->vendor ? s1->vendor : ID_EMPTY;
1383   v2 = s2->vendor ? s2->vendor : ID_EMPTY;
1384   if (v1 == v2)
1385     return 0;
1386   vendormask1 = pool_vendor2mask(pool, v1);
1387   if (!vendormask1)
1388     return 1;   /* can't match */
1389   vendormask2 = pool_vendor2mask(pool, v2);
1390   if ((vendormask1 & vendormask2) != 0)
1391     return 0;
1392   return 1;     /* no class matches */
1393 }
1394
1395 /* check if it is illegal to replace installed
1396  * package "is" with package "s" (which must obsolete "is")
1397  */
1398 int
1399 policy_is_illegal(Solver *solv, Solvable *is, Solvable *s, int ignore)
1400 {
1401   Pool *pool = solv->pool;
1402   int ret = 0;
1403   int duppkg = solv->dupinvolvedmap_all || (solv->dupinvolvedmap.size && MAPTST(&solv->dupinvolvedmap, is - pool->solvables));
1404   if (!(ignore & POLICY_ILLEGAL_DOWNGRADE) && !(duppkg ? solv->dup_allowdowngrade : solv->allowdowngrade))
1405     {
1406       if (is->name == s->name && pool_evrcmp(pool, is->evr, s->evr, EVRCMP_COMPARE) > 0)
1407         ret |= POLICY_ILLEGAL_DOWNGRADE;
1408     }
1409   if (!(ignore & POLICY_ILLEGAL_ARCHCHANGE) && !(duppkg ? solv->dup_allowarchchange : solv->allowarchchange))
1410     {
1411       if (is->arch != s->arch && policy_illegal_archchange(solv, is, s))
1412         ret |= POLICY_ILLEGAL_ARCHCHANGE;
1413     }
1414   if (!(ignore & POLICY_ILLEGAL_VENDORCHANGE) && !(duppkg ? solv->dup_allowvendorchange : solv->allowvendorchange))
1415     {
1416       if (is->vendor != s->vendor && policy_illegal_vendorchange(solv, is, s))
1417         ret |= POLICY_ILLEGAL_VENDORCHANGE;
1418     }
1419   if (!(ignore & POLICY_ILLEGAL_NAMECHANGE) && !(duppkg ? solv->dup_allownamechange : solv->allownamechange))
1420     {
1421       if (is->name != s->name)
1422         ret |= POLICY_ILLEGAL_NAMECHANGE;
1423     }
1424   return ret;
1425 }
1426
1427 /*-------------------------------------------------------------------
1428  *
1429  * create reverse obsoletes map for installed solvables
1430  *
1431  * For each installed solvable find which packages with *different* names
1432  * obsolete the solvable.
1433  * This index is used in policy_findupdatepackages() below.
1434  */
1435 void
1436 policy_create_obsolete_index(Solver *solv)
1437 {
1438   Pool *pool = solv->pool;
1439   Solvable *s;
1440   Repo *installed = solv->installed;
1441   Id p, pp, obs, *obsp, *obsoletes, *obsoletes_data;
1442   int i, n, cnt;
1443
1444   solv->obsoletes = solv_free(solv->obsoletes);
1445   solv->obsoletes_data = solv_free(solv->obsoletes_data);
1446   if (!installed || installed->start == installed->end)
1447     return;
1448   cnt = installed->end - installed->start;
1449   solv->obsoletes = obsoletes = solv_calloc(cnt, sizeof(Id));
1450   for (i = 1; i < pool->nsolvables; i++)
1451     {
1452       s = pool->solvables + i;
1453       if (!s->obsoletes)
1454         continue;
1455       if (!pool_installable(pool, s))
1456         continue;
1457       obsp = s->repo->idarraydata + s->obsoletes;
1458       while ((obs = *obsp++) != 0)
1459         {
1460           FOR_PROVIDES(p, pp, obs)
1461             {
1462               Solvable *ps = pool->solvables + p;;
1463               if (ps->repo != installed)
1464                 continue;
1465               if (ps->name == s->name)
1466                 continue;
1467               if (!pool->obsoleteusesprovides && !pool_match_nevr(pool, ps, obs))
1468                 continue;
1469               if (pool->obsoleteusescolors && !pool_colormatch(pool, s, ps))
1470                 continue;
1471               obsoletes[p - installed->start]++;
1472             }
1473         }
1474     }
1475   n = 0;
1476   for (i = 0; i < cnt; i++)
1477     if (obsoletes[i])
1478       {
1479         n += obsoletes[i] + 1;
1480         obsoletes[i] = n;
1481       }
1482   solv->obsoletes_data = obsoletes_data = solv_calloc(n + 1, sizeof(Id));
1483   POOL_DEBUG(SOLV_DEBUG_STATS, "obsoletes data: %d entries\n", n + 1);
1484   for (i = pool->nsolvables - 1; i > 0; i--)
1485     {
1486       s = pool->solvables + i;
1487       if (!s->obsoletes)
1488         continue;
1489       if (!pool_installable(pool, s))
1490         continue;
1491       obsp = s->repo->idarraydata + s->obsoletes;
1492       while ((obs = *obsp++) != 0)
1493         {
1494           FOR_PROVIDES(p, pp, obs)
1495             {
1496               Solvable *ps = pool->solvables + p;;
1497               if (ps->repo != installed)
1498                 continue;
1499               if (ps->name == s->name)
1500                 continue;
1501               if (!pool->obsoleteusesprovides && !pool_match_nevr(pool, ps, obs))
1502                 continue;
1503               if (pool->obsoleteusescolors && !pool_colormatch(pool, s, ps))
1504                 continue;
1505               if (obsoletes_data[obsoletes[p - installed->start]] != i)
1506                 obsoletes_data[--obsoletes[p - installed->start]] = i;
1507             }
1508         }
1509     }
1510 }
1511
1512
1513 /*
1514  * find update candidates
1515  *
1516  * s: installed solvable to be updated
1517  * qs: [out] queue to hold Ids of candidates
1518  * allow_all: 0 = dont allow downgrades, 1 = allow all candidates
1519  *            2 = dup mode
1520  *
1521  */
1522 void
1523 policy_findupdatepackages(Solver *solv, Solvable *s, Queue *qs, int allow_all)
1524 {
1525   /* installed packages get a special upgrade allowed rule */
1526   Pool *pool = solv->pool;
1527   Id p, pp, n, p2, pp2;
1528   Id obs, *obsp;
1529   Solvable *ps;
1530   int haveprovobs = 0;
1531   int allowdowngrade = allow_all ? 1 : solv->allowdowngrade;
1532   int allownamechange = allow_all ? 1 : solv->allownamechange;
1533   int allowarchchange = allow_all ? 1 : solv->allowarchchange;
1534   int allowvendorchange = allow_all ? 1 : solv->allowvendorchange;
1535   if (allow_all == 2)
1536     {
1537       allowdowngrade = solv->dup_allowdowngrade;
1538       allownamechange = solv->dup_allownamechange;
1539       allowarchchange = solv->dup_allowarchchange;
1540       allowvendorchange = solv->dup_allowvendorchange;
1541     }
1542
1543   queue_empty(qs);
1544
1545   n = s - pool->solvables;
1546
1547   /*
1548    * look for updates for s
1549    */
1550   FOR_PROVIDES(p, pp, s->name)  /* every provider of s' name */
1551     {
1552       if (p == n)               /* skip itself */
1553         continue;
1554
1555       ps = pool->solvables + p;
1556       if (s->name == ps->name)  /* name match */
1557         {
1558           if (pool->implicitobsoleteusescolors && !pool_colormatch(pool, s, ps))
1559             continue;
1560           if (!allowdowngrade && pool_evrcmp(pool, s->evr, ps->evr, EVRCMP_COMPARE) > 0)
1561             continue;
1562         }
1563       else if (!allownamechange)
1564         continue;
1565       else if ((!solv->noupdateprovide || solv->needupdateprovide) && ps->obsoletes)   /* provides/obsoletes combination ? */
1566         {
1567           /* check if package ps obsoletes installed package s */
1568           /* implicitobsoleteusescolors is somewhat wrong here, but we nevertheless
1569            * use it to limit our update candidates */
1570           if ((pool->obsoleteusescolors || pool->implicitobsoleteusescolors) && !pool_colormatch(pool, s, ps))
1571             continue;
1572           obsp = ps->repo->idarraydata + ps->obsoletes;
1573           while ((obs = *obsp++) != 0)  /* for all obsoletes */
1574             {
1575               FOR_PROVIDES(p2, pp2, obs)   /* and all matching providers of the obsoletes */
1576                 {
1577                   Solvable *ps2 = pool->solvables + p2;
1578                   if (!pool->obsoleteusesprovides && !pool_match_nevr(pool, ps2, obs))
1579                     continue;
1580                   if (p2 == n)          /* match ! */
1581                     break;
1582                 }
1583               if (p2)                   /* match! */
1584                 break;
1585             }
1586           if (!obs)                     /* continue if no match */
1587             continue;
1588           /* here we have 'p' with a matching provides/obsoletes combination
1589            * thus flagging p as a valid update candidate for s
1590            */
1591           haveprovobs = 1;
1592         }
1593       else
1594         continue;
1595       if (!allowarchchange && s->arch != ps->arch && policy_illegal_archchange(solv, s, ps))
1596         continue;
1597       if (!allowvendorchange && s->vendor != ps->vendor && policy_illegal_vendorchange(solv, s, ps))
1598         continue;
1599       queue_push(qs, p);
1600     }
1601   if (!allownamechange)
1602     return;
1603   /* if we have found some valid candidates and noupdateprovide is not set, we're
1604      done. otherwise we fallback to all obsoletes */
1605   if (solv->needupdateprovide || (!solv->noupdateprovide && haveprovobs))
1606     return;
1607   if (solv->obsoletes && solv->obsoletes[n - solv->installed->start])
1608     {
1609       Id *opp;
1610       for (opp = solv->obsoletes_data + solv->obsoletes[n - solv->installed->start]; (p = *opp++) != 0;)
1611         {
1612           ps = pool->solvables + p;
1613           if (!allowarchchange && s->arch != ps->arch && policy_illegal_archchange(solv, s, ps))
1614             continue;
1615           if (!allowvendorchange && s->vendor != ps->vendor && policy_illegal_vendorchange(solv, s, ps))
1616             continue;
1617           /* implicitobsoleteusescolors is somewhat wrong here, but we nevertheless
1618            * use it to limit our update candidates */
1619           if (pool->implicitobsoleteusescolors && !pool_colormatch(pool, s, ps))
1620             continue;
1621           queue_push(qs, p);
1622         }
1623     }
1624 }
1625
1626 const char *
1627 policy_illegal2str(Solver *solv, int illegal, Solvable *s, Solvable *rs)
1628 {
1629   Pool *pool = solv->pool;
1630   const char *str;
1631   if (illegal == POLICY_ILLEGAL_DOWNGRADE)
1632     {
1633       str = pool_tmpjoin(pool, "downgrade of ", pool_solvable2str(pool, s), 0);
1634       return pool_tmpappend(pool, str, " to ", pool_solvable2str(pool, rs));
1635     }
1636   if (illegal == POLICY_ILLEGAL_NAMECHANGE)
1637     {
1638       str = pool_tmpjoin(pool, "name change of ", pool_solvable2str(pool, s), 0);
1639       return pool_tmpappend(pool, str, " to ", pool_solvable2str(pool, rs));
1640     }
1641   if (illegal == POLICY_ILLEGAL_ARCHCHANGE)
1642     {
1643       str = pool_tmpjoin(pool, "architecture change of ", pool_solvable2str(pool, s), 0);
1644       return pool_tmpappend(pool, str, " to ", pool_solvable2str(pool, rs));
1645     }
1646   if (illegal == POLICY_ILLEGAL_VENDORCHANGE)
1647     {
1648       str = pool_tmpjoin(pool, "vendor change from '", pool_id2str(pool, s->vendor), "' (");
1649       if (rs->vendor)
1650         {
1651           str = pool_tmpappend(pool, str, pool_solvable2str(pool, s), ") to '");
1652           str = pool_tmpappend(pool, str, pool_id2str(pool, rs->vendor), "' (");
1653         }
1654       else
1655         str = pool_tmpappend(pool, str, pool_solvable2str(pool, s), ") to no vendor (");
1656       return pool_tmpappend(pool, str, pool_solvable2str(pool, rs), ")");
1657     }
1658   return "unknown illegal change";
1659 }
1660