#include "gssapiP_generic.h"
#include <string.h>
#define QUEUE_LENGTH 20
typedef struct _queue {
int do_replay;
int do_sequence;
int start;
int length;
unsigned int firstnum;
unsigned int elem[QUEUE_LENGTH];
} queue;
#define QSIZE(q) (sizeof((q)->elem)/sizeof((q)->elem[0]))
#define QELEM(q,i) ((q)->elem[(i)%QSIZE(q)])
static void
queue_insert(queue *q, int after, unsigned int seqnum)
{
int i;
for (i=q->start+q->length-1; i>after; i--)
QELEM(q,i+1) = QELEM(q,i);
QELEM(q,after+1) = seqnum;
if (q->length == QSIZE(q)) {
q->start++;
if (q->start == QSIZE(q))
q->start = 0;
} else {
q->length++;
}
}
gss_int32
g_order_init(void **vqueue, OM_uint32 seqnum,
int do_replay, int do_sequence)
{
queue *q;
if ((q = (queue *) malloc(sizeof(queue))) == NULL)
return(ENOMEM);
q->do_replay = do_replay;
q->do_sequence = do_sequence;
q->start = 0;
q->length = 1;
q->firstnum = seqnum;
q->elem[q->start] = seqnum-1;
*vqueue = (void *) q;
return(0);
}
gss_int32
g_order_check(void **vqueue, OM_uint32 seqnum)
{
queue *q;
int i;
q = (queue *) (*vqueue);
if (!q->do_replay && !q->do_sequence)
return(GSS_S_COMPLETE);
if (seqnum == QELEM(q,q->start+q->length-1)+1) {
queue_insert(q, q->start+q->length-1, seqnum);
return(GSS_S_COMPLETE);
}
if ((seqnum > QELEM(q,q->start+q->length-1)+1) ||
(seqnum < q->firstnum)) {
queue_insert(q, q->start+q->length-1, seqnum);
if (q->do_replay && !q->do_sequence)
return(GSS_S_COMPLETE);
else
return(GSS_S_GAP_TOKEN);
}
if ((seqnum < QELEM(q,q->start)) &&
(seqnum >= q->firstnum)) {
if (q->do_replay && !q->do_sequence)
return(GSS_S_OLD_TOKEN);
else
return(GSS_S_UNSEQ_TOKEN);
}
else {
if (seqnum == QELEM(q,q->start+q->length-1))
return(GSS_S_DUPLICATE_TOKEN);
for (i=q->start; i<q->start+q->length-1; i++) {
if (seqnum == QELEM(q,i))
return(GSS_S_DUPLICATE_TOKEN);
if ((seqnum > QELEM(q,i)) && (seqnum < QELEM(q,i+1))) {
queue_insert(q, i, seqnum);
if (q->do_replay && !q->do_sequence)
return(GSS_S_COMPLETE);
else
return(GSS_S_UNSEQ_TOKEN);
}
}
}
return(GSS_S_FAILURE);
}
void
g_order_free(void **vqueue)
{
queue *q;
q = (queue *) (*vqueue);
free(q);
*vqueue = NULL;
}
gss_uint32
g_queue_size(void *vqueue, size_t *sizep)
{
*sizep += sizeof(queue);
return 0;
}
gss_uint32
g_queue_externalize(void *vqueue, unsigned char **buf, size_t *lenremain)
{
memcpy(*buf, vqueue, sizeof(queue));
*buf += sizeof(queue);
*lenremain -= sizeof(queue);
return 0;
}
gss_uint32
g_queue_internalize(void **vqueue, unsigned char **buf, size_t *lenremain)
{
void *q;
if ((q = malloc(sizeof(queue))) == 0)
return ENOMEM;
memcpy(q, *buf, sizeof(queue));
*buf += sizeof(queue);
*lenremain -= sizeof(queue);
*vqueue = q;
return 0;
}