epics/pcas
0
0
Fork 0
Code Issues Pull Requests Projects Wiki Activity

events on action now a subroutine

Browse Source
This commit is contained in:
Jeff Hill
1993-09-14 19:24:02 +00:00
parent 40afc52233
commit 0215216cb4
1 changed files with 54 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

89
src/rsrv/camessage.c
View File

@@ -44,6 +44,7 @@
* .10 joh 050692 added new routine - cas_send_heartbeat()
* .11 joh 062492 dont allow flow control to turn off gets
* .12 joh 090893 converted pointer to server id
* .13 joh 091493 made events on action a subroutine for debugging
*/
static char *sccsId = "$Id$";
@@ -125,6 +126,10 @@ LOCAL struct channel_in_use *MPTOPCIU(
struct extmsg *mp
);
LOCAL void events_on_action(
struct client *client
);
LOCAL unsigned long bucketID;
@@ -256,46 +261,15 @@ struct message_buffer *recv
UNLOCK_CLIENT(client);
}
break;
case IOC_EVENTS_ON:
{
struct event_ext *pevext;
struct event_ext evext;
client->eventsoff = FALSE;
LOCK_CLIENT(client);
pciu = (struct channel_in_use *)
client->addrq.node.next;
while (pciu) {
pevext = (struct event_ext *)
pciu->eventq.node.next;
while (pevext){
if (pevext->modified) {
evext = *pevext;
evext.send_lock = FALSE;
evext.get = TRUE;
read_reply(
&evext,
&pciu->addr,
TRUE,
NULL);
pevext->modified = FALSE;
}
pevext = (struct event_ext *)
pevext->node.next;
}
pciu = (struct channel_in_use *)
pciu->node.next;
}
UNLOCK_CLIENT(client);
events_on_action(client);
break;
}
case IOC_EVENTS_OFF:
client->eventsoff = TRUE;
break;
case IOC_READ_SYNC:
read_sync_reply(mp, client);
break;
@@ -376,6 +350,51 @@ struct message_buffer *recv
return OK;
}
/*
*
* events_on_action()
*
*/
LOCAL void events_on_action(
struct client *client
)
{
struct channel_in_use *pciu;
struct event_ext *pevext;
struct event_ext evext;
client->eventsoff = FALSE;
LOCK_CLIENT(client);
pciu = (struct channel_in_use *)
client->addrq.node.next;
while (pciu) {
pevext = (struct event_ext *)
pciu->eventq.node.next;
while (pevext){
if (pevext->modified) {
evext = *pevext;
evext.send_lock = FALSE;
evext.get = TRUE;
read_reply(
&evext,
&pciu->addr,
TRUE,
NULL);
pevext->modified = FALSE;
}
pevext = (struct event_ext *)
pevext->node.next;
}
pciu = (struct channel_in_use *)
pciu->node.next;
}
UNLOCK_CLIENT(client);
}
/*