nownext.c

Dvbstreamer 用在解析MPTS的部分内容

/*
Copyright (C) 2006  Adam Charrett

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program 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 General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA

nownext.c

Plugin to display Present/Following (ie Now/Next) EPG information.

*/
#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>
#include <string.h>
#include <stdint.h>

#include "plugin.h"
#include "dvbpsi/datetime.h"
#include "dvbpsi/eit.h"
#include "dvbpsi/dr_4d.h"

#include "list.h"
#include "logging.h"
#include "subtableprocessor.h"



/*******************************************************************************
* Defines                                                                      *
*******************************************************************************/
#define EIT_PID 0x12
#define TABLE_ID_PF_ACTUAL 0x4e
#define TABLE_ID_PF_OTHER  0x4f

#define MAX_STRING_LEN 256


/*******************************************************************************
* Typedefs                                                                     *
*******************************************************************************/

typedef struct Event_s
{
    char name[MAX_STRING_LEN];
    char description[MAX_STRING_LEN];
    dvbpsi_date_time_t startTime;
    dvbpsi_eit_event_duration_t duration;
}Event_t;

typedef struct ServiceNowNextInfo_s
{
    uint16_t networkId;
    uint16_t tsId;
    uint16_t serviceId;
    Event_t  now;
    Event_t  next;
}ServiceNowNextInfo_t;


/*******************************************************************************
* Prototypes                                                                   *
*******************************************************************************/
static void CommandNow(int argc, char **argv);
static void CommandNext(int argc, char **argv);
static void PrintEvent(Event_t *event);
static void Init0x12Filter(PIDFilter_t *filter);
static void Deinit0x12Filter(PIDFilter_t *filter);
static ServiceNowNextInfo_t *FindServiceName(char *name);
static ServiceNowNextInfo_t *FindService(uint16_t networkId, uint16_t tsId, uint16_t serviceId);
static void SubTableHandler(void * arg, dvbpsi_handle demuxHandle, uint8_t tableId, uint16_t extension);
static void ProcessEIT(void *arg, dvbpsi_eit_t *newEIT);
static void UpdateEvent(Event_t *event, dvbpsi_eit_event_t *eitevent);


/*******************************************************************************
* Global variables                                                             *
*******************************************************************************/
static PluginFilter_t filter = {NULL, Init0x12Filter, Deinit0x12Filter};
static List_t *serviceNowNextInfoList;

static char NOWNEXT[]="NowNext";

/*******************************************************************************
* Plugin Setup                                                                 *
*******************************************************************************/
#ifdef __CYGWIN__
#define PluginInterface NowNextPluginInterface
#endif

PLUGIN_COMMANDS(
    {
        "now",
        FALSE, 1, 1,
        "Display the current program.",
        "Display the current program on all channels (assuming the data is "
        "present on the current TS). Dates are in YYYY/MM/DD format and times"
        "are in HH:MM:SS",
        CommandNow
    },
    {
        "next",
        FALSE, 1, 1,
        "Display the next program.",
        "Display the next program on all channels (assuming the data is "
        "present on the current TS). Dates are in YYYY/MM/DD format and times"
        "are in HH:MM:SS",
        CommandNext
    }
);

PLUGIN_FEATURES(
    PLUGIN_FEATURE_FILTER(filter)
    );

PLUGIN_INTERFACE_CF(
    PLUGIN_FOR_DVB,
    "NowNext", "0.2", 
    "Plugin to display present/following EPG information.", 
    "[e-mail]"
    );

/*******************************************************************************
* Command Functions                                                            *
*******************************************************************************/
static void CommandNow(int argc, char **argv)
{
    ServiceNowNextInfo_t *info = FindServiceName(argv[0]);
    if (info)
    {
        PrintEvent(&info->now);
    }
    else
    {
        CommandError(COMMAND_ERROR_GENERIC, "No info found for \"%s\"", argv[0]);
    }
}

static void CommandNext(int argc, char **argv)
{
    ServiceNowNextInfo_t *info = FindServiceName(argv[0]);
    if (info)
    {
        PrintEvent(&info->next);
    }    
    else
    {
        CommandError(COMMAND_ERROR_GENERIC, "No info found for \"%s\"", argv[0]);
    }    
}

static void PrintEvent(Event_t *event)
{
    CommandPrintf("Name       : %s\n", event->name);
    CommandPrintf("Start time : %04d/%02d/%02d %02d:%02d:%02d\n",
        event->startTime.i_year, event->startTime.i_month, event->startTime.i_day,
        event->startTime.i_hour, event->startTime.i_minute, event->startTime.i_second);
    CommandPrintf("Duration   : %02d:%02d:%02d\n", 
        event->duration.i_hours, event->duration.i_minutes, event->duration.i_seconds);
    CommandPrintf("Description:\n%s\n", event->description);
}
/*******************************************************************************
* Filter Functions                                                             *
*******************************************************************************/
static void Init0x12Filter(PIDFilter_t *filter)
{
    serviceNowNextInfoList = ListCreate();
    filter->name = "Now/Next";
    filter->enabled = TRUE;
    SubTableProcessorInit(filter, 0x12, SubTableHandler, NULL, NULL, NULL);
    if (filter->tsFilter->adapter->hardwareRestricted)
    {
        DVBDemuxAllocateFilter(filter->tsFilter->adapter, EIT_PID, TRUE);
    }       
}

static void Deinit0x12Filter(PIDFilter_t *filter)
{
    filter->enabled = FALSE;
    if (filter->tsFilter->adapter->hardwareRestricted)
    {
        DVBDemuxReleaseFilter(filter->tsFilter->adapter, EIT_PID);
    }            
    SubTableProcessorDeinit(filter);
    ListFree(serviceNowNextInfoList, free);
}

static void SubTableHandler(void * arg, dvbpsi_handle demuxHandle, uint8_t tableId, uint16_t extension)
{
    switch (tableId)
    {
        case TABLE_ID_PF_ACTUAL: 
            dvbpsi_AttachEIT(demuxHandle, tableId, extension, ProcessEIT, NULL);
            break;
        case TABLE_ID_PF_OTHER: 
            dvbpsi_AttachEIT(demuxHandle, tableId, extension, ProcessEIT, NULL);
            break;
    }
}

static void ProcessEIT(void *arg, dvbpsi_eit_t *newEIT)
{
    ServiceNowNextInfo_t *info = FindService(newEIT->i_network_id, newEIT->i_ts_id, newEIT->i_service_id);
    LogModule(LOG_DEBUG, NOWNEXT, "EIT received (version %d) net id %x ts id %x service id %x info %p\n",
        newEIT->i_version, newEIT->i_network_id, newEIT->i_ts_id, newEIT->i_service_id, info);
    if (!info)
    {
        info = calloc(1, sizeof(ServiceNowNextInfo_t));
        if (info)
        {
            ListAdd(serviceNowNextInfoList, info);
            info->networkId = newEIT->i_network_id;
            info->tsId = newEIT->i_ts_id;
            info->serviceId = newEIT->i_service_id;
        }
        else
        {
            return;
        }
    }

    memset(&info->now, 0, sizeof(Event_t));
    memset(&info->next, 0, sizeof(Event_t));
    if (newEIT->p_first_event)
    {
        UpdateEvent(&info->now, newEIT->p_first_event);
        if (newEIT->p_first_event->p_next)
        {
            UpdateEvent(&info->next, newEIT->p_first_event->p_next);
        }
    }

    ObjectRefDec(newEIT);
}

static void UpdateEvent(Event_t *event, dvbpsi_eit_event_t *eitevent)
{
    dvbpsi_descriptor_t *descriptor;
    dvbpsi_short_event_dr_t * sedescriptor;

    event->startTime = eitevent->t_start_time;
    event->duration  = eitevent->t_duration;
                        
    for (descriptor = eitevent->p_first_descriptor; descriptor; descriptor = descriptor->p_next)
    {
        if (descriptor->i_tag == 0x4d)
        {
            sedescriptor = dvbpsi_DecodeShortEventDr(descriptor);
            memcpy(event->name, sedescriptor->i_event_name, sedescriptor->i_event_name_length);
            event->name[sedescriptor->i_event_name_length] = 0;
            memcpy(event->description, sedescriptor->i_text, sedescriptor->i_text_length);
            event->description[sedescriptor->i_text_length] = 0;
        }
    }
}

/*******************************************************************************
* Event List Helper Functions                                                  *
*******************************************************************************/
static ServiceNowNextInfo_t *FindServiceName(char *name)
{
    Service_t *service = ServiceFind(name);
    Multiplex_t *multiplex;
    ServiceNowNextInfo_t *info;
    if (!service)
    {
        CommandError(COMMAND_ERROR_GENERIC, "Unknown service \"%s\"", name);
        return NULL;
    }

    multiplex = MultiplexFindUID(service->multiplexUID);
    if (!multiplex)
    {
        CommandError(COMMAND_ERROR_GENERIC, "Failed to find multiplex!");
        ServiceRefDec(service);
        return NULL;
    }

    info = FindService(multiplex->networkId, multiplex->tsId, service->id);
    ServiceRefDec(service);
    MultiplexRefDec(multiplex);
    return info;
}

static ServiceNowNextInfo_t *FindService(uint16_t networkId, uint16_t tsId, uint16_t serviceId)
{
    ListIterator_t iterator;

    for (ListIterator_Init(iterator, serviceNowNextInfoList); 
         ListIterator_MoreEntries(iterator); 
         ListIterator_Next(iterator))
    {
        ServiceNowNextInfo_t *info = ListIterator_Current(iterator);

        if ((info->networkId == networkId) && (info->tsId == tsId) && (info->serviceId == serviceId))
        {
            return info;
        }
    }
    return NULL;
}