Main Page   Modules   Class Hierarchy   Alphabetical List   Compound List   File List   Compound Members   File Members  

qsemu.h File Reference

#include <errno.h>
#include <stdlib.h>
#include <sys/types.h>
#include <unistd.h>
#include <signal.h>
#include <pwd.h>
#include <limits.h>
#include <pthread.h>
#include <netdb.h>

Include dependency graph for qsemu.h:

Include dependency graph

Go to the source code of this file.

Compounds

struct  msgQUEUE
struct  qsemuNET_HEADER
struct  qsemuNET_PACKET
struct  qsemuHELLO_MSG
struct  qsemuNET_PACKET_ID
struct  qsemuNAME_STRUCT
struct  qsemuENV_LIST
struct  Hashtable_item

Defines

#define SELCAST(X)   (X)
#define qsemuCMD_PRINT_TBL   "QPRTBL"
#define qsemuPROTOCOL_VERSION   3
#define qsemuPROTOCOL_VERSION_RTAP_6_6   3
#define qsemuMAX_ENVS   100
#define qsemuMAX_CONNECT_FAILURES   4
#define qsemuDISCONNECT_WAIT_TIME   18
#define qsemuRETRY_TIMEOUT   3
#define qsemuHASH_SIZE   65536
#define qsemuTIMEOUT   9
#define ERROR   -1
#define OK   0
#define HASH_STRING_LENGTH   10

Typedefs

typedef qsemuNET_PACKET * qsemuNET_PACKETP

Enumerations

enum  qsemuSTATE { qsemuDISCONNECTED = 0, qsemuCONNECTING, qsemuCONNECTED }

Functions

ccsCOMPL_STAT qsemuParseEnvList ()
ccsCOMPL_STAT qsemuCreateSocket (ccsERROR *error)
void qsemuGetFromLocal (ccsERROR *error)
void qsemuGetFromRemote ()
void qsemuSendNackToLocal (rtMsgHeader *header, ccsSINGLE_ERROR *singleError)
ccsCOMPL_STAT qsemuSendToLocal (msgQUEUE *msg, int size, int *errVal, ccsSINGLE_ERROR *singleError)
qsemuENV_LIST * qsemuGetTblEntry (char *env)
ccsCOMPL_STAT qsemuConnectRemote (qsemuENV_LIST *entry, ccsSINGLE_ERROR *singleError, ccsERROR *error)
ccsCOMPL_STAT qsemuSendHello (int fd, ccsSINGLE_ERROR *singleError)
ccsCOMPL_STAT qsemuReadHello (int fd, qsemuENV_LIST *entry, ccsSINGLE_ERROR *singleError)
int qsemuReadSocket (int fd, char *buf, int len)
ccsCOMPL_STAT qsemuSendToRemote (qsemuENV_LIST *entry, qsemuNET_PACKET *qsMsg, ccsSINGLE_ERROR *singleError)
void qsemuCloseEnv (qsemuENV_LIST *entry)
ccsCOMPL_STAT qsemuGetHelloAccept (int fd, qsemuENV_LIST **entry)
ccsCOMPL_STAT qsemuSendNackToRemote (qsemuENV_LIST *entry, vltUINT16 msgSeqNum, rtMsgHeader *header, ccsSINGLE_ERROR *singleError, vltUINT8 type)
ccsCOMPL_STAT qsemuSendAckToRemote (qsemuENV_LIST *entry, vltUINT16 msgSeqNum, rtMsgHeader *header, ccsSINGLE_ERROR *singleError)
void qsemuSendObituary (rtMsgHeader *msg)
void qsemuEnvThread (qsemuENV_LIST *entry)
ccsCOMPL_STAT qsemuSendPingResponse (qsemuENV_LIST *entry, vltUINT16 msgSeqNum, rtMsgHeader *header, ccsSINGLE_ERROR *singleError)
ccsCOMPL_STAT qsemuSendProcnum (qsemuENV_LIST *entry, vltUINT16 msgSeqNum, rtMsgHeader *header, ccsPROCNUM procnum, ccsSINGLE_ERROR *singleError)
ccsCOMPL_STAT qsemuSendProcname (qsemuENV_LIST *entry, vltUINT16 msgSeqNum, rtMsgHeader *header, ccsPROCNAME name, ccsSINGLE_ERROR *singleError)
ccsCOMPL_STAT qsemuSendPid (qsemuENV_LIST *entry, vltUINT16 msgSeqNum, rtMsgHeader *header, rtInt pid, ccsSINGLE_ERROR *singleError)
void qsemuPrintNetHeader (qsemuNET_HEADER *netHeader)
void qsemuPrintMsgHeader (rtMsgHeader *msgHeader)
void qsemuLogDebug (char *fmt, int arg1, int arg2, int arg3, int arg4, int arg5, int arg6)
void qsemuPrintNack (ccsACKNOWLEDGE *ack)
msgLENGTH qsemuSendTblToLocal (msgMSG *header, msgQUEUE *buf, ccsSINGLE_ERROR *singleError, ccsERROR *error)
ccsCOMPL_STAT qsemuQueryEnvTbl (char *printBuffer, int *printSize)
ccsCOMPL_STAT qsemuSendPingRequest (qsemuENV_LIST *entry, ccsSINGLE_ERROR *singleError)
int qsemuCompare (const void *name1, const void *name2)
int symAdd (void *symTblId, char *key, char *value)
int symFindByName (void *symTblId, char *key, char **pValue)
int symRemove (void *symTblId, char *key)
int memPartAddToPool (void *partId, char *pPool, unsigned poolSize)
int symHashCreate (int tableSize, void *symPartId)
int fetch_hash_index (void *symTblId, char *search_key, size_t *hash_index)
size_t hash_function (void *symTblId, char *key)
int hashtable_print_qsemu (void *symTblId)
int hashtable_statistics (void *symTblId)

Variables

int qsemuTimeout
char qsemuEnvTbl [MAX_INPUT]
ccsENVNAME qsemuEnvName
qsemuENV_LIST * qsemuEnvList
int qsemuEnvCnt
char qsemuUser [9]
int qsemuFdReceive
int qsemuPid
int qsemuProtocolVersion
int qsemuMsgSeqNum
pthread_t qsemuThread
pthread_mutex_t qsemuMutex
void * qsemuHash
qsemuNAME_STRUCT * qsemuNames
vltLOGICAL qsemuLog
int qsemuCnt

Define Documentation

#define SELCAST (  X    )     (X)
 

#define qsemuCMD_PRINT_TBL   "QPRTBL"
 

#define qsemuPROTOCOL_VERSION   3
 

#define qsemuPROTOCOL_VERSION_RTAP_6_6   3
 

#define qsemuMAX_ENVS   100
 

#define qsemuMAX_CONNECT_FAILURES   4
 

#define qsemuDISCONNECT_WAIT_TIME   18
 

#define qsemuRETRY_TIMEOUT   3
 

#define qsemuHASH_SIZE   65536
 

#define qsemuTIMEOUT   9
 

#define ERROR   -1
 

#define OK   0
 

#define HASH_STRING_LENGTH   10
 

Typedef Documentation

typedef qsemuNET_PACKET* qsemuNET_PACKETP
 

Enumeration Type Documentation

enum qsemuSTATE
 

Enumeration values:
qsemuDISCONNECTED 
qsemuCONNECTING 
qsemuCONNECTED 

Function Documentation

ccsCOMPL_STAT qsemuParseEnvList (    ) 
 

ccsCOMPL_STAT qsemuCreateSocket (  ccsERROR *    error ) 
 

void qsemuGetFromLocal (  ccsERROR *    error ) 
 

void qsemuGetFromRemote (    ) 
 

void qsemuSendNackToLocal (  rtMsgHeader *    header,
ccsSINGLE_ERROR *    singleError
) 
 

ccsCOMPL_STAT qsemuSendToLocal (  msgQUEUE *    msg,
int    size,
int *    errVal,
ccsSINGLE_ERROR *    singleError
) 
 

qsemuENV_LIST* qsemuGetTblEntry (  char *    env ) 
 

ccsCOMPL_STAT qsemuConnectRemote (  qsemuENV_LIST *    entry,
ccsSINGLE_ERROR *    singleError,
ccsERROR *    error
) 
 

ccsCOMPL_STAT qsemuSendHello (  int    fd,
ccsSINGLE_ERROR *    singleError
) 
 

ccsCOMPL_STAT qsemuReadHello (  int    fd,
qsemuENV_LIST *    entry,
ccsSINGLE_ERROR *    singleError
) 
 

int qsemuReadSocket (  int    fd,
char *    buf,
int    len
) 
 

ccsCOMPL_STAT qsemuSendToRemote (  qsemuENV_LIST *    entry,
qsemuNET_PACKET *    qsMsg,
ccsSINGLE_ERROR *    singleError
) 
 

void qsemuCloseEnv (  qsemuENV_LIST *    entry ) 
 

ccsCOMPL_STAT qsemuGetHelloAccept (  int    fd,
qsemuENV_LIST **    entry
) 
 

ccsCOMPL_STAT qsemuSendNackToRemote (  qsemuENV_LIST *    entry,
vltUINT16    msgSeqNum,
rtMsgHeader *    header,
ccsSINGLE_ERROR *    singleError,
vltUINT8    type
) 
 

ccsCOMPL_STAT qsemuSendAckToRemote (  qsemuENV_LIST *    entry,
vltUINT16    msgSeqNum,
rtMsgHeader *    header,
ccsSINGLE_ERROR *    singleError
) 
 

void qsemuSendObituary (  rtMsgHeader *    msg ) 
 

void qsemuEnvThread (  qsemuENV_LIST *    entry ) 
 

ccsCOMPL_STAT qsemuSendPingResponse (  qsemuENV_LIST *    entry,
vltUINT16    msgSeqNum,
rtMsgHeader *    header,
ccsSINGLE_ERROR *    singleError
) 
 

ccsCOMPL_STAT qsemuSendProcnum (  qsemuENV_LIST *    entry,
vltUINT16    msgSeqNum,
rtMsgHeader *    header,
ccsPROCNUM    procnum,
ccsSINGLE_ERROR *    singleError
) 
 

ccsCOMPL_STAT qsemuSendProcname (  qsemuENV_LIST *    entry,
vltUINT16    msgSeqNum,
rtMsgHeader *    header,
ccsPROCNAME    name,
ccsSINGLE_ERROR *    singleError
) 
 

ccsCOMPL_STAT qsemuSendPid (  qsemuENV_LIST *    entry,
vltUINT16    msgSeqNum,
rtMsgHeader *    header,
rtInt    pid,
ccsSINGLE_ERROR *    singleError
) 
 

void qsemuPrintNetHeader (  qsemuNET_HEADER *    netHeader ) 
 

void qsemuPrintMsgHeader (  rtMsgHeader *    msgHeader ) 
 

void qsemuLogDebug (  char *    fmt,
int    arg1,
int    arg2,
int    arg3,
int    arg4,
int    arg5,
int    arg6
) 
 

void qsemuPrintNack (  ccsACKNOWLEDGE *    ack ) 
 

msgLENGTH qsemuSendTblToLocal (  msgMSG *    header,
msgQUEUE *    buf,
ccsSINGLE_ERROR *    singleError,
ccsERROR *    error
) 
 

ccsCOMPL_STAT qsemuQueryEnvTbl (  char *    printBuffer,
int *    printSize
) 
 

ccsCOMPL_STAT qsemuSendPingRequest (  qsemuENV_LIST *    entry,
ccsSINGLE_ERROR *    singleError
) 
 

int qsemuCompare (  const void *    name1,
const void *    name2
) 
 

int symAdd (  void *    symTblId,
char *    key,
char *    value
) 
 

int symFindByName (  void *    symTblId,
char *    key,
char **    pValue
) 
 

int symRemove (  void *    symTblId,
char *    key
) 
 

int memPartAddToPool (  void *    partId,
char *    pPool,
unsigned    poolSize
) 
 

int symHashCreate (  int    tableSize,
void *    symPartId
) 
 

int fetch_hash_index (  void *    symTblId,
char *    search_key,
size_t *    hash_index
) 
 

size_t hash_function (  void *    symTblId,
char *    key
) 
 

int hashtable_print_qsemu (  void *    symTblId ) 
 

int hashtable_statistics (  void *    symTblId ) 
 

Variable Documentation

int qsemuTimeout
 

char qsemuEnvTbl[MAX_INPUT]
 

ccsENVNAME qsemuEnvName
 

qsemuENV_LIST* qsemuEnvList
 

int qsemuEnvCnt
 

char qsemuUser[9]
 

int qsemuFdReceive
 

int qsemuPid
 

int qsemuProtocolVersion
 

int qsemuMsgSeqNum
 

pthread_t qsemuThread
 

pthread_mutex_t qsemuMutex
 

void* qsemuHash
 

qsemuNAME_STRUCT* qsemuNames
 

vltLOGICAL qsemuLog
 

int qsemuCnt
 

Generated on Wed Dec 3 14:55:49 2003 for ATCS API by doxygen1.2.13.1 written by Dimitri van Heesch, © 1997-2001