Merge "Cmake, change files missing from previous commit"
[ric-plt/lib/rmr.git] / src / rmr / si / src / si95 / siwait.c
1 // vim: noet sw=4 ts=4:
2 /*
3 ==================================================================================
4     Copyright (c) 2020 Nokia
5     Copyright (c) 2020 AT&T Intellectual Property.
6
7    Licensed under the Apache License, Version 2.0 (the "License");
8    you may not use this file except in compliance with the License.
9    You may obtain a copy of the License at
10
11        http://www.apache.org/licenses/LICENSE-2.0
12
13    Unless required by applicable law or agreed to in writing, software
14    distributed under the License is distributed on an "AS IS" BASIS,
15    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16    See the License for the specific language governing permissions and
17    limitations under the License.
18 ==================================================================================
19 */
20
21 /*
22 **************************************************************************
23 *  Mnemonic: SIwait
24 *  Abstract: This  routine will wait for an event to occur on the
25 *            connections in tplist. When an event is received on a fd
26 *            the status of the fd is checked and the event handled, driving
27 *            a callback routine if necessary. The system call poll is usd
28 *            to wait, and will be interrupted if a signal is caught,
29 *            therefore the routine will handle any work that is required
30 *            when a signal is received. The routine continues to loop
31 *            until the shutdown flag is set, or until there are no open
32 *            file descriptors on which to wait.
33 *  Parms:    gptr - Pointer to the global information block
34 *  Returns:  SI_OK if the caller can continue, SI_ERROR if all sessions have been
35 *            stopped, or the interface cannot proceed. When SI_ERROR is
36 *            returned the caller should cleanup and exit immediatly (we
37 *            have probably received a sigter or sigquit.
38 *  Date:     28 March 1995
39 *  Author:   E. Scott Daniels
40 *
41 *  Modified: 11 Apr 1995 - To pass execption to select when no keyboard
42 *            19 Apr 1995 - To call do key to do better keyboard editing
43 *            18 Aug 1995 - To init kstat to 0 to prevent key hold if
44 *                          network data pending prior to entry.
45 *                       31 Jul 2016 - Major formatting clean up in the main while loop.
46 **************************************************************************
47 */
48 #include  "sisetup.h"     //  get the setup stuff 
49 #include "sitransport.h"
50 #include        <sys/wait.h>
51
52 /*
53         The select timeout is about 300 mu-sec. This is fast enough to add a new
54         outbound connection to the poll list before the other side responds,
55         but slow enough so as not to consume excess CPU when idle.
56 */
57 #define SI_SELECT_TIMEOUT 300000
58
59 extern int SIwait( struct ginfo_blk *gptr ) {
60         int fd;                                                 //  file descriptor for use in this routine 
61         int ((*cbptr)());                               //  pointer to callback routine to call 
62         int status = SI_OK;                             //  return status 
63         int addrlen;                                    //  length of address from recvfrom call 
64         int i;                                                  //  loop index 
65         struct tp_blk *tpptr;                   //  pointer at tp stuff 
66         struct tp_blk *nextone;                 //  point at next block to process in loop 
67         int pstat;                                              //  poll status 
68         struct timeval  timeout;                //  delay to use on select call
69         char *buf;
70         char *ibuf;
71
72         ibuf = (char *) malloc( 2048 );
73
74         gptr->sierr = SI_ERR_SHUTD;
75
76         if( gptr->flags & GIF_SHUTDOWN ) {                              //  cannot do if we should shutdown 
77                 return SI_ERROR;                                                        //  so just get out 
78         }
79
80         gptr->sierr = SI_ERR_HANDLE;
81
82         if( gptr->magicnum != MAGICNUM ) {                              //  if not a valid ginfo block 
83                 rmr_vlog( RMR_VL_CRIT, "SI95: wait: bad global info struct magic number is wrong\n" );
84                 return SI_ERROR;
85         }
86
87         do {                                                                    // spin until a callback says to stop (likely never)
88                 timeout.tv_sec = 0;                                     // must be reset on every call!
89                 timeout.tv_usec = SI_SELECT_TIMEOUT;
90
91                 SIbldpoll( gptr );                                      // poll list is trashed on each pop; must rebuild
92                 pstat = select( gptr->fdcount, &gptr->readfds, &gptr->writefds, &gptr->execpfds, &timeout );
93
94                 if( (pstat < 0 && errno != EINTR)  ) {
95                         gptr->fdcount = 0;                              //  prevent trying to look at a session 
96                         gptr->flags |= GIF_SHUTDOWN;    //  cause cleanup and exit at end 
97                 }
98
99                 if( pstat > 0  &&  (! (gptr->flags & GIF_SHUTDOWN)) ) {
100                         for( tpptr = gptr->tplist; tpptr != NULL; tpptr = nextone ) {
101                                 nextone = tpptr->next;                          //  prevent issues if we delete the block during loop 
102
103                                 if( tpptr->fd >= 0 ) {
104                                         if( tpptr->squeue != NULL && (FD_ISSET( tpptr->fd, &gptr->writefds )) ) {
105                                                 SIsend( gptr, tpptr );                  //  send if clear to send 
106                                         }
107         
108                                         if( FD_ISSET( tpptr->fd, &gptr->execpfds ) ) {
109                                                         ;                               // sunos seems to set the except flag for unknown reasons; ignore it
110                                         } else {
111                                                 if( FD_ISSET( tpptr->fd, &gptr->readfds ) ) {                   // ready to read
112                                                         fd = tpptr->fd;
113                                                         tpptr->rcvd++;
114         
115                                                         if( tpptr->flags & TPF_LISTENFD ) {                                     // new session request
116                                                                 errno=0;
117                                                                 status = SInewsession( gptr, tpptr );                   // accept connection
118                                                         } else  {                                                                                       //  data received on a regular port (we support just tcp now
119                                                                 status = RECV( fd, gptr->rbuf, MAX_RBUF, 0 );   //  read data 
120                                                                 if( status > 0  &&  ! (tpptr->flags & TPF_DRAIN) ) {
121                                                                         if( (cbptr = gptr->cbtab[SI_CB_CDATA].cbrtn) != NULL ) {
122                                                                                 status = (*cbptr)( gptr->cbtab[SI_CB_CDATA].cbdata, fd, gptr->rbuf, status );
123                                                                                 SIcbstat( gptr, status, SI_CB_CDATA );  //  handle cb status 
124                                                                         }
125                                                                 } else {                                                                                // no bites, but read flagged indicates disconnect
126                                                                         if( (cbptr = gptr->cbtab[SI_CB_DISC].cbrtn) != NULL ) {
127                                                                                 status = (*cbptr)( gptr->cbtab[SI_CB_DISC].cbdata, tpptr->fd );
128                                                                                 SIcbstat( gptr, status, SI_CB_DISC );   //  handle status 
129                                                                         }
130                                                                         SIterm( gptr, tpptr );
131                                                                 }
132                                                         }
133                                                 }
134                                         }
135                                 }                                                               //  if still good fd 
136                         }
137                 }
138         } while( gptr->tplist != NULL && !(gptr->flags & GIF_SHUTDOWN) );
139
140         free( ibuf );
141         if( gptr->tplist == NULL )                                      //  indicate all fds closed 
142                 gptr->sierr = SI_ERR_NOFDS;
143
144         if( gptr->flags & GIF_SHUTDOWN ) {                      //  we need to stop for some reason 
145                 gptr->sierr = SI_ERR_SHUTD;                             //  indicate error exit status 
146                 status = SI_ERROR;                                              //  status should indicate to user to die 
147                 SIshutdown( gptr );                                             //  clean things up 
148         } else {
149                 status = SI_OK;                                                 //  user can continue to process 
150         }
151
152         return status;
153 }