X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Frmr%2Fsi%2Fsrc%2Fsi95%2Fsisend.c;fp=src%2Frmr%2Fsi%2Fsrc%2Fsi95%2Fsisend.c;h=5a8a94e38ccc476985619c7371251cbc5a040820;hb=ec88d3c0563eeb6ae5f73427edb0b3c4d7acf299;hp=0000000000000000000000000000000000000000;hpb=77406e61f2158f5b88b7a9f6e3e86d8f62c8f71a;p=ric-plt%2Flib%2Frmr.git

diff --git a/src/rmr/si/src/si95/sisend.c b/src/rmr/si/src/si95/sisend.c
new file mode 100644
index 0000000..5a8a94e
--- /dev/null
+++ b/src/rmr/si/src/si95/sisend.c
@@ -0,0 +1,87 @@
+// 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: SIsend
+*  Abstract: This routine is called to send a buffer of data to a partner
+*            if the buffer has been queued waiting for the session to
+*            unblock. The top qio block is removed from the tp block's
+*            queue and is sent. It is assumed that for UDP data the
+*            unit data structure was created and contains the buffer and
+*            address and is pointed to by the qio block. The block and
+*            associated buffers are then freed.
+*  Parms:
+*            tpptr- Pointer to the tp block
+*
+*  Returns:	Nothing.
+*  Date:	27 March 1995
+*  Author:	E. Scott Daniels
+*  Mod:		22 Feb 2002 - To support sendqueue tail 
+*
+******************************************************************************
+*/
+#include "sisetup.h"      //  get include files etc 
+#include "sitransport.h"
+
+extern void SIsend( struct ginfo_blk *gptr, struct tp_blk *tpptr ) {
+	struct t_unitdata *udata;      //  pointer at UDP unit data 
+	struct ioq_blk *qptr;          //  pointer at qio block for free 
+	int status;
+//static int announced = 0;	// TESTING
+
+	if( tpptr->squeue == NULL )    //  who knows why we were called 
+		return;                        //  nothing queued - just leave 
+
+/*
+	if( tpptr->type == SOCK_DGRAM ) {                                //  udp send?  
+		sendto( tpptr->fd, tpptr->squeue->data, tpptr->squeue->dlen, 0, tpptr->squeue->addr, sizeof( struct sockaddr ) );
+		if( tpptr->squeue->addr != NULL )
+			free( tpptr->squeue->data );
+		tpptr->squeue->addr = NULL;
+	} else {
+*/
+		status= SEND( tpptr->fd, tpptr->squeue->data, tpptr->squeue->dlen, 0 );
+/*
+	}
+*/
+
+
+/*
+//TESTING
+if( !announced && status < tpptr->squeue->dlen ) {
+announced = 1;
+fprintf( stderr, ">>>>>>> !!!!!! SIsend: short send: %d != %d\n", status, tpptr->squeue->dlen );
+}
+*/
+	free( tpptr->squeue->data );           //  trash buffer or the udp block 
+	qptr = tpptr->squeue;                  //  hold pointer for free 
+	tpptr->squeue = tpptr->squeue->next;   //  next in queue becommes head 
+	if( !tpptr->squeue )
+		tpptr->sqtail = NULL;		//  no tail left either 
+
+	free( qptr );
+
+	if( (tpptr->flags & TPF_DRAIN) && tpptr->squeue == NULL )  //  done w/ drain? 
+	{
+		SIterm( gptr, tpptr );     //  trash the tp block 
+	}
+}                      //  SIsend