lcp.c
上传用户:nvosite88
上传日期:2007-01-17
资源大小:4983k
文件大小:44k
源码类别:

VxWorks

开发平台:

C/C++

  1. /* lcp.c - PPP Link Control Protocol */
  2. /* Copyright 1995 Wind River Systems, Inc. */
  3. #include "copyright_wrs.h"
  4. /*
  5.  * Copyright (c) 1989 Carnegie Mellon University.
  6.  * All rights reserved.
  7.  *
  8.  * Redistribution and use in source and binary forms are permitted
  9.  * provided that the above copyright notice and this paragraph are
  10.  * duplicated in all such forms and that any documentation,
  11.  * advertising materials, and other materials related to such
  12.  * distribution and use acknowledge that the software was developed
  13.  * by Carnegie Mellon University.  The name of the
  14.  * University may not be used to endorse or promote products derived
  15.  * from this software without specific prior written permission.
  16.  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
  17.  * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
  18.  * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
  19.  */
  20. /*
  21. modification history
  22. --------------------
  23. 01d,14apr97,vin  lcp state machine fixes from ppp-2.3b3, corrected the
  24.  problem of lcp_reqci generating CONFREJ instead of CONFNAKs.
  25. 01e,10dec96,vin  fixed additional problem with lcp_finished(), SPR7604.
  26. 01d,15nov96,vin  fixed lcp_finished(), calls fsm_open() if OPT_RESTART
  27.  is specified. This will cause the ppp deamon task
  28.  to wait for the next connection. This is typically useful
  29.  when vxWorks target is acting as a ppp server.
  30.  Added flag OPT_RESTART if passive or silent options are 
  31.  specified.
  32. 01c,16jun95,dzb  header file consolidation.
  33.                  changed [UN]TIMEOUT macros to PPP_[UN]TIMEOUT.
  34. 01b,09feb95,dab  ensure ao->mru is not 0 when setting interface mtu.
  35.                  removed lcp_echo_fails_reached variable.
  36. 01a,21dec94,dab  VxWorks port - first WRS version.
  37.    +dzb  added: path for ppp header files, WRS copyright.
  38. */
  39. #include "vxWorks.h"
  40. #include "stdio.h"
  41. #include "string.h"
  42. #include "sys/ioctl.h"
  43. #include "sys/types.h"
  44. #include "sys/socket.h"
  45. #include "sys/times.h"
  46. #include "netinet/in.h"
  47. #include "pppLib.h"
  48. /*
  49.  * Callbacks for fsm code.  (CI = Configuration Information)
  50.  */
  51. static void lcp_resetci __ARGS((fsm *)); /* Reset our CI */
  52. static int  lcp_cilen __ARGS((fsm *)); /* Return length of our CI */
  53. static void lcp_addci __ARGS((fsm *, u_char *, int *)); /* Add our CI to pkt */
  54. static int  lcp_ackci __ARGS((fsm *, u_char *, int)); /* Peer ack'd our CI */
  55. static int  lcp_nakci __ARGS((fsm *, u_char *, int)); /* Peer nak'd our CI */
  56. static int  lcp_rejci __ARGS((fsm *, u_char *, int)); /* Peer rej'd our CI */
  57. static int  lcp_reqci __ARGS((fsm *, u_char *, int *, int)); /* Rcv peer CI */
  58. static void lcp_up __ARGS((fsm *)); /* We're UP */
  59. static void lcp_down __ARGS((fsm *)); /* We're DOWN */
  60. static void lcp_starting __ARGS((fsm *)); /* We need lower layer up */
  61. static void lcp_finished __ARGS((fsm *)); /* We need lower layer down */
  62. static int  lcp_extcode __ARGS((fsm *, int, int, u_char *, int));
  63. static void lcp_rprotrej __ARGS((fsm *, u_char *, int));
  64. /*
  65.  * routines to send LCP echos to peer
  66.  */
  67. static void lcp_echo_lowerup __ARGS((int));
  68. static void lcp_echo_lowerdown __ARGS((int));
  69. static void LcpEchoTimeout __ARGS((caddr_t));
  70. static void lcp_received_echo_reply __ARGS((fsm *, int, u_char *, int));
  71. static void LcpSendEchoRequest __ARGS((fsm *));
  72. static void LcpLinkFailure __ARGS((fsm *));
  73. static fsm_callbacks lcp_callbacks = { /* LCP callback routines */
  74.     lcp_resetci, /* Reset our Configuration Information */
  75.     lcp_cilen, /* Length of our Configuration Information */
  76.     lcp_addci, /* Add our Configuration Information */
  77.     lcp_ackci, /* ACK our Configuration Information */
  78.     lcp_nakci, /* NAK our Configuration Information */
  79.     lcp_rejci, /* Reject our Configuration Information */
  80.     lcp_reqci, /* Request peer's Configuration Information */
  81.     lcp_up, /* Called when fsm reaches OPENED state */
  82.     lcp_down, /* Called when fsm leaves OPENED state */
  83.     lcp_starting, /* Called when we want the lower layer up */
  84.     lcp_finished, /* Called when we want the lower layer down */
  85.     NULL, /* Called when Protocol-Reject received */
  86.     NULL, /* Retransmission is necessary */
  87.     lcp_extcode, /* Called to handle LCP-specific codes */
  88.     "LCP" /* String name of protocol */
  89. };
  90. int lcp_warnloops = DEFWARNLOOPS; /* Warn about a loopback this often */
  91. /*
  92.  * Length of each type of configuration option (in octets)
  93.  */
  94. #define CILEN_VOID 2
  95. #define CILEN_SHORT 4 /* CILEN_VOID + sizeof(short) */
  96. #define CILEN_CHAP 5 /* CILEN_VOID + sizeof(short) + 1 */
  97. #define CILEN_LONG 6 /* CILEN_VOID + sizeof(long) */
  98. #define CILEN_LQR 8 /* CILEN_VOID + sizeof(short) + sizeof(long) */
  99. #define CODENAME(x) ((x) == CONFACK ? "ACK" : 
  100.  (x) == CONFNAK ? "NAK" : "REJ")
  101. static u_char nak_buffer[PPP_MRU]; /* where we construct a nak packet */
  102. /*
  103.  * lcp_init - Initialize LCP.
  104.  */
  105. void
  106. lcp_init(unit)
  107.     int unit;
  108. {
  109.     fsm *f = &ppp_if[unit]->lcp_fsm;
  110.     lcp_options *wo = &ppp_if[unit]->lcp_wantoptions;
  111.     lcp_options *ao = &ppp_if[unit]->lcp_allowoptions;
  112.     f->unit = unit;
  113.     f->protocol = LCP;
  114.     f->callbacks = &lcp_callbacks;
  115.     fsm_init(f);
  116.     wo->passive = 0;
  117.     wo->silent = 0;
  118.     wo->restart = 0; /* Set to 1 in kernels or multi-line
  119.    implementations */
  120.     wo->neg_mru = 1;
  121.     wo->mru = DEFMRU;
  122.     wo->neg_asyncmap = 0;
  123.     wo->asyncmap = 0;
  124.     wo->neg_chap = 0; /* Set to 1 on server */
  125.     wo->neg_upap = 0; /* Set to 1 on server */
  126.     wo->chap_mdtype = CHAP_DIGEST_MD5;
  127.     wo->neg_magicnumber = 1;
  128.     wo->neg_pcompression = 1;
  129.     wo->neg_accompression = 1;
  130.     wo->neg_lqr = 0; /* no LQR implementation yet */
  131.     ao->neg_mru = 1;
  132.     ao->mru = MAXMRU;
  133.     ao->neg_asyncmap = 1;
  134.     ao->asyncmap = 0;
  135.     ao->neg_chap = 1;
  136.     ao->chap_mdtype = CHAP_DIGEST_MD5;
  137.     ao->neg_upap = 1;
  138.     ao->neg_magicnumber = 1;
  139.     ao->neg_pcompression = 1;
  140.     ao->neg_accompression = 1;
  141.     ao->neg_lqr = 0; /* no LQR implementation yet */
  142.     bzero((char *)ppp_if[unit]->xmit_accm, sizeof(ppp_if[unit]->xmit_accm[0]));
  143.     ppp_if[unit]->xmit_accm[3] = 0x60000000;
  144. }
  145. /*
  146.  * lcp_open - LCP is allowed to come up.
  147.  */
  148. void
  149. lcp_open(unit)
  150.     int unit;
  151. {
  152.     fsm *f = &ppp_if[unit]->lcp_fsm;
  153.     lcp_options *wo = &ppp_if[unit]->lcp_wantoptions;
  154.     f->flags = 0;
  155.     if (wo->passive)
  156. f->flags |= (OPT_PASSIVE | OPT_RESTART) ;
  157.     if (wo->silent)
  158. f->flags |= (OPT_SILENT | OPT_RESTART);
  159.     fsm_open(f);
  160. }
  161. /*
  162.  * lcp_close - Take LCP down.
  163.  */
  164. void
  165. lcp_close(unit)
  166.     int unit;
  167. {
  168.     fsm *f = &ppp_if[unit]->lcp_fsm;
  169.     if (f->state == STOPPED && f->flags & (OPT_PASSIVE|OPT_SILENT)) {
  170.         /*
  171.          * This action is not strictly according to the FSM in RFC1548,
  172.          * but it does mean that the program terminates if you do a
  173.          * lcp_close(0) in passive/silent mode when a connection hasn't
  174.          * been established.
  175.          */
  176.         f->state = CLOSED;
  177.         lcp_finished(f);
  178.     } else
  179.         fsm_close(&ppp_if[unit]->lcp_fsm);
  180. }
  181. /*
  182.  * lcp_lowerup - The lower layer is up.
  183.  */
  184. void
  185. lcp_lowerup(unit)
  186.     int unit;
  187. {
  188.     sifdown(unit);
  189.     ppp_set_xaccm(unit, ppp_if[unit]->xmit_accm);
  190.     ppp_send_config(unit, MTU, 0xffffffff, 0, 0);
  191.     ppp_recv_config(unit, MTU, 0x00000000, 0, 0);
  192.     ppp_if[unit]->peer_mru = MTU;
  193.     ppp_if[unit]->lcp_allowoptions.asyncmap = ppp_if[unit]->xmit_accm[0];
  194.     fsm_lowerup(&ppp_if[unit]->lcp_fsm);
  195. }
  196. /*
  197.  * lcp_lowerdown - The lower layer is down.
  198.  */
  199. void
  200. lcp_lowerdown(unit)
  201.     int unit;
  202. {
  203.     fsm_lowerdown(&ppp_if[unit]->lcp_fsm);
  204. }
  205. /*
  206.  * lcp_input - Input LCP packet.
  207.  */
  208. void
  209. lcp_input(unit, p, len)
  210.     int unit;
  211.     u_char *p;
  212.     int len;
  213. {
  214.     fsm_input(&ppp_if[unit]->lcp_fsm, p, len);
  215. }
  216. /*
  217.  * lcp_extcode - Handle a LCP-specific code.
  218.  */
  219. static int
  220. lcp_extcode(f, code, id, inp, len)
  221.     fsm *f;
  222.     int code, id;
  223.     u_char *inp;
  224.     int len;
  225. {
  226.     u_char *magp;
  227.     switch( code ){
  228.     case PROTREJ:
  229. lcp_rprotrej(f, inp, len);
  230. break;
  231.     
  232.     case ECHOREQ:
  233. if (f->state != OPENED)
  234.     break;
  235. LCPDEBUG((LOG_INFO, "lcp: Echo-Request, Rcvd id %d", id));
  236.         magp = inp;
  237.         PUTLONG(ppp_if[f->unit]->lcp_gotoptions.magicnumber, magp);
  238.         if (len < CILEN_LONG)
  239.             len = CILEN_LONG;
  240. fsm_sdata(f, ECHOREP, id, inp, len);
  241. break;
  242.     
  243.     case ECHOREP:
  244.         lcp_received_echo_reply(f, id, inp, len);
  245.         break;
  246.     case DISCREQ:
  247. break;
  248.     default:
  249. return 0;
  250.     }
  251.     return 1;
  252. }
  253.     
  254. /*
  255.  * lcp_rprotrej - Receive an Protocol-Reject.
  256.  *
  257.  * Figure out which protocol is rejected and inform it.
  258.  */
  259. static void
  260. lcp_rprotrej(f, inp, len)
  261.     fsm *f;
  262.     u_char *inp;
  263.     int len;
  264. {
  265.     u_short prot;
  266.     LCPDEBUG((LOG_INFO, "lcp_rprotrej."));
  267.     if (len < sizeof (u_short)) {
  268. LCPDEBUG((LOG_INFO,
  269.                   "lcp_rprotrej: Rcvd short Protocol-Reject packet!"));
  270. return;
  271.     }
  272.     GETSHORT(prot, inp);
  273.     LCPDEBUG((LOG_INFO,
  274.               "lcp_rprotrej: Rcvd Protocol-Reject packet for %x!",
  275.       prot));
  276.     /*
  277.      * Protocol-Reject packets received in any state other than the LCP
  278.      * OPENED state SHOULD be silently discarded.
  279.      */
  280.     if( f->state != OPENED ){
  281. LCPDEBUG((LOG_INFO, "Protocol-Reject discarded: LCP in state %d",
  282.                   f->state));
  283. return;
  284.     }
  285.     DEMUXPROTREJ(f->unit, prot); /* Inform protocol */
  286. }
  287. /*
  288.  * lcp_protrej - A Protocol-Reject was received.
  289.  */
  290. /*ARGSUSED*/
  291. void
  292. lcp_protrej(unit)
  293.     int unit;
  294. {
  295.     /*
  296.      * Can't reject LCP!
  297.      */
  298.     LCPDEBUG((LOG_WARNING,
  299.               "lcp_protrej: Received Protocol-Reject for LCP!"));
  300.     fsm_protreject(&ppp_if[unit]->lcp_fsm);
  301. }
  302. /*
  303.  * lcp_sprotrej - Send a Protocol-Reject for some protocol.
  304.  */
  305. void
  306. lcp_sprotrej(unit, p, len)
  307.     int unit;
  308.     u_char *p;
  309.     int len;
  310. {
  311.     /*
  312.      * Send back the protocol and the information field of the
  313.      * rejected packet.  We only get here if LCP is in the OPENED state.
  314.      */
  315.     p += 2;
  316.     len -= 2;
  317.     fsm_sdata(&ppp_if[unit]->lcp_fsm, PROTREJ, ++ppp_if[unit]->lcp_fsm.id,
  318.       p, len);
  319. }
  320. /*
  321.  * lcp_resetci - Reset our CI.
  322.  */
  323. static void
  324.   lcp_resetci(f)
  325. fsm *f;
  326. {
  327.     ppp_if[f->unit]->lcp_wantoptions.magicnumber = magic();
  328.     ppp_if[f->unit]->lcp_wantoptions.numloops = 0;
  329.     ppp_if[f->unit]->lcp_gotoptions = ppp_if[f->unit]->lcp_wantoptions;
  330.     ppp_if[f->unit]->peer_mru = MTU;
  331. }
  332. /*
  333.  * lcp_cilen - Return length of our CI.
  334.  */
  335. static int
  336. lcp_cilen(f)
  337.     fsm *f;
  338. {
  339.     lcp_options *go = &ppp_if[f->unit]->lcp_gotoptions;
  340. #define LENCIVOID(neg) (neg ? CILEN_VOID : 0)
  341. #define LENCICHAP(neg) (neg ? CILEN_CHAP : 0)
  342. #define LENCISHORT(neg) (neg ? CILEN_SHORT : 0)
  343. #define LENCILONG(neg) (neg ? CILEN_LONG : 0)
  344. #define LENCILQR(neg) (neg ? CILEN_LQR: 0)
  345.     /*
  346.      * NB: we only ask for one of CHAP and UPAP, even if we will
  347.      * accept either.
  348.      */
  349.     return (LENCISHORT(go->neg_mru) +
  350.     LENCILONG(go->neg_asyncmap) +
  351.     LENCICHAP(go->neg_chap) +
  352.     LENCISHORT(!go->neg_chap && go->neg_upap) +
  353.     LENCILQR(go->neg_lqr) +
  354.     LENCILONG(go->neg_magicnumber) +
  355.     LENCIVOID(go->neg_pcompression) +
  356.     LENCIVOID(go->neg_accompression));
  357. }
  358. /*
  359.  * lcp_addci - Add our desired CIs to a packet.
  360.  */
  361. static void
  362. lcp_addci(f, ucp, lenp)
  363.     fsm *f;
  364.     u_char *ucp;
  365.     int *lenp;
  366. {
  367.     lcp_options *go = &ppp_if[f->unit]->lcp_gotoptions;
  368.     u_char *start_ucp = ucp;
  369. #define ADDCIVOID(opt, neg) 
  370.     if (neg) { 
  371. PUTCHAR(opt, ucp); 
  372. PUTCHAR(CILEN_VOID, ucp); 
  373.     }
  374. #define ADDCISHORT(opt, neg, val) 
  375.     if (neg) { 
  376. PUTCHAR(opt, ucp); 
  377. PUTCHAR(CILEN_SHORT, ucp); 
  378. PUTSHORT(val, ucp); 
  379.     }
  380. #define ADDCICHAP(opt, neg, val, digest) 
  381.     if (neg) { 
  382. PUTCHAR(opt, ucp); 
  383. PUTCHAR(CILEN_CHAP, ucp); 
  384. PUTSHORT(val, ucp); 
  385. PUTCHAR(digest, ucp); 
  386.     }
  387. #define ADDCILONG(opt, neg, val) 
  388.     if (neg) { 
  389. PUTCHAR(opt, ucp); 
  390. PUTCHAR(CILEN_LONG, ucp); 
  391. PUTLONG(val, ucp); 
  392.     }
  393. #define ADDCILQR(opt, neg, val) 
  394.     if (neg) { 
  395. PUTCHAR(opt, ucp); 
  396. PUTCHAR(CILEN_LQR, ucp); 
  397. PUTSHORT(LQR, ucp); 
  398. PUTLONG(val, ucp); 
  399.     }
  400.     ADDCISHORT(CI_MRU, go->neg_mru, go->mru);
  401.     ADDCILONG(CI_ASYNCMAP, go->neg_asyncmap, go->asyncmap);
  402.     ADDCICHAP(CI_AUTHTYPE, go->neg_chap, CHAP, go->chap_mdtype);
  403.     ADDCISHORT(CI_AUTHTYPE, !go->neg_chap && go->neg_upap, UPAP);
  404.     ADDCILQR(CI_QUALITY, go->neg_lqr, go->lqr_period);
  405.     ADDCILONG(CI_MAGICNUMBER, go->neg_magicnumber, go->magicnumber);
  406.     ADDCIVOID(CI_PCOMPRESSION, go->neg_pcompression);
  407.     ADDCIVOID(CI_ACCOMPRESSION, go->neg_accompression);
  408.     if (ucp - start_ucp != *lenp) {
  409. /* this should never happen, because peer_mtu should be 1500 */
  410. syslog(LOG_ERR, "Bug in lcp_addci: wrong length");
  411.     }
  412. }
  413. /*
  414.  * lcp_ackci - Ack our CIs.
  415.  * This should not modify any state if the Ack is bad.
  416.  *
  417.  * Returns:
  418.  * 0 - Ack was bad.
  419.  * 1 - Ack was good.
  420.  */
  421. static int
  422. lcp_ackci(f, p, len)
  423.     fsm *f;
  424.     u_char *p;
  425.     int len;
  426. {
  427.     lcp_options *go = &ppp_if[f->unit]->lcp_gotoptions;
  428.     u_char cilen, citype, cichar;
  429.     u_short cishort;
  430.     u_long cilong;
  431.     /*
  432.      * CIs must be in exactly the same order that we sent.
  433.      * Check packet length and CI length at each step.
  434.      * If we find any deviations, then this packet is bad.
  435.      */
  436. #define ACKCIVOID(opt, neg) 
  437.     if (neg) { 
  438. if ((len -= CILEN_VOID) < 0) 
  439.     goto bad; 
  440. GETCHAR(citype, p); 
  441. GETCHAR(cilen, p); 
  442. if (cilen != CILEN_VOID || 
  443.     citype != opt) 
  444.     goto bad; 
  445.     }
  446. #define ACKCISHORT(opt, neg, val) 
  447.     if (neg) { 
  448. if ((len -= CILEN_SHORT) < 0) 
  449.     goto bad; 
  450. GETCHAR(citype, p); 
  451. GETCHAR(cilen, p); 
  452. if (cilen != CILEN_SHORT || 
  453.     citype != (u_char)opt) 
  454.     goto bad; 
  455. GETSHORT(cishort, p); 
  456. if (cishort != (u_short)val) 
  457.     goto bad; 
  458.     }
  459. #define ACKCICHAP(opt, neg, val, digest) 
  460.     if (neg) { 
  461. if ((len -= CILEN_CHAP) < 0) 
  462.     goto bad; 
  463. GETCHAR(citype, p); 
  464. GETCHAR(cilen, p); 
  465. if (cilen != CILEN_CHAP || 
  466.     citype != (u_char)opt) 
  467.     goto bad; 
  468. GETSHORT(cishort, p); 
  469. if (cishort != (u_short)val) 
  470.     goto bad; 
  471. GETCHAR(cichar, p); 
  472. if (cichar != (u_char)digest) 
  473.   goto bad; 
  474.     }
  475. #define ACKCILONG(opt, neg, val) 
  476.     if (neg) { 
  477. if ((len -= CILEN_LONG) < 0) 
  478.     goto bad; 
  479. GETCHAR(citype, p); 
  480. GETCHAR(cilen, p); 
  481. if (cilen != CILEN_LONG || 
  482.     citype != (u_char)opt) 
  483.     goto bad; 
  484. GETLONG(cilong, p); 
  485. if (cilong != (u_long)val) 
  486.     goto bad; 
  487.     }
  488. #define ACKCILQR(opt, neg, val) 
  489.     if (neg) { 
  490. if ((len -= CILEN_LQR) < 0) 
  491.     goto bad; 
  492. GETCHAR(citype, p); 
  493. GETCHAR(cilen, p); 
  494. if (cilen != CILEN_LQR || 
  495.     citype != (u_char)opt) 
  496.     goto bad; 
  497. GETSHORT(cishort, p); 
  498. if (cishort != LQR) 
  499.     goto bad; 
  500. GETLONG(cilong, p); 
  501. if (cilong != (u_long)val) 
  502.   goto bad; 
  503.     }
  504.     ACKCISHORT(CI_MRU, go->neg_mru, go->mru);
  505.     ACKCILONG(CI_ASYNCMAP, go->neg_asyncmap, go->asyncmap);
  506.     ACKCICHAP(CI_AUTHTYPE, go->neg_chap, CHAP, go->chap_mdtype);
  507.     ACKCISHORT(CI_AUTHTYPE, !go->neg_chap && go->neg_upap, UPAP);
  508.     ACKCILQR(CI_QUALITY, go->neg_lqr, go->lqr_period);
  509.     ACKCILONG(CI_MAGICNUMBER, go->neg_magicnumber, go->magicnumber);
  510.     ACKCIVOID(CI_PCOMPRESSION, go->neg_pcompression);
  511.     ACKCIVOID(CI_ACCOMPRESSION, go->neg_accompression);
  512.     /*
  513.      * If there are any remaining CIs, then this packet is bad.
  514.      */
  515.     if (len != 0)
  516. goto bad;
  517.     return (1);
  518. bad:
  519.     LCPDEBUG((LOG_WARNING, "lcp_acki: received bad Ack!"));
  520.     return (0);
  521. }
  522. /*
  523.  * lcp_nakci - Peer has sent a NAK for some of our CIs.
  524.  * This should not modify any state if the Nak is bad
  525.  * or if LCP is in the OPENED state.
  526.  *
  527.  * Returns:
  528.  * 0 - Nak was bad.
  529.  * 1 - Nak was good.
  530.  */
  531. static int
  532. lcp_nakci(f, p, len)
  533.     fsm *f;
  534.     u_char *p;
  535.     int len;
  536. {
  537.     lcp_options *go = &ppp_if[f->unit]->lcp_gotoptions;
  538.     lcp_options *wo = &ppp_if[f->unit]->lcp_wantoptions;
  539.     u_char cilen, citype, cichar, *next;
  540.     u_short cishort = 0;
  541.     u_long cilong;
  542.     lcp_options no; /* options we've seen Naks for */
  543.     lcp_options try; /* options to request next time */
  544.     int looped_back = 0;
  545.     BZERO((char *)&no, sizeof(no));
  546.     try = *go;
  547.     /*
  548.      * Any Nak'd CIs must be in exactly the same order that we sent.
  549.      * Check packet length and CI length at each step.
  550.      * If we find any deviations, then this packet is bad.
  551.      */
  552. #define NAKCIVOID(opt, neg, code) 
  553.     if (go->neg && 
  554. len >= CILEN_VOID && 
  555. p[1] == CILEN_VOID && 
  556. p[0] == opt) { 
  557. len -= CILEN_VOID; 
  558. INCPTR(CILEN_VOID, p); 
  559. no.neg = 1; 
  560. code 
  561.     }
  562. #define NAKCICHAP(opt, neg, code) 
  563.     if (go->neg && 
  564. len >= CILEN_CHAP && 
  565. p[1] == CILEN_CHAP && 
  566. p[0] == opt) { 
  567. len -= CILEN_CHAP; 
  568. INCPTR(2, p); 
  569. GETSHORT(cishort, p); 
  570. GETCHAR(cichar, p); 
  571. no.neg = 1; 
  572. code 
  573.     }
  574. #define NAKCISHORT(opt, neg, code) 
  575.     if (go->neg && 
  576. len >= CILEN_SHORT && 
  577. p[1] == CILEN_SHORT && 
  578. p[0] == opt) { 
  579. len -= CILEN_SHORT; 
  580. INCPTR(2, p); 
  581. GETSHORT(cishort, p); 
  582. no.neg = 1; 
  583. code 
  584.     }
  585. #define NAKCILONG(opt, neg, code) 
  586.     if (go->neg && 
  587. len >= CILEN_LONG && 
  588. p[1] == CILEN_LONG && 
  589. p[0] == opt) { 
  590. len -= CILEN_LONG; 
  591. INCPTR(2, p); 
  592. GETLONG(cilong, p); 
  593. no.neg = 1; 
  594. code 
  595.     }
  596. #define NAKCILQR(opt, neg, code) 
  597.     if (go->neg && 
  598. len >= CILEN_LQR && 
  599. p[1] == CILEN_LQR && 
  600. p[0] == opt) { 
  601. len -= CILEN_LQR; 
  602. INCPTR(2, p); 
  603. GETSHORT(cishort, p); 
  604. GETLONG(cilong, p); 
  605. no.neg = 1; 
  606. code 
  607.     }
  608.     /*
  609.      * We don't care if they want to send us smaller packets than
  610.      * we want.  Therefore, accept any MRU less than what we asked for,
  611.      * but then ignore the new value when setting the MRU in the kernel.
  612.      * If they send us a bigger MRU than what we asked, accept it, up to
  613.      * the limit of the default MRU we'd get if we didn't negotiate.
  614.      */
  615.     NAKCISHORT(CI_MRU, neg_mru,
  616.        if (cishort <= wo->mru || cishort < DEFMRU)
  617.    try.mru = cishort;
  618.        );
  619.     /*
  620.      * Add any characters they want to our (receive-side) asyncmap.
  621.      */
  622.     NAKCILONG(CI_ASYNCMAP, neg_asyncmap,
  623.       try.asyncmap = go->asyncmap | cilong;
  624.       );
  625.     /*
  626.      * If they can't cope with our CHAP hash algorithm, we'll have
  627.      * to stop asking for CHAP.  We haven't got any other algorithm.
  628.      */
  629.     NAKCICHAP(CI_AUTHTYPE, neg_chap,
  630.       try.neg_chap = 0;
  631.       );
  632.     /*
  633.      * Peer shouldn't send Nak for UPAP, protocol compression or
  634.      * address/control compression requests; they should send
  635.      * a Reject instead.  If they send a Nak, treat it as a Reject.
  636.      */
  637.     if (!go->neg_chap ){
  638. NAKCISHORT(CI_AUTHTYPE, neg_upap,
  639.    try.neg_upap = 0;
  640.    );
  641.     }
  642.     /*
  643.      * If they can't cope with our link quality protocol, we'll have
  644.      * to stop asking for LQR.  We haven't got any other protocol.
  645.      * If they Nak the reporting period, take their value XXX ?
  646.      */
  647.     NAKCILQR(CI_QUALITY, neg_lqr,
  648.       if (cishort != LQR)
  649.   try.neg_lqr = 0;
  650.       else
  651.           try.lqr_period = cilong;
  652.       );
  653.     /*
  654.      * Check for a looped-back line.
  655.      */
  656.     NAKCILONG(CI_MAGICNUMBER, neg_magicnumber,
  657.       try.magicnumber = magic();
  658.       ++try.numloops;
  659.       looped_back = 1;
  660.       );
  661.     NAKCIVOID(CI_PCOMPRESSION, neg_pcompression,
  662.       try.neg_pcompression = 0;
  663.       );
  664.     NAKCIVOID(CI_ACCOMPRESSION, neg_accompression,
  665.       try.neg_accompression = 0;
  666.       );
  667.     /*
  668.      * There may be remaining CIs, if the peer is requesting negotiation
  669.      * on an option that we didn't include in our request packet.
  670.      * If we see an option that we requested, or one we've already seen
  671.      * in this packet, then this packet is bad.
  672.      * If we wanted to respond by starting to negotiate on the requested
  673.      * option(s), we could, but we don't, because except for the
  674.      * authentication type and quality protocol, if we are not negotiating
  675.      * an option, it is because we were told not to.
  676.      * For the authentication type, the Nak from the peer means
  677.      * `let me authenticate myself with you' which is a bit pointless.
  678.      * For the quality protocol, the Nak means `ask me to send you quality
  679.      * reports', but if we didn't ask for them, we don't want them.
  680.      */
  681.     while (len > CILEN_VOID) {
  682. GETCHAR(citype, p);
  683. GETCHAR(cilen, p);
  684. if( (len -= cilen) < 0 )
  685.     goto bad;
  686. next = p + cilen - 2;
  687. switch (citype) {
  688. case CI_MRU:
  689.     if (go->neg_mru || no.neg_mru || cilen != CILEN_SHORT)
  690. goto bad;
  691.     break;
  692. case CI_ASYNCMAP:
  693.     if (go->neg_asyncmap || no.neg_asyncmap || cilen != CILEN_LONG)
  694. goto bad;
  695.     break;
  696. case CI_AUTHTYPE:
  697.     if (go->neg_chap || no.neg_chap || go->neg_upap || no.neg_upap)
  698. goto bad;
  699.     break;
  700. case CI_MAGICNUMBER:
  701.     if (go->neg_magicnumber || no.neg_magicnumber ||
  702. cilen != CILEN_LONG)
  703. goto bad;
  704.     break;
  705. case CI_PCOMPRESSION:
  706.     if (go->neg_pcompression || no.neg_pcompression
  707. || cilen != CILEN_VOID)
  708. goto bad;
  709.     break;
  710. case CI_ACCOMPRESSION:
  711.     if (go->neg_accompression || no.neg_accompression
  712. || cilen != CILEN_VOID)
  713. goto bad;
  714.     break;
  715. case CI_QUALITY:
  716.     if (go->neg_lqr || no.neg_lqr || cilen != CILEN_LQR)
  717. goto bad;
  718.     break;
  719. default:
  720.     goto bad;
  721. }
  722. p = next;
  723.     }
  724.     /* If there is still anything left, this packet is bad. */
  725.     if (len != 0)
  726. goto bad;
  727.     /*
  728.      * OK, the Nak is good.  Now we can update state.
  729.      */
  730.     if (f->state != OPENED) {
  731. *go = try;
  732. if (looped_back && try.numloops % lcp_warnloops == 0)
  733.     LCPDEBUG((LOG_INFO, "The line appears to be looped back."));
  734.     }
  735.     return 1;
  736. bad:
  737.     LCPDEBUG((LOG_WARNING, "lcp_nakci: received bad Nak!"));
  738.     return 0;
  739. }
  740. /*
  741.  * lcp_rejci - Peer has Rejected some of our CIs.
  742.  * This should not modify any state if the Reject is bad
  743.  * or if LCP is in the OPENED state.
  744.  *
  745.  * Returns:
  746.  * 0 - Reject was bad.
  747.  * 1 - Reject was good.
  748.  */
  749. static int
  750. lcp_rejci(f, p, len)
  751.     fsm *f;
  752.     u_char *p;
  753.     int len;
  754. {
  755.     lcp_options *go = &ppp_if[f->unit]->lcp_gotoptions;
  756.     u_char cichar = 0;
  757.     u_short cishort;
  758.     u_long cilong;
  759. #ifdef DEBUGLCP
  760.     u_char *start = p;
  761.     int plen = len;
  762. #endif /* DEBUGLCP */
  763.     lcp_options try; /* options to request next time */
  764.     try = *go;
  765.     /*
  766.      * Any Rejected CIs must be in exactly the same order that we sent.
  767.      * Check packet length and CI length at each step.
  768.      * If we find any deviations, then this packet is bad.
  769.      */
  770. #define REJCIVOID(opt, neg) 
  771.     if (go->neg && 
  772. len >= CILEN_VOID && 
  773. p[1] == CILEN_VOID && 
  774. p[0] == opt) { 
  775. len -= CILEN_VOID; 
  776. INCPTR(CILEN_VOID, p); 
  777. try.neg = 0; 
  778. LCPDEBUG((LOG_INFO, "lcp_rejci rejected void opt %d", opt)); 
  779.     }
  780. #define REJCISHORT(opt, neg, val) 
  781.     if (go->neg && 
  782. len >= CILEN_SHORT && 
  783. p[1] == CILEN_SHORT && 
  784. p[0] == opt) { 
  785. len -= CILEN_SHORT; 
  786. INCPTR(2, p); 
  787. GETSHORT(cishort, p); 
  788. /* Check rejected value. */ 
  789. if (cishort != (u_short)val) 
  790.     goto bad; 
  791. try.neg = 0; 
  792. LCPDEBUG((LOG_INFO,"lcp_rejci rejected short opt %d", opt)); 
  793.     }
  794. #define REJCICHAP(opt, neg, val, digest) 
  795.     if (go->neg && 
  796. len >= CILEN_CHAP && 
  797. p[1] == CILEN_CHAP && 
  798. p[0] == opt) { 
  799. len -= CILEN_CHAP; 
  800. INCPTR(2, p); 
  801. GETSHORT(cishort, p); 
  802. GETCHAR(cichar, p); 
  803. /* Check rejected value. */ 
  804. if (cishort != (u_short)val || cichar != (u_char)digest) 
  805.     goto bad; 
  806. try.neg = 0; 
  807. LCPDEBUG((LOG_INFO,"lcp_rejci rejected chap opt %d", opt)); 
  808.     }
  809. #define REJCILONG(opt, neg, val) 
  810.     if (go->neg && 
  811. len >= CILEN_LONG && 
  812. p[1] == CILEN_LONG && 
  813. p[0] == opt) { 
  814. len -= CILEN_LONG; 
  815. INCPTR(2, p); 
  816. GETLONG(cilong, p); 
  817. /* Check rejected value. */ 
  818. if (cilong != (u_long)val) 
  819.     goto bad; 
  820. try.neg = 0; 
  821. LCPDEBUG((LOG_INFO,"lcp_rejci rejected long opt %d", opt)); 
  822.     }
  823. #define REJCILQR(opt, neg, val) 
  824.     if (go->neg && 
  825. len >= CILEN_LQR && 
  826. p[1] == CILEN_LQR && 
  827. p[0] == opt) { 
  828. len -= CILEN_LQR; 
  829. INCPTR(2, p); 
  830. GETSHORT(cishort, p); 
  831. GETLONG(cilong, p); 
  832. /* Check rejected value. */ 
  833. if (cishort != LQR || cilong != val) 
  834.     goto bad; 
  835. try.neg = 0; 
  836. LCPDEBUG((LOG_INFO,"lcp_rejci rejected LQR opt %d", opt)); 
  837.     }
  838.     REJCISHORT(CI_MRU, neg_mru, go->mru);
  839.     REJCILONG(CI_ASYNCMAP, neg_asyncmap, go->asyncmap);
  840.     REJCICHAP(CI_AUTHTYPE, neg_chap, CHAP, go->chap_mdtype);
  841.     if (!go->neg_chap) {
  842. REJCISHORT(CI_AUTHTYPE, neg_upap, UPAP);
  843.     }
  844.     REJCILQR(CI_QUALITY, neg_lqr, go->lqr_period);
  845.     REJCILONG(CI_MAGICNUMBER, neg_magicnumber, go->magicnumber);
  846.     REJCIVOID(CI_PCOMPRESSION, neg_pcompression);
  847.     REJCIVOID(CI_ACCOMPRESSION, neg_accompression);
  848.     /*
  849.      * If there are any remaining CIs, then this packet is bad.
  850.      */
  851.     if (len != 0)
  852. goto bad;
  853.     /*
  854.      * Now we can update state.
  855.      */
  856.     if (f->state != OPENED)
  857. *go = try;
  858.     return 1;
  859. bad:
  860.     LCPDEBUG((LOG_WARNING, "lcp_rejci: received bad Reject!"));
  861.     LCPDEBUG((LOG_WARNING, "lcp_rejci: plen %d len %d off %d",
  862.               plen, len, p - start));
  863.     return 0;
  864. }
  865. /*
  866.  * lcp_reqci - Check the peer's requested CIs and send appropriate response.
  867.  *
  868.  * Returns: CONFACK, CONFNAK or CONFREJ and input packet modified
  869.  * appropriately.  If reject_if_disagree is non-zero, doesn't return
  870.  * CONFNAK; returns CONFREJ if it can't return CONFACK.
  871.  */
  872. static int
  873. lcp_reqci(f, inp, lenp, reject_if_disagree)
  874.     fsm *f;
  875.     u_char *inp;                /* Requested CIs */
  876.     int *lenp;                  /* Length of requested CIs */
  877.     int reject_if_disagree;
  878. {
  879.     lcp_options *go = &ppp_if[f->unit]->lcp_gotoptions;
  880.     lcp_options *ho = &ppp_if[f->unit]->lcp_hisoptions;
  881.     lcp_options *ao = &ppp_if[f->unit]->lcp_allowoptions;
  882.     u_char *cip, *next; /* Pointer to current and next CIs */
  883.     u_char cilen, citype = 0, cichar;/* Parsed len, type, char value */
  884.     u_short cishort; /* Parsed short value */
  885.     u_long cilong; /* Parse long value */
  886.     int rc = CONFACK; /* Final packet return code */
  887.     int orc; /* Individual option return code */
  888.     u_char *p; /* Pointer to next char to parse */
  889.     u_char *rejp; /* Pointer to next char in reject frame */
  890.     u_char *nakp; /* Pointer to next char in Nak frame */
  891.     int l = *lenp; /* Length left */
  892.     /*
  893.      * Reset all his options.
  894.      */
  895.     BZERO((char *)ho, sizeof(*ho));
  896.     /*
  897.      * Process all his options.
  898.      */
  899.     next = inp;
  900.     nakp = nak_buffer;
  901.     rejp = inp;
  902.     while (l) {
  903. orc = CONFACK; /* Assume success */
  904. cip = p = next; /* Remember begining of CI */
  905. if (l < 2 || /* Not enough data for CI header or */
  906.     p[1] < 2 || /*  CI length too small or */
  907.     p[1] > l) { /*  CI length too big? */
  908.     LCPDEBUG((LOG_WARNING, "lcp_reqci: bad CI length!"));
  909.     orc = CONFREJ; /* Reject bad CI */
  910.     cilen = l; /* Reject till end of packet */
  911.     l = 0; /* Don't loop again */
  912.     goto endswitch;
  913. }
  914. GETCHAR(citype, p); /* Parse CI type */
  915. GETCHAR(cilen, p); /* Parse CI length */
  916. l -= cilen; /* Adjust remaining length */
  917. next += cilen; /* Step to next CI */
  918. switch (citype) { /* Check CI type */
  919. case CI_MRU:
  920.     LCPDEBUG((LOG_INFO, "lcp_reqci: rcvd MRU"));
  921.     if (!ao->neg_mru || /* Allow option? */
  922. cilen != CILEN_SHORT) { /* Check CI length */
  923. orc = CONFREJ; /* Reject CI */
  924. break;
  925.     }
  926.     GETSHORT(cishort, p); /* Parse MRU */
  927.     LCPDEBUG((LOG_INFO, "(%d)", cishort));
  928.     /*
  929.      * He must be able to receive at least our minimum.
  930.      * No need to check a maximum.  If he sends a large number,
  931.      * we'll just ignore it.
  932.      */
  933.     if (cishort < MINMRU) {
  934. orc = CONFNAK; /* Nak CI */
  935. if( !reject_if_disagree ){
  936.     DECPTR(sizeof (short), p); /* Backup */
  937.     PUTSHORT(MINMRU, p); /* Give him a hint */
  938. }
  939. break;
  940.     }
  941.     ho->neg_mru = 1; /* Remember he sent MRU */
  942.     ho->mru = cishort; /* And remember value */
  943.     break;
  944. case CI_ASYNCMAP:
  945.     LCPDEBUG((LOG_INFO, "lcp_reqci: rcvd ASYNCMAP"));
  946.     if (!ao->neg_asyncmap ||
  947. cilen != CILEN_LONG) {
  948. orc = CONFREJ;
  949. break;
  950.     }
  951.     GETLONG(cilong, p);
  952.     LCPDEBUG((LOG_INFO, "(%lx)", cilong));
  953.     /*
  954.      * Asyncmap must have set at least the bits
  955.      * which are set in lcp_allowoptions[unit].asyncmap.
  956.      */
  957.     if ((ao->asyncmap & ~cilong) != 0) {
  958. orc = CONFNAK;
  959. if( !reject_if_disagree ){
  960.     DECPTR(sizeof (long), p);
  961.     PUTLONG(ao->asyncmap | cilong, p);
  962. }
  963. break;
  964.     }
  965.     ho->neg_asyncmap = 1;
  966.     ho->asyncmap = cilong;
  967.     break;
  968. case CI_AUTHTYPE:
  969.     LCPDEBUG((LOG_INFO, "lcp_reqci: rcvd AUTHTYPE"));
  970.     if (cilen < CILEN_SHORT ||
  971. !(ao->neg_upap || ao->neg_chap)) {
  972. orc = CONFREJ;
  973. if (!ao->neg_upap && !ao->neg_chap)
  974.     LCPDEBUG((LOG_INFO, " we're not willing to authenticate"));
  975. else
  976.     LCPDEBUG((LOG_INFO, " cilen is too short!"));
  977. break;
  978.     }
  979.     GETSHORT(cishort, p);
  980.     LCPDEBUG((LOG_INFO, "(%x)", cishort));
  981.     /*
  982.      * Authtype must be UPAP or CHAP.
  983.      *
  984.      * Note: if both ao->neg_upap and ao->neg_chap are set,
  985.      * and the peer sends a Configure-Request with two
  986.      * authenticate-protocol requests, one for CHAP and one
  987.      * for UPAP, then we will reject the second request.
  988.      * Whether we end up doing CHAP or UPAP depends then on
  989.      * the ordering of the CIs in the peer's Configure-Request.
  990.      */
  991.     if (cishort == UPAP) {
  992. if (ho->neg_chap || /* we've already accepted CHAP */
  993.     cilen != CILEN_SHORT) {
  994.     LCPDEBUG((LOG_WARNING,
  995.       "lcp_reqci: rcvd AUTHTYPE PAP, rejecting..."));
  996.     orc = CONFREJ;
  997.     break;
  998. }
  999. if (!ao->neg_upap) { /* we don't want to do PAP */
  1000.     orc = CONFNAK; /* NAK it and suggest CHAP */
  1001.     PUTCHAR(CI_AUTHTYPE, nakp);
  1002.     PUTCHAR(CILEN_CHAP, nakp);
  1003.     PUTSHORT(CHAP, nakp);
  1004.     PUTCHAR(ao->chap_mdtype, nakp);
  1005.     break;
  1006. }
  1007. ho->neg_upap = 1;
  1008. break;
  1009.     }
  1010.     if (cishort == CHAP) {
  1011. if (ho->neg_upap || /* we've already accepted PAP */
  1012.     cilen != CILEN_CHAP) {
  1013.     LCPDEBUG((LOG_INFO,
  1014.       "lcp_reqci: rcvd AUTHTYPE CHAP, rejecting..."));
  1015.     orc = CONFREJ;
  1016.     break;
  1017. }
  1018. if (!ao->neg_chap) { /* we don't want to do CHAP */
  1019.     orc = CONFNAK; /* NAK it and suggest PAP */
  1020.     PUTCHAR(CI_AUTHTYPE, nakp);
  1021.     PUTCHAR(CILEN_SHORT, nakp);
  1022.     PUTSHORT(UPAP, nakp);
  1023.     break;
  1024. }
  1025. GETCHAR(cichar, p); /* get digest type*/
  1026. if (cichar != (u_char)ao->chap_mdtype) {
  1027.     orc = CONFNAK;
  1028.     PUTCHAR(CI_AUTHTYPE, nakp);
  1029.     PUTCHAR(CILEN_CHAP, nakp);
  1030.     PUTSHORT(CHAP, nakp);
  1031.     PUTCHAR(ao->chap_mdtype, nakp);
  1032.     break;
  1033. }
  1034. ho->chap_mdtype = cichar; /* save md type */
  1035. ho->neg_chap = 1;
  1036. break;
  1037.     }
  1038.     /*
  1039.      * We don't recognize the protocol they're asking for.
  1040.      * Nak it with something we're willing to do.
  1041.      * (At this point we know ao->neg_upap || ao->neg_chap.)
  1042.      */
  1043.     orc = CONFNAK;
  1044.     PUTCHAR(CI_AUTHTYPE, nakp);
  1045.     if (ao->neg_chap) {
  1046. PUTCHAR(CILEN_CHAP, nakp);
  1047. PUTSHORT(CHAP, nakp);
  1048. PUTCHAR(ao->chap_mdtype, nakp);
  1049.     } else {
  1050. PUTCHAR(CILEN_SHORT, nakp);
  1051. PUTSHORT(UPAP, nakp);
  1052.     }
  1053.     break;
  1054.             
  1055. case CI_QUALITY:
  1056.     LCPDEBUG((LOG_INFO, "lcp_reqci: rcvd QUALITY"));
  1057.     if (!ao->neg_lqr ||
  1058. cilen != CILEN_LQR) {
  1059. orc = CONFREJ;
  1060. break;
  1061.     }
  1062.     GETSHORT(cishort, p);
  1063.     GETLONG(cilong, p);
  1064.     LCPDEBUG((LOG_INFO, "(%x %lx)", cishort, cilong));
  1065.     /*
  1066.      * Check the protocol and the reporting period.
  1067.      * XXX When should we Nak this, and what with?
  1068.      */
  1069.     if (cishort != LQR) {
  1070. orc = CONFNAK;
  1071. PUTCHAR(CI_QUALITY, nakp);
  1072. PUTCHAR(CILEN_LQR, nakp);
  1073. PUTSHORT(LQR, nakp);
  1074. PUTLONG(ao->lqr_period, nakp);
  1075. break;
  1076.     }
  1077.     break;
  1078. case CI_MAGICNUMBER:
  1079.     LCPDEBUG((LOG_INFO, "lcp_reqci: rcvd MAGICNUMBER"));
  1080.     if (!(ao->neg_magicnumber || go->neg_magicnumber) ||
  1081. cilen != CILEN_LONG) {
  1082. orc = CONFREJ;
  1083. break;
  1084.     }
  1085.     GETLONG(cilong, p);
  1086.     LCPDEBUG((LOG_INFO, "(%lx)", cilong));
  1087.     /*
  1088.      * He must have a different magic number.
  1089.      */
  1090.     if (go->neg_magicnumber &&
  1091. cilong == go->magicnumber) {
  1092. orc = CONFNAK;
  1093. cilong = magic(); /* Don't put magic() inside macro! */
  1094. orc = CONFNAK;
  1095. PUTCHAR(CI_MAGICNUMBER, nakp);
  1096. PUTCHAR(CILEN_LONG, nakp);
  1097. PUTLONG(cilong, nakp);
  1098. break;
  1099.     }
  1100.     ho->neg_magicnumber = 1;
  1101.     ho->magicnumber = cilong;
  1102.     break;
  1103. case CI_PCOMPRESSION:
  1104.     LCPDEBUG((LOG_INFO, "lcp_reqci: rcvd PCOMPRESSION"));
  1105.     if (!ao->neg_pcompression ||
  1106. cilen != CILEN_VOID) {
  1107. orc = CONFREJ;
  1108. break;
  1109.     }
  1110.     ho->neg_pcompression = 1;
  1111.     break;
  1112. case CI_ACCOMPRESSION:
  1113.     LCPDEBUG((LOG_INFO, "lcp_reqci: rcvd ACCOMPRESSION"));
  1114.     if (!ao->neg_accompression ||
  1115. cilen != CILEN_VOID) {
  1116. orc = CONFREJ;
  1117. break;
  1118.     }
  1119.     ho->neg_accompression = 1;
  1120.     break;
  1121. default:
  1122.     LCPDEBUG((LOG_INFO, "lcp_reqci: rcvd unknown option %d",
  1123.       citype));
  1124.     orc = CONFREJ;
  1125.     break;
  1126. }
  1127. endswitch:
  1128. LCPDEBUG((LOG_INFO, " (%s)", CODENAME(orc)));
  1129. if (orc == CONFACK && /* Good CI */
  1130.     rc != CONFACK) /*  but prior CI wasnt? */
  1131.     continue; /* Don't send this one */
  1132. if (orc == CONFNAK) { /* Nak this CI? */
  1133.     if (reject_if_disagree /* Getting fed up with sending NAKs? */
  1134. && citype != CI_MAGICNUMBER) {
  1135. orc = CONFREJ; /* Get tough if so */
  1136.     } else {
  1137. if (rc == CONFREJ) /* Rejecting prior CI? */
  1138.     continue; /* Don't send this one */
  1139. rc = CONFNAK;
  1140.     }
  1141. }
  1142. if (orc == CONFREJ) { /* Reject this CI */
  1143.     rc = CONFREJ;
  1144.     if (cip != rejp) /* Need to move rejected CI? */
  1145. BCOPY(cip, rejp, cilen); /* Move it */
  1146.     INCPTR(cilen, rejp); /* Update output pointer */
  1147. }
  1148.     }
  1149.     /*
  1150.      * If we wanted to send additional NAKs (for unsent CIs), the
  1151.      * code would go here.  The extra NAKs would go at *nakp.
  1152.      * At present there are no cases where we want to ask the
  1153.      * peer to negotiate an option.
  1154.      */
  1155.     switch (rc) {
  1156.     case CONFACK:
  1157. *lenp = next - inp;
  1158. break;
  1159.     case CONFNAK:
  1160. /*
  1161.  * Copy the Nak'd options from the nak_buffer to the caller's buffer.
  1162.  */
  1163. *lenp = nakp - nak_buffer;
  1164. BCOPY(nak_buffer, inp, *lenp);
  1165. break;
  1166.     case CONFREJ:
  1167. *lenp = rejp - inp;
  1168. break;
  1169.     }
  1170.     LCPDEBUG((LOG_INFO, "lcp_reqci: returning CONF%s.", CODENAME(rc)));
  1171.     return (rc); /* Return final code */
  1172. }
  1173. /*
  1174.  * lcp_up - LCP has come UP.
  1175.  *
  1176.  * Start UPAP, IPCP, etc.
  1177.  */
  1178. static void
  1179. lcp_up(f)
  1180.     fsm *f;
  1181. {
  1182.     lcp_options *wo = &ppp_if[f->unit]->lcp_wantoptions;
  1183.     lcp_options *ho = &ppp_if[f->unit]->lcp_hisoptions;
  1184.     lcp_options *go = &ppp_if[f->unit]->lcp_gotoptions;
  1185.     lcp_options *ao = &ppp_if[f->unit]->lcp_allowoptions;
  1186.     if (!go->neg_magicnumber)
  1187.         go->magicnumber = 0;
  1188.     if (!ho->neg_magicnumber)
  1189.         ho->magicnumber = 0;
  1190.     /*
  1191.      * Set our MTU to the smaller of the MTU we wanted and
  1192.      * the MRU our peer wanted.  If we negotiated an MRU,
  1193.      * set our MRU to the larger of value we wanted and
  1194.      * the value we got in the negotiation.
  1195.      */
  1196.     ppp_send_config(f->unit,
  1197.                     MIN(ao->mru? ao->mru: MTU, (ho->neg_mru? ho->mru: MTU)),
  1198.     (ho->neg_asyncmap? ho->asyncmap: 0xffffffff),
  1199.     ho->neg_pcompression, ho->neg_accompression);
  1200.     /*
  1201.      * If the asyncmap hasn't been negotiated, we really should
  1202.      * set the receive asyncmap to ffffffff, but we set it to 0
  1203.      * for backwards contemptibility.
  1204.      */
  1205.     ppp_recv_config(f->unit, (go->neg_mru? MAX(wo->mru, go->mru): MTU),
  1206.                     (go->neg_asyncmap? go->asyncmap: 0x00000000),
  1207.                     go->neg_pcompression, go->neg_accompression);
  1208.     if (ho->neg_mru)
  1209. ppp_if[f->unit]->peer_mru = ho->mru;
  1210.     ChapLowerUp(f->unit); /* Enable CHAP */
  1211.     upap_lowerup(f->unit); /* Enable UPAP */
  1212.     ipcp_lowerup(f->unit); /* Enable IPCP */
  1213.     lcp_echo_lowerup(f->unit);  /* Enable echo messages */
  1214.     link_established(f->unit);
  1215. }
  1216. /*
  1217.  * lcp_down - LCP has gone DOWN.
  1218.  *
  1219.  * Alert other protocols.
  1220.  */
  1221. static void
  1222. lcp_down(f)
  1223.     fsm *f;
  1224. {
  1225.     lcp_echo_lowerdown(f->unit);
  1226.     ipcp_lowerdown(f->unit);
  1227.     ChapLowerDown(f->unit);
  1228.     upap_lowerdown(f->unit);
  1229.     sifdown(f->unit);
  1230.     ppp_send_config(f->unit, MTU, 0xffffffff, 0, 0);
  1231.     ppp_recv_config(f->unit, MTU, 0x00000000, 0, 0);
  1232.     ppp_if[f->unit]->peer_mru = MTU;
  1233.     link_down(f->unit);
  1234. }
  1235. /*
  1236.  * lcp_starting - LCP needs the lower layer up.
  1237.  */
  1238. static void
  1239. lcp_starting(f)
  1240.     fsm *f;
  1241. {
  1242.     link_required(f->unit);
  1243. }
  1244. /*
  1245.  * lcp_finished - LCP has finished with the lower layer.
  1246.  */
  1247. static void
  1248. lcp_finished(f)
  1249.     fsm *f;
  1250. {
  1251.     /* if passive or silent flags set and if lcp state is STOPPED or CLOSED 
  1252.      * then reopen the link for the next connection
  1253.      */
  1254.     if (((f->state == STOPPED) || (f->state == CLOSED)) && 
  1255. (f->flags & OPT_RESTART))
  1256. fsm_open (f); 
  1257.     else 
  1258. link_terminated(f->unit);
  1259. }
  1260. /*
  1261.  * lcp_printpkt - print the contents of an LCP packet.
  1262.  */
  1263. char *lcp_codenames[] = {
  1264.     "ConfReq", "ConfAck", "ConfNak", "ConfRej",
  1265.     "TermReq", "TermAck", "CodeRej", "ProtRej",
  1266.     "EchoReq", "EchoRep", "DiscReq"
  1267. };
  1268. int
  1269. lcp_printpkt(p, plen, printer, arg)
  1270.     u_char *p;
  1271.     int plen;
  1272.     void (*printer) __ARGS((void *, char *, ...));
  1273.     void *arg;
  1274. {
  1275.     int code, id, len, olen;
  1276.     u_char *pstart, *optend;
  1277.     u_short cishort;
  1278.     u_long cilong;
  1279.     if (plen < HEADERLEN)
  1280.         return 0;
  1281.     pstart = p;
  1282.     GETCHAR(code, p);
  1283.     GETCHAR(id, p);
  1284.     GETSHORT(len, p);
  1285.     if (len < HEADERLEN || len > plen)
  1286.         return 0;
  1287.     if (code >= 1 && code <= sizeof(lcp_codenames) / sizeof(char *))
  1288.         printer(arg, " %s", lcp_codenames[code-1]);
  1289.     else
  1290.         printer(arg, " code=0x%x", code);
  1291.     printer(arg, " id=0x%x", id);
  1292.     len -= HEADERLEN;
  1293.     switch (code) {
  1294.     case CONFREQ:
  1295.     case CONFACK:
  1296.     case CONFNAK:
  1297.     case CONFREJ:
  1298.         /* print option list */
  1299.         while (len >= 2) {
  1300.             GETCHAR(code, p);
  1301.             GETCHAR(olen, p);
  1302.             p -= 2;
  1303.             if (olen < 2 || olen > len) {
  1304.                 break;
  1305.             }
  1306.             printer(arg, " <");
  1307.             len -= olen;
  1308.             optend = p + olen;
  1309.             switch (code) {
  1310.             case CI_MRU:
  1311.                 if (olen == CILEN_SHORT) {
  1312.                     p += 2;
  1313.                     GETSHORT(cishort, p);
  1314.                     printer(arg, "mru %d", cishort);
  1315.                 }
  1316.                 break;
  1317.             case CI_ASYNCMAP:
  1318.                 if (olen == CILEN_LONG) {
  1319.                     p += 2;
  1320.                     GETLONG(cilong, p);
  1321.                     printer(arg, "asyncmap 0x%x", cilong);
  1322.                 }
  1323.                 break;
  1324.             case CI_AUTHTYPE:
  1325.                 if (olen >= CILEN_SHORT) {
  1326.                     p += 2;
  1327.                     printer(arg, "auth ");
  1328.                     GETSHORT(cishort, p);
  1329.                     switch (cishort) {
  1330.                     case UPAP:
  1331.                         printer(arg, "upap");
  1332.                         break;
  1333.                     case CHAP:
  1334.                         printer(arg, "chap");
  1335.                         break;
  1336.                     default:
  1337.                         printer(arg, "0x%x", cishort);
  1338.                     }
  1339.                 }
  1340.                 break;
  1341.             case CI_QUALITY:
  1342.                 if (olen >= CILEN_SHORT) {
  1343.                     p += 2;
  1344.                     printer(arg, "quality ");
  1345.                     GETSHORT(cishort, p);
  1346.                     switch (cishort) {
  1347.                     case LQR:
  1348.                         printer(arg, "lqr");
  1349.                         break;
  1350.                     default:
  1351.                         printer(arg, "0x%x", cishort);
  1352.                     }
  1353.                 }
  1354.                 break;
  1355.             case CI_MAGICNUMBER:
  1356.                 if (olen == CILEN_LONG) {
  1357.                     p += 2;
  1358.                     GETLONG(cilong, p);
  1359.                     printer(arg, "magic 0x%x", cilong);
  1360.                 }
  1361.                 break;
  1362.             case CI_PCOMPRESSION:
  1363.                 if (olen == CILEN_VOID) {
  1364.                     p += 2;
  1365.                     printer(arg, "pcomp");
  1366.                 }
  1367.                 break;
  1368.             case CI_ACCOMPRESSION:
  1369.                 if (olen == CILEN_VOID) {
  1370.                     p += 2;
  1371.                     printer(arg, "accomp");
  1372.                 }
  1373.                 break;
  1374.             }
  1375.             while (p < optend) {
  1376.                 GETCHAR(code, p);
  1377.                 printer(arg, " %.2x", code);
  1378.             }
  1379.             printer(arg, ">");
  1380.         }
  1381.         break;
  1382.     }
  1383.     /* print the rest of the bytes in the packet */
  1384.     for (; len > 0; --len) {
  1385.         GETCHAR(code, p);
  1386.         printer(arg, " %.2x", code);
  1387.     }
  1388.     return p - pstart;
  1389. }
  1390. /*
  1391.  * Time to shut down the link because there is nothing out there.
  1392.  */
  1393. static
  1394. void LcpLinkFailure (f)
  1395.     fsm *f;
  1396. {
  1397.     if (f->state == OPENED) {
  1398.         syslog (LOG_NOTICE, "Excessive lack of response to LCP echo frames.");
  1399.         lcp_lowerdown(f->unit);         /* Reset connection */
  1400. ppp_if[f->unit]->phase = PHASE_TERMINATE;
  1401.     }
  1402. }
  1403. /*
  1404.  * Timer expired for the LCP echo requests from this process.
  1405.  */
  1406. static void
  1407. LcpEchoCheck (f)
  1408.     fsm *f;
  1409. {
  1410.     u_long             delta;
  1411. #ifdef __linux__
  1412.     struct ppp_ddinfo  ddinfo;
  1413.     u_long             latest;
  1414. /*
  1415.  * Read the time since the last packet was received.
  1416.  */
  1417.     if (ioctl (fd, PPPIOCGTIME, &ddinfo) < 0) {
  1418.         syslog (LOG_ERR, "ioctl(PPPIOCGTIME): %m");
  1419.         die (1);
  1420.     }
  1421. /*
  1422.  * Choose the most recient frame received. It may be an IP or NON-IP frame.
  1423.  */
  1424.     latest = ddinfo.nip_rjiffies < ddinfo.ip_rjiffies ? ddinfo.nip_rjiffies
  1425.                                                       : ddinfo.ip_rjiffies;
  1426. /*
  1427.  * Compute the time since the last packet was received. If the timer
  1428.  *  has expired then send the echo request and reset the timer to maximum.
  1429.  */
  1430.     delta = (lcp_echo_interval * HZ) - latest;
  1431.     if (delta < HZ || latest < 0L) {
  1432.         LcpSendEchoRequest (f);
  1433.         delta = lcp_echo_interval * HZ;
  1434.     }
  1435.     delta /= HZ;
  1436. #else /* Other implementations do not have ability to find delta */
  1437.     LcpSendEchoRequest (f);
  1438.     delta = ppp_if[f->unit]->lcp_echo_interval;
  1439. #endif
  1440. /*
  1441.  * Start the timer for the next interval.
  1442.  */
  1443.     assert (ppp_if[f->unit]->lcp_echo_timer_running==0);
  1444.     PPP_TIMEOUT (LcpEchoTimeout, (caddr_t) f, delta);
  1445.     ppp_if[f->unit]->lcp_echo_timer_running = 1;
  1446. }
  1447. /*
  1448.  * LcpEchoTimeout - Timer expired on the LCP echo
  1449.  */
  1450. static void
  1451. LcpEchoTimeout (arg)
  1452.     caddr_t arg;
  1453. {
  1454.     fsm *f = (fsm *)arg;
  1455.     if (ppp_if[f->unit]->lcp_echo_timer_running != 0) {
  1456.         ppp_if[f->unit]->lcp_echo_timer_running = 0;
  1457.         LcpEchoCheck ((fsm *) arg);
  1458.     }
  1459. }
  1460. /*
  1461.  * LcpEchoReply - LCP has received a reply to the echo
  1462.  */
  1463. static void
  1464. lcp_received_echo_reply (f, id, inp, len)
  1465.     fsm *f;
  1466.     int id; u_char *inp; int len;
  1467. {
  1468.     u_long magic;
  1469.     /* Check the magic number - don't count replies from ourselves. */
  1470. #ifdef notyet
  1471.     if (len < CILEN_LONG)
  1472.         return;
  1473. #endif /* notyet */
  1474.     GETLONG(magic, inp);
  1475.     if (ppp_if[f->unit]->lcp_gotoptions.neg_magicnumber
  1476.         && magic == ppp_if[f->unit]->lcp_gotoptions.magicnumber)
  1477.         return;
  1478.     /* Reset the number of outstanding echo frames */
  1479.     ppp_if[f->unit]->lcp_echos_pending = 0;
  1480. }
  1481. /*
  1482.  * LcpSendEchoRequest - Send an echo request frame to the peer
  1483.  */
  1484. static void
  1485. LcpSendEchoRequest (f)
  1486.     fsm *f;
  1487. {
  1488.     u_long lcp_magic;
  1489.     u_char pkt[4], *pktp;
  1490. /*
  1491.  * Detect the failure of the peer at this point.
  1492.  */
  1493.     if (ppp_if[f->unit]->lcp_echo_fails != 0) {
  1494.         if (ppp_if[f->unit]->lcp_echos_pending++ >= ppp_if[f->unit]->lcp_echo_fails) {
  1495.             LcpLinkFailure(f);
  1496.             ppp_if[f->unit]->lcp_echos_pending = 0;
  1497.     die(f->unit, 1);
  1498.         }
  1499.     }
  1500. /*
  1501.  * Make and send the echo request frame.
  1502.  */
  1503.     if (f->state == OPENED) {
  1504.         lcp_magic = ppp_if[f->unit]->lcp_gotoptions.neg_magicnumber
  1505.                     ? ppp_if[f->unit]->lcp_gotoptions.magicnumber
  1506.                     : 0L;
  1507.         pktp = pkt;
  1508.         PUTLONG(lcp_magic, pktp);
  1509.         fsm_sdata(f, ECHOREQ,
  1510.                   ppp_if[f->unit]->lcp_echo_number++ & 0xFF, pkt, pktp - pkt);
  1511.     }
  1512. }
  1513. /*
  1514.  * lcp_echo_lowerup - Start the timer for the LCP frame
  1515.  */
  1516. static void
  1517. lcp_echo_lowerup (unit)
  1518.     int unit;
  1519. {
  1520.     fsm *f = &ppp_if[unit]->lcp_fsm;
  1521.     /* Clear the parameters for generating echo frames */
  1522.     ppp_if[unit]->lcp_echos_pending      = 0;
  1523.     ppp_if[unit]->lcp_echo_number        = 0;
  1524.     ppp_if[unit]->lcp_echo_timer_running = 0;
  1525.     /* If a timeout interval is specified then start the timer */
  1526.     if (ppp_if[unit]->lcp_echo_interval != 0)
  1527.         LcpEchoCheck (f);
  1528. }
  1529. /*
  1530.  * lcp_echo_lowerdown - Stop the timer for the LCP frame
  1531.  */
  1532. static void
  1533. lcp_echo_lowerdown (unit)
  1534.     int unit;
  1535. {
  1536.     fsm *f = &ppp_if[unit]->lcp_fsm;
  1537.     if (ppp_if[unit]->lcp_echo_timer_running != 0) {
  1538.         PPP_UNTIMEOUT (LcpEchoTimeout, (caddr_t) f);
  1539.         ppp_if[unit]->lcp_echo_timer_running = 0;
  1540.     }
  1541. }