tls_ct_q.h

Go to the documentation of this file.

/* 
 * Copyright (C) 2010 iptelorg GmbH
 *
 * Permission to use, copy, modify, and distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */

/*
 * History:
 * --------
 *  2010-03-31  initial version (andrei)
*/

#ifndef __tls_ct_q_h
#define __tls_ct_q_h

#include "sbufq.h"
#include "../../compiler_opt.h"

typedef struct sbuffer_queue tls_ct_q;


#define tls_ct_q_empty(bq) ((bq)==0 || (bq)->first==0)
#define tls_ct_q_non_empty(bq) ((bq) && (bq)->first!=0)


inline static int tls_ct_q_add(tls_ct_q** ct_q, const void* data,
                                                                unsigned int size, unsigned int min_buf_size)
{
        tls_ct_q* q;
        
        q = *ct_q;
        if (likely(q == 0)){
                q=shm_malloc(sizeof(tls_ct_q));
                if (unlikely(q==0))
                        goto error;
                memset(q, 0, sizeof(tls_ct_q));
                *ct_q = q;
        }
        return sbufq_add(q, data, size, min_buf_size);
error:
        return -1;
}



inline static unsigned int tls_ct_q_destroy(tls_ct_q** ct_q)
{
        unsigned int ret;
        
        ret = 0;
        if (likely(ct_q && *ct_q)) {
                ret = sbufq_destroy(*ct_q);
                shm_free(*ct_q);
                *ct_q = 0;
        }
        return ret;
}



inline static int tls_ct_q_flush(tls_ct_q** tc_q, int* flags,
                                                                int (*flush_f)(void* p1, void* p2,
                                                                                                const void* buf,
                                                                                                unsigned size),
                                                                void* flush_p1, void* flush_p2)
{
        return *tc_q?sbufq_flush(*tc_q, flags, flush_f, flush_p1, flush_p2):0;
}



#endif /*__tls_ct_q_h*/

/* vi: set ts=4 sw=4 tw=79:ai:cindent: */