+  e - Added a new function DIS_tcp_close to the the code. This takes care of a problem

+      where TORQUE memory keeps growing because the read and write buffers associated

+      with each tcparray entry would grow to accommodate incoming and outgoing data

+      but would not shrink.

Index: src/include/dis.h

===================================================================

--- src/include/dis.h	(revision 5257)

+++ src/include/dis.h	(revision 5258)

@@ -238,13 +238,15 @@

 /* the following routines set/control DIS over tcp */

-extern void DIS_tcp_reset (int fd, int rw);

-extern void DIS_tcp_setup (int fd);

-extern int  DIS_tcp_wflush (int fd);

-extern void DIS_tcp_settimeout (long timeout);

-extern int  DIS_tcp_istimeout (int fd);

+void DIS_tcp_reset (int fd, int rw);

+void DIS_tcp_setup (int fd);

+int  DIS_tcp_wflush (int fd);

+void DIS_tcp_settimeout (long timeout);

+int  DIS_tcp_istimeout (int fd);

+void DIS_tcp_close (int fd);

+

 extern int  PConnTimeout(int);

 /* NOTE:  increase THE_BUF_SIZE to 131072 for systems > 5k nodes */

Index: src/lib/Libattr/attr_fn_arst.c

===================================================================

--- src/lib/Libattr/attr_fn_arst.c	(revision 5257)

+++ src/lib/Libattr/attr_fn_arst.c	(revision 5258)

@@ -186,13 +186,14 @@

   bksize = (ns - 1) * sizeof(char *) + sizeof(struct array_strings);

-  if ((stp = (struct array_strings *)malloc(bksize)) == NULL)

+  if (( patr->at_val.at_arst = (struct array_strings *)malloc(bksize)) == NULL)

     {

     /* FAILURE */

     return(PBSE_SYSTEM);

     }

+  stp = patr->at_val.at_arst;

   memset(stp, 0, bksize);

   stp->as_npointers = ns;

@@ -238,7 +239,7 @@

   patr->at_flags |= ATR_VFLAG_SET | ATR_VFLAG_MODIFY;

-  patr->at_val.at_arst = stp;

+/*  patr->at_val.at_arst = stp;*/

   free(tmpval);

Index: src/lib/Libifl/tcp_dis.c

===================================================================

--- src/lib/Libifl/tcp_dis.c	(revision 5257)

+++ src/lib/Libifl/tcp_dis.c	(revision 5258)

@@ -790,9 +790,30 @@

   return;

   }

+void DIS_tcp_close(

+  int fd)

+  {

+  struct tcp_chan *tcp;

+  tcp = tcparray[fd];

+  if(tcp != NULL)

+    {

+    if(tcp->readbuf.tdis_thebuf != NULL)

+      free(tcp->readbuf.tdis_thebuf);

+    if(tcp->writebuf.tdis_thebuf != NULL)

+      free(tcp->writebuf.tdis_thebuf);

+

+    free(tcp);

+    tcparray[fd] = NULL;

+    }

+

+  return;

+  }

+

+

+

 /*

  * DIS_tcp_setup - setup supports routines for dis, "data is strings", to

  * use tcp stream I/O.  Also initializes an array of pointers to

Index: src/lib/Libnet/net_server.c

===================================================================

--- src/lib/Libnet/net_server.c	(revision 5257)

+++ src/lib/Libnet/net_server.c	(revision 5258)

@@ -114,6 +114,7 @@

 #include "server_limits.h"

 #include "net_connect.h"

 #include "log.h"

+#include "dis.h" /* DIS_tcp_close */

 extern int LOGLEVEL;

@@ -718,6 +719,7 @@

   int sd) /* I */

   {

+

   if ((sd < 0) || (max_connection <= sd))

     {

     return;

@@ -757,6 +759,9 @@

   num_connections--;

+  DIS_tcp_close(sd);

+

+

   return;

   }  /* END close_conn() */