icl_deque.c

Go to the documentation of this file.

#include "icl_deque.h"


icl_deque_t* icl_deque_new()
{
    icl_deque_t *deque = (icl_deque_t*)malloc(sizeof(icl_deque_t));
    if (deque == NULL)
        return NULL;

    deque->list = icl_list_new();
    if (deque->list == NULL) {
        free(deque);
        return NULL;
    }
    if (pthread_spin_init(&deque->spinlock, PTHREAD_PROCESS_PRIVATE) != 0) {
        free(deque->list);
        free(deque);
        return NULL;
    }
    deque->size = 0;
    return deque;
}


int icl_deque_destroy(icl_deque_t *deque, void (*free_func)(void*))
{
    if (deque == NULL)
        return -1;

    if (pthread_spin_destroy(&deque->spinlock) != 0)
        return -1;

    if (icl_list_destroy(deque->list, free_func) != 0)
        return -1;

    free(deque);
    return 0;
}


icl_node_t* icl_deque_first(icl_deque_t *deque)
{
    if (deque == NULL)
        return NULL;

    pthread_spin_lock(&deque->spinlock);
    icl_node_t *node = icl_list_first(deque->list);
    pthread_spin_unlock(&deque->spinlock);

    return node;
}


icl_node_t* icl_deque_next(icl_deque_t *deque, icl_node_t *node)
{
    if (deque == NULL)
        return NULL;

    pthread_spin_lock(&deque->spinlock);
    icl_node_t *next = icl_list_next(deque->list, node);
    pthread_spin_unlock(&deque->spinlock);

    return next;
}


icl_node_t* icl_deque_append(icl_deque_t *deque, void *data)
{
    if (deque == NULL || data == NULL)
        return NULL;

    pthread_spin_lock(&deque->spinlock);
    icl_node_t *node = icl_list_append(deque->list, data);
    deque->size++;
    pthread_spin_unlock(&deque->spinlock);

    return node;
}


icl_node_t* icl_deque_prepend(icl_deque_t *deque, void *data)
{
    if (deque == NULL || data == NULL)
        return NULL;

    pthread_spin_lock(&deque->spinlock);
    icl_node_t *node = icl_list_prepend(deque->list, data);
    deque->size++;
    pthread_spin_unlock(&deque->spinlock);

    return node;
}


int icl_deque_delete(
    icl_deque_t *deque, icl_node_t *node, void (*free_func)(void*))
{
    if (deque == NULL || node == NULL)
        return -1;

    pthread_spin_lock(&deque->spinlock);
    if (icl_list_delete(deque->list, node, free_func) == 0) {
        deque->size--;
        pthread_spin_unlock(&deque->spinlock);
        return 0;
    }
    else {
        pthread_spin_unlock(&deque->spinlock);
        return -1;
    }
}


int icl_deque_size(icl_deque_t *deque)
{
    if (deque == NULL)
        return -1;

    pthread_spin_lock(&deque->spinlock);
    int size = deque->size;
    pthread_spin_unlock(&deque->spinlock);
    return size;
}