bufferpool.h

Go to the documentation of this file.

/* * 
 * This file is part of libnemesi
 *
 * Copyright (C) 2007 by LScube team <team@streaming.polito.it>
 * See AUTHORS for more details
 * 
 * libnemesi is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * libnemesi is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with libnemesi; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 *  
 * */

#ifndef NEMESI_BUFFERPOOL_H
#define NEMESI_BUFFERPOOL_H
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <stdint.h>
            /* #define BP_SLOT_NUM 50 */
/* 1000ms / 20ms = Playout Buffer Size (in seconds) / Required RTP payload size (in seconds) */
#define BP_SLOT_NUM 150        // Bigger buffer. For video needs.

/*#define BP_SLOT_SIZE 548 *//* 576 - 20 - 8 = Minimum Reassembly Buffer Size - IP datagram header -  UDP hedaer */
#define BP_SLOT_SIZE 2048    /* bigger slot */

#define BP_SIZE BP_SLOT_NUM*BP_SLOT_SIZE    /* 1 sec G.711 - 8kHz * 8bit
                           per sample */

#define BP_MAX_SIZE BP_SLOT_NUM*50


typedef struct {
    char x[BP_SLOT_SIZE];    
} bp_slot;

typedef struct {
    int pktlen; 
    int prev;   
    int next;   
} poitem;

typedef struct playout_buff_t {
    bp_slot **bufferpool;        
    poitem pobuff[BP_MAX_SIZE]; 
    pthread_mutex_t po_mutex;   
    /* pthread_cond_t cond_empty; */
    int pocount;            
    int pohead;            
    int potail;            
    uint32_t cycles;            
                                         // shawill: probably to be moved.
} playout_buff;

typedef struct buffer_pool_t {
    bp_slot *bufferpool;       
    pthread_mutex_t fl_mutex;  
    pthread_cond_t cond_full;  
    int *freelist;             
    int flhead;                
    int flcount;               
    int size;
} buffer_pool;

#define PKT_DUPLICATED    1
#define PKT_MISORDERED    2

int poinit(playout_buff *, buffer_pool *);
int poadd(playout_buff *, int, uint32_t);
int podel(playout_buff *, int);
int bpinit(buffer_pool *);
int bpkill(buffer_pool *);
int bpget(buffer_pool *);
int bpfree(buffer_pool *, int);
int bprmv(buffer_pool *, playout_buff *, int);
int bpenlarge(buffer_pool * bp);

#endif /* NEMESI_BUFFERPOOL_H */
/* @} */

---