Deneme - | Mbed

Users » dcoban » Code » Deneme

Dependencies: FatFileSystem mbed WeatherMeters SDFileSystem

NetStack/lwip/netif/ppp/fsm.c@0:1a61c61d0845, 2012-04-03 (annotated)

Committer:: dcoban
Date:: Tue Apr 03 18:43:13 2012 +0000
Revision:: 0:1a61c61d0845

Who changed what in which revision?

User	Revision	Line number	New contents of line
dcoban	0:1a61c61d0845	1	/*****************************************************************************
dcoban	0:1a61c61d0845	2	* fsm.c - Network Control Protocol Finite State Machine program file.
dcoban	0:1a61c61d0845	3	*
dcoban	0:1a61c61d0845	4	* Copyright (c) 2003 by Marc Boucher, Services Informatiques (MBSI) inc.
dcoban	0:1a61c61d0845	5	* portions Copyright (c) 1997 by Global Election Systems Inc.
dcoban	0:1a61c61d0845	6	*
dcoban	0:1a61c61d0845	7	* The authors hereby grant permission to use, copy, modify, distribute,
dcoban	0:1a61c61d0845	8	* and license this software and its documentation for any purpose, provided
dcoban	0:1a61c61d0845	9	* that existing copyright notices are retained in all copies and that this
dcoban	0:1a61c61d0845	10	* notice and the following disclaimer are included verbatim in any
dcoban	0:1a61c61d0845	11	* distributions. No written agreement, license, or royalty fee is required
dcoban	0:1a61c61d0845	12	* for any of the authorized uses.
dcoban	0:1a61c61d0845	13	*
dcoban	0:1a61c61d0845	14	* THIS SOFTWARE IS PROVIDED BY THE CONTRIBUTORS AS IS AND ANY EXPRESS OR
dcoban	0:1a61c61d0845	15	* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
dcoban	0:1a61c61d0845	16	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
dcoban	0:1a61c61d0845	17	* IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
dcoban	0:1a61c61d0845	18	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
dcoban	0:1a61c61d0845	19	* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
dcoban	0:1a61c61d0845	20	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
dcoban	0:1a61c61d0845	21	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
dcoban	0:1a61c61d0845	22	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
dcoban	0:1a61c61d0845	23	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
dcoban	0:1a61c61d0845	24	*
dcoban	0:1a61c61d0845	25	******************************************************************************
dcoban	0:1a61c61d0845	26	* REVISION HISTORY
dcoban	0:1a61c61d0845	27	*
dcoban	0:1a61c61d0845	28	* 03-01-01 Marc Boucher <marc@mbsi.ca>
dcoban	0:1a61c61d0845	29	* Ported to lwIP.
dcoban	0:1a61c61d0845	30	* 97-12-01 Guy Lancaster <lancasterg@acm.org>, Global Election Systems Inc.
dcoban	0:1a61c61d0845	31	* Original based on BSD fsm.c.
dcoban	0:1a61c61d0845	32	*****************************************************************************/
dcoban	0:1a61c61d0845	33	/*
dcoban	0:1a61c61d0845	34	* fsm.c - {Link, IP} Control Protocol Finite State Machine.
dcoban	0:1a61c61d0845	35	*
dcoban	0:1a61c61d0845	36	* Copyright (c) 1989 Carnegie Mellon University.
dcoban	0:1a61c61d0845	37	* All rights reserved.
dcoban	0:1a61c61d0845	38	*
dcoban	0:1a61c61d0845	39	* Redistribution and use in source and binary forms are permitted
dcoban	0:1a61c61d0845	40	* provided that the above copyright notice and this paragraph are
dcoban	0:1a61c61d0845	41	* duplicated in all such forms and that any documentation,
dcoban	0:1a61c61d0845	42	* advertising materials, and other materials related to such
dcoban	0:1a61c61d0845	43	* distribution and use acknowledge that the software was developed
dcoban	0:1a61c61d0845	44	* by Carnegie Mellon University. The name of the
dcoban	0:1a61c61d0845	45	* University may not be used to endorse or promote products derived
dcoban	0:1a61c61d0845	46	* from this software without specific prior written permission.
dcoban	0:1a61c61d0845	47	* THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
dcoban	0:1a61c61d0845	48	* IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
dcoban	0:1a61c61d0845	49	* WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
dcoban	0:1a61c61d0845	50	*/
dcoban	0:1a61c61d0845	51
dcoban	0:1a61c61d0845	52	/*
dcoban	0:1a61c61d0845	53	* TODO:
dcoban	0:1a61c61d0845	54	* Randomize fsm id on link/init.
dcoban	0:1a61c61d0845	55	* Deal with variable outgoing MTU.
dcoban	0:1a61c61d0845	56	*/
dcoban	0:1a61c61d0845	57
dcoban	0:1a61c61d0845	58	#include "lwip/opt.h"
dcoban	0:1a61c61d0845	59
dcoban	0:1a61c61d0845	60	#if PPP_SUPPORT /* don't build if not configured for use in lwipopts.h */
dcoban	0:1a61c61d0845	61
dcoban	0:1a61c61d0845	62	#include "ppp.h"
dcoban	0:1a61c61d0845	63	#include "pppdebug.h"
dcoban	0:1a61c61d0845	64
dcoban	0:1a61c61d0845	65	#include "fsm.h"
dcoban	0:1a61c61d0845	66
dcoban	0:1a61c61d0845	67	#include <string.h>
dcoban	0:1a61c61d0845	68
dcoban	0:1a61c61d0845	69	#if PPP_DEBUG
dcoban	0:1a61c61d0845	70	static const char *ppperr_strerr[] = {
dcoban	0:1a61c61d0845	71	"LS_INITIAL", /* LS_INITIAL 0 */
dcoban	0:1a61c61d0845	72	"LS_STARTING", /* LS_STARTING 1 */
dcoban	0:1a61c61d0845	73	"LS_CLOSED", /* LS_CLOSED 2 */
dcoban	0:1a61c61d0845	74	"LS_STOPPED", /* LS_STOPPED 3 */
dcoban	0:1a61c61d0845	75	"LS_CLOSING", /* LS_CLOSING 4 */
dcoban	0:1a61c61d0845	76	"LS_STOPPING", /* LS_STOPPING 5 */
dcoban	0:1a61c61d0845	77	"LS_REQSENT", /* LS_REQSENT 6 */
dcoban	0:1a61c61d0845	78	"LS_ACKRCVD", /* LS_ACKRCVD 7 */
dcoban	0:1a61c61d0845	79	"LS_ACKSENT", /* LS_ACKSENT 8 */
dcoban	0:1a61c61d0845	80	"LS_OPENED" /* LS_OPENED 9 */
dcoban	0:1a61c61d0845	81	};
dcoban	0:1a61c61d0845	82	#endif /* PPP_DEBUG */
dcoban	0:1a61c61d0845	83
dcoban	0:1a61c61d0845	84	static void fsm_timeout (void *);
dcoban	0:1a61c61d0845	85	static void fsm_rconfreq (fsm , u_char, u_char , int);
dcoban	0:1a61c61d0845	86	static void fsm_rconfack (fsm , int, u_char , int);
dcoban	0:1a61c61d0845	87	static void fsm_rconfnakrej (fsm , int, int, u_char , int);
dcoban	0:1a61c61d0845	88	static void fsm_rtermreq (fsm , int, u_char , int);
dcoban	0:1a61c61d0845	89	static void fsm_rtermack (fsm *);
dcoban	0:1a61c61d0845	90	static void fsm_rcoderej (fsm , u_char , int);
dcoban	0:1a61c61d0845	91	static void fsm_sconfreq (fsm *, int);
dcoban	0:1a61c61d0845	92
dcoban	0:1a61c61d0845	93	#define PROTO_NAME(f) ((f)->callbacks->proto_name)
dcoban	0:1a61c61d0845	94
dcoban	0:1a61c61d0845	95	int peer_mru[NUM_PPP];
dcoban	0:1a61c61d0845	96
dcoban	0:1a61c61d0845	97
dcoban	0:1a61c61d0845	98	/*
dcoban	0:1a61c61d0845	99	* fsm_init - Initialize fsm.
dcoban	0:1a61c61d0845	100	*
dcoban	0:1a61c61d0845	101	* Initialize fsm state.
dcoban	0:1a61c61d0845	102	*/
dcoban	0:1a61c61d0845	103	void
dcoban	0:1a61c61d0845	104	fsm_init(fsm *f)
dcoban	0:1a61c61d0845	105	{
dcoban	0:1a61c61d0845	106	f->state = LS_INITIAL;
dcoban	0:1a61c61d0845	107	f->flags = 0;
dcoban	0:1a61c61d0845	108	f->id = 0; /* XXX Start with random id? */
dcoban	0:1a61c61d0845	109	f->timeouttime = FSM_DEFTIMEOUT;
dcoban	0:1a61c61d0845	110	f->maxconfreqtransmits = FSM_DEFMAXCONFREQS;
dcoban	0:1a61c61d0845	111	f->maxtermtransmits = FSM_DEFMAXTERMREQS;
dcoban	0:1a61c61d0845	112	f->maxnakloops = FSM_DEFMAXNAKLOOPS;
dcoban	0:1a61c61d0845	113	f->term_reason_len = 0;
dcoban	0:1a61c61d0845	114	}
dcoban	0:1a61c61d0845	115
dcoban	0:1a61c61d0845	116
dcoban	0:1a61c61d0845	117	/*
dcoban	0:1a61c61d0845	118	* fsm_lowerup - The lower layer is up.
dcoban	0:1a61c61d0845	119	*/
dcoban	0:1a61c61d0845	120	void
dcoban	0:1a61c61d0845	121	fsm_lowerup(fsm *f)
dcoban	0:1a61c61d0845	122	{
dcoban	0:1a61c61d0845	123	int oldState = f->state;
dcoban	0:1a61c61d0845	124
dcoban	0:1a61c61d0845	125	LWIP_UNUSED_ARG(oldState);
dcoban	0:1a61c61d0845	126
dcoban	0:1a61c61d0845	127	switch( f->state ) {
dcoban	0:1a61c61d0845	128	case LS_INITIAL:
dcoban	0:1a61c61d0845	129	f->state = LS_CLOSED;
dcoban	0:1a61c61d0845	130	break;
dcoban	0:1a61c61d0845	131
dcoban	0:1a61c61d0845	132	case LS_STARTING:
dcoban	0:1a61c61d0845	133	if( f->flags & OPT_SILENT ) {
dcoban	0:1a61c61d0845	134	f->state = LS_STOPPED;
dcoban	0:1a61c61d0845	135	} else {
dcoban	0:1a61c61d0845	136	/* Send an initial configure-request */
dcoban	0:1a61c61d0845	137	fsm_sconfreq(f, 0);
dcoban	0:1a61c61d0845	138	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	139	}
dcoban	0:1a61c61d0845	140	break;
dcoban	0:1a61c61d0845	141
dcoban	0:1a61c61d0845	142	default:
dcoban	0:1a61c61d0845	143	FSMDEBUG(LOG_INFO, ("%s: Up event in state %d (%s)!\n",
dcoban	0:1a61c61d0845	144	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	145	}
dcoban	0:1a61c61d0845	146
dcoban	0:1a61c61d0845	147	FSMDEBUG(LOG_INFO, ("%s: lowerup state %d (%s) -> %d (%s)\n",
dcoban	0:1a61c61d0845	148	PROTO_NAME(f), oldState, ppperr_strerr[oldState], f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	149	}
dcoban	0:1a61c61d0845	150
dcoban	0:1a61c61d0845	151
dcoban	0:1a61c61d0845	152	/*
dcoban	0:1a61c61d0845	153	* fsm_lowerdown - The lower layer is down.
dcoban	0:1a61c61d0845	154	*
dcoban	0:1a61c61d0845	155	* Cancel all timeouts and inform upper layers.
dcoban	0:1a61c61d0845	156	*/
dcoban	0:1a61c61d0845	157	void
dcoban	0:1a61c61d0845	158	fsm_lowerdown(fsm *f)
dcoban	0:1a61c61d0845	159	{
dcoban	0:1a61c61d0845	160	int oldState = f->state;
dcoban	0:1a61c61d0845	161
dcoban	0:1a61c61d0845	162	LWIP_UNUSED_ARG(oldState);
dcoban	0:1a61c61d0845	163
dcoban	0:1a61c61d0845	164	switch( f->state ) {
dcoban	0:1a61c61d0845	165	case LS_CLOSED:
dcoban	0:1a61c61d0845	166	f->state = LS_INITIAL;
dcoban	0:1a61c61d0845	167	break;
dcoban	0:1a61c61d0845	168
dcoban	0:1a61c61d0845	169	case LS_STOPPED:
dcoban	0:1a61c61d0845	170	f->state = LS_STARTING;
dcoban	0:1a61c61d0845	171	if( f->callbacks->starting ) {
dcoban	0:1a61c61d0845	172	(*f->callbacks->starting)(f);
dcoban	0:1a61c61d0845	173	}
dcoban	0:1a61c61d0845	174	break;
dcoban	0:1a61c61d0845	175
dcoban	0:1a61c61d0845	176	case LS_CLOSING:
dcoban	0:1a61c61d0845	177	f->state = LS_INITIAL;
dcoban	0:1a61c61d0845	178	UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
dcoban	0:1a61c61d0845	179	break;
dcoban	0:1a61c61d0845	180
dcoban	0:1a61c61d0845	181	case LS_STOPPING:
dcoban	0:1a61c61d0845	182	case LS_REQSENT:
dcoban	0:1a61c61d0845	183	case LS_ACKRCVD:
dcoban	0:1a61c61d0845	184	case LS_ACKSENT:
dcoban	0:1a61c61d0845	185	f->state = LS_STARTING;
dcoban	0:1a61c61d0845	186	UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
dcoban	0:1a61c61d0845	187	break;
dcoban	0:1a61c61d0845	188
dcoban	0:1a61c61d0845	189	case LS_OPENED:
dcoban	0:1a61c61d0845	190	if( f->callbacks->down ) {
dcoban	0:1a61c61d0845	191	(*f->callbacks->down)(f);
dcoban	0:1a61c61d0845	192	}
dcoban	0:1a61c61d0845	193	f->state = LS_STARTING;
dcoban	0:1a61c61d0845	194	break;
dcoban	0:1a61c61d0845	195
dcoban	0:1a61c61d0845	196	default:
dcoban	0:1a61c61d0845	197	FSMDEBUG(LOG_INFO, ("%s: Down event in state %d (%s)!\n",
dcoban	0:1a61c61d0845	198	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	199	}
dcoban	0:1a61c61d0845	200
dcoban	0:1a61c61d0845	201	FSMDEBUG(LOG_INFO, ("%s: lowerdown state %d (%s) -> %d (%s)\n",
dcoban	0:1a61c61d0845	202	PROTO_NAME(f), oldState, ppperr_strerr[oldState], f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	203	}
dcoban	0:1a61c61d0845	204
dcoban	0:1a61c61d0845	205
dcoban	0:1a61c61d0845	206	/*
dcoban	0:1a61c61d0845	207	* fsm_open - Link is allowed to come up.
dcoban	0:1a61c61d0845	208	*/
dcoban	0:1a61c61d0845	209	void
dcoban	0:1a61c61d0845	210	fsm_open(fsm *f)
dcoban	0:1a61c61d0845	211	{
dcoban	0:1a61c61d0845	212	int oldState = f->state;
dcoban	0:1a61c61d0845	213
dcoban	0:1a61c61d0845	214	LWIP_UNUSED_ARG(oldState);
dcoban	0:1a61c61d0845	215
dcoban	0:1a61c61d0845	216	switch( f->state ) {
dcoban	0:1a61c61d0845	217	case LS_INITIAL:
dcoban	0:1a61c61d0845	218	f->state = LS_STARTING;
dcoban	0:1a61c61d0845	219	if( f->callbacks->starting ) {
dcoban	0:1a61c61d0845	220	(*f->callbacks->starting)(f);
dcoban	0:1a61c61d0845	221	}
dcoban	0:1a61c61d0845	222	break;
dcoban	0:1a61c61d0845	223
dcoban	0:1a61c61d0845	224	case LS_CLOSED:
dcoban	0:1a61c61d0845	225	if( f->flags & OPT_SILENT ) {
dcoban	0:1a61c61d0845	226	f->state = LS_STOPPED;
dcoban	0:1a61c61d0845	227	} else {
dcoban	0:1a61c61d0845	228	/* Send an initial configure-request */
dcoban	0:1a61c61d0845	229	fsm_sconfreq(f, 0);
dcoban	0:1a61c61d0845	230	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	231	}
dcoban	0:1a61c61d0845	232	break;
dcoban	0:1a61c61d0845	233
dcoban	0:1a61c61d0845	234	case LS_CLOSING:
dcoban	0:1a61c61d0845	235	f->state = LS_STOPPING;
dcoban	0:1a61c61d0845	236	/* fall through */
dcoban	0:1a61c61d0845	237	case LS_STOPPED:
dcoban	0:1a61c61d0845	238	case LS_OPENED:
dcoban	0:1a61c61d0845	239	if( f->flags & OPT_RESTART ) {
dcoban	0:1a61c61d0845	240	fsm_lowerdown(f);
dcoban	0:1a61c61d0845	241	fsm_lowerup(f);
dcoban	0:1a61c61d0845	242	}
dcoban	0:1a61c61d0845	243	break;
dcoban	0:1a61c61d0845	244	}
dcoban	0:1a61c61d0845	245
dcoban	0:1a61c61d0845	246	FSMDEBUG(LOG_INFO, ("%s: open state %d (%s) -> %d (%s)\n",
dcoban	0:1a61c61d0845	247	PROTO_NAME(f), oldState, ppperr_strerr[oldState], f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	248	}
dcoban	0:1a61c61d0845	249
dcoban	0:1a61c61d0845	250	#if 0 /* backport pppd 2.4.4b1; */
dcoban	0:1a61c61d0845	251	/*
dcoban	0:1a61c61d0845	252	* terminate_layer - Start process of shutting down the FSM
dcoban	0:1a61c61d0845	253	*
dcoban	0:1a61c61d0845	254	* Cancel any timeout running, notify upper layers we're done, and
dcoban	0:1a61c61d0845	255	* send a terminate-request message as configured.
dcoban	0:1a61c61d0845	256	*/
dcoban	0:1a61c61d0845	257	static void
dcoban	0:1a61c61d0845	258	terminate_layer(fsm *f, int nextstate)
dcoban	0:1a61c61d0845	259	{
dcoban	0:1a61c61d0845	260	/* @todo */
dcoban	0:1a61c61d0845	261	}
dcoban	0:1a61c61d0845	262	#endif
dcoban	0:1a61c61d0845	263
dcoban	0:1a61c61d0845	264	/*
dcoban	0:1a61c61d0845	265	* fsm_close - Start closing connection.
dcoban	0:1a61c61d0845	266	*
dcoban	0:1a61c61d0845	267	* Cancel timeouts and either initiate close or possibly go directly to
dcoban	0:1a61c61d0845	268	* the LS_CLOSED state.
dcoban	0:1a61c61d0845	269	*/
dcoban	0:1a61c61d0845	270	void
dcoban	0:1a61c61d0845	271	fsm_close(fsm f, char reason)
dcoban	0:1a61c61d0845	272	{
dcoban	0:1a61c61d0845	273	int oldState = f->state;
dcoban	0:1a61c61d0845	274
dcoban	0:1a61c61d0845	275	LWIP_UNUSED_ARG(oldState);
dcoban	0:1a61c61d0845	276
dcoban	0:1a61c61d0845	277	f->term_reason = reason;
dcoban	0:1a61c61d0845	278	f->term_reason_len = (reason == NULL ? 0 : (int)strlen(reason));
dcoban	0:1a61c61d0845	279	switch( f->state ) {
dcoban	0:1a61c61d0845	280	case LS_STARTING:
dcoban	0:1a61c61d0845	281	f->state = LS_INITIAL;
dcoban	0:1a61c61d0845	282	break;
dcoban	0:1a61c61d0845	283	case LS_STOPPED:
dcoban	0:1a61c61d0845	284	f->state = LS_CLOSED;
dcoban	0:1a61c61d0845	285	break;
dcoban	0:1a61c61d0845	286	case LS_STOPPING:
dcoban	0:1a61c61d0845	287	f->state = LS_CLOSING;
dcoban	0:1a61c61d0845	288	break;
dcoban	0:1a61c61d0845	289
dcoban	0:1a61c61d0845	290	case LS_REQSENT:
dcoban	0:1a61c61d0845	291	case LS_ACKRCVD:
dcoban	0:1a61c61d0845	292	case LS_ACKSENT:
dcoban	0:1a61c61d0845	293	case LS_OPENED:
dcoban	0:1a61c61d0845	294	if( f->state != LS_OPENED ) {
dcoban	0:1a61c61d0845	295	UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
dcoban	0:1a61c61d0845	296	} else if( f->callbacks->down ) {
dcoban	0:1a61c61d0845	297	(f->callbacks->down)(f); / Inform upper layers we're down */
dcoban	0:1a61c61d0845	298	}
dcoban	0:1a61c61d0845	299	/* Init restart counter, send Terminate-Request */
dcoban	0:1a61c61d0845	300	f->retransmits = f->maxtermtransmits;
dcoban	0:1a61c61d0845	301	fsm_sdata(f, TERMREQ, f->reqid = ++f->id,
dcoban	0:1a61c61d0845	302	(u_char *) f->term_reason, f->term_reason_len);
dcoban	0:1a61c61d0845	303	TIMEOUT(fsm_timeout, f, f->timeouttime);
dcoban	0:1a61c61d0845	304	--f->retransmits;
dcoban	0:1a61c61d0845	305
dcoban	0:1a61c61d0845	306	f->state = LS_CLOSING;
dcoban	0:1a61c61d0845	307	break;
dcoban	0:1a61c61d0845	308	}
dcoban	0:1a61c61d0845	309
dcoban	0:1a61c61d0845	310	FSMDEBUG(LOG_INFO, ("%s: close reason=%s state %d (%s) -> %d (%s)\n",
dcoban	0:1a61c61d0845	311	PROTO_NAME(f), reason, oldState, ppperr_strerr[oldState], f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	312	}
dcoban	0:1a61c61d0845	313
dcoban	0:1a61c61d0845	314
dcoban	0:1a61c61d0845	315	/*
dcoban	0:1a61c61d0845	316	* fsm_timeout - Timeout expired.
dcoban	0:1a61c61d0845	317	*/
dcoban	0:1a61c61d0845	318	static void
dcoban	0:1a61c61d0845	319	fsm_timeout(void *arg)
dcoban	0:1a61c61d0845	320	{
dcoban	0:1a61c61d0845	321	fsm f = (fsm ) arg;
dcoban	0:1a61c61d0845	322
dcoban	0:1a61c61d0845	323	switch (f->state) {
dcoban	0:1a61c61d0845	324	case LS_CLOSING:
dcoban	0:1a61c61d0845	325	case LS_STOPPING:
dcoban	0:1a61c61d0845	326	if( f->retransmits <= 0 ) {
dcoban	0:1a61c61d0845	327	FSMDEBUG(LOG_WARNING, ("%s: timeout sending Terminate-Request state=%d (%s)\n",
dcoban	0:1a61c61d0845	328	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	329	/*
dcoban	0:1a61c61d0845	330	* We've waited for an ack long enough. Peer probably heard us.
dcoban	0:1a61c61d0845	331	*/
dcoban	0:1a61c61d0845	332	f->state = (f->state == LS_CLOSING)? LS_CLOSED: LS_STOPPED;
dcoban	0:1a61c61d0845	333	if( f->callbacks->finished ) {
dcoban	0:1a61c61d0845	334	(*f->callbacks->finished)(f);
dcoban	0:1a61c61d0845	335	}
dcoban	0:1a61c61d0845	336	} else {
dcoban	0:1a61c61d0845	337	FSMDEBUG(LOG_WARNING, ("%s: timeout resending Terminate-Requests state=%d (%s)\n",
dcoban	0:1a61c61d0845	338	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	339	/* Send Terminate-Request */
dcoban	0:1a61c61d0845	340	fsm_sdata(f, TERMREQ, f->reqid = ++f->id,
dcoban	0:1a61c61d0845	341	(u_char *) f->term_reason, f->term_reason_len);
dcoban	0:1a61c61d0845	342	TIMEOUT(fsm_timeout, f, f->timeouttime);
dcoban	0:1a61c61d0845	343	--f->retransmits;
dcoban	0:1a61c61d0845	344	}
dcoban	0:1a61c61d0845	345	break;
dcoban	0:1a61c61d0845	346
dcoban	0:1a61c61d0845	347	case LS_REQSENT:
dcoban	0:1a61c61d0845	348	case LS_ACKRCVD:
dcoban	0:1a61c61d0845	349	case LS_ACKSENT:
dcoban	0:1a61c61d0845	350	if (f->retransmits <= 0) {
dcoban	0:1a61c61d0845	351	FSMDEBUG(LOG_WARNING, ("%s: timeout sending Config-Requests state=%d (%s)\n",
dcoban	0:1a61c61d0845	352	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	353	f->state = LS_STOPPED;
dcoban	0:1a61c61d0845	354	if( (f->flags & OPT_PASSIVE) == 0 && f->callbacks->finished ) {
dcoban	0:1a61c61d0845	355	(*f->callbacks->finished)(f);
dcoban	0:1a61c61d0845	356	}
dcoban	0:1a61c61d0845	357	} else {
dcoban	0:1a61c61d0845	358	FSMDEBUG(LOG_WARNING, ("%s: timeout resending Config-Request state=%d (%s)\n",
dcoban	0:1a61c61d0845	359	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	360	/* Retransmit the configure-request */
dcoban	0:1a61c61d0845	361	if (f->callbacks->retransmit) {
dcoban	0:1a61c61d0845	362	(*f->callbacks->retransmit)(f);
dcoban	0:1a61c61d0845	363	}
dcoban	0:1a61c61d0845	364	fsm_sconfreq(f, 1); /* Re-send Configure-Request */
dcoban	0:1a61c61d0845	365	if( f->state == LS_ACKRCVD ) {
dcoban	0:1a61c61d0845	366	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	367	}
dcoban	0:1a61c61d0845	368	}
dcoban	0:1a61c61d0845	369	break;
dcoban	0:1a61c61d0845	370
dcoban	0:1a61c61d0845	371	default:
dcoban	0:1a61c61d0845	372	FSMDEBUG(LOG_INFO, ("%s: UNHANDLED timeout event in state %d (%s)!\n",
dcoban	0:1a61c61d0845	373	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	374	}
dcoban	0:1a61c61d0845	375	}
dcoban	0:1a61c61d0845	376
dcoban	0:1a61c61d0845	377
dcoban	0:1a61c61d0845	378	/*
dcoban	0:1a61c61d0845	379	* fsm_input - Input packet.
dcoban	0:1a61c61d0845	380	*/
dcoban	0:1a61c61d0845	381	void
dcoban	0:1a61c61d0845	382	fsm_input(fsm f, u_char inpacket, int l)
dcoban	0:1a61c61d0845	383	{
dcoban	0:1a61c61d0845	384	u_char *inp = inpacket;
dcoban	0:1a61c61d0845	385	u_char code, id;
dcoban	0:1a61c61d0845	386	int len;
dcoban	0:1a61c61d0845	387
dcoban	0:1a61c61d0845	388	/*
dcoban	0:1a61c61d0845	389	* Parse header (code, id and length).
dcoban	0:1a61c61d0845	390	* If packet too short, drop it.
dcoban	0:1a61c61d0845	391	*/
dcoban	0:1a61c61d0845	392	if (l < HEADERLEN) {
dcoban	0:1a61c61d0845	393	FSMDEBUG(LOG_WARNING, ("fsm_input(%x): Rcvd short header.\n",
dcoban	0:1a61c61d0845	394	f->protocol));
dcoban	0:1a61c61d0845	395	return;
dcoban	0:1a61c61d0845	396	}
dcoban	0:1a61c61d0845	397	GETCHAR(code, inp);
dcoban	0:1a61c61d0845	398	GETCHAR(id, inp);
dcoban	0:1a61c61d0845	399	GETSHORT(len, inp);
dcoban	0:1a61c61d0845	400	if (len < HEADERLEN) {
dcoban	0:1a61c61d0845	401	FSMDEBUG(LOG_INFO, ("fsm_input(%x): Rcvd illegal length.\n",
dcoban	0:1a61c61d0845	402	f->protocol));
dcoban	0:1a61c61d0845	403	return;
dcoban	0:1a61c61d0845	404	}
dcoban	0:1a61c61d0845	405	if (len > l) {
dcoban	0:1a61c61d0845	406	FSMDEBUG(LOG_INFO, ("fsm_input(%x): Rcvd short packet.\n",
dcoban	0:1a61c61d0845	407	f->protocol));
dcoban	0:1a61c61d0845	408	return;
dcoban	0:1a61c61d0845	409	}
dcoban	0:1a61c61d0845	410	len -= HEADERLEN; /* subtract header length */
dcoban	0:1a61c61d0845	411
dcoban	0:1a61c61d0845	412	if( f->state == LS_INITIAL \|\| f->state == LS_STARTING ) {
dcoban	0:1a61c61d0845	413	FSMDEBUG(LOG_INFO, ("fsm_input(%x): Rcvd packet in state %d (%s).\n",
dcoban	0:1a61c61d0845	414	f->protocol, f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	415	return;
dcoban	0:1a61c61d0845	416	}
dcoban	0:1a61c61d0845	417	FSMDEBUG(LOG_INFO, ("fsm_input(%s):%d,%d,%d\n", PROTO_NAME(f), code, id, l));
dcoban	0:1a61c61d0845	418	/*
dcoban	0:1a61c61d0845	419	* Action depends on code.
dcoban	0:1a61c61d0845	420	*/
dcoban	0:1a61c61d0845	421	switch (code) {
dcoban	0:1a61c61d0845	422	case CONFREQ:
dcoban	0:1a61c61d0845	423	fsm_rconfreq(f, id, inp, len);
dcoban	0:1a61c61d0845	424	break;
dcoban	0:1a61c61d0845	425
dcoban	0:1a61c61d0845	426	case CONFACK:
dcoban	0:1a61c61d0845	427	fsm_rconfack(f, id, inp, len);
dcoban	0:1a61c61d0845	428	break;
dcoban	0:1a61c61d0845	429
dcoban	0:1a61c61d0845	430	case CONFNAK:
dcoban	0:1a61c61d0845	431	case CONFREJ:
dcoban	0:1a61c61d0845	432	fsm_rconfnakrej(f, code, id, inp, len);
dcoban	0:1a61c61d0845	433	break;
dcoban	0:1a61c61d0845	434
dcoban	0:1a61c61d0845	435	case TERMREQ:
dcoban	0:1a61c61d0845	436	fsm_rtermreq(f, id, inp, len);
dcoban	0:1a61c61d0845	437	break;
dcoban	0:1a61c61d0845	438
dcoban	0:1a61c61d0845	439	case TERMACK:
dcoban	0:1a61c61d0845	440	fsm_rtermack(f);
dcoban	0:1a61c61d0845	441	break;
dcoban	0:1a61c61d0845	442
dcoban	0:1a61c61d0845	443	case CODEREJ:
dcoban	0:1a61c61d0845	444	fsm_rcoderej(f, inp, len);
dcoban	0:1a61c61d0845	445	break;
dcoban	0:1a61c61d0845	446
dcoban	0:1a61c61d0845	447	default:
dcoban	0:1a61c61d0845	448	FSMDEBUG(LOG_INFO, ("fsm_input(%s): default: \n", PROTO_NAME(f)));
dcoban	0:1a61c61d0845	449	if( !f->callbacks->extcode \|\|
dcoban	0:1a61c61d0845	450	!(*f->callbacks->extcode)(f, code, id, inp, len) ) {
dcoban	0:1a61c61d0845	451	fsm_sdata(f, CODEREJ, ++f->id, inpacket, len + HEADERLEN);
dcoban	0:1a61c61d0845	452	}
dcoban	0:1a61c61d0845	453	break;
dcoban	0:1a61c61d0845	454	}
dcoban	0:1a61c61d0845	455	}
dcoban	0:1a61c61d0845	456
dcoban	0:1a61c61d0845	457
dcoban	0:1a61c61d0845	458	/*
dcoban	0:1a61c61d0845	459	* fsm_rconfreq - Receive Configure-Request.
dcoban	0:1a61c61d0845	460	*/
dcoban	0:1a61c61d0845	461	static void
dcoban	0:1a61c61d0845	462	fsm_rconfreq(fsm f, u_char id, u_char inp, int len)
dcoban	0:1a61c61d0845	463	{
dcoban	0:1a61c61d0845	464	int code, reject_if_disagree;
dcoban	0:1a61c61d0845	465
dcoban	0:1a61c61d0845	466	FSMDEBUG(LOG_INFO, ("fsm_rconfreq(%s): Rcvd id %d state=%d (%s)\n",
dcoban	0:1a61c61d0845	467	PROTO_NAME(f), id, f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	468	switch( f->state ) {
dcoban	0:1a61c61d0845	469	case LS_CLOSED:
dcoban	0:1a61c61d0845	470	/* Go away, we're closed */
dcoban	0:1a61c61d0845	471	fsm_sdata(f, TERMACK, id, NULL, 0);
dcoban	0:1a61c61d0845	472	return;
dcoban	0:1a61c61d0845	473	case LS_CLOSING:
dcoban	0:1a61c61d0845	474	case LS_STOPPING:
dcoban	0:1a61c61d0845	475	return;
dcoban	0:1a61c61d0845	476
dcoban	0:1a61c61d0845	477	case LS_OPENED:
dcoban	0:1a61c61d0845	478	/* Go down and restart negotiation */
dcoban	0:1a61c61d0845	479	if( f->callbacks->down ) {
dcoban	0:1a61c61d0845	480	(f->callbacks->down)(f); / Inform upper layers */
dcoban	0:1a61c61d0845	481	}
dcoban	0:1a61c61d0845	482	fsm_sconfreq(f, 0); /* Send initial Configure-Request */
dcoban	0:1a61c61d0845	483	break;
dcoban	0:1a61c61d0845	484
dcoban	0:1a61c61d0845	485	case LS_STOPPED:
dcoban	0:1a61c61d0845	486	/* Negotiation started by our peer */
dcoban	0:1a61c61d0845	487	fsm_sconfreq(f, 0); /* Send initial Configure-Request */
dcoban	0:1a61c61d0845	488	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	489	break;
dcoban	0:1a61c61d0845	490	}
dcoban	0:1a61c61d0845	491
dcoban	0:1a61c61d0845	492	/*
dcoban	0:1a61c61d0845	493	* Pass the requested configuration options
dcoban	0:1a61c61d0845	494	* to protocol-specific code for checking.
dcoban	0:1a61c61d0845	495	*/
dcoban	0:1a61c61d0845	496	if (f->callbacks->reqci) { /* Check CI */
dcoban	0:1a61c61d0845	497	reject_if_disagree = (f->nakloops >= f->maxnakloops);
dcoban	0:1a61c61d0845	498	code = (*f->callbacks->reqci)(f, inp, &len, reject_if_disagree);
dcoban	0:1a61c61d0845	499	} else if (len) {
dcoban	0:1a61c61d0845	500	code = CONFREJ; /* Reject all CI */
dcoban	0:1a61c61d0845	501	} else {
dcoban	0:1a61c61d0845	502	code = CONFACK;
dcoban	0:1a61c61d0845	503	}
dcoban	0:1a61c61d0845	504
dcoban	0:1a61c61d0845	505	/* send the Ack, Nak or Rej to the peer */
dcoban	0:1a61c61d0845	506	fsm_sdata(f, (u_char)code, id, inp, len);
dcoban	0:1a61c61d0845	507
dcoban	0:1a61c61d0845	508	if (code == CONFACK) {
dcoban	0:1a61c61d0845	509	if (f->state == LS_ACKRCVD) {
dcoban	0:1a61c61d0845	510	UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
dcoban	0:1a61c61d0845	511	f->state = LS_OPENED;
dcoban	0:1a61c61d0845	512	if (f->callbacks->up) {
dcoban	0:1a61c61d0845	513	(f->callbacks->up)(f); / Inform upper layers */
dcoban	0:1a61c61d0845	514	}
dcoban	0:1a61c61d0845	515	} else {
dcoban	0:1a61c61d0845	516	f->state = LS_ACKSENT;
dcoban	0:1a61c61d0845	517	}
dcoban	0:1a61c61d0845	518	f->nakloops = 0;
dcoban	0:1a61c61d0845	519	} else {
dcoban	0:1a61c61d0845	520	/* we sent CONFACK or CONFREJ */
dcoban	0:1a61c61d0845	521	if (f->state != LS_ACKRCVD) {
dcoban	0:1a61c61d0845	522	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	523	}
dcoban	0:1a61c61d0845	524	if( code == CONFNAK ) {
dcoban	0:1a61c61d0845	525	++f->nakloops;
dcoban	0:1a61c61d0845	526	}
dcoban	0:1a61c61d0845	527	}
dcoban	0:1a61c61d0845	528	}
dcoban	0:1a61c61d0845	529
dcoban	0:1a61c61d0845	530
dcoban	0:1a61c61d0845	531	/*
dcoban	0:1a61c61d0845	532	* fsm_rconfack - Receive Configure-Ack.
dcoban	0:1a61c61d0845	533	*/
dcoban	0:1a61c61d0845	534	static void
dcoban	0:1a61c61d0845	535	fsm_rconfack(fsm f, int id, u_char inp, int len)
dcoban	0:1a61c61d0845	536	{
dcoban	0:1a61c61d0845	537	FSMDEBUG(LOG_INFO, ("fsm_rconfack(%s): Rcvd id %d state=%d (%s)\n",
dcoban	0:1a61c61d0845	538	PROTO_NAME(f), id, f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	539
dcoban	0:1a61c61d0845	540	if (id != f->reqid \|\| f->seen_ack) { /* Expected id? */
dcoban	0:1a61c61d0845	541	return; /* Nope, toss... */
dcoban	0:1a61c61d0845	542	}
dcoban	0:1a61c61d0845	543	if( !(f->callbacks->ackci? (*f->callbacks->ackci)(f, inp, len): (len == 0)) ) {
dcoban	0:1a61c61d0845	544	/* Ack is bad - ignore it */
dcoban	0:1a61c61d0845	545	FSMDEBUG(LOG_INFO, ("%s: received bad Ack (length %d)\n",
dcoban	0:1a61c61d0845	546	PROTO_NAME(f), len));
dcoban	0:1a61c61d0845	547	return;
dcoban	0:1a61c61d0845	548	}
dcoban	0:1a61c61d0845	549	f->seen_ack = 1;
dcoban	0:1a61c61d0845	550
dcoban	0:1a61c61d0845	551	switch (f->state) {
dcoban	0:1a61c61d0845	552	case LS_CLOSED:
dcoban	0:1a61c61d0845	553	case LS_STOPPED:
dcoban	0:1a61c61d0845	554	fsm_sdata(f, TERMACK, (u_char)id, NULL, 0);
dcoban	0:1a61c61d0845	555	break;
dcoban	0:1a61c61d0845	556
dcoban	0:1a61c61d0845	557	case LS_REQSENT:
dcoban	0:1a61c61d0845	558	f->state = LS_ACKRCVD;
dcoban	0:1a61c61d0845	559	f->retransmits = f->maxconfreqtransmits;
dcoban	0:1a61c61d0845	560	break;
dcoban	0:1a61c61d0845	561
dcoban	0:1a61c61d0845	562	case LS_ACKRCVD:
dcoban	0:1a61c61d0845	563	/* Huh? an extra valid Ack? oh well... */
dcoban	0:1a61c61d0845	564	UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
dcoban	0:1a61c61d0845	565	fsm_sconfreq(f, 0);
dcoban	0:1a61c61d0845	566	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	567	break;
dcoban	0:1a61c61d0845	568
dcoban	0:1a61c61d0845	569	case LS_ACKSENT:
dcoban	0:1a61c61d0845	570	UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
dcoban	0:1a61c61d0845	571	f->state = LS_OPENED;
dcoban	0:1a61c61d0845	572	f->retransmits = f->maxconfreqtransmits;
dcoban	0:1a61c61d0845	573	if (f->callbacks->up) {
dcoban	0:1a61c61d0845	574	(f->callbacks->up)(f); / Inform upper layers */
dcoban	0:1a61c61d0845	575	}
dcoban	0:1a61c61d0845	576	break;
dcoban	0:1a61c61d0845	577
dcoban	0:1a61c61d0845	578	case LS_OPENED:
dcoban	0:1a61c61d0845	579	/* Go down and restart negotiation */
dcoban	0:1a61c61d0845	580	if (f->callbacks->down) {
dcoban	0:1a61c61d0845	581	(f->callbacks->down)(f); / Inform upper layers */
dcoban	0:1a61c61d0845	582	}
dcoban	0:1a61c61d0845	583	fsm_sconfreq(f, 0); /* Send initial Configure-Request */
dcoban	0:1a61c61d0845	584	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	585	break;
dcoban	0:1a61c61d0845	586	}
dcoban	0:1a61c61d0845	587	}
dcoban	0:1a61c61d0845	588
dcoban	0:1a61c61d0845	589
dcoban	0:1a61c61d0845	590	/*
dcoban	0:1a61c61d0845	591	* fsm_rconfnakrej - Receive Configure-Nak or Configure-Reject.
dcoban	0:1a61c61d0845	592	*/
dcoban	0:1a61c61d0845	593	static void
dcoban	0:1a61c61d0845	594	fsm_rconfnakrej(fsm f, int code, int id, u_char inp, int len)
dcoban	0:1a61c61d0845	595	{
dcoban	0:1a61c61d0845	596	int (proc) (fsm , u_char *, int);
dcoban	0:1a61c61d0845	597	int ret;
dcoban	0:1a61c61d0845	598
dcoban	0:1a61c61d0845	599	FSMDEBUG(LOG_INFO, ("fsm_rconfnakrej(%s): Rcvd id %d state=%d (%s)\n",
dcoban	0:1a61c61d0845	600	PROTO_NAME(f), id, f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	601
dcoban	0:1a61c61d0845	602	if (id != f->reqid \|\| f->seen_ack) { /* Expected id? */
dcoban	0:1a61c61d0845	603	return; /* Nope, toss... */
dcoban	0:1a61c61d0845	604	}
dcoban	0:1a61c61d0845	605	proc = (code == CONFNAK)? f->callbacks->nakci: f->callbacks->rejci;
dcoban	0:1a61c61d0845	606	if (!proc \|\| !((ret = proc(f, inp, len)))) {
dcoban	0:1a61c61d0845	607	/* Nak/reject is bad - ignore it */
dcoban	0:1a61c61d0845	608	FSMDEBUG(LOG_INFO, ("%s: received bad %s (length %d)\n",
dcoban	0:1a61c61d0845	609	PROTO_NAME(f), (code==CONFNAK? "Nak": "reject"), len));
dcoban	0:1a61c61d0845	610	return;
dcoban	0:1a61c61d0845	611	}
dcoban	0:1a61c61d0845	612	f->seen_ack = 1;
dcoban	0:1a61c61d0845	613
dcoban	0:1a61c61d0845	614	switch (f->state) {
dcoban	0:1a61c61d0845	615	case LS_CLOSED:
dcoban	0:1a61c61d0845	616	case LS_STOPPED:
dcoban	0:1a61c61d0845	617	fsm_sdata(f, TERMACK, (u_char)id, NULL, 0);
dcoban	0:1a61c61d0845	618	break;
dcoban	0:1a61c61d0845	619
dcoban	0:1a61c61d0845	620	case LS_REQSENT:
dcoban	0:1a61c61d0845	621	case LS_ACKSENT:
dcoban	0:1a61c61d0845	622	/* They didn't agree to what we wanted - try another request */
dcoban	0:1a61c61d0845	623	UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
dcoban	0:1a61c61d0845	624	if (ret < 0) {
dcoban	0:1a61c61d0845	625	f->state = LS_STOPPED; /* kludge for stopping CCP */
dcoban	0:1a61c61d0845	626	} else {
dcoban	0:1a61c61d0845	627	fsm_sconfreq(f, 0); /* Send Configure-Request */
dcoban	0:1a61c61d0845	628	}
dcoban	0:1a61c61d0845	629	break;
dcoban	0:1a61c61d0845	630
dcoban	0:1a61c61d0845	631	case LS_ACKRCVD:
dcoban	0:1a61c61d0845	632	/* Got a Nak/reject when we had already had an Ack?? oh well... */
dcoban	0:1a61c61d0845	633	UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
dcoban	0:1a61c61d0845	634	fsm_sconfreq(f, 0);
dcoban	0:1a61c61d0845	635	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	636	break;
dcoban	0:1a61c61d0845	637
dcoban	0:1a61c61d0845	638	case LS_OPENED:
dcoban	0:1a61c61d0845	639	/* Go down and restart negotiation */
dcoban	0:1a61c61d0845	640	if (f->callbacks->down) {
dcoban	0:1a61c61d0845	641	(f->callbacks->down)(f); / Inform upper layers */
dcoban	0:1a61c61d0845	642	}
dcoban	0:1a61c61d0845	643	fsm_sconfreq(f, 0); /* Send initial Configure-Request */
dcoban	0:1a61c61d0845	644	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	645	break;
dcoban	0:1a61c61d0845	646	}
dcoban	0:1a61c61d0845	647	}
dcoban	0:1a61c61d0845	648
dcoban	0:1a61c61d0845	649
dcoban	0:1a61c61d0845	650	/*
dcoban	0:1a61c61d0845	651	* fsm_rtermreq - Receive Terminate-Req.
dcoban	0:1a61c61d0845	652	*/
dcoban	0:1a61c61d0845	653	static void
dcoban	0:1a61c61d0845	654	fsm_rtermreq(fsm f, int id, u_char p, int len)
dcoban	0:1a61c61d0845	655	{
dcoban	0:1a61c61d0845	656	LWIP_UNUSED_ARG(p);
dcoban	0:1a61c61d0845	657
dcoban	0:1a61c61d0845	658	FSMDEBUG(LOG_INFO, ("fsm_rtermreq(%s): Rcvd id %d state=%d (%s)\n",
dcoban	0:1a61c61d0845	659	PROTO_NAME(f), id, f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	660
dcoban	0:1a61c61d0845	661	switch (f->state) {
dcoban	0:1a61c61d0845	662	case LS_ACKRCVD:
dcoban	0:1a61c61d0845	663	case LS_ACKSENT:
dcoban	0:1a61c61d0845	664	f->state = LS_REQSENT; /* Start over but keep trying */
dcoban	0:1a61c61d0845	665	break;
dcoban	0:1a61c61d0845	666
dcoban	0:1a61c61d0845	667	case LS_OPENED:
dcoban	0:1a61c61d0845	668	if (len > 0) {
dcoban	0:1a61c61d0845	669	FSMDEBUG(LOG_INFO, ("%s terminated by peer (%p)\n", PROTO_NAME(f), p));
dcoban	0:1a61c61d0845	670	} else {
dcoban	0:1a61c61d0845	671	FSMDEBUG(LOG_INFO, ("%s terminated by peer\n", PROTO_NAME(f)));
dcoban	0:1a61c61d0845	672	}
dcoban	0:1a61c61d0845	673	if (f->callbacks->down) {
dcoban	0:1a61c61d0845	674	(f->callbacks->down)(f); / Inform upper layers */
dcoban	0:1a61c61d0845	675	}
dcoban	0:1a61c61d0845	676	f->retransmits = 0;
dcoban	0:1a61c61d0845	677	f->state = LS_STOPPING;
dcoban	0:1a61c61d0845	678	TIMEOUT(fsm_timeout, f, f->timeouttime);
dcoban	0:1a61c61d0845	679	break;
dcoban	0:1a61c61d0845	680	}
dcoban	0:1a61c61d0845	681
dcoban	0:1a61c61d0845	682	fsm_sdata(f, TERMACK, (u_char)id, NULL, 0);
dcoban	0:1a61c61d0845	683	}
dcoban	0:1a61c61d0845	684
dcoban	0:1a61c61d0845	685
dcoban	0:1a61c61d0845	686	/*
dcoban	0:1a61c61d0845	687	* fsm_rtermack - Receive Terminate-Ack.
dcoban	0:1a61c61d0845	688	*/
dcoban	0:1a61c61d0845	689	static void
dcoban	0:1a61c61d0845	690	fsm_rtermack(fsm *f)
dcoban	0:1a61c61d0845	691	{
dcoban	0:1a61c61d0845	692	FSMDEBUG(LOG_INFO, ("fsm_rtermack(%s): state=%d (%s)\n",
dcoban	0:1a61c61d0845	693	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	694
dcoban	0:1a61c61d0845	695	switch (f->state) {
dcoban	0:1a61c61d0845	696	case LS_CLOSING:
dcoban	0:1a61c61d0845	697	UNTIMEOUT(fsm_timeout, f);
dcoban	0:1a61c61d0845	698	f->state = LS_CLOSED;
dcoban	0:1a61c61d0845	699	if( f->callbacks->finished ) {
dcoban	0:1a61c61d0845	700	(*f->callbacks->finished)(f);
dcoban	0:1a61c61d0845	701	}
dcoban	0:1a61c61d0845	702	break;
dcoban	0:1a61c61d0845	703
dcoban	0:1a61c61d0845	704	case LS_STOPPING:
dcoban	0:1a61c61d0845	705	UNTIMEOUT(fsm_timeout, f);
dcoban	0:1a61c61d0845	706	f->state = LS_STOPPED;
dcoban	0:1a61c61d0845	707	if( f->callbacks->finished ) {
dcoban	0:1a61c61d0845	708	(*f->callbacks->finished)(f);
dcoban	0:1a61c61d0845	709	}
dcoban	0:1a61c61d0845	710	break;
dcoban	0:1a61c61d0845	711
dcoban	0:1a61c61d0845	712	case LS_ACKRCVD:
dcoban	0:1a61c61d0845	713	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	714	break;
dcoban	0:1a61c61d0845	715
dcoban	0:1a61c61d0845	716	case LS_OPENED:
dcoban	0:1a61c61d0845	717	if (f->callbacks->down) {
dcoban	0:1a61c61d0845	718	(f->callbacks->down)(f); / Inform upper layers */
dcoban	0:1a61c61d0845	719	}
dcoban	0:1a61c61d0845	720	fsm_sconfreq(f, 0);
dcoban	0:1a61c61d0845	721	break;
dcoban	0:1a61c61d0845	722	default:
dcoban	0:1a61c61d0845	723	FSMDEBUG(LOG_INFO, ("fsm_rtermack(%s): UNHANDLED state=%d (%s)!!!\n",
dcoban	0:1a61c61d0845	724	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	725	}
dcoban	0:1a61c61d0845	726	}
dcoban	0:1a61c61d0845	727
dcoban	0:1a61c61d0845	728
dcoban	0:1a61c61d0845	729	/*
dcoban	0:1a61c61d0845	730	* fsm_rcoderej - Receive an Code-Reject.
dcoban	0:1a61c61d0845	731	*/
dcoban	0:1a61c61d0845	732	static void
dcoban	0:1a61c61d0845	733	fsm_rcoderej(fsm f, u_char inp, int len)
dcoban	0:1a61c61d0845	734	{
dcoban	0:1a61c61d0845	735	u_char code, id;
dcoban	0:1a61c61d0845	736
dcoban	0:1a61c61d0845	737	FSMDEBUG(LOG_INFO, ("fsm_rcoderej(%s): state=%d (%s)\n",
dcoban	0:1a61c61d0845	738	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	739
dcoban	0:1a61c61d0845	740	if (len < HEADERLEN) {
dcoban	0:1a61c61d0845	741	FSMDEBUG(LOG_INFO, ("fsm_rcoderej: Rcvd short Code-Reject packet!\n"));
dcoban	0:1a61c61d0845	742	return;
dcoban	0:1a61c61d0845	743	}
dcoban	0:1a61c61d0845	744	GETCHAR(code, inp);
dcoban	0:1a61c61d0845	745	GETCHAR(id, inp);
dcoban	0:1a61c61d0845	746	FSMDEBUG(LOG_WARNING, ("%s: Rcvd Code-Reject for code %d, id %d\n",
dcoban	0:1a61c61d0845	747	PROTO_NAME(f), code, id));
dcoban	0:1a61c61d0845	748
dcoban	0:1a61c61d0845	749	if( f->state == LS_ACKRCVD ) {
dcoban	0:1a61c61d0845	750	f->state = LS_REQSENT;
dcoban	0:1a61c61d0845	751	}
dcoban	0:1a61c61d0845	752	}
dcoban	0:1a61c61d0845	753
dcoban	0:1a61c61d0845	754
dcoban	0:1a61c61d0845	755	/*
dcoban	0:1a61c61d0845	756	* fsm_protreject - Peer doesn't speak this protocol.
dcoban	0:1a61c61d0845	757	*
dcoban	0:1a61c61d0845	758	* Treat this as a catastrophic error (RXJ-).
dcoban	0:1a61c61d0845	759	*/
dcoban	0:1a61c61d0845	760	void
dcoban	0:1a61c61d0845	761	fsm_protreject(fsm *f)
dcoban	0:1a61c61d0845	762	{
dcoban	0:1a61c61d0845	763	switch( f->state ) {
dcoban	0:1a61c61d0845	764	case LS_CLOSING:
dcoban	0:1a61c61d0845	765	UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
dcoban	0:1a61c61d0845	766	/* fall through */
dcoban	0:1a61c61d0845	767	case LS_CLOSED:
dcoban	0:1a61c61d0845	768	f->state = LS_CLOSED;
dcoban	0:1a61c61d0845	769	if( f->callbacks->finished ) {
dcoban	0:1a61c61d0845	770	(*f->callbacks->finished)(f);
dcoban	0:1a61c61d0845	771	}
dcoban	0:1a61c61d0845	772	break;
dcoban	0:1a61c61d0845	773
dcoban	0:1a61c61d0845	774	case LS_STOPPING:
dcoban	0:1a61c61d0845	775	case LS_REQSENT:
dcoban	0:1a61c61d0845	776	case LS_ACKRCVD:
dcoban	0:1a61c61d0845	777	case LS_ACKSENT:
dcoban	0:1a61c61d0845	778	UNTIMEOUT(fsm_timeout, f); /* Cancel timeout */
dcoban	0:1a61c61d0845	779	/* fall through */
dcoban	0:1a61c61d0845	780	case LS_STOPPED:
dcoban	0:1a61c61d0845	781	f->state = LS_STOPPED;
dcoban	0:1a61c61d0845	782	if( f->callbacks->finished ) {
dcoban	0:1a61c61d0845	783	(*f->callbacks->finished)(f);
dcoban	0:1a61c61d0845	784	}
dcoban	0:1a61c61d0845	785	break;
dcoban	0:1a61c61d0845	786
dcoban	0:1a61c61d0845	787	case LS_OPENED:
dcoban	0:1a61c61d0845	788	if( f->callbacks->down ) {
dcoban	0:1a61c61d0845	789	(*f->callbacks->down)(f);
dcoban	0:1a61c61d0845	790	}
dcoban	0:1a61c61d0845	791	/* Init restart counter, send Terminate-Request */
dcoban	0:1a61c61d0845	792	f->retransmits = f->maxtermtransmits;
dcoban	0:1a61c61d0845	793	fsm_sdata(f, TERMREQ, f->reqid = ++f->id,
dcoban	0:1a61c61d0845	794	(u_char *) f->term_reason, f->term_reason_len);
dcoban	0:1a61c61d0845	795	TIMEOUT(fsm_timeout, f, f->timeouttime);
dcoban	0:1a61c61d0845	796	--f->retransmits;
dcoban	0:1a61c61d0845	797
dcoban	0:1a61c61d0845	798	f->state = LS_STOPPING;
dcoban	0:1a61c61d0845	799	break;
dcoban	0:1a61c61d0845	800
dcoban	0:1a61c61d0845	801	default:
dcoban	0:1a61c61d0845	802	FSMDEBUG(LOG_INFO, ("%s: Protocol-reject event in state %d (%s)!\n",
dcoban	0:1a61c61d0845	803	PROTO_NAME(f), f->state, ppperr_strerr[f->state]));
dcoban	0:1a61c61d0845	804	}
dcoban	0:1a61c61d0845	805	}
dcoban	0:1a61c61d0845	806
dcoban	0:1a61c61d0845	807
dcoban	0:1a61c61d0845	808	/*
dcoban	0:1a61c61d0845	809	* fsm_sconfreq - Send a Configure-Request.
dcoban	0:1a61c61d0845	810	*/
dcoban	0:1a61c61d0845	811	static void
dcoban	0:1a61c61d0845	812	fsm_sconfreq(fsm *f, int retransmit)
dcoban	0:1a61c61d0845	813	{
dcoban	0:1a61c61d0845	814	u_char *outp;
dcoban	0:1a61c61d0845	815	int cilen;
dcoban	0:1a61c61d0845	816
dcoban	0:1a61c61d0845	817	if( f->state != LS_REQSENT && f->state != LS_ACKRCVD && f->state != LS_ACKSENT ) {
dcoban	0:1a61c61d0845	818	/* Not currently negotiating - reset options */
dcoban	0:1a61c61d0845	819	if( f->callbacks->resetci ) {
dcoban	0:1a61c61d0845	820	(*f->callbacks->resetci)(f);
dcoban	0:1a61c61d0845	821	}
dcoban	0:1a61c61d0845	822	f->nakloops = 0;
dcoban	0:1a61c61d0845	823	}
dcoban	0:1a61c61d0845	824
dcoban	0:1a61c61d0845	825	if( !retransmit ) {
dcoban	0:1a61c61d0845	826	/* New request - reset retransmission counter, use new ID */
dcoban	0:1a61c61d0845	827	f->retransmits = f->maxconfreqtransmits;
dcoban	0:1a61c61d0845	828	f->reqid = ++f->id;
dcoban	0:1a61c61d0845	829	}
dcoban	0:1a61c61d0845	830
dcoban	0:1a61c61d0845	831	f->seen_ack = 0;
dcoban	0:1a61c61d0845	832
dcoban	0:1a61c61d0845	833	/*
dcoban	0:1a61c61d0845	834	* Make up the request packet
dcoban	0:1a61c61d0845	835	*/
dcoban	0:1a61c61d0845	836	outp = outpacket_buf[f->unit] + PPP_HDRLEN + HEADERLEN;
dcoban	0:1a61c61d0845	837	if( f->callbacks->cilen && f->callbacks->addci ) {
dcoban	0:1a61c61d0845	838	cilen = (*f->callbacks->cilen)(f);
dcoban	0:1a61c61d0845	839	if( cilen > peer_mru[f->unit] - (int)HEADERLEN ) {
dcoban	0:1a61c61d0845	840	cilen = peer_mru[f->unit] - HEADERLEN;
dcoban	0:1a61c61d0845	841	}
dcoban	0:1a61c61d0845	842	if (f->callbacks->addci) {
dcoban	0:1a61c61d0845	843	(*f->callbacks->addci)(f, outp, &cilen);
dcoban	0:1a61c61d0845	844	}
dcoban	0:1a61c61d0845	845	} else {
dcoban	0:1a61c61d0845	846	cilen = 0;
dcoban	0:1a61c61d0845	847	}
dcoban	0:1a61c61d0845	848
dcoban	0:1a61c61d0845	849	/* send the request to our peer */
dcoban	0:1a61c61d0845	850	fsm_sdata(f, CONFREQ, f->reqid, outp, cilen);
dcoban	0:1a61c61d0845	851
dcoban	0:1a61c61d0845	852	/* start the retransmit timer */
dcoban	0:1a61c61d0845	853	--f->retransmits;
dcoban	0:1a61c61d0845	854	TIMEOUT(fsm_timeout, f, f->timeouttime);
dcoban	0:1a61c61d0845	855
dcoban	0:1a61c61d0845	856	FSMDEBUG(LOG_INFO, ("%s: sending Configure-Request, id %d\n",
dcoban	0:1a61c61d0845	857	PROTO_NAME(f), f->reqid));
dcoban	0:1a61c61d0845	858	}
dcoban	0:1a61c61d0845	859
dcoban	0:1a61c61d0845	860
dcoban	0:1a61c61d0845	861	/*
dcoban	0:1a61c61d0845	862	* fsm_sdata - Send some data.
dcoban	0:1a61c61d0845	863	*
dcoban	0:1a61c61d0845	864	* Used for all packets sent to our peer by this module.
dcoban	0:1a61c61d0845	865	*/
dcoban	0:1a61c61d0845	866	void
dcoban	0:1a61c61d0845	867	fsm_sdata( fsm f, u_char code, u_char id, u_char data, int datalen)
dcoban	0:1a61c61d0845	868	{
dcoban	0:1a61c61d0845	869	u_char *outp;
dcoban	0:1a61c61d0845	870	int outlen;
dcoban	0:1a61c61d0845	871
dcoban	0:1a61c61d0845	872	/* Adjust length to be smaller than MTU */
dcoban	0:1a61c61d0845	873	outp = outpacket_buf[f->unit];
dcoban	0:1a61c61d0845	874	if (datalen > peer_mru[f->unit] - (int)HEADERLEN) {
dcoban	0:1a61c61d0845	875	datalen = peer_mru[f->unit] - HEADERLEN;
dcoban	0:1a61c61d0845	876	}
dcoban	0:1a61c61d0845	877	if (datalen && data != outp + PPP_HDRLEN + HEADERLEN) {
dcoban	0:1a61c61d0845	878	BCOPY(data, outp + PPP_HDRLEN + HEADERLEN, datalen);
dcoban	0:1a61c61d0845	879	}
dcoban	0:1a61c61d0845	880	outlen = datalen + HEADERLEN;
dcoban	0:1a61c61d0845	881	MAKEHEADER(outp, f->protocol);
dcoban	0:1a61c61d0845	882	PUTCHAR(code, outp);
dcoban	0:1a61c61d0845	883	PUTCHAR(id, outp);
dcoban	0:1a61c61d0845	884	PUTSHORT(outlen, outp);
dcoban	0:1a61c61d0845	885	pppWrite(f->unit, outpacket_buf[f->unit], outlen + PPP_HDRLEN);
dcoban	0:1a61c61d0845	886	FSMDEBUG(LOG_INFO, ("fsm_sdata(%s): Sent code %d,%d,%d.\n",
dcoban	0:1a61c61d0845	887	PROTO_NAME(f), code, id, outlen));
dcoban	0:1a61c61d0845	888	}
dcoban	0:1a61c61d0845	889
dcoban	0:1a61c61d0845	890	#endif /* PPP_SUPPORT */

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	03 Apr 2012
Imports:	2
Forks:	0
Commits:	1
Dependents:	0
Dependencies:	4
Followers:	1

NetStack/lwip/netif/ppp/fsm.c@0:1a61c61d0845, 2012-04-03 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning