#include "example.h"
#define DURATION_ms 6000
#define TXALMOSTFULL 100
#define TXALMOSTEMPTY 30
#define RXALMOSTFULL 10
#define RXALMOSTEMPTY 5
#define SCANFIELD 0X7FF8
#define LABELFIELD 0X00FF
#define CTRLACCEPFIELD 0X0300
#define MODEFIELD 0X1C00
#define TILTFIELD1 0XE000
#define TILTFIELD2 0X000F
#define RANGEFIELD 0XFC00
#define GAINFIELD 0X03F0
#define DATAACCEPTFIELD 0X00006
#define BINFIELD 0X00007
uint32 asyncEventHandler(HMXF_ASYNCEVENT asyncEvent, void *param);
int main(void)
{
uint32 rc;
HMXF_SERVER server;
HMXF_DEVICE device=0;
HMXF_MODULE module=0;
HMXF_CHANNEL rxChannel=0, txChannel=0;
HMXF_ASYNCEVENT asyncEvent=0;
HMXF_BUFFER rxBuffer=0, txBuffer=0;
uint64 moduleCount=0, channelCount;
size_t txBufferSize, rxBufferSize;
HMXF_SCHED schedule=0;
HMXF_SCHED_MSG msgSched;
#ifdef LOCAL
#else
#endif
if (!rc)
{
printf("Starting ...\n");
}
if (!rc)
if (!rc)
if(!rc && !moduleCount)
rc = MAXT_ERROR_NOT_FOUND;
if (!rc)
{
if (rc == MAXT_ERROR_NOT_SUPPORTED)
rc = MAXT_SUCCESS;
}
if(!rc)
if (!rc)
#ifdef LOOPBACK
if(!rc)
#endif
if(!rc)
{
if(!rc)
{
if(!txHostBuffer)
rc = MAXT_ERROR_MEM;
}
}
if(!rc)
{
if(!rc)
{
if(!rxHostBuffer)
rc = MAXT_ERROR_MEM;
}
}
if(!rc)
if(!rc)
if(!rc)
{
memset(&RXasyncEventInfo, 0, sizeof(RXasyncEventInfo));
RXasyncEventInfo.
condID = MXF_ASYNCEVENT_COND_RXACQ_BUFFER_THRESHOLD;
}
if(!rc)
if(!rc)
if(!rc)
printf("Acquisition started\n\r");
if(!rc)
{
memset(&TXasyncEventInfo, 0, sizeof(TXasyncEventInfo));
TXasyncEventInfo.
condID = MXF_ASYNCEVENT_COND_TXPERIODIC_UPDATEMSG_BUFFER_THRESHOLD;
}
if(!rc)
if(!rc)
if(!rc)
if(!rc)
if(!rc)
{
}
if(!rc)
if(!rc)
if(!rc)
if(!rc)
if(rc)
{
char buffer[256];
sprintf (buffer,"ERROR # 0x%08X", rc);
printf("%s\n\r", buffer);
}
if (rxBuffer)
if (txBuffer)
if(txHostBuffer)
free(txHostBuffer);
if(rxHostBuffer)
free(rxHostBuffer);
printf("\nPress enter to terminate\n");
getchar();
return rc;
}
uint32 asyncEventHandler(HMXF_ASYNCEVENT asyncEvent, pvoid param)
{
uint64 maxCount=64, pendingCount;
uint64 i;
uint32 rc;
for (i=0; !rc && i<pendingCount; i++)
{
switch(pendingList[i].condID)
{
case MXF_ASYNCEVENT_COND_TXPERIODIC_UPDATEMSG_BUFFER_THRESHOLD:
updateMsgs(pendingList[i].condition.txPeriodicUpdateMsgBufferThreshold.buffer, (
MXF_A708_DATAREC *)param);
break;
case MXF_ASYNCEVENT_COND_RXACQ_BUFFER_THRESHOLD:
readAcquisition(pendingList[i].condition.rxAcqBufferThreshold.buffer, (
MXF_A708_DATAREC *)param);
break;
default:
printf("Unknown condID 0x%llx)", pendingList[i].condID);
break;
}
}
return rc;
}
{
uint32 rc=0;
uint16 i, bin;
static uint32 TXAsyncEvents=0;
static uint16 scanAngle=0;
static uint16 binValue=0;
for(i=0; !rc && i<TXALMOSTFULL; i++, scanAngle++)
{
if(scanAngle > 720)
{
scanAngle = 0;
binValue++;
}
setLabel(recPtr, 055);
setCtrlAccept(recPtr, 0x3);
setMode(recPtr, 1);
setTilt(recPtr, 0);
setGain(recPtr, -16);
setRange(recPtr, 80);
setDataAccept(recPtr, 3);
setScanAngle(recPtr, ((double)scanAngle*0.25)+270);
for(bin=1; bin<=512; bin++)
{
setBin(recPtr, bin, binValue);
}
if(!rc)
}
if(!rc)
if(rc)
printf("Periodic Update failed; rc=0x%08x\n", rc);
else
printf("\nAsync Event %d - Writing %d records\n", ++TXAsyncEvents, i);
return rc;
}
{
uint64 status, msgsCount, bytesCount;
uint32 rc;
rc =
mxfA708RxAcqRead(rxBuffer, 0, bufferSize, &status, &msgsCount, &bytesCount, rxHostBuffer);
if(!rc)
printf("String received count = %llu \n", msgsCount);
if(rc)
printf("Acquisition read failed; rc=0x%08x\n", rc);
return rc;
}
{
uint64 iRec,
iData;
printf("\n");
for(iRec=0; iRec < recNum; iRec++)
{
for(iData=0; iData < p->
dataSize/2; iData++)
{
printf(
"%04x ", p->
data[iData]);
if(!((iData+1)%8) && (iData+1 < p->
dataSize/2))
printf("\n ");
}
printf("\n");
}
}
{
rec->
data[0] = (rec->
data[0] & ~LABELFIELD) | label;
}
{
rec->
data[0] = ((rec->
data[0] & ~CTRLACCEPFIELD) | (CTRLACCEPFIELD & (ctrlAccept<<8)));
}
{
rec->
data[1] = ((rec->
data[1] & ~MODEFIELD) | (MODEFIELD & (mode<<10)));
}
{
rec->
data[1] = ((rec->
data[1] & ~TILTFIELD1) | (TILTFIELD1 & ((uint16)(tilt/0.25)<<13)));
rec->
data[2] = ((rec->
data[2] & ~TILTFIELD2) | (TILTFIELD2 & ((uint16)(tilt/0.25)>>3)));
}
{
rec->
data[2] = (( rec->
data[2] & ~GAINFIELD) | (GAINFIELD & ((gain/-1)<<4)));
}
{
rec->
data[2] = ((rec->
data[2] & ~RANGEFIELD) | (RANGEFIELD & ((range/5)<<10)));
}
{
rec->
data[3] = ((rec->
data[3] & ~DATAACCEPTFIELD) | (DATAACCEPTFIELD & (dataAccept<<1)));
}
{
rec->
data[3] = (( rec->
data[3] & ~SCANFIELD) | (SCANFIELD & ((uint16)(angle/0.0879)<<3)));
}
{
uint16 word_index = ((bin - 1)*3 + 64) / 16;
uint16 startbit = ((bin - 1)*3) % 16;
uint16 bin_field;
if (startbit < 14)
{
bin_field = BINFIELD << (startbit);
rec->
data[word_index] = (uint16)((rec->
data[word_index] & ~bin_field) | (bin_field & (val << startbit)));
}
if (startbit >= 14)
{
bin_field = BINFIELD << startbit;
rec->
data[word_index] = ((rec->
data[word_index] & ~bin_field) | (bin_field & (val << startbit)));
bin_field = BINFIELD >> (16-startbit);
rec->
data[word_index + 1] = ((rec->
data[word_index + 1] & ~bin_field) | (bin_field & (val >> (16-startbit))));
}
}