Real-Time API Revision2025.1-3
Loading...
Searching...
No Matches
udpioutils.c File Reference
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <fcntl.h>
#include <errno.h>
#include <unistd.h>
#include <pthread.h>
#include <sys/mman.h>
#include <sys/stat.h>
#include <sys/time.h>
#include <sys/types.h>
#include "simrtdb.h"
#include "udpioutils.h"
#include "dirconfig.h"
#include "ccurutils.h"
#include "rtdbutils.h"
#include "simerrors.h"
Include dependency graph for udpioutils.c:

Functions

void * ccurUDPIO_outGetNextMessageAddress ()
int ccurUDPIO_outputQueueMap (int init)
int ccurUDPIO_outputQPutData (unsigned char boardNum, const char *msgName, int msgLen)
int ccurUDPIO_outputQPutCommand (unsigned char boardNum, unsigned char operation, const char *msgName, int parm)
int ccurUDPIO_outputQGet (UDPOutQElement *e, unsigned char **buffer)
int ccurUDPIO_readHeader (int boardNum, IOUDPHeader *header)
int ccurUDPIO_readMessages (int boardNum, int dir, IOUDPMessage **netMessages, int *nMessages)

Function Documentation

◆ ccurUDPIO_outGetNextMessageAddress()

void * ccurUDPIO_outGetNextMessageAddress ( )

Return the address of the next available NET message buffer in the output queue.
The caller must fill the buffer with the NET data and then call ccurNET_outputQPut to place the element int the queue.

Returns
The address of the next available message buffer. NULL if the queue is full . The queue can fill up if the consumer processes data slower that the producer places element in the queue.

◆ ccurUDPIO_outputQueueMap()

int ccurUDPIO_outputQueueMap ( int init)

◆ ccurUDPIO_outputQPutData()

int ccurUDPIO_outputQPutData ( unsigned char boardNum,
const char * msgName,
int msgLen )

◆ ccurUDPIO_outputQPutCommand()

int ccurUDPIO_outputQPutCommand ( unsigned char boardNum,
unsigned char operation,
const char * msgName,
int parm )

◆ ccurUDPIO_outputQGet()

int ccurUDPIO_outputQGet ( UDPOutQElement * e,
unsigned char ** buffer )

◆ ccurUDPIO_readHeader()

int ccurUDPIO_readHeader ( int boardNum,
IOUDPHeader * header )

◆ ccurUDPIO_readMessages()

int ccurUDPIO_readMessages ( int boardNum,
int dir,
IOUDPMessage ** netMessages,
int * nMessages )