mirror of
https://git.savannah.nongnu.org/git/lwip.git
synced 2025-08-11 08:54:38 +08:00
Fixed bug #28195 (PPP: remove duplicate TCP/IP protocol header definitions - use the lwIP ones) - deleted unused header file
This commit is contained in:
parent
81640c4a83
commit
53bc34f3e2
@ -47,14 +47,6 @@
|
|||||||
#define INCR(counter)
|
#define INCR(counter)
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#if defined(NO_CHAR_BITFIELDS)
|
|
||||||
#define getip_hl(base) ((base).ip_hl_v&0xf)
|
|
||||||
#define getth_off(base) (((base).th_x2_off&0xf0)>>4)
|
|
||||||
#else
|
|
||||||
#define getip_hl(base) ((base).ip_hl)
|
|
||||||
#define getth_off(base) ((base).th_off)
|
|
||||||
#endif
|
|
||||||
|
|
||||||
void
|
void
|
||||||
vj_compress_init(struct vjcompress *comp)
|
vj_compress_init(struct vjcompress *comp)
|
||||||
{
|
{
|
||||||
@ -145,11 +137,11 @@ vj_compress_init(struct vjcompress *comp)
|
|||||||
u_int
|
u_int
|
||||||
vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
||||||
{
|
{
|
||||||
register struct ip *ip = (struct ip *)pb->payload;
|
register struct ip_hdr *ip = (struct ip_hdr *)pb->payload;
|
||||||
register struct cstate *cs = comp->last_cs->cs_next;
|
register struct cstate *cs = comp->last_cs->cs_next;
|
||||||
register u_short hlen = getip_hl(*ip);
|
register u_short hlen = IPH_HL(ip);
|
||||||
register struct tcphdr *oth;
|
register struct tcp_hdr *oth;
|
||||||
register struct tcphdr *th;
|
register struct tcp_hdr *th;
|
||||||
register u_short deltaS, deltaA;
|
register u_short deltaS, deltaA;
|
||||||
register u_long deltaL;
|
register u_long deltaL;
|
||||||
register u_int changes = 0;
|
register u_int changes = 0;
|
||||||
@ -159,7 +151,7 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
/*
|
/*
|
||||||
* Check that the packet is IP proto TCP.
|
* Check that the packet is IP proto TCP.
|
||||||
*/
|
*/
|
||||||
if (ip->ip_p != IPPROTO_TCP) {
|
if (IPH_PROTO(ip) != IPPROTO_TCP) {
|
||||||
return (TYPE_IP);
|
return (TYPE_IP);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -168,11 +160,11 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
* `compressible' (i.e., ACK isn't set or some other control bit is
|
* `compressible' (i.e., ACK isn't set or some other control bit is
|
||||||
* set).
|
* set).
|
||||||
*/
|
*/
|
||||||
if ((ip->ip_off & htons(0x3fff)) || pb->tot_len < 40) {
|
if ((IPH_OFFSET(ip) & htons(0x3fff)) || pb->tot_len < 40) {
|
||||||
return (TYPE_IP);
|
return (TYPE_IP);
|
||||||
}
|
}
|
||||||
th = (struct tcphdr *)&((long *)ip)[hlen];
|
th = (struct tcp_hdr *)&((long *)ip)[hlen];
|
||||||
if ((th->th_flags & (TCP_SYN|TCP_FIN|TCP_RST|TCP_ACK)) != TCP_ACK) {
|
if ((TCPH_FLAGS(th) & (TCP_SYN|TCP_FIN|TCP_RST|TCP_ACK)) != TCP_ACK) {
|
||||||
return (TYPE_IP);
|
return (TYPE_IP);
|
||||||
}
|
}
|
||||||
/*
|
/*
|
||||||
@ -183,9 +175,9 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
* again & we don't have to do any reordering if it's used.
|
* again & we don't have to do any reordering if it's used.
|
||||||
*/
|
*/
|
||||||
INCR(vjs_packets);
|
INCR(vjs_packets);
|
||||||
if (ip->ip_src.s_addr != cs->cs_ip.ip_src.s_addr
|
if (ip->src.addr != cs->cs_ip.src.addr
|
||||||
|| ip->ip_dst.s_addr != cs->cs_ip.ip_dst.s_addr
|
|| ip->dest.addr != cs->cs_ip.dest.addr
|
||||||
|| *(long *)th != ((long *)&cs->cs_ip)[getip_hl(cs->cs_ip)]) {
|
|| *(long *)th != ((long *)&cs->cs_ip)[IPH_HL(&cs->cs_ip)]) {
|
||||||
/*
|
/*
|
||||||
* Wasn't the first -- search for it.
|
* Wasn't the first -- search for it.
|
||||||
*
|
*
|
||||||
@ -204,9 +196,9 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
do {
|
do {
|
||||||
lcs = cs; cs = cs->cs_next;
|
lcs = cs; cs = cs->cs_next;
|
||||||
INCR(vjs_searches);
|
INCR(vjs_searches);
|
||||||
if (ip->ip_src.s_addr == cs->cs_ip.ip_src.s_addr
|
if (ip->src.addr == cs->cs_ip.src.addr
|
||||||
&& ip->ip_dst.s_addr == cs->cs_ip.ip_dst.s_addr
|
&& ip->dest.addr == cs->cs_ip.dest.addr
|
||||||
&& *(long *)th == ((long *)&cs->cs_ip)[getip_hl(cs->cs_ip)]) {
|
&& *(long *)th == ((long *)&cs->cs_ip)[IPH_HL(&cs->cs_ip)]) {
|
||||||
goto found;
|
goto found;
|
||||||
}
|
}
|
||||||
} while (cs != lastcs);
|
} while (cs != lastcs);
|
||||||
@ -221,7 +213,7 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
*/
|
*/
|
||||||
INCR(vjs_misses);
|
INCR(vjs_misses);
|
||||||
comp->last_cs = lcs;
|
comp->last_cs = lcs;
|
||||||
hlen += getth_off(*th);
|
hlen += TCPH_OFFSET(th);
|
||||||
hlen <<= 2;
|
hlen <<= 2;
|
||||||
/* Check that the IP/TCP headers are contained in the first buffer. */
|
/* Check that the IP/TCP headers are contained in the first buffer. */
|
||||||
if (hlen > pb->len) {
|
if (hlen > pb->len) {
|
||||||
@ -242,9 +234,9 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
oth = (struct tcphdr *)&((long *)&cs->cs_ip)[hlen];
|
oth = (struct tcp_hdr *)&((long *)&cs->cs_ip)[hlen];
|
||||||
deltaS = hlen;
|
deltaS = hlen;
|
||||||
hlen += getth_off(*th);
|
hlen += TCPH_OFFSET(th);
|
||||||
hlen <<= 2;
|
hlen <<= 2;
|
||||||
/* Check that the IP/TCP headers are contained in the first buffer. */
|
/* Check that the IP/TCP headers are contained in the first buffer. */
|
||||||
if (hlen > pb->len) {
|
if (hlen > pb->len) {
|
||||||
@ -266,9 +258,9 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
if (((u_short *)ip)[0] != ((u_short *)&cs->cs_ip)[0]
|
if (((u_short *)ip)[0] != ((u_short *)&cs->cs_ip)[0]
|
||||||
|| ((u_short *)ip)[3] != ((u_short *)&cs->cs_ip)[3]
|
|| ((u_short *)ip)[3] != ((u_short *)&cs->cs_ip)[3]
|
||||||
|| ((u_short *)ip)[4] != ((u_short *)&cs->cs_ip)[4]
|
|| ((u_short *)ip)[4] != ((u_short *)&cs->cs_ip)[4]
|
||||||
|| getth_off(*th) != getth_off(*oth)
|
|| TCPH_OFFSET(th) != TCPH_OFFSET(oth)
|
||||||
|| (deltaS > 5 && BCMP(ip + 1, &cs->cs_ip + 1, (deltaS - 5) << 2))
|
|| (deltaS > 5 && BCMP(ip + 1, &cs->cs_ip + 1, (deltaS - 5) << 2))
|
||||||
|| (getth_off(*th) > 5 && BCMP(th + 1, oth + 1, (getth_off(*th) - 5) << 2))) {
|
|| (TCPH_OFFSET(th) > 5 && BCMP(th + 1, oth + 1, (TCPH_OFFSET(th) - 5) << 2))) {
|
||||||
goto uncompressed;
|
goto uncompressed;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -278,11 +270,11 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
* ack, seq (the order minimizes the number of temporaries
|
* ack, seq (the order minimizes the number of temporaries
|
||||||
* needed in this section of code).
|
* needed in this section of code).
|
||||||
*/
|
*/
|
||||||
if (th->th_flags & TCP_URG) {
|
if (TCPH_FLAGS(th) & TCP_URG) {
|
||||||
deltaS = ntohs(th->th_urp);
|
deltaS = ntohs(th->urgp);
|
||||||
ENCODEZ(deltaS);
|
ENCODEZ(deltaS);
|
||||||
changes |= NEW_U;
|
changes |= NEW_U;
|
||||||
} else if (th->th_urp != oth->th_urp) {
|
} else if (th->urgp != oth->urgp) {
|
||||||
/* argh! URG not set but urp changed -- a sensible
|
/* argh! URG not set but urp changed -- a sensible
|
||||||
* implementation should never do this but RFC793
|
* implementation should never do this but RFC793
|
||||||
* doesn't prohibit the change so we have to deal
|
* doesn't prohibit the change so we have to deal
|
||||||
@ -290,12 +282,12 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
goto uncompressed;
|
goto uncompressed;
|
||||||
}
|
}
|
||||||
|
|
||||||
if ((deltaS = (u_short)(ntohs(th->th_win) - ntohs(oth->th_win))) != 0) {
|
if ((deltaS = (u_short)(ntohs(th->wnd) - ntohs(oth->wnd))) != 0) {
|
||||||
ENCODE(deltaS);
|
ENCODE(deltaS);
|
||||||
changes |= NEW_W;
|
changes |= NEW_W;
|
||||||
}
|
}
|
||||||
|
|
||||||
if ((deltaL = ntohl(th->th_ack) - ntohl(oth->th_ack)) != 0) {
|
if ((deltaL = ntohl(th->ackno) - ntohl(oth->ackno)) != 0) {
|
||||||
if (deltaL > 0xffff) {
|
if (deltaL > 0xffff) {
|
||||||
goto uncompressed;
|
goto uncompressed;
|
||||||
}
|
}
|
||||||
@ -304,7 +296,7 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
changes |= NEW_A;
|
changes |= NEW_A;
|
||||||
}
|
}
|
||||||
|
|
||||||
if ((deltaL = ntohl(th->th_seq) - ntohl(oth->th_seq)) != 0) {
|
if ((deltaL = ntohl(th->seqno) - ntohl(oth->seqno)) != 0) {
|
||||||
if (deltaL > 0xffff) {
|
if (deltaL > 0xffff) {
|
||||||
goto uncompressed;
|
goto uncompressed;
|
||||||
}
|
}
|
||||||
@ -323,8 +315,8 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
* retransmitted ack or window probe. Send it uncompressed
|
* retransmitted ack or window probe. Send it uncompressed
|
||||||
* in case the other side missed the compressed version.
|
* in case the other side missed the compressed version.
|
||||||
*/
|
*/
|
||||||
if (ip->ip_len != cs->cs_ip.ip_len &&
|
if (IPH_LEN(ip) != IPH_LEN(&cs->cs_ip) &&
|
||||||
ntohs(cs->cs_ip.ip_len) == hlen) {
|
ntohs(IPH_LEN(&cs->cs_ip)) == hlen) {
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -339,7 +331,7 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
goto uncompressed;
|
goto uncompressed;
|
||||||
|
|
||||||
case NEW_S|NEW_A:
|
case NEW_S|NEW_A:
|
||||||
if (deltaS == deltaA && deltaS == ntohs(cs->cs_ip.ip_len) - hlen) {
|
if (deltaS == deltaA && deltaS == ntohs(IPH_LEN(&cs->cs_ip)) - hlen) {
|
||||||
/* special case for echoed terminal traffic */
|
/* special case for echoed terminal traffic */
|
||||||
changes = SPECIAL_I;
|
changes = SPECIAL_I;
|
||||||
cp = new_seq;
|
cp = new_seq;
|
||||||
@ -347,7 +339,7 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
break;
|
break;
|
||||||
|
|
||||||
case NEW_S:
|
case NEW_S:
|
||||||
if (deltaS == ntohs(cs->cs_ip.ip_len) - hlen) {
|
if (deltaS == ntohs(IPH_LEN(&cs->cs_ip)) - hlen) {
|
||||||
/* special case for data xfer */
|
/* special case for data xfer */
|
||||||
changes = SPECIAL_D;
|
changes = SPECIAL_D;
|
||||||
cp = new_seq;
|
cp = new_seq;
|
||||||
@ -355,19 +347,19 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
deltaS = (u_short)(ntohs(ip->ip_id) - ntohs(cs->cs_ip.ip_id));
|
deltaS = (u_short)(ntohs(IPH_ID(ip)) - ntohs(IPH_ID(&cs->cs_ip)));
|
||||||
if (deltaS != 1) {
|
if (deltaS != 1) {
|
||||||
ENCODEZ(deltaS);
|
ENCODEZ(deltaS);
|
||||||
changes |= NEW_I;
|
changes |= NEW_I;
|
||||||
}
|
}
|
||||||
if (th->th_flags & TCP_PSH) {
|
if (TCPH_FLAGS(th) & TCP_PSH) {
|
||||||
changes |= TCP_PUSH_BIT;
|
changes |= TCP_PUSH_BIT;
|
||||||
}
|
}
|
||||||
/*
|
/*
|
||||||
* Grab the cksum before we overwrite it below. Then update our
|
* Grab the cksum before we overwrite it below. Then update our
|
||||||
* state with this packet's header.
|
* state with this packet's header.
|
||||||
*/
|
*/
|
||||||
deltaA = ntohs(th->th_sum);
|
deltaA = ntohs(th->chksum);
|
||||||
BCOPY(ip, &cs->cs_ip, hlen);
|
BCOPY(ip, &cs->cs_ip, hlen);
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@ -412,7 +404,7 @@ vj_compress_tcp(struct vjcompress *comp, struct pbuf *pb)
|
|||||||
*/
|
*/
|
||||||
uncompressed:
|
uncompressed:
|
||||||
BCOPY(ip, &cs->cs_ip, hlen);
|
BCOPY(ip, &cs->cs_ip, hlen);
|
||||||
ip->ip_p = cs->cs_id;
|
IPH_PROTO_SET(ip, cs->cs_id);
|
||||||
comp->last_xmit = cs->cs_id;
|
comp->last_xmit = cs->cs_id;
|
||||||
return (TYPE_UNCOMPRESSED_TCP);
|
return (TYPE_UNCOMPRESSED_TCP);
|
||||||
}
|
}
|
||||||
@ -436,24 +428,24 @@ vj_uncompress_uncomp(struct pbuf *nb, struct vjcompress *comp)
|
|||||||
{
|
{
|
||||||
register u_int hlen;
|
register u_int hlen;
|
||||||
register struct cstate *cs;
|
register struct cstate *cs;
|
||||||
register struct ip *ip;
|
register struct ip_hdr *ip;
|
||||||
|
|
||||||
ip = (struct ip *)nb->payload;
|
ip = (struct ip_hdr *)nb->payload;
|
||||||
hlen = getip_hl(*ip) << 2;
|
hlen = IPH_HL(ip) << 2;
|
||||||
if (ip->ip_p >= MAX_SLOTS
|
if (IPH_PROTO(ip) >= MAX_SLOTS
|
||||||
|| hlen + sizeof(struct tcphdr) > nb->len
|
|| hlen + sizeof(struct tcp_hdr) > nb->len
|
||||||
|| (hlen += getth_off(*((struct tcphdr *)&((char *)ip)[hlen])) << 2)
|
|| (hlen += TCPH_OFFSET(((struct tcp_hdr *)&((char *)ip)[hlen])) << 2)
|
||||||
> nb->len
|
> nb->len
|
||||||
|| hlen > MAX_HDR) {
|
|| hlen > MAX_HDR) {
|
||||||
PPPDEBUG((LOG_INFO, "vj_uncompress_uncomp: bad cid=%d, hlen=%d buflen=%d\n",
|
PPPDEBUG((LOG_INFO, "vj_uncompress_uncomp: bad cid=%d, hlen=%d buflen=%d\n",
|
||||||
ip->ip_p, hlen, nb->len));
|
IPH_PROTO(ip), hlen, nb->len));
|
||||||
comp->flags |= VJF_TOSS;
|
comp->flags |= VJF_TOSS;
|
||||||
INCR(vjs_errorin);
|
INCR(vjs_errorin);
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
cs = &comp->rstate[comp->last_recv = ip->ip_p];
|
cs = &comp->rstate[comp->last_recv = IPH_PROTO(ip)];
|
||||||
comp->flags &=~ VJF_TOSS;
|
comp->flags &=~ VJF_TOSS;
|
||||||
ip->ip_p = IPPROTO_TCP;
|
IPH_PROTO_SET(ip, IPPROTO_TCP);
|
||||||
BCOPY(ip, &cs->cs_ip, hlen);
|
BCOPY(ip, &cs->cs_ip, hlen);
|
||||||
cs->cs_hlen = hlen;
|
cs->cs_hlen = hlen;
|
||||||
INCR(vjs_uncompressedin);
|
INCR(vjs_uncompressedin);
|
||||||
@ -472,7 +464,7 @@ int
|
|||||||
vj_uncompress_tcp(struct pbuf **nb, struct vjcompress *comp)
|
vj_uncompress_tcp(struct pbuf **nb, struct vjcompress *comp)
|
||||||
{
|
{
|
||||||
u_char *cp;
|
u_char *cp;
|
||||||
struct tcphdr *th;
|
struct tcp_hdr *th;
|
||||||
struct cstate *cs;
|
struct cstate *cs;
|
||||||
u_short *bp;
|
u_short *bp;
|
||||||
struct pbuf *n0 = *nb;
|
struct pbuf *n0 = *nb;
|
||||||
@ -507,57 +499,57 @@ vj_uncompress_tcp(struct pbuf **nb, struct vjcompress *comp)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
cs = &comp->rstate[comp->last_recv];
|
cs = &comp->rstate[comp->last_recv];
|
||||||
hlen = getip_hl(cs->cs_ip) << 2;
|
hlen = IPH_HL(&cs->cs_ip) << 2;
|
||||||
th = (struct tcphdr *)&((u_char *)&cs->cs_ip)[hlen];
|
th = (struct tcp_hdr *)&((u_char *)&cs->cs_ip)[hlen];
|
||||||
th->th_sum = htons((*cp << 8) | cp[1]);
|
th->chksum = htons((*cp << 8) | cp[1]);
|
||||||
cp += 2;
|
cp += 2;
|
||||||
if (changes & TCP_PUSH_BIT) {
|
if (changes & TCP_PUSH_BIT) {
|
||||||
th->th_flags |= TCP_PSH;
|
TCPH_SET_FLAG(th, TCP_PSH);
|
||||||
} else {
|
} else {
|
||||||
th->th_flags &=~ TCP_PSH;
|
TCPH_UNSET_FLAG(th, TCP_PSH);
|
||||||
}
|
}
|
||||||
|
|
||||||
switch (changes & SPECIALS_MASK) {
|
switch (changes & SPECIALS_MASK) {
|
||||||
case SPECIAL_I:
|
case SPECIAL_I:
|
||||||
{
|
{
|
||||||
register u32_t i = ntohs(cs->cs_ip.ip_len) - cs->cs_hlen;
|
register u32_t i = ntohs(IPH_LEN(&cs->cs_ip)) - cs->cs_hlen;
|
||||||
/* some compilers can't nest inline assembler.. */
|
/* some compilers can't nest inline assembler.. */
|
||||||
tmp = ntohl(th->th_ack) + i;
|
tmp = ntohl(th->ackno) + i;
|
||||||
th->th_ack = htonl(tmp);
|
th->ackno = htonl(tmp);
|
||||||
tmp = ntohl(th->th_seq) + i;
|
tmp = ntohl(th->seqno) + i;
|
||||||
th->th_seq = htonl(tmp);
|
th->seqno = htonl(tmp);
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case SPECIAL_D:
|
case SPECIAL_D:
|
||||||
/* some compilers can't nest inline assembler.. */
|
/* some compilers can't nest inline assembler.. */
|
||||||
tmp = ntohl(th->th_seq) + ntohs(cs->cs_ip.ip_len) - cs->cs_hlen;
|
tmp = ntohl(th->seqno) + ntohs(IPH_LEN(&cs->cs_ip)) - cs->cs_hlen;
|
||||||
th->th_seq = htonl(tmp);
|
th->seqno = htonl(tmp);
|
||||||
break;
|
break;
|
||||||
|
|
||||||
default:
|
default:
|
||||||
if (changes & NEW_U) {
|
if (changes & NEW_U) {
|
||||||
th->th_flags |= TCP_URG;
|
TCPH_SET_FLAG(th, TCP_URG);
|
||||||
DECODEU(th->th_urp);
|
DECODEU(th->urgp);
|
||||||
} else {
|
} else {
|
||||||
th->th_flags &=~ TCP_URG;
|
TCPH_UNSET_FLAG(th, TCP_URG);
|
||||||
}
|
}
|
||||||
if (changes & NEW_W) {
|
if (changes & NEW_W) {
|
||||||
DECODES(th->th_win);
|
DECODES(th->wnd);
|
||||||
}
|
}
|
||||||
if (changes & NEW_A) {
|
if (changes & NEW_A) {
|
||||||
DECODEL(th->th_ack);
|
DECODEL(th->ackno);
|
||||||
}
|
}
|
||||||
if (changes & NEW_S) {
|
if (changes & NEW_S) {
|
||||||
DECODEL(th->th_seq);
|
DECODEL(th->seqno);
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
if (changes & NEW_I) {
|
if (changes & NEW_I) {
|
||||||
DECODES(cs->cs_ip.ip_id);
|
DECODES(cs->cs_ip._id);
|
||||||
} else {
|
} else {
|
||||||
cs->cs_ip.ip_id = ntohs(cs->cs_ip.ip_id) + 1;
|
IPH_ID_SET(&cs->cs_ip, ntohs(IPH_ID(&cs->cs_ip)) + 1);
|
||||||
cs->cs_ip.ip_id = htons(cs->cs_ip.ip_id);
|
IPH_ID_SET(&cs->cs_ip, htons(IPH_ID(&cs->cs_ip)));
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@ -578,20 +570,20 @@ vj_uncompress_tcp(struct pbuf **nb, struct vjcompress *comp)
|
|||||||
|
|
||||||
#if BYTE_ORDER == LITTLE_ENDIAN
|
#if BYTE_ORDER == LITTLE_ENDIAN
|
||||||
tmp = n0->tot_len - vjlen + cs->cs_hlen;
|
tmp = n0->tot_len - vjlen + cs->cs_hlen;
|
||||||
cs->cs_ip.ip_len = htons(tmp);
|
IPH_LEN_SET(&cs->cs_ip, htons(tmp));
|
||||||
#else
|
#else
|
||||||
cs->cs_ip.ip_len = htons(n0->tot_len - vjlen + cs->cs_hlen);
|
IPH_LEN_SET(&cs->cs_ip, htons(n0->tot_len - vjlen + cs->cs_hlen));
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
/* recompute the ip header checksum */
|
/* recompute the ip header checksum */
|
||||||
bp = (u_short *) &cs->cs_ip;
|
bp = (u_short *) &cs->cs_ip;
|
||||||
cs->cs_ip.ip_sum = 0;
|
IPH_CHKSUM_SET(&cs->cs_ip, 0);
|
||||||
for (tmp = 0; hlen > 0; hlen -= 2) {
|
for (tmp = 0; hlen > 0; hlen -= 2) {
|
||||||
tmp += *bp++;
|
tmp += *bp++;
|
||||||
}
|
}
|
||||||
tmp = (tmp & 0xffff) + (tmp >> 16);
|
tmp = (tmp & 0xffff) + (tmp >> 16);
|
||||||
tmp = (tmp & 0xffff) + (tmp >> 16);
|
tmp = (tmp & 0xffff) + (tmp >> 16);
|
||||||
cs->cs_ip.ip_sum = (u_short)(~tmp);
|
IPH_CHKSUM_SET(&cs->cs_ip, (u_short)(~tmp));
|
||||||
|
|
||||||
/* Remove the compressed header and prepend the uncompressed header. */
|
/* Remove the compressed header and prepend the uncompressed header. */
|
||||||
if(pbuf_header(n0, -((s16_t)(vjlen)))) {
|
if(pbuf_header(n0, -((s16_t)(vjlen)))) {
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
/*
|
/*
|
||||||
* Definitions for tcp compression routines.
|
* Definitions for tcp compression routines.
|
||||||
*
|
*
|
||||||
* $Id: vj.h,v 1.5 2007/12/19 20:47:23 fbernon Exp $
|
* $Id: vj.h,v 1.6 2010/01/09 12:45:23 goldsimon Exp $
|
||||||
*
|
*
|
||||||
* Copyright (c) 1989 Regents of the University of California.
|
* Copyright (c) 1989 Regents of the University of California.
|
||||||
* All rights reserved.
|
* All rights reserved.
|
||||||
@ -25,7 +25,8 @@
|
|||||||
#ifndef VJ_H
|
#ifndef VJ_H
|
||||||
#define VJ_H
|
#define VJ_H
|
||||||
|
|
||||||
#include "vjbsdhdr.h"
|
#include "lwip/ip.h"
|
||||||
|
#include "lwip/tcp.h"
|
||||||
|
|
||||||
#define MAX_SLOTS 16 /* must be > 2 and < 256 */
|
#define MAX_SLOTS 16 /* must be > 2 and < 256 */
|
||||||
#define MAX_HDR 128
|
#define MAX_HDR 128
|
||||||
@ -108,7 +109,7 @@ struct cstate {
|
|||||||
u_char cs_filler;
|
u_char cs_filler;
|
||||||
union {
|
union {
|
||||||
char csu_hdr[MAX_HDR];
|
char csu_hdr[MAX_HDR];
|
||||||
struct ip csu_ip; /* ip/tcp hdr from most recent packet */
|
struct ip_hdr csu_ip; /* ip/tcp hdr from most recent packet */
|
||||||
} vjcs_u;
|
} vjcs_u;
|
||||||
};
|
};
|
||||||
#define cs_ip vjcs_u.csu_ip
|
#define cs_ip vjcs_u.csu_ip
|
||||||
|
@ -1,75 +0,0 @@
|
|||||||
#ifndef VJBSDHDR_H
|
|
||||||
#define VJBSDHDR_H
|
|
||||||
|
|
||||||
#include "lwip/tcp.h"
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Structure of an internet header, naked of options.
|
|
||||||
*
|
|
||||||
* We declare ip_len and ip_off to be short, rather than u_short
|
|
||||||
* pragmatically since otherwise unsigned comparisons can result
|
|
||||||
* against negative integers quite easily, and fail in subtle ways.
|
|
||||||
*/
|
|
||||||
PACK_STRUCT_BEGIN
|
|
||||||
struct ip
|
|
||||||
{
|
|
||||||
#if defined(NO_CHAR_BITFIELDS)
|
|
||||||
u_char ip_hl_v; /* bug in GCC for mips means the bitfield stuff will sometimes break - so we use a char for both and get round it with macro's instead... */
|
|
||||||
#else
|
|
||||||
#if BYTE_ORDER == LITTLE_ENDIAN
|
|
||||||
unsigned ip_hl:4, /* header length */
|
|
||||||
ip_v :4; /* version */
|
|
||||||
#elif BYTE_ORDER == BIG_ENDIAN
|
|
||||||
unsigned ip_v :4, /* version */
|
|
||||||
ip_hl:4; /* header length */
|
|
||||||
#else
|
|
||||||
COMPLAIN - NO BYTE ORDER SELECTED!
|
|
||||||
#endif
|
|
||||||
#endif
|
|
||||||
u_char ip_tos; /* type of service */
|
|
||||||
u_short ip_len; /* total length */
|
|
||||||
u_short ip_id; /* identification */
|
|
||||||
u_short ip_off; /* fragment offset field */
|
|
||||||
#define IP_DF 0x4000 /* dont fragment flag */
|
|
||||||
#define IP_MF 0x2000 /* more fragments flag */
|
|
||||||
#define IP_OFFMASK 0x1fff /* mask for fragmenting bits */
|
|
||||||
u_char ip_ttl; /* time to live */
|
|
||||||
u_char ip_p; /* protocol */
|
|
||||||
u_short ip_sum; /* checksum */
|
|
||||||
struct in_addr ip_src,ip_dst; /* source and dest address */
|
|
||||||
};
|
|
||||||
PACK_STRUCT_END
|
|
||||||
|
|
||||||
typedef u32_t tcp_seq;
|
|
||||||
|
|
||||||
/*
|
|
||||||
* TCP header.
|
|
||||||
* Per RFC 793, September, 1981.
|
|
||||||
*/
|
|
||||||
PACK_STRUCT_BEGIN
|
|
||||||
struct tcphdr
|
|
||||||
{
|
|
||||||
u_short th_sport; /* source port */
|
|
||||||
u_short th_dport; /* destination port */
|
|
||||||
tcp_seq th_seq; /* sequence number */
|
|
||||||
tcp_seq th_ack; /* acknowledgement number */
|
|
||||||
#if defined(NO_CHAR_BITFIELDS)
|
|
||||||
u_char th_x2_off;
|
|
||||||
#else
|
|
||||||
#if BYTE_ORDER == LITTLE_ENDIAN
|
|
||||||
unsigned th_x2 :4, /* (unused) */
|
|
||||||
th_off:4; /* data offset */
|
|
||||||
#endif
|
|
||||||
#if BYTE_ORDER == BIG_ENDIAN
|
|
||||||
unsigned th_off:4, /* data offset */
|
|
||||||
th_x2 :4; /* (unused) */
|
|
||||||
#endif
|
|
||||||
#endif
|
|
||||||
u_char th_flags;
|
|
||||||
u_short th_win; /* window */
|
|
||||||
u_short th_sum; /* checksum */
|
|
||||||
u_short th_urp; /* urgent pointer */
|
|
||||||
};
|
|
||||||
PACK_STRUCT_END
|
|
||||||
|
|
||||||
#endif /* VJBSDHDR_H */
|
|
Loading…
x
Reference in New Issue
Block a user