X-Git-Url: http://git.ozlabs.org/?p=ppp.git;a=blobdiff_plain;f=modules%2Fppp_ahdlc.c;h=93c5226189de10cd8aa140a5f72d570966a2eef8;hp=79a2d05d870b33f860cc597f66724ff89ee456b3;hb=cde2830f103bd3ad372b0e33263d589ad7db88e2;hpb=cac90e238d9c18c513cf0d45dfdd1e217df2a176 diff --git a/modules/ppp_ahdlc.c b/modules/ppp_ahdlc.c index 79a2d05..93c5226 100644 --- a/modules/ppp_ahdlc.c +++ b/modules/ppp_ahdlc.c @@ -24,7 +24,7 @@ * OBLIGATION TO PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, * OR MODIFICATIONS. * - * $Id: ppp_ahdlc.c,v 1.5 1997/03/04 03:31:51 paulus Exp $ + * $Id: ppp_ahdlc.c,v 1.9 1999/02/26 10:52:07 paulus Exp $ */ /* @@ -42,6 +42,9 @@ #include #else #include +#ifdef __osf__ +#include +#endif #endif /* SVR4 */ #include @@ -91,8 +94,6 @@ struct streamtab ppp_ahdlcinfo = { &rinit, &winit, NULL, NULL }; -int ppp_ahdlc_count; - typedef struct ahdlc_state { int flags; mblk_t *cur_frame; @@ -168,8 +169,7 @@ MOD_OPEN(ahdlc_open) WR(q)->q_ptr = (caddr_t) sp; sp->xaccm[0] = ~0; sp->xaccm[3] = 0x60000000; - sp->mru = 1500; - ++ppp_ahdlc_count; + sp->mru = PPP_MRU; qprocson(q); } return 0; @@ -187,7 +187,8 @@ MOD_CLOSE(ahdlc_close) state->cur_frame = 0; } FREE(q->q_ptr, sizeof(ahdlc_state_t)); - --ppp_ahdlc_count; + q->q_ptr = NULL; + OTHERQ(q)->q_ptr = NULL; } return 0; } @@ -204,6 +205,12 @@ ahdlc_wput(q, mp) struct ppp_stats *psp; state = (ahdlc_state_t *) q->q_ptr; + if (state == 0) { + DPRINT("state == 0 in ahdlc_wput\n"); + freemsg(mp); + return 0; + } + switch (mp->b_datap->db_type) { case M_DATA: /* @@ -222,6 +229,10 @@ ahdlc_wput(q, mp) if (iop->ioc_count < sizeof(u_int32_t) || iop->ioc_count > sizeof(ext_accm)) break; + if (mp->b_cont == 0) { + DPRINT1("ahdlc_wput/%d: PPPIO_XACCM b_cont = 0!\n", state->unit); + break; + } bcopy((caddr_t)mp->b_cont->b_rptr, (caddr_t)state->xaccm, iop->ioc_count); state->xaccm[2] &= ~0x40000000; /* don't escape 0x5e */ @@ -233,6 +244,10 @@ ahdlc_wput(q, mp) case PPPIO_RACCM: if (iop->ioc_count != sizeof(u_int32_t)) break; + if (mp->b_cont == 0) { + DPRINT1("ahdlc_wput/%d: PPPIO_RACCM b_cont = 0!\n", state->unit); + break; + } bcopy((caddr_t)mp->b_cont->b_rptr, (caddr_t)&state->raccm, sizeof(u_int32_t)); iop->ioc_count = 0; @@ -315,6 +330,7 @@ ahdlc_wput(q, mp) default: putnext(q, mp); } + return 0; } @@ -327,6 +343,13 @@ ahdlc_rput(q, mp) uchar_t *cp; ahdlc_state_t *state; + state = (ahdlc_state_t *) q->q_ptr; + if (state == 0) { + DPRINT("state == 0 in ahdlc_rput\n"); + freemsg(mp); + return 0; + } + switch (mp->b_datap->db_type) { case M_DATA: unstuff_chars(q, mp); @@ -334,7 +357,6 @@ ahdlc_rput(q, mp) break; case M_HANGUP: - state = (ahdlc_state_t *) q->q_ptr; if (state->cur_frame != 0) { /* XXX would like to send this up for debugging */ freemsg(state->cur_frame); @@ -384,12 +406,14 @@ stuff_frame(q, mp) goto bomb; /* - * Put in an initial flag for now. We'll remove it later - * if we decide we don't need it. + * Put in an initial flag, unless the serial driver currently has + * packets still to be transmitted in its queue. */ dp = op->b_wptr; - *dp++ = PPP_FLAG; - --olen; + if (qsize(q->q_next) == 0) { + *dp++ = PPP_FLAG; + --olen; + } /* * For LCP packets with code values between 1 and 7 (Conf-Req @@ -501,12 +525,6 @@ stuff_frame(q, mp) *dp++ = PPP_FLAG; op->b_wptr = dp; - /* - * Remove the initial flag, if possible. - */ - if (qsize(q->q_next) > 0) - ++omsg->b_rptr; - /* * Update statistics. */