diff options
Diffstat (limited to 'libexec/pppd/ipcp.c')
-rw-r--r-- | libexec/pppd/ipcp.c | 1057 |
1 files changed, 573 insertions, 484 deletions
diff --git a/libexec/pppd/ipcp.c b/libexec/pppd/ipcp.c index a805a3b612538..3638419ea6acb 100644 --- a/libexec/pppd/ipcp.c +++ b/libexec/pppd/ipcp.c @@ -17,12 +17,12 @@ * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE. */ +#ifndef lint +static char rcsid[] = "$Id: ipcp.c,v 1.3 1994/03/30 09:38:13 jkh Exp $"; +#endif + /* * TODO: - * Fix IP address negotiation (wantoptions or hisoptions). - * Don't set zero IP addresses. - * Send NAKs for unsent CIs. - * VJ compression. */ #include <stdio.h> @@ -33,64 +33,42 @@ #include <sys/time.h> #include <net/if.h> +#include <net/if_ppp.h> #include <net/route.h> #include <netinet/in.h> #include <string.h> -#ifndef BSD -#ifndef sun -#define BSD 44 -#endif -#endif /*BSD*/ - -#ifdef STREAMS -#include <sys/stream.h> -#include "ppp_str.h" -#endif - #include "pppd.h" -#include <net/if_ppp.h> - -#include <net/ppp.h> +#include "ppp.h" #include "fsm.h" #include "ipcp.h" /* global vars */ -ipcp_options ipcp_wantoptions[NPPP]; /* Options that we want to request */ -ipcp_options ipcp_gotoptions[NPPP]; /* Options that peer ack'd */ -ipcp_options ipcp_allowoptions[NPPP]; /* Options that we allow peer to - request */ -ipcp_options ipcp_hisoptions[NPPP]; /* Options that we ack'd */ +ipcp_options ipcp_wantoptions[_NPPP]; /* Options that we want to request */ +ipcp_options ipcp_gotoptions[_NPPP]; /* Options that peer ack'd */ +ipcp_options ipcp_allowoptions[_NPPP]; /* Options we allow peer to request */ +ipcp_options ipcp_hisoptions[_NPPP]; /* Options that we ack'd */ /* local vars */ +static int cis_received[_NPPP]; /* # Conf-Reqs received */ /* - * VJ compression protocol mode for negotiation. See ipcp.h for a - * description of each mode. + * Callbacks for fsm code. (CI = Configuration Information) */ -static int vj_mode = IPCP_VJMODE_RFC1332; - -static int vj_opt_len = 6; /* holds length in octets for valid vj */ - /* compression frame depending on mode */ - -static int vj_opt_val = IPCP_VJ_COMP; - /* compression negotiation frames */ - /* depending on vj_mode */ - -static void ipcp_resetci __ARGS((fsm *)); /* Reset our Configuration Information */ -static int ipcp_cilen __ARGS((fsm *)); /* Return length of our CI */ -static void ipcp_addci __ARGS((fsm *, u_char *)); /* Add our CIs */ -static int ipcp_ackci __ARGS((fsm *, u_char *, int)); /* Ack some CIs */ -static void ipcp_nakci __ARGS((fsm *, u_char *, int)); /* Nak some CIs */ -static void ipcp_rejci __ARGS((fsm *, u_char *, int)); /* Reject some CIs */ -static u_char ipcp_reqci __ARGS((fsm *, u_char *, int *)); /* Check the requested CIs */ +static void ipcp_resetci __ARGS((fsm *)); /* Reset our CI */ +static int ipcp_cilen __ARGS((fsm *)); /* Return length of our CI */ +static void ipcp_addci __ARGS((fsm *, u_char *, int *)); /* Add our CI */ +static int ipcp_ackci __ARGS((fsm *, u_char *, int)); /* Peer ack'd our CI */ +static int ipcp_nakci __ARGS((fsm *, u_char *, int)); /* Peer nak'd our CI */ +static int ipcp_rejci __ARGS((fsm *, u_char *, int)); /* Peer rej'd our CI */ +static int ipcp_reqci __ARGS((fsm *, u_char *, int *, int)); /* Rcv CI */ static void ipcp_up __ARGS((fsm *)); /* We're UP */ -static void ipcp_down __ARGS((fsm *)); /* We're DOWN */ +static void ipcp_down __ARGS((fsm *)); /* We're DOWN */ -static fsm ipcp_fsm[NPPP]; /* IPCP fsm structure */ +fsm ipcp_fsm[_NPPP]; /* IPCP fsm structure */ static fsm_callbacks ipcp_callbacks = { /* IPCP callback routines */ ipcp_resetci, /* Reset our Configuration Information */ @@ -100,19 +78,38 @@ static fsm_callbacks ipcp_callbacks = { /* IPCP callback routines */ ipcp_nakci, /* NAK our Configuration Information */ ipcp_rejci, /* Reject our Configuration Information */ ipcp_reqci, /* Request peer's Configuration Information */ - ipcp_up, /* Called when fsm reaches OPEN state */ - ipcp_down, /* Called when fsm leaves OPEN state */ - NULL, /* Called when fsm reaches CLOSED state */ + ipcp_up, /* Called when fsm reaches OPENED state */ + ipcp_down, /* Called when fsm leaves OPENED state */ + NULL, /* Called when we want the lower layer up */ + NULL, /* Called when we want the lower layer down */ NULL, /* Called when Protocol-Reject received */ - NULL /* Retransmission is necessary */ + NULL, /* Retransmission is necessary */ + NULL, /* Called to handle protocol-specific codes */ + "IPCP" /* String name of protocol */ }; +/* + * Lengths of configuration options. + */ +#define CILEN_VOID 2 +#define CILEN_COMPRESS 4 /* min length for compression protocol opt. */ +#define CILEN_VJ 6 /* length for RFC1332 Van-Jacobson opt. */ +#define CILEN_ADDR 6 /* new-style single address option */ +#define CILEN_ADDRS 10 /* old-style dual address option */ + + +#define CODENAME(x) ((x) == CONFACK ? "ACK" : \ + (x) == CONFNAK ? "NAK" : "REJ") + + +/* + * Make a string representation of a network IP address. + */ char * ip_ntoa(ipaddr) u_long ipaddr; { - static char b1[64], b2[64], w = 0; - char *b = (w++&1) ? b1 : b2; + static char b[64]; ipaddr = ntohl(ipaddr); @@ -124,12 +121,13 @@ u_long ipaddr; return b; } + /* * ipcp_init - Initialize IPCP. */ void - ipcp_init(unit) -int unit; +ipcp_init(unit) + int unit; { fsm *f = &ipcp_fsm[unit]; ipcp_options *wo = &ipcp_wantoptions[unit]; @@ -137,17 +135,17 @@ int unit; f->unit = unit; f->protocol = IPCP; - f->timeouttime = DEFTIMEOUT; - f->maxconfreqtransmits = DEFMAXCONFIGREQS; - f->maxtermtransmits = DEFMAXTERMTRANSMITS; - f->maxnakloops = DEFMAXNAKLOOPS; f->callbacks = &ipcp_callbacks; + fsm_init(&ipcp_fsm[unit]); - wo->neg_addrs = 1; + wo->neg_addr = 1; + wo->old_addrs = 0; wo->ouraddr = 0; wo->hisaddr = 0; wo->neg_vj = 1; + wo->old_vj = 0; + wo->vj_protocol = IPCP_VJ_COMP; wo->maxslotindex = MAX_STATES - 1; /* really max index */ wo->cflag = 1; @@ -155,77 +153,30 @@ int unit; /* ppp_if.c to 16 and 1, this needs to be changed (among other */ /* things) gmc */ - ao->neg_addrs = 1; /* accept old style dual addr */ - ao->neg_addr = 1; /* accept new style single addr */ + ao->neg_addr = 1; ao->neg_vj = 1; ao->maxslotindex = MAX_STATES - 1; ao->cflag = 1; - fsm_init(&ipcp_fsm[unit]); } -/* - * ipcp_vj_setmode - set option length and option value for vj - * compression negotiation frames depending on mode - */ - -void - ipcp_vj_setmode(mode) -int mode; -{ - vj_mode = mode; - - switch (vj_mode) { - - case IPCP_VJMODE_OLD: /* with wrong code (0x0037) */ - vj_opt_len = 4; - vj_opt_val = IPCP_VJ_COMP_OLD; - break; - - case IPCP_VJMODE_RFC1172: /* as per rfc1172 */ - vj_opt_len = 4; - vj_opt_val = IPCP_VJ_COMP; - break; - case IPCP_VJMODE_RFC1332: /* draft mode vj compression */ - vj_opt_len = 6; /* negotiation includes values for */ - /* maxslot and slot number compression */ - vj_opt_val = IPCP_VJ_COMP; - break; - - default: - IPCPDEBUG((LOG_WARNING, "Unknown vj compression mode %d. Please report \ -this error.", vj_mode)) - break; - } - -} /* - * ipcp_activeopen - Actively open IPCP. + * ipcp_open - IPCP is allowed to come up. */ void - ipcp_activeopen(unit) -int unit; -{ - fsm_activeopen(&ipcp_fsm[unit]); -} - - -/* - * ipcp_passiveopen - Passively open IPCP. - */ -void ipcp_passiveopen(unit) +ipcp_open(unit) int unit; { - fsm_passiveopen(&ipcp_fsm[unit]); + fsm_open(&ipcp_fsm[unit]); } /* - * ipcp_close - Close IPCP. + * ipcp_close - Take IPCP down. */ void - ipcp_close(unit) -int unit; +ipcp_close(unit) + int unit; { fsm_close(&ipcp_fsm[unit]); } @@ -235,8 +186,8 @@ int unit; * ipcp_lowerup - The lower layer is up. */ void - ipcp_lowerup(unit) -int unit; +ipcp_lowerup(unit) + int unit; { fsm_lowerup(&ipcp_fsm[unit]); } @@ -246,8 +197,8 @@ int unit; * ipcp_lowerdown - The lower layer is down. */ void - ipcp_lowerdown(unit) -int unit; +ipcp_lowerdown(unit) + int unit; { fsm_lowerdown(&ipcp_fsm[unit]); } @@ -257,10 +208,10 @@ int unit; * ipcp_input - Input IPCP packet. */ void - ipcp_input(unit, p, len) -int unit; -u_char *p; -int len; +ipcp_input(unit, p, len) + int unit; + u_char *p; + int len; { fsm_input(&ipcp_fsm[unit], p, len); } @@ -269,11 +220,11 @@ int len; /* * ipcp_protrej - A Protocol-Reject was received for IPCP. * - * Simply pretend that LCP went down. + * Pretend the lower layer went down, so we shut up. */ void - ipcp_protrej(unit) -int unit; +ipcp_protrej(unit) + int unit; { fsm_lowerdown(&ipcp_fsm[unit]); } @@ -283,10 +234,18 @@ int unit; * ipcp_resetci - Reset our CI. */ static void - ipcp_resetci(f) -fsm *f; +ipcp_resetci(f) + fsm *f; { - ipcp_gotoptions[f->unit] = ipcp_wantoptions[f->unit]; + ipcp_options *wo = &ipcp_wantoptions[f->unit]; + + wo->req_addr = wo->neg_addr && ipcp_allowoptions[f->unit].neg_addr; + if (wo->ouraddr == 0) + wo->accept_local = 1; + if (wo->hisaddr == 0) + wo->accept_remote = 1; + ipcp_gotoptions[f->unit] = *wo; + cis_received[f->unit] = 0; } @@ -294,21 +253,16 @@ fsm *f; * ipcp_cilen - Return length of our CI. */ static int - ipcp_cilen(f) -fsm *f; +ipcp_cilen(f) + fsm *f; { ipcp_options *go = &ipcp_gotoptions[f->unit]; +#define LENCIVJ(neg, old) (neg ? (old? CILEN_COMPRESS : CILEN_VJ) : 0) +#define LENCIADDR(neg, old) (neg ? (old? CILEN_ADDRS : CILEN_ADDR) : 0) -#define LENCISHORT(neg) (neg ? vj_opt_len : 0) - -#define LENCIADDRS(neg) (neg ? 10 : 0) - -#define LENCIADDR(neg) (neg ? 6 : 0) - - return (LENCIADDRS(go->neg_addrs) + - LENCIADDR(go->neg_addr) + - LENCISHORT(go->neg_vj)); + return (LENCIADDR(go->neg_addr, go->old_addrs) + + LENCIVJ(go->neg_vj, go->old_vj)); } @@ -316,50 +270,81 @@ fsm *f; * ipcp_addci - Add our desired CIs to a packet. */ static void - ipcp_addci(f, ucp) -fsm *f; -u_char *ucp; +ipcp_addci(f, ucp, lenp) + fsm *f; + u_char *ucp; + int *lenp; { + ipcp_options *wo = &ipcp_wantoptions[f->unit]; ipcp_options *go = &ipcp_gotoptions[f->unit]; + ipcp_options *ho = &ipcp_hisoptions[f->unit]; + int len = *lenp; - -#define ADDCISHORT(opt, neg, val, maxslotindex, cflag) \ +#define ADDCIVJ(opt, neg, val, old, maxslotindex, cflag) \ if (neg) { \ - PUTCHAR(opt, ucp); \ - PUTCHAR(vj_opt_len, ucp); \ - PUTSHORT(val, ucp); \ - if (vj_mode == IPCP_VJMODE_RFC1332) { \ - PUTCHAR(maxslotindex, ucp); \ - PUTCHAR(cflag, ucp); \ - } \ + int vjlen = old? CILEN_COMPRESS : CILEN_VJ; \ + if (len >= vjlen) { \ + PUTCHAR(opt, ucp); \ + PUTCHAR(vjlen, ucp); \ + PUTSHORT(val, ucp); \ + if (!old) { \ + PUTCHAR(maxslotindex, ucp); \ + PUTCHAR(cflag, ucp); \ + } \ + len -= vjlen; \ + } else \ + neg = 0; \ } -#define ADDCIADDRS(opt, neg, val1, val2) \ +#define ADDCIADDR(opt, neg, old, val1, val2) \ if (neg) { \ - u_long l; \ - PUTCHAR(opt, ucp); \ - PUTCHAR(2 + 2 * sizeof (long), ucp); \ - l = ntohl(val1); \ - PUTLONG(l, ucp); \ - l = ntohl(val2); \ - PUTLONG(l, ucp); \ + int addrlen = (old? CILEN_ADDRS: CILEN_ADDR); \ + if (len >= addrlen) { \ + u_long l; \ + PUTCHAR(opt, ucp); \ + PUTCHAR(addrlen, ucp); \ + l = ntohl(val1); \ + PUTLONG(l, ucp); \ + if (old) { \ + l = ntohl(val2); \ + PUTLONG(l, ucp); \ + } \ + len -= addrlen; \ + } else \ + neg = 0; \ } -#define ADDCIADDR(opt, neg, val) \ - if (neg) { \ - u_long l; \ - PUTCHAR(opt, ucp); \ - PUTCHAR(2 + sizeof (long), ucp); \ - l = ntohl(val); \ - PUTLONG(l, ucp); \ + /* + * First see if we want to change our options to the old + * forms because we have received old forms from the peer. + */ + if (wo->neg_addr && !go->neg_addr && !go->old_addrs) { + /* use the old style of address negotiation */ + go->neg_addr = 1; + go->old_addrs = 1; + } + if (wo->neg_vj && !go->neg_vj && !go->old_vj) { + /* try an older style of VJ negotiation */ + if (cis_received[f->unit] == 0) { + /* keep trying the new style until we see some CI from the peer */ + go->neg_vj = 1; + } else { + /* use the old style only if the peer did */ + if (ho->neg_vj && ho->old_vj) { + go->neg_vj = 1; + go->old_vj = 1; + go->vj_protocol = ho->vj_protocol; + } + } } - ADDCIADDRS(CI_ADDRS, go->neg_addrs, go->ouraddr, go->hisaddr) + ADDCIADDR((go->old_addrs? CI_ADDRS: CI_ADDR), go->neg_addr, + go->old_addrs, go->ouraddr, go->hisaddr); - ADDCIADDR(CI_ADDR, go->neg_addr, go->ouraddr) + ADDCIVJ(CI_COMPRESSTYPE, go->neg_vj, go->vj_protocol, go->old_vj, + go->maxslotindex, go->cflag); - ADDCISHORT(CI_COMPRESSTYPE, go->neg_vj, vj_opt_val, - go->maxslotindex, go->cflag) + *lenp -= len; } @@ -371,93 +356,74 @@ u_char *ucp; * 1 - Ack was good. */ static int - ipcp_ackci(f, p, len) -fsm *f; -u_char *p; -int len; +ipcp_ackci(f, p, len) + fsm *f; + u_char *p; + int len; { ipcp_options *go = &ipcp_gotoptions[f->unit]; u_short cilen, citype, cishort; u_long cilong; u_char cimaxslotindex, cicflag; + /* * CIs must be in exactly the same order that we sent... * Check packet length and CI length at each step. * If we find any deviations, then this packet is bad. */ -#define ACKCISHORT(opt, neg, val, maxslotindex, cflag) \ + +#define ACKCIVJ(opt, neg, val, old, maxslotindex, cflag) \ if (neg) { \ - if ((len -= vj_opt_len) < 0) \ + int vjlen = old? CILEN_COMPRESS : CILEN_VJ; \ + if ((len -= vjlen) < 0) \ goto bad; \ GETCHAR(citype, p); \ GETCHAR(cilen, p); \ - if (cilen != vj_opt_len || \ + if (cilen != vjlen || \ citype != opt) \ goto bad; \ GETSHORT(cishort, p); \ if (cishort != val) \ goto bad; \ - if (vj_mode == IPCP_VJMODE_RFC1332) { \ - GETCHAR(cimaxslotindex, p); \ - if (cimaxslotindex > maxslotindex) \ - goto bad; \ - GETCHAR(cicflag, p); \ - if (cicflag != cflag) \ - goto bad; \ - } \ - } - -#define ACKCIADDRS(opt, neg, val1, val2) \ - if (neg) { \ - u_long l; \ - if ((len -= 2 + 2 * sizeof (long)) < 0) \ - goto bad; \ - GETCHAR(citype, p); \ - GETCHAR(cilen, p); \ - if (cilen != 2 + 2 * sizeof (long) || \ - citype != opt) \ - goto bad; \ - GETLONG(l, p); \ - cilong = htonl(l); \ - if (val1) { \ - if (val1 != cilong) \ + if (!old) { \ + GETCHAR(cimaxslotindex, p); \ + if (cimaxslotindex != maxslotindex) \ goto bad; \ - } \ - else \ - val1 = cilong; \ - GETLONG(l, p); \ - cilong = htonl(l); \ - if (val2) { \ - if (val2 != cilong) \ + GETCHAR(cicflag, p); \ + if (cicflag != cflag) \ goto bad; \ } \ - else \ - val2 = cilong; \ } -#define ACKCIADDR(opt, neg, val) \ +#define ACKCIADDR(opt, neg, old, val1, val2) \ if (neg) { \ + int addrlen = (old? CILEN_ADDRS: CILEN_ADDR); \ u_long l; \ - if ((len -= 2 + sizeof (long)) < 0) \ + if ((len -= addrlen) < 0) \ goto bad; \ GETCHAR(citype, p); \ GETCHAR(cilen, p); \ - if (cilen != 2 + sizeof (long) || \ + if (cilen != addrlen || \ citype != opt) \ goto bad; \ GETLONG(l, p); \ cilong = htonl(l); \ - if (val) { \ - if (val != cilong) \ + if (val1 != cilong) \ + goto bad; \ + if (old) { \ + GETLONG(l, p); \ + cilong = htonl(l); \ + if (val2 != cilong) \ goto bad; \ } \ - else \ - val = cilong; \ } - ACKCIADDRS(CI_ADDRS, go->neg_addrs, go->ouraddr, go->hisaddr) - ACKCIADDR(CI_ADDR, go->neg_addr, go->ouraddr) - ACKCISHORT(CI_COMPRESSTYPE, go->neg_vj, vj_opt_val, go->maxslotindex, go->cflag) + ACKCIADDR((go->old_addrs? CI_ADDRS: CI_ADDR), go->neg_addr, + go->old_addrs, go->ouraddr, go->hisaddr); + + ACKCIVJ(CI_COMPRESSTYPE, go->neg_vj, go->vj_protocol, go->old_vj, + go->maxslotindex, go->cflag); + /* * If there are any remaining CIs, then this packet is bad. */ @@ -467,153 +433,246 @@ int len; bad: IPCPDEBUG((LOG_INFO, "ipcp_ackci: received bad Ack!")); - - if (vj_mode == IPCP_VJMODE_RFC1332 ) - IPCPDEBUG((LOG_INFO, "ipcp_ackci: citype %d, cilen %l", - citype, cilen)); - - if (citype == CI_COMPRESSTYPE) { - IPCPDEBUG((LOG_INFO, "ipcp_ackci: compress_type %d", cishort)); - if (vj_mode == IPCP_VJMODE_RFC1332) - IPCPDEBUG((LOG_INFO, ", maxslotindex %d, cflag %d", - cishort, cimaxslotindex, cicflag)); - } return (0); } /* - * ipcp_nakci - NAK some of our CIs. + * ipcp_nakci - Peer has sent a NAK for some of our CIs. + * This should not modify any state if the Nak is bad + * or if IPCP is in the OPENED state. * * Returns: * 0 - Nak was bad. * 1 - Nak was good. */ -static void - ipcp_nakci(f, p, len) -fsm *f; -u_char *p; -int len; +static int +ipcp_nakci(f, p, len) + fsm *f; + u_char *p; + int len; { ipcp_options *go = &ipcp_gotoptions[f->unit]; u_char cimaxslotindex, cicflag; + u_char citype, cilen, *next; u_short cishort; - u_long ciaddr1, ciaddr2; + u_long ciaddr1, ciaddr2, l; + ipcp_options no; /* options we've seen Naks for */ + ipcp_options try; /* options to request next time */ + + BZERO(&no, sizeof(no)); + try = *go; /* * Any Nak'd CIs must be in exactly the same order that we sent. * Check packet length and CI length at each step. * If we find any deviations, then this packet is bad. */ -#define NAKCISHORT(opt, neg, code) \ - if (neg && \ - len >= vj_opt_len && \ - p[1] == vj_opt_len && \ +#define NAKCIADDR(opt, neg, old, code) \ + if (go->neg && \ + len >= (cilen = (old? CILEN_ADDRS: CILEN_ADDR)) && \ + p[1] == cilen && \ p[0] == opt) { \ - len -= vj_opt_len; \ - INCPTR(2, p); \ - GETSHORT(cishort, p); \ - if (vj_mode == IPCP_VJMODE_RFC1332) { \ - GETCHAR(cimaxslotindex, p); \ - GETCHAR(cicflag, p); \ - } \ - code \ - } - -#define NAKCIADDRS(opt, neg, code) \ - if (neg && \ - len >= 2 + 2 * sizeof (long) && \ - p[1] == 2 + 2 * sizeof (long) && \ - p[0] == opt) { \ - u_long l; \ - len -= 2 + 2 * sizeof (long); \ + len -= cilen; \ INCPTR(2, p); \ GETLONG(l, p); \ ciaddr1 = htonl(l); \ - GETLONG(l, p); \ - ciaddr2 = htonl(l); \ + if (old) { \ + GETLONG(l, p); \ + ciaddr2 = htonl(l); \ + no.old_addrs = 1; \ + } else \ + ciaddr2 = 0; \ + no.neg = 1; \ code \ } -#define NAKCIADDR(opt, neg, code) \ - if (neg && \ - len >= 2 + sizeof (long) && \ - p[1] == 2 + sizeof (long) && \ +#define NAKCIVJ(opt, neg, code) \ + if (go->neg && \ + ((cilen = p[1]) == CILEN_COMPRESS || cilen == CILEN_VJ) && \ + len >= cilen && \ p[0] == opt) { \ - u_long l; \ - len -= 2 + sizeof (long); \ + len -= cilen; \ INCPTR(2, p); \ - GETLONG(l, p); \ - ciaddr1 = htonl(l); \ - code \ + GETSHORT(cishort, p); \ + if (cilen == CILEN_VJ) { \ + GETCHAR(cimaxslotindex, p); \ + GETCHAR(cicflag, p); \ + } \ + no.neg = 1; \ + code \ } - NAKCIADDRS(CI_ADDRS, go->neg_addrs, - if (!go->ouraddr) { /* Didn't know our address? */ - syslog(LOG_INFO, "local IP address %s", ip_ntoa(ciaddr1)); - go->ouraddr = ciaddr1; - } - if (ciaddr2) { /* Does he know his? */ - go->hisaddr = ciaddr2; - syslog(LOG_INFO, "remote IP address %s", ip_ntoa(ciaddr2)); - } - ) - - NAKCIADDR(CI_ADDR, go->neg_addr, - logf(LOG_INFO, "acquired IP address %s", ip_ntoa(ciaddr1)); - if (!go->ouraddr) { /* Didn't know our address? */ - go->ouraddr = ciaddr1; - syslog(LOG_INFO, "remote IP address %s", ip_ntoa(ciaddr1)); - } - ) - - NAKCISHORT(CI_COMPRESSTYPE, go->neg_vj, - if (cishort != vj_opt_val) - goto bad; - go->maxslotindex = cimaxslotindex; /* this is what it */ - go->cflag = cicflag; /* wants */ - - ) /* - * If there are any remaining CIs, then this packet is bad. + * Accept the peer's idea of {our,his} address, if different + * from our idea, only if the accept_{local,remote} flag is set. */ - if (len == 0) - return; + NAKCIADDR(CI_ADDR, neg_addr, go->old_addrs, + if (go->accept_local && ciaddr1) { /* Do we know our address? */ + try.ouraddr = ciaddr1; + IPCPDEBUG((LOG_INFO, "local IP address %s", + ip_ntoa(ciaddr1))); + } + if (go->accept_remote && ciaddr2) { /* Does he know his? */ + try.hisaddr = ciaddr2; + IPCPDEBUG((LOG_INFO, "remote IP address %s", + ip_ntoa(ciaddr2))); + } + ); + + /* + * Accept the peer's value of maxslotindex provided that it + * is less than what we asked for. Turn off slot-ID compression + * if the peer wants. Send old-style compress-type option if + * the peer wants. + */ + NAKCIVJ(CI_COMPRESSTYPE, neg_vj, + if (cilen == CILEN_VJ) { + if (cishort == IPCP_VJ_COMP) { + try.old_vj = 0; + if (cimaxslotindex < go->maxslotindex) + try.maxslotindex = cimaxslotindex; + if (!cicflag) + try.cflag = 0; + } else { + try.neg_vj = 0; + } + } else { + if (cishort == IPCP_VJ_COMP || cishort == IPCP_VJ_COMP_OLD) { + try.old_vj = 1; + try.vj_protocol = cishort; + } else { + try.neg_vj = 0; + } + } + ); + + /* + * There may be remaining CIs, if the peer is requesting negotiation + * on an option that we didn't include in our request packet. + * If they want to negotiate about IP addresses, we comply. + * If they want us to ask for compression, we refuse. + */ + while (len > CILEN_VOID) { + GETCHAR(citype, p); + GETCHAR(cilen, p); + if( (len -= cilen) < 0 ) + goto bad; + next = p + cilen - 2; + + switch (citype) { + case CI_COMPRESSTYPE: + if (go->neg_vj || no.neg_vj || + (cilen != CILEN_VJ && cilen != CILEN_COMPRESS)) + goto bad; + no.neg_vj = 1; + break; + case CI_ADDRS: + if (go->neg_addr && go->old_addrs || no.old_addrs + || cilen != CILEN_ADDRS) + goto bad; + try.neg_addr = 1; + try.old_addrs = 1; + GETLONG(l, p); + ciaddr1 = htonl(l); + if (ciaddr1 && go->accept_local) + try.ouraddr = ciaddr1; + GETLONG(l, p); + ciaddr2 = htonl(l); + if (ciaddr2 && go->accept_remote) + try.hisaddr = ciaddr2; + no.old_addrs = 1; + break; + case CI_ADDR: + if (go->neg_addr || no.neg_addr || cilen != CILEN_ADDR) + goto bad; + try.neg_addr = 1; + try.old_addrs = 0; + GETLONG(l, p); + ciaddr1 = htonl(l); + if (ciaddr1 && go->accept_local) + try.ouraddr = ciaddr1; + no.neg_addr = 1; + break; + default: + goto bad; + } + p = next; + } + + /* If there is still anything left, this packet is bad. */ + if (len != 0) + goto bad; + + /* + * OK, the Nak is good. Now we can update state. + */ + if (f->state != OPENED) + *go = try; + + return 1; + bad: IPCPDEBUG((LOG_INFO, "ipcp_nakci: received bad Nak!")); + return 0; } /* * ipcp_rejci - Reject some of our CIs. */ -static void - ipcp_rejci(f, p, len) -fsm *f; -u_char *p; -int len; +static int +ipcp_rejci(f, p, len) + fsm *f; + u_char *p; + int len; { ipcp_options *go = &ipcp_gotoptions[f->unit]; - u_char cimaxslotindex, ciflag; + u_char cimaxslotindex, ciflag, cilen; u_short cishort; u_long cilong; + ipcp_options try; /* options to request next time */ + try = *go; /* * Any Rejected CIs must be in exactly the same order that we sent. * Check packet length and CI length at each step. * If we find any deviations, then this packet is bad. */ -#define REJCISHORT(opt, neg, val, maxslot, cflag) \ - if (neg && \ - len >= vj_opt_len && \ - p[1] == vj_opt_len && \ +#define REJCIADDR(opt, neg, old, val1, val2) \ + if (go->neg && \ + len >= (cilen = old? CILEN_ADDRS: CILEN_ADDR) && \ + p[1] == cilen && \ + p[0] == opt) { \ + u_long l; \ + len -= cilen; \ + INCPTR(2, p); \ + GETLONG(l, p); \ + cilong = htonl(l); \ + /* Check rejected value. */ \ + if (cilong != val1) \ + goto bad; \ + if (old) { \ + GETLONG(l, p); \ + cilong = htonl(l); \ + /* Check rejected value. */ \ + if (cilong != val2) \ + goto bad; \ + } \ + try.neg = 0; \ + } + +#define REJCIVJ(opt, neg, val, old, maxslot, cflag) \ + if (go->neg && \ + p[1] == (old? CILEN_COMPRESS : CILEN_VJ) && \ + len >= p[1] && \ p[0] == opt) { \ - len -= vj_opt_len; \ + len -= p[1]; \ INCPTR(2, p); \ GETSHORT(cishort, p); \ /* Check rejected value. */ \ if (cishort != val) \ goto bad; \ - if (vj_mode == IPCP_VJMODE_RFC1332) { \ + if (!old) { \ GETCHAR(cimaxslotindex, p); \ if (cimaxslotindex != maxslot) \ goto bad; \ @@ -621,60 +680,30 @@ int len; if (ciflag != cflag) \ goto bad; \ } \ - neg = 0; \ + try.neg = 0; \ } -#define REJCIADDRS(opt, neg, val1, val2) \ - if (neg && \ - len >= 2 + 2 * sizeof (long) && \ - p[1] == 2 + 2 * sizeof (long) && \ - p[0] == opt) { \ - u_long l; \ - len -= 2 + 2 * sizeof (long); \ - INCPTR(2, p); \ - GETLONG(l, p); \ - cilong = htonl(l); \ - /* Check rejected value. */ \ - if (cilong != val2) \ - goto bad; \ - GETLONG(l, p); \ - cilong = htonl(l); \ - /* Check rejected value. */ \ - if (cilong != val1) \ - goto bad; \ - neg = 0; \ - } + REJCIADDR((go->old_addrs? CI_ADDRS: CI_ADDR), neg_addr, + go->old_addrs, go->ouraddr, go->hisaddr); -#define REJCIADDR(opt, neg, val) \ - if (neg && \ - len >= 2 + sizeof (long) && \ - p[1] == 2 + sizeof (long) && \ - p[0] == opt) { \ - u_long l; \ - len -= 2 + sizeof (long); \ - INCPTR(2, p); \ - GETLONG(l, p); \ - cilong = htonl(l); \ - /* Check rejected value. */ \ - if (cilong != val) \ - goto bad; \ - neg = 0; \ - } - - REJCIADDRS(CI_ADDRS, go->neg_addrs, go->ouraddr, go->hisaddr) - - REJCIADDR(CI_ADDR, go->neg_addr, go->ouraddr) - - REJCISHORT(CI_COMPRESSTYPE, go->neg_vj, vj_opt_val, go->maxslotindex, go->cflag) + REJCIVJ(CI_COMPRESSTYPE, neg_vj, go->vj_protocol, go->old_vj, + go->maxslotindex, go->cflag); /* * If there are any remaining CIs, then this packet is bad. */ - if (len == 0) - return; + if (len != 0) + goto bad; + /* + * Now we can update state. + */ + if (f->state != OPENED) + *go = try; + return 1; bad: IPCPDEBUG((LOG_INFO, "ipcp_rejci: received bad Reject!")); + return 0; } @@ -682,25 +711,27 @@ bad: * ipcp_reqci - Check the peer's requested CIs and send appropriate response. * * Returns: CONFACK, CONFNAK or CONFREJ and input packet modified - * appropriately. + * appropriately. If reject_if_disagree is non-zero, doesn't return + * CONFNAK; returns CONFREJ if it can't return CONFACK. */ -static u_char - ipcp_reqci(f, inp, len) -fsm *f; -u_char *inp; /* Requested CIs */ -int *len; /* Length of requested CIs */ +static int +ipcp_reqci(f, inp, len, reject_if_disagree) + fsm *f; + u_char *inp; /* Requested CIs */ + int *len; /* Length of requested CIs */ + int reject_if_disagree; { ipcp_options *wo = &ipcp_wantoptions[f->unit]; ipcp_options *ho = &ipcp_hisoptions[f->unit]; ipcp_options *ao = &ipcp_allowoptions[f->unit]; ipcp_options *go = &ipcp_gotoptions[f->unit]; - u_char *cip; /* Pointer to Current CI */ + u_char *cip, *next; /* Pointer to current and next CIs */ u_short cilen, citype; /* Parsed len, type */ u_short cishort; /* Parsed short value */ - u_long tl, ciaddr1, ciaddr2; /* Parsed address values */ + u_long tl, ciaddr1, ciaddr2;/* Parsed address values */ int rc = CONFACK; /* Final packet return code */ int orc; /* Individual option return code */ - u_char *p = inp; /* Pointer to next char to parse */ + u_char *p; /* Pointer to next char to parse */ u_char *ucp = inp; /* Pointer to current output char */ int l = *len; /* Length left */ u_char maxslotindex, cflag; @@ -708,17 +739,15 @@ int *len; /* Length of requested CIs */ /* * Reset all his options. */ - ho->neg_addrs = 0; - ho->neg_vj = 0; - ho->maxslotindex = 0; - ho->cflag = 0; + BZERO(ho, sizeof(*ho)); /* * Process all his options. */ + next = inp; while (l) { orc = CONFACK; /* Assume success */ - cip = p; /* Remember begining of CI */ + cip = p = next; /* Remember begining of CI */ if (l < 2 || /* Not enough data for CI header or */ p[1] < 2 || /* CI length too small or */ p[1] > l) { /* CI length too big? */ @@ -731,15 +760,13 @@ int *len; /* Length of requested CIs */ GETCHAR(citype, p); /* Parse CI type */ GETCHAR(cilen, p); /* Parse CI length */ l -= cilen; /* Adjust remaining length */ - cilen -= 2; /* Adjust cilen to just data */ + next += cilen; /* Step to next CI */ switch (citype) { /* Check CI type */ - case CI_ADDRS: - logf(LOG_INFO, "ipcp: received ADDRS "); - if (!ao->neg_addrs || - cilen != 2 * sizeof (long)) - { /* Check CI length */ - INCPTR(cilen, p); /* Skip rest of CI */ + case CI_ADDRS: + IPCPDEBUG((LOG_INFO, "ipcp: received ADDRS ")); + if (!ao->neg_addr || + cilen != CILEN_ADDRS) { /* Check CI length */ orc = CONFREJ; /* Reject CI */ break; } @@ -752,13 +779,15 @@ int *len; /* Length of requested CIs */ */ GETLONG(tl, p); /* Parse source address (his) */ ciaddr1 = htonl(tl); - if (!ciaddr1 || - (wo->neg_addrs && wo->hisaddr && ciaddr1 != wo->hisaddr)) - { + IPCPDEBUG((LOG_INFO, "(%s:", ip_ntoa(ciaddr1))); + if (ciaddr1 != wo->hisaddr + && (ciaddr1 == 0 || !wo->accept_remote)) { orc = CONFNAK; - DECPTR(sizeof (long), p); - tl = wo->neg_addrs ? ntohl(wo->hisaddr) : 0; - PUTLONG(tl, p); + if (!reject_if_disagree) { + DECPTR(sizeof (long), p); + tl = ntohl(wo->hisaddr); + PUTLONG(tl, p); + } } /* @@ -767,37 +796,35 @@ int *len; /* Length of requested CIs */ */ GETLONG(tl, p); /* Parse desination address (ours) */ ciaddr2 = htonl(tl); - logf(LOG_INFO, "(%s:%s)", ip_ntoa(ciaddr1), ip_ntoa(ciaddr2)); - if (!ciaddr2 || - (wo->neg_addrs && wo->ouraddr && ciaddr2 != wo->ouraddr)) - { - orc = CONFNAK; - DECPTR(sizeof (long), p); - tl = ntohl(wo->ouraddr); - PUTLONG(tl, p); + IPCPDEBUG((LOG_INFO, "%s)", ip_ntoa(ciaddr2))); + if (ciaddr2 != wo->ouraddr) { + if (ciaddr2 == 0 || !wo->accept_local) { + orc = CONFNAK; + if (!reject_if_disagree) { + DECPTR(sizeof (long), p); + tl = ntohl(wo->ouraddr); + PUTLONG(tl, p); + } + } else { + go->ouraddr = ciaddr2; /* accept peer's idea */ + } } - if (orc == CONFNAK) - break; - /* XXX ho or go? */ - ho->neg_addrs = 1; + ho->neg_addr = 1; + ho->old_addrs = 1; ho->hisaddr = ciaddr1; ho->ouraddr = ciaddr2; break; - case CI_ADDR: - logf(LOG_INFO, "ipcp: received ADDR "); - go->got_addr = 1; - go->neg_addrs = 0; - go->neg_addr = 1; + case CI_ADDR: + IPCPDEBUG((LOG_INFO, "ipcp: received ADDR ")); if (!ao->neg_addr || - cilen != sizeof (long)) { /* Check CI length */ - INCPTR(cilen, p); /* Skip rest of CI */ - orc = CONFREJ; /* Reject CI */ + cilen != CILEN_ADDR) { /* Check CI length */ + orc = CONFREJ; /* Reject CI */ break; } - + /* * If he has no address, or if we both have his address but * disagree about it, then NAK it with our idea. @@ -806,86 +833,83 @@ int *len; /* Length of requested CIs */ */ GETLONG(tl, p); /* Parse source address (his) */ ciaddr1 = htonl(tl); - logf(LOG_INFO, "(%s)", ip_ntoa(ciaddr1)); - if (!ciaddr1 || - (wo->neg_addr && wo->hisaddr && ciaddr1 != wo->hisaddr)) { + IPCPDEBUG((LOG_INFO, "(%s)", ip_ntoa(ciaddr1))); + if (ciaddr1 != wo->hisaddr + && (ciaddr1 == 0 || !wo->accept_remote)) { orc = CONFNAK; - DECPTR(sizeof (long), p); - tl = wo->neg_addr ? ntohl(wo->hisaddr) : 0; - PUTLONG(tl, p); + if (!reject_if_disagree) { + DECPTR(sizeof (long), p); + tl = ntohl(wo->hisaddr); + PUTLONG(tl, p); + } } - if (orc == CONFNAK) - break; - - /* XXX ho or go? */ ho->neg_addr = 1; ho->hisaddr = ciaddr1; break; - case CI_COMPRESSTYPE: - logf(LOG_INFO, "ipcp: received COMPRESSTYPE "); + case CI_COMPRESSTYPE: + IPCPDEBUG((LOG_INFO, "ipcp: received COMPRESSTYPE ")); if (!ao->neg_vj || - cilen != (vj_opt_len - 2)) { - INCPTR(cilen, p); + (cilen != CILEN_VJ && cilen != CILEN_COMPRESS)) { orc = CONFREJ; break; } GETSHORT(cishort, p); - logf(LOG_INFO, "(%d)", cishort); + IPCPDEBUG((LOG_INFO, "(%d)", cishort)); - /* - * Compresstype must be vj_opt_val. - */ - if (cishort != vj_opt_val) { - DECPTR(sizeof (short), p); - orc = CONFNAK; - PUTSHORT(vj_opt_val, p); + if (!(cishort == IPCP_VJ_COMP || + (cishort == IPCP_VJ_COMP_OLD && cilen == CILEN_COMPRESS))) { + orc = CONFREJ; break; } - ho->neg_vj = 1; - if (vj_mode == IPCP_VJMODE_RFC1332) { - GETCHAR(maxslotindex, p); - if (maxslotindex > wo->maxslotindex) { - DECPTR(1, p); - orc = CONFNAK; - PUTCHAR(wo->maxslotindex, p); - break; - } - ho->maxslotindex = maxslotindex; - GETCHAR(cflag, p); - if (cflag != wo->cflag) { - DECPTR(1, p); - orc = CONFNAK; - PUTCHAR(wo->cflag, p); - break; - } - ho->cflag = wo->cflag; + ho->neg_vj = 1; + ho->vj_protocol = cishort; + if (cilen == CILEN_VJ) { + GETCHAR(maxslotindex, p); + if (maxslotindex > ao->maxslotindex) { + orc = CONFNAK; + if (!reject_if_disagree){ + DECPTR(1, p); + PUTCHAR(ao->maxslotindex, p); + } + } + GETCHAR(cflag, p); + if (cflag && !ao->cflag) { + orc = CONFNAK; + if (!reject_if_disagree){ + DECPTR(1, p); + PUTCHAR(wo->cflag, p); + } + } + ho->maxslotindex = maxslotindex; + ho->cflag = wo->cflag; } break; - default: - INCPTR(cilen, p); + default: orc = CONFREJ; break; } - cilen += 2; /* Adjust cilen whole CI */ endswitch: - logf(LOG_INFO, " (%s)\n", - orc == CONFACK ? "ACK" : (orc == CONFNAK ? "NAK" : "Reject")); + IPCPDEBUG((LOG_INFO, " (%s)\n", CODENAME(orc))); if (orc == CONFACK && /* Good CI */ rc != CONFACK) /* but prior CI wasnt? */ continue; /* Don't send this one */ if (orc == CONFNAK) { /* Nak this CI? */ - if (rc == CONFREJ) /* Rejecting prior CI? */ - continue; /* Don't send this one */ - if (rc == CONFACK) { /* Ack'd all prior CIs? */ - rc = CONFNAK; /* Not anymore... */ - ucp = inp; /* Backup */ + if (reject_if_disagree) /* Getting fed up with sending NAKs? */ + orc = CONFREJ; /* Get tough if so */ + else { + if (rc == CONFREJ) /* Rejecting prior CI? */ + continue; /* Don't send this one */ + if (rc == CONFACK) { /* Ack'd all prior CIs? */ + rc = CONFNAK; /* Not anymore... */ + ucp = inp; /* Backup */ + } } } @@ -897,72 +921,137 @@ endswitch: /* Need to move CI? */ if (ucp != cip) - /* Move it */ - memcpy(ucp, cip, (size_t)cilen); + BCOPY(cip, ucp, cilen); /* Move it */ /* Update output pointer */ INCPTR(cilen, ucp); } /* - * XXX If we wanted to send additional NAKs (for unsent CIs), the - * code would go here. This must be done with care since it might - * require a longer packet than we received. + * If we aren't rejecting this packet, and we want to negotiate + * their address, and they didn't send their address, then we + * send a NAK with a CI_ADDR option appended. We assume the + * input buffer is long enough that we can append the extra + * option safely. */ + if (rc != CONFREJ && !ho->neg_addr && + wo->req_addr && !reject_if_disagree) { + if (rc == CONFACK) { + rc = CONFNAK; + ucp = inp; /* reset pointer */ + wo->req_addr = 0; /* don't ask again */ + } + PUTCHAR(CI_ADDR, ucp); + PUTCHAR(CILEN_ADDR, ucp); + tl = ntohl(wo->hisaddr); + PUTLONG(tl, ucp); + } *len = ucp - inp; /* Compute output length */ - - syslog(LOG_INFO, "ipcp: returning Configure-%s", - rc == CONFACK ? "ACK" : - rc == CONFNAK ? "NAK" : "Reject"); - + IPCPDEBUG((LOG_INFO, "ipcp: returning Configure-%s", CODENAME(rc))); return (rc); /* Return final code */ } /* * ipcp_up - IPCP has come UP. + * + * Configure the IP network interface appropriately and bring it up. */ static void - ipcp_up(f) -fsm *f; +ipcp_up(f) + fsm *f; { - u_long mask; + u_long mask; + ipcp_options *ho = &ipcp_hisoptions[f->unit]; + ipcp_options *go = &ipcp_gotoptions[f->unit]; - syslog(LOG_INFO, "ipcp: up"); + IPCPDEBUG((LOG_INFO, "ipcp: up")); + go->default_route = 0; + go->proxy_arp = 0; - if (ipcp_hisoptions[f->unit].hisaddr == 0) - ipcp_hisoptions[f->unit].hisaddr = ipcp_wantoptions[f->unit].hisaddr; + /* + * We must have a non-zero IP address for both ends of the link. + */ + if (!ho->neg_addr) + ho->hisaddr = ipcp_wantoptions[f->unit].hisaddr; - syslog(LOG_INFO, "local IP address %s", - ip_ntoa(ipcp_gotoptions[f->unit].ouraddr)); - syslog(LOG_INFO, "remote IP address %s", - ip_ntoa(ipcp_hisoptions[f->unit].hisaddr)); + if (ho->hisaddr == 0) { + syslog(LOG_ERR, "Could not determine remote IP address"); + ipcp_close(f->unit); + return; + } + if (go->ouraddr == 0) { + syslog(LOG_ERR, "Could not determine local IP address"); + ipcp_close(f->unit); + return; + } - SIFADDR(f->unit, ipcp_gotoptions[f->unit].ouraddr, - ipcp_hisoptions[f->unit].hisaddr); + /* + * Check that the peer is allowed to use the IP address he wants. + */ + if (!auth_ip_addr(f->unit, ho->hisaddr)) { + syslog(LOG_ERR, "Peer is not authorized to use remote address %s", + ip_ntoa(ho->hisaddr)); + ipcp_close(f->unit); + return; + } - /* set new netmask if specified */ - mask = GetMask(ipcp_gotoptions[f->unit].ouraddr); - if (mask) - SIFMASK(f->unit, mask); + syslog(LOG_NOTICE, "local IP address %s", ip_ntoa(go->ouraddr)); + syslog(LOG_NOTICE, "remote IP address %s", ip_ntoa(ho->hisaddr)); + + /* + * Set IP addresses and (if specified) netmask. + */ + mask = GetMask(go->ouraddr); + if (!sifaddr(f->unit, go->ouraddr, ho->hisaddr, mask)) { + IPCPDEBUG((LOG_WARNING, "sifaddr failed")); + ipcp_close(f->unit); + return; + } - /* set tcp compression */ - SIFVJCOMP(f->unit, ipcp_hisoptions[f->unit].neg_vj); + /* set tcp compression */ + sifvjcomp(f->unit, ho->neg_vj, ho->cflag); + + /* bring the interface up for IP */ + if (!sifup(f->unit)) { + IPCPDEBUG((LOG_WARNING, "sifup failed")); + ipcp_close(f->unit); + return; + } + + /* assign a default route through the interface if required */ + if (ipcp_wantoptions[f->unit].default_route) + if (sifdefaultroute(f->unit, ho->hisaddr)) + go->default_route = 1; + + /* Make a proxy ARP entry if requested. */ + if (ipcp_wantoptions[f->unit].proxy_arp) + if (sifproxyarp(f->unit, ho->hisaddr)) + go->proxy_arp = 1; } /* * ipcp_down - IPCP has gone DOWN. * - * Alert other protocols. + * Take the IP network interface down, clear its addresses + * and delete routes through it. */ static void - ipcp_down(f) -fsm *f; +ipcp_down(f) + fsm *f; { - syslog(LOG_INFO, "ipcp: down"); - - CIFADDR(f->unit, ipcp_gotoptions[f->unit].ouraddr, - ipcp_hisoptions[f->unit].hisaddr); + u_long ouraddr, hisaddr; + + IPCPDEBUG((LOG_INFO, "ipcp: down")); + + ouraddr = ipcp_gotoptions[f->unit].ouraddr; + hisaddr = ipcp_hisoptions[f->unit].hisaddr; + if (ipcp_gotoptions[f->unit].proxy_arp) + cifproxyarp(f->unit, hisaddr); + if (ipcp_gotoptions[f->unit].default_route) + cifdefaultroute(f->unit, hisaddr); + sifdown(f->unit); + cifaddr(f->unit, ouraddr, hisaddr); } |