|
Packit |
c4476c |
/*
|
|
Packit |
c4476c |
* Copyright 2005-2018 The OpenSSL Project Authors. All Rights Reserved.
|
|
Packit |
c4476c |
*
|
|
Packit |
c4476c |
* Licensed under the OpenSSL license (the "License"). You may not use
|
|
Packit |
c4476c |
* this file except in compliance with the License. You can obtain a copy
|
|
Packit |
c4476c |
* in the file LICENSE in the source distribution or at
|
|
Packit |
c4476c |
* https://www.openssl.org/source/license.html
|
|
Packit |
c4476c |
*/
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
#include "ssl_local.h"
|
|
Packit |
c4476c |
#include <openssl/bn.h>
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
struct pqueue_st {
|
|
Packit |
c4476c |
pitem *items;
|
|
Packit |
c4476c |
int count;
|
|
Packit |
c4476c |
};
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
pitem *pitem_new(unsigned char *prio64be, void *data)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
pitem *item = OPENSSL_malloc(sizeof(*item));
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
if (item == NULL) {
|
|
Packit |
c4476c |
SSLerr(SSL_F_PITEM_NEW, ERR_R_MALLOC_FAILURE);
|
|
Packit |
c4476c |
return NULL;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
memcpy(item->priority, prio64be, sizeof(item->priority));
|
|
Packit |
c4476c |
item->data = data;
|
|
Packit |
c4476c |
item->next = NULL;
|
|
Packit |
c4476c |
return item;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
void pitem_free(pitem *item)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
OPENSSL_free(item);
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
pqueue *pqueue_new(void)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
pqueue *pq = OPENSSL_zalloc(sizeof(*pq));
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
if (pq == NULL)
|
|
Packit |
c4476c |
SSLerr(SSL_F_PQUEUE_NEW, ERR_R_MALLOC_FAILURE);
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
return pq;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
void pqueue_free(pqueue *pq)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
OPENSSL_free(pq);
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
pitem *pqueue_insert(pqueue *pq, pitem *item)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
pitem *curr, *next;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
if (pq->items == NULL) {
|
|
Packit |
c4476c |
pq->items = item;
|
|
Packit |
c4476c |
return item;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
for (curr = NULL, next = pq->items;
|
|
Packit |
c4476c |
next != NULL; curr = next, next = next->next) {
|
|
Packit |
c4476c |
/*
|
|
Packit |
c4476c |
* we can compare 64-bit value in big-endian encoding with memcmp:-)
|
|
Packit |
c4476c |
*/
|
|
Packit |
c4476c |
int cmp = memcmp(next->priority, item->priority, 8);
|
|
Packit |
c4476c |
if (cmp > 0) { /* next > item */
|
|
Packit |
c4476c |
item->next = next;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
if (curr == NULL)
|
|
Packit |
c4476c |
pq->items = item;
|
|
Packit |
c4476c |
else
|
|
Packit |
c4476c |
curr->next = item;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
return item;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
else if (cmp == 0) /* duplicates not allowed */
|
|
Packit |
c4476c |
return NULL;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
item->next = NULL;
|
|
Packit |
c4476c |
curr->next = item;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
return item;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
pitem *pqueue_peek(pqueue *pq)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
return pq->items;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
pitem *pqueue_pop(pqueue *pq)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
pitem *item = pq->items;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
if (pq->items != NULL)
|
|
Packit |
c4476c |
pq->items = pq->items->next;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
return item;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
pitem *pqueue_find(pqueue *pq, unsigned char *prio64be)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
pitem *next;
|
|
Packit |
c4476c |
pitem *found = NULL;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
if (pq->items == NULL)
|
|
Packit |
c4476c |
return NULL;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
for (next = pq->items; next->next != NULL; next = next->next) {
|
|
Packit |
c4476c |
if (memcmp(next->priority, prio64be, 8) == 0) {
|
|
Packit |
c4476c |
found = next;
|
|
Packit |
c4476c |
break;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
/* check the one last node */
|
|
Packit |
c4476c |
if (memcmp(next->priority, prio64be, 8) == 0)
|
|
Packit |
c4476c |
found = next;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
if (!found)
|
|
Packit |
c4476c |
return NULL;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
return found;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
pitem *pqueue_iterator(pqueue *pq)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
return pqueue_peek(pq);
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
pitem *pqueue_next(piterator *item)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
pitem *ret;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
if (item == NULL || *item == NULL)
|
|
Packit |
c4476c |
return NULL;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
/* *item != NULL */
|
|
Packit |
c4476c |
ret = *item;
|
|
Packit |
c4476c |
*item = (*item)->next;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
return ret;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
size_t pqueue_size(pqueue *pq)
|
|
Packit |
c4476c |
{
|
|
Packit |
c4476c |
pitem *item = pq->items;
|
|
Packit |
c4476c |
size_t count = 0;
|
|
Packit |
c4476c |
|
|
Packit |
c4476c |
while (item != NULL) {
|
|
Packit |
c4476c |
count++;
|
|
Packit |
c4476c |
item = item->next;
|
|
Packit |
c4476c |
}
|
|
Packit |
c4476c |
return count;
|
|
Packit |
c4476c |
}
|