source: svn/trunk/newcon3bcm2_21bu/dta/src/app/chan_mgr_rrt.c

/*
Summary:
        Callback function normally called when a complete message has
 *              been received and passed the filter criteria.
 */
#ifdef DEBUG_RRT
static void chm_output_rrt(chm_mgr_t *p_chm);
#endif
static void * chm_smessage_rrt_callback(void * context, size_t size)
{
        chm_mgr_t * p_chm = (chm_mgr_t*)context;
        PSIP_RRT_header header;
        bapp_t *p_app = (bapp_t*)p_chm->p_app;


        p_chm->rrt_cnt++;

        PSIP_RRT_getHeader(p_chm->rrt_buf, &header);

        if ((header.rating_region == 1) || ((size == p_app->settings.rrt_settings.rrt_size) && (memcmp(p_chm->rrt_buf,p_app->settings.rrt_settings.rrt, size) == 0)))
        {
                BDBG_WRN(("RRTs region 1 or they match so don't update\n"));
                return(void*)p_chm->rrt_buf;
        }

#ifdef DEBUG_RRT
        chm_output_rrt(p_chm); /* DEBUG ONLY */
#endif
        p_chm->rrt_evt.type = eCHM_EVT_RRT;
        p_chm->rrt_evt.size = size;
        memcpy(p_chm->rrt_evt.rrt,p_chm->rrt_buf,size);

        chm_post_app_event_cb(p_chm,(chm_event_t*)&p_chm->rrt_evt);
        
        return(void*)p_chm->rrt_buf;
}
/*
Summary:
Get the RRT. return non-zero on failure
 */

static int chm_rrt_start(chm_mgr_t *p_chm,              /* Channel manager reference */
                                                 unsigned short network_pid)
{
        int cerr;
        smessage_stream_params_t params;

        cerr = eCHM_ERR_OK;
        BDBG_MSG(("%s:%d (0x%04x)",__FUNCTION__, __LINE__,network_pid));

        chm_rrt_stop(p_chm);

        p_chm->rrt_msg = smessage_open(smessage_format_psi);
        if (NULL == p_chm->rrt_msg)
        {
                BDBG_ERR(("%s:%d",__FILE__, __LINE__));
                cerr = eCHM_ERR_FAILED;
                goto ExitFunc;
        }
        smessage_stream_params_init(&params, p_chm->rrt_msg);
        params.band = p_chm->band;
        params.pid = (uint16_t)network_pid;
        params.filter.coef[0] = 0xCA;
        params.filter.mask[0] = 0x00;
        params.buffer = p_chm->rrt_buf;
        params.buffer_size = RRT_BUF_LEN;
        /* processing is done in callback */
        params.data_ready_callback = chm_smessage_rrt_callback;
        params.overflow = NULL;
        params.callback_context = (void *)p_chm;
        BDBG_WRN(("%s\n",__FUNCTION__));
        if (b_ok != smessage_start(&params, p_chm->rrt_msg))
        {
                BDBG_ERR(("%s:%d",__FILE__, __LINE__));
                cerr = eCHM_ERR_FAILED;
        }
        ExitFunc:
        return cerr;
}

/*
Summary:
        Stop the RRT. return non-zero on failure
*/
static void chm_rrt_stop(chm_mgr_t *p_chm)
{
        if (NULL != p_chm->rrt_msg)
        {
                BDBG_WRN(("%s\n",__FUNCTION__));
                if (b_ok != smessage_stop(p_chm->rrt_msg))
                {
                        BDBG_ERR(("%s:%d",__FUNCTION__, __LINE__));
                        return;
                }
                smessage_close(p_chm->rrt_msg);
                p_chm->rrt_msg = NULL;
        }
}

#ifdef DEBUG_RRT
static void chm_output_rrt(chm_mgr_t *p_chm)
{
        PSIP_RRT_header header;
        PSIP_RRT_dimension dim;
        PSIP_RRT_value val;
        int dim_idx,val_idx;
        char tmp_str[64];

        if (p_chm->rrt_cnt <= 0)
                return;

        PSIP_RRT_getHeader(p_chm->rrt_buf, &header);
        if (chm_process_mss(p_chm,header.p_rating_region_name_text,tmp_str,64) == 0)
        {
                BDBG_WRN(("RRT %8s",tmp_str));
        }

        for (dim_idx = 0; dim_idx < header.dimensions_defined; ++dim_idx)
        {
                if (PSIP_RRT_getDimension(p_chm->rrt_buf,dim_idx,&dim) != BERR_SUCCESS)
                        continue;

                if (chm_process_mss(p_chm,dim.p_dimension_name_text,tmp_str,sizeof(tmp_str)) == 0)
                {
                        BDBG_WRN(("  RRT[%d] %8s(%d)",dim_idx,tmp_str,dim.graduated_scale));
                }

                for (val_idx = 0; val_idx < dim.values_defined; ++val_idx)
                {
                        if (PSIP_RRT_getValue(p_chm->rrt_buf,dim_idx,val_idx,&val) != BERR_SUCCESS)
                                continue;

                        if (chm_process_mss(p_chm,val.p_rating_value_text,tmp_str,sizeof(tmp_str)) == 0)
                        {
                                BDBG_WRN(("  RRT[%d,%d] %8s",dim_idx,val_idx,tmp_str));
                        }

                        if (chm_process_mss(p_chm,val.p_abbrev_rating_value_text,tmp_str,sizeof(tmp_str)) == 0)
                        {
                                BDBG_WRN(("  RRT[%d,%d] %8s",dim_idx,val_idx,tmp_str));
                        }
                }
        }
}
#endif