source: svn/newcon3bcm2_21bu/BSEAV/lib/scte_127/pmt_desc_scte_127.c

/***************************************************************************
 *     Copyright (c) 2008, Broadcom Corporation
 *     All Rights Reserved
 *     Confidential Property of Broadcom Corporation
 *
 *  THIS SOFTWARE MAY ONLY BE USED SUBJECT TO AN EXECUTED SOFTWARE LICENSE
 *  AGREEMENT  BETWEEN THE USER AND BROADCOM.  YOU HAVE NO RIGHT TO USE OR
 *  EXPLOIT THIS MATERIAL EXCEPT SUBJECT TO THE TERMS OF SUCH AN AGREEMENT.
 *
 * $brcm_Workfile: pes_scte_127.c $
 * $brcm_Revision: $
 * $brcm_Date: $
 *
 * [File Description:]
 *
 * Revision History:
 *
 ***************************************************************************/
#include "pmt_desc_scte_127.h"

BDBG_MODULE(pmt_desc_scte_127);

#define PMT_SECTION_LENGTH(buf) (TS_READ_16(&buf[PMT_DESC_SECTION_LEN_OFFSET]) & 0xFFF)

/* return to start point of descriptors */
uint8_t *pmt_table_parser(const uint8_t *pmt_table, size_t size, size_t *desc_bytes)
{
        uint32_t len, len1;
        uint8_t *p;
        
        /* we assume that the size of pmt buffer must be 188 or more */
        CHECK(pmt_table && desc_bytes);

        /* table ID byte */
        if (PMT_DESC_TABLE_CODE_ID != pmt_table[0]) {
#ifdef  HOST_BUILD
                printf("%s: not PMT table (0x%x)\n", __func__, pmt_table[0]);
#endif
                return NULL;
        }
        
        p = (uint8_t *)pmt_table;
        p++;
        len = (TS_READ_16(p) & 0xFFF);
#ifdef  HOST_BUILD
        printf("%s: PMT section len = %d\n", __func__, len);
#endif
        p += 2;
#ifdef  HOST_BUILD
        printf("%s: PMT program no. = %d\n", __func__, TS_READ_16(p));
#endif
        p += 2;

        /* skip more bytes */
        p += 1 + 1 + 1;         /* version number + section number + last section number */
        
#ifdef  HOST_BUILD
        printf("%s: PMT PID number  = 0x%04x\n", __func__, TS_READ_16(p) & 0xFFF);
#endif
        p += 2;

        len1 = TS_READ_16(p) & 0xFFF;
        p += 2;
        /* skip program info length info */
        p += len1;

        size = (int)(p - pmt_table);

        *desc_bytes = len - 4 - (size - 8);

        return p;
}

#ifdef  HOST_BUILD
/* return to start point of descriptors */
uint8_t *pmt_parser_ts(const uint8_t *pmt, size_t *size, size_t *desc_bytes)
{
        uint32_t len;
        uint8_t *p, adaptation_field;
        
        /* we assume that the size of pmt buffer must be 188 or more */
        CHECK(pmt && size && desc_bytes);

        /* sync byte */
        CHECK(0x47 == pmt[0]);
        adaptation_field = (pmt[PMT_DESC_ADAPTATION_OFFSET] >> 4) & 0x3;
        if (0x01 != adaptation_field) {
                printf("%s: invalid PMT packet (0x%x)\n", __func__, adaptation_field);
                return NULL;
        }
        p = (uint8_t *)pmt + PMT_DESC_TABLE_ID_OFFSET;
        *size -= PMT_DESC_TABLE_ID_OFFSET;
        p = pmt_table_parser(p, *size, &len); 
        if (p) {
                *size = (int)(p - pmt);
        }
        else
                *size = 0;

        return p;
}

void pmt_desc_scte127_dump(const uint8_t *desc_data, pmt_descriptor *pmt_desc)
{
        uint8_t *p;
        int len;

        printf("====Dump VBI descriptor====\n");
        printf("\tstream type = 0x%02x\n", pmt_desc->stream_type);
        printf("\telement. PID= 0x%04x\n", pmt_desc->elementary_pid);
        printf("\tES info len = %d\n", pmt_desc->es_info_length);

        p = (uint8_t *)desc_data;
        CHECK(PMT_DESC_VBI_DESCRIPTOR_ID == *(p));
        p++;
        len = *p;
        p++;
        
        while (len) {
                switch ((int)*p)
                {
                        case SCTE_127_DATA_SERVICE_ID_AMOL:
                                printf("\thas AMOL 48/96 data\n");
                                break;  

                        case SCTE_127_DATA_SERVICE_ID_TVG2X:
                                printf("\thas TVG2X data\n");
                                break;  

                        case 0xfd:
                                printf("\thas Protected 1 data\n");
                                break;  

                        case SCTE_127_DATA_SERVICE_ID_NABTS:
                                printf("\thas NABTS data\n");
                                break;  

                        case 0xfA:
                                printf("\thas Protected 2 data\n");
                                break;  

                        case SCTE_127_DATA_SERVICE_ID_CP:
                                printf("\thas Copy Protection data\n");
                                break;  

                        case 0xf8:
                                printf("\thas Protected 3 data\n");
                                break;  

                        case SCTE_127_DATA_SERVICE_ID_VITC:
                                printf("\thas VITC data\n");
                                break;  

                        default:
                                break;
                }
                p++;
                len--;
                len -= (*p + 1);
                p += (*p + 1);
        }
}
#endif

uint8_t *pmt_desc_find(const uint8_t *desc_data, size_t desc_bytes, pmt_descriptor *pmt_desc)
{
        uint8_t *p = (uint8_t *)desc_data;
        int len;
        
        CHECK(desc_data && desc_bytes && pmt_desc);
        
        while (desc_bytes) 
        {
                if (*p == pmt_desc->stream_type)
                {
                        pmt_desc->elementary_pid = TS_READ_16(p + 1) & 0x1FFF;
                        pmt_desc->es_info_length = TS_READ_16(p + 3) & 0xFFF;
                        return p;       
                }       
                p += 3;
                desc_bytes -= 3;
                len = TS_READ_16(p) & 0xFFF;
                p += len;
                desc_bytes -= len;
                p += 2;
                desc_bytes -= 2;
        };

        return NULL;
}

uint8_t *pmt_desc_is_scte127(const uint8_t *desc_data, uint16_t es_info_length)
{
        uint8_t *p = (uint8_t *)desc_data;
        int len;

        p += 5; /* move to the start of descriptor id */
        while (es_info_length > 0) {
                if (PMT_DESC_VBI_DESCRIPTOR_ID == *p) {
                        return p;
        }
                p++;
                len = (int)*p;
                p += len + 1;
                es_info_length -= (len + 2);
        }
        return NULL;
}