diff --git a/pasdk/test_dsp/framework/audioStreamInpProc.c b/pasdk/test_dsp/framework/audioStreamInpProc.c
index ab3bf34466c3998dd6e2c5aa71bc3731ce044e2c..318a5feb73b80179fdaa898c90fb4e4047b04fdf 100644 (file)
#include "statusOp_common.h"
-#define CACHE_COHERENCE
-
// -----------------------------------------------------------------------------
// Debugging Trace Control, local to this file.
// Messaging
ASP_Msg *pAspMsg;
Int status;
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
Int8 tempVar8;
#endif
Cache_inv((Ptr)(&IACP_STD_BETA_TABLE.pStatus[STD_BETA_PCM2]), sizeof(IALG_Status *), Cache_Type_ALLD, 0);
Cache_inv((Ptr)(&IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP]), sizeof(IALG_Status *), Cache_Type_ALLD, 0);
Cache_inv((Ptr)(&IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP2]), sizeof(IALG_Status *), Cache_Type_ALLD, 0);
+ Cache_inv((Ptr)(&IACP_STD_BETA_TABLE.pStatus[STD_BETA_THD]), sizeof(IALG_Status *), Cache_Type_ALLD, 0);
+ Cache_inv((Ptr)(&IACP_STD_BETA_TABLE.pStatus[STD_BETA_THD2]), sizeof(IALG_Status *), Cache_Type_ALLD, 0);
Cache_wait();
if (!IACP_STD_BETA_TABLE.pStatus[STD_BETA_DECODE]) Log_info0("ERROR: beta unit for Dec==NULL");
if (!IACP_STD_BETA_TABLE.pStatus[STD_BETA_PCM]) Log_info0("ERROR: beta unit for Dec==NULL");
if (!IACP_STD_BETA_TABLE.pStatus[STD_BETA_PCM2]) Log_info0("ERROR: beta unit for Dec==NULL");
if (!IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP]) Log_info0("ERROR: beta unit for Dec==NULL");
if (!IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP2]) Log_info0("ERROR: beta unit for Dec==NULL");
+ if (!IACP_STD_BETA_TABLE.pStatus[STD_BETA_THD]) Log_info0("ERROR: beta unit for Dec==NULL");
+ if (!IACP_STD_BETA_TABLE.pStatus[STD_BETA_THD2]) Log_info0("ERROR: beta unit for Dec==NULL");
// (***) FL: revisit
// invalidate Status structures for Beta Units initialized on Slave
Cache_inv((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP2]), sizeof(Int), Cache_Type_ALLD, 0);
size = IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP2]->size;
Cache_inv((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP2]), size, Cache_Type_ALLD, 0);
+ Cache_inv((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_THD]), sizeof(Int), Cache_Type_ALLD, 0);
+ size = IACP_STD_BETA_TABLE.pStatus[STD_BETA_THD]->size;
+ Cache_inv((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_THD]), size, Cache_Type_ALLD, 0);
+ Cache_inv((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_THD2]), sizeof(Int), Cache_Type_ALLD, 0);
+ size = IACP_STD_BETA_TABLE.pStatus[STD_BETA_THD2]->size;
+ Cache_inv((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_THD2]), size, Cache_Type_ALLD, 0);
+ size = IACP_STD_BETA_TABLE.pStatus[STD_BETA_DTSUHDA]->size;
+ Cache_inv((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_DTSUHDA]), size, Cache_Type_ALLD, 0);
Cache_wait();
+#ifdef NON_CACHE_STATUS
+ // Get the shared status structure GateMP handles. Initialized at slave.
+ if (statusOp_Init(GATEMP_INDEX_DEC) == STATUSOP_INIT_FAIL)
+ {
+ Log_info1("TaskAfp: Gate Index %d:Open status GateMP Fail.", GATEMP_INDEX_DEC);
+ }
+ if (statusOp_Init(GATEMP_INDEX_DDP) == STATUSOP_INIT_FAIL)
+ {
+ Log_info1("TaskAfp: Gate Index %d:Open status GateMP Fail.", GATEMP_INDEX_DDP);
+ }
+ if (statusOp_Init(GATEMP_INDEX_PCM) == STATUSOP_INIT_FAIL)
+ {
+ Log_info1("TaskAfp: Gate Index %d:Open status GateMP Fail.", GATEMP_INDEX_PCM);
+ }
+ if (statusOp_Init(GATEMP_INDEX_THD) == STATUSOP_INIT_FAIL)
+ {
+ Log_info1("TaskAfp: Gate Index %d:Open status GateMP Fail.", GATEMP_INDEX_THD);
+ }
+#endif
+
// (***) FL: revisit
// invalidate Dec configuration
Cache_inv(&gPAF_AST_config.xDec[0], DECODEN*sizeof(PAF_AST_Decode), Cache_Type_ALLD, 0);
// so set to unknown and skip any remaining processing
if (!pAstCfg->xInp[zMI].hRxSio)
{
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
tempVar8 = PAF_SOURCE_UNKNOWN;
statusOp_write(&(pAstCfg->xDec[zMD].decodeStatus.sourceProgram),
&tempVar8,
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
#else
pAstCfg->xDec[zMD].decodeStatus.sourceProgram = PAF_SOURCE_UNKNOWN;
#endif
continue;
}
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.mode),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
// If master decoder is not enabled, or the input is unlocked, then do nothing
if (!tempVar8 || !pAstCfg->xInp[zMI].inpBufStatus.lock)
{
}
#endif
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.sourceSelect),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
// If no source selected then do nothing
if (tempVar8 == PAF_SOURCE_NONE)
{
tempVar8 = PAF_SOURCE_NONE;
statusOp_write(&(pAstCfg->xDec[zMD].decodeStatus.sourceProgram),
&tempVar8,
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
TRACE_VERBOSE1("TaskAsip: AS%d: no source selected, continue", as+zMS);
continue;
}
}
#endif
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.sourceSelect),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
// If we want pass processing then proceed directly
if (tempVar8 == PAF_SOURCE_PASS)
{
tempVar8 = PAF_SOURCE_PASS;
statusOp_write(&(pAstCfg->xDec[zMD].decodeStatus.sourceProgram),
&tempVar8,
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
#else
// If we want pass processing then proceed directly
if (pAstCfg->xDec[zMD].decodeStatus.sourceSelect == PAF_SOURCE_PASS)
continue;
}
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.sourceSelect),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
// .....................................................................
// At this point we have an enabled input and want to decode something.
// If no decoder selected then do nothing. Need to reset the sourceProgram, since
errno = ASPERR_AUTO_PROGRAM;
continue;
}
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_write(&(pAstCfg->xDec[zMD].decodeStatus.sourceProgram),
&(sourceProgram),
- sizeof(sourceProgram));
+ sizeof(sourceProgram),
+ GATEMP_INDEX_DEC);
#else
pAstCfg->xDec[zMD].decodeStatus.sourceProgram = sourceProgram;
#endif
// input frame, we determine whether or not to call decodeProcessing and with
// what decAlg.
sourceSelect = PAF_SOURCE_NONE;
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.sourceSelect),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
switch (tempVar8)
{
#else
// If user made specific selection then program must match select.
// (NB: this compare relies on ordering of PAF_SOURCE)
default:
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
sourceSelect = 0; // due to size difference
statusOp_read(&sourceSelect,
&(pAstCfg->xDec[zMD].decodeStatus.sourceSelect),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
#else
sourceSelect = pAstCfg->xDec[zMD].decodeStatus.sourceSelect;
#endif
INPUTN * sizeof (*pAstCfg->xInp),
HEAP_ID_INTERNAL1_SHM, (IArg)pAstCfg->xInp);
+#ifdef NON_CACHE_STATUS
+ /* Decode memory */
+ if (!(pAstCfg->xDec = Memory_calloc((IHeap_Handle)HEAP_EXTERNAL_NONCACHED_SHM,
+ DECODEN * sizeof (*pAstCfg->xDec), 4, &eb)))
+ {
+ TRACE_TERSE1("PAF_ASIT_initPhaseMalloc: AS%d: Memory_calloc failed", as+zMS);
+ SW_BREAKPOINT;
+ return __LINE__;
+ }
+#else
/* Decode memory */
if (!(pAstCfg->xDec = Memory_calloc((IHeap_Handle)HEAP_INTERNAL1_SHM,
DECODEN * sizeof (*pAstCfg->xDec), 4, &eb)))
SW_BREAKPOINT;
return __LINE__;
}
+#endif
TRACE_TERSE3("PAF_ASIT_initPhaseMalloc. (pC->xDec) %d bytes from space %d at 0x%x.",
DECODEN * sizeof (*pAstCfg->xDec),
HEAP_ID_INTERNAL1_SHM, (IArg)pAstCfg->xDec);
SW_BREAKPOINT;
return __LINE__;
}
+
TRACE_TERSE3("PAF_ASIT_initPhaseDecOpCircBuf. (pC->xDecOpCb) %d bytes from space %d at 0x%x.",
DECODEN * sizeof (*pAstCfg->xDecOpCb),
HEAP_ID_INTERNAL1_SHM, (IArg)pAstCfg->xDecOpCb);
// allocate audio frame PCM sample pointer array
for (i = 0; i<ASP_DECOP_CB_MAX_NUM_AF; i++)
{
- if (!(pCb->afCb[i].data.sample = Memory_calloc((IHeap_Handle)HEAP_INTERNAL1_SHM, ASP_DECOP_CB_MAX_NUM_PCM_CH * sizeof(PAF_AudioData *), 4, &eb)))
+ if (!(pCb->afCb[i].data.sample = Memory_calloc((IHeap_Handle)HEAP_INTERNAL1_SHM, ASP_DECOP_CB_MAX_NUM_PCM_CH_MAT * sizeof(PAF_AudioData *), 4, &eb)))
{
TRACE_TERSE1("PAF_ASIT_initPhaseDecOpCircBuf: AS%d: Memory_calloc failed", as+zMS);
SW_BREAKPOINT;
}
- if (!(pCb->afCb[i].data.samsiz = Memory_calloc((IHeap_Handle)HEAP_INTERNAL1_SHM, ASP_DECOP_CB_MAX_NUM_PCM_CH * sizeof(PAF_AudioSize), 4, &eb)))
+ if (!(pCb->afCb[i].data.samsiz = Memory_calloc((IHeap_Handle)HEAP_INTERNAL1_SHM, ASP_DECOP_CB_MAX_NUM_PCM_CH_MAT * sizeof(PAF_AudioSize), 4, &eb)))
{
TRACE_TERSE1("PAF_ASIT_initPhaseDecOpCircBuf: AS%d: Memory_calloc failed", as+zMS);
SW_BREAKPOINT;
}
}
// allocate PCM sample buffer
- if (!(pCb->pcmBuf = Memory_calloc((IHeap_Handle)HEAP_INTERNAL1_SHM, ASP_DECOP_CB_PCM_BUF_SZ * sizeof(PAF_AudioData), 4, &eb)))
+ if (!(pCb->pcmBuf = Memory_calloc((IHeap_Handle)HEAP_EXTERNAL_SHM, ASP_DECOP_CB_PCM_BUF_SZ * sizeof(PAF_AudioData), 4, &eb)))
{
TRACE_TERSE1("PAF_ASIT_initPhaseDecOpCircBuf: AS%d: Memory_calloc failed", as+zMS);
SW_BREAKPOINT;
}
+ pCb->pcmBufEnd = pCb->pcmBuf + ASP_DECOP_CB_PCM_BUF_SZ;
// allocate Metadata buffers //QIN
- if (!(pCb->metaBuf = Memory_calloc((IHeap_Handle)HEAP_INTERNAL1_SHM, ASP_DECOP_CB_MAX_NUM_AF * PAF_MAX_PRIVATE_MD_SZ * PAF_MAX_NUM_PRIVATE_MD * sizeof(Int8), 4, &eb)))
+ if (!(pCb->metaBuf = Memory_calloc((IHeap_Handle)HEAP_EXTERNAL_SHM, ASP_DECOP_CB_MAX_NUM_AF * PAF_MAX_PRIVATE_MD_SZ * PAF_MAX_NUM_PRIVATE_MD * sizeof(Int8), 4, &eb)))
{
TRACE_TERSE1("PAF_ASIT_initPhaseDecOpCircBuf: AS%d: Memory_calloc failed", as+zMS);
SW_BREAKPOINT;
}
-
+ pCb->metaBufEnd = pCb->metaBuf + (ASP_DECOP_CB_MAX_NUM_AF * PAF_MAX_PRIVATE_MD_SZ * PAF_MAX_NUM_PRIVATE_MD);
// (***) FL: revisit, here PCM is hard-coded for 256 sample dec op frame length
// Initialize decoder output circular buffer for PCM
errno = cbInit(pCb);
//PAF_InpBufConfig *pIpBufConfig;
Int frame; // decoder input frame count
Int block; // (***) FL: formerly -- decoder output block count / input frame
-#ifdef CACHE_COHERENCE
- Int8 tempVar8;
+#ifdef NON_CACHE_STATUS
+ Int8 tempVar8, tempVar8_2;
#endif
pAstCfg = pC->pAstCfg; // get pointer to common (shared) configuration
state = INIT;
errno = 0; /* error number */
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.sourceSelect),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
TRACE_TERSE1("PAF_ASIT_decodeProcessing: sourceSelect is %d", tempVar8);
for (;;)
size = IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP]->size;
Cache_wb((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP]), size, Cache_Type_ALLD, 0);
Cache_wait();*/
+ size = IACP_STD_BETA_TABLE.pStatus[STD_BETA_DTSUHDA]->size;
+ Cache_wb((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_DTSUHDA]), size, Cache_Type_ALLD, 0);
+ Cache_wait();
#endif
#if 0
////size = IACP_STD_BETA_TABLE.pStatus[STD_BETA_DECODE]->size;
size = IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP]->size;
Cache_inv((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_DDP]), size, Cache_Type_ALLD, 0);
Cache_wait();*/
+ size = IACP_STD_BETA_TABLE.pStatus[STD_BETA_DTSUHDA]->size;
+ Cache_inv((Ptr)(IACP_STD_BETA_TABLE.pStatus[STD_BETA_DTSUHDA]), size, Cache_Type_ALLD, 0);
+ Cache_wait();
#endif
frame = 0;
#endif
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.sourceDecode),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
+
+ statusOp_read(&tempVar8_2,
+ &(pAstCfg->xDec[zMD].decodeStatus.sampleRate),
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
// Don't start decode until major access unit is found.
if (((tempVar8 == PAF_SOURCE_THD) ||
(tempVar8 == PAF_SOURCE_DXP) ||
- (tempVar8 == PAF_SOURCE_DTSHD)) &&
- (pAstCfg->xStr[zMS].pAudioFrame->sampleRate == PAF_SAMPLERATE_UNKNOWN))
+ (tempVar8 == PAF_SOURCE_DTSHD))
+ &&
+ //(pAstCfg->xStr[zMS].pAudioFrame->sampleRate == PAF_SAMPLERATE_UNKNOWN)
+ (tempVar8_2 == PAF_SAMPLERATE_UNKNOWN) // debug chitresh as per govind
+ )
#else
// Don't start decode until major access unit is found.
if (((pAstCfg->xDec[zMD].decodeStatus.sourceDecode == PAF_SOURCE_THD) ||
for (z=DECODE1; z < DECODEN; z++)
{
Int zI = pP->inputsFromDecodes[z];
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.mode),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
if (pAstCfg->xInp[zI].hRxSio && tempVar8)
{
#else
Int as; /* Audio Stream Number (1, 2, etc.) */
Int z; /* decode counter */
Int zS;
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
Int8 tempVar8;
#endif
for (z=DECODE1; z < DECODEN; z++)
{
zS = pP->streamsFromDecodes[z];
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.command2),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
if (!(tempVar8 & 0x80))
{
switch (tempVar8)
tempVar8 |= 0x80;
statusOp_write(&(pAstCfg->xDec[z].decodeStatus.command2),
&tempVar8,
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
break;
case 1: // command abort - leave now
TRACE_TERSE2("AS%d: PAF_ASIT_decodeCommand: decode command abort (0x%02x)", as+zS, 1);
tempVar8 |= 0x80;
statusOp_write(&(pAstCfg->xDec[z].decodeStatus.command2),
&tempVar8,
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
return (ASPERR_ABORT);
case 2: // command restart - leave later
TRACE_TERSE2("AS%d: PAF_ASIT_decodeCommand: decode command quit (0x%02x)", as+zS, 2);
tempVar8 |= 0x80;
statusOp_write(&(pAstCfg->xDec[z].decodeStatus.command2),
&tempVar8,
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
return (ASPERR_QUIT);
default: // command unknown - ignore
break;
Int argIdx;
Int decErrno;
Int status;
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
Int8 tempVar8;
#endif
pCbCtl = &pC->pAspmCfg->decOpCircBufCtl; // get pointer to circular buffer control
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
// reset frameCount
for (z=DECODE1; z < DECODEN; z++)
{
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.mode),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
if (tempVar8)
{
tempVar8 = 0;
statusOp_write(&(pAstCfg->xDec[z].decodeStatus.frameCount),
&tempVar8,
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
}
}
(void)zS; // clear compiler warning in case not used with tracing disabled
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.mode),
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
if (pAstCfg->xInp[zI].hRxSio && tempVar8)
{
#else
return errno;
#endif
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
gear = 0; // due to size difference
statusOp_read(&gear,
&(pAstCfg->xDec[z].decodeStatus.aspGearControl),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
tempVar8 = gear < GEARS ? gear : 0;
statusOp_write(&(pAstCfg->xDec[z].decodeStatus.aspGearStatus),
&tempVar8,
- sizeof(tempVar8));
+ sizeof(tempVar8),
+ GATEMP_INDEX_DEC);
#else
gear = pAstCfg->xDec[z].decodeStatus.aspGearControl;
pAstCfg->xDec[z].decodeStatus.aspGearStatus = gear < GEARS ? gear : 0;
{
frameLength = 1536;
}
+ else if (sourceSelect == PAF_SOURCE_THD)
+ {
+ frameLength = 1536; //QIN FIX ME
+ }
+ else if ((sourceSelect == PAF_SOURCE_DTS) ||
+ (sourceSelect == PAF_SOURCE_DTSHD) ||
+ (sourceSelect == PAF_SOURCE_DTS12) ||
+ (sourceSelect == PAF_SOURCE_DTS13) ||
+ (sourceSelect == PAF_SOURCE_DTS14) ||
+ (sourceSelect == PAF_SOURCE_DTS16) ||
+ (sourceSelect == PAF_SOURCE_DTSALL)
+ )
+ {
+ frameLength = 8192; // TODO: Chitresh FIX ME
+ }
else
{
frameLength = 256;
}
}
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.sourceSelect),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
if (errno = SIO_ctrl(pAstCfg->xInp[zI].hRxSio, PAF_SIO_CONTROL_SET_SOURCESELECT,
DECSIOMAP(tempVar8)))
{
ASP_Msg *pAspMsg; /* Messaging */
Int argIdx;
Int status;
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
Int8 tempVar8;
Int tempVar;
#endif
// return (ASPERR_INFO_RATECHANGE);
}
}
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zD].decodeStatus.sourceDecode),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
pAstCfg->xDec[zD].decodeControl.emphasis =
tempVar8 != PAF_SOURCE_PCM
? PAF_IEC_PREEMPHASIS_NO // fix for Mantis ID #119
zI = pP->inputsFromDecodes[z];
zS = pP->streamsFromDecodes[z];
(void)zS; // clear compiler warning in case not used with tracing disabled
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.mode),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
if (pAstCfg->xInp[zI].hRxSio && tempVar8)
{
#else
TRACE_TERSE1("return error errno 0x%x.", errno);
return errno;
}
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar,
&(pAstCfg->xDec[z].decodeStatus.frameCount),
- sizeof(Int));
+ sizeof(Int),
+ GATEMP_INDEX_DEC);
// increment decoded frame count
tempVar += 1;
statusOp_write(&(pAstCfg->xDec[z].decodeStatus.frameCount),
&tempVar,
- sizeof(Int));
+ sizeof(Int),
+ GATEMP_INDEX_DEC);
#else
// increment decoded frame count
pAstCfg->xDec[z].decodeStatus.frameCount += 1;
}
} // z=DECODE1 to DECODEN
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.mode),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
// query IB for latest sourceProgram (needed if we started decoding due to a force mode)
if (tempVar8)
{
}
statusOp_write(&(pAstCfg->xDec[zMD].decodeStatus.sourceProgram),
&(sourceProgram),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
}
// since now decoding update decode status for all enabled decoders
{
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.mode),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
if (tempVar8)
{
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.sourceProgram),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
statusOp_write(&(pAstCfg->xDec[z].decodeStatus.sourceDecode),
&tempVar8,
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.sourceSelect),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
if (tempVar8 == PAF_SOURCE_SNG)
{
tempVar8 = PAF_SOURCE_SNG;
statusOp_write(&(pAstCfg->xDec[z].decodeStatus.sourceDecode),
&tempVar8,
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
}
}
}
Int z; /* decode counter */
Int zI, zS;
Int zMD;
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
Int8 tempVar8;
#endif
zI = pP->inputsFromDecodes[z];
zS = pP->streamsFromDecodes[z];
(void)zS;
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.mode),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
if (z == zMD
|| ! pAstCfg->xInp[zI].hRxSio
|| ! tempVar8)
{
frameLength = 1536;
}
+ else if (sourceSelect == PAF_SOURCE_THD)
+ {
+ frameLength = 1536; //QIN FIX ME
+ }
+ else if ((sourceSelect == PAF_SOURCE_DTS) ||
+ (sourceSelect == PAF_SOURCE_DTSHD) ||
+ (sourceSelect == PAF_SOURCE_DTS12) ||
+ (sourceSelect == PAF_SOURCE_DTS13) ||
+ (sourceSelect == PAF_SOURCE_DTS14) ||
+ (sourceSelect == PAF_SOURCE_DTS16) ||
+ (sourceSelect == PAF_SOURCE_DTSALL)
+ )
+ {
+ frameLength = 8192; // TODO: Chitresh FIX ME
+ }
else
{
frameLength = 256;
Int zMD;
Int sourceSelect;
Int sourceProgram;
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
Int8 tempVar8, temp2Var8;
#endif
pAstCfg = pC->pAstCfg; // get pointer to common (shared) configuration
zMD = pAstCfg->masterDec;
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.sourceSelect),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
sourceSelect = tempVar8;
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.sourceProgram),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
sourceProgram = tempVar8;
#else
sourceSelect = pAstCfg->xDec[zMD].decodeStatus.sourceSelect;
}
else
{
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[zMD].decodeStatus.sourceDecode),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
statusOp_read(&temp2Var8,
&(pAstCfg->xDec[zMD].decodeStatus.sourceSelect),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
if (temp2Var8 != tempVar8)
{
return 1;
Int argIdx;
Int errno; /* error number */
Int status;
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
Int8 tempVar8;
#endif
DEC_Handle dec = (DEC_Handle )decAlg[z];
#endif /* PAF_ASP_FINAL */
Int zI = pP->inputsFromDecodes[z];
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.mode),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
if (pAstCfg->xInp[zI].hRxSio && tempVar8)
{
#else
{
PAF_AST_Config *pAstCfg;
Int z; /* decode counter */
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
Int8 tempVar8;
#endif
for (z=DECODE1; z < DECODEN; z++)
{
-#ifdef CACHE_COHERENCE
+#ifdef NON_CACHE_STATUS
statusOp_read(&tempVar8,
&(pAstCfg->xDec[z].decodeStatus.mode),
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
if (tempVar8)
{
tempVar8 = x;
statusOp_write(&(pAstCfg->xDec[z].decodeStatus.sourceDecode),
&tempVar8,
- sizeof(Int8));
+ sizeof(Int8),
+ GATEMP_INDEX_DEC);
}
#else
if (pAstCfg->xDec[z].decodeStatus.mode)