play_psfdemux_checksum.c

Sample code for use on smp 863x processor.

/*
 *
 * Copyright (c) Sigma Designs, Inc. 2002. All rights reserved.
 *
 */

/**
   @file play_psfdemux_checksum.c
   @brief sample application for hardware demux of EM86xx
	
   @author Aurelia Popa-Radu, Michael Uman
   @ingroup dccsamplecode
*/

#include "../samples/sample_os.h"

#define ALLOW_OS_CODE 1
#include <libgen.h>
#include "../dcc/include/dcc.h"
#include "../samples/common.h"
#include "command_ids.h"

#include "play_psfdemux_helper.h"

#include "psfdemux_common.h"
#include "../gbuslib/include/gbus_fifo.h" /* needed for receiving data from DemuxOutput direct from DRAM fifo */

#include "../samples/rmttx.h"
#include "checksum.h"

/* ################## Begin DTCP code ################### */
#if (EM86XX_CHIP == EM86XX_CHIPID_TANGO15)
#include "../rmdtcp/include/dtcp_session.h"
#else
#include "../rmdtcpapi/include/dtcp_session.h"
#endif
/* ############### End DTCP code ####################### */

/* to enable or disable the debug messages of this source file, put 1 or 0 below */
#if 0
#define LOCALDBG ENABLE
#else
#define LOCALDBG DISABLE
#endif

#if 0
#define SENDDBG ENABLE
#define CRCDBG	ENABLE
#else
#define SENDDBG DISABLE
#define CRCDBG 	DISABLE
#endif

#define	DO_SAVE			1
#define DO_CRC32		1
//#define DO_DUMP		1
#define WAIT_FOR_KEY		1
#define DO_LINEAR_BUFFER	1
#define USE_WAITEOS			1
#define DO_CAPTURE			1
//#define INIT_DISPLAY_CONSUMER	1
#define SAVEPATH			"SAVEYUV"
#define HANDLE_DISPLAY_STATUS	1

#if 0
#define CALLDBG ENABLE
#else
#define CALLDBG DISABLE
#endif

#define FORCE_MONITOR		0
#define	FORCE_DECRYPTION	1

#define NO_FAST_AUDIO_RECOVERY_AFTER_TRICKMODE 0 // only to disable it (enabled by default), otherwise use -far cmdline option

#define RM_DEVICES_STC      0x1
#define RM_DEVICES_VIDEO    0x2
#define RM_DEVICES_AUDIO    0x4
#define RM_DEVICES_PSFDEMUX 0x8

#define RM_DEVICES_ALL (RM_DEVICES_STC | RM_DEVICES_VIDEO | RM_DEVICES_AUDIO | RM_DEVICES_PSFDEMUX)

#define KEYFLAGS (SET_KEY_DISPLAY | SET_KEY_PLAYBACK | SET_KEY_AUDIO | SET_KEY_DEBUG | SET_KEY_SPI)


#define DMA_BUFFER_SIZE_LOG2	15	// 32k buffer
#define DMA_BUFFER_COUNT	16	// 16*32k = 0x80000 = 0.5M 
#define DEMUX_FIFO_SIZE		(1<<DMA_BUFFER_SIZE_LOG2) * DMA_BUFFER_COUNT	// match the dma pool for standalone
#define DEMUX_XFER_FIFO_COUNT	DMA_BUFFER_COUNT	// same as dma pool buffers - this application sends complete buffer every time. 

#define VIDEO_FIFO_SIZE		( 1792*1024) /* "-vfifo 1792", default same value as in play_demux and play_hwdemux */
#define AUDIO_FIFO_SIZE		(  128*1024)
#define SPU_FIFO_SIZE		(  104*1024)
#define VIDEO_PTS_FIFO_COUNT    (512) /* ~8 sec fifo for 60 frames/sec */
#define VIDEO_INBAND_FIFO_COUNT (128)


#ifdef WITH_MONO
#define MAX_TASK_COUNT		1
#else
#define MAX_TASK_COUNT		3
#endif

#define FILE_PLAYBACK_START_POSITION		0 // byte position in file from where the playback starts - used for debug

/************************************************************************************************
Description of the events - masks correspondence:
  event, module - one event for all tasks         mask                       bit position
    SOFT_IRQ_EVENT_ERROR, CPUBlock                CPU_ERROR_EVENT_MASK       bit0
  
  event, module per task                          mask
    SOFT_IRQ_EVENT_XFER_RECEIVE_READY, DemuxTask  DEMUX_RECEIVE_EVENT_MASK   bit1 
    SOFT_IRQ_XFER_FIFO_READY, DemuxTask           DEMUX_SEND_EVENT_MASK      bit2, used only in file playback 
    SOFT_IRQ_INBAND_COMMAND, DemuxTask            DEMUX_EOS_EVENT_MASK       bit2, same mask as send event
    SOFT_IRQ_INBAND_COMMAND, VideoDecoder         VIDEO_EOS_EVENT_MASK       bit3, used only in file playback
    SOFT_IRQ_INBAND_COMMAND, DisplayBlock         DISPLAY_EOS_EVENT_MASK     bit4, used only in file playback
    SOFT_IRQ_INBAND_COMMAND, AudioDecoder         AUDIO_EOS_EVENT_MASK       bit5, used only in file playback
    SOFT_IRQ_EVENT_DEMUX_SECTION_END, DemuxTask   DEMUX_SECTION_EVENT_MASK   bit6
    SOFT_IRQ_EVENT_FILLING, DemuxTask             DEMUX_THRESHOLD_EVENT_MASK bit7

*************************************************************************************************/
/* 7 events = 1demux + 1video + 1display + 1audio for file playback + 1 xfer receive event + 1 section_end event/threshold when we don't use DMA */
#define MAX_EVENT_COUNT_PER_TASK      7

#define CPU_ERROR_EVENT_MASK          (1<<0)
#define DEMUX_RECEIVE_EVENT_MASK(i)   (1<<(1+0+i*MAX_EVENT_COUNT_PER_TASK))
#define DEMUX_SEND_EVENT_MASK(i)      (1<<(1+1+i*MAX_EVENT_COUNT_PER_TASK))
#define DEMUX_EOS_EVENT_MASK(i)       (1<<(1+1+i*MAX_EVENT_COUNT_PER_TASK))
#define VIDEO_EOS_EVENT_MASK(i)       (1<<(1+2+i*MAX_EVENT_COUNT_PER_TASK))
#define DISPLAY_EOS_EVENT_MASK(i)     (1<<(1+3+i*MAX_EVENT_COUNT_PER_TASK))
#define AUDIO_EOS_EVENT_MASK(i)       (1<<(1+4+i*MAX_EVENT_COUNT_PER_TASK))
#define DEMUX_SECTION_EVENT_MASK(i)   (1<<(1+5+i*MAX_EVENT_COUNT_PER_TASK))
#define DEMUX_THRESHOLD_EVENT_MASK(i) (1<<(1+6+i*MAX_EVENT_COUNT_PER_TASK))

// av_flags
#define VIDEO_PID_FROM_CMDLINE		(1 << 0)
#define PCR_PID_FROM_CMDLINE		(1 << 1)
#define AUDIO_PID_FROM_CMDLINE		(1 << 2)
#define AV_PIDS_ENABLE_FIRST_TIME	(1 << 3)
#define	ECM0_PID_FROM_CMDLINE		(1 << 4)
#define	ECM1_PID_FROM_CMDLINE		(1 << 5)
#define	TTX_PID_FROM_CMDLINE		(1 << 6)

static RMascii		crcLogFilename[1024];

#ifdef	DO_SAVE
void save_frame(int count,
				RMuint8* pLuma, RMuint32 luma_w, RMuint32 luma_h, RMuint32 luma_width,
				RMuint8* pChroma, RMuint32  chroma_w, RMuint32 chroma_h, RMuint32 chroma_width);
#endif

void compute_crclog_filename(RMascii* bsFilename, RMascii* logFilename);
RMstatus WaitForFrames(struct dcc_context *pSendContext);

#ifdef	DO_CAPTURE
int get_picture(struct dcc_context *dccContext);
#endif

struct dvb_csa_key arte_dvb_key_table[] = {
#ifdef ARTE_DVB_KEY_TABLE
#include "keys/arte_dvb_key_table.h"
#endif
};

/* STREAM-4.ts */
struct dvb_csa_key stream_dvb_key_table[] = {
#ifdef STREAM_DVB_KEY_TABLE
#include "keys/stream_dvb_key_table.h"
#endif
};

struct dvb_csa_key cweven_dvb_key_table[] = {
#ifdef CWEVEN_DVB_KEY_TABLE
#include "keys/cweven_dvb_key_table.h"
#endif
};

struct dvb_csa_key cwodd_dvb_key_table[] = {
#ifdef CWODD_DVB_KEY_TABLE
#include "keys/cwodd_dvb_key_table.h"
#endif
};
	
struct dvb_csa_key ecm1_dvb_key_table[] = {
#ifdef ECM1_DVB_KEY_TABLE
#include "keys/ecm1_dvb_key_table.h"
#endif
};
	
struct dvb_csa_key ecm4_dvb_key_table[] = {
	/* to prove that ECM parsing is Ok invalidate key_byte_counter and scrambling settings */
#ifdef ECM4_DVB_KEY_TABLE
#include "keys/ecm4_dvb_key_table.h"
#endif
};

struct dvb_csa_key cwtest_dvb_key_table[] = {
#ifdef CWTEST_DVB_KEY_TABLE
#define ORIGINAL_CWTEST  // for file CWtest.trp
//#define DVBCSA_ODD_TAR // for file phat_odd.mpg
#include "keys/cwtest_dvb_key_table.h"
#endif
};

/* vgs3.mpg */
struct dvb_csa_key vgs3_dvb_key_table[] = {
	/* to prove that ECM parsing is Ok invalidate key_byte_counter and scrambling settings */
#ifdef VGS3_DVB_KEY_TABLE
#include "keys/vgs3_dvb_key_table.h"
#endif
};

/* suitei05_KDDI_DRM.m2t */
struct aes_key skf_aes_key_table[] = {
#ifdef SKF_AES_KEY_TABLE
#include "keys/skf_aes_key_table.h"
#endif
};

/* dsodd.ts */
struct aes_key dsodd_aes_key_table[] = {
#ifdef DSODD_AES_KEY_TABLE
#include "keys/dsodd_aes_key_table.h"
#endif
};

/* scrambled.ts */
struct aes_key scrambled_aes_key_table[] = {
#ifdef SCRAMBLED_AES_KEY_TABLE
#define AES_SCRAMBLED_ORIGINAL
#include "keys/scrambled_aes_key_table.h"
#endif
};

/* dscps.ts */
struct aes_key dscps_aes_key_table[] = {
#ifdef DSCPS_AES_KEY_TABLE
#include "keys/dscps_aes_key_table.h"
#endif
};

/* aes cbc+ofb keys for transport/mpeg2/Confidential/AES/11-7 */
struct aes_key aes_cbc_ofb_key_table[] = {
#ifdef AES_CBC_OFB_KEY_TABLE
//#define AES_KEY_1107
//#define AES_KEY_SCR1111
//#define AES_KEY_SCR1112
#include "keys/aes_cbc_ofb_key_table.h"
#endif
};

/* aes ecb keys (clear partial block) for transport/mpeg2/HD_underwater_encrypted.ts */
struct aes_key aes_ecb_key_table[] = {
#ifdef AES_ECB_KEY_TABLE
#define AES_KEY_ICE_UNDER_CEMA
//#define AES_KEY_TSDAT
#include "keys/aes_ecb_key_table.h"
#endif
};

/* ############## AES_CBC_PRECIPHER TEST CODE BEGIN ############## */
/* hardcoded keys for pre-encrypted test files (ex: mummy.2keys.800000.aes.m2t) */
struct aes_2keys_test precipher_aes_key_table[] = {
#ifdef PRECIPHER_AES_KEY_TABLE
#include "keys/precipher_aes_key_table.h"
#endif
};
/* ############## AES_CBC_PRECIPHER TEST CODE END ############### */

struct dvb_arib_key arib_key_table[] = {
#ifdef MULTI2_EIGHT_KEYS
#define ARIB_KEY_TABLE
#define MULTI2_STREAM_8_ECM
#endif
#ifdef ARIB_KEY_TABLE
//#define MULTI2_U17_TVSIZUOKA
//#define MULTI2_TR27_ECM
//#define MULTI2_TR26_ECM_X2
//#define MULTI2_ARIB_STREAM_1_TO_7
//#define ARIB_orig
#include "keys/arib_key_table.h"
#endif
};

static RMstatus HwPlay(struct context_per_task *context);
static RMstatus HwStop(struct context_per_task *context);
static RMstatus OpenVideoDecoder(struct context_per_task *context);
static RMstatus Play(struct context_per_task *pContext, RMuint32 devices, enum DCCVideoPlayCommand mode);
static RMstatus Stop(struct context_per_task *pContext, RMuint32 devices);
static RMstatus Pause(struct context_per_task *pContext, RMuint32 devices);
static RMstatus ProcessKey(void);


static void printTimeOfDay(struct timeval now)
{
	RMuint64 secondsPerMinute = 60;
	RMuint64 secondsPerHour = 60 * secondsPerMinute;
	RMuint64 secondsPerDay = 24 * secondsPerHour;
	RMuint64 today, h, m;

	today = (now.tv_sec - ((now.tv_sec / secondsPerDay) * secondsPerDay));

	h = today / secondsPerHour;
	today -= h * secondsPerHour;
	m = today / secondsPerMinute;
	today -= m * secondsPerMinute;
	
	fprintf(stderr, "time is %02llu:%02llu:%02llu.%llu\n", h, m, today, (RMuint64)now.tv_usec);

}


#define GET_DATA_FIFO_INFO(pRUA, ModuleId, checkStarvation)		\
	{								\
		struct DataFIFOInfo DataFIFOInfo;			\
		RMreal fullness;					\
		RUAGetProperty(pRUA, ModuleId, RMGenericPropertyID_DataFIFOInfo, &DataFIFOInfo, sizeof(DataFIFOInfo)); \
		fullness = (RMreal)((100./DataFIFOInfo.Size)*DataFIFOInfo.Readable); \
		fprintf(stderr, "Data %lx: st=%08lx sz=%ld wr=%ld rd=%ld --> f : %.02f\n", ModuleId, DataFIFOInfo.StartAddress,	\
			DataFIFOInfo.Size, DataFIFOInfo.Writable,  DataFIFOInfo.Readable, fullness); \
		if ((fullness < 2) && checkStarvation) {		\
			struct timeval now;				\
									\
			gettimeofday(&now, NULL);			\
			RMDBGLOG((ENABLE, "close to starvation at\n")); \
			printTimeOfDay(now);				\
		}							\
	}								\


#define GET_XFER_FIFO_INFO(pRUA, ModuleId, checkStarvation)		\
	{								\
		struct XferFIFOInfo_type XferFIFOInfo;			\
		RMreal fullness;					\
		RMstatus err;						\
		err = RUAGetProperty(pRUA, ModuleId, RMGenericPropertyID_XferFIFOInfo, &XferFIFOInfo, sizeof(XferFIFOInfo)); \
		if ( RMFAILED(err) ) {					\
			fprintf(stderr, "XFER %lx: ERROR\n", ModuleId);	\
		}							\
		else {							\