1995-01-31 06:29:58 +00:00
|
|
|
/*
|
|
|
|
* Written by Toshiharu OHNO (tony-o@iij.ad.jp)
|
|
|
|
*
|
|
|
|
* Copyright (C) 1993, Internet Initiative Japan, Inc. All rights reserverd.
|
|
|
|
*
|
|
|
|
* Redistribution and use in source and binary forms are permitted
|
|
|
|
* provided that the above copyright notice and this paragraph are
|
|
|
|
* duplicated in all such forms and that any documentation,
|
|
|
|
* advertising materials, and other materials related to such
|
|
|
|
* distribution and use acknowledge that the software was developed
|
|
|
|
* by the Internet Initiative Japan. The name of the
|
|
|
|
* IIJ may not be used to endorse or promote products derived
|
|
|
|
* from this software without specific prior written permission.
|
|
|
|
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
|
|
|
|
* IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
|
|
|
|
* WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
|
|
|
|
*
|
1998-06-25 22:33:31 +00:00
|
|
|
* $Id: fsm.h,v 1.18 1998/06/20 00:19:38 brian Exp $
|
1995-01-31 06:29:58 +00:00
|
|
|
*
|
|
|
|
* TODO:
|
|
|
|
*/
|
1995-02-26 12:18:08 +00:00
|
|
|
|
1995-01-31 06:29:58 +00:00
|
|
|
/*
|
|
|
|
* State of machine
|
|
|
|
*/
|
|
|
|
#define ST_INITIAL 0
|
|
|
|
#define ST_STARTING 1
|
|
|
|
#define ST_CLOSED 2
|
|
|
|
#define ST_STOPPED 3
|
|
|
|
#define ST_CLOSING 4
|
|
|
|
#define ST_STOPPING 5
|
|
|
|
#define ST_REQSENT 6
|
|
|
|
#define ST_ACKRCVD 7
|
|
|
|
#define ST_ACKSENT 8
|
|
|
|
#define ST_OPENED 9
|
|
|
|
|
|
|
|
#define ST_MAX 10
|
|
|
|
#define ST_UNDEF -1
|
|
|
|
|
|
|
|
#define MODE_REQ 0
|
|
|
|
#define MODE_NAK 1
|
|
|
|
#define MODE_REJ 2
|
1995-02-26 12:18:08 +00:00
|
|
|
#define MODE_NOP 3
|
1997-12-03 10:23:54 +00:00
|
|
|
#define MODE_ACK 4 /* pseudo mode for ccp negotiations */
|
1995-01-31 06:29:58 +00:00
|
|
|
|
1998-01-20 22:47:48 +00:00
|
|
|
#define OPEN_PASSIVE -1
|
1995-01-31 06:29:58 +00:00
|
|
|
|
1998-05-21 21:49:08 +00:00
|
|
|
struct fsm;
|
|
|
|
|
|
|
|
struct fsm_decode {
|
|
|
|
u_char ack[100], *ackend;
|
|
|
|
u_char nak[100], *nakend;
|
|
|
|
u_char rej[100], *rejend;
|
|
|
|
};
|
|
|
|
|
|
|
|
struct fsm_callbacks {
|
|
|
|
int (*LayerUp) (struct fsm *); /* Layer is now up (tlu) */
|
|
|
|
void (*LayerDown) (struct fsm *); /* About to come down (tld) */
|
|
|
|
void (*LayerStart) (struct fsm *); /* Layer about to start up (tls) */
|
|
|
|
void (*LayerFinish) (struct fsm *); /* Layer now down (tlf) */
|
|
|
|
void (*InitRestartCounter) (struct fsm *); /* Set fsm timer load */
|
|
|
|
void (*SendConfigReq) (struct fsm *); /* Send REQ please */
|
|
|
|
void (*SentTerminateReq) (struct fsm *); /* Term REQ just sent */
|
|
|
|
void (*SendTerminateAck) (struct fsm *, u_char); /* Send Term ACK please */
|
|
|
|
void (*DecodeConfig) (struct fsm *, u_char *, int, int, struct fsm_decode *);
|
|
|
|
/* Deal with incoming data */
|
|
|
|
void (*RecvResetReq) (struct fsm *fp); /* Reset output */
|
|
|
|
void (*RecvResetAck) (struct fsm *fp, u_char); /* Reset input */
|
|
|
|
};
|
|
|
|
|
|
|
|
struct fsm_parent {
|
|
|
|
void (*LayerStart) (void *, struct fsm *); /* tls */
|
|
|
|
void (*LayerUp) (void *, struct fsm *); /* tlu */
|
|
|
|
void (*LayerDown) (void *, struct fsm *); /* tld */
|
|
|
|
void (*LayerFinish) (void *, struct fsm *); /* tlf */
|
|
|
|
void *object;
|
|
|
|
};
|
|
|
|
|
|
|
|
struct link;
|
|
|
|
struct bundle;
|
|
|
|
|
1995-01-31 06:29:58 +00:00
|
|
|
struct fsm {
|
1997-11-22 03:37:54 +00:00
|
|
|
const char *name; /* Name of protocol */
|
1995-01-31 06:29:58 +00:00
|
|
|
u_short proto; /* Protocol number */
|
1998-05-21 21:49:08 +00:00
|
|
|
u_short min_code;
|
1995-01-31 06:29:58 +00:00
|
|
|
u_short max_code;
|
1998-05-21 21:49:08 +00:00
|
|
|
int open_mode; /* Delay before config REQ (-1 forever) */
|
1997-08-25 00:29:32 +00:00
|
|
|
int state; /* State of the machine */
|
Implement Reset{Req,Ack} properly, as per rfc 1962.
(I completely mis-read the rfc last time 'round!)
This means:
o Better CCP/WARN Reset diagnostics.
o After we've sent a REQ and before we've received an ACK, we drop
incoming compressed data and send another REQ.
o Before sending an ACK, re-sequence all pending PRI_NORMAL data in
the modem queue so that pending packets won't get to the peer
*after* the ResetAck.
o Send ACKs with the `identifier' from the REQ frame.
o After we've received a correct ACK, duplicate ACKs are ok (and will
reset our history).
o Incorrect ACKs (not matching the last REQ) are moaned about and dropped.
Also,
o Calculate the correct FCS after compressing a packet. DEFLATE
*may* produce an mbuf with more than a single link in the chain,
but HdlcOutput didn't know how to calculate the FCS :-(
o Make `struct fsm'::reqid a u_char, not an int.
This fix will prevent us from sending id `255' 2,000,000,000 times
before wrapping to `0' for another 2,000,000,000 sends :-/
o Bump the version number a little.
The end result: DEFLATE now works over an unreliable link layer.
I can txfr a 1.5Mb kernel over a (rather bad) null-modem
cable at an average of 21679 bytes per second using rcp.
Repeat after me: Don't test compression using a loopback ppp/tcp setup as
we never lose packets and therefore never have to reset!
1998-01-10 01:55:11 +00:00
|
|
|
u_char reqid; /* Next request id */
|
1997-08-25 00:29:32 +00:00
|
|
|
int restart; /* Restart counter value */
|
1998-05-21 21:49:08 +00:00
|
|
|
int maxconfig; /* Max config REQ before a close() */
|
1995-01-31 06:29:58 +00:00
|
|
|
|
|
|
|
struct pppTimer FsmTimer; /* Restart Timer */
|
1998-01-20 22:47:48 +00:00
|
|
|
struct pppTimer OpenTimer; /* Delay before opening */
|
1995-01-31 06:29:58 +00:00
|
|
|
|
1997-08-20 23:47:53 +00:00
|
|
|
/*
|
|
|
|
* This timer times the ST_STOPPED state out after the given value
|
1997-08-25 00:29:32 +00:00
|
|
|
* (specified via "set stopped ..."). Although this isn't specified in the
|
|
|
|
* rfc, the rfc *does* say that "the application may use higher level
|
|
|
|
* timers to avoid deadlock". The StoppedTimer takes effect when the other
|
|
|
|
* side ABENDs rather than going into ST_ACKSENT (and sending the ACK),
|
|
|
|
* causing ppp to time out and drop into ST_STOPPED. At this point,
|
|
|
|
* nothing will change this state :-(
|
1997-08-20 23:47:53 +00:00
|
|
|
*/
|
|
|
|
struct pppTimer StoppedTimer;
|
|
|
|
int LogLevel;
|
|
|
|
|
1998-05-21 21:49:08 +00:00
|
|
|
/* The link layer active with this FSM (may be our bundle below) */
|
|
|
|
struct link *link;
|
|
|
|
|
|
|
|
/* Our high-level link */
|
|
|
|
struct bundle *bundle;
|
|
|
|
|
|
|
|
const struct fsm_parent *parent;
|
|
|
|
const struct fsm_callbacks *fn;
|
1995-01-31 06:29:58 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
struct fsmheader {
|
1997-08-25 00:29:32 +00:00
|
|
|
u_char code; /* Request code */
|
|
|
|
u_char id; /* Identification */
|
|
|
|
u_short length; /* Length of packet */
|
1995-01-31 06:29:58 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
#define CODE_CONFIGREQ 1
|
|
|
|
#define CODE_CONFIGACK 2
|
|
|
|
#define CODE_CONFIGNAK 3
|
|
|
|
#define CODE_CONFIGREJ 4
|
|
|
|
#define CODE_TERMREQ 5
|
|
|
|
#define CODE_TERMACK 6
|
|
|
|
#define CODE_CODEREJ 7
|
|
|
|
#define CODE_PROTOREJ 8
|
1997-08-25 00:29:32 +00:00
|
|
|
#define CODE_ECHOREQ 9 /* Used in LCP */
|
|
|
|
#define CODE_ECHOREP 10 /* Used in LCP */
|
1995-01-31 06:29:58 +00:00
|
|
|
#define CODE_DISCREQ 11
|
1997-08-25 00:29:32 +00:00
|
|
|
#define CODE_IDENT 12 /* Used in LCP Extension */
|
|
|
|
#define CODE_TIMEREM 13 /* Used in LCP Extension */
|
|
|
|
#define CODE_RESETREQ 14 /* Used in CCP */
|
|
|
|
#define CODE_RESETACK 15 /* Used in CCP */
|
1995-01-31 06:29:58 +00:00
|
|
|
|
1998-05-21 21:49:08 +00:00
|
|
|
/* Minimum config req size. This struct is *only* used for it's size */
|
1995-01-31 06:29:58 +00:00
|
|
|
struct fsmconfig {
|
|
|
|
u_char type;
|
|
|
|
u_char length;
|
|
|
|
};
|
|
|
|
|
1998-05-21 21:49:08 +00:00
|
|
|
extern void fsm_Init(struct fsm *, const char *, u_short, int, int, int, int,
|
|
|
|
struct bundle *, struct link *, const struct fsm_parent *,
|
|
|
|
struct fsm_callbacks *, const char *[3]);
|
|
|
|
extern void fsm_Output(struct fsm *, u_int, u_int, u_char *, int);
|
|
|
|
extern void fsm_Open(struct fsm *);
|
|
|
|
extern void fsm_Up(struct fsm *);
|
|
|
|
extern void fsm_Down(struct fsm *);
|
|
|
|
extern void fsm_Input(struct fsm *, struct mbuf *);
|
|
|
|
extern void fsm_Close(struct fsm *);
|
1998-06-20 00:19:42 +00:00
|
|
|
extern void fsm_NullRecvResetReq(struct fsm *);
|
|
|
|
extern void fsm_NullRecvResetAck(struct fsm *, u_char);
|
1998-06-25 22:33:31 +00:00
|
|
|
extern void fsm_Reopen(struct fsm *);
|
1998-06-20 00:19:42 +00:00
|
|
|
extern void fsm2initial(struct fsm *);
|
1998-05-21 21:49:08 +00:00
|
|
|
extern const char *State2Nam(u_int);
|