55 #define PROTO_NAME(f)	((f)->callbacks->proto_name)  argument
78 fsm_init(f)  in fsm_init()  argument
79     fsm *f;  in fsm_init()
81     f->state = INITIAL;
82     f->flags = 0;
83     f->id = (uchar_t)(drand48() * 0xFF);	/* Start with random id */
84     f->timeouttime = DEFTIMEOUT;
85     f->maxconfreqtransmits = DEFMAXCONFREQS;
86     f->maxtermtransmits = DEFMAXTERMREQS;
87     f->maxnakloops = DEFMAXNAKLOOPS;
88     f->term_reason_len = 0;
96 fsm_lowerup(f)  in fsm_lowerup()  argument
97     fsm *f;  in fsm_lowerup()
99     switch( f->state ){
101 	f->state = CLOSED;
105 	if( f->flags & OPT_SILENT )
106 	    f->state = STOPPED;
109 	    fsm_sconfreq(f, 0);
110 	    f->state = REQSENT;
115 	error("%s: Up event in state %s", PROTO_NAME(f), fsm_state(f->state));
126 fsm_lowerdown(f)  in fsm_lowerdown()  argument
127     fsm *f;  in fsm_lowerdown()
129     switch( f->state ){
131 	f->state = INITIAL;
135 	f->state = STARTING;
136 	if (f->callbacks->starting != NULL)
137 	    (*f->callbacks->starting)(f);
141 	f->state = INITIAL;
142 	UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
149 	f->state = STARTING;
150 	UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
154 	f->state = STARTING;
155 	if (f->callbacks->down != NULL)
156 	    (*f->callbacks->down)(f);
160 	dbglog("%s: Down event in state %s", PROTO_NAME(f),
161 	    fsm_state(f->state));
170 fsm_open(f)  in fsm_open()  argument
171     fsm *f;  in fsm_open()
173     switch( f->state ){
175 	f->state = STARTING;
176 	if (f->callbacks->starting != NULL)
177 	    (*f->callbacks->starting)(f);
181 	if( f->flags & OPT_SILENT )
182 	    f->state = STOPPED;
185 	    fsm_sconfreq(f, 0);
186 	    f->state = REQSENT;
191 	f->state = STOPPING;
196 	if( f->flags & OPT_RESTART ){
197 	    fsm_lowerdown(f);
198 	    fsm_lowerup(f);
219 fsm_close(f, reason)  in fsm_close()  argument
220     fsm *f;  in fsm_close()
223     int prevstate = f->state;
225     f->term_reason = reason;
226     f->term_reason_len = (reason == NULL? 0: strlen(reason));
227     switch( f->state ){
229 	f->state = INITIAL;
230 	if (f->callbacks->finished != NULL)
231 	    (*f->callbacks->finished)(f);
235 	f->state = CLOSED;
239 	f->state = CLOSING;
246 	f->state = CLOSING;
248 	    UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
249 	else if (f->callbacks->down != NULL)
250 	    (*f->callbacks->down)(f);	/* Inform upper layers we're down */
257 	f->retransmits = f->maxtermtransmits;
258 	fsm_sdata(f, CODE_TERMREQ, f->reqid = ++f->id,
259 		  (u_char *) f->term_reason, f->term_reason_len);
260 	TIMEOUT(fsm_timeout, f, f->timeouttime);
261 	--f->retransmits;
280     fsm *f = (fsm *) arg;  local
282     switch (f->state) {
285 	if( f->retransmits <= 0 ){
289 	    f->state = (f->state == CLOSING)? CLOSED: STOPPED;
290 	    if (f->callbacks->finished != NULL)
291 		(*f->callbacks->finished)(f);
294 	    fsm_sdata(f, CODE_TERMREQ, f->reqid = ++f->id,
295 		      (u_char *) f->term_reason, f->term_reason_len);
296 	    TIMEOUT(fsm_timeout, f, f->timeouttime);
297 	    --f->retransmits;
304 	if (f->retransmits <= 0) {
305 	    warn("%s: timeout sending Config-Requests\n", PROTO_NAME(f));
306 	    f->state = STOPPED;
307 	    if (!(f->flags & OPT_PASSIVE) && f->callbacks->finished != NULL)
308 		(*f->callbacks->finished)(f);
312 	    if (f->callbacks->retransmit != NULL)
313 		(*f->callbacks->retransmit)(f);
314 	    fsm_sconfreq(f, 1);		/* Re-send Configure-Request */
315 	    if( f->state == ACKRCVD )
316 		f->state = REQSENT;
321 	fatal("%s: Timeout event in state %s!", PROTO_NAME(f),
322 	    fsm_state(f->state));
331 fsm_input(f, inpacket, l)  in fsm_input()  argument
332     fsm *f;  in fsm_input()
346 	error("%s packet: discard; too small (%d < %d)", PROTO_NAME(f), l,
354 	error("%s packet: discard; invalid length (%d < %d)", PROTO_NAME(f),
359 	error("%s packet: discard; truncated (%d > %d)", PROTO_NAME(f), len,
365     if (f->state == INITIAL || f->state == STARTING) {
366 	dbglog("%s: discarded packet in state %s", PROTO_NAME(f),
367 	    fsm_state(f->state));
376 	fsm_rconfreq(f, id, inp, len);
380 	fsm_rconfack(f, id, inp, len);
385 	fsm_rconfnakrej(f, code, id, inp, len);
389 	fsm_rtermreq(f, id, inp, len);
393 	fsm_rtermack(f);
397 	fsm_rcoderej(f, inp, len);
401 	if (f->callbacks->extcode == NULL ||
402 	    !(*f->callbacks->extcode)(f, code, id, inp, len))
403 	    fsm_sdata(f, CODE_CODEREJ, ++f->id, inpacket, len + HEADERLEN);
413 fsm_rconfreq(f, id, inp, len)  in fsm_rconfreq()  argument
414     fsm *f;  in fsm_rconfreq()
421     switch( f->state ){
424 	fsm_sdata(f, CODE_TERMACK, id, NULL, 0);
429 	dbglog("%s: discarded Configure-Request in state %s", PROTO_NAME(f),
430 	    fsm_state(f->state));
435 	if (f->callbacks->down != NULL)
436 	    (*f->callbacks->down)(f);	/* Inform upper layers */
449     if (f->callbacks->reqci != NULL) {		/* Check CI */
450 	reject_if_disagree = (f->nakloops >= f->maxnakloops);
451 	code = (*f->callbacks->reqci)(f, inp, &len, reject_if_disagree);
461     if (f->state == OPENED || f->state == STOPPED)
462 	fsm_sconfreq(f, 0);		/* Send initial Configure-Request */
465     fsm_sdata(f, code, id, inp, len);
469 	if (f->state == ACKRCVD) {
470 	    UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
471 	    f->state = OPENED;
472 	    if (f->callbacks->up != NULL)
473 		(*f->callbacks->up)(f);	/* Inform upper layers */
475 	    f->state = ACKSENT;
476 	f->nakloops = 0;
481 	if (f->state != ACKRCVD)
482 	    f->state = REQSENT;
484 	    ++f->nakloops;
493 fsm_rconfack(f, id, inp, len)  in fsm_rconfack()  argument
494     fsm *f;  in fsm_rconfack()
499     if (id != f->reqid || f->seen_ack)		/* Expected id? */
501     if( !(f->callbacks->ackci != NULL ? (*f->callbacks->ackci)(f, inp, len):
507     f->seen_ack = 1;
509     switch (f->state) {
512 	fsm_sdata(f, CODE_TERMACK, id, NULL, 0);
516 	f->state = ACKRCVD;
517 	f->retransmits = f->maxconfreqtransmits;
522 	UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
523 	fsm_sconfreq(f, 0);
524 	f->state = REQSENT;
528 	UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
529 	f->state = OPENED;
530 	f->retransmits = f->maxconfreqtransmits;
531 	if (f->callbacks->up != NULL)
532 	    (*f->callbacks->up)(f);	/* Inform upper layers */
537 	fsm_sconfreq(f, 0);		/* Send initial Configure-Request */
538 	f->state = REQSENT;
539 	if (f->callbacks->down != NULL)
540 	    (*f->callbacks->down)(f);	/* Inform upper layers */
550 fsm_rconfnakrej(f, code, id, inp, len)  in fsm_rconfnakrej()  argument
551     fsm *f;  in fsm_rconfnakrej()
559     if (id != f->reqid || f->seen_ack)	/* Expected id? */
561     proc = (code == CODE_CONFNAK)? f->callbacks->nakci: f->callbacks->rejci;
562     if (proc == NULL || !(ret = proc(f, inp, len))) {
567     f->seen_ack = 1;
569     switch (f->state) {
572 	fsm_sdata(f, CODE_TERMACK, id, NULL, 0);
578 	UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
580 	    f->state = STOPPED;		/* kludge for stopping CCP */
582 	    fsm_sconfreq(f, 0);		/* Send Configure-Request */
587 	UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
588 	fsm_sconfreq(f, 0);
589 	f->state = REQSENT;
594 	fsm_sconfreq(f, 0);		/* Send initial Configure-Request */
595 	f->state = REQSENT;
596 	if (f->callbacks->down != NULL)
597 	    (*f->callbacks->down)(f);	/* Inform upper layers */
607 fsm_rtermreq(f, id, p, len)  in fsm_rtermreq()  argument
608     fsm *f;  in fsm_rtermreq()
613     switch (f->state) {
616 	f->state = REQSENT;		/* Start over but keep trying */
621 	    info("%s terminated by peer (%0.*v)", PROTO_NAME(f), len, p);
623 	    info("%s terminated by peer", PROTO_NAME(f));
625 	f->state = STOPPING;
626 	if (f->callbacks->down != NULL)
627 	    (*f->callbacks->down)(f);	/* Inform upper layers */
628 	f->retransmits = 0;
629 	TIMEOUT(fsm_timeout, f, f->timeouttime);
633     fsm_sdata(f, CODE_TERMACK, id, NULL, 0);
641 fsm_rtermack(f)  in fsm_rtermack()  argument
642     fsm *f;  in fsm_rtermack()
644     switch (f->state) {
646 	UNTIMEOUT(fsm_timeout, f);
647 	f->state = CLOSED;
648 	if (f->callbacks->finished != NULL)
649 	    (*f->callbacks->finished)(f);
652 	UNTIMEOUT(fsm_timeout, f);
653 	f->state = STOPPED;
654 	if (f->callbacks->finished != NULL)
655 	    (*f->callbacks->finished)(f);
659 	f->state = REQSENT;
663 	fsm_sconfreq(f, 0);
664 	f->state = REQSENT;
665 	if (f->callbacks->down != NULL)
666 	    (*f->callbacks->down)(f);	/* Inform upper layers */
676 fsm_rcoderej(f, inp, len)  in fsm_rcoderej()  argument
677     fsm *f;  in fsm_rcoderej()
685 	error("%s: Code-Reject too short (%d < %d)", PROTO_NAME(f), len,
692     warn("%s: Rcvd Code-Reject for %s id %d", PROTO_NAME(f),
695     setbit(f->codemask, code);
698     if (f->callbacks->codereject != NULL) {
699 	seriouserr = (*f->callbacks->codereject)(f,code,id,inp,len);
710 	switch (f->state) {
712 	    UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
715 	    f->state = CLOSED;
716 	    if (f->callbacks->finished != NULL)
717 		(*f->callbacks->finished)(f);
724 	    UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
725 	    f->state = STOPPED;
728 	    if (f->callbacks->finished != NULL)
729 		(*f->callbacks->finished)(f);
733 	    f->state = STOPPING;
734 	    if (f->callbacks->down != NULL)
735 		(*f->callbacks->down)(f);
737 	    if (f->term_reason == NULL) {
738 		f->term_reason = "unacceptable Code-Reject received";
739 		f->term_reason_len = strlen(f->term_reason);
743 	    f->retransmits = f->maxtermtransmits;
744 	    fsm_sdata(f, CODE_TERMREQ, f->reqid = ++f->id,
745 		(u_char *) f->term_reason, f->term_reason_len);
746 	    TIMEOUT(fsm_timeout, f, f->timeouttime);
747 	    --f->retransmits;
755 	if (f->state == ACKRCVD)
756 	    f->state = REQSENT;
767 fsm_protreject(f)  in fsm_protreject()  argument
768     fsm *f;  in fsm_protreject()
770     switch( f->state ){
772 	UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
775 	f->state = CLOSED;
776 	if (f->callbacks->finished != NULL)
777 	    (*f->callbacks->finished)(f);
784 	UNTIMEOUT(fsm_timeout, f);	/* Cancel timeout */
787 	f->state = STOPPED;
788 	if (f->callbacks->finished != NULL)
789 	    (*f->callbacks->finished)(f);
793 	f->state = STOPPING;
794 	if (f->callbacks->down != NULL)
795 	    (*f->callbacks->down)(f);
798 	f->retransmits = f->maxtermtransmits;
799 	fsm_sdata(f, CODE_TERMREQ, f->reqid = ++f->id,
800 		  (u_char *) f->term_reason, f->term_reason_len);
801 	TIMEOUT(fsm_timeout, f, f->timeouttime);
802 	--f->retransmits;
806 	dbglog("%s: Protocol-Reject in state %s", PROTO_NAME(f),
807 	    fsm_state(f->state));
816 fsm_sconfreq(f, retransmit)  in fsm_sconfreq()  argument
817     fsm *f;  in fsm_sconfreq()
823     if( f->state != REQSENT && f->state != ACKRCVD && f->state != ACKSENT ){
825 	if (f->callbacks->resetci != NULL)
826 	    (*f->callbacks->resetci)(f);
827 	f->nakloops = 0;
832 	f->retransmits = f->maxconfreqtransmits;
833 	f->reqid = ++f->id;
836     f->seen_ack = 0;
842     if (f->callbacks->cilen != NULL) {
843 	cilen = (*f->callbacks->cilen)(f);
844 	if (cilen > peer_mru[f->unit] - HEADERLEN)
845 	    cilen = peer_mru[f->unit] - HEADERLEN;
847 	cilen = peer_mru[f->unit] - HEADERLEN;
850     if (f->callbacks->addci != NULL)
851 	(*f->callbacks->addci)(f, outp, &cilen);
856     fsm_sdata(f, CODE_CONFREQ, f->reqid, outp, cilen);
859     --f->retransmits;
860     TIMEOUT(fsm_timeout, f, f->timeouttime);
870 fsm_sdata(f, code, id, data, datalen)  in fsm_sdata()  argument
871     fsm *f;  in fsm_sdata()
879     if (isset(f->codemask,code)) {
881 	    PROTO_NAME(f), code_name(code,0));
887     if (datalen > peer_mru[f->unit] - HEADERLEN)
888 	datalen = peer_mru[f->unit] - HEADERLEN;
892     MAKEHEADER(outp, f->protocol);
896     output(f->unit, outpacket_buf, outlen + PPP_HDRLEN);