Merge git://git.kernel.org/pub/scm/linux/kernel/git/mchehab/v4l-dvb
[linux-2.6] / lib / prio_heap.c
1 /*
2  * Simple insertion-only static-sized priority heap containing
3  * pointers, based on CLR, chapter 7
4  */
5
6 #include <linux/slab.h>
7 #include <linux/prio_heap.h>
8
9 int heap_init(struct ptr_heap *heap, size_t size, gfp_t gfp_mask,
10               int (*gt)(void *, void *))
11 {
12         heap->ptrs = kmalloc(size, gfp_mask);
13         if (!heap->ptrs)
14                 return -ENOMEM;
15         heap->size = 0;
16         heap->max = size / sizeof(void *);
17         heap->gt = gt;
18         return 0;
19 }
20
21 void heap_free(struct ptr_heap *heap)
22 {
23         kfree(heap->ptrs);
24 }
25
26 void *heap_insert(struct ptr_heap *heap, void *p)
27 {
28         void *res;
29         void **ptrs = heap->ptrs;
30         int pos;
31
32         if (heap->size < heap->max) {
33                 /* Heap insertion */
34                 int pos = heap->size++;
35                 while (pos > 0 && heap->gt(p, ptrs[(pos-1)/2])) {
36                         ptrs[pos] = ptrs[(pos-1)/2];
37                         pos = (pos-1)/2;
38                 }
39                 ptrs[pos] = p;
40                 return NULL;
41         }
42
43         /* The heap is full, so something will have to be dropped */
44
45         /* If the new pointer is greater than the current max, drop it */
46         if (heap->gt(p, ptrs[0]))
47                 return p;
48
49         /* Replace the current max and heapify */
50         res = ptrs[0];
51         ptrs[0] = p;
52         pos = 0;
53
54         while (1) {
55                 int left = 2 * pos + 1;
56                 int right = 2 * pos + 2;
57                 int largest = pos;
58                 if (left < heap->size && heap->gt(ptrs[left], p))
59                         largest = left;
60                 if (right < heap->size && heap->gt(ptrs[right], ptrs[largest]))
61                         largest = right;
62                 if (largest == pos)
63                         break;
64                 /* Push p down the heap one level and bump one up */
65                 ptrs[pos] = ptrs[largest];
66                 ptrs[largest] = p;
67                 pos = largest;
68         }
69         return res;
70 }