#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <strings.h>
#include <unistd.h>
#include <pthread.h>
#include <time.h>
#include <fcntl.h>
#include <limits.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/mman.h>
#include <regex.h>
#include <errno.h>
#include "simerrors.h"
#include "rtdbutils.h"
#include "tscutils.h"
#include "dirconfig.h"
#include "netioutils.h"

Include dependency graph for asyncio_net.c:

Macros
#define	_XOPEN_SOURCE 600
#define	POSIX_SHARED

Functions
void	netioAllocateSharedMem (int init)
int	ccurAsyncIO_netIOAddMessage (int boardNumber, IONETMessage *message)
int	ccurAsyncIO_netStreamAddMessage (int boardNumber, IONETMessage *message)
int	ccurAsyncIO_netIOMessagesReady (void)
void	ccurAsyncIO_netIOMessagesSetReady (int ready)
void	ccurAsyncIO_netIOSetMinRate (double r)
double	ccurAsyncIO_netIOGetMinRate ()
int	ccurAsyncIO_netStreamMessagesReady (void)
void	ccurAsyncIO_netStreamMessagesSetReady (int ready)
void	ccurAsyncIO_netStreamSetMinRate (double r)
double	ccurAsyncIO_netStreamGetMinRate ()
NETResidentMessage *	ccurAsyncIO_netIOFindMessage (int boardNumber, const char *name)
NETResidentMessage *	ccurAsyncIO_netStreamFindMessage (int boardNumber, const char *name)
int	ccurAsyncIO_netIOGetMessageIndex (NETResidentMessage *pMsg)
int	ccurAsyncIO_netStreamGetMessageIndex (NETResidentMessage *pMsg)
unsigned long long	ccurAsyncIO_netIOGetTimeStamp (int boardNumber, const char *name)
NETResidentMessage *	ccurRTDB_netIOGetMessageTable (void)
NETResidentMessage *	ccurRTDB_netStreamGetMessageTable (void)
void	ccurRTDB_netIOInitMessageTable (void)
void	ccurRTDB_netStreamInitMessageTable (void)
int	ccurAsyncIO_netIOTXQueueNow (RTDBItem *pItem)
int	ccurAsyncIO_netStreamTXQueueNow (RTDBItem *pItem)
int	ccurAsyncIO_netIOTXQueueNowName (const char *pointName)
int	ccurAsyncIO_netStreamTXQueueNowName (const char *pointName)
int	ccurAsyncIO_netIOTXQueueNowMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netStreamTXQueueNowMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netIOResumeMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netStreamResumeMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netIOResumeItemMsg (RTDBItem *pItem)
int	ccurAsyncIO_netStreamResumeItemMsg (RTDBItem *pItem)
int	ccurAsyncIO_netIOResumeItemMsgName (const char *pointName)
int	ccurAsyncIO_netStreamResumeItemMsgName (const char *pointName)
int	ccurAsyncIO_netIOPauseMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netStreamPauseMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netIOPauseItemMsg (RTDBItem *pItem)
int	ccurAsyncIO_netStreamPauseItemMsg (RTDBItem *pItem)
int	ccurAsyncIO_netIOPauseItemMsgName (const char *pointName)
int	ccurAsyncIO_netStreamPauseItemMsgName (const char *pointName)
int	ccurAsyncIO_netIOSetTxRateMsg (int boardNum, const char *msgName, int msRate)
int	ccurAsyncIO_netStreamSetTxRateMsg (int boardNum, const char *msgName, int msRate)
int	ccurAsyncIO_netIOGetTxRateMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netStreamGetTxRateMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netIOGetDefaultTxRateMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netStreamGetDefaultTxRateMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netIOGetTxFlagsMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netStreamGetTxFlagsMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netIOGetDefaultTxFlagsMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netStreamGetDefaultTxFlagsMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netIOSetTxRateP (RTDBItem *pItem, int msRate)
int	ccurAsyncIO_netStreamSetTxRateP (RTDBItem *pItem, int msRate)
int	ccurAsyncIO_netIOGetTxRateP (RTDBItem *pItem)
int	ccurAsyncIO_netStreamGetTxRateP (RTDBItem *pItem)
int	ccurAsyncIO_netIOGetDefaultTxRateP (RTDBItem *pItem)
int	ccurAsyncIO_netStreamGetDefaultTxRateP (RTDBItem *pItem)
int	ccurAsyncIO_netIOGetTxFlagsP (RTDBItem *pItem)
int	ccurAsyncIO_netStreamGetTxFlagsP (RTDBItem *pItem)
int	ccurAsyncIO_netIOGetDefaultTxFlagsP (RTDBItem *pItem)
int	ccurAsyncIO_netStreamGetDefaultTxFlagsP (RTDBItem *pItem)
int	ccurAsyncIO_netIOSetTxRate (char *pointName, int msRate)
int	ccurAsyncIO_netStreamSetTxRate (char *pointName, int msRate)
int	ccurAsyncIO_netIOGetTxRate (char *pointName)
int	ccurAsyncIO_netStreamGetTxRate (char *pointName)
int	ccurAsyncIO_netIOGetDefaultTxRate (char *pointName)
int	ccurAsyncIO_netStreamGetDefaultTxRate (char *pointName)
int	ccurAsyncIO_netIOGetTxFlags (char *pointName)
int	ccurAsyncIO_netStreamGetTxFlags (char *pointName)
int	ccurAsyncIO_netIOGetDefaultTxFlags (char *pointName)
int	ccurAsyncIO_netStreamGetDefaultTxFlags (char *pointName)
int	ccurAsyncIO_netIOSetTxScheduledToFIFOP (RTDBItem *pItem)
int	ccurAsyncIO_netStreamSetTxScheduledToFIFOP (RTDBItem *pItem)
int	ccurAsyncIO_netIOSetTxScheduledToFIFO (const char *pointName)
int	ccurAsyncIO_netStreamSetTxScheduledToFIFO (const char *pointName)
int	ccurAsyncIO_netIOSetTxScheduledToFIFOMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netStreamSetTxScheduledToFIFOMsg (int boardNum, const char *msgName)
int	ccurAsyncIO_netIOSetTxFIFOToScheduledP (RTDBItem *pItem, int msRate)
int	ccurAsyncIO_netStreamSetTxFIFOToScheduledP (RTDBItem *pItem, int msRate)
int	ccurAsyncIO_netIOSetTxFIFOToScheduled (const char *pointName, int msRate)
int	ccurAsyncIO_netStreamSetTxFIFOToScheduled (const char *pointName, int msRate)
int	ccurAsyncIO_netIOSetTxFIFOToScheduledMsg (int boardNum, const char *msgName, int msRate)
int	ccurAsyncIO_netStreamSetTxFIFOToScheduledMsg (int boardNum, const char *msgName, int msRate)
int	ccurAsyncIO_netIOSetFIFOTxOnChangeP (RTDBItem *pItem, int txOnChange)
int	ccurAsyncIO_netStreamSetFIFOTxOnChangeP (RTDBItem *pItem, int txOnChange)
int	ccurAsyncIO_netIOSetFIFOTxOnChange (const char *pointName, int txOnChange)
int	ccurAsyncIO_netStreamSetFIFOTxOnChange (const char *pointName, int txOnChange)
int	ccurAsyncIO_netIOSetFIFOTxOnChangeMsg (int boardNum, const char *msgName, int txOnChange)
int	ccurAsyncIO_netStreamSetFIFOTxOnChangeMsg (int boardNum, const char *msgName, int txOnChange)
int	ccurAsyncIO_netIOSetDestPortIP (int boardNum, const char *msgName, int destPort, int destIP)

Macro Definition Documentation

◆ _XOPEN_SOURCE

#define _XOPEN_SOURCE 600

◆ POSIX_SHARED

#define POSIX_SHARED

Function Documentation

◆ netioAllocateSharedMem()

void netioAllocateSharedMem ( int init )

◆ ccurAsyncIO_netStreamAddMessage()

int ccurAsyncIO_netStreamAddMessage	(	int	boardNumber,
		IONETMessage *	message )

◆ ccurAsyncIO_netIOMessagesReady()

int ccurAsyncIO_netIOMessagesReady ( void )

◆ ccurAsyncIO_netIOMessagesSetReady()

void ccurAsyncIO_netIOMessagesSetReady ( int ready )

◆ ccurAsyncIO_netIOSetMinRate()

void ccurAsyncIO_netIOSetMinRate ( double r )

◆ ccurAsyncIO_netIOGetMinRate()

double ccurAsyncIO_netIOGetMinRate ( )

◆ ccurAsyncIO_netStreamMessagesReady()

int ccurAsyncIO_netStreamMessagesReady ( void )

◆ ccurAsyncIO_netStreamMessagesSetReady()

void ccurAsyncIO_netStreamMessagesSetReady ( int ready )

◆ ccurAsyncIO_netStreamSetMinRate()

void ccurAsyncIO_netStreamSetMinRate ( double r )

◆ ccurAsyncIO_netStreamGetMinRate()

double ccurAsyncIO_netStreamGetMinRate ( )

◆ ccurAsyncIO_netIOGetMessageIndex()

int ccurAsyncIO_netIOGetMessageIndex ( NETResidentMessage * pMsg )

◆ ccurAsyncIO_netStreamGetMessageIndex()

int ccurAsyncIO_netStreamGetMessageIndex ( NETResidentMessage * pMsg )

◆ ccurRTDB_netStreamGetMessageTable()

NETResidentMessage * ccurRTDB_netStreamGetMessageTable ( void )

◆ ccurRTDB_netStreamInitMessageTable()

void ccurRTDB_netStreamInitMessageTable ( void )

Macros

Functions