| OLD | NEW |
| (Empty) |
| 1 /* crypto/pqueue/pqueue.c */ | |
| 2 /* | |
| 3 * DTLS implementation written by Nagendra Modadugu | |
| 4 * (nagendra@cs.stanford.edu) for the OpenSSL project 2005. | |
| 5 */ | |
| 6 /* ==================================================================== | |
| 7 * Copyright (c) 1999-2005 The OpenSSL Project. All rights reserved. | |
| 8 * | |
| 9 * Redistribution and use in source and binary forms, with or without | |
| 10 * modification, are permitted provided that the following conditions | |
| 11 * are met: | |
| 12 * | |
| 13 * 1. Redistributions of source code must retain the above copyright | |
| 14 * notice, this list of conditions and the following disclaimer. | |
| 15 * | |
| 16 * 2. Redistributions in binary form must reproduce the above copyright | |
| 17 * notice, this list of conditions and the following disclaimer in | |
| 18 * the documentation and/or other materials provided with the | |
| 19 * distribution. | |
| 20 * | |
| 21 * 3. All advertising materials mentioning features or use of this | |
| 22 * software must display the following acknowledgment: | |
| 23 * "This product includes software developed by the OpenSSL Project | |
| 24 * for use in the OpenSSL Toolkit. (http://www.OpenSSL.org/)" | |
| 25 * | |
| 26 * 4. The names "OpenSSL Toolkit" and "OpenSSL Project" must not be used to | |
| 27 * endorse or promote products derived from this software without | |
| 28 * prior written permission. For written permission, please contact | |
| 29 * openssl-core@OpenSSL.org. | |
| 30 * | |
| 31 * 5. Products derived from this software may not be called "OpenSSL" | |
| 32 * nor may "OpenSSL" appear in their names without prior written | |
| 33 * permission of the OpenSSL Project. | |
| 34 * | |
| 35 * 6. Redistributions of any form whatsoever must retain the following | |
| 36 * acknowledgment: | |
| 37 * "This product includes software developed by the OpenSSL Project | |
| 38 * for use in the OpenSSL Toolkit (http://www.OpenSSL.org/)" | |
| 39 * | |
| 40 * THIS SOFTWARE IS PROVIDED BY THE OpenSSL PROJECT ``AS IS'' AND ANY | |
| 41 * EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | |
| 42 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR | |
| 43 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE OpenSSL PROJECT OR | |
| 44 * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | |
| 45 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT | |
| 46 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | |
| 47 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) | |
| 48 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, | |
| 49 * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) | |
| 50 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED | |
| 51 * OF THE POSSIBILITY OF SUCH DAMAGE. | |
| 52 * ==================================================================== | |
| 53 * | |
| 54 * This product includes cryptographic software written by Eric Young | |
| 55 * (eay@cryptsoft.com). This product includes software written by Tim | |
| 56 * Hudson (tjh@cryptsoft.com). | |
| 57 * | |
| 58 */ | |
| 59 | |
| 60 #include "cryptlib.h" | |
| 61 #include <openssl/bn.h> | |
| 62 #include "pqueue.h" | |
| 63 | |
| 64 typedef struct _pqueue | |
| 65 { | |
| 66 pitem *items; | |
| 67 int count; | |
| 68 } pqueue_s; | |
| 69 | |
| 70 pitem * | |
| 71 pitem_new(unsigned char *prio64be, void *data) | |
| 72 { | |
| 73 pitem *item = (pitem *) OPENSSL_malloc(sizeof(pitem)); | |
| 74 if (item == NULL) return NULL; | |
| 75 | |
| 76 memcpy(item->priority,prio64be,sizeof(item->priority)); | |
| 77 | |
| 78 item->data = data; | |
| 79 item->next = NULL; | |
| 80 | |
| 81 return item; | |
| 82 } | |
| 83 | |
| 84 void | |
| 85 pitem_free(pitem *item) | |
| 86 { | |
| 87 if (item == NULL) return; | |
| 88 | |
| 89 OPENSSL_free(item); | |
| 90 } | |
| 91 | |
| 92 pqueue_s * | |
| 93 pqueue_new() | |
| 94 { | |
| 95 pqueue_s *pq = (pqueue_s *) OPENSSL_malloc(sizeof(pqueue_s)); | |
| 96 if (pq == NULL) return NULL; | |
| 97 | |
| 98 memset(pq, 0x00, sizeof(pqueue_s)); | |
| 99 return pq; | |
| 100 } | |
| 101 | |
| 102 void | |
| 103 pqueue_free(pqueue_s *pq) | |
| 104 { | |
| 105 if (pq == NULL) return; | |
| 106 | |
| 107 OPENSSL_free(pq); | |
| 108 } | |
| 109 | |
| 110 pitem * | |
| 111 pqueue_insert(pqueue_s *pq, pitem *item) | |
| 112 { | |
| 113 pitem *curr, *next; | |
| 114 | |
| 115 if (pq->items == NULL) | |
| 116 { | |
| 117 pq->items = item; | |
| 118 return item; | |
| 119 } | |
| 120 | |
| 121 for(curr = NULL, next = pq->items; | |
| 122 next != NULL; | |
| 123 curr = next, next = next->next) | |
| 124 { | |
| 125 /* we can compare 64-bit value in big-endian encoding | |
| 126 * with memcmp:-) */ | |
| 127 int cmp = memcmp(next->priority, item->priority,8); | |
| 128 if (cmp > 0) /* next > item */ | |
| 129 { | |
| 130 item->next = next; | |
| 131 | |
| 132 if (curr == NULL) | |
| 133 pq->items = item; | |
| 134 else | |
| 135 curr->next = item; | |
| 136 | |
| 137 return item; | |
| 138 } | |
| 139 | |
| 140 else if (cmp == 0) /* duplicates not allowed */ | |
| 141 return NULL; | |
| 142 } | |
| 143 | |
| 144 item->next = NULL; | |
| 145 curr->next = item; | |
| 146 | |
| 147 return item; | |
| 148 } | |
| 149 | |
| 150 pitem * | |
| 151 pqueue_peek(pqueue_s *pq) | |
| 152 { | |
| 153 return pq->items; | |
| 154 } | |
| 155 | |
| 156 pitem * | |
| 157 pqueue_pop(pqueue_s *pq) | |
| 158 { | |
| 159 pitem *item = pq->items; | |
| 160 | |
| 161 if (pq->items != NULL) | |
| 162 pq->items = pq->items->next; | |
| 163 | |
| 164 return item; | |
| 165 } | |
| 166 | |
| 167 pitem * | |
| 168 pqueue_find(pqueue_s *pq, unsigned char *prio64be) | |
| 169 { | |
| 170 pitem *next; | |
| 171 pitem *found = NULL; | |
| 172 | |
| 173 if ( pq->items == NULL) | |
| 174 return NULL; | |
| 175 | |
| 176 for ( next = pq->items; next->next != NULL; next = next->next) | |
| 177 { | |
| 178 if ( memcmp(next->priority, prio64be,8) == 0) | |
| 179 { | |
| 180 found = next; | |
| 181 break; | |
| 182 } | |
| 183 } | |
| 184 | |
| 185 /* check the one last node */ | |
| 186 if ( memcmp(next->priority, prio64be,8) ==0) | |
| 187 found = next; | |
| 188 | |
| 189 if ( ! found) | |
| 190 return NULL; | |
| 191 | |
| 192 #if 0 /* find works in peek mode */ | |
| 193 if ( prev == NULL) | |
| 194 pq->items = next->next; | |
| 195 else | |
| 196 prev->next = next->next; | |
| 197 #endif | |
| 198 | |
| 199 return found; | |
| 200 } | |
| 201 | |
| 202 void | |
| 203 pqueue_print(pqueue_s *pq) | |
| 204 { | |
| 205 pitem *item = pq->items; | |
| 206 | |
| 207 while(item != NULL) | |
| 208 { | |
| 209 printf("item\t%02x%02x%02x%02x%02x%02x%02x%02x\n", | |
| 210 item->priority[0],item->priority[1], | |
| 211 item->priority[2],item->priority[3], | |
| 212 item->priority[4],item->priority[5], | |
| 213 item->priority[6],item->priority[7]); | |
| 214 item = item->next; | |
| 215 } | |
| 216 } | |
| 217 | |
| 218 pitem * | |
| 219 pqueue_iterator(pqueue_s *pq) | |
| 220 { | |
| 221 return pqueue_peek(pq); | |
| 222 } | |
| 223 | |
| 224 pitem * | |
| 225 pqueue_next(pitem **item) | |
| 226 { | |
| 227 pitem *ret; | |
| 228 | |
| 229 if ( item == NULL || *item == NULL) | |
| 230 return NULL; | |
| 231 | |
| 232 | |
| 233 /* *item != NULL */ | |
| 234 ret = *item; | |
| 235 *item = (*item)->next; | |
| 236 | |
| 237 return ret; | |
| 238 } | |
| 239 | |
| 240 int | |
| 241 pqueue_size(pqueue_s *pq) | |
| 242 { | |
| 243 pitem *item = pq->items; | |
| 244 int count = 0; | |
| 245 | |
| 246 while(item != NULL) | |
| 247 { | |
| 248 count++; | |
| 249 item = item->next; | |
| 250 } | |
| 251 return count; | |
| 252 } | |
| OLD | NEW |