flexdio_sampling_acq.c

/*******************************************************************************
//
//   File:
//      flexdio_sampling_acq.c
//
//     Copyright (c) MAX Technologies Inc. 1988-2022, All Rights Reserved. 
//           CONFIDENTIAL AND PROPRIETARY INFORMATION WHICH IS THE 
//                      PROPERTY OF MAX TECHNOLOGIES INC. 
//
//   This demo illustrates how to start acquisition on discrete input channel.
//
//   Hardware Requirements:
//       - MAXT FlexMAX with FlexMAX DIO module
//
*******************************************************************************/

#include "example.h"

//#define LOCAL

#define BUFFER_SIZE (1000*sizeof(MXF_FLEXDIO_DATAREC))

/***************************************************************************************************************/
//   Main
/***************************************************************************************************************/

int main(void)
{
uint32 rc;
HMXF_SERVER  server;
uint64 count=0;
HMXF_CHANNEL ioChannel=0;
HMXF_BUFFER  rxBuffer=0;
MXF_FLEXDIO_DATAREC *recDiscrete=NULL;
uint64 dev, mod, port;
int pin;
   
   // Connect to services local or remote 
#ifdef LOCAL
   rc = mxfServerConnect("0.0.0.0", "", "", FALSE, &server);
#else
   rc = mxfServerConnect("192.168.0.1", "admin", "admin", FALSE, &server);
#endif

   if (rc)
   {
      printf("Failed to connect; rc=0x%08x", rc);
      printf("\nPress a key to terminate\n");
      getchar();
      return 0;
   }
   
   // Initialize the server
   printf("\nStarting\n");
   
   rc = mxfSystemInit(server);

   // Obtain the first FlexDIO channel
   if (!rc)
      rc = mxfChannelAllGet(server, MXF_CLASS_FLEXDIO, MXF_SCLASS_ALL, MXF_MODULE_ALL, 1, &count, &ioChannel);

   // If channel not found, return an error
   if(!rc && !count)
      rc = MAXT_ERROR_NOT_FOUND;

   // Set timebase to device time 64-bit microseconds
   if (!rc)
      rc = mxfSystemTimeBaseSet(server, MXF_TIMEBASE_DEVICE_USEC);
   
   // Get the physical port location
   if (!rc)
   {
      rc = mxfChannelLocationGet(ioChannel, &dev, &mod, &port);
      if (!rc)
         printf("IO Channel location=%"PRIu64".%"PRIu64".%"PRIu64"\n", dev, mod, port);
   }

   // Set mode to sampling
   if (!rc)
      rc = mxfAttributeUint64Set(ioChannel, KMXF_FLEXDIO_RX_FIFO_MODE, VMXF_FLEXDIO_RX_FIFO_MODE_SAMPLING);

   // Set sampling period to 1 ms
   if (!rc)
      rc = mxfAttributeUint64Set(ioChannel, KMXF_FLEXDIO_RX_SAMP_PERIOD, 1000);

   // Configure all pins as input with pull-up
   for(pin=0; pin<64 && !rc; pin++)
   {
      rc = mxfFlexDIOModeSet(ioChannel, pin, MXF_FLEXDIO_MODE_IN_PULLUP);
   }

   // Allocate RX acquisition buffer
   if (!rc)
      rc = mxfRxAcqBufferAlloc(ioChannel, BUFFER_SIZE, &rxBuffer, NULL);

   // Allocate host buffer
   if (!rc)
   {
      recDiscrete = (MXF_FLEXDIO_DATAREC*)malloc(BUFFER_SIZE);
      if (!recDiscrete)
         rc = MAXT_ERROR_MEM;
   }

   // Start the acquisition process
   if (!rc)
      rc = mxfRxAcqModeSet(rxBuffer, MXF_RXACQ_MODE_LINEAR);
   if (!rc)
   {
      rc = mxfRxAcqStart(rxBuffer, MXF_RXACQ_FLAG_DEFAULT, 0, 0);
      if (!rc)
         printf("\nAcquisition started\n\r");
   }

   // Read discrete data in acquisition buffer
   if (!rc)
   {
      rc = mxfSleep(100);
      if (!rc)
      {
      uint64 status, msgsCount, bytesCount;
      uint64 j;
      MXF_FLEXDIO_DATAREC* rec=recDiscrete;

         // Read and display records
         rc = mxfRxAcqRead(rxBuffer, 0, BUFFER_SIZE, &status, &msgsCount, &bytesCount, recDiscrete);
         for (j=0; j<msgsCount && !rc; j++)
         {
            printf("   %02"PRIu64": Timetag=%012"PRIu64", Data=0x%016"PRIx64"\n", j, rec->timeTag, rec->data);

            rc = mxfFlexDIONextDataRecordPtrGet(rec, &rec);
         }
      }
   }

   // Stop and flush unread data
   if (!rc)
      rc = mxfRxAcqStop(rxBuffer);
   if (!rc)
   {
      rc = mxfRxAcqClear(rxBuffer);
      if (!rc)
         printf("\nAcquisition stopped\n\r");
   }

   // Catch any previous error
   if (rc)
   {
   char buffer[256];
      rc = mxfSystemErrorStringGet(server, rc, sizeof(buffer), buffer);
      printf("%s\n", buffer);
   }
   
   printf("\nTerminating\n");

   if (recDiscrete)
      free(recDiscrete);
   
   mxfSystemTerminate(server);
   mxfServerDisconnect(server);

   printf("\nPress enter to terminate\n");
   getchar();

   return rc;
}