#define LOOPBACK
using System;
using System.Net;
using System.Runtime.InteropServices;
using static MAXT.MXFoundation.mxf;
namespace ar664_example
{
public class ar664_sampling
{
private const UInt32 TEST_DATASIZE = 64;
private const UInt64 DATARECS_BUFFER_SIZE_MAX = 64 * 1024;
private const string SRC_IP_ADRS = "10.0.0.111";
private const UInt32 SRC_UDP_PORT = 1234;
private const string DST_IP_ADRS = "10.0.0.222";
private const UInt32 DST_UDP_PORT = 5678;
static void Main(string[] args)
{
UInt64 server = 0;
UInt64 portTx = 0;
UInt64 portRx = 0;
UInt64 vlTx = 0, vlRx = 0;
UInt64 rxBuffer = 0;
var module = new UInt64[1];
UInt64 device = 0;
var phyChn = new UInt64[1];
IntPtr recPtr = IntPtr.Zero;
var vlParamTx = new MXF_A664_VL_PARAM_TX();
var vlParamRx = new MXF_A664_VL_PARAM_RX();
int srcIpAdrs = 0, dstIpAdrs = 0;
UInt64 status;
UInt64 usedBytes, freeBytes;
UInt64 msgCount = 0;
UInt32 dataIdx;
UInt32 vlid = 100;
UInt32 rc;
UInt64 count = 0;
# if LOCAL
#else
#endif
if (rc != MAXT_SUCCESS)
{
Console.Write("Failed to connect; rc=0x{0:x8}\n", rc);
Console.Write("\nPress a key to terminate\n");
Console.ReadKey();
return;
}
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS && count > 0)
if (rc == MAXT_SUCCESS && count == 0)
rc = MAXT_ERROR_NOT_FOUND;
#if LOOPBACK
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
#endif
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
vlParamTx.dir.Tx.subVl = new MXF_A664_VL_PARAM_TX.Dir.TX.SubVl[4];
vlParamTx.direction = MXF_A664_VL_DIR_TX;
vlParamTx.VLId = vlid;
vlParamTx.frameType = MXF_A664_FRAME_TYPE_ARINC664;
vlParamTx.frameSizeMax = 512;
vlParamTx.dir.Tx.subVlNumber = 1;
vlParamTx.dir.Tx.bag = 1 * 1000 * 1000;
vlParamTx.dir.Tx.netSelection = MXF_A664_NETSELECT_ALL;
vlParamTx.dir.Tx.Ede.enable = VMXF_DISABLE;
vlParamTx.dir.Tx.subVl[0].bufferSize = vlParamTx.frameSizeMax;
vlParamTx.dir.Tx.subVl[0].maxBuffers = 1;
}
if (rc == MAXT_SUCCESS)
{
srcIpAdrs = BitConverter.ToInt32(IPAddress.Parse(SRC_IP_ADRS).GetAddressBytes(), 0);
srcIpAdrs = IPAddress.HostToNetworkOrder(srcIpAdrs);
dstIpAdrs = BitConverter.ToInt32(IPAddress.Parse(DST_IP_ADRS).GetAddressBytes(), 0);
dstIpAdrs = IPAddress.HostToNetworkOrder(dstIpAdrs);
portParam.portType = MXF_A664_PORT_TYPE_COM;
portParam.family = MXF_A664_PORT_FAMILY_IPV4;
portParam.mode = MXF_A664_PORT_MODE_SAMPLING;
portParam.dir.Tx.Sampling.rate = 10 * 1000 * 1000;
portParam.type.COM.destAddress.port = DST_UDP_PORT;
portParam.type.COM.destAddress.version.IPv4.address = (UInt32)dstIpAdrs;
portParam.type.COM.srcAddress.port = SRC_UDP_PORT;
portParam.type.COM.srcAddress.version.IPv4.address = (UInt32)srcIpAdrs;
}
if (rc == MAXT_SUCCESS)
{
vlParamRx = new MXF_A664_VL_PARAM_RX();
vlParamRx.VLId = vlid;
vlParamRx.frameType = MXF_A664_FRAME_TYPE_ARINC664;
vlParamRx.direction = MXF_A664_VL_DIR_RX;
vlParamRx.frameSizeMax = 512;
vlParamRx.dir.Rx.Mac.skewMax = 4 * 1000 * 1000;
vlParamRx.dir.Rx.Mac.rmPSNRange = 2;
}
if (rc == MAXT_SUCCESS)
{
portParam.portType = MXF_A664_PORT_TYPE_COM;
portParam.family = MXF_A664_PORT_FAMILY_IPV4;
portParam.mode = MXF_A664_PORT_MODE_SAMPLING;
portParam.dir.Rx.network = MXF_A664_NETSELECT_ALL;
portParam.dir.Rx.maxBuffers = 1;
portParam.dir.Rx.bufferSize = 512;
portParam.type.COM.destAddress.port = DST_UDP_PORT;
portParam.type.COM.destAddress.version.IPv4.address = (UInt32)dstIpAdrs;
portParam.type.COM.srcAddress.port = SRC_UDP_PORT;
portParam.type.COM.srcAddress.version.IPv4.address = (UInt32)srcIpAdrs;
}
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
if (rc == MAXT_SUCCESS && (status & MXF_RXSAMPLING_STATUS_RUNNING) > 0)
Console.Write("Sampling Running\n");
}
if (rc == MAXT_SUCCESS)
{
try
{
recPtr = Marshal.AllocHGlobal((int)DATARECS_BUFFER_SIZE_MAX);
}
catch (OutOfMemoryException)
{
rc = MAXT_ERROR_MEM;
}
}
for (count = 0; count < 10 && rc == MAXT_SUCCESS; count++)
{
if ((count % 5) == 0)
{
txRec.data = new byte[8192];
txRec.dataSize = TEST_DATASIZE;
txRec.repeatCount = 1;
for (dataIdx = 0; dataIdx < TEST_DATASIZE; dataIdx++)
txRec.data[dataIdx] = (byte)((dataIdx + ((count * TEST_DATASIZE) & 0xff)) & 0xff);
Marshal.StructureToPtr(txRec, recPtr, true);
}
if (rc == MAXT_SUCCESS)
{
rc = readSamplingData(rxBuffer);
}
}
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
if (rc == MAXT_SUCCESS && (status & MXF_RXSAMPLING_STATUS_STOPPED) > 0)
Console.Write("\nSampling stopped\n");
}
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (recPtr != IntPtr.Zero)
Marshal.FreeHGlobal(recPtr);
Console.Write("\n\nPress a key to terminate rc=0x{0:X8}\n", rc);
Console.ReadKey();
return;
}
private static UInt32 readSamplingData(UInt64 rxBuffer)
{
IntPtr sampRecPtr = IntPtr.Zero;
UInt64 dataIdx;
UInt64 msgCount = 0, bytesCount = 0;
UInt32 dataSize;
UInt32 rc = 0;
try
{
sampRecPtr = Marshal.AllocHGlobal((int)DATARECS_BUFFER_SIZE_MAX);
}
catch (OutOfMemoryException)
{
rc = MAXT_ERROR_MEM;
}
if (rc == MAXT_SUCCESS)
rc =
mxfA664RxSamplingRead(rxBuffer, 0, 0, DATARECS_BUFFER_SIZE_MAX, out msgCount, out bytesCount, sampRecPtr);
if (rc == MAXT_SUCCESS)
Console.Write("{0} records received\n\n", msgCount);
if (msgCount > 0 && rc == MAXT_SUCCESS)
{
Console.Write(" timeTag={0:D12}, Size={1}\n", rxRec.timeTag, rxRec.dataSize);
Console.Write("\n data=");
dataSize = rxRec.dataSize;
for (dataIdx = 0; dataIdx < dataSize; dataIdx++)
{
Console.Write("{0:X2} ", rxRec.data[dataIdx]);
if (((dataIdx + 1) % 8) == 0 && (dataIdx + 1 < rxRec.dataSize))
Console.Write("\n ");
}
Console.Write("\n\n");
}
return rc;
}
}
}