cosmetic, V4/V5. dont use vxWorks.h under UNIX
This commit is contained in:
Jeff Hill
@@ -7,158 +7,195 @@
|
||||
*
|
||||
* History
|
||||
* .01 joh 110190 Moved to this file
|
||||
* .02 joh 082891 on UNIX copy in a new delay into the timeval
|
||||
* arg to select each call in TCPDELAY in case
|
||||
* the system modifies my timeval structure.
|
||||
* Also droped the TCPDELAY to 50 mS
|
||||
* .03 joh 090391 Updated for V5 vxWorks
|
||||
*
|
||||
*/
|
||||
|
||||
#ifndef INCos_depenh
|
||||
#define INCos_depenh
|
||||
|
||||
#ifdef vxWorks
|
||||
#if defined(UNIX)
|
||||
# ifndef _sys_time_h
|
||||
# include <sys/time.h>
|
||||
# endif
|
||||
#elif defined(vxWorks)
|
||||
# ifndef INCfast_lockh
|
||||
# include <fast_lock.h>
|
||||
# endif
|
||||
# ifndef INCtaskLibh
|
||||
# include <taskLib.h>
|
||||
# endif
|
||||
#elif defined(VMS)
|
||||
#else
|
||||
@@@@ dont compile in this case @@@@
|
||||
#endif
|
||||
|
||||
|
||||
#if !defined(NULL) || (NULL!=0)
|
||||
#define NULL 0
|
||||
#endif
|
||||
|
||||
#if !defined(FALSE) || (FALSE!=0)
|
||||
#define FALSE 0
|
||||
#endif
|
||||
|
||||
#if !defined(TRUE) || (TRUE!=1)
|
||||
#define TRUE 1
|
||||
#endif
|
||||
|
||||
#if !defined(OK) || (OK!=0)
|
||||
#define OK 0
|
||||
#endif
|
||||
|
||||
#if !defined(ERROR) || (ERROR!=(-1))
|
||||
#define ERROR (-1)
|
||||
#endif
|
||||
|
||||
/************************************************************************/
|
||||
/* Provided to enforce one thread at a time code sections */
|
||||
/* independent of a particular operating system */
|
||||
/************************************************************************/
|
||||
#ifdef VMS
|
||||
#if defined(VMS)
|
||||
/* provides for data structure mutal exclusive lock out */
|
||||
/* in the VMS AST environment. */
|
||||
/* note: the following must allways be used together */
|
||||
# define LOCK\
|
||||
{register long astenblwas;\
|
||||
astenblwas = sys$setast(FALSE);
|
||||
# define UNLOCK\
|
||||
if(astenblwas == SS$_WASSET)sys$setast(TRUE);}
|
||||
# define LOCKEVENTS
|
||||
# define UNLOCKEVENTS
|
||||
#endif
|
||||
|
||||
#ifdef vxWorks
|
||||
# define LOCK FASTLOCK(&client_lock);
|
||||
# define UNLOCK FASTUNLOCK(&client_lock);
|
||||
# define LOCKEVENTS FASTLOCK(&event_lock);
|
||||
# define UNLOCKEVENTS FASTUNLOCK(&event_lock);
|
||||
#endif
|
||||
|
||||
#ifdef UNIX
|
||||
# define LOCK
|
||||
# define UNLOCK
|
||||
# define LOCKEVENTS
|
||||
# define UNLOCKEVENTS
|
||||
#endif
|
||||
|
||||
#ifdef vxWorks
|
||||
#define VXTHISTASKID taskIdCurrent
|
||||
extern int taskIdCurrent;
|
||||
#define abort() taskSuspend(VXTHISTASKID);
|
||||
#endif
|
||||
|
||||
#ifdef vxWorks
|
||||
# define memcpy(D,S,N) bcopy(S,D,N)
|
||||
# define memset(D,V,N) bfill(D,N,V)
|
||||
# define printf logMsg
|
||||
#endif
|
||||
|
||||
#ifdef VMS
|
||||
#ifdef WINTCP /* Wallangong */
|
||||
/* (the VAXC runtime lib has its own close */
|
||||
# define socket_close(S) netclose(S)
|
||||
# define socket_ioctl(A,B,C) ioctl(A,B,C)
|
||||
# define LOCK\
|
||||
{register long astenblwas;\
|
||||
astenblwas = sys$setast(FALSE);
|
||||
# define UNLOCK\
|
||||
if(astenblwas == SS$_WASSET)sys$setast(TRUE);}
|
||||
# define LOCKEVENTS
|
||||
# define UNLOCKEVENTS
|
||||
#elif defined(vxWorks)
|
||||
# define LOCK FASTLOCK(&client_lock);
|
||||
# define UNLOCK FASTUNLOCK(&client_lock);
|
||||
# define LOCKEVENTS FASTLOCK(&event_lock);
|
||||
# define UNLOCKEVENTS FASTUNLOCK(&event_lock);
|
||||
#elif defined(UNIX)
|
||||
# define LOCK
|
||||
# define UNLOCK
|
||||
# define LOCKEVENTS
|
||||
# define UNLOCKEVENTS
|
||||
#else
|
||||
#endif
|
||||
#endif
|
||||
|
||||
#ifdef UNIX
|
||||
# define socket_close(S) close(S)
|
||||
# define socket_ioctl(A,B,C) ioctl(A,B,C)
|
||||
@@@@ dont compile in this case @@@@
|
||||
#endif
|
||||
|
||||
#ifdef vxWorks
|
||||
# define socket_close(S) close(S)
|
||||
# define socket_ioctl(A,B,C) ioctl(A,B,C)
|
||||
# define VXTHISTASKID taskIdSelf()
|
||||
# define abort(A) taskSuspend(VXTHISTASKID)
|
||||
# define memcpy(D,S,N) bcopy(S,D,N)
|
||||
# define memset(D,V,N) bfill(D,N,V)
|
||||
# define printf logMsg
|
||||
#endif
|
||||
|
||||
#ifdef VMS
|
||||
#ifdef WINTCP
|
||||
extern int uerrno; /* Wallongong errno is uerrno */
|
||||
# define MYERRNO uerrno
|
||||
#else
|
||||
extern volatile int noshare socket_errno;
|
||||
# define MYERRNO socket_errno
|
||||
#endif
|
||||
#endif
|
||||
|
||||
#ifdef vxWorks
|
||||
# define MYERRNO (errnoGet()&0xffff)
|
||||
#endif
|
||||
|
||||
#ifdef UNIX
|
||||
extern int errno;
|
||||
# define MYERRNO errno
|
||||
#endif
|
||||
|
||||
#ifdef VMS
|
||||
struct iosb{
|
||||
short status;
|
||||
unsigned short count;
|
||||
void *device;
|
||||
};
|
||||
static char ca_unique_address;
|
||||
#define MYTIMERID (&ca_unique_address)
|
||||
#endif
|
||||
|
||||
struct timeval{
|
||||
unsigned long tv_sec;
|
||||
unsigned long tv_usec;
|
||||
};
|
||||
|
||||
#ifdef vxWorks
|
||||
# define POST_IO_EV vrtxPost(&io_done_flag, TRUE)
|
||||
#endif
|
||||
#ifdef VMS
|
||||
# define POST_IO_EV sys$setef(io_done_flag)
|
||||
#endif
|
||||
#ifdef UNIX
|
||||
# define POST_IO_EV
|
||||
#endif
|
||||
|
||||
/* 50 mS delay for TCP to finish transmitting */
|
||||
/* select wakes you if message is only partly here */
|
||||
/* so this wait free's up the processor until it completely arrives */
|
||||
/* NOTE: DELAYVAL must be less than 1.0 */
|
||||
#define DELAYVAL 0.250 /* 250 mS */
|
||||
|
||||
#ifdef VMS
|
||||
# define SYSFREQ 10000000 /* 10 MHz */
|
||||
# define TCPDELAY\
|
||||
{float delay = DELAYVAL; static int ef=NULL;\
|
||||
int status; int systim[2]={-SYSFREQ*DELAYVAL,~0};\
|
||||
if(!ef)ef= lib$get_ef(&ef);\
|
||||
status = sys$setimr(ef,systim,NULL,MYTIMERID,NULL);\
|
||||
if(~status&STS$M_SUCCESS)lib$signal(status);\
|
||||
status = sys$waitfr(ef);\
|
||||
if(~status&STS$M_SUCCESS)lib$signal(status);\
|
||||
};
|
||||
#endif
|
||||
|
||||
#ifdef vxWorks
|
||||
# define SYSFREQ sysClkRateGet() /* usually 60 Hz */
|
||||
# define TCPDELAY taskDelay((unsigned int)DELAYVAL*SYSFREQ);
|
||||
# define time(A) (tickGet()/SYSFREQ)
|
||||
#endif
|
||||
|
||||
#ifdef UNIX
|
||||
# define SYSFREQ 1000000 /* 1 MHz */
|
||||
# define TCPDELAY {if(select(0,NULL,NULL,NULL,&tcpdelayval)<0)abort();}
|
||||
# ifndef CA_GLBLSOURCE
|
||||
extern struct timeval tcpdelayval;
|
||||
#if defined(VMS)
|
||||
# ifdef WINTCP /* Wallangong */
|
||||
/* (the VAXC runtime lib has its own close */
|
||||
# define socket_close(S) netclose(S)
|
||||
# define socket_ioctl(A,B,C) ioctl(A,B,C)
|
||||
# else
|
||||
struct timeval tcpdelayval = {0,(unsigned int)DELAYVAL*SYSFREQ};
|
||||
# endif
|
||||
#elif defined(UNIX)
|
||||
# define socket_close(S) close(S)
|
||||
# define socket_ioctl(A,B,C) ioctl(A,B,C)
|
||||
#elif defined(vxWorks)
|
||||
# define socket_close(S) close(S)
|
||||
# define socket_ioctl(A,B,C) ioctl(A,B,C)
|
||||
#else
|
||||
@@@@ dont compile in this case @@@@
|
||||
#endif
|
||||
|
||||
#if defined(VMS)
|
||||
# ifdef WINTCP
|
||||
extern int uerrno; /* Wallongong errno is uerrno */
|
||||
# define MYERRNO uerrno
|
||||
# else
|
||||
extern volatile int noshare socket_errno;
|
||||
# define MYERRNO socket_errno
|
||||
# endif
|
||||
#elif defined(vxWorks)
|
||||
# define MYERRNO (errnoGet()&0xffff)
|
||||
#elif defined(UNIX)
|
||||
extern int errno;
|
||||
# define MYERRNO errno
|
||||
#endif
|
||||
|
||||
#ifdef VMS
|
||||
struct iosb{
|
||||
short status;
|
||||
unsigned short count;
|
||||
void *device;
|
||||
};
|
||||
static char ca_unique_address;
|
||||
#define MYTIMERID (&ca_unique_address)
|
||||
#endif
|
||||
|
||||
|
||||
#if defined(vxWorks)
|
||||
#ifdef V5_vxWorks
|
||||
# define POST_IO_EV semGive(io_done_sem)
|
||||
#else
|
||||
# define POST_IO_EV vrtxPost(&io_done_sem->count, TRUE)
|
||||
#endif
|
||||
#elif defined(VMS)
|
||||
# define POST_IO_EV sys$setef(io_done_flag)
|
||||
#elif defined(UNIX)
|
||||
# define POST_IO_EV
|
||||
#endif
|
||||
|
||||
/* delay for when a poll is used */
|
||||
/* NOTE: DELAYTICKS must be less than TICKSPERSEC */
|
||||
#define DELAYTICKS 50L /* (adjust units below) */
|
||||
#define TICKSPERSEC 1000L /* mili sec per sec */
|
||||
|
||||
/*
|
||||
* order of ops is important here
|
||||
* SYSFREQ must evenly divide by DELAYTICKS for
|
||||
* optimal accuracy without overflow
|
||||
*/
|
||||
#define LOCALTICKS ((SYSFREQ/TICKSPERSEC)*DELAYTICKS)
|
||||
|
||||
|
||||
#if defined(VMS)
|
||||
# define SYSFREQ 10000000L /* 10 MHz */
|
||||
# define TCPDELAY\
|
||||
{ \
|
||||
static int ef=NULL; \
|
||||
int status; \
|
||||
int systim[2]={-LOCALTICKS,~0}; \
|
||||
if(!ef) ef= lib$get_ef(&ef); \
|
||||
status = sys$setimr(ef,systim,NULL,MYTIMERID,NULL); \
|
||||
if(~status&STS$M_SUCCESS)lib$signal(status); \
|
||||
status = sys$waitfr(ef); \
|
||||
if(~status&STS$M_SUCCESS)lib$signal(status); \
|
||||
};
|
||||
#elif defined(vxWorks)
|
||||
# define SYSFREQ ((long) sysClkRateGet()) /* usually 60 Hz */
|
||||
# define TCPDELAY taskDelay(LOCALTICKS);
|
||||
# define time(A) (tickGet()/SYSFREQ)
|
||||
#elif defined(UNIX)
|
||||
# define SYSFREQ 1000000L /* 1 MHz */
|
||||
/*
|
||||
* this version of TCPDELAY copies tcpdelayval into temporary storage
|
||||
* just in case the system modifies the timeval arg to select
|
||||
* in the future as is hinted in the select man page.
|
||||
*/
|
||||
# define TCPDELAY \
|
||||
{ \
|
||||
struct timeval dv; \
|
||||
dv = tcpdelayval; \
|
||||
if(select(0,NULL,NULL,NULL,&dv)<0)abort(); \
|
||||
}
|
||||
# ifdef CA_GLBLSOURCE
|
||||
struct timeval tcpdelayval = {0,LOCALTICKS};
|
||||
# else
|
||||
extern struct timeval tcpdelayval;
|
||||
# endif
|
||||
#endif
|
||||
|
||||
|
||||
#endif
|
||||
|
||||
Reference in New Issue
Block a user