void drain( int sd )

void drain( int sd )

{

{

   char buf[ 256 ] ; /* This size is arbitrarily chosen */

   char buf[ 256 ] ; /* This size is arbitrarily chosen */

   int old_val ;

   int old_val ;

   /* Put in non-blocking mode so we don't hang. */

   /* Put in non-blocking mode so we don't hang. */

{

{

   char            buf[ DATAGRAM_SIZE ] ;

   char            buf[ DATAGRAM_SIZE ] ;

   union xsockaddr lsin;

   union xsockaddr lsin;

   unsigned int    sin_len = 0;

   unsigned int    sin_len = 0;

   int             descriptor = SERVER_FD( serp ) ;

   int             descriptor = SERVER_FD( serp ) ;

   const char     *func = "dgram_echo";

   const char     *func = "dgram_echo";

static stream_status_e tcp_local_to_remote( channel_s *chp )

static stream_status_e tcp_local_to_remote( channel_s *chp )

{

{

   char  buf[ DATAGRAM_SIZE ] ;

   char  buf[ DATAGRAM_SIZE ] ;

   char *p ;

   char *p ;

   int   left ;

   int   left ;

   const char *func = "tcp_local_to_remote" ;

   const char *func = "tcp_local_to_remote" ;

static stream_status_e tcp_remote_to_local( channel_s *chp )

static stream_status_e tcp_remote_to_local( channel_s *chp )

{

{

   char  buf[ DATAGRAM_SIZE ] ;

   char  buf[ DATAGRAM_SIZE ] ;

   int   left ;

   int   left ;

   char *p ;

   char *p ;

   const char *func = "tcp_remote_to_local" ;

   const char *func = "tcp_remote_to_local" ;

   for ( ;; )

   for ( ;; )

   {

   {

      from_len = sizeof( pp->from ) ;

      from_len = sizeof( pp->from ) ;

      cc = recvfrom( INT_REMOTE( ip ), pp->data, pp->size,

      cc = recvfrom( INT_REMOTE( ip ), pp->data, pp->size,

static status_e udp_local_to_remote( channel_s *chp )

static status_e udp_local_to_remote( channel_s *chp )

{

{

   char   buf[ MAX_DATAGRAM_SIZE ] ;

   char   buf[ MAX_DATAGRAM_SIZE ] ;

   const char   *func = "udp_local_to_remote" ;

   const char   *func = "udp_local_to_remote" ;

   for ( ;; )

   for ( ;; )