home *** CD-ROM | disk | FTP | other *** search
/ Source Code 1992 March / Source_Code_CD-ROM_Walnut_Creek_March_1992.iso / usenet / compsrcs / unix / volume04 / rlogin < prev    next >
Encoding:
Text File  |  1988-09-11  |  39.4 KB  |  1,557 lines
  1. Subject:  4.2bsd rlogin enhancements
  2. Newsgroups: mod.sources
  3. Approved: jpn@panda.UUCP
  4.  
  5. Mod.sources:  Volume 4, Issue 52
  6. Submitted by: genrad!decvax!philabs!nyit!rick
  7.  
  8. ---CUT HERE---CUT HERE---CUT HERE---CUT HERE---CUT HERE--CUT HERE--
  9. echo shar: extracting README
  10. cat - << \SHAR_EOF > README
  11. NYIT rlogin performance enhancements            01-Apr-86
  12.  
  13. INTRODUCTION
  14. This package contains a set of source code modifications to
  15. 4.2bsd UNIX to enhance the performance of rlogin connections.
  16. Performance improvement results from reducing the involvement
  17. of the agent processes (rlogin and rlogind) in the task of
  18. passing characters between the client and server hosts.
  19. In this implementation, the agent processes retain their
  20. previous function of establishing an rlogin-style connection
  21. between two hosts; however, once the connection is established,
  22. the agents sleep until the connection is interrrupted by an
  23. escape character on the client host, or terminated by either host.
  24. The character-switching functions formerly performed by rlogin
  25. and rlogind are now handled entirely within kernel interrupt
  26. logic, eliminating the delays and scheduling overhead of the
  27. original implementation and improving response and throughput.
  28.  
  29. It is important to note that, although the character traffic
  30. is now being handled exclusively in the kernel, the rlogin
  31. protocol has been maintained.  This ensures that an enhanced
  32. client can interoperate with a vanilla 4.2bsd server, and
  33. vice versa, still gaining an improvement in performance.
  34.  
  35. The implementation is separated into two logical parts:  client
  36. and server.  The client part is called the NVT, an acronym for
  37. Network Virtual Terminal; the server is called the NVS, meaning
  38. Network Virtual Server.  Within the kernel, NVT logic appears
  39. within a "#ifdef KNVT" conditional, and NVS logic appears
  40. within a "#ifdef KNVS" conditional.  All user-mode NVT logic
  41. resides in /usr/ucb/rlogin.  All user-mode NVS logic resides
  42. in /etc/rlogind.
  43.  
  44. AFFECTED SOFTWARE
  45. The following executables are affected:
  46.  
  47.     1.  The 4.2bsd kernel
  48.     2.  /usr/ucb/rlogin
  49.     3.  /etc/rlogind
  50.  
  51. The vanilla and enhanced versions of any of these programs can be
  52. used in any combination with no risk.  The NVT and NVS logic
  53. in the kernel remains dormant unless invoked by an enhanced
  54. rlogin or rlogind; the enhanced kernel support the vanilla
  55. rlogin/rlogind as well as their new counterparts.  The enhanced
  56. rlogin and rlogind determine if the kernel offers the enhanced
  57. NVT or NVS service, and, if not, they will operate in vanilla
  58. 4.2bsd rlogin mode.
  59.  
  60. BUGS
  61. The user interface of rlogin is slightly different with regard
  62. to the operation of the escape character.  This is not an
  63. unavoidable consequence of this implementation, but rather an
  64. issue of expediency made during development; it can be fixed.
  65.  
  66. The implementation within the kernel is practical, but not
  67. elegant.  I grovel in advance for the indulgence of the purists.
  68. [Remember:  you didn't *pay money* to buy this :-)]
  69.  
  70. No explicit aid is offered for telnet connections; however,
  71. inspection of this implementation might inspire those who
  72. use telnet to improve its performance in a similar fashion.
  73.  
  74.  
  75. CONTENTS OF THIS DISTRIBUTION
  76.   [Explanations of changes appear in brackets]
  77.  
  78.   README        This file
  79.   diff_files        diff -c of kernel conf/files
  80.             [add two new kernel source files: tty_nv[st].c]
  81.   diff_ioctl.h        diff -c of kernel h/ioctl.h
  82.             [add ioctl defs SIOCJNVS and SIOCJNVT]
  83.   diff_rlogin.c        diff -c of source for /usr/ucb/rlogin
  84.             [invoke SIOCJNVT ioctl to join socket and tty]
  85.   diff_rlogind.c    diff -c of source for /etc/rlogind
  86.             [invoke SIOCJNVS ioctl to join socket and pty]
  87.   diff_socketvar.h    diff -c of kernel h/socketvar.h
  88.             [add defs SB_NVS and SB_NVT]
  89.   diff_tcp_usrreq.c    diff -c of kernel netinet/tcp_usrreq.c
  90.             [add code to handle SIOCJNVS and SIOCJNVT ioctls]
  91.   diff_tty.c        diff -c of kernel sys/tty.c
  92.             [add hook in ttyinput() to intercept NVT characters]
  93.   diff_tty.h        diff -c of kernel h/tty.h
  94.             [add def TS_NVT]
  95.   diff_tty_pty.c    diff -c of kernel sys/tty_pty.c
  96.             [add subroutines driven off pty data structures]
  97.   diff_tty_subr.c    diff -c of kernel sys/tty_subr.c
  98.             [remove #ifdef notdef surrounding q_to_b]
  99.   diff_uipc_socket2.c    diff -c of kernel sys/uipc_socket2.c
  100.             [add hooks in sbwakeup() to intercept NVS/NVT traffic]
  101.   tty_nvs.c        New kernel source file sys/tty_nvs.c
  102.             [most of the logic to implement NVS service]
  103.   tty_nvt.c        New kernel source file sys/tty_nvt.c
  104.             [most of the logic to implement NVT service]
  105.  
  106. INSTALLATION
  107.     1.  Copy tty_nvs.c and tty_nvt.c into /sys/sys.
  108.     2.  Locate files whose names begin with "diff_".  These files
  109.     represent Berkeley 4.2bsd source modules that must be modified.
  110.     Apply the changes in each "diff_" file to their respective
  111.     4.2bsd source modules.
  112.     3.  cd to /sys/conf and add the following two lines to your
  113.     kernel configuration file:
  114.         options        NKVS
  115.         options        KNVT
  116.     4.  Run /etc/config to regenerate the kernel configuration files.
  117.     5.  cd to the kernel directory and run "make" to build a new kernel.
  118.     6.  Install the new kernel in /.
  119.     7.  Recompile and install /usr/ucb/rlogin (must be setuid-root).
  120.     8.  Recompile and install /etc/rlogind.
  121.     9.  Reboot and enjoy more responsive rlogin connections.
  122.  
  123.  
  124. Please address comments, questions, bugfixes (please, no flames
  125. about hooks in ttyinput() or sbwakeup()) to the author:
  126.  
  127. Rick Ace
  128. New York Institute of Technology
  129. Computer Graphics Laboratory
  130. Wheatley Road
  131. Old Westbury, NY  11568
  132.  
  133. (516) 686-7644
  134.  
  135. USENET:    {decvax,seismo}!philabs!nyit!rick
  136. SHAR_EOF
  137. echo shar: extracting diff_files
  138. cat - << \SHAR_EOF > diff_files
  139. *** conf/files420    Sun Jun 12 18:45:11 1983
  140. --- conf/files    Tue Apr  1 07:20:48 1986
  141. ***************
  142. *** 102,104
  143.   sys/vm_swap.c        standard
  144.   sys/vm_swp.c        standard
  145.   sys/vm_text.c        standard
  146.  
  147. --- 102,106 -----
  148.   sys/vm_swap.c        standard
  149.   sys/vm_swp.c        standard
  150.   sys/vm_text.c        standard
  151. + sys/tty_nvs.c        standard
  152. + sys/tty_nvt.c        standard
  153. SHAR_EOF
  154. echo shar: extracting diff_ioctl.h
  155. cat - << \SHAR_EOF > diff_ioctl.h
  156. *** h/ioctl.h420    Sat Aug 20 19:04:34 1983
  157. --- h/ioctl.h    Tue Apr  1 07:27:50 1986
  158. ***************
  159. *** 194,199
  160.   #define    SIOCATMARK    _IOR(s,  7, int)        /* at oob mark? */
  161.   #define    SIOCSPGRP    _IOW(s,  8, int)        /* set process group */
  162.   #define    SIOCGPGRP    _IOR(s,  9, int)        /* get process group */
  163.   
  164.   #define    SIOCADDRT    _IOW(r, 10, struct rtentry)    /* add route */
  165.   #define    SIOCDELRT    _IOW(r, 11, struct rtentry)    /* delete route */
  166.  
  167. --- 194,201 -----
  168.   #define    SIOCATMARK    _IOR(s,  7, int)        /* at oob mark? */
  169.   #define    SIOCSPGRP    _IOW(s,  8, int)        /* set process group */
  170.   #define    SIOCGPGRP    _IOR(s,  9, int)        /* get process group */
  171. + #define SIOCJNVT    _IOW(s, 70, int)        /* join NVT tty&socket */
  172. + #define SIOCJNVS    _IOW(s, 71, int)        /* join NVS pty&socket */
  173.   
  174.   #define    SIOCADDRT    _IOW(r, 10, struct rtentry)    /* add route */
  175.   #define    SIOCDELRT    _IOW(r, 11, struct rtentry)    /* delete route */
  176. SHAR_EOF
  177. echo shar: extracting diff_rlogin.c
  178. cat - << \SHAR_EOF > diff_rlogin.c
  179. *** 4.2rlogin.c    Tue Apr  1 12:12:32 1986
  180. --- rlogin.c    Tue Apr  1 11:17:44 1986
  181. ***************
  182. *** 144,149
  183.       signal(SIGINT, exit);
  184.       signal(SIGHUP, exit);
  185.       signal(SIGQUIT, exit);
  186.       child = fork();
  187.       if (child == -1) {
  188.           perror("rlogin: fork");
  189.  
  190. --- 144,150 -----
  191.       signal(SIGINT, exit);
  192.       signal(SIGHUP, exit);
  193.       signal(SIGQUIT, exit);
  194. +     knvt();                /* returns iff no kernel NVT service */
  195.       child = fork();
  196.       if (child == -1) {
  197.           perror("rlogin: fork");
  198. ***************
  199. *** 376,380
  200.   {
  201.       signal(SIGPIPE, SIG_IGN);
  202.       prf("\007Connection closed.");
  203.       done();
  204.   }
  205.  
  206. --- 377,429 -----
  207.   {
  208.       signal(SIGPIPE, SIG_IGN);
  209.       prf("\007Connection closed.");
  210. +     done();
  211. + }
  212. + 
  213. + nvtsig()
  214. + {
  215. +     signal(SIGINT, nvtsig);
  216. + }
  217. + 
  218. + /*
  219. +  * Invoke kernel NVT service
  220. +  *
  221. +  * Returns iff kernel does not support NVT service (i.e., do the
  222. +  * job the old-fashioned way) 
  223. +  */
  224. + knvt()
  225. + {
  226. +     char cmdc;
  227. +     static int ttyfd = 0;
  228. + 
  229. +     signal(SIGINT, nvtsig);
  230. +     notc.t_intrc = cmdchar;
  231. +     mode(1);
  232. +     while (ioctl(rem, SIOCJNVT, &ttyfd) < 0) {
  233. +         if (errno != EINTR) {
  234. +             /*
  235. +              * Unexpected error, assume the kernel does not
  236. +              * honor the ioctl call and return to doit().
  237. +              */
  238. +             notc.t_intrc = -1;
  239. +             return;
  240. +         }
  241. +         /*
  242. +          * The user typed the escape character.  Read the next
  243. +          * character from the terminal to see what I should do.
  244. +          */
  245. +         if (read(0, &cmdc, 1) != 1) 
  246. +             cmdc = deftc.t_eofc;
  247. +         if (cmdc == '.' || cmdc == deftc.t_eofc) 
  248. +             break;
  249. +         if (cmdc == defltc.t_suspc ||
  250. +             cmdc == defltc.t_dsuspc) {
  251. +             write(0, CRLF, sizeof(CRLF));
  252. +             mode(0);
  253. +             kill(getpid(), SIGTSTP);
  254. +             mode(1);
  255. +         }
  256. +     }
  257. +     prf("\r\nConnection closed");
  258.       done();
  259.   }
  260. SHAR_EOF
  261. echo shar: extracting diff_rlogind.c
  262. cat - << \SHAR_EOF > diff_rlogind.c
  263. *** 4.2rlogind.c    Tue Apr  1 12:12:50 1986
  264. --- rlogind.c    Tue Apr  1 09:32:50 1986
  265. ***************
  266. *** 200,205
  267.           ioctl(p, TIOCPKT, &on);
  268.           signal(SIGTSTP, SIG_IGN);
  269.           signal(SIGCHLD, cleanup);
  270.           for (;;) {
  271.               int ibits = 0, obits = 0;
  272.   
  273.  
  274. --- 200,219 -----
  275.           ioctl(p, TIOCPKT, &on);
  276.           signal(SIGTSTP, SIG_IGN);
  277.           signal(SIGCHLD, cleanup);
  278. +         /* BEGIN NVS support */
  279. +         /*
  280. +          * If kernel supports high-performance NVS operation,
  281. +          * invoke it and sleep until connection is broken.
  282. +          * If remote end dies: ioctl() returns 0.
  283. +          * If local job exits: ioctl() returns -1 / EINTR.
  284. +          * Any other return from ioctl() is interpreted to mean
  285. +          * the kernel doesn't support high-performance NVS
  286. +          * operation, so do the job the standard Berkeley way.
  287. +          */
  288. +         if (ioctl(f, SIOCJNVS, (char *)&p) == 0 ||
  289. +             errno == EINTR)
  290. +             cleanup();
  291. +         /* END NVS support */
  292.           for (;;) {
  293.               int ibits = 0, obits = 0;
  294.   
  295. ***************
  296. *** 292,297
  297.   
  298.       rmut();
  299.       vhangup();        /* XXX */
  300.       shutdown(netf, 2);
  301.       kill(0, SIGKILL);
  302.       exit(1);
  303.  
  304. --- 306,313 -----
  305.   
  306.       rmut();
  307.       vhangup();        /* XXX */
  308. + #ifdef notdef
  309. +     /* NYIT remove bogus statement (netf is never set!) */
  310.       shutdown(netf, 2);
  311.   #endif
  312.       kill(0, SIGKILL);
  313. ***************
  314. *** 293,298
  315.       rmut();
  316.       vhangup();        /* XXX */
  317.       shutdown(netf, 2);
  318.       kill(0, SIGKILL);
  319.       exit(1);
  320.   }
  321.  
  322. --- 309,315 -----
  323.   #ifdef notdef
  324.       /* NYIT remove bogus statement (netf is never set!) */
  325.       shutdown(netf, 2);
  326. + #endif
  327.       kill(0, SIGKILL);
  328.       exit(1);
  329.   }
  330. SHAR_EOF
  331. echo shar: extracting diff_socketvar.h
  332. cat - << \SHAR_EOF > diff_socketvar.h
  333. *** h/socketvar.h420    Fri Jul 29 09:49:20 1983
  334. --- h/socketvar.h    Tue Apr  1 07:24:02 1986
  335. ***************
  336. *** 49,54
  337.   #define    SB_WAIT        0x04        /* someone is waiting for data/space */
  338.   #define    SB_SEL        0x08        /* buffer is selected */
  339.   #define    SB_COLL        0x10        /* collision selecting */
  340.       short    so_timeo;        /* connection timeout */
  341.       u_short    so_error;        /* error affecting connection */
  342.       short    so_oobmark;        /* chars to oob mark */
  343.  
  344. --- 49,56 -----
  345.   #define    SB_WAIT        0x04        /* someone is waiting for data/space */
  346.   #define    SB_SEL        0x08        /* buffer is selected */
  347.   #define    SB_COLL        0x10        /* collision selecting */
  348. + #define SB_NVT        0x20        /* socket crossbared to NVT tty */
  349. + #define SB_NVS        0x40        /* socket crossbared to NVS tty/pty */
  350.       short    so_timeo;        /* connection timeout */
  351.       u_short    so_error;        /* error affecting connection */
  352.       short    so_oobmark;        /* chars to oob mark */
  353. SHAR_EOF
  354. echo shar: extracting diff_tcp_usrreq.c
  355. cat - << \SHAR_EOF > diff_tcp_usrreq.c
  356. *** netinet/tcp_usrreq.c420    Fri Jul 29 10:14:49 1983
  357. --- netinet/tcp_usrreq.c    Tue Apr  1 07:32:53 1986
  358. ***************
  359. *** 24,29
  360.   #include "../netinet/tcpip.h"
  361.   #include "../netinet/tcp_debug.h"
  362.   
  363.   /*
  364.    * TCP protocol interface to socket abstraction.
  365.    */
  366.  
  367. --- 24,33 -----
  368.   #include "../netinet/tcpip.h"
  369.   #include "../netinet/tcp_debug.h"
  370.   
  371. + #if defined(KNVS) || defined(KNVT)
  372. + #include "../h/ioctl.h"
  373. + #endif
  374. + 
  375.   /*
  376.    * TCP protocol interface to socket abstraction.
  377.    */
  378. ***************
  379. *** 233,238
  380.   
  381.   /* SOME AS YET UNIMPLEMENTED HOOKS */
  382.       case PRU_CONTROL:
  383.           error = EOPNOTSUPP;
  384.           break;
  385.   
  386.  
  387. --- 237,260 -----
  388.   
  389.   /* SOME AS YET UNIMPLEMENTED HOOKS */
  390.       case PRU_CONTROL:
  391. + #ifdef KNVS
  392. +         if ((int)m == SIOCJNVS) {
  393. +             if (tp->t_state == TCPS_ESTABLISHED)
  394. +                 error = nvs_ioc_join(so, *(int *)nam);
  395. +             else
  396. +                 error = ENOTCONN;
  397. +             break;
  398. +         }
  399. + #endif
  400. + #ifdef KNVT
  401. +         if ((int)m == SIOCJNVT) {
  402. +             if (tp->t_state == TCPS_ESTABLISHED)
  403. +                 error = nvt_ioc_join(so, *(int *)nam);
  404. +             else
  405. +                 error = ENOTCONN;
  406. +             break;
  407. +         }
  408. + #endif
  409.           error = EOPNOTSUPP;
  410.           break;
  411.   
  412. SHAR_EOF
  413. echo shar: extracting diff_tty.c
  414. cat - << \SHAR_EOF > diff_tty.c
  415. *** sys/tty.c420    Sun Oct  2 02:06:25 1983
  416. --- sys/tty.c    Tue Apr  1 08:04:59 1986
  417. ***************
  418. *** 826,831
  419.       }
  420.   
  421.   endcase:
  422.       /*
  423.        * If DEC-style start/stop is enabled don't restart
  424.        * output until seeing the start character.
  425.  
  426. --- 826,838 -----
  427.       }
  428.   
  429.   endcase:
  430. + #ifdef KNVT
  431. +     /*
  432. +      * If this tty is operating as an NVT, pass character to remote host
  433. +      */
  434. +     if (tp->t_state & TS_NVT)
  435. +         nvt_output(tp);
  436. + #endif KNVT
  437.       /*
  438.        * If DEC-style start/stop is enabled don't restart
  439.        * output until seeing the start character.
  440. SHAR_EOF
  441. echo shar: extracting diff_tty.h
  442. cat - << \SHAR_EOF > diff_tty.h
  443. *** h/tty.h420    Thu Aug  4 23:58:20 1983
  444. --- h/tty.h    Tue Apr  1 08:02:28 1986
  445. ***************
  446. *** 117,122
  447.   #define    TS_LNCH        0x080000    /* next character is literal */
  448.   #define    TS_TYPEN    0x100000    /* retyping suspended input (PENDIN) */
  449.   #define    TS_CNTTB    0x200000    /* counting tab width; leave FLUSHO alone */
  450.   
  451.   #define    TS_LOCAL    (TS_BKSL|TS_QUOT|TS_ERASE|TS_LNCH|TS_TYPEN|TS_CNTTB)
  452.   
  453.  
  454. --- 117,123 -----
  455.   #define    TS_LNCH        0x080000    /* next character is literal */
  456.   #define    TS_TYPEN    0x100000    /* retyping suspended input (PENDIN) */
  457.   #define    TS_CNTTB    0x200000    /* counting tab width; leave FLUSHO alone */
  458. + #define TS_NVT        0x400000    /* NVT tty is bound to a socket */
  459.   
  460.   #define    TS_LOCAL    (TS_BKSL|TS_QUOT|TS_ERASE|TS_LNCH|TS_TYPEN|TS_CNTTB)
  461.   
  462. SHAR_EOF
  463. echo shar: extracting diff_tty_pty.c
  464. cat - << \SHAR_EOF > diff_tty_pty.c
  465. *** sys/tty_pty.c420    Sun Oct  2 02:06:25 1983
  466. --- sys/tty_pty.c    Tue Apr  1 07:55:36 1986
  467. ***************
  468. *** 24,29
  469.   #define    NPTY    32        /* crude XXX */
  470.   #endif
  471.   
  472.   #define BUFSIZ 100        /* Chunk size iomoved from user */
  473.   
  474.   /*
  475.  
  476. --- 24,34 -----
  477.   #define    NPTY    32        /* crude XXX */
  478.   #endif
  479.   
  480. + #ifdef KNVS
  481. + #include "../h/socketvar.h"
  482. + struct socket    *ptynvsso[NPTY];    /* socket indexed by pty minor dev# */
  483. + #endif
  484. + 
  485.   #define BUFSIZ 100        /* Chunk size iomoved from user */
  486.   
  487.   /*
  488. ***************
  489. *** 78,83
  490.       tp = &pt_tty[minor(dev)];
  491.       (*linesw[tp->t_line].l_close)(tp);
  492.       ttyclose(tp);
  493.   }
  494.   
  495.   ptsread(dev, uio)
  496.  
  497. --- 83,89 -----
  498.       tp = &pt_tty[minor(dev)];
  499.       (*linesw[tp->t_line].l_close)(tp);
  500.       ttyclose(tp);
  501. +     ptcwakeup(tp);                /* wake master */
  502.   }
  503.   
  504.   ptsread(dev, uio)
  505. ***************
  506. *** 439,445
  507.                 tp->t_startc == ('q'&037));
  508.       if (pti->pt_flags & PF_NOSTOP) {
  509.           if (stop) {
  510. !             pti->pt_send &= TIOCPKT_NOSTOP;
  511.               pti->pt_send |= TIOCPKT_DOSTOP;
  512.               pti->pt_flags &= ~PF_NOSTOP;
  513.               ptcwakeup(tp);
  514.  
  515. --- 445,451 -----
  516.                 tp->t_startc == ('q'&037));
  517.       if (pti->pt_flags & PF_NOSTOP) {
  518.           if (stop) {
  519. !             pti->pt_send &= ~TIOCPKT_NOSTOP;
  520.               pti->pt_send |= TIOCPKT_DOSTOP;
  521.               pti->pt_flags &= ~PF_NOSTOP;
  522.               ptcwakeup(tp);
  523. ***************
  524. *** 455,458
  525.       }
  526.       return (error);
  527.   }
  528.   #endif
  529.  
  530. --- 461,511 -----
  531.       }
  532.       return (error);
  533.   }
  534. + 
  535. + #ifdef KNVS
  536. + 
  537. + /*
  538. +  * Transfer characters from NVS tty outq to associated socket
  539. +  * (Simply a jacket because timeout() accepts only 1 argument).
  540. +  *
  541. +  * Called at or below network IPL
  542. +  */
  543. + ptsnvsnet(tp)
  544. +     struct tty *tp;
  545. + {
  546. +     nvs_output(tp, &pt_ioctl[minor(tp->t_dev)].pt_send);
  547. + }
  548. + 
  549. + /*
  550. +  * Alternate t_oproc routine used when the pty is operating as an NVS
  551. +  */
  552. + ptsnvsstart(tp)
  553. +     register struct tty *tp;
  554. + {
  555. +     register int s;
  556. + 
  557. +     s = spl5();
  558. +     /*
  559. +      * TS_BUSY set means Ptsnvsnet() is either running or queued to run
  560. +      */
  561. +     if ((tp->t_state & TS_BUSY) == 0) {
  562. +         tp->t_state |= TS_BUSY;
  563. + #ifdef vax
  564. +         /*
  565. +          * If at low IPL, can make output happen now;
  566. +          * otherwise must sequence it through softclock
  567. +          */
  568. +         if (s == 0) {
  569. +             (void) spl0();        /* reduce IPL */
  570. +             nvs_output(tp, &pt_ioctl[minor(tp->t_dev)].pt_send);
  571. +         }
  572. +         else
  573. + #endif vax
  574. +             timeout(ptsnvsnet, (caddr_t)tp, 0);
  575. +     }
  576. +     splx(s);
  577. + }
  578. + 
  579. + #endif KNVS
  580. + 
  581.   #endif
  582. SHAR_EOF
  583. echo shar: extracting diff_tty_subr.c
  584. cat - << \SHAR_EOF > diff_tty_subr.c
  585. *** sys/tty_subr.c420    Fri Jul 29 10:07:23 1983
  586. --- sys/tty_subr.c    Tue Apr  1 09:04:49 1986
  587. ***************
  588. *** 54,60
  589.       return(c);
  590.   }
  591.   
  592. - #ifdef notdef
  593.   /*
  594.    * copy clist to buffer.
  595.    * return number of bytes moved.
  596.  
  597. --- 54,59 -----
  598.       return(c);
  599.   }
  600.   
  601.   /*
  602.    * copy clist to buffer.
  603.    * return number of bytes moved.
  604. ***************
  605. *** 110,116
  606.       splx(s);
  607.       return(cp-acp);
  608.   }
  609. - #endif
  610.   
  611.   /*
  612.    * Return count of contiguous characters
  613.  
  614. --- 109,114 -----
  615.       splx(s);
  616.       return(cp-acp);
  617.   }
  618.   
  619.   /*
  620.    * Return count of contiguous characters
  621. SHAR_EOF
  622. echo shar: extracting diff_uipc_socket2.c
  623. cat - << \SHAR_EOF > diff_uipc_socket2.c
  624. *** sys/uipc_socket2.c420    Fri Jul 29 10:07:27 1983
  625. --- sys/uipc_socket2.c    Tue Apr  1 07:59:50 1986
  626. ***************
  627. *** 243,248
  628.       register struct sockbuf *sb;
  629.   {
  630.   
  631.       if (sb->sb_sel) {
  632.           selwakeup(sb->sb_sel, sb->sb_flags & SB_COLL);
  633.           sb->sb_sel = 0;
  634.  
  635. --- 243,260 -----
  636.       register struct sockbuf *sb;
  637.   {
  638.   
  639. + #ifdef KNVS
  640. +     if (sb->sb_flags & SB_NVS) {
  641. +         nvs_input(sb);
  642. +         return;
  643. +     }
  644. + #endif KNVS
  645. + #ifdef KNVT
  646. +     if (sb->sb_flags & SB_NVT) {
  647. +         nvt_input(sb);
  648. +         return;
  649. +     }
  650. + #endif KNVT
  651.       if (sb->sb_sel) {
  652.           selwakeup(sb->sb_sel, sb->sb_flags & SB_COLL);
  653.           sb->sb_sel = 0;
  654. SHAR_EOF
  655. echo shar: extracting tty_nvs.c
  656. cat - << \SHAR_EOF > tty_nvs.c
  657. /*
  658.  * Network virtual terminals via sockets - server end
  659.  *
  660.  *    Rick Ace
  661.  *    New York Institute of Technology
  662.  *    Computer Graphics Laboratory
  663.  *    Old Westbury, New York  11568
  664.  */
  665.  
  666. /*
  667.  * The code in this module supports the NVS, or remote end of the connection
  668.  * (i.e., the link between the network and the pseudo-terminal).
  669.  * The purpose of this code is to emulate efficiently the character-
  670.  * shuffling functions performed by /etc/rlogind.  The rlogin on the other
  671.  * host will believe it is talking to rlogind, when it is in reality
  672.  * talking to the NVS kernel software herein.
  673.  *
  674.  * The NVS kernel software achieves performance improvements by handling
  675.  * incoming character traffic at interrupt level, eliminating the overhead
  676.  * and delays resulting from scheduling a user-mode process (rlogind).
  677.  * Outgoing character traffic is dumped directly into the socket by
  678.  * Ptsnvsstart() in tty_pty.c, further eliminating the need for service
  679.  * by a user-mode process.
  680.  *
  681.  * The implementation is broken into two main layers:
  682.  *    1)  high-level software, common to all NVSs (nvs_XXX subrs) 
  683.  *    2)  protocol-specific stuff (tcp_XXX, etc.) 
  684.  * Presently, there is only a TCP implementation for layer # 2.
  685.  */
  686.  
  687. #ifdef KNVS
  688.  
  689. #include "../h/param.h"
  690. #include "../h/conf.h"
  691. #include "../h/dir.h"
  692. #include "../h/user.h"
  693. #include "../h/proc.h"        /* for lint */
  694. #include "../h/file.h"
  695. #include "../h/tty.h"
  696. #include "../h/mbuf.h"
  697. #include "../h/protosw.h"
  698. #include "../h/socketvar.h"
  699. #ifdef NFS
  700. #include "../h/vnode.h"
  701. #include "../ufs/inode.h"
  702. #else NFS
  703. #include "../h/inode.h"
  704. #endif NFS
  705.  
  706. #define nvs_emsg    nvt_emsg
  707.  
  708. #define MAXNVS    16        /* should be in a parameter file */
  709.  
  710. /*
  711.  * tp-to-socket correspondence table.
  712.  *
  713.  * This table is searched linearly.  A highest-entry mark is maintained
  714.  * to keep search overhead low.  If there is a need to support large
  715.  * numbers of NVSs, the linear search should be replaced by hashing.
  716.  */
  717. struct nvsj {
  718.     struct tty    *nvs_tp;    /* tty/pty context, or 0 if free */
  719.     struct socket    *nvs_so;    /* socket context */
  720. } nvsj[MAXNVS + 1];
  721.  
  722. struct nvsj    *nvshij = &nvsj[0];    /* highest active entry */
  723.  
  724. #ifndef lint
  725. int    nvsj_n = MAXNVS;        /* for kernel debug utilities */
  726. #endif
  727.  
  728. int    nvsichz;
  729.  
  730. extern struct socket *ptynvsso[ /* NPTY */ ]; /* socket indexed by pty minor */
  731.  
  732. int    ptsstart(), ptsnvsstart(), ptsnvsnet();
  733.  
  734. /*
  735.  * Mate a tty and a socket
  736.  *
  737.  * Returns UNIX error code
  738.  * Must be called at splimp
  739.  */
  740. nvs_add(tp, so, anvs)
  741.     struct tty *tp;
  742.     struct socket *so;
  743.     struct nvsj **anvs;    /* return addr of NVS context here */
  744. {
  745.     register struct nvsj *nvs, *nx;
  746.     extern int hz;                /* XXX */
  747.  
  748.     if (nvsichz == 0) 
  749.         nvsichz = hz / 3;        /* XXX */
  750.     if (tp->t_oproc != ptsstart) 
  751.         return ENOTTY;        /* not a pty or not in right mode */
  752.     nvs = 0;
  753.     nx = &nvsj[MAXNVS - 1];
  754.     do {
  755.         if (nx->nvs_tp) {
  756.             if (nx->nvs_tp == tp || nx->nvs_so == so) 
  757.                 return EBUSY; /* tty or socket already an NVS */
  758.         }
  759.         else
  760.             nvs = nx;    /* remember lowest empty slot */
  761.     } while (--nx >= &nvsj[0]);
  762.     if (nvs == 0) 
  763.         return ENFILE;        /* all slots are in use */
  764.     /*
  765.      * All is clear, mate them
  766.      */
  767.     if (nvs > nvshij) 
  768.         nvshij = nvs;        /* update highest active entry */
  769.     *anvs = nvs;            /* pass context pointer to caller */
  770.     nvs->nvs_so = so;
  771.     nvs->nvs_tp = tp;
  772.     so->so_rcv.sb_flags |= SB_NVS;
  773.     tp->t_oproc = ptsnvsstart;
  774.     ptynvsso[minor(tp->t_dev)] = so;
  775.     sbwakeup(&so->so_rcv);        /* get characters flowing */
  776.     ptsnvsstart(tp);        /* ditto */
  777.     return 0;
  778. }
  779.  
  780. /*
  781.  * Undo a tty/socket correspondence
  782.  *
  783.  * Must be called at splimp
  784.  */
  785. nvs_del(nvs)
  786.     register struct nvsj *nvs;
  787. {
  788.     register struct tty *tp;
  789.  
  790.     nvs->nvs_so->so_rcv.sb_flags &= ~SB_NVS;
  791.     tp = nvs->nvs_tp;
  792.     if (tp->t_oproc == ptsnvsstart) 
  793.         tp->t_oproc = ptsstart;
  794.     ptynvsso[minor(tp->t_dev)] = 0;
  795.     /*
  796.      * Delete this entry and adjust Nvshij if necessary
  797.      */
  798.     nvs->nvs_tp = 0;        /* mark entry as free */
  799.     if (nvshij == nvs) 
  800.         while (nvshij > &nvsj[0] && nvshij->nvs_tp == 0) 
  801.             nvshij--;
  802. }
  803.  
  804. /*
  805.  * Called from sbwakeup() when NVS has incoming characters from the net,
  806.  * to transfer those characters from the socket to the tty's input queue
  807.  *
  808.  * Logic here is similar to that of soreceive() in uipc_socket.c
  809.  */
  810. nvs_input(sb)
  811.     struct sockbuf *sb;        /* so_rcv */
  812. {
  813. #define STRUCT_OFF(strnam, elem) \
  814.     ((char *)&((struct strnam *)0)->elem - (char *)0) 
  815.     register struct socket *so;
  816.     register struct nvsj *nvs;
  817.     register struct tty *tp;
  818.     register struct mbuf *m;
  819.     register unsigned char *cp;
  820.     register int n;
  821.     struct mbuf *mz;
  822.  
  823.     /*
  824.      * Convert so_rcv address to socket address (a bit gross),
  825.      * then search the active-connection table for that socket
  826.      */
  827.     so = (struct socket *)((char *)sb - STRUCT_OFF(socket, so_rcv));
  828.     nvs = &nvsj[0];
  829.     while (nvs->nvs_so != so || (tp = nvs->nvs_tp) == 0) {
  830.         if (++nvs > nvshij) {
  831.             nvs_emsg("nvs input no so %x\n", so);
  832.             return;
  833.         }
  834.     }
  835.     /*
  836.      * Have located the tty, now pass it the data
  837.      */
  838.     so->so_state &= ~SS_RCVATMARK;        /* ignore out-of-band data */
  839.     so->so_oobmark = 0;            /* ditto */
  840.     /*
  841.      * Process each mbuf on the socket's rcv queue
  842.      */
  843.     while (so->so_rcv.sb_cc > 0) {
  844.         m = so->so_rcv.sb_mb;
  845.         if (m == 0) 
  846.             panic("nvs_input");
  847.         cp = mtod(m, unsigned char *);
  848.         for (n = m->m_len; --n >= 0; ) 
  849.             (*linesw[tp->t_line].l_rint)(*cp++, tp);
  850.         sbfree(&so->so_rcv, m);
  851.         MFREE(m, mz);
  852.         so->so_rcv.sb_mb = m = mz;
  853.     }
  854.     /*
  855.      * Notify protocol that more space is available in the socket
  856.      */
  857.     if ((so->so_state & SS_CANTRCVMORE) == 0 &&
  858.         so->so_proto->pr_flags & PR_WANTRCVD &&
  859.         so->so_pcb) 
  860.         (*so->so_proto->pr_usrreq)(so, PRU_RCVD,
  861.             (struct mbuf *)0, (struct mbuf *)0, (struct mbuf *)0);
  862.     /*
  863.      * If socket closes at remote end first (not the most common case),
  864.      * wake up the agent process so it can exit.
  865.      */
  866.     if (so->so_state & (SS_CANTRCVMORE | SS_CANTSENDMORE)) {
  867.         so->so_rcv.sb_flags &= ~SB_NVS;
  868.         wakeup((caddr_t)nvs);
  869.     }
  870. }
  871.  
  872. /*
  873.  * Handle ioctl request on socket to join socket and pty, called
  874.  * from protocol ioctl logic.  Protocol-specific validation is
  875.  * done before you get here.
  876.  *
  877.  * If the connection was successfully established, sleep and wait
  878.  * until it is broken at the remote end, or until a signal is
  879.  * received on the local end.
  880.  *
  881.  * Returns
  882.  *    0 = remote NVT closed the connection
  883.  *    EINTR = interrupted by signal
  884.  *    Anything else = an error establishing the connection
  885.  */
  886. nvs_ioc_join(so, ptyfd)
  887.     register struct socket *so;
  888.     int ptyfd;        /* pty file descriptor */
  889. {
  890.     register struct file *fp;
  891.     register struct inode *ip;
  892.     register struct tty *tp;
  893.     int error, s;
  894.     struct nvsj *nvsp;
  895.     int ptcopen();
  896.  
  897.     /*
  898.      * Validate file descriptor and ensure it references a pty
  899.      */
  900.     if ((unsigned)ptyfd >= NOFILE || (fp = u.u_ofile[ptyfd]) == 0) 
  901.         return EBADF;
  902. #ifdef NFS
  903.     {
  904.         register struct vnode *vp;
  905.  
  906.         vp = (struct vnode *)fp->f_data;
  907.         if (fp->f_type != DTYPE_VNODE || vp->v_op != &ufs_vnodeops) 
  908.             return ENOTTY;
  909.         ip = VTOI(vp);
  910.         if ((ip->i_mode & IFMT) != IFCHR ||
  911.             cdevsw[major(ip->i_rdev)].d_open != ptcopen) 
  912.             return ENOTTY;        /* really ENOTPTY :-) */
  913.     }
  914. #else NFS
  915.     ip = (struct inode *)fp->f_data;
  916.     if (fp->f_type != DTYPE_INODE ||
  917.         (ip->i_mode & IFMT) != IFCHR ||
  918.         cdevsw[major(ip->i_rdev)].d_open != ptcopen) 
  919.         return ENOTTY;        /* really ENOTPTY :-) */
  920. #endif NFS
  921.     /*
  922.      * Argument socket and pty are valid, now join them and wait
  923.      */
  924.     tp = cdevsw[major(ip->i_rdev)].d_ttys;
  925.     s = splimp();
  926.     if (error = nvs_add(tp + minor(ip->i_rdev), so, &nvsp)) {
  927.         splx(s);
  928.         return error;
  929.     }
  930.     if (setjmp(&u.u_qsave)) {
  931.         /*
  932.          * The process received a signal
  933.          */
  934.         nvs_del(nvsp);        /* disassociate pty&socket */
  935.         splx(s);
  936.         return EINTR;
  937.     }
  938.     do sleep((caddr_t)nvsp, PZERO + 1); /* wait for signal or disconnect */
  939.      while (nvsp->nvs_so->so_rcv.sb_flags & SB_NVS);
  940.     /*
  941.      * The remote disconnected.
  942.      */
  943.     nvs_del(nvsp);            /* disassociate pty&socket */
  944.     splx(s);
  945.     return 0;
  946. }
  947.  
  948. /*
  949.  * Move characters from pty outq to network
  950.  * TS_BUSY is assumed to be set upon entry
  951.  *
  952.  * Must be called at or below net IPL
  953.  */
  954. /*ARGSUSED*/
  955. nvs_output(tp, urgentp)
  956.     register struct tty *tp;
  957.     int *urgentp;        /* call by reference because I can zero it */
  958. {
  959.     register struct mbuf *m;
  960.     register struct socket *so;
  961.     register int error, s, space;
  962.  
  963.     s = splnet();
  964.     if ((so = ptynvsso[minor(tp->t_dev)]) == 0) {    /* paranoid */
  965.         /*
  966.          * no longer an NVS!
  967.          */
  968.         tp->t_state &= ~TS_BUSY;
  969.         if (tp->t_oproc) 
  970.             (*tp->t_oproc)(tp);
  971.         goto rspl;
  972.     }
  973.     if (so->so_state & SS_CANTSENDMORE) {
  974.         while (getc(&tp->t_outq) >= 0) 
  975.             ;
  976.         *urgentp = 0;
  977.     }
  978.     MGET(m, M_DONTWAIT, MT_DATA);
  979.     if (m == 0) 
  980.         goto out;
  981.     /*
  982.      * If there is urgent data to send, ship it now
  983.      */
  984.     if (*urgentp) {
  985.         *mtod(m, unsigned char *) = *urgentp;
  986.         *urgentp = 0;
  987.         m->m_len = 1;
  988.         error = (*so->so_proto->pr_usrreq)(so,
  989.             PRU_SENDOOB, m, (struct mbuf *)0, (struct mbuf *)0);
  990.         if (error) 
  991.             nvs_emsg("nvs SENDOOB %d\n", error);
  992.         goto out;
  993.     }
  994.     while (1) {
  995.         /*
  996.          * Send a chunk of character traffic that may be pending
  997.          */
  998.         space = sbspace(&so->so_snd);
  999.         if (space > MLEN) 
  1000.             space = MLEN;
  1001.         if ((m->m_len = q_to_b(&tp->t_outq, mtod(m, char *), space)) == 0) {
  1002.             /*
  1003.              * No outq traffic or socket is saturated
  1004.              */
  1005.             (void) m_free(m);
  1006.             goto out;
  1007.         }
  1008.         error = (*so->so_proto->pr_usrreq)(so,
  1009.             PRU_SEND, m, (struct mbuf *)0, (struct mbuf *)0);
  1010. #ifdef lint
  1011.         /* Same actuals as above, better information for lint */
  1012.         error = tcp_usrreq(so,
  1013.             PRU_SEND, m, (struct mbuf *)0, (struct mbuf *)0);
  1014. #endif
  1015.         /*
  1016.          * If space != MLEN then socket is saturating or I've drained
  1017.          * the tty's outq, so there's not much sense in continuing.
  1018.          * Otherwise, remain in loop to feed the socket.
  1019.          */
  1020.         if (space != MLEN) 
  1021.             goto out;
  1022.         MGET(m, M_DONTWAIT, MT_DATA);
  1023.         if (m == 0) 
  1024.             goto out;
  1025.     }
  1026.  
  1027. out:    /*
  1028.      * Perpetuate myself if work remains
  1029.      */
  1030.     (void) spl5();            /* block out tty activity */
  1031.     if (tp->t_outq.c_cc > 0 || *urgentp) 
  1032.         timeout(ptsnvsnet, (caddr_t)tp, nvsichz); /* TS_BUSY remains set */
  1033.     else
  1034.         tp->t_state &= ~TS_BUSY;
  1035.     /*
  1036.      * Wake up sleepers
  1037.      */
  1038.     if (tp->t_outq.c_cc <= TTLOWAT(tp)) {
  1039.         if (tp->t_state&TS_ASLEEP) {
  1040.             tp->t_state &= ~TS_ASLEEP;
  1041.             wakeup((caddr_t)&tp->t_outq);
  1042.         }
  1043.         if (tp->t_wsel) {
  1044.             selwakeup(tp->t_wsel, tp->t_state & TS_WCOLL);
  1045.             tp->t_wsel = 0;
  1046.             tp->t_state &= ~TS_WCOLL;
  1047.         }
  1048.     }
  1049. rspl:    splx(s);
  1050. }
  1051.  
  1052. #endif KNVS
  1053. SHAR_EOF
  1054. echo shar: extracting tty_nvt.c
  1055. cat - << \SHAR_EOF > tty_nvt.c
  1056. /*
  1057.  * Network virtual terminals via sockets - client end
  1058.  *
  1059.  *    Rick Ace
  1060.  *    New York Institute of Technology
  1061.  *    Computer Graphics Laboratory
  1062.  *    Old Westbury, New York  11568
  1063.  */
  1064.  
  1065. /*
  1066.  * The code in this module supports the NVT, or local end of the connection
  1067.  * (i.e., the link between the network and the user's physical terminal).
  1068.  * The purpose of this code is to emulate efficiently the character-
  1069.  * shuffling functions performed by rlogin(1).  The rlogind on the remote
  1070.  * host will believe it is talking to an rlogin, when it is in reality
  1071.  * talking to the NVT kernel software herein.
  1072.  *
  1073.  * The NVT kernel software achieves performance improvements by handling
  1074.  * incoming and outgoing character traffic at interrupt level, eliminating
  1075.  * the overhead and delays resulting from scheduling a user-mode process.
  1076.  *
  1077.  * The implementation is broken into two main layers:
  1078.  *    1)  high-level software, common to all NVTs (nvt_XXX subrs) 
  1079.  *    2)  protocol-specific stuff (tcp_XXX, etc.) 
  1080.  * Presently, there is only a TCP implementation for layer # 2.
  1081.  */
  1082.  
  1083. #ifdef KNVT
  1084.  
  1085. #include "../h/param.h"
  1086. #include "../h/conf.h"
  1087. #include "../h/dir.h"
  1088. #include "../h/user.h"
  1089. #include "../h/file.h"
  1090. #include "../h/ioctl.h"
  1091. #include "../h/tty.h"
  1092. #include "../h/mbuf.h"
  1093. #include "../h/protosw.h"
  1094. #include "../h/socketvar.h"
  1095. #ifdef NFS
  1096. #include "../h/vnode.h"
  1097. #include "../ufs/inode.h"
  1098. #else NFS
  1099. #include "../h/inode.h"
  1100. #endif NFS
  1101.  
  1102. #define MAXNVT    16        /* should be in a parameter file */
  1103.  
  1104. /*
  1105.  * tp-to-socket correspondence table.
  1106.  *
  1107.  * This table is searched linearly.  A highest-entry mark is maintained
  1108.  * to keep search overhead low.  If there is a need to support large
  1109.  * numbers of NVTs, the linear search should be replaced by hashing.
  1110.  */
  1111. struct nvtj {
  1112.     struct tty    *nvt_tp;    /* tty context, or 0 if free slot */
  1113.     struct socket    *nvt_so;    /* socket context */
  1114.     char        nvt_ostopc;    /* original tty stop character */
  1115.     char        nvt_ostartc;    /* original tty start character */
  1116. } nvtj[MAXNVT];
  1117.  
  1118. struct nvtj    *nvthij = &nvtj[0];    /* highest active entry */
  1119.  
  1120. #ifndef lint
  1121. int    nvtj_n = MAXNVT;        /* for kernel debug utilities */
  1122. #endif
  1123.  
  1124. int    nvtichz;        /* hz between icpy scans */
  1125. int    nvtnmsg = 10;        /* # of kernel printfs remaining */
  1126. short    nvtricpy;        /* icpy: callout request exists */
  1127. short    nvtrocpy;        /* ocpy: callout request exists */
  1128.  
  1129. int    nvt_icpy();
  1130.  
  1131. /*
  1132.  * Mate a tty and a socket
  1133.  *
  1134.  * Returns UNIX error code
  1135.  * Must be called at splimp
  1136.  */
  1137. nvt_add(tp, so, anvt)
  1138.     struct tty *tp;
  1139.     struct socket *so;
  1140.     struct nvtj **anvt;    /* return addr of NVT context here */
  1141. {
  1142.     register struct nvtj *nvt, *nx;
  1143.     extern int hz;                /* XXX */
  1144.  
  1145.     if (nvtichz == 0) 
  1146.         nvtichz = hz / 3;        /* XXX */
  1147.     nvt = 0;
  1148.     nx = &nvtj[MAXNVT - 1];
  1149.     do {
  1150.         if (nx->nvt_tp) {
  1151.             if (nx->nvt_tp == tp || nx->nvt_so == so) 
  1152.                 return EBUSY; /* tty or socket already an NVT */
  1153.         }
  1154.         else
  1155.             nvt = nx;    /* remember lowest empty slot */
  1156.     } while (--nx >= &nvtj[0]);
  1157.     if (nvt == 0) 
  1158.         return ENFILE;        /* all slots are in use */
  1159.     /*
  1160.      * All is clear, mate them
  1161.      */
  1162.     if (nvt > nvthij) 
  1163.         nvthij = nvt;        /* update highest active entry */
  1164.     *anvt = nvt;            /* pass context pointer to caller */
  1165.     nvt->nvt_so = so;
  1166.     nvt->nvt_tp = tp;
  1167.     so->so_rcv.sb_flags |= SB_NVT;
  1168.     tp->t_state |= TS_NVT;
  1169.     nvt->nvt_ostopc = tp->t_stopc;
  1170.     nvt->nvt_ostartc = tp->t_startc;
  1171.     sbwakeup(&so->so_rcv);        /* get characters flowing */
  1172.     return 0;
  1173. }
  1174.  
  1175. /*
  1176.  * Undo a tty/socket correspondence
  1177.  *
  1178.  * Must be called at splimp
  1179.  */
  1180. nvt_del(nvt)
  1181.     register struct nvtj *nvt;
  1182. {
  1183.     register struct tty *tp;
  1184.  
  1185.     tp = nvt->nvt_tp;
  1186.     if (tp == 0) 
  1187.         panic("Nvt_del");
  1188.     tp->t_state &= ~TS_NVT;
  1189.     tp->t_stopc = nvt->nvt_ostopc;
  1190.     tp->t_startc = nvt->nvt_ostartc;
  1191.     nvt->nvt_so->so_rcv.sb_flags &= ~SB_NVT;
  1192.     /*
  1193.      * Delete this entry and adjust Nvthij if necessary
  1194.      */
  1195.     nvt->nvt_tp = 0;        /* mark entry as free */
  1196.     if (nvthij == nvt) 
  1197.         while (nvthij > &nvtj[0] && nvthij->nvt_tp == 0) 
  1198.             nvthij--;
  1199. }
  1200.  
  1201. /*
  1202.  * Kernel printf error message
  1203.  */
  1204. /*VARARGS1*/
  1205. nvt_emsg(msg, dat)
  1206.     char *msg;        /* error message with optional % */
  1207.     int dat;        /* optional data */
  1208. {
  1209.     if (--nvtnmsg >= 0) 
  1210.         printf(msg, dat);
  1211. }
  1212.  
  1213. /*
  1214.  * Copy incoming NVT characters from socket to tty
  1215.  *
  1216.  * Logic here is similar to that of soreceive() in uipc_socket.c
  1217.  */
  1218. nvt_i1cpy(nvt)
  1219.     struct nvtj *nvt;
  1220. {
  1221.     register struct socket *so = nvt->nvt_so;
  1222.     register struct tty *tp = nvt->nvt_tp;
  1223.     register struct mbuf *m;
  1224.     register int n, s;
  1225.  
  1226.     s = splnet();
  1227.     while (1) {
  1228.         /*
  1229.          * Handle out-of-band data if I'm at that point
  1230.          */
  1231.         if (so->so_state & SS_RCVATMARK) {
  1232.             m = m_get(M_DONTWAIT, MT_DATA);
  1233.             if (m == 0) 
  1234.                 goto out;
  1235.             if ((n = (*so->so_proto->pr_usrreq)(so, PRU_RCVOOB,
  1236.                 m, (struct mbuf *)0, (struct mbuf *)0)) == 0) {
  1237.                 nvt_oob(nvt, *mtod(m, unsigned char *));
  1238.                 so->so_state &= ~SS_RCVATMARK;
  1239.             }
  1240.             else
  1241.                 nvt_emsg("nvt RCVOOB %d\n", n);
  1242.             (void) m_free(m);
  1243.         }
  1244.         if (so->so_rcv.sb_cc <= 0) 
  1245.             goto out;
  1246.         /*
  1247.          * Check for out-of-band data preceded by character traffic.
  1248.          * If present, flush the precding character traffic;
  1249.          * otherwise, just transfer character traffic to the tty.
  1250.          */
  1251.         if ((n = so->so_oobmark) <= 0) {    /* if no OOB data... */
  1252.             n = TTHIWAT(tp);
  1253.             n -= tp->t_outq.c_cc;
  1254.             if (n <= 0) {
  1255.                 /*
  1256.                  * No room in tty's outq for more characters, so
  1257.                  * set up delay to retry after a brief interval.
  1258.                  */
  1259.                 if (!nvtricpy) {
  1260.                     nvtricpy++;
  1261.                     timeout(nvt_icpy, (caddr_t)0, nvtichz);
  1262.                 }
  1263.                 goto out;
  1264.             }
  1265.         }
  1266.         /*
  1267.          * Attack the first mbuf on the socket's rcv queue
  1268.          */
  1269.         m = so->so_rcv.sb_mb;
  1270.         if (m == 0) 
  1271.             panic("nvt_i1cpy");
  1272.         if (n > m->m_len) 
  1273.             n = m->m_len;
  1274.         if (so->so_oobmark <= 0 &&
  1275.             b_to_q(mtod(m, char *), n, &tp->t_outq)) 
  1276.             nvt_emsg("nvt b_to_q resid tp=%x\n", tp);
  1277.         ttstart(tp);
  1278.         if (n == m->m_len) {
  1279.             struct mbuf *mz;
  1280.  
  1281.             sbfree(&so->so_rcv, m);
  1282.             MFREE(m, mz);
  1283.             so->so_rcv.sb_mb = m = mz;
  1284.         }
  1285.         else {
  1286.             m->m_off += n;
  1287.             m->m_len -= n;
  1288.             so->so_rcv.sb_cc -= n;
  1289.         }
  1290.         if (so->so_oobmark > 0 && (so->so_oobmark -= n) == 0) 
  1291.             so->so_state |= SS_RCVATMARK;
  1292.         /*
  1293.          * Notify protocol that more space is available in the socket
  1294.          */
  1295.         if ((so->so_proto->pr_flags & PR_WANTRCVD) && so->so_pcb) 
  1296.             (*so->so_proto->pr_usrreq)(so, PRU_RCVD,
  1297.                 (struct mbuf *)0, (struct mbuf *)0, (struct mbuf *)0);
  1298.     }
  1299.  
  1300. out:    /*
  1301.      * If the remote has closed its output and I have passed all
  1302.      * incoming traffic to the tty, dissolve the NVT connection
  1303.      * between the socket and the local tty, and wake up rlogin.
  1304.      */
  1305.     if (so->so_state & SS_CANTRCVMORE && so->so_rcv.sb_cc <= 0) {
  1306.         so->so_rcv.sb_flags &= ~SB_NVT;
  1307.         tp->t_state &= ~TS_NVT;
  1308.         wakeup((caddr_t)nvt);
  1309.     }
  1310.     splx(s);
  1311. }
  1312.  
  1313. /*
  1314.  * Softclock interrupt routine to move characters from
  1315.  * socket receive buffer to tty output queue.  This
  1316.  * is used only to retry transfering characters to ttys
  1317.  * whose output queues were saturated.
  1318.  */
  1319. /*ARGSUSED*/
  1320. nvt_icpy(d)
  1321.     caddr_t d;    /* 2nd argument of timeout() */
  1322. {
  1323.     register struct nvtj *nvt;
  1324.  
  1325.     nvtricpy = 0;
  1326.     /*
  1327.      * Scan all NVT sockets for incoming traffic
  1328.      */
  1329.     nvt = &nvtj[0];
  1330.     do {
  1331.         if (nvt->nvt_tp && nvt->nvt_so->so_rcv.sb_cc > 0) 
  1332.             nvt_i1cpy(nvt);
  1333.     } while (++nvt <= nvthij);
  1334. }
  1335.  
  1336. /*
  1337.  * Called to report that an NVT has incoming characters from the net
  1338.  */
  1339. nvt_input(sb)
  1340.     struct sockbuf *sb;        /* so_rcv */
  1341. {
  1342. #define STRUCT_OFF(strnam, elem) \
  1343.     ((char *)&((struct strnam *)0)->elem - (char *)0) 
  1344.     register struct socket *so;
  1345.     register struct nvtj *nvt;
  1346.  
  1347.     /*
  1348.      * Convert so_rcv address to socket address (a bit gross),
  1349.      * then search the active-connection table for that socket
  1350.      */
  1351.     so = (struct socket *)((char *)sb - STRUCT_OFF(socket, so_rcv));
  1352.     nvt = &nvtj[0];
  1353.     do {
  1354.         if (nvt->nvt_so == so && nvt->nvt_tp) {
  1355.             /*
  1356.              * Have located the tty, now pass it the data
  1357.              */
  1358.             nvt_i1cpy(nvt);
  1359.             return;
  1360.         }
  1361.     } while (++nvt <= nvthij);
  1362.     nvt_emsg("nvt input no so %x\n", so);
  1363. }
  1364.  
  1365. /*
  1366.  * Handle ioctl request on socket to join socket and tty, called
  1367.  * from protocol ioctl logic.  Protocol-specific validation is
  1368.  * done before you get here.
  1369.  *
  1370.  * If the connection was successfully established, sleep and wait
  1371.  * until it is broken at the remote end, or until a signal is
  1372.  * received on the local end (viz., from the local tty driver
  1373.  * when the user types the escape character).
  1374.  *
  1375.  * Returns
  1376.  *    0 = remote closed the connection
  1377.  *    EINTR = signal from local tty (connection can be re-established) 
  1378.  *    Anything else = an error establishing the connection
  1379.  */
  1380. nvt_ioc_join(so, ttyfd)
  1381.     register struct socket *so;
  1382.     int ttyfd;        /* tty file descriptor */
  1383. {
  1384.     register struct file *fp;
  1385.     register struct inode *ip;
  1386.     register struct tty *tp;
  1387.     int error, s;
  1388.     struct nvtj *nvtp;
  1389.  
  1390.     /*
  1391.      * Validate file descriptor and ensure it references a tty
  1392.      */
  1393.     if ((unsigned)ttyfd >= NOFILE || (fp = u.u_ofile[ttyfd]) == 0) 
  1394.         return EBADF;
  1395. #ifdef NFS
  1396.     {
  1397.         register struct vnode *vp;
  1398.  
  1399.         vp = (struct vnode *)fp->f_data;
  1400.         if (fp->f_type != DTYPE_VNODE || vp->v_op != &ufs_vnodeops) 
  1401.             return ENOTTY;
  1402.         ip = VTOI(vp);
  1403.         if ((ip->i_mode & IFMT) != IFCHR ||
  1404.             (tp = cdevsw[major(ip->i_rdev)].d_ttys) == 0) 
  1405.             return ENOTTY;
  1406.     }
  1407. #else NFS
  1408.     ip = (struct inode *)fp->f_data;
  1409.     if (fp->f_type != DTYPE_INODE ||
  1410.         (ip->i_mode & IFMT) != IFCHR ||
  1411.         (tp = cdevsw[major(ip->i_rdev)].d_ttys) == 0) 
  1412.         return ENOTTY;
  1413. #endif NFS
  1414.     /*
  1415.      * Argument socket and tty are valid, now join them and wait
  1416.      */
  1417.     s = splimp();
  1418.     if (error = nvt_add(tp + minor(ip->i_rdev), so, &nvtp)) {
  1419.         splx(s);
  1420.         return error;
  1421.     }
  1422.     if (setjmp(&u.u_qsave)) {
  1423.         /*
  1424.          * The process received a signal
  1425.          */
  1426.         nvt_del(nvtp);        /* disassociate tty&socket */
  1427.         splx(s);
  1428.         return EINTR;
  1429.     }
  1430.     do sleep((caddr_t)nvtp, PZERO + 1); /* wait for signal or disconnect */
  1431.      while (nvtp->nvt_so->so_rcv.sb_flags & SB_NVT);
  1432.     /*
  1433.      * The remote disconnected.
  1434.      */
  1435.     nvt_del(nvtp);            /* disassociate tty&socket */
  1436.     splx(s);
  1437.     return 0;
  1438. }
  1439.  
  1440. /*
  1441.  * Softclock interrupt routine to move characters from local tty
  1442.  * input queues to network
  1443.  */
  1444. /*ARGSUSED*/
  1445. nvt_ocpy(d)
  1446.     caddr_t d;    /* 2nd argument of Timeout() */
  1447. {
  1448.     register struct mbuf *m;
  1449.     register struct tty *tp;
  1450.     register int c;
  1451.     register unsigned char *cp, *cplim;
  1452.     register struct nvtj *nvt;
  1453.     int error;
  1454.  
  1455.     nvtrocpy = 0;
  1456.     /*
  1457.      * Scan all NVT ttys for outbound characters
  1458.      */
  1459.     nvt = &nvtj[0];
  1460.     do {
  1461.         if ((tp = nvt->nvt_tp) == 0) 
  1462.             continue;        /* slot is not active */
  1463.         if (tp->t_rawq.c_cc <= 0 && tp->t_canq.c_cc <= 0) 
  1464.             continue;        /* no data */
  1465.         if (nvt->nvt_so->so_state & SS_CANTSENDMORE) 
  1466.             continue;
  1467.         MGET(m, M_DONTWAIT, MT_DATA);
  1468.         if (m == 0) 
  1469.             continue;
  1470.         cp = m->m_dat;
  1471.         cplim = cp + MLEN;
  1472.         if (tp->t_canq.c_cc > 0)          /* unlikely */
  1473.             while ((c = getc(&tp->t_canq)) >= 0) {
  1474.                 *cp++ = c;
  1475.                 if (cp >= cplim) 
  1476.                     goto mfull;
  1477.             }
  1478.         while ((c = getc(&tp->t_rawq)) >= 0) {
  1479.             if (tp->t_flags & RAW && (c & 0177) == tp->t_intrc) {
  1480.                 /*
  1481.                  * rlogin escape character typed in raw mode,
  1482.                  * simulate ttyinput() processing thereof
  1483.                  */
  1484.                 gsignal(tp->t_pgrp, SIGINT);
  1485.                 continue;
  1486.             }
  1487.             *cp++ = c;
  1488.             if (cp >= cplim) 
  1489.                 goto mfull;
  1490.         }
  1491. mfull:        m->m_len = cp - m->m_dat;
  1492.         error = (*nvt->nvt_so->so_proto->pr_usrreq)(nvt->nvt_so,
  1493.             PRU_SEND, m, (struct mbuf *)0, (struct mbuf *)0);
  1494. #ifdef lint
  1495.         /* Same actuals as above, better information for lint */
  1496.         error = tcp_usrreq(nvt->nvt_so,
  1497.             PRU_SEND, m, (struct mbuf *)0, (struct mbuf *)0);
  1498. #endif
  1499.         if (error) 
  1500.             nvt_emsg("nvt SEND %d\n", error);
  1501.     } while (++nvt <= nvthij);
  1502. }
  1503.  
  1504. /*
  1505.  * Process out-of-band data from remote
  1506.  */
  1507. nvt_oob(nvt, od)
  1508.     register struct nvtj *nvt;
  1509.     unsigned char od;        /* data */
  1510. {
  1511.     register struct tty *tp = nvt->nvt_tp;
  1512.  
  1513.     ttyflush(tp, FWRITE);
  1514.     if (od & TIOCPKT_NOSTOP) {
  1515.         tp->t_stopc = -1;
  1516.         tp->t_startc = -1;
  1517.     }
  1518.     if (od & TIOCPKT_DOSTOP) {
  1519.         tp->t_stopc = nvt->nvt_ostopc;
  1520.         tp->t_startc = nvt->nvt_ostartc;
  1521.     }
  1522.     if (nvtnmsg > 10) 
  1523.         nvt_emsg("nvt oob %x\n", od);
  1524. }
  1525.  
  1526. /*
  1527.  * Send characters typed at a local terminal across the net
  1528.  *
  1529.  * Called from tty hardware interrupt handler, so must queue request
  1530.  * to be handled at net IPL
  1531.  */
  1532. nvt_output(tp)
  1533.     register struct tty *tp;
  1534. {
  1535.     register struct nvtj *nvt;
  1536.  
  1537.     nvt = &nvtj[0];
  1538.     do {
  1539.         if (nvt->nvt_tp == tp) {
  1540.             if (!nvtrocpy) {
  1541.                 nvtrocpy++;
  1542.                 timeout(nvt_ocpy, (caddr_t)0, 0);
  1543.             }
  1544.             return;
  1545.         }
  1546.     } while (++nvt <= nvthij);
  1547.     /*
  1548.      * Not in my list, this tty is no longer associated with a socket
  1549.      */
  1550.     tp->t_state &= ~TS_NVT;
  1551. }
  1552.  
  1553. #endif KNVT
  1554. SHAR_EOF
  1555.  
  1556.  
  1557.