crypto/kerberosIV/appl/telnet/telnet/network.c

   1 /*
   2  * Copyright (c) 1988, 1993
   3  *      The Regents of the University of California.  All rights reserved.
   4  *
   5  * Redistribution and use in source and binary forms, with or without
   6  * modification, are permitted provided that the following conditions
   7  * are met:
   8  * 1. Redistributions of source code must retain the above copyright
   9  *    notice, this list of conditions and the following disclaimer.
  10  * 2. Redistributions in binary form must reproduce the above copyright
  11  *    notice, this list of conditions and the following disclaimer in the
  12  *    documentation and/or other materials provided with the distribution.
  13  * 3. All advertising materials mentioning features or use of this software
  14  *    must display the following acknowledgement:
  15  *      This product includes software developed by the University of
  16  *      California, Berkeley and its contributors.
  17  * 4. Neither the name of the University nor the names of its contributors
  18  *    may be used to endorse or promote products derived from this software
  19  *    without specific prior written permission.
  20  *
  21  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  22  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  23  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  24  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  25  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  26  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  27  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  28  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  29  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  30  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  31  * SUCH DAMAGE.
  32  */
  33
  34 #include "telnet_locl.h"
  35
  36 RCSID("$Id: network.c,v 1.10.28.1 2000/10/10 13:08:27 assar Exp $");
  37
  38 Ring            netoring, netiring;
  39 unsigned char   netobuf[2*BUFSIZ], netibuf[BUFSIZ];
  40
  41 /*
  42  * Initialize internal network data structures.
  43  */
  44
  45 void
  46 init_network(void)
  47 {
  48     if (ring_init(&netoring, netobuf, sizeof netobuf) != 1) {
  49         exit(1);
  50     }
  51     if (ring_init(&netiring, netibuf, sizeof netibuf) != 1) {
  52         exit(1);
  53     }
  54     NetTrace = stdout;
  55 }
  56
  57
  58 /*
  59  * Check to see if any out-of-band data exists on a socket (for
  60  * Telnet "synch" processing).
  61  */
  62
  63 int
  64 stilloob(void)
  65 {
  66     static struct timeval timeout = { 0 };
  67     fd_set      excepts;
  68     int value;
  69
  70     do {
  71         FD_ZERO(&excepts);
  72         if (net >= FD_SETSIZE)
  73             errx (1, "fd too large");
  74         FD_SET(net, &excepts);
  75         value = select(net+1, 0, 0, &excepts, &timeout);
  76     } while ((value == -1) && (errno == EINTR));
  77
  78     if (value < 0) {
  79         perror("select");
  80         quit();
  81         /* NOTREACHED */
  82     }
  83     if (FD_ISSET(net, &excepts)) {
  84         return 1;
  85     } else {
  86         return 0;
  87     }
  88 }
  89
  90
  91 /*
  92  *  setneturg()
  93  *
  94  *      Sets "neturg" to the current location.
  95  */
  96
  97 void
  98 setneturg(void)
  99 {
 100     ring_mark(&netoring);
 101 }
 102
 103
 104 /*
 105  *  netflush
 106  *              Send as much data as possible to the network,
 107  *      handling requests for urgent data.
 108  *
 109  *              The return value indicates whether we did any
 110  *      useful work.
 111  */
 112
 113
 114 int
 115 netflush(void)
 116 {
 117     int n, n1;
 118
 119 #if     defined(ENCRYPTION)
 120     if (encrypt_output)
 121         ring_encrypt(&netoring, encrypt_output);
 122 #endif
 123     if ((n1 = n = ring_full_consecutive(&netoring)) > 0) {
 124         if (!ring_at_mark(&netoring)) {
 125             n = send(net, (char *)netoring.consume, n, 0); /* normal write */
 126         } else {
 127             /*
 128              * In 4.2 (and 4.3) systems, there is some question about
 129              * what byte in a sendOOB operation is the "OOB" data.
 130              * To make ourselves compatible, we only send ONE byte
 131              * out of band, the one WE THINK should be OOB (though
 132              * we really have more the TCP philosophy of urgent data
 133              * rather than the Unix philosophy of OOB data).
 134              */
 135             n = send(net, (char *)netoring.consume, 1, MSG_OOB);/* URGENT data */
 136         }
 137     }
 138     if (n < 0) {
 139         if (errno != ENOBUFS && errno != EWOULDBLOCK) {
 140             setcommandmode();
 141             perror(hostname);
 142             NetClose(net);
 143             ring_clear_mark(&netoring);
 144             longjmp(peerdied, -1);
 145             /*NOTREACHED*/
 146         }
 147         n = 0;
 148     }
 149     if (netdata && n) {
 150         Dump('>', netoring.consume, n);
 151     }
 152     if (n) {
 153         ring_consumed(&netoring, n);
 154         /*
 155          * If we sent all, and more to send, then recurse to pick
 156          * up the other half.
 157          */
 158         if ((n1 == n) && ring_full_consecutive(&netoring)) {
 159             netflush();
 160         }
 161         return 1;
 162     } else {
 163         return 0;
 164     }
 165 }