#include "example.h"
#define LOOPBACK
#define LOCAL
#define BUFFER_SIZE 1*1024*1024 // 1 MiB
#define TXALMOSTFULL 7
#define TXALMOSTEMPTY 3
#define RXALMOSTFULL 5
#define RXALMOSTEMPTY 2
#define TX_MSG_LABEL 5
#define TX_MSG_SDI 0
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;
HMXF_SCHED schedule = 0;
HMXF_SCHED_MSG msgSched;
uint64 count=0, type=0, options=0;
#ifdef LOCAL
#else
#endif
if (rc != MAXT_SUCCESS)
{
printf("Failed to connect; rc=0x%08x", rc);
printf("\nPress a key to terminate\n");
getchar();
return 0;
}
printf("\nStarting\n");
if (!rc)
rc =
mxfChannelAllGet(server, MXF_CLASS_A429, MXF_SCLASS_RX_CHANNEL, MXF_MODULE_ALL, 1, &count, &rxChannel);
if (!rc && count)
rc =
mxfChannelAllGet(server, MXF_CLASS_A429, MXF_SCLASS_TX_CHANNEL, MXF_MODULE_ALL, 1, &count, &txChannel);
if (!rc && !count)
rc = MAXT_ERROR_NOT_FOUND;
if (!rc)
if (!rc)
if(!rc)
{
if(type == MXF_MODULE_A429E)
{
if(!rc)
}
else
{
if(!rc)
}
}
if(!rc && type == MXF_MODULE_FLEX429)
{
if(!rc && (options & VMXF_A429_MODULE_OPTIONS_BIDIRECTIONAL))
}
#ifdef LOOPBACK
if (!rc)
#endif
if (!rc)
if (!rc)
{
if (!hostBuffer)
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)
if (!rc)
printf("Acquisition started\n\r");
if (!rc)
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)
{
printf("Running periodic transmission...\n\r");
}
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 (hostBuffer)
free(hostBuffer);
printf("\nPress enter to terminate\n");
getchar();
return rc;
}
uint32 asyncEventHandler(HMXF_ASYNCEVENT asyncEvent, void* 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_A429_DATAREC*)param);
break;
case MXF_ASYNCEVENT_COND_RXACQ_BUFFER_THRESHOLD:
readAcquisition(pendingList[i].condition.rxAcqBufferThreshold.buffer, (
MXF_A429_DATAREC*)param);
break;
default:
printf("Unknown condID 0x%llx)", pendingList[i].condID);
break;
}
}
return rc;
}
{
uint32 rc = 0;
uint32 i;
uint64 label, sdi, ssm, parity;
static uint64 data = 0;
static uint32 TXAsyncEvents = 0;
for (i = 0; !rc && i < TXALMOSTFULL; i++)
{
recPtr->
control = (i != 0) ? 0 : MXF_A429_TX_REC_CTRL_PARITY_ERROR;
label = TX_MSG_LABEL;
sdi = TX_MSG_SDI;
data++;
ssm = 0;
parity = VMXF_A429_PARITY_ODD;
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;
uint64 label, sdi, data, ssm, parity;
uint64 j;
uint32 rc;
rc =
mxfA429RxAcqRead(buffer, 0, BUFFER_SIZE, &status, &msgsCount, &bytesCount, hostBuffer);
if (!rc)
{
printf("Read %llu messages\n\r", msgsCount);
for (j = 0; !rc && j < msgsCount; j++)
{
if (!rc)
{
printf(
"%02llu: Timetag %llu", j, recPtr->
timeTag);
printf(
" - Control : %s ", (recPtr->
control == MXF_A429_RX_REC_CTRL_PARITY_ERROR) ?
"PARITY ERROR" :
"NO ERROR");
printf("- ARINC word=[%03llo,%lld,%05llX,%lld,%s]\n", label, sdi, data, ssm, (parity == VMXF_A429_PARITY_ODD) ? "ODD" : "EVEN");
if (!rc)
}
}
}
if (rc)
printf("Acquisition read failed; rc=0x%08x\n", rc);
return rc;
}