Lines Matching refs:fp
129 struct fsm *fp = (struct fsm *)v;
131 log_Printf(fp->LogLevel, "%s: Stopped timer expired\n", fp->link->name);
132 if (fp->OpenTimer.state == TIMER_RUNNING) {
134 fp->link->name, fp->name);
135 timer_Stop(&fp->OpenTimer);
137 if (fp->state == ST_STOPPED)
138 fsm2initial(fp);
142 fsm_Init(struct fsm *fp, const char *name, u_short proto, int mincode,
147 fp->name = name;
148 fp->proto = proto;
149 fp->min_code = mincode;
150 fp->max_code = maxcode;
151 fp->state = fp->min_code > CODE_TERMACK ? ST_OPENED : ST_INITIAL;
152 fp->reqid = 1;
153 fp->restart = 1;
154 fp->more.reqs = fp->more.naks = fp->more.rejs = 3;
155 memset(&fp->FsmTimer, '\0', sizeof fp->FsmTimer);
156 memset(&fp->OpenTimer, '\0', sizeof fp->OpenTimer);
157 memset(&fp->StoppedTimer, '\0', sizeof fp->StoppedTimer);
158 fp->LogLevel = LogLevel;
159 fp->link = l;
160 fp->bundle = bundle;
161 fp->parent = parent;
162 fp->fn = fn;
163 fp->FsmTimer.name = timer_names[0];
164 fp->OpenTimer.name = timer_names[1];
165 fp->StoppedTimer.name = timer_names[2];
169 NewState(struct fsm *fp, int new)
171 log_Printf(fp->LogLevel, "%s: State change %s --> %s\n",
172 fp->link->name, State2Nam(fp->state), State2Nam(new));
173 if (fp->state == ST_STOPPED && fp->StoppedTimer.state == TIMER_RUNNING)
174 timer_Stop(&fp->StoppedTimer);
175 fp->state = new;
177 timer_Stop(&fp->FsmTimer);
178 if (new == ST_STOPPED && fp->StoppedTimer.load) {
179 timer_Stop(&fp->StoppedTimer);
180 fp->StoppedTimer.func = StoppedTimeout;
181 fp->StoppedTimer.arg = (void *) fp;
182 timer_Start(&fp->StoppedTimer);
188 fsm_Output(struct fsm *fp, u_int code, u_int id, u_char *ptr, unsigned count,
195 if (log_IsKept(fp->LogLevel)) {
196 log_Printf(fp->LogLevel, "%s: Send%s(%d) state = %s\n",
197 fp->link->name, Code2Nam(code), id, State2Nam(fp->state));
203 (*fp->fn->DecodeConfig)(fp, ptr, ptr + count, MODE_NOP, NULL);
205 log_Printf(fp->LogLevel, " [EMPTY]\n");
219 link_PushPacket(fp->link, bp, fp->bundle, LINK_QUEUES(fp->link) - 1,
220 fp->proto);
223 lcp_SendIdentification(&fp->link->lcp);
229 struct fsm *fp = (struct fsm *)v;
231 timer_Stop(&fp->OpenTimer);
232 if (fp->state <= ST_STOPPED) {
233 if (fp->state != ST_STARTING) {
245 (*fp->fn->LayerStart)(fp);
246 (*fp->parent->LayerStart)(fp->parent->object, fp);
248 FsmInitRestartCounter(fp, FSM_REQ_TIMER);
249 FsmSendConfigReq(fp);
250 NewState(fp, ST_REQSENT);
255 fsm_Open(struct fsm *fp)
257 switch (fp->state) {
259 NewState(fp, ST_STARTING);
260 (*fp->fn->LayerStart)(fp);
261 (*fp->parent->LayerStart)(fp->parent->object, fp);
264 if (fp->open_mode == OPEN_PASSIVE) {
265 NewState(fp, ST_STOPPED); /* XXX: This is a hack ! */
266 } else if (fp->open_mode > 0) {
267 if (fp->open_mode > 1)
269 fp->link->name, fp->open_mode);
270 NewState(fp, ST_STOPPED); /* XXX: This is a not-so-bad hack ! */
271 timer_Stop(&fp->OpenTimer);
272 fp->OpenTimer.load = fp->open_mode * SECTICKS;
273 fp->OpenTimer.func = FsmOpenNow;
274 fp->OpenTimer.arg = (void *)fp;
275 timer_Start(&fp->OpenTimer);
277 FsmOpenNow(fp);
287 NewState(fp, ST_STOPPING);
293 fsm_Up(struct fsm *fp)
295 switch (fp->state) {
297 log_Printf(fp->LogLevel, "FSM: Using \"%s\" as a transport\n",
298 fp->link->name);
299 NewState(fp, ST_CLOSED);
302 FsmInitRestartCounter(fp, FSM_REQ_TIMER);
303 FsmSendConfigReq(fp);
304 NewState(fp, ST_REQSENT);
307 log_Printf(fp->LogLevel, "%s: Oops, Up at %s\n",
308 fp->link->name, State2Nam(fp->state));
314 fsm_Down(struct fsm *fp)
316 switch (fp->state) {
318 NewState(fp, ST_INITIAL);
322 (*fp->fn->LayerFinish)(fp);
323 NewState(fp, ST_INITIAL);
324 (*fp->parent->LayerFinish)(fp->parent->object, fp);
327 NewState(fp, ST_STARTING);
328 (*fp->fn->LayerStart)(fp);
329 (*fp->parent->LayerStart)(fp->parent->object, fp);
335 NewState(fp, ST_STARTING);
338 (*fp->fn->LayerDown)(fp);
339 NewState(fp, ST_STARTING);
340 (*fp->parent->LayerDown)(fp->parent->object, fp);
346 fsm_Close(struct fsm *fp)
348 switch (fp->state) {
350 (*fp->fn->LayerFinish)(fp);
351 NewState(fp, ST_INITIAL);
352 (*fp->parent->LayerFinish)(fp->parent->object, fp);
355 NewState(fp, ST_CLOSED);
358 NewState(fp, ST_CLOSING);
361 (*fp->fn->LayerDown)(fp);
362 if (fp->state == ST_OPENED) {
363 FsmInitRestartCounter(fp, FSM_TRM_TIMER);
364 FsmSendTerminateReq(fp);
365 NewState(fp, ST_CLOSING);
366 (*fp->parent->LayerDown)(fp->parent->object, fp);
372 FsmInitRestartCounter(fp, FSM_TRM_TIMER);
373 FsmSendTerminateReq(fp);
374 NewState(fp, ST_CLOSING);
383 FsmSendConfigReq(struct fsm *fp)
385 if (fp->more.reqs-- > 0 && fp->restart-- > 0) {
386 (*fp->fn->SendConfigReq)(fp);
387 timer_Start(&fp->FsmTimer); /* Start restart timer */
389 if (fp->more.reqs < 0)
391 "negotiation\n", fp->link->name, fp->name);
392 lcp_SendIdentification(&fp->link->lcp);
393 fsm_Close(fp);
398 FsmSendTerminateReq(struct fsm *fp)
400 fsm_Output(fp, CODE_TERMREQ, fp->reqid, NULL, 0, MB_UNKNOWN);
401 (*fp->fn->SentTerminateReq)(fp);
402 timer_Start(&fp->FsmTimer); /* Start restart timer */
403 fp->restart--; /* Decrement restart counter */
412 struct fsm *fp = (struct fsm *)v;
414 if (fp->restart) {
415 switch (fp->state) {
418 FsmSendTerminateReq(fp);
422 FsmSendConfigReq(fp);
425 FsmSendConfigReq(fp);
426 NewState(fp, ST_REQSENT);
429 timer_Start(&fp->FsmTimer);
431 switch (fp->state) {
433 (*fp->fn->LayerFinish)(fp);
434 NewState(fp, ST_CLOSED);
435 (*fp->parent->LayerFinish)(fp->parent->object, fp);
438 (*fp->fn->LayerFinish)(fp);
439 NewState(fp, ST_STOPPED);
440 (*fp->parent->LayerFinish)(fp->parent->object, fp);
445 (*fp->fn->LayerFinish)(fp);
446 NewState(fp, ST_STOPPED);
447 (*fp->parent->LayerFinish)(fp->parent->object, fp);
454 FsmInitRestartCounter(struct fsm *fp, int what)
456 timer_Stop(&fp->FsmTimer);
457 fp->FsmTimer.func = FsmTimeout;
458 fp->FsmTimer.arg = (void *)fp;
459 (*fp->fn->InitRestartCounter)(fp, what);
466 FsmRecvConfigReq(struct fsm *fp, struct fsmheader *lhp, struct mbuf *bp)
479 fp->link->name, plen, flen);
485 switch (fp->state) {
487 (*fp->fn->LayerDown)(fp);
494 (*fp->fn->DecodeConfig)(fp, cp, cp + flen, MODE_REQ, &dec);
496 log_Printf(fp->LogLevel, " [EMPTY]\n");
502 switch (fp->state) {
504 if (fp->proto == PROTO_CCP && fp->link->lcp.fsm.state == ST_OPENED) {
510 bp = proto_Prepend(bp, fp->proto, 0, 0);
512 lcp_SendProtoRej(&fp->link->lcp, MBUF_CTOP(bp), bp->m_len);
518 log_Printf(fp->LogLevel, "%s: Oops, RCR in %s.\n",
519 fp->link->name, State2Nam(fp->state));
523 (*fp->fn->SendTerminateAck)(fp, lhp->id);
527 log_Printf(fp->LogLevel, "%s: Error: Got ConfigReq while state = %s\n",
528 fp->link->name, State2Nam(fp->state));
533 FsmInitRestartCounter(fp, FSM_REQ_TIMER);
536 FsmSendConfigReq(fp);
541 fsm_Output(fp, CODE_CONFIGREJ, lhp->id, dec.rej, dec.rejend - dec.rej,
544 fsm_Output(fp, CODE_CONFIGNAK, lhp->id, dec.nak, dec.nakend - dec.nak,
547 fsm_Output(fp, CODE_CONFIGACK, lhp->id, dec.ack, dec.ackend - dec.ack,
550 switch (fp->state) {
557 (*fp->fn->LayerStart)(fp);
558 (*fp->parent->LayerStart)(fp->parent->object, fp);
563 NewState(fp, ST_ACKSENT);
565 NewState(fp, ST_REQSENT);
566 (*fp->parent->LayerDown)(fp->parent->object, fp);
570 NewState(fp, ST_ACKSENT);
574 NewState(fp, ST_OPENED);
575 if ((*fp->fn->LayerUp)(fp))
576 (*fp->parent->LayerUp)(fp->parent->object, fp);
578 (*fp->fn->LayerDown)(fp);
579 FsmInitRestartCounter(fp, FSM_TRM_TIMER);
580 FsmSendTerminateReq(fp);
581 NewState(fp, ST_CLOSING);
582 lcp_SendIdentification(&fp->link->lcp);
588 NewState(fp, ST_REQSENT);
593 if (dec.rejend != dec.rej && --fp->more.rejs <= 0) {
595 fp->link->name, fp->name);
596 lcp_SendIdentification(&fp->link->lcp);
597 fsm_Close(fp);
600 if (dec.nakend != dec.nak && --fp->more.naks <= 0) {
602 fp->link->name, fp->name);
603 lcp_SendIdentification(&fp->link->lcp);
604 fsm_Close(fp);
609 FsmRecvConfigAck(struct fsm *fp, struct fsmheader *lhp, struct mbuf *bp)
628 (*fp->fn->DecodeConfig)(fp, cp, cp + flen, MODE_ACK, &dec);
630 log_Printf(fp->LogLevel, " [EMPTY]\n");
632 switch (fp->state) {
635 (*fp->fn->SendTerminateAck)(fp, lhp->id);
641 FsmInitRestartCounter(fp, FSM_REQ_TIMER);
642 NewState(fp, ST_ACKRCVD);
645 FsmSendConfigReq(fp);
646 NewState(fp, ST_REQSENT);
649 FsmInitRestartCounter(fp, FSM_REQ_TIMER);
650 NewState(fp, ST_OPENED);
651 if ((*fp->fn->LayerUp)(fp))
652 (*fp->parent->LayerUp)(fp->parent->object, fp);
654 (*fp->fn->LayerDown)(fp);
655 FsmInitRestartCounter(fp, FSM_TRM_TIMER);
656 FsmSendTerminateReq(fp);
657 NewState(fp, ST_CLOSING);
658 lcp_SendIdentification(&fp->link->lcp);
662 (*fp->fn->LayerDown)(fp);
663 FsmSendConfigReq(fp);
664 NewState(fp, ST_REQSENT);
665 (*fp->parent->LayerDown)(fp->parent->object, fp);
672 FsmRecvConfigNak(struct fsm *fp, struct fsmheader *lhp, struct mbuf *bp)
689 switch (fp->state) {
692 log_Printf(fp->LogLevel, "%s: Oops, RCN in %s.\n",
693 fp->link->name, State2Nam(fp->state));
698 (*fp->fn->SendTerminateAck)(fp, lhp->id);
712 (*fp->fn->DecodeConfig)(fp, cp, cp + flen, MODE_NAK, &dec);
714 log_Printf(fp->LogLevel, " [EMPTY]\n");
716 switch (fp->state) {
719 FsmInitRestartCounter(fp, FSM_REQ_TIMER);
720 FsmSendConfigReq(fp);
723 (*fp->fn->LayerDown)(fp);
724 FsmSendConfigReq(fp);
725 NewState(fp, ST_REQSENT);
726 (*fp->parent->LayerDown)(fp->parent->object, fp);
729 FsmSendConfigReq(fp);
730 NewState(fp, ST_REQSENT);
738 FsmRecvTermReq(struct fsm *fp, struct fsmheader *lhp, struct mbuf *bp)
741 switch (fp->state) {
744 log_Printf(fp->LogLevel, "%s: Oops, RTR in %s\n",
745 fp->link->name, State2Nam(fp->state));
752 (*fp->fn->SendTerminateAck)(fp, lhp->id);
756 (*fp->fn->SendTerminateAck)(fp, lhp->id);
757 NewState(fp, ST_REQSENT);
760 (*fp->fn->LayerDown)(fp);
761 (*fp->fn->SendTerminateAck)(fp, lhp->id);
762 FsmInitRestartCounter(fp, FSM_TRM_TIMER);
763 timer_Start(&fp->FsmTimer); /* Start restart timer */
764 fp->restart = 0;
765 NewState(fp, ST_STOPPING);
766 (*fp->parent->LayerDown)(fp->parent->object, fp);
774 FsmRecvTermAck(struct fsm *fp, struct fsmheader *lhp __unused, struct mbuf *bp)
777 switch (fp->state) {
779 (*fp->fn->LayerFinish)(fp);
780 NewState(fp, ST_CLOSED);
781 (*fp->parent->LayerFinish)(fp->parent->object, fp);
784 (*fp->fn->LayerFinish)(fp);
785 NewState(fp, ST_STOPPED);
786 (*fp->parent->LayerFinish)(fp->parent->object, fp);
789 NewState(fp, ST_REQSENT);
792 (*fp->fn->LayerDown)(fp);
793 FsmSendConfigReq(fp);
794 NewState(fp, ST_REQSENT);
795 (*fp->parent->LayerDown)(fp->parent->object, fp);
802 FsmRecvConfigRej(struct fsm *fp, struct fsmheader *lhp, struct mbuf *bp)
817 lcp_SendIdentification(&fp->link->lcp);
822 switch (fp->state) {
825 log_Printf(fp->LogLevel, "%s: Oops, RCJ in %s.\n",
826 fp->link->name, State2Nam(fp->state));
831 (*fp->fn->SendTerminateAck)(fp, lhp->id);
845 (*fp->fn->DecodeConfig)(fp, cp, cp + flen, MODE_REJ, &dec);
847 log_Printf(fp->LogLevel, " [EMPTY]\n");
849 switch (fp->state) {
852 FsmInitRestartCounter(fp, FSM_REQ_TIMER);
853 FsmSendConfigReq(fp);
856 (*fp->fn->LayerDown)(fp);
857 FsmSendConfigReq(fp);
858 NewState(fp, ST_REQSENT);
859 (*fp->parent->LayerDown)(fp->parent->object, fp);
862 FsmSendConfigReq(fp);
863 NewState(fp, ST_REQSENT);
870 FsmRecvCodeRej(struct fsm *fp __unused, struct fsmheader *lhp __unused,
877 FsmRecvProtoRej(struct fsm *fp, struct fsmheader *lhp __unused, struct mbuf *bp)
879 struct physical *p = link2physical(fp->link);
888 log_Printf(fp->LogLevel, "%s: -- Protocol 0x%04x (%s) was rejected!\n",
889 fp->link->name, proto, hdlc_Protocol2Nam(proto));
897 fp->link->name);
900 if (fp->proto == PROTO_LCP) {
901 fp = &fp->link->ccp.fsm;
903 /* (*fp->fn->LayerFinish)(fp); */
904 switch (fp->state) {
907 NewState(fp, ST_CLOSED);
910 NewState(fp, ST_STOPPED);
914 /* (*fp->parent->LayerFinish)(fp->parent->object, fp); */
918 if (fp->proto == PROTO_LCP) {
920 fp->link->name);
921 fsm_Close(&fp->bundle->ncp.ipcp.fsm);
926 if (fp->proto == PROTO_LCP) {
928 fp->link->name);
929 fsm_Close(&fp->bundle->ncp.ipv6cp.fsm);
934 if (fp->proto == PROTO_LCP) {
935 struct lcp *lcp = fsm2lcp(fp);
939 fp->link->name);
940 fsm_Close(fp);
949 FsmRecvEchoReq(struct fsm *fp, struct fsmheader *lhp, struct mbuf *bp)
951 struct lcp *lcp = fsm2lcp(fp);
962 log_Printf(fp->LogLevel, "%s: RecvEchoReq: magic 0x%08lx is wrong,"
963 " expecting 0x%08lx\n", fp->link->name, (u_long)magic,
967 if (fp->state == ST_OPENED) {
969 fsm_Output(fp, CODE_ECHOREP, lhp->id, cp,
977 FsmRecvEchoRep(struct fsm *fp, struct fsmheader *lhp __unused, struct mbuf *bp)
979 if (fsm2lcp(fp))
980 bp = lqr_RecvEcho(fp, bp);
986 FsmRecvDiscReq(struct fsm *fp __unused, struct fsmheader *lhp __unused,
993 FsmRecvIdent(struct fsm *fp, struct fsmheader *lhp, struct mbuf *bp)
1004 if (magic != fp->link->lcp.his_magic)
1005 log_Printf(fp->LogLevel, "%s: RecvIdent: magic 0x%08lx is wrong,"
1006 " expecting 0x%08lx\n", fp->link->name, (u_long)magic,
1007 (u_long)fp->link->lcp.his_magic);
1009 lcp_RecvIdentification(&fp->link->lcp, cp + 4);
1015 FsmRecvTimeRemain(struct fsm *fp __unused, struct fsmheader *lhp __unused,
1022 FsmRecvResetReq(struct fsm *fp, struct fsmheader *lhp, struct mbuf *bp)
1024 if ((*fp->fn->RecvResetReq)(fp)) {
1030 link_SequenceQueue(fp->link);
1031 fsm_Output(fp, CODE_RESETACK, lhp->id, NULL, 0, MB_CCPOUT);
1037 FsmRecvResetAck(struct fsm *fp, struct fsmheader *lhp, struct mbuf *bp)
1039 (*fp->fn->RecvResetAck)(fp, lhp->id);
1044 fsm_Input(struct fsm *fp, struct mbuf *bp)
1059 "- dropped\n", fp->link->name, len, (int)ntohs(lh.length));
1064 if (lh.code < fp->min_code || lh.code > fp->max_code ||
1074 fsm_Output(fp, CODE_CODEREJ, id++, MBUF_CTOP(bp), bp->m_len, MB_UNKNOWN);
1080 if (lh.id != fp->reqid && codep->check_reqid &&
1081 Enabled(fp->bundle, OPT_IDCHECK)) {
1082 log_Printf(fp->LogLevel, "%s: Recv%s(%d), dropped (expected %d)\n",
1083 fp->link->name, codep->name, lh.id, fp->reqid);
1087 log_Printf(fp->LogLevel, "%s: Recv%s(%d) state = %s\n",
1088 fp->link->name, codep->name, lh.id, State2Nam(fp->state));
1090 if (codep->inc_reqid && (lh.id == fp->reqid ||
1091 (!Enabled(fp->bundle, OPT_IDCHECK) && codep->check_reqid)))
1092 fp->reqid++; /* That's the end of that ``exchange''.... */
1094 (*codep->recv)(fp, &lh, bp);
1098 fsm_NullRecvResetReq(struct fsm *fp)
1100 log_Printf(fp->LogLevel, "%s: Oops - received unexpected reset req\n",
1101 fp->link->name);
1106 fsm_NullRecvResetAck(struct fsm *fp, u_char id __unused)
1108 log_Printf(fp->LogLevel, "%s: Oops - received unexpected reset ack\n",
1109 fp->link->name);
1113 fsm_Reopen(struct fsm *fp)
1115 if (fp->state == ST_OPENED) {
1116 (*fp->fn->LayerDown)(fp);
1117 FsmInitRestartCounter(fp, FSM_REQ_TIMER);
1118 FsmSendConfigReq(fp);
1119 NewState(fp, ST_REQSENT);
1120 (*fp->parent->LayerDown)(fp->parent->object, fp);
1125 fsm2initial(struct fsm *fp)
1127 timer_Stop(&fp->FsmTimer);
1128 timer_Stop(&fp->OpenTimer);
1129 timer_Stop(&fp->StoppedTimer);
1130 if (fp->state == ST_STOPPED)
1131 fsm_Close(fp);
1132 if (fp->state > ST_INITIAL)
1133 fsm_Down(fp);
1134 if (fp->state > ST_INITIAL)
1135 fsm_Close(fp);