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

descrambler: filter equal ECM/EMM requests

Browse source
This commit is contained in:
Jaroslav Kysela 2014-06-08 21:13:09 +02:00
parent 9887c5773d
commit a326371cf9
2 changed files with 17 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/descrambler.h
View file

@ -61,7 +61,9 @@ typedef void (*descrambler_section_callback_t)
typedef struct descrambler_section {
TAILQ_ENTRY(descrambler_section) link;
descrambler_section_callback_t callback;
void *opaque;
void *opaque;
uint8_t *last_data;
int last_data_len;
} descrambler_section_t;
typedef struct descrambler_table {

15
src/descrambler/descrambler.c
View file

@ -216,7 +216,18 @@ descrambler_table_callback
pthread_mutex_lock(&mt->mt_mux->mm_descrambler_lock);
TAILQ_FOREACH(ds, &dt->sections, link)
ds->callback(ds->opaque, mt->mt_pid, ptr, len);
if (ds->last_data == NULL || len != ds->last_data_len ||
memcmp(ds->last_data, ptr, len)) {
free(ds->last_data);
ds->last_data = malloc(len);
if (ds->last_data) {
memcpy(ds->last_data, ptr, len);
ds->last_data_len = len;
} else {
ds->last_data_len = 0;
}
ds->callback(ds->opaque, mt->mt_pid, ptr, len);
}
pthread_mutex_unlock(&mt->mt_mux->mm_descrambler_lock);
return 0;
}
@ -283,6 +294,7 @@ descrambler_close_pid_( mpegts_mux_t *mux, void *opaque, int pid )
if (ds->opaque == opaque) {
TAILQ_REMOVE(&dt->sections, ds, link);
ds->callback(ds->opaque, -1, NULL, 0);
free(ds->last_data);
free(ds);
if (TAILQ_FIRST(&dt->sections) == NULL) {
TAILQ_REMOVE(&mux->mm_descrambler_tables, dt, link);
@ -324,6 +336,7 @@ descrambler_flush_tables( mpegts_mux_t *mux )
while ((ds = TAILQ_FIRST(&dt->sections)) != NULL) {
TAILQ_REMOVE(&dt->sections, ds, link);
ds->callback(ds->opaque, -1, NULL, 0);
free(ds->last_data);
free(ds);
}
TAILQ_REMOVE(&mux->mm_descrambler_tables, dt, link);