1 /* $FreeBSD: src/sys/netinet6/ipcomp_core.c,v 1.1.2.5 2003/01/11 19:10:59 ume Exp $ */
2 /* $DragonFly: src/sys/netinet6/ipcomp_core.c,v 1.3 2003/08/23 11:02:45 rob Exp $ */
3 /* $KAME: ipcomp_core.c,v 1.25 2001/07/26 06:53:17 jinmei Exp $ */
6 * Copyright (C) 1999 WIDE Project.
9 * Redistribution and use in source and binary forms, with or without
10 * modification, are permitted provided that the following conditions
12 * 1. Redistributions of source code must retain the above copyright
13 * notice, this list of conditions and the following disclaimer.
14 * 2. Redistributions in binary form must reproduce the above copyright
15 * notice, this list of conditions and the following disclaimer in the
16 * documentation and/or other materials provided with the distribution.
17 * 3. Neither the name of the project nor the names of its contributors
18 * may be used to endorse or promote products derived from this software
19 * without specific prior written permission.
21 * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
22 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
24 * ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
25 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
26 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
27 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
29 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
30 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
35 * RFC2393 IP payload compression protocol (IPComp).
39 #include "opt_inet6.h"
41 #include <sys/param.h>
42 #include <sys/systm.h>
43 #include <sys/malloc.h>
45 #include <sys/domain.h>
46 #include <sys/protosw.h>
47 #include <sys/socket.h>
48 #include <sys/errno.h>
50 #include <sys/syslog.h>
51 #include <sys/queue.h>
54 #include <net/route.h>
55 #include <netinet/in.h>
56 #include <net/netisr.h>
58 #include <machine/cpu.h>
60 #include <netinet6/ipcomp.h>
62 #include <netinet6/ipcomp6.h>
64 #include <netinet6/ipsec.h>
66 #include <netinet6/ipsec6.h>
69 #include <machine/stdarg.h>
71 #include <net/net_osdep.h>
73 static void *deflate_alloc (void *, u_int, u_int);
74 static void deflate_free (void *, void *);
75 static int deflate_common (struct mbuf *, struct mbuf *, size_t *, int);
76 static int deflate_compress (struct mbuf *, struct mbuf *, size_t *);
77 static int deflate_decompress (struct mbuf *, struct mbuf *, size_t *);
80 * We need to use default window size (2^15 = 32Kbytes as of writing) for
81 * inbound case. Otherwise we get interop problem.
82 * Use negative value to avoid Adler32 checksum. This is an undocumented
83 * feature in zlib (see ipsec wg mailing list archive in January 2000).
85 static int deflate_policy = Z_DEFAULT_COMPRESSION;
86 static int deflate_window_out = -12;
87 static const int deflate_window_in = -1 * MAX_WBITS; /* don't change it */
88 static int deflate_memlevel = MAX_MEM_LEVEL;
90 static const struct ipcomp_algorithm ipcomp_algorithms[] = {
91 { deflate_compress, deflate_decompress, 90 },
94 const struct ipcomp_algorithm *
95 ipcomp_algorithm_lookup(idx)
99 if (idx == SADB_X_CALG_DEFLATE)
100 return &ipcomp_algorithms[0];
105 deflate_alloc(aux, items, siz)
111 ptr = malloc(items * siz, M_TEMP, M_NOWAIT);
116 deflate_free(aux, ptr)
124 deflate_common(m, md, lenp, mode)
128 int mode; /* 0: compress 1: decompress */
132 struct mbuf *n = NULL, *n0 = NULL, **np;
138 #define MOREBLOCK() \
140 /* keep the reply buffer into our chain */ \
142 n->m_len = zs.total_out - offset; \
143 offset = zs.total_out; \
149 /* get a fresh reply buffer */ \
150 MGET(n, M_DONTWAIT, MT_DATA); \
152 MCLGET(n, M_DONTWAIT); \
159 n->m_len = M_TRAILINGSPACE(n); \
162 * if this is the first reply buffer, reserve \
163 * region for ipcomp header. \
166 n->m_len -= sizeof(struct ipcomp); \
167 n->m_data += sizeof(struct ipcomp); \
170 zs.next_out = mtod(n, u_int8_t *); \
171 zs.avail_out = n->m_len; \
174 for (mprev = m; mprev && mprev->m_next != md; mprev = mprev->m_next)
177 panic("md is not in m in deflate_common");
179 bzero(&zs, sizeof(zs));
180 zs.zalloc = deflate_alloc;
181 zs.zfree = deflate_free;
183 zerror = mode ? inflateInit2(&zs, deflate_window_in)
184 : deflateInit2(&zs, deflate_policy, Z_DEFLATED,
185 deflate_window_out, deflate_memlevel,
187 if (zerror != Z_OK) {
197 while (p && p->m_len == 0) {
201 /* input stream and output stream are available */
202 while (p && zs.avail_in == 0) {
203 /* get input buffer */
204 if (p && zs.avail_in == 0) {
205 zs.next_in = mtod(p, u_int8_t *);
206 zs.avail_in = p->m_len;
208 while (p && p->m_len == 0) {
213 /* get output buffer */
214 if (zs.next_out == NULL || zs.avail_out == 0) {
218 zerror = mode ? inflate(&zs, Z_NO_FLUSH)
219 : deflate(&zs, Z_NO_FLUSH);
221 if (zerror == Z_STREAM_END)
223 else if (zerror == Z_OK) {
224 /* inflate: Z_OK can indicate the end of decode */
225 if (mode && !p && zs.avail_out != 0)
231 ipseclog((LOG_ERR, "ipcomp_%scompress: "
232 "%sflate(Z_NO_FLUSH): %s\n",
233 mode ? "de" : "", mode ? "in" : "de",
236 ipseclog((LOG_ERR, "ipcomp_%scompress: "
237 "%sflate(Z_NO_FLUSH): unknown error (%d)\n",
238 mode ? "de" : "", mode ? "in" : "de",
241 mode ? inflateEnd(&zs) : deflateEnd(&zs);
247 if (zerror == Z_STREAM_END)
252 /* get output buffer */
253 if (zs.next_out == NULL || zs.avail_out == 0) {
257 zerror = mode ? inflate(&zs, Z_SYNC_FLUSH)
258 : deflate(&zs, Z_FINISH);
260 if (zerror == Z_STREAM_END)
262 else if (zerror == Z_OK) {
263 if (mode && zs.avail_out != 0)
269 ipseclog((LOG_ERR, "ipcomp_%scompress: "
270 "%sflate(Z_FINISH): %s\n",
271 mode ? "de" : "", mode ? "in" : "de",
274 ipseclog((LOG_ERR, "ipcomp_%scompress: "
275 "%sflate(Z_FINISH): unknown error (%d)\n",
276 mode ? "de" : "", mode ? "in" : "de",
279 mode ? inflateEnd(&zs) : deflateEnd(&zs);
286 zerror = mode ? inflateEnd(&zs) : deflateEnd(&zs);
287 if (zerror != Z_OK) {
289 ipseclog((LOG_ERR, "ipcomp_%scompress: "
291 mode ? "de" : "", mode ? "in" : "de",
294 ipseclog((LOG_ERR, "ipcomp_%scompress: "
295 "%sflateEnd: unknown error (%d)\n",
296 mode ? "de" : "", mode ? "in" : "de",
302 /* keep the final reply buffer into our chain */
304 n->m_len = zs.total_out - offset;
305 offset = zs.total_out;
311 /* switch the mbuf to the new one */
314 *lenp = zs.total_out;
330 deflate_compress(m, md, lenp)
336 panic("m == NULL in deflate_compress");
338 panic("md == NULL in deflate_compress");
340 panic("lenp == NULL in deflate_compress");
342 return deflate_common(m, md, lenp, 0);
346 deflate_decompress(m, md, lenp)
352 panic("m == NULL in deflate_decompress");
354 panic("md == NULL in deflate_decompress");
356 panic("lenp == NULL in deflate_decompress");
358 return deflate_common(m, md, lenp, 1);