Add SI95 transport support

[ric-plt/lib/rmr.git] / src / rmr / si / src / si95 / siconnect.c

diff --git a/src/rmr/si/src/si95/siconnect.c b/src/rmr/si/src/si95/siconnect.c
new file mode 100644 (file)
index 0000000..e7fd7b3
--- /dev/null
+++ b/src/rmr/si/src/si95/siconnect.c
@@ -0,0 +1,96 @@
+// vim: noet sw=4 ts=4:
+/*
+==================================================================================
+    Copyright (c) 2020 Nokia
+    Copyright (c) 2020 AT&T Intellectual Property.
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+==================================================================================
+*/
+
+/*
+***************************************************************************
+*
+*  Mnemonic:   SIconnect
+*  Abstract:   Start a TCP/IP session with another process.
+*  Parms:    
+*              addr - Pointer to a string containing the process' address
+*                              The address is either ipv4 or ipv6 formmat with the
+*                              port number separated with a semicolon (::1;4444,
+*                              localhost;4444 climber;4444 129.168.0.4;4444).
+*  Returns:    The session number if all goes well, SI_ERROR if not.
+*
+*  Date:               March 1995
+*  Author:             E. Scott Daniels
+*
+*  Mod:                08 Mar 2007 - conversion of sorts to support ipv6
+******************************************************************************
+*/
+#include "sisetup.h"
+#include "sitransport.h"
+
+/*
+       Accept a file descriptor and add it to the map.
+*/
+extern void SImap_fd( struct ginfo_blk *gptr, int fd, struct tp_blk* tpptr ) {
+       if( fd < MAX_FDS ) {
+               gptr->tp_map[fd] = tpptr;
+       } else {
+               fprintf( stderr, "[WRN] fd on connected session is out of range: %d\n", fd );
+       }
+}
+
+extern int SIconnect( struct ginfo_blk *gptr, char *abuf ) {
+       int status;
+       struct tp_blk *tpptr;           //  pointer to new block 
+       struct sockaddr *taddr;         // convenience pointer to addr of target
+       int alen = 0;                                   //  len of address struct 
+       int fd = SI_ERROR;              //  file descriptor to return to caller 
+
+       if( PARINOID_CHECKS ) {
+               if( gptr == NULL ) {
+                       return SI_ERROR;
+               }
+
+               gptr->sierr = SI_ERR_HANDLE;
+               if( gptr->magicnum != MAGICNUM ) {              // no cookie -- no connection
+                       return SI_ERROR;
+               }
+       }
+
+       gptr->sierr = SI_ERR_TPORT;
+       tpptr = SIconn_prep( gptr, TCP_DEVICE, abuf, 0 );                       // create tp struct, and socket. get peer address 0 == any family that suits the addr
+       if( tpptr != NULL ) {
+               taddr = tpptr->paddr;
+               gptr->sierr = SI_ERR_TP;
+               errno = 0;
+               if( connect( tpptr->fd, taddr, tpptr->palen ) != 0 ) {
+                       close( tpptr->fd );                             //  clean up fd and tp_block 
+                       SItrash( TP_BLK, tpptr );               //  free the trasnsport block 
+                       fd = SI_ERROR;                                  //  send bad session id num back 
+               } else  {                                       //  connect ok 
+                       gptr->sierr = 0;
+                       tpptr->flags |= TPF_SESSION;                    //  indicate we have a session here 
+                       tpptr->next = gptr->tplist;                     //  add block to the list 
+                       if( tpptr->next != NULL ) {
+                               tpptr->next->prev = tpptr;              //  if there - point back at new 
+                       }
+
+                       gptr->tplist = tpptr;                           //  point at new head 
+                       fd = tpptr->fd;                                 //  save for return value 
+                       SImap_fd( gptr, fd, tpptr );
+               }
+       }
+
+       return fd;                    
+}