stv0g/tvheadend
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

tvheadend: Use atomic ops for packet refcounts instead of a global mutex

Browse source
This commit is contained in:
Andreas Öman 2008-09-28 13:28:43 +00:00
parent 168aaa826c
commit 2232af1d3b
1 changed files with 4 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
packet.c
View file

@ -16,14 +16,12 @@
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include <libhts/htsatomic.h>
#include "tvhead.h"
#include "packet.h"
#include "string.h"
static pthread_mutex_t refmutex = PTHREAD_MUTEX_INITIALIZER;
/*
*
*/
@ -64,15 +62,8 @@ pkt_alloc(void *data, size_t datalen, int64_t pts, int64_t dts)
void
pkt_ref_dec(th_pkt_t *pkt)
{
if(pkt->pkt_refcount == 1) {
if((atomic_add(&pkt->pkt_refcount, -1)) == 1)
pkt_destroy(pkt);
return;
}
/* Use atomic decrease */
pthread_mutex_lock(&refmutex);
pkt->pkt_refcount--;
pthread_mutex_unlock(&refmutex);
}
@ -82,10 +73,7 @@ pkt_ref_dec(th_pkt_t *pkt)
void
pkt_ref_inc(th_pkt_t *pkt)
{
/* Use atomic increase */
pthread_mutex_lock(&refmutex);
pkt->pkt_refcount++;
pthread_mutex_unlock(&refmutex);
atomic_add(&pkt->pkt_refcount, 1);
}
/**
@ -94,9 +82,7 @@ pkt_ref_inc(th_pkt_t *pkt)
void
pkt_ref_inc_poly(th_pkt_t *pkt, int n)
{
pthread_mutex_lock(&refmutex);
pkt->pkt_refcount += n;
pthread_mutex_unlock(&refmutex);
atomic_add(&pkt->pkt_refcount, n);
}