V5 switches out
This commit is contained in:
@@ -1,4 +1,3 @@
|
||||
#ifdef V5_vxWorks
|
||||
|
||||
static char *sccsId = "@(#)V5_vxWorks_patch.c 1.2\t7/27/92";
|
||||
|
||||
@@ -64,4 +63,3 @@ int taskVarGetPatch (tid, pVar)
|
||||
return (ERROR);
|
||||
}
|
||||
|
||||
#endif
|
||||
|
||||
+22
-45
@@ -111,7 +111,7 @@
|
||||
/************************************************************************/
|
||||
/*_end */
|
||||
|
||||
static char *sccsId = "$Id$\t$Date$";
|
||||
static char *sccsId = "@(#)access.c 1.34\t8/5/93";
|
||||
|
||||
/*
|
||||
* allocate error message string array
|
||||
@@ -372,11 +372,7 @@ int ca_task_initialize
|
||||
|
||||
FASTLOCKINIT(&client_lock);
|
||||
FASTLOCKINIT(&event_lock);
|
||||
# ifdef V5_vxWorks
|
||||
io_done_sem = semBCreate(SEM_Q_PRIORITY, SEM_EMPTY);
|
||||
# else
|
||||
io_done_sem = semCreate();
|
||||
# endif
|
||||
if(!io_done_sem){
|
||||
abort();
|
||||
}
|
||||
@@ -585,11 +581,9 @@ ca_add_task_variable()
|
||||
ca_printf("CAC: adding delete hook\n");
|
||||
# endif
|
||||
|
||||
# ifdef V5_vxWorks
|
||||
status = taskVarInit();
|
||||
if (status != OK)
|
||||
return ERROR;
|
||||
# endif
|
||||
status = taskVarInit();
|
||||
if (status != OK)
|
||||
return ERROR;
|
||||
status = taskDeleteHookAdd(ca_task_exit_tcb);
|
||||
if (status != OK) {
|
||||
logMsg("ca_init_task: could not add CA delete routine\n");
|
||||
@@ -636,7 +630,6 @@ int ca_task_exit
|
||||
*
|
||||
*/
|
||||
#ifdef vxWorks
|
||||
#ifdef V5_vxWorks
|
||||
static void
|
||||
ca_task_exit_tcb(ptcb)
|
||||
WIND_TCB *ptcb;
|
||||
@@ -654,14 +647,6 @@ WIND_TCB *ptcb;
|
||||
*/
|
||||
ca_task_exit_tid((int) ptcb);
|
||||
}
|
||||
#else
|
||||
static void
|
||||
ca_task_exit_tcb(ptcbx)
|
||||
TCBX *ptcbx;
|
||||
{
|
||||
ca_task_exit_tid((int) ptcbx->taskId);
|
||||
}
|
||||
#endif
|
||||
#endif
|
||||
|
||||
|
||||
@@ -697,13 +682,8 @@ ca_process_exit()
|
||||
|
||||
# if defined(vxWorks)
|
||||
|
||||
# ifdef V5_vxWorks
|
||||
ca_temp = (struct ca_static *)
|
||||
ca_temp = (struct ca_static *)
|
||||
taskVarGetPatch(tid, &ca_static);
|
||||
# else
|
||||
ca_temp = (struct ca_static *)
|
||||
taskVarGet(tid, &ca_static);
|
||||
# endif
|
||||
|
||||
if (ca_temp == (struct ca_static *) ERROR){
|
||||
# if DEBUG
|
||||
@@ -804,11 +784,19 @@ ca_process_exit()
|
||||
* event blocks
|
||||
*/
|
||||
for (i = 0; i < ca_temp->ca_nxtiiu; i++) {
|
||||
if (ca_temp->ca_iiu[i].conn_up)
|
||||
if (socket_close(ca_temp->ca_iiu[i].sock_chan) < 0)
|
||||
if (ca_temp->ca_iiu[i].conn_up){
|
||||
if(fd_register_func){
|
||||
(*fd_register_func)(
|
||||
fd_register_arg,
|
||||
ca_temp->ca_iiu[i].sock_chan,
|
||||
FALSE);
|
||||
}
|
||||
if (socket_close(ca_temp->ca_iiu[i].sock_chan) < 0){
|
||||
ca_signal(
|
||||
ECA_INTERNAL,
|
||||
"Corrupt iiu list- at close");
|
||||
}
|
||||
}
|
||||
free((char *)ca_temp->ca_iiu[i].send);
|
||||
free((char *)ca_temp->ca_iiu[i].recv);
|
||||
}
|
||||
@@ -851,16 +839,12 @@ ca_process_exit()
|
||||
ca_signal(ECA_INTERNAL, "couldnt free memory");
|
||||
if(FASTLOCKFREE(&ca_temp->ca_event_lock) < 0)
|
||||
ca_signal(ECA_INTERNAL, "couldnt free memory");
|
||||
# ifdef V5_vxWorks
|
||||
status = semDelete(ca_temp->ca_io_done_sem);
|
||||
if(status < 0){
|
||||
ca_signal(
|
||||
ECA_INTERNAL,
|
||||
"couldnt free sem");
|
||||
}
|
||||
# else
|
||||
semDelete(ca_temp->ca_io_done_sem);
|
||||
# endif
|
||||
status = semDelete(ca_temp->ca_io_done_sem);
|
||||
if(status < 0){
|
||||
ca_signal(
|
||||
ECA_INTERNAL,
|
||||
"couldnt free sem");
|
||||
}
|
||||
# endif
|
||||
|
||||
free((char *)ca_temp);
|
||||
@@ -2336,14 +2320,7 @@ int early;
|
||||
}
|
||||
#else
|
||||
# if defined(vxWorks)
|
||||
# ifdef V5_vxWorks
|
||||
semTake(io_done_sem, LOCALTICKS);
|
||||
# else
|
||||
{
|
||||
int dummy;
|
||||
vrtxPend(&io_done_sem->count, LOCALTICKS, &dummy);
|
||||
}
|
||||
# endif
|
||||
semTake(io_done_sem, LOCALTICKS);
|
||||
# else
|
||||
# if defined(VMS)
|
||||
{
|
||||
|
||||
@@ -40,9 +40,6 @@ static char *sccsId = "@(#)flow_control.c 1.7\t6/2/93";
|
||||
# include <ioLib.h>
|
||||
# include <socket.h>
|
||||
# include <ioctl.h>
|
||||
# ifndef V5_vxWorks
|
||||
# include <types.h>
|
||||
# endif
|
||||
#else
|
||||
# if defined(VMS)
|
||||
# include <sys/types.h>
|
||||
|
||||
+1
-5
@@ -97,11 +97,7 @@ static char *sccsId = "$Id$\t$Date$";
|
||||
# else
|
||||
# if defined(vxWorks)
|
||||
# include <vxWorks.h>
|
||||
# ifdef V5_vxWorks
|
||||
# include <systime.h>
|
||||
# else
|
||||
# include <utime.h>
|
||||
# endif
|
||||
# include <systime.h>
|
||||
# include <ioLib.h>
|
||||
# include <errno.h>
|
||||
# include <socket.h>
|
||||
|
||||
+1
-5
@@ -66,11 +66,7 @@ static char *iocinfhSccsId = "@(#)iocinf.h 1.15\t6/2/93";
|
||||
# include <netinet/in.h>
|
||||
# else
|
||||
# if defined(vxWorks)
|
||||
# ifdef V5_vxWorks
|
||||
# include <vxWorks.h>
|
||||
# else
|
||||
# include <types.h>
|
||||
# endif
|
||||
# include <vxWorks.h>
|
||||
# include <in.h>
|
||||
# else
|
||||
DONT_COMPILE
|
||||
|
||||
@@ -49,9 +49,6 @@ static char *os_depenhSccsId = "@(#)os_depen.h 1.12\t2/19/93";
|
||||
# ifndef INCtaskLibh
|
||||
# include <taskLib.h>
|
||||
# endif
|
||||
# ifndef V5_vxWorks
|
||||
IMPORT ULONG taskIdCurrent;
|
||||
# endif
|
||||
# else
|
||||
# if defined(VMS)
|
||||
# else
|
||||
@@ -201,12 +198,8 @@ static char *os_depenhSccsId = "@(#)os_depen.h 1.12\t2/19/93";
|
||||
|
||||
|
||||
#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
|
||||
#else
|
||||
# if defined(VMS)
|
||||
# define POST_IO_EV sys$setef(io_done_flag)
|
||||
# else
|
||||
|
||||
@@ -80,9 +80,6 @@ static char *sccsId = "@(#)service.c 1.17\t6/2/93";
|
||||
# else
|
||||
# if defined(vxWorks)
|
||||
# include <vxWorks.h>
|
||||
# ifndef V5_vxWorks
|
||||
# include <types.h>
|
||||
# endif
|
||||
# else
|
||||
@@@@ dont compile @@@@
|
||||
# endif
|
||||
|
||||
Reference in New Issue
Block a user