1*10465441SEvalZero /*
2*10465441SEvalZero * fsm.c - {Link, IP} Control Protocol Finite State Machine.
3*10465441SEvalZero *
4*10465441SEvalZero * Copyright (c) 1984-2000 Carnegie Mellon University. All rights reserved.
5*10465441SEvalZero *
6*10465441SEvalZero * Redistribution and use in source and binary forms, with or without
7*10465441SEvalZero * modification, are permitted provided that the following conditions
8*10465441SEvalZero * are met:
9*10465441SEvalZero *
10*10465441SEvalZero * 1. Redistributions of source code must retain the above copyright
11*10465441SEvalZero * notice, this list of conditions and the following disclaimer.
12*10465441SEvalZero *
13*10465441SEvalZero * 2. Redistributions in binary form must reproduce the above copyright
14*10465441SEvalZero * notice, this list of conditions and the following disclaimer in
15*10465441SEvalZero * the documentation and/or other materials provided with the
16*10465441SEvalZero * distribution.
17*10465441SEvalZero *
18*10465441SEvalZero * 3. The name "Carnegie Mellon University" must not be used to
19*10465441SEvalZero * endorse or promote products derived from this software without
20*10465441SEvalZero * prior written permission. For permission or any legal
21*10465441SEvalZero * details, please contact
22*10465441SEvalZero * Office of Technology Transfer
23*10465441SEvalZero * Carnegie Mellon University
24*10465441SEvalZero * 5000 Forbes Avenue
25*10465441SEvalZero * Pittsburgh, PA 15213-3890
26*10465441SEvalZero * (412) 268-4387, fax: (412) 268-7395
27*10465441SEvalZero * [email protected]
28*10465441SEvalZero *
29*10465441SEvalZero * 4. Redistributions of any form whatsoever must retain the following
30*10465441SEvalZero * acknowledgment:
31*10465441SEvalZero * "This product includes software developed by Computing Services
32*10465441SEvalZero * at Carnegie Mellon University (http://www.cmu.edu/computing/)."
33*10465441SEvalZero *
34*10465441SEvalZero * CARNEGIE MELLON UNIVERSITY DISCLAIMS ALL WARRANTIES WITH REGARD TO
35*10465441SEvalZero * THIS SOFTWARE, INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
36*10465441SEvalZero * AND FITNESS, IN NO EVENT SHALL CARNEGIE MELLON UNIVERSITY BE LIABLE
37*10465441SEvalZero * FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
38*10465441SEvalZero * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN
39*10465441SEvalZero * AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
40*10465441SEvalZero * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
41*10465441SEvalZero */
42*10465441SEvalZero
43*10465441SEvalZero #include "netif/ppp/ppp_opts.h"
44*10465441SEvalZero #if PPP_SUPPORT /* don't build if not configured for use in lwipopts.h */
45*10465441SEvalZero
46*10465441SEvalZero /*
47*10465441SEvalZero * @todo:
48*10465441SEvalZero * Randomize fsm id on link/init.
49*10465441SEvalZero * Deal with variable outgoing MTU.
50*10465441SEvalZero */
51*10465441SEvalZero
52*10465441SEvalZero #if 0 /* UNUSED */
53*10465441SEvalZero #include <stdio.h>
54*10465441SEvalZero #include <string.h>
55*10465441SEvalZero #include <sys/types.h>
56*10465441SEvalZero #endif /* UNUSED */
57*10465441SEvalZero
58*10465441SEvalZero #include "netif/ppp/ppp_impl.h"
59*10465441SEvalZero
60*10465441SEvalZero #include "netif/ppp/fsm.h"
61*10465441SEvalZero
62*10465441SEvalZero static void fsm_timeout (void *);
63*10465441SEvalZero static void fsm_rconfreq(fsm *f, u_char id, u_char *inp, int len);
64*10465441SEvalZero static void fsm_rconfack(fsm *f, int id, u_char *inp, int len);
65*10465441SEvalZero static void fsm_rconfnakrej(fsm *f, int code, int id, u_char *inp, int len);
66*10465441SEvalZero static void fsm_rtermreq(fsm *f, int id, u_char *p, int len);
67*10465441SEvalZero static void fsm_rtermack(fsm *f);
68*10465441SEvalZero static void fsm_rcoderej(fsm *f, u_char *inp, int len);
69*10465441SEvalZero static void fsm_sconfreq(fsm *f, int retransmit);
70*10465441SEvalZero
71*10465441SEvalZero #define PROTO_NAME(f) ((f)->callbacks->proto_name)
72*10465441SEvalZero
73*10465441SEvalZero /*
74*10465441SEvalZero * fsm_init - Initialize fsm.
75*10465441SEvalZero *
76*10465441SEvalZero * Initialize fsm state.
77*10465441SEvalZero */
fsm_init(fsm * f)78*10465441SEvalZero void fsm_init(fsm *f) {
79*10465441SEvalZero ppp_pcb *pcb = f->pcb;
80*10465441SEvalZero f->state = PPP_FSM_INITIAL;
81*10465441SEvalZero f->flags = 0;
82*10465441SEvalZero f->id = 0; /* XXX Start with random id? */
83*10465441SEvalZero f->maxnakloops = pcb->settings.fsm_max_nak_loops;
84*10465441SEvalZero f->term_reason_len = 0;
85*10465441SEvalZero }
86*10465441SEvalZero
87*10465441SEvalZero
88*10465441SEvalZero /*
89*10465441SEvalZero * fsm_lowerup - The lower layer is up.
90*10465441SEvalZero */
fsm_lowerup(fsm * f)91*10465441SEvalZero void fsm_lowerup(fsm *f) {
92*10465441SEvalZero switch( f->state ){
93*10465441SEvalZero case PPP_FSM_INITIAL:
94*10465441SEvalZero f->state = PPP_FSM_CLOSED;
95*10465441SEvalZero break;
96*10465441SEvalZero
97*10465441SEvalZero case PPP_FSM_STARTING:
98*10465441SEvalZero if( f->flags & OPT_SILENT )
99*10465441SEvalZero f->state = PPP_FSM_STOPPED;
100*10465441SEvalZero else {
101*10465441SEvalZero /* Send an initial configure-request */
102*10465441SEvalZero fsm_sconfreq(f, 0);
103*10465441SEvalZero f->state = PPP_FSM_REQSENT;
104*10465441SEvalZero }
105*10465441SEvalZero break;
106*10465441SEvalZero
107*10465441SEvalZero default:
108*10465441SEvalZero FSMDEBUG(("%s: Up event in state %d!", PROTO_NAME(f), f->state));
109*10465441SEvalZero /* no break */
110*10465441SEvalZero }
111*10465441SEvalZero }
112*10465441SEvalZero
113*10465441SEvalZero
114*10465441SEvalZero /*
115*10465441SEvalZero * fsm_lowerdown - The lower layer is down.
116*10465441SEvalZero *
117*10465441SEvalZero * Cancel all timeouts and inform upper layers.
118*10465441SEvalZero */
fsm_lowerdown(fsm * f)119*10465441SEvalZero void fsm_lowerdown(fsm *f) {
120*10465441SEvalZero switch( f->state ){
121*10465441SEvalZero case PPP_FSM_CLOSED:
122*10465441SEvalZero f->state = PPP_FSM_INITIAL;
123*10465441SEvalZero break;
124*10465441SEvalZero
125*10465441SEvalZero case PPP_FSM_STOPPED:
126*10465441SEvalZero f->state = PPP_FSM_STARTING;
127*10465441SEvalZero if( f->callbacks->starting )
128*10465441SEvalZero (*f->callbacks->starting)(f);
129*10465441SEvalZero break;
130*10465441SEvalZero
131*10465441SEvalZero case PPP_FSM_CLOSING:
132*10465441SEvalZero f->state = PPP_FSM_INITIAL;
133*10465441SEvalZero UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
134*10465441SEvalZero break;
135*10465441SEvalZero
136*10465441SEvalZero case PPP_FSM_STOPPING:
137*10465441SEvalZero case PPP_FSM_REQSENT:
138*10465441SEvalZero case PPP_FSM_ACKRCVD:
139*10465441SEvalZero case PPP_FSM_ACKSENT:
140*10465441SEvalZero f->state = PPP_FSM_STARTING;
141*10465441SEvalZero UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
142*10465441SEvalZero break;
143*10465441SEvalZero
144*10465441SEvalZero case PPP_FSM_OPENED:
145*10465441SEvalZero if( f->callbacks->down )
146*10465441SEvalZero (*f->callbacks->down)(f);
147*10465441SEvalZero f->state = PPP_FSM_STARTING;
148*10465441SEvalZero break;
149*10465441SEvalZero
150*10465441SEvalZero default:
151*10465441SEvalZero FSMDEBUG(("%s: Down event in state %d!", PROTO_NAME(f), f->state));
152*10465441SEvalZero /* no break */
153*10465441SEvalZero }
154*10465441SEvalZero }
155*10465441SEvalZero
156*10465441SEvalZero
157*10465441SEvalZero /*
158*10465441SEvalZero * fsm_open - Link is allowed to come up.
159*10465441SEvalZero */
fsm_open(fsm * f)160*10465441SEvalZero void fsm_open(fsm *f) {
161*10465441SEvalZero switch( f->state ){
162*10465441SEvalZero case PPP_FSM_INITIAL:
163*10465441SEvalZero f->state = PPP_FSM_STARTING;
164*10465441SEvalZero if( f->callbacks->starting )
165*10465441SEvalZero (*f->callbacks->starting)(f);
166*10465441SEvalZero break;
167*10465441SEvalZero
168*10465441SEvalZero case PPP_FSM_CLOSED:
169*10465441SEvalZero if( f->flags & OPT_SILENT )
170*10465441SEvalZero f->state = PPP_FSM_STOPPED;
171*10465441SEvalZero else {
172*10465441SEvalZero /* Send an initial configure-request */
173*10465441SEvalZero fsm_sconfreq(f, 0);
174*10465441SEvalZero f->state = PPP_FSM_REQSENT;
175*10465441SEvalZero }
176*10465441SEvalZero break;
177*10465441SEvalZero
178*10465441SEvalZero case PPP_FSM_CLOSING:
179*10465441SEvalZero f->state = PPP_FSM_STOPPING;
180*10465441SEvalZero /* fall through */
181*10465441SEvalZero /* no break */
182*10465441SEvalZero case PPP_FSM_STOPPED:
183*10465441SEvalZero case PPP_FSM_OPENED:
184*10465441SEvalZero if( f->flags & OPT_RESTART ){
185*10465441SEvalZero fsm_lowerdown(f);
186*10465441SEvalZero fsm_lowerup(f);
187*10465441SEvalZero }
188*10465441SEvalZero break;
189*10465441SEvalZero default:
190*10465441SEvalZero break;
191*10465441SEvalZero }
192*10465441SEvalZero }
193*10465441SEvalZero
194*10465441SEvalZero /*
195*10465441SEvalZero * terminate_layer - Start process of shutting down the FSM
196*10465441SEvalZero *
197*10465441SEvalZero * Cancel any timeout running, notify upper layers we're done, and
198*10465441SEvalZero * send a terminate-request message as configured.
199*10465441SEvalZero */
terminate_layer(fsm * f,int nextstate)200*10465441SEvalZero static void terminate_layer(fsm *f, int nextstate) {
201*10465441SEvalZero ppp_pcb *pcb = f->pcb;
202*10465441SEvalZero
203*10465441SEvalZero if( f->state != PPP_FSM_OPENED )
204*10465441SEvalZero UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
205*10465441SEvalZero else if( f->callbacks->down )
206*10465441SEvalZero (*f->callbacks->down)(f); /* Inform upper layers we're down */
207*10465441SEvalZero
208*10465441SEvalZero /* Init restart counter and send Terminate-Request */
209*10465441SEvalZero f->retransmits = pcb->settings.fsm_max_term_transmits;
210*10465441SEvalZero fsm_sdata(f, TERMREQ, f->reqid = ++f->id,
211*10465441SEvalZero (const u_char *) f->term_reason, f->term_reason_len);
212*10465441SEvalZero
213*10465441SEvalZero if (f->retransmits == 0) {
214*10465441SEvalZero /*
215*10465441SEvalZero * User asked for no terminate requests at all; just close it.
216*10465441SEvalZero * We've already fired off one Terminate-Request just to be nice
217*10465441SEvalZero * to the peer, but we're not going to wait for a reply.
218*10465441SEvalZero */
219*10465441SEvalZero f->state = nextstate == PPP_FSM_CLOSING ? PPP_FSM_CLOSED : PPP_FSM_STOPPED;
220*10465441SEvalZero if( f->callbacks->finished )
221*10465441SEvalZero (*f->callbacks->finished)(f);
222*10465441SEvalZero return;
223*10465441SEvalZero }
224*10465441SEvalZero
225*10465441SEvalZero TIMEOUT(fsm_timeout, f, pcb->settings.fsm_timeout_time);
226*10465441SEvalZero --f->retransmits;
227*10465441SEvalZero
228*10465441SEvalZero f->state = nextstate;
229*10465441SEvalZero }
230*10465441SEvalZero
231*10465441SEvalZero /*
232*10465441SEvalZero * fsm_close - Start closing connection.
233*10465441SEvalZero *
234*10465441SEvalZero * Cancel timeouts and either initiate close or possibly go directly to
235*10465441SEvalZero * the PPP_FSM_CLOSED state.
236*10465441SEvalZero */
fsm_close(fsm * f,const char * reason)237*10465441SEvalZero void fsm_close(fsm *f, const char *reason) {
238*10465441SEvalZero f->term_reason = reason;
239*10465441SEvalZero f->term_reason_len = (reason == NULL? 0: (u8_t)LWIP_MIN(strlen(reason), 0xFF) );
240*10465441SEvalZero switch( f->state ){
241*10465441SEvalZero case PPP_FSM_STARTING:
242*10465441SEvalZero f->state = PPP_FSM_INITIAL;
243*10465441SEvalZero break;
244*10465441SEvalZero case PPP_FSM_STOPPED:
245*10465441SEvalZero f->state = PPP_FSM_CLOSED;
246*10465441SEvalZero break;
247*10465441SEvalZero case PPP_FSM_STOPPING:
248*10465441SEvalZero f->state = PPP_FSM_CLOSING;
249*10465441SEvalZero break;
250*10465441SEvalZero
251*10465441SEvalZero case PPP_FSM_REQSENT:
252*10465441SEvalZero case PPP_FSM_ACKRCVD:
253*10465441SEvalZero case PPP_FSM_ACKSENT:
254*10465441SEvalZero case PPP_FSM_OPENED:
255*10465441SEvalZero terminate_layer(f, PPP_FSM_CLOSING);
256*10465441SEvalZero break;
257*10465441SEvalZero default:
258*10465441SEvalZero break;
259*10465441SEvalZero }
260*10465441SEvalZero }
261*10465441SEvalZero
262*10465441SEvalZero
263*10465441SEvalZero /*
264*10465441SEvalZero * fsm_timeout - Timeout expired.
265*10465441SEvalZero */
fsm_timeout(void * arg)266*10465441SEvalZero static void fsm_timeout(void *arg) {
267*10465441SEvalZero fsm *f = (fsm *) arg;
268*10465441SEvalZero ppp_pcb *pcb = f->pcb;
269*10465441SEvalZero
270*10465441SEvalZero switch (f->state) {
271*10465441SEvalZero case PPP_FSM_CLOSING:
272*10465441SEvalZero case PPP_FSM_STOPPING:
273*10465441SEvalZero if( f->retransmits <= 0 ){
274*10465441SEvalZero /*
275*10465441SEvalZero * We've waited for an ack long enough. Peer probably heard us.
276*10465441SEvalZero */
277*10465441SEvalZero f->state = (f->state == PPP_FSM_CLOSING)? PPP_FSM_CLOSED: PPP_FSM_STOPPED;
278*10465441SEvalZero if( f->callbacks->finished )
279*10465441SEvalZero (*f->callbacks->finished)(f);
280*10465441SEvalZero } else {
281*10465441SEvalZero /* Send Terminate-Request */
282*10465441SEvalZero fsm_sdata(f, TERMREQ, f->reqid = ++f->id,
283*10465441SEvalZero (const u_char *) f->term_reason, f->term_reason_len);
284*10465441SEvalZero TIMEOUT(fsm_timeout, f, pcb->settings.fsm_timeout_time);
285*10465441SEvalZero --f->retransmits;
286*10465441SEvalZero }
287*10465441SEvalZero break;
288*10465441SEvalZero
289*10465441SEvalZero case PPP_FSM_REQSENT:
290*10465441SEvalZero case PPP_FSM_ACKRCVD:
291*10465441SEvalZero case PPP_FSM_ACKSENT:
292*10465441SEvalZero if (f->retransmits <= 0) {
293*10465441SEvalZero ppp_warn("%s: timeout sending Config-Requests", PROTO_NAME(f));
294*10465441SEvalZero f->state = PPP_FSM_STOPPED;
295*10465441SEvalZero if( (f->flags & OPT_PASSIVE) == 0 && f->callbacks->finished )
296*10465441SEvalZero (*f->callbacks->finished)(f);
297*10465441SEvalZero
298*10465441SEvalZero } else {
299*10465441SEvalZero /* Retransmit the configure-request */
300*10465441SEvalZero if (f->callbacks->retransmit)
301*10465441SEvalZero (*f->callbacks->retransmit)(f);
302*10465441SEvalZero fsm_sconfreq(f, 1); /* Re-send Configure-Request */
303*10465441SEvalZero if( f->state == PPP_FSM_ACKRCVD )
304*10465441SEvalZero f->state = PPP_FSM_REQSENT;
305*10465441SEvalZero }
306*10465441SEvalZero break;
307*10465441SEvalZero
308*10465441SEvalZero default:
309*10465441SEvalZero FSMDEBUG(("%s: Timeout event in state %d!", PROTO_NAME(f), f->state));
310*10465441SEvalZero /* no break */
311*10465441SEvalZero }
312*10465441SEvalZero }
313*10465441SEvalZero
314*10465441SEvalZero
315*10465441SEvalZero /*
316*10465441SEvalZero * fsm_input - Input packet.
317*10465441SEvalZero */
fsm_input(fsm * f,u_char * inpacket,int l)318*10465441SEvalZero void fsm_input(fsm *f, u_char *inpacket, int l) {
319*10465441SEvalZero u_char *inp;
320*10465441SEvalZero u_char code, id;
321*10465441SEvalZero int len;
322*10465441SEvalZero
323*10465441SEvalZero /*
324*10465441SEvalZero * Parse header (code, id and length).
325*10465441SEvalZero * If packet too short, drop it.
326*10465441SEvalZero */
327*10465441SEvalZero inp = inpacket;
328*10465441SEvalZero if (l < HEADERLEN) {
329*10465441SEvalZero FSMDEBUG(("fsm_input(%x): Rcvd short header.", f->protocol));
330*10465441SEvalZero return;
331*10465441SEvalZero }
332*10465441SEvalZero GETCHAR(code, inp);
333*10465441SEvalZero GETCHAR(id, inp);
334*10465441SEvalZero GETSHORT(len, inp);
335*10465441SEvalZero if (len < HEADERLEN) {
336*10465441SEvalZero FSMDEBUG(("fsm_input(%x): Rcvd illegal length.", f->protocol));
337*10465441SEvalZero return;
338*10465441SEvalZero }
339*10465441SEvalZero if (len > l) {
340*10465441SEvalZero FSMDEBUG(("fsm_input(%x): Rcvd short packet.", f->protocol));
341*10465441SEvalZero return;
342*10465441SEvalZero }
343*10465441SEvalZero len -= HEADERLEN; /* subtract header length */
344*10465441SEvalZero
345*10465441SEvalZero if( f->state == PPP_FSM_INITIAL || f->state == PPP_FSM_STARTING ){
346*10465441SEvalZero FSMDEBUG(("fsm_input(%x): Rcvd packet in state %d.",
347*10465441SEvalZero f->protocol, f->state));
348*10465441SEvalZero return;
349*10465441SEvalZero }
350*10465441SEvalZero
351*10465441SEvalZero /*
352*10465441SEvalZero * Action depends on code.
353*10465441SEvalZero */
354*10465441SEvalZero switch (code) {
355*10465441SEvalZero case CONFREQ:
356*10465441SEvalZero fsm_rconfreq(f, id, inp, len);
357*10465441SEvalZero break;
358*10465441SEvalZero
359*10465441SEvalZero case CONFACK:
360*10465441SEvalZero fsm_rconfack(f, id, inp, len);
361*10465441SEvalZero break;
362*10465441SEvalZero
363*10465441SEvalZero case CONFNAK:
364*10465441SEvalZero case CONFREJ:
365*10465441SEvalZero fsm_rconfnakrej(f, code, id, inp, len);
366*10465441SEvalZero break;
367*10465441SEvalZero
368*10465441SEvalZero case TERMREQ:
369*10465441SEvalZero fsm_rtermreq(f, id, inp, len);
370*10465441SEvalZero break;
371*10465441SEvalZero
372*10465441SEvalZero case TERMACK:
373*10465441SEvalZero fsm_rtermack(f);
374*10465441SEvalZero break;
375*10465441SEvalZero
376*10465441SEvalZero case CODEREJ:
377*10465441SEvalZero fsm_rcoderej(f, inp, len);
378*10465441SEvalZero break;
379*10465441SEvalZero
380*10465441SEvalZero default:
381*10465441SEvalZero if( !f->callbacks->extcode
382*10465441SEvalZero || !(*f->callbacks->extcode)(f, code, id, inp, len) )
383*10465441SEvalZero fsm_sdata(f, CODEREJ, ++f->id, inpacket, len + HEADERLEN);
384*10465441SEvalZero break;
385*10465441SEvalZero }
386*10465441SEvalZero }
387*10465441SEvalZero
388*10465441SEvalZero
389*10465441SEvalZero /*
390*10465441SEvalZero * fsm_rconfreq - Receive Configure-Request.
391*10465441SEvalZero */
fsm_rconfreq(fsm * f,u_char id,u_char * inp,int len)392*10465441SEvalZero static void fsm_rconfreq(fsm *f, u_char id, u_char *inp, int len) {
393*10465441SEvalZero int code, reject_if_disagree;
394*10465441SEvalZero
395*10465441SEvalZero switch( f->state ){
396*10465441SEvalZero case PPP_FSM_CLOSED:
397*10465441SEvalZero /* Go away, we're closed */
398*10465441SEvalZero fsm_sdata(f, TERMACK, id, NULL, 0);
399*10465441SEvalZero return;
400*10465441SEvalZero case PPP_FSM_CLOSING:
401*10465441SEvalZero case PPP_FSM_STOPPING:
402*10465441SEvalZero return;
403*10465441SEvalZero
404*10465441SEvalZero case PPP_FSM_OPENED:
405*10465441SEvalZero /* Go down and restart negotiation */
406*10465441SEvalZero if( f->callbacks->down )
407*10465441SEvalZero (*f->callbacks->down)(f); /* Inform upper layers */
408*10465441SEvalZero fsm_sconfreq(f, 0); /* Send initial Configure-Request */
409*10465441SEvalZero f->state = PPP_FSM_REQSENT;
410*10465441SEvalZero break;
411*10465441SEvalZero
412*10465441SEvalZero case PPP_FSM_STOPPED:
413*10465441SEvalZero /* Negotiation started by our peer */
414*10465441SEvalZero fsm_sconfreq(f, 0); /* Send initial Configure-Request */
415*10465441SEvalZero f->state = PPP_FSM_REQSENT;
416*10465441SEvalZero break;
417*10465441SEvalZero default:
418*10465441SEvalZero break;
419*10465441SEvalZero }
420*10465441SEvalZero
421*10465441SEvalZero /*
422*10465441SEvalZero * Pass the requested configuration options
423*10465441SEvalZero * to protocol-specific code for checking.
424*10465441SEvalZero */
425*10465441SEvalZero if (f->callbacks->reqci){ /* Check CI */
426*10465441SEvalZero reject_if_disagree = (f->nakloops >= f->maxnakloops);
427*10465441SEvalZero code = (*f->callbacks->reqci)(f, inp, &len, reject_if_disagree);
428*10465441SEvalZero } else if (len)
429*10465441SEvalZero code = CONFREJ; /* Reject all CI */
430*10465441SEvalZero else
431*10465441SEvalZero code = CONFACK;
432*10465441SEvalZero
433*10465441SEvalZero /* send the Ack, Nak or Rej to the peer */
434*10465441SEvalZero fsm_sdata(f, code, id, inp, len);
435*10465441SEvalZero
436*10465441SEvalZero if (code == CONFACK) {
437*10465441SEvalZero if (f->state == PPP_FSM_ACKRCVD) {
438*10465441SEvalZero UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
439*10465441SEvalZero f->state = PPP_FSM_OPENED;
440*10465441SEvalZero if (f->callbacks->up)
441*10465441SEvalZero (*f->callbacks->up)(f); /* Inform upper layers */
442*10465441SEvalZero } else
443*10465441SEvalZero f->state = PPP_FSM_ACKSENT;
444*10465441SEvalZero f->nakloops = 0;
445*10465441SEvalZero
446*10465441SEvalZero } else {
447*10465441SEvalZero /* we sent CONFACK or CONFREJ */
448*10465441SEvalZero if (f->state != PPP_FSM_ACKRCVD)
449*10465441SEvalZero f->state = PPP_FSM_REQSENT;
450*10465441SEvalZero if( code == CONFNAK )
451*10465441SEvalZero ++f->nakloops;
452*10465441SEvalZero }
453*10465441SEvalZero }
454*10465441SEvalZero
455*10465441SEvalZero
456*10465441SEvalZero /*
457*10465441SEvalZero * fsm_rconfack - Receive Configure-Ack.
458*10465441SEvalZero */
fsm_rconfack(fsm * f,int id,u_char * inp,int len)459*10465441SEvalZero static void fsm_rconfack(fsm *f, int id, u_char *inp, int len) {
460*10465441SEvalZero ppp_pcb *pcb = f->pcb;
461*10465441SEvalZero
462*10465441SEvalZero if (id != f->reqid || f->seen_ack) /* Expected id? */
463*10465441SEvalZero return; /* Nope, toss... */
464*10465441SEvalZero if( !(f->callbacks->ackci? (*f->callbacks->ackci)(f, inp, len):
465*10465441SEvalZero (len == 0)) ){
466*10465441SEvalZero /* Ack is bad - ignore it */
467*10465441SEvalZero ppp_error("Received bad configure-ack: %P", inp, len);
468*10465441SEvalZero return;
469*10465441SEvalZero }
470*10465441SEvalZero f->seen_ack = 1;
471*10465441SEvalZero f->rnakloops = 0;
472*10465441SEvalZero
473*10465441SEvalZero switch (f->state) {
474*10465441SEvalZero case PPP_FSM_CLOSED:
475*10465441SEvalZero case PPP_FSM_STOPPED:
476*10465441SEvalZero fsm_sdata(f, TERMACK, id, NULL, 0);
477*10465441SEvalZero break;
478*10465441SEvalZero
479*10465441SEvalZero case PPP_FSM_REQSENT:
480*10465441SEvalZero f->state = PPP_FSM_ACKRCVD;
481*10465441SEvalZero f->retransmits = pcb->settings.fsm_max_conf_req_transmits;
482*10465441SEvalZero break;
483*10465441SEvalZero
484*10465441SEvalZero case PPP_FSM_ACKRCVD:
485*10465441SEvalZero /* Huh? an extra valid Ack? oh well... */
486*10465441SEvalZero UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
487*10465441SEvalZero fsm_sconfreq(f, 0);
488*10465441SEvalZero f->state = PPP_FSM_REQSENT;
489*10465441SEvalZero break;
490*10465441SEvalZero
491*10465441SEvalZero case PPP_FSM_ACKSENT:
492*10465441SEvalZero UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
493*10465441SEvalZero f->state = PPP_FSM_OPENED;
494*10465441SEvalZero f->retransmits = pcb->settings.fsm_max_conf_req_transmits;
495*10465441SEvalZero if (f->callbacks->up)
496*10465441SEvalZero (*f->callbacks->up)(f); /* Inform upper layers */
497*10465441SEvalZero break;
498*10465441SEvalZero
499*10465441SEvalZero case PPP_FSM_OPENED:
500*10465441SEvalZero /* Go down and restart negotiation */
501*10465441SEvalZero if (f->callbacks->down)
502*10465441SEvalZero (*f->callbacks->down)(f); /* Inform upper layers */
503*10465441SEvalZero fsm_sconfreq(f, 0); /* Send initial Configure-Request */
504*10465441SEvalZero f->state = PPP_FSM_REQSENT;
505*10465441SEvalZero break;
506*10465441SEvalZero default:
507*10465441SEvalZero break;
508*10465441SEvalZero }
509*10465441SEvalZero }
510*10465441SEvalZero
511*10465441SEvalZero
512*10465441SEvalZero /*
513*10465441SEvalZero * fsm_rconfnakrej - Receive Configure-Nak or Configure-Reject.
514*10465441SEvalZero */
fsm_rconfnakrej(fsm * f,int code,int id,u_char * inp,int len)515*10465441SEvalZero static void fsm_rconfnakrej(fsm *f, int code, int id, u_char *inp, int len) {
516*10465441SEvalZero int ret;
517*10465441SEvalZero int treat_as_reject;
518*10465441SEvalZero
519*10465441SEvalZero if (id != f->reqid || f->seen_ack) /* Expected id? */
520*10465441SEvalZero return; /* Nope, toss... */
521*10465441SEvalZero
522*10465441SEvalZero if (code == CONFNAK) {
523*10465441SEvalZero ++f->rnakloops;
524*10465441SEvalZero treat_as_reject = (f->rnakloops >= f->maxnakloops);
525*10465441SEvalZero if (f->callbacks->nakci == NULL
526*10465441SEvalZero || !(ret = f->callbacks->nakci(f, inp, len, treat_as_reject))) {
527*10465441SEvalZero ppp_error("Received bad configure-nak: %P", inp, len);
528*10465441SEvalZero return;
529*10465441SEvalZero }
530*10465441SEvalZero } else {
531*10465441SEvalZero f->rnakloops = 0;
532*10465441SEvalZero if (f->callbacks->rejci == NULL
533*10465441SEvalZero || !(ret = f->callbacks->rejci(f, inp, len))) {
534*10465441SEvalZero ppp_error("Received bad configure-rej: %P", inp, len);
535*10465441SEvalZero return;
536*10465441SEvalZero }
537*10465441SEvalZero }
538*10465441SEvalZero
539*10465441SEvalZero f->seen_ack = 1;
540*10465441SEvalZero
541*10465441SEvalZero switch (f->state) {
542*10465441SEvalZero case PPP_FSM_CLOSED:
543*10465441SEvalZero case PPP_FSM_STOPPED:
544*10465441SEvalZero fsm_sdata(f, TERMACK, id, NULL, 0);
545*10465441SEvalZero break;
546*10465441SEvalZero
547*10465441SEvalZero case PPP_FSM_REQSENT:
548*10465441SEvalZero case PPP_FSM_ACKSENT:
549*10465441SEvalZero /* They didn't agree to what we wanted - try another request */
550*10465441SEvalZero UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
551*10465441SEvalZero if (ret < 0)
552*10465441SEvalZero f->state = PPP_FSM_STOPPED; /* kludge for stopping CCP */
553*10465441SEvalZero else
554*10465441SEvalZero fsm_sconfreq(f, 0); /* Send Configure-Request */
555*10465441SEvalZero break;
556*10465441SEvalZero
557*10465441SEvalZero case PPP_FSM_ACKRCVD:
558*10465441SEvalZero /* Got a Nak/reject when we had already had an Ack?? oh well... */
559*10465441SEvalZero UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
560*10465441SEvalZero fsm_sconfreq(f, 0);
561*10465441SEvalZero f->state = PPP_FSM_REQSENT;
562*10465441SEvalZero break;
563*10465441SEvalZero
564*10465441SEvalZero case PPP_FSM_OPENED:
565*10465441SEvalZero /* Go down and restart negotiation */
566*10465441SEvalZero if (f->callbacks->down)
567*10465441SEvalZero (*f->callbacks->down)(f); /* Inform upper layers */
568*10465441SEvalZero fsm_sconfreq(f, 0); /* Send initial Configure-Request */
569*10465441SEvalZero f->state = PPP_FSM_REQSENT;
570*10465441SEvalZero break;
571*10465441SEvalZero default:
572*10465441SEvalZero break;
573*10465441SEvalZero }
574*10465441SEvalZero }
575*10465441SEvalZero
576*10465441SEvalZero
577*10465441SEvalZero /*
578*10465441SEvalZero * fsm_rtermreq - Receive Terminate-Req.
579*10465441SEvalZero */
fsm_rtermreq(fsm * f,int id,u_char * p,int len)580*10465441SEvalZero static void fsm_rtermreq(fsm *f, int id, u_char *p, int len) {
581*10465441SEvalZero ppp_pcb *pcb = f->pcb;
582*10465441SEvalZero
583*10465441SEvalZero switch (f->state) {
584*10465441SEvalZero case PPP_FSM_ACKRCVD:
585*10465441SEvalZero case PPP_FSM_ACKSENT:
586*10465441SEvalZero f->state = PPP_FSM_REQSENT; /* Start over but keep trying */
587*10465441SEvalZero break;
588*10465441SEvalZero
589*10465441SEvalZero case PPP_FSM_OPENED:
590*10465441SEvalZero if (len > 0) {
591*10465441SEvalZero ppp_info("%s terminated by peer (%0.*v)", PROTO_NAME(f), len, p);
592*10465441SEvalZero } else
593*10465441SEvalZero ppp_info("%s terminated by peer", PROTO_NAME(f));
594*10465441SEvalZero f->retransmits = 0;
595*10465441SEvalZero f->state = PPP_FSM_STOPPING;
596*10465441SEvalZero if (f->callbacks->down)
597*10465441SEvalZero (*f->callbacks->down)(f); /* Inform upper layers */
598*10465441SEvalZero TIMEOUT(fsm_timeout, f, pcb->settings.fsm_timeout_time);
599*10465441SEvalZero break;
600*10465441SEvalZero default:
601*10465441SEvalZero break;
602*10465441SEvalZero }
603*10465441SEvalZero
604*10465441SEvalZero fsm_sdata(f, TERMACK, id, NULL, 0);
605*10465441SEvalZero }
606*10465441SEvalZero
607*10465441SEvalZero
608*10465441SEvalZero /*
609*10465441SEvalZero * fsm_rtermack - Receive Terminate-Ack.
610*10465441SEvalZero */
fsm_rtermack(fsm * f)611*10465441SEvalZero static void fsm_rtermack(fsm *f) {
612*10465441SEvalZero switch (f->state) {
613*10465441SEvalZero case PPP_FSM_CLOSING:
614*10465441SEvalZero UNTIMEOUT(fsm_timeout, f);
615*10465441SEvalZero f->state = PPP_FSM_CLOSED;
616*10465441SEvalZero if( f->callbacks->finished )
617*10465441SEvalZero (*f->callbacks->finished)(f);
618*10465441SEvalZero break;
619*10465441SEvalZero case PPP_FSM_STOPPING:
620*10465441SEvalZero UNTIMEOUT(fsm_timeout, f);
621*10465441SEvalZero f->state = PPP_FSM_STOPPED;
622*10465441SEvalZero if( f->callbacks->finished )
623*10465441SEvalZero (*f->callbacks->finished)(f);
624*10465441SEvalZero break;
625*10465441SEvalZero
626*10465441SEvalZero case PPP_FSM_ACKRCVD:
627*10465441SEvalZero f->state = PPP_FSM_REQSENT;
628*10465441SEvalZero break;
629*10465441SEvalZero
630*10465441SEvalZero case PPP_FSM_OPENED:
631*10465441SEvalZero if (f->callbacks->down)
632*10465441SEvalZero (*f->callbacks->down)(f); /* Inform upper layers */
633*10465441SEvalZero fsm_sconfreq(f, 0);
634*10465441SEvalZero f->state = PPP_FSM_REQSENT;
635*10465441SEvalZero break;
636*10465441SEvalZero default:
637*10465441SEvalZero break;
638*10465441SEvalZero }
639*10465441SEvalZero }
640*10465441SEvalZero
641*10465441SEvalZero
642*10465441SEvalZero /*
643*10465441SEvalZero * fsm_rcoderej - Receive an Code-Reject.
644*10465441SEvalZero */
fsm_rcoderej(fsm * f,u_char * inp,int len)645*10465441SEvalZero static void fsm_rcoderej(fsm *f, u_char *inp, int len) {
646*10465441SEvalZero u_char code, id;
647*10465441SEvalZero
648*10465441SEvalZero if (len < HEADERLEN) {
649*10465441SEvalZero FSMDEBUG(("fsm_rcoderej: Rcvd short Code-Reject packet!"));
650*10465441SEvalZero return;
651*10465441SEvalZero }
652*10465441SEvalZero GETCHAR(code, inp);
653*10465441SEvalZero GETCHAR(id, inp);
654*10465441SEvalZero ppp_warn("%s: Rcvd Code-Reject for code %d, id %d", PROTO_NAME(f), code, id);
655*10465441SEvalZero
656*10465441SEvalZero if( f->state == PPP_FSM_ACKRCVD )
657*10465441SEvalZero f->state = PPP_FSM_REQSENT;
658*10465441SEvalZero }
659*10465441SEvalZero
660*10465441SEvalZero
661*10465441SEvalZero /*
662*10465441SEvalZero * fsm_protreject - Peer doesn't speak this protocol.
663*10465441SEvalZero *
664*10465441SEvalZero * Treat this as a catastrophic error (RXJ-).
665*10465441SEvalZero */
fsm_protreject(fsm * f)666*10465441SEvalZero void fsm_protreject(fsm *f) {
667*10465441SEvalZero switch( f->state ){
668*10465441SEvalZero case PPP_FSM_CLOSING:
669*10465441SEvalZero UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
670*10465441SEvalZero /* fall through */
671*10465441SEvalZero /* no break */
672*10465441SEvalZero case PPP_FSM_CLOSED:
673*10465441SEvalZero f->state = PPP_FSM_CLOSED;
674*10465441SEvalZero if( f->callbacks->finished )
675*10465441SEvalZero (*f->callbacks->finished)(f);
676*10465441SEvalZero break;
677*10465441SEvalZero
678*10465441SEvalZero case PPP_FSM_STOPPING:
679*10465441SEvalZero case PPP_FSM_REQSENT:
680*10465441SEvalZero case PPP_FSM_ACKRCVD:
681*10465441SEvalZero case PPP_FSM_ACKSENT:
682*10465441SEvalZero UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
683*10465441SEvalZero /* fall through */
684*10465441SEvalZero /* no break */
685*10465441SEvalZero case PPP_FSM_STOPPED:
686*10465441SEvalZero f->state = PPP_FSM_STOPPED;
687*10465441SEvalZero if( f->callbacks->finished )
688*10465441SEvalZero (*f->callbacks->finished)(f);
689*10465441SEvalZero break;
690*10465441SEvalZero
691*10465441SEvalZero case PPP_FSM_OPENED:
692*10465441SEvalZero terminate_layer(f, PPP_FSM_STOPPING);
693*10465441SEvalZero break;
694*10465441SEvalZero
695*10465441SEvalZero default:
696*10465441SEvalZero FSMDEBUG(("%s: Protocol-reject event in state %d!",
697*10465441SEvalZero PROTO_NAME(f), f->state));
698*10465441SEvalZero /* no break */
699*10465441SEvalZero }
700*10465441SEvalZero }
701*10465441SEvalZero
702*10465441SEvalZero
703*10465441SEvalZero /*
704*10465441SEvalZero * fsm_sconfreq - Send a Configure-Request.
705*10465441SEvalZero */
fsm_sconfreq(fsm * f,int retransmit)706*10465441SEvalZero static void fsm_sconfreq(fsm *f, int retransmit) {
707*10465441SEvalZero ppp_pcb *pcb = f->pcb;
708*10465441SEvalZero struct pbuf *p;
709*10465441SEvalZero u_char *outp;
710*10465441SEvalZero int cilen;
711*10465441SEvalZero
712*10465441SEvalZero if( f->state != PPP_FSM_REQSENT && f->state != PPP_FSM_ACKRCVD && f->state != PPP_FSM_ACKSENT ){
713*10465441SEvalZero /* Not currently negotiating - reset options */
714*10465441SEvalZero if( f->callbacks->resetci )
715*10465441SEvalZero (*f->callbacks->resetci)(f);
716*10465441SEvalZero f->nakloops = 0;
717*10465441SEvalZero f->rnakloops = 0;
718*10465441SEvalZero }
719*10465441SEvalZero
720*10465441SEvalZero if( !retransmit ){
721*10465441SEvalZero /* New request - reset retransmission counter, use new ID */
722*10465441SEvalZero f->retransmits = pcb->settings.fsm_max_conf_req_transmits;
723*10465441SEvalZero f->reqid = ++f->id;
724*10465441SEvalZero }
725*10465441SEvalZero
726*10465441SEvalZero f->seen_ack = 0;
727*10465441SEvalZero
728*10465441SEvalZero /*
729*10465441SEvalZero * Make up the request packet
730*10465441SEvalZero */
731*10465441SEvalZero if( f->callbacks->cilen && f->callbacks->addci ){
732*10465441SEvalZero cilen = (*f->callbacks->cilen)(f);
733*10465441SEvalZero if( cilen > pcb->peer_mru - HEADERLEN )
734*10465441SEvalZero cilen = pcb->peer_mru - HEADERLEN;
735*10465441SEvalZero } else
736*10465441SEvalZero cilen = 0;
737*10465441SEvalZero
738*10465441SEvalZero p = pbuf_alloc(PBUF_RAW, (u16_t)(cilen + HEADERLEN + PPP_HDRLEN), PPP_CTRL_PBUF_TYPE);
739*10465441SEvalZero if(NULL == p)
740*10465441SEvalZero return;
741*10465441SEvalZero if(p->tot_len != p->len) {
742*10465441SEvalZero pbuf_free(p);
743*10465441SEvalZero return;
744*10465441SEvalZero }
745*10465441SEvalZero
746*10465441SEvalZero /* send the request to our peer */
747*10465441SEvalZero outp = (u_char*)p->payload;
748*10465441SEvalZero MAKEHEADER(outp, f->protocol);
749*10465441SEvalZero PUTCHAR(CONFREQ, outp);
750*10465441SEvalZero PUTCHAR(f->reqid, outp);
751*10465441SEvalZero PUTSHORT(cilen + HEADERLEN, outp);
752*10465441SEvalZero if (cilen != 0) {
753*10465441SEvalZero (*f->callbacks->addci)(f, outp, &cilen);
754*10465441SEvalZero LWIP_ASSERT("cilen == p->len - HEADERLEN - PPP_HDRLEN", cilen == p->len - HEADERLEN - PPP_HDRLEN);
755*10465441SEvalZero }
756*10465441SEvalZero
757*10465441SEvalZero ppp_write(pcb, p);
758*10465441SEvalZero
759*10465441SEvalZero /* start the retransmit timer */
760*10465441SEvalZero --f->retransmits;
761*10465441SEvalZero TIMEOUT(fsm_timeout, f, pcb->settings.fsm_timeout_time);
762*10465441SEvalZero }
763*10465441SEvalZero
764*10465441SEvalZero
765*10465441SEvalZero /*
766*10465441SEvalZero * fsm_sdata - Send some data.
767*10465441SEvalZero *
768*10465441SEvalZero * Used for all packets sent to our peer by this module.
769*10465441SEvalZero */
fsm_sdata(fsm * f,u_char code,u_char id,const u_char * data,int datalen)770*10465441SEvalZero void fsm_sdata(fsm *f, u_char code, u_char id, const u_char *data, int datalen) {
771*10465441SEvalZero ppp_pcb *pcb = f->pcb;
772*10465441SEvalZero struct pbuf *p;
773*10465441SEvalZero u_char *outp;
774*10465441SEvalZero int outlen;
775*10465441SEvalZero
776*10465441SEvalZero /* Adjust length to be smaller than MTU */
777*10465441SEvalZero if (datalen > pcb->peer_mru - HEADERLEN)
778*10465441SEvalZero datalen = pcb->peer_mru - HEADERLEN;
779*10465441SEvalZero outlen = datalen + HEADERLEN;
780*10465441SEvalZero
781*10465441SEvalZero p = pbuf_alloc(PBUF_RAW, (u16_t)(outlen + PPP_HDRLEN), PPP_CTRL_PBUF_TYPE);
782*10465441SEvalZero if(NULL == p)
783*10465441SEvalZero return;
784*10465441SEvalZero if(p->tot_len != p->len) {
785*10465441SEvalZero pbuf_free(p);
786*10465441SEvalZero return;
787*10465441SEvalZero }
788*10465441SEvalZero
789*10465441SEvalZero outp = (u_char*)p->payload;
790*10465441SEvalZero if (datalen) /* && data != outp + PPP_HDRLEN + HEADERLEN) -- was only for fsm_sconfreq() */
791*10465441SEvalZero MEMCPY(outp + PPP_HDRLEN + HEADERLEN, data, datalen);
792*10465441SEvalZero MAKEHEADER(outp, f->protocol);
793*10465441SEvalZero PUTCHAR(code, outp);
794*10465441SEvalZero PUTCHAR(id, outp);
795*10465441SEvalZero PUTSHORT(outlen, outp);
796*10465441SEvalZero ppp_write(pcb, p);
797*10465441SEvalZero }
798*10465441SEvalZero
799*10465441SEvalZero #endif /* PPP_SUPPORT */
800