#define LOCAL
using System;
using static MAXT.MXFoundation.mxf;
using System.Runtime.InteropServices;
using System.Text;
namespace discrete_example
{
class discrete_pulse_clock
{
const int MAX_TX_RECORDS_TO_TRANSMIT = 100;
public static readonly UInt64 BUFFER_SIZE = (UInt64)(MAX_TX_RECORDS_TO_TRANSMIT * Marshal.SizeOf(typeof(
MXF_DISCRETE_DATAREC)));
static void Main(string[] args)
{
UInt32 rc;
UInt64 server;
UInt64 count = 0;
var rxChannel = new UInt64[1];
var txChannel = new UInt64[1];
UInt64 rxBuffer = 0;
UInt64 txBuffer = 0;
IntPtr recDiscrete = IntPtr.Zero;
UInt64 dev, mod, port;
UInt64 condList = 0;
UInt64 module = 0;
UInt64 moduleType = 0;
#if LOCAL
#else
#endif
if (rc != MAXT_SUCCESS)
{
Console.Write("Failed to connect; rc=0x%08x", rc);
Console.Write("\nPress a key to terminate\n");
Console.ReadKey();
return;
}
Console.Write("\nStarting\n");
if (rc == MAXT_SUCCESS)
rc =
mxfChannelAllGet(server, MXF_CLASS_DISCRETE, MXF_SCLASS_RX_CHANNEL, MXF_MODULE_ALL, 1, out count, rxChannel);
if (rc == MAXT_SUCCESS && count > 0)
rc =
mxfChannelAllGet(server, MXF_CLASS_DISCRETE, MXF_SCLASS_TX_CHANNEL, MXF_MODULE_ALL, 1, out count, txChannel);
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 (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
if (moduleType == MXF_MODULE_DIOFIFO_EH)
{
#if LOOPBACK
if (rc == MAXT_SUCCESS)
#endif
}
else
{
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
}
}
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
try
{
recDiscrete = Marshal.AllocHGlobal((int)BUFFER_SIZE);
}
catch (OutOfMemoryException)
{
rc = MAXT_ERROR_MEM;
}
}
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
condParam.mask = 1 << 5;
condParam.data = 1 << 5;
condParam.offset = 0;
condParam.options = MXF_RXACQ_TRIG_COND_RDATA_OPTIONS_EQUAL;
}
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
if (rc == MAXT_SUCCESS)
Console.Write("\nAcquisition started\n\r");
}
if (rc == MAXT_SUCCESS)
{
rc = TransmitAperiodicData(txBuffer, recDiscrete, moduleType);
if (rc == MAXT_SUCCESS)
{
rc = ReadAcquisitionData(rxBuffer, recDiscrete);
}
}
if (rc == MAXT_SUCCESS)
if (rc == MAXT_SUCCESS)
{
if (rc == MAXT_SUCCESS)
Console.Write("\nAcquisition stopped\n\r");
}
if (rc == MAXT_SUCCESS)
if (rc != MAXT_SUCCESS)
{
var buffer = new StringBuilder(256);
Console.Write(buffer + "ERROR # 0x{0:X8}", rc);
Console.Write("{0}\n\r", buffer);
}
Console.Write("\nTerminating\n");
if (recDiscrete != IntPtr.Zero)
Marshal.FreeHGlobal(recDiscrete);
Console.Write("\nPress enter to terminate\n");
Console.ReadKey();
return;
}
private static UInt32 TransmitAperiodicData(UInt64 txBuffer, IntPtr recDiscrete, UInt64 moduleType)
{
UInt32 rc;
IntPtr recPtr = recDiscrete;
UInt64 data;
UInt64 startTime = 100 * 1000;
UInt64 delay = 1 * 1000;
for (data = 0; data < MAX_TX_RECORDS_TO_TRANSMIT; data++)
{
rec.
timeTag = startTime + (data * delay);
rec.
edge = (uint)((moduleType == MXF_MODULE_DIOFIFO_EH) ? 0xffff : 0);
Marshal.StructureToPtr(rec, recPtr, true);
}
Console.Write("Transmitting ...\n");
rc =
mxfTxAperiodicWrite(txBuffer, MXF_TXAPERIODIC_FLAG_USE_RECORD_RELATIVE_TIME, 0, MAX_TX_RECORDS_TO_TRANSMIT, recDiscrete);
if (rc == MAXT_SUCCESS)
return rc;
}
private static UInt32 ReadAcquisitionData(UInt64 rxBuffer, IntPtr recDiscrete)
{
IntPtr recPtr = recDiscrete;
UInt64 status, msgsCount, bytesCount, pendingBytes, freeBytes;
UInt64 j, trigTime = 0;
UInt32 rc;
UInt64 usec;
var offset = TimeZoneInfo.Local.GetUtcOffset(DateTime.UtcNow);
var time = new DateTime(1970, 1, 1).AddTicks(offset.Ticks);
if (rc == MAXT_SUCCESS)
{
if ((status & MXF_RXACQ_STATUS_TRIG_OCCURRED) > 0)
{
if (rc == MAXT_SUCCESS)
{
time = time.AddMilliseconds(trigTime / 1000);
usec = trigTime % 1000;
Console.WriteLine("Event triggered at {0}:{1:000}", time.ToString("yyyy-MM-dd HH:mm:ss:fff"), usec);;
}
}
else
Console.Write("Trigger not fired\n");
}
rc =
mxfDiscreteRxAcqRead(rxBuffer, 0, BUFFER_SIZE, out status, out msgsCount, out bytesCount, recDiscrete);
for (j = 0; j < msgsCount && rc == MAXT_SUCCESS; j++)
{
Console.Write(
" {0:00}: Timetag={1}, Data=0x{2:x4} {3}\n", j, rec.
timeTag, rec.
data, trigTime == rec.
timeTag ?
" *" :
"");
}
return rc;
}
}
}