pqueue.c 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236
  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. #include "cryptlib.h"
  60. #include <openssl/bn.h>
  61. #include "pqueue.h"
  62. typedef struct _pqueue {
  63. pitem *items;
  64. int count;
  65. } pqueue_s;
  66. pitem *pitem_new(unsigned char *prio64be, void *data)
  67. {
  68. pitem *item = (pitem *)OPENSSL_malloc(sizeof(pitem));
  69. if (item == NULL)
  70. return NULL;
  71. memcpy(item->priority, prio64be, sizeof(item->priority));
  72. item->data = data;
  73. item->next = NULL;
  74. return item;
  75. }
  76. void pitem_free(pitem *item)
  77. {
  78. if (item == NULL)
  79. return;
  80. OPENSSL_free(item);
  81. }
  82. pqueue_s *pqueue_new()
  83. {
  84. pqueue_s *pq = (pqueue_s *)OPENSSL_malloc(sizeof(pqueue_s));
  85. if (pq == NULL)
  86. return NULL;
  87. memset(pq, 0x00, sizeof(pqueue_s));
  88. return pq;
  89. }
  90. void pqueue_free(pqueue_s *pq)
  91. {
  92. if (pq == NULL)
  93. return;
  94. OPENSSL_free(pq);
  95. }
  96. pitem *pqueue_insert(pqueue_s *pq, pitem *item)
  97. {
  98. pitem *curr, *next;
  99. if (pq->items == NULL) {
  100. pq->items = item;
  101. return item;
  102. }
  103. for (curr = NULL, next = pq->items;
  104. next != NULL; curr = next, next = next->next) {
  105. /*
  106. * we can compare 64-bit value in big-endian encoding with memcmp:-)
  107. */
  108. int cmp = memcmp(next->priority, item->priority, 8);
  109. if (cmp > 0) { /* next > item */
  110. item->next = next;
  111. if (curr == NULL)
  112. pq->items = item;
  113. else
  114. curr->next = item;
  115. return item;
  116. }
  117. else if (cmp == 0) /* duplicates not allowed */
  118. return NULL;
  119. }
  120. item->next = NULL;
  121. curr->next = item;
  122. return item;
  123. }
  124. pitem *pqueue_peek(pqueue_s *pq)
  125. {
  126. return pq->items;
  127. }
  128. pitem *pqueue_pop(pqueue_s *pq)
  129. {
  130. pitem *item = pq->items;
  131. if (pq->items != NULL)
  132. pq->items = pq->items->next;
  133. return item;
  134. }
  135. pitem *pqueue_find(pqueue_s *pq, unsigned char *prio64be)
  136. {
  137. pitem *next;
  138. pitem *found = NULL;
  139. if (pq->items == NULL)
  140. return NULL;
  141. for (next = pq->items; next->next != NULL; next = next->next) {
  142. if (memcmp(next->priority, prio64be, 8) == 0) {
  143. found = next;
  144. break;
  145. }
  146. }
  147. /* check the one last node */
  148. if (memcmp(next->priority, prio64be, 8) == 0)
  149. found = next;
  150. if (!found)
  151. return NULL;
  152. #if 0 /* find works in peek mode */
  153. if (prev == NULL)
  154. pq->items = next->next;
  155. else
  156. prev->next = next->next;
  157. #endif
  158. return found;
  159. }
  160. void pqueue_print(pqueue_s *pq)
  161. {
  162. pitem *item = pq->items;
  163. while (item != NULL) {
  164. printf("item\t%02x%02x%02x%02x%02x%02x%02x%02x\n",
  165. item->priority[0], item->priority[1],
  166. item->priority[2], item->priority[3],
  167. item->priority[4], item->priority[5],
  168. item->priority[6], item->priority[7]);
  169. item = item->next;
  170. }
  171. }
  172. pitem *pqueue_iterator(pqueue_s *pq)
  173. {
  174. return pqueue_peek(pq);
  175. }
  176. pitem *pqueue_next(pitem **item)
  177. {
  178. pitem *ret;
  179. if (item == NULL || *item == NULL)
  180. return NULL;
  181. /* *item != NULL */
  182. ret = *item;
  183. *item = (*item)->next;
  184. return ret;
  185. }
  186. int pqueue_size(pqueue_s *pq)
  187. {
  188. pitem *item = pq->items;
  189. int count = 0;
  190. while (item != NULL) {
  191. count++;
  192. item = item->next;
  193. }
  194. return count;
  195. }