diff options
Diffstat (limited to 'kaffeine/src/input/dvb/lib/libdvben50221/en50221_app_dvb.c')
-rw-r--r-- | kaffeine/src/input/dvb/lib/libdvben50221/en50221_app_dvb.c | 387 |
1 files changed, 203 insertions, 184 deletions
diff --git a/kaffeine/src/input/dvb/lib/libdvben50221/en50221_app_dvb.c b/kaffeine/src/input/dvb/lib/libdvben50221/en50221_app_dvb.c index dfda1bf..21b2bec 100644 --- a/kaffeine/src/input/dvb/lib/libdvben50221/en50221_app_dvb.c +++ b/kaffeine/src/input/dvb/lib/libdvben50221/en50221_app_dvb.c @@ -2,7 +2,7 @@ en50221 encoder An implementation for libdvb an implementation for the en50221 transport layer - Copyright (C) 2004, 2005 Manu Abraham (manu@kromtek.com) + Copyright (C) 2004, 2005 Manu Abraham <abraham.manu@gmail.com> Copyright (C) 2005 Julian Scheel (julian at jusst dot de) Copyright (C) 2006 Andrew de Quincey (adq_dvb@lidskialf.net) @@ -18,7 +18,7 @@ You should have received a copy of the GNU Lesser General Public License along with this library; if not, write to the Free Software - Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA + Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ #include <string.h> @@ -28,137 +28,144 @@ #include "en50221_app_tags.h" #include "asn_1.h" -struct en50221_app_dvb_private { - struct en50221_app_send_functions *funcs; +struct en50221_app_dvb { + struct en50221_app_send_functions *funcs; - en50221_app_dvb_tune_callback tune_callback; - void *tune_callback_arg; + en50221_app_dvb_tune_callback tune_callback; + void *tune_callback_arg; - en50221_app_dvb_replace_callback replace_callback; - void *replace_callback_arg; + en50221_app_dvb_replace_callback replace_callback; + void *replace_callback_arg; - en50221_app_dvb_clear_replace_callback clear_replace_callback; - void *clear_replace_callback_arg; + en50221_app_dvb_clear_replace_callback clear_replace_callback; + void *clear_replace_callback_arg; - pthread_mutex_t lock; + pthread_mutex_t lock; }; -static int en50221_app_dvb_parse_tune(struct en50221_app_dvb_private *private, - uint8_t slot_id, uint16_t session_number, - uint8_t *data, uint32_t data_length); +static int en50221_app_dvb_parse_tune(struct en50221_app_dvb *dvb, + uint8_t slot_id, + uint16_t session_number, + uint8_t * data, + uint32_t data_length); -static int en50221_app_dvb_parse_replace(struct en50221_app_dvb_private *private, - uint8_t slot_id, uint16_t session_number, - uint8_t *data, uint32_t data_length); +static int en50221_app_dvb_parse_replace(struct en50221_app_dvb *dvb, + uint8_t slot_id, + uint16_t session_number, + uint8_t * data, + uint32_t data_length); -static int en50221_app_dvb_parse_clear_replace(struct en50221_app_dvb_private *private, - uint8_t slot_id, uint16_t session_number, - uint8_t *data, uint32_t data_length); +static int en50221_app_dvb_parse_clear_replace(struct en50221_app_dvb *dvb, + uint8_t slot_id, + uint16_t session_number, + uint8_t * data, + uint32_t data_length); -en50221_app_dvb en50221_app_dvb_create(struct en50221_app_send_functions *funcs) +struct en50221_app_dvb *en50221_app_dvb_create(struct en50221_app_send_functions *funcs) { - struct en50221_app_dvb_private *private = NULL; - - // create structure and set it up - private = malloc(sizeof(struct en50221_app_dvb_private)); - if (private == NULL) { - return NULL; - } - private->funcs = funcs; - private->tune_callback = NULL; - private->replace_callback = NULL; - private->clear_replace_callback = NULL; - - pthread_mutex_init(&private->lock, NULL); - - // done - return private; + struct en50221_app_dvb *dvb = NULL; + + // create structure and set it up + dvb = malloc(sizeof(struct en50221_app_dvb)); + if (dvb == NULL) { + return NULL; + } + dvb->funcs = funcs; + dvb->tune_callback = NULL; + dvb->replace_callback = NULL; + dvb->clear_replace_callback = NULL; + + pthread_mutex_init(&dvb->lock, NULL); + + // done + return dvb; } -void en50221_app_dvb_destroy(en50221_app_dvb dvb) +void en50221_app_dvb_destroy(struct en50221_app_dvb *dvb) { - struct en50221_app_dvb_private *private = (struct en50221_app_dvb_private *) dvb; - - pthread_mutex_destroy(&private->lock); - free(private); + pthread_mutex_destroy(&dvb->lock); + free(dvb); } -void en50221_app_dvb_register_tune_callback(en50221_app_dvb dvb, - en50221_app_dvb_tune_callback callback, void *arg) +void en50221_app_dvb_register_tune_callback(struct en50221_app_dvb *dvb, + en50221_app_dvb_tune_callback callback, + void *arg) { - struct en50221_app_dvb_private *private = (struct en50221_app_dvb_private *) dvb; - - pthread_mutex_lock(&private->lock); - private->tune_callback = callback; - private->tune_callback_arg = arg; - pthread_mutex_unlock(&private->lock); + pthread_mutex_lock(&dvb->lock); + dvb->tune_callback = callback; + dvb->tune_callback_arg = arg; + pthread_mutex_unlock(&dvb->lock); } -void en50221_app_dvb_register_replace_callback(en50221_app_dvb dvb, - en50221_app_dvb_replace_callback callback, void *arg) +void en50221_app_dvb_register_replace_callback(struct en50221_app_dvb *dvb, + en50221_app_dvb_replace_callback callback, + void *arg) { - struct en50221_app_dvb_private *private = (struct en50221_app_dvb_private *) dvb; - - pthread_mutex_lock(&private->lock); - private->replace_callback = callback; - private->replace_callback_arg = arg; - pthread_mutex_unlock(&private->lock); + pthread_mutex_lock(&dvb->lock); + dvb->replace_callback = callback; + dvb->replace_callback_arg = arg; + pthread_mutex_unlock(&dvb->lock); } -void en50221_app_dvb_register_clear_replace_callback(en50221_app_dvb dvb, - en50221_app_dvb_clear_replace_callback callback, void *arg) +void en50221_app_dvb_register_clear_replace_callback(struct en50221_app_dvb *dvb, + en50221_app_dvb_clear_replace_callback callback, + void *arg) { - struct en50221_app_dvb_private *private = (struct en50221_app_dvb_private *) dvb; - - pthread_mutex_lock(&private->lock); - private->clear_replace_callback = callback; - private->clear_replace_callback_arg = arg; - pthread_mutex_unlock(&private->lock); + pthread_mutex_lock(&dvb->lock); + dvb->clear_replace_callback = callback; + dvb->clear_replace_callback_arg = arg; + pthread_mutex_unlock(&dvb->lock); } -int en50221_app_dvb_ask_release(en50221_app_dvb dvb, uint16_t session_number) +int en50221_app_dvb_ask_release(struct en50221_app_dvb *dvb, + uint16_t session_number) { - struct en50221_app_dvb_private *private = (struct en50221_app_dvb_private *) dvb; - uint8_t data[4]; + uint8_t data[4]; - data[0] = (TAG_ASK_RELEASE >> 16) & 0xFF; - data[1] = (TAG_ASK_RELEASE >> 8) & 0xFF; - data[2] = TAG_ASK_RELEASE & 0xFF; - data[3] = 0; + data[0] = (TAG_ASK_RELEASE >> 16) & 0xFF; + data[1] = (TAG_ASK_RELEASE >> 8) & 0xFF; + data[2] = TAG_ASK_RELEASE & 0xFF; + data[3] = 0; - return private->funcs->send_data(private->funcs->arg, session_number, data, 4); + return dvb->funcs->send_data(dvb->funcs->arg, session_number, data, 4); } -int en50221_app_dvb_message(en50221_app_dvb dvb, - uint8_t slot_id, - uint16_t session_number, - uint32_t resource_id, - uint8_t *data, uint32_t data_length) +int en50221_app_dvb_message(struct en50221_app_dvb *dvb, + uint8_t slot_id, + uint16_t session_number, + uint32_t resource_id, + uint8_t * data, uint32_t data_length) { - struct en50221_app_dvb_private *private = (struct en50221_app_dvb_private *) dvb; - (void) resource_id; - - // get the tag - if (data_length < 3) { - print(LOG_LEVEL, ERROR, 1, "Received short data\n"); - return -1; - } - uint32_t tag = (data[0] << 16) | (data[1] << 8) | data[2]; - - switch(tag) - { - case TAG_TUNE: - return en50221_app_dvb_parse_tune(private, slot_id, session_number, data+3, data_length-3); - case TAG_REPLACE: - return en50221_app_dvb_parse_replace(private, slot_id, session_number, data+3, data_length-3); - case TAG_CLEAR_REPLACE: - return en50221_app_dvb_parse_clear_replace(private, slot_id, session_number, data+3, data_length-3); - } - - print(LOG_LEVEL, ERROR, 1, "Received unexpected tag %x\n", tag); - return -1; + (void) resource_id; + + // get the tag + if (data_length < 3) { + print(LOG_LEVEL, ERROR, 1, "Received short data\n"); + return -1; + } + uint32_t tag = (data[0] << 16) | (data[1] << 8) | data[2]; + + switch (tag) { + case TAG_TUNE: + return en50221_app_dvb_parse_tune(dvb, slot_id, + session_number, data + 3, + data_length - 3); + case TAG_REPLACE: + return en50221_app_dvb_parse_replace(dvb, slot_id, + session_number, + data + 3, + data_length - 3); + case TAG_CLEAR_REPLACE: + return en50221_app_dvb_parse_clear_replace(dvb, slot_id, + session_number, + data + 3, + data_length - 3); + } + + print(LOG_LEVEL, ERROR, 1, "Received unexpected tag %x\n", tag); + return -1; } @@ -170,94 +177,106 @@ int en50221_app_dvb_message(en50221_app_dvb dvb, -static int en50221_app_dvb_parse_tune(struct en50221_app_dvb_private *private, - uint8_t slot_id, uint16_t session_number, - uint8_t *data, uint32_t data_length) +static int en50221_app_dvb_parse_tune(struct en50221_app_dvb *dvb, + uint8_t slot_id, + uint16_t session_number, + uint8_t * data, uint32_t data_length) { - // validate data - if (data_length < 9) { - print(LOG_LEVEL, ERROR, 1, "Received short data\n"); - return -1; - } - if (data[0] != 8) { - print(LOG_LEVEL, ERROR, 1, "Received short data\n"); - return -1; - } - uint8_t *tune_data = data+1; - - // parse it - uint16_t network_id = (tune_data[0] << 8) | tune_data[1]; - uint16_t original_network_id = (tune_data[2] << 8) | tune_data[3]; - uint16_t transport_stream_id = (tune_data[4] << 8) | tune_data[5]; - uint16_t service_id = (tune_data[6] << 8) | tune_data[7]; - - // tell the app - pthread_mutex_lock(&private->lock); - en50221_app_dvb_tune_callback cb = private->tune_callback; - void *cb_arg = private->tune_callback_arg; - pthread_mutex_unlock(&private->lock); - if (cb) { - return cb(cb_arg, slot_id, session_number, network_id, original_network_id, transport_stream_id, service_id); - } - return 0; + // validate data + if (data_length < 9) { + print(LOG_LEVEL, ERROR, 1, "Received short data\n"); + return -1; + } + if (data[0] != 8) { + print(LOG_LEVEL, ERROR, 1, "Received short data\n"); + return -1; + } + uint8_t *tune_data = data + 1; + + // parse it + uint16_t network_id = (tune_data[0] << 8) | tune_data[1]; + uint16_t original_network_id = (tune_data[2] << 8) | tune_data[3]; + uint16_t transport_stream_id = (tune_data[4] << 8) | tune_data[5]; + uint16_t service_id = (tune_data[6] << 8) | tune_data[7]; + + // tell the app + pthread_mutex_lock(&dvb->lock); + en50221_app_dvb_tune_callback cb = dvb->tune_callback; + void *cb_arg = dvb->tune_callback_arg; + pthread_mutex_unlock(&dvb->lock); + if (cb) { + return cb(cb_arg, slot_id, session_number, network_id, + original_network_id, transport_stream_id, + service_id); + } + return 0; } -static int en50221_app_dvb_parse_replace(struct en50221_app_dvb_private *private, - uint8_t slot_id, uint16_t session_number, - uint8_t *data, uint32_t data_length) +static int en50221_app_dvb_parse_replace(struct en50221_app_dvb *dvb, + uint8_t slot_id, + uint16_t session_number, + uint8_t * data, + uint32_t data_length) { - // validate data - if (data_length < 6) { - print(LOG_LEVEL, ERROR, 1, "Received short data\n"); - return -1; - } - if (data[0] != 5) { - print(LOG_LEVEL, ERROR, 1, "Received short data\n"); - return -1; - } - uint8_t *replace_data = data+1; - - // parse it - uint8_t replacement_ref = replace_data[0]; - uint16_t replace_pid = ((replace_data[1] & 0x1f)<<8) | replace_data[2]; - uint16_t replacement_pid = ((replace_data[3] & 0x1f)<<8) | replace_data[4]; - - // tell the app - pthread_mutex_lock(&private->lock); - en50221_app_dvb_replace_callback cb = private->replace_callback; - void *cb_arg = private->replace_callback_arg; - pthread_mutex_unlock(&private->lock); - if (cb) { - return cb(cb_arg, slot_id, session_number, replacement_ref, replace_pid, replacement_pid); - } - return 0; + // validate data + if (data_length < 6) { + print(LOG_LEVEL, ERROR, 1, "Received short data\n"); + return -1; + } + if (data[0] != 5) { + print(LOG_LEVEL, ERROR, 1, "Received short data\n"); + return -1; + } + uint8_t *replace_data = data + 1; + + // parse it + uint8_t replacement_ref = replace_data[0]; + uint16_t replace_pid = + ((replace_data[1] & 0x1f) << 8) | replace_data[2]; + uint16_t replacement_pid = + ((replace_data[3] & 0x1f) << 8) | replace_data[4]; + + // tell the app + pthread_mutex_lock(&dvb->lock); + en50221_app_dvb_replace_callback cb = dvb->replace_callback; + void *cb_arg = dvb->replace_callback_arg; + pthread_mutex_unlock(&dvb->lock); + if (cb) { + return cb(cb_arg, slot_id, session_number, replacement_ref, + replace_pid, replacement_pid); + } + return 0; } -static int en50221_app_dvb_parse_clear_replace(struct en50221_app_dvb_private *private, - uint8_t slot_id, uint16_t session_number, - uint8_t *data, uint32_t data_length) +static int en50221_app_dvb_parse_clear_replace(struct en50221_app_dvb *dvb, + uint8_t slot_id, + uint16_t session_number, + uint8_t * data, + uint32_t data_length) { - // validate data - if (data_length < 2) { - print(LOG_LEVEL, ERROR, 1, "Received short data\n"); - return -1; - } - if (data[0] != 1) { - print(LOG_LEVEL, ERROR, 1, "Received short data\n"); - return -1; - } - uint8_t *replace_data = data+1; - - // parse it - uint8_t replacement_ref = replace_data[0]; - - // tell the app - pthread_mutex_lock(&private->lock); - en50221_app_dvb_clear_replace_callback cb = private->clear_replace_callback; - void *cb_arg = private->clear_replace_callback_arg; - pthread_mutex_unlock(&private->lock); - if (cb) { - return cb(cb_arg, slot_id, session_number, replacement_ref); - } - return 0; + // validate data + if (data_length < 2) { + print(LOG_LEVEL, ERROR, 1, "Received short data\n"); + return -1; + } + if (data[0] != 1) { + print(LOG_LEVEL, ERROR, 1, "Received short data\n"); + return -1; + } + uint8_t *replace_data = data + 1; + + // parse it + uint8_t replacement_ref = replace_data[0]; + + // tell the app + pthread_mutex_lock(&dvb->lock); + en50221_app_dvb_clear_replace_callback cb = + dvb->clear_replace_callback; + void *cb_arg = dvb->clear_replace_callback_arg; + pthread_mutex_unlock(&dvb->lock); + if (cb) { + return cb(cb_arg, slot_id, session_number, + replacement_ref); + } + return 0; } |