using System;
using static MAXT.MXFoundation.mxf;
using System.Text;
using System.Runtime.InteropServices;
namespace DeviceMgmt_example
{
class usb
{
public const int BUFFER_SIZE = 4096;
public const int TX_MSG_LABEL = 5;
public const int TX_MSG_SDI = 0;
static void Main(string[] args)
{
UInt32 rc;
UInt64 server = 0;
UInt64 device = 0;
var module = new UInt64[1];
UInt64 count = 0;
var rxChannel = new UInt64[1];
var txChannel = new UInt64[1];
UInt64 rxBuffer = 0;
UInt64 txBuffer = 0;
IntPtr rec429 = IntPtr.Zero;
UInt64 dev, mod, port;
UInt64 usbDevCount;
if (rc == MAXT_SUCCESS && usbDevCount == 0)
{
Console.Write("No MAXT USB device detected\n");
rc = MAXT_ERROR_DEVICE_NOT_DETECTED;
}
if (rc == MAXT_SUCCESS)
if (rc != MAXT_SUCCESS)
{
Console.Write("Failed to connect; rc=0x{0:x8}", rc);
Console.Write("\nPress a key to terminate\n");
Console.ReadKey();
return;
}
Console.Write("\nStarting\n");
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS && count > 0)
if (rc == MAXT_SUCCESS && count > 0)
if (rc == MAXT_SUCCESS && count == 0)
rc = MAXT_ERROR_NOT_FOUND;
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
if (rc == MAXT_SUCCESS)
Console.Write("Acquisition Channel (RX) location={0}.{1}.{2}\n", dev, mod, port);
}
if (rc == MAXT_SUCCESS)
{
if (rc == MAXT_SUCCESS)
Console.Write("Transmitter Channel (TX) location={0}.{1}.{2}\n", dev, mod, port);
}
# if LOOPBACK
if (rc == MAXT_SUCCESS)
#endif
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
try
{
rec429 = Marshal.AllocHGlobal(BUFFER_SIZE);
}
catch (OutOfMemoryException)
{
rc = MAXT_ERROR_MEM;
};
}
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
if (rc == MAXT_SUCCESS)
Console.Write("\nAcquisition started\n\r");
}
if (rc == MAXT_SUCCESS)
{
rc = TX429PeriodicScheduling(txChannel[0], txBuffer, rec429);
if (rc == MAXT_SUCCESS)
{
rc = RX429ReadAcquisitionData(rxBuffer, rec429);
}
}
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
if (rc == MAXT_SUCCESS)
Console.Write("\nAcquisition stopped\n\r");
}
if (rc != MAXT_SUCCESS)
{
StringBuilder buffer = new StringBuilder(256);
Console.WriteLine(buffer + "\n");
}
Console.Write("\nTerminating\n");
if (device != 0)
if (rec429 != IntPtr.Zero)
Marshal.FreeHGlobal(rec429);
Console.Write("\nPress enter to terminate\n");
Console.ReadKey();
return;
}
private static UInt32 RX429ReadAcquisitionData(UInt64 rxBuffer, IntPtr rec429Ptr)
{
IntPtr recPtr = rec429Ptr;
UInt64 status, msgsCount, bytesCount;
UInt64 label, sdi, data, ssm, parity;
UInt64 j;
UInt32 rc;
rc =
mxfA429RxAcqRead(rxBuffer, 0, BUFFER_SIZE, out status, out msgsCount, out bytesCount, rec429Ptr);
for (j = 0; j < msgsCount && rc == MAXT_SUCCESS; j++)
{
if (rc == MAXT_SUCCESS)
{
Console.Write("{0:00}: Timetag {1} - ARINC word=[{2:000},{3},{4:x5},{5},{6}]\n",
j, rec429.
timeTag, label, sdi, data, ssm, (parity == VMXF_A429_PARITY_ODD) ?
"ODD" :
"EVEN");
if (rc == MAXT_SUCCESS)
}
}
return rc;
}
private static UInt32 TX429PeriodicScheduling(UInt64 txChannel, UInt64 txBuffer, IntPtr rec429Ptr)
{
UInt64 schedule;
UInt64 msg = 0;
UInt64 label, sdi, data, ssm, parity;
UInt32 rc;
UInt64[] bufferArray = { txBuffer };
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
label = TX_MSG_LABEL;
sdi = TX_MSG_SDI;
data = 0x7fe;
parity = VMXF_A429_PARITY_ODD;
ssm = 1;
Marshal.StructureToPtr(rec429, rec429Ptr, true);
if (rc == MAXT_SUCCESS)
}
if (rc == MAXT_SUCCESS)
{
Console.Write("Running periodic transmission, please wait...\n\r");
}
if (rc == MAXT_SUCCESS)
{
}
if (rc == MAXT_SUCCESS)
Console.Write("\n\rTransmission stopped\n\r");
return rc;
}
}
}