xform_ipcomp.c revision 1.61 1 1.61 maxv /* $NetBSD: xform_ipcomp.c,v 1.61 2018/04/19 07:58:26 maxv Exp $ */
2 1.1 jonathan /* $FreeBSD: src/sys/netipsec/xform_ipcomp.c,v 1.1.4.1 2003/01/24 05:11:36 sam Exp $ */
3 1.1 jonathan /* $OpenBSD: ip_ipcomp.c,v 1.1 2001/07/05 12:08:52 jjbg Exp $ */
4 1.1 jonathan
5 1.1 jonathan /*
6 1.1 jonathan * Copyright (c) 2001 Jean-Jacques Bernard-Gundol (jj (at) wabbitt.org)
7 1.1 jonathan *
8 1.1 jonathan * Redistribution and use in source and binary forms, with or without
9 1.1 jonathan * modification, are permitted provided that the following conditions
10 1.1 jonathan * are met:
11 1.1 jonathan *
12 1.1 jonathan * 1. Redistributions of source code must retain the above copyright
13 1.1 jonathan * notice, this list of conditions and the following disclaimer.
14 1.1 jonathan * 2. Redistributions in binary form must reproduce the above copyright
15 1.1 jonathan * notice, this list of conditions and the following disclaimer in the
16 1.1 jonathan * documentation and/or other materials provided with the distribution.
17 1.1 jonathan * 3. The name of the author may not be used to endorse or promote products
18 1.1 jonathan * derived from this software without specific prior written permission.
19 1.1 jonathan *
20 1.1 jonathan * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
21 1.1 jonathan * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
22 1.1 jonathan * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
23 1.1 jonathan * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
24 1.1 jonathan * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
25 1.1 jonathan * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
26 1.1 jonathan * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
27 1.1 jonathan * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
28 1.1 jonathan * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
29 1.1 jonathan * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
30 1.1 jonathan */
31 1.1 jonathan
32 1.1 jonathan #include <sys/cdefs.h>
33 1.61 maxv __KERNEL_RCSID(0, "$NetBSD: xform_ipcomp.c,v 1.61 2018/04/19 07:58:26 maxv Exp $");
34 1.1 jonathan
35 1.1 jonathan /* IP payload compression protocol (IPComp), see RFC 2393 */
36 1.32 ozaki #if defined(_KERNEL_OPT)
37 1.1 jonathan #include "opt_inet.h"
38 1.32 ozaki #endif
39 1.1 jonathan
40 1.1 jonathan #include <sys/param.h>
41 1.1 jonathan #include <sys/systm.h>
42 1.1 jonathan #include <sys/mbuf.h>
43 1.1 jonathan #include <sys/socket.h>
44 1.1 jonathan #include <sys/kernel.h>
45 1.1 jonathan #include <sys/protosw.h>
46 1.1 jonathan #include <sys/sysctl.h>
47 1.47 ozaki #include <sys/pool.h>
48 1.49 ozaki #include <sys/pserialize.h>
49 1.1 jonathan
50 1.1 jonathan #include <netinet/in.h>
51 1.1 jonathan #include <netinet/in_systm.h>
52 1.1 jonathan #include <netinet/ip.h>
53 1.1 jonathan #include <netinet/ip_var.h>
54 1.1 jonathan
55 1.1 jonathan #include <net/route.h>
56 1.1 jonathan #include <netipsec/ipsec.h>
57 1.18 thorpej #include <netipsec/ipsec_private.h>
58 1.1 jonathan #include <netipsec/xform.h>
59 1.1 jonathan
60 1.1 jonathan #ifdef INET6
61 1.1 jonathan #include <netinet/ip6.h>
62 1.1 jonathan #include <netipsec/ipsec6.h>
63 1.1 jonathan #endif
64 1.1 jonathan
65 1.1 jonathan #include <netipsec/ipcomp.h>
66 1.1 jonathan #include <netipsec/ipcomp_var.h>
67 1.1 jonathan
68 1.4 tls #include <netipsec/key.h>
69 1.4 tls #include <netipsec/key_debug.h>
70 1.1 jonathan
71 1.1 jonathan #include <opencrypto/cryptodev.h>
72 1.1 jonathan #include <opencrypto/deflate.h>
73 1.1 jonathan #include <opencrypto/xform.h>
74 1.1 jonathan
75 1.18 thorpej percpu_t *ipcompstat_percpu;
76 1.18 thorpej
77 1.57 maxv int ipcomp_enable = 1;
78 1.1 jonathan
79 1.1 jonathan static int ipcomp_input_cb(struct cryptop *crp);
80 1.1 jonathan static int ipcomp_output_cb(struct cryptop *crp);
81 1.1 jonathan
82 1.33 christos const uint8_t ipcomp_stats[256] = { SADB_CALG_STATS_INIT };
83 1.33 christos
84 1.52 ozaki static pool_cache_t ipcomp_tdb_crypto_pool_cache;
85 1.47 ozaki
86 1.24 drochner const struct comp_algo *
87 1.1 jonathan ipcomp_algorithm_lookup(int alg)
88 1.1 jonathan {
89 1.1 jonathan switch (alg) {
90 1.1 jonathan case SADB_X_CALG_DEFLATE:
91 1.25 drochner return &comp_algo_deflate_nogrow;
92 1.1 jonathan }
93 1.1 jonathan return NULL;
94 1.1 jonathan }
95 1.1 jonathan
96 1.1 jonathan /*
97 1.1 jonathan * ipcomp_init() is called when an CPI is being set up.
98 1.1 jonathan */
99 1.1 jonathan static int
100 1.24 drochner ipcomp_init(struct secasvar *sav, const struct xformsw *xsp)
101 1.1 jonathan {
102 1.24 drochner const struct comp_algo *tcomp;
103 1.1 jonathan struct cryptoini cric;
104 1.17 tls int ses;
105 1.1 jonathan
106 1.1 jonathan /* NB: algorithm really comes in alg_enc and not alg_comp! */
107 1.1 jonathan tcomp = ipcomp_algorithm_lookup(sav->alg_enc);
108 1.1 jonathan if (tcomp == NULL) {
109 1.34 christos DPRINTF(("%s: unsupported compression algorithm %d\n",
110 1.34 christos __func__, sav->alg_comp));
111 1.1 jonathan return EINVAL;
112 1.1 jonathan }
113 1.1 jonathan sav->alg_comp = sav->alg_enc; /* set for doing histogram */
114 1.1 jonathan sav->tdb_xform = xsp;
115 1.1 jonathan sav->tdb_compalgxform = tcomp;
116 1.1 jonathan
117 1.1 jonathan /* Initialize crypto session */
118 1.34 christos memset(&cric, 0, sizeof(cric));
119 1.1 jonathan cric.cri_alg = sav->tdb_compalgxform->type;
120 1.1 jonathan
121 1.17 tls ses = crypto_newsession(&sav->tdb_cryptoid, &cric, crypto_support);
122 1.17 tls return ses;
123 1.1 jonathan }
124 1.1 jonathan
125 1.1 jonathan /*
126 1.1 jonathan * ipcomp_zeroize() used when IPCA is deleted
127 1.1 jonathan */
128 1.1 jonathan static int
129 1.1 jonathan ipcomp_zeroize(struct secasvar *sav)
130 1.1 jonathan {
131 1.1 jonathan int err;
132 1.1 jonathan
133 1.1 jonathan err = crypto_freesession(sav->tdb_cryptoid);
134 1.1 jonathan sav->tdb_cryptoid = 0;
135 1.1 jonathan return err;
136 1.1 jonathan }
137 1.1 jonathan
138 1.1 jonathan /*
139 1.1 jonathan * ipcomp_input() gets called to uncompress an input packet
140 1.1 jonathan */
141 1.1 jonathan static int
142 1.42 ozaki ipcomp_input(struct mbuf *m, struct secasvar *sav, int skip, int protoff)
143 1.1 jonathan {
144 1.1 jonathan struct tdb_crypto *tc;
145 1.1 jonathan struct cryptodesc *crdc;
146 1.1 jonathan struct cryptop *crp;
147 1.55 ozaki int error, hlen = IPCOMP_HLENGTH, stat = IPCOMP_STAT_CRYPTO;
148 1.1 jonathan
149 1.34 christos IPSEC_SPLASSERT_SOFTNET(__func__);
150 1.61 maxv KASSERT(skip + hlen <= m->m_pkthdr.len);
151 1.1 jonathan
152 1.1 jonathan /* Get crypto descriptors */
153 1.1 jonathan crp = crypto_getreq(1);
154 1.1 jonathan if (crp == NULL) {
155 1.34 christos DPRINTF(("%s: no crypto descriptors\n", __func__));
156 1.55 ozaki error = ENOBUFS;
157 1.55 ozaki goto error_m;
158 1.1 jonathan }
159 1.1 jonathan /* Get IPsec-specific opaque pointer */
160 1.52 ozaki tc = pool_cache_get(ipcomp_tdb_crypto_pool_cache, PR_NOWAIT);
161 1.1 jonathan if (tc == NULL) {
162 1.34 christos DPRINTF(("%s: cannot allocate tdb_crypto\n", __func__));
163 1.55 ozaki error = ENOBUFS;
164 1.55 ozaki goto error_crp;
165 1.1 jonathan }
166 1.29 drochner
167 1.29 drochner error = m_makewritable(&m, 0, m->m_pkthdr.len, M_NOWAIT);
168 1.29 drochner if (error) {
169 1.34 christos DPRINTF(("%s: m_makewritable failed\n", __func__));
170 1.55 ozaki goto error_tc;
171 1.29 drochner }
172 1.29 drochner
173 1.51 ozaki {
174 1.51 ozaki int s = pserialize_read_enter();
175 1.51 ozaki
176 1.51 ozaki /*
177 1.51 ozaki * Take another reference to the SA for opencrypto callback.
178 1.51 ozaki */
179 1.51 ozaki if (__predict_false(sav->state == SADB_SASTATE_DEAD)) {
180 1.51 ozaki pserialize_read_exit(s);
181 1.55 ozaki stat = IPCOMP_STAT_NOTDB;
182 1.55 ozaki error = ENOENT;
183 1.55 ozaki goto error_tc;
184 1.51 ozaki }
185 1.51 ozaki KEY_SA_REF(sav);
186 1.51 ozaki pserialize_read_exit(s);
187 1.51 ozaki }
188 1.51 ozaki
189 1.1 jonathan crdc = crp->crp_desc;
190 1.1 jonathan
191 1.1 jonathan crdc->crd_skip = skip + hlen;
192 1.1 jonathan crdc->crd_len = m->m_pkthdr.len - (skip + hlen);
193 1.29 drochner crdc->crd_inject = 0; /* unused */
194 1.1 jonathan
195 1.1 jonathan /* Decompression operation */
196 1.1 jonathan crdc->crd_alg = sav->tdb_compalgxform->type;
197 1.1 jonathan
198 1.1 jonathan /* Crypto operation descriptor */
199 1.1 jonathan crp->crp_ilen = m->m_pkthdr.len - (skip + hlen);
200 1.25 drochner crp->crp_olen = MCLBYTES; /* hint to decompression code */
201 1.1 jonathan crp->crp_flags = CRYPTO_F_IMBUF;
202 1.13 degroote crp->crp_buf = m;
203 1.1 jonathan crp->crp_callback = ipcomp_input_cb;
204 1.1 jonathan crp->crp_sid = sav->tdb_cryptoid;
205 1.13 degroote crp->crp_opaque = tc;
206 1.1 jonathan
207 1.1 jonathan /* These are passed as-is to the callback */
208 1.1 jonathan tc->tc_spi = sav->spi;
209 1.1 jonathan tc->tc_dst = sav->sah->saidx.dst;
210 1.1 jonathan tc->tc_proto = sav->sah->saidx.proto;
211 1.1 jonathan tc->tc_protoff = protoff;
212 1.1 jonathan tc->tc_skip = skip;
213 1.42 ozaki tc->tc_sav = sav;
214 1.1 jonathan
215 1.1 jonathan return crypto_dispatch(crp);
216 1.55 ozaki
217 1.55 ozaki error_tc:
218 1.55 ozaki pool_cache_put(ipcomp_tdb_crypto_pool_cache, tc);
219 1.55 ozaki error_crp:
220 1.55 ozaki crypto_freereq(crp);
221 1.55 ozaki error_m:
222 1.55 ozaki m_freem(m);
223 1.55 ozaki IPCOMP_STATINC(stat);
224 1.55 ozaki return error;
225 1.1 jonathan }
226 1.1 jonathan
227 1.1 jonathan #ifdef INET6
228 1.40 ozaki #define IPSEC_COMMON_INPUT_CB(m, sav, skip, protoff) do { \
229 1.1 jonathan if (saidx->dst.sa.sa_family == AF_INET6) { \
230 1.40 ozaki error = ipsec6_common_input_cb(m, sav, skip, protoff); \
231 1.1 jonathan } else { \
232 1.40 ozaki error = ipsec4_common_input_cb(m, sav, skip, protoff); \
233 1.1 jonathan } \
234 1.1 jonathan } while (0)
235 1.1 jonathan #else
236 1.40 ozaki #define IPSEC_COMMON_INPUT_CB(m, sav, skip, protoff) \
237 1.40 ozaki (error = ipsec4_common_input_cb(m, sav, skip, protoff))
238 1.1 jonathan #endif
239 1.1 jonathan
240 1.1 jonathan /*
241 1.1 jonathan * IPComp input callback from the crypto driver.
242 1.1 jonathan */
243 1.1 jonathan static int
244 1.1 jonathan ipcomp_input_cb(struct cryptop *crp)
245 1.1 jonathan {
246 1.38 ryo char buf[IPSEC_ADDRSTRLEN];
247 1.1 jonathan struct tdb_crypto *tc;
248 1.1 jonathan int skip, protoff;
249 1.1 jonathan struct mbuf *m;
250 1.1 jonathan struct secasvar *sav;
251 1.31 mrg struct secasindex *saidx __diagused;
252 1.48 ozaki int hlen = IPCOMP_HLENGTH, error, clen;
253 1.34 christos uint8_t nproto;
254 1.57 maxv struct ipcomp *ipc;
255 1.34 christos uint16_t dport;
256 1.34 christos uint16_t sport;
257 1.48 ozaki IPSEC_DECLARE_LOCK_VARIABLE;
258 1.1 jonathan
259 1.36 ozaki KASSERT(crp->crp_opaque != NULL);
260 1.34 christos tc = crp->crp_opaque;
261 1.1 jonathan skip = tc->tc_skip;
262 1.1 jonathan protoff = tc->tc_protoff;
263 1.34 christos m = crp->crp_buf;
264 1.1 jonathan
265 1.14 degroote /* find the source port for NAT-T */
266 1.30 christos nat_t_ports_get(m, &dport, &sport);
267 1.14 degroote
268 1.48 ozaki IPSEC_ACQUIRE_GLOBAL_LOCKS();
269 1.1 jonathan
270 1.42 ozaki sav = tc->tc_sav;
271 1.1 jonathan saidx = &sav->sah->saidx;
272 1.36 ozaki KASSERTMSG(saidx->dst.sa.sa_family == AF_INET ||
273 1.36 ozaki saidx->dst.sa.sa_family == AF_INET6,
274 1.36 ozaki "unexpected protocol family %u", saidx->dst.sa.sa_family);
275 1.1 jonathan
276 1.1 jonathan /* Check for crypto errors */
277 1.1 jonathan if (crp->crp_etype) {
278 1.1 jonathan /* Reset the session ID */
279 1.1 jonathan if (sav->tdb_cryptoid != 0)
280 1.1 jonathan sav->tdb_cryptoid = crp->crp_sid;
281 1.1 jonathan
282 1.1 jonathan if (crp->crp_etype == EAGAIN) {
283 1.50 ozaki KEY_SA_UNREF(&sav);
284 1.48 ozaki IPSEC_RELEASE_GLOBAL_LOCKS();
285 1.1 jonathan return crypto_dispatch(crp);
286 1.1 jonathan }
287 1.1 jonathan
288 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_NOXFORM);
289 1.34 christos DPRINTF(("%s: crypto error %d\n", __func__, crp->crp_etype));
290 1.1 jonathan error = crp->crp_etype;
291 1.1 jonathan goto bad;
292 1.1 jonathan }
293 1.45 ozaki
294 1.33 christos IPCOMP_STATINC(IPCOMP_STAT_HIST + ipcomp_stats[sav->alg_comp]);
295 1.1 jonathan
296 1.20 degroote /* Update the counters */
297 1.20 degroote IPCOMP_STATADD(IPCOMP_STAT_IBYTES, m->m_pkthdr.len - skip - hlen);
298 1.20 degroote
299 1.57 maxv /* Length of data after processing */
300 1.57 maxv clen = crp->crp_olen;
301 1.1 jonathan
302 1.1 jonathan /* Release the crypto descriptors */
303 1.52 ozaki pool_cache_put(ipcomp_tdb_crypto_pool_cache, tc);
304 1.47 ozaki tc = NULL;
305 1.57 maxv crypto_freereq(crp);
306 1.57 maxv crp = NULL;
307 1.1 jonathan
308 1.1 jonathan /* In case it's not done already, adjust the size of the mbuf chain */
309 1.1 jonathan m->m_pkthdr.len = clen + hlen + skip;
310 1.1 jonathan
311 1.61 maxv /*
312 1.61 maxv * Get the next protocol field.
313 1.61 maxv *
314 1.61 maxv * XXX: Really, we should use m_copydata instead of m_pullup.
315 1.61 maxv */
316 1.1 jonathan if (m->m_len < skip + hlen && (m = m_pullup(m, skip + hlen)) == 0) {
317 1.57 maxv IPCOMP_STATINC(IPCOMP_STAT_HDROPS);
318 1.34 christos DPRINTF(("%s: m_pullup failed\n", __func__));
319 1.57 maxv error = EINVAL;
320 1.1 jonathan goto bad;
321 1.1 jonathan }
322 1.57 maxv ipc = (struct ipcomp *)(mtod(m, uint8_t *) + skip);
323 1.57 maxv nproto = ipc->comp_nxt;
324 1.61 maxv
325 1.34 christos switch (nproto) {
326 1.34 christos case IPPROTO_IPCOMP:
327 1.34 christos case IPPROTO_AH:
328 1.34 christos case IPPROTO_ESP:
329 1.26 spz IPCOMP_STATINC(IPCOMP_STAT_HDROPS);
330 1.34 christos DPRINTF(("%s: nested ipcomp, IPCA %s/%08lx\n", __func__,
331 1.38 ryo ipsec_address(&sav->sah->saidx.dst, buf, sizeof(buf)),
332 1.34 christos (u_long) ntohl(sav->spi)));
333 1.26 spz error = EINVAL;
334 1.26 spz goto bad;
335 1.34 christos default:
336 1.34 christos break;
337 1.26 spz }
338 1.1 jonathan
339 1.1 jonathan /* Remove the IPCOMP header */
340 1.1 jonathan error = m_striphdr(m, skip, hlen);
341 1.1 jonathan if (error) {
342 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_HDROPS);
343 1.34 christos DPRINTF(("%s: bad mbuf chain, IPCA %s/%08lx\n", __func__,
344 1.38 ryo ipsec_address(&sav->sah->saidx.dst, buf, sizeof(buf)),
345 1.38 ryo (u_long) ntohl(sav->spi)));
346 1.1 jonathan goto bad;
347 1.1 jonathan }
348 1.1 jonathan
349 1.1 jonathan /* Restore the Next Protocol field */
350 1.61 maxv m_copyback(m, protoff, sizeof(nproto), &nproto);
351 1.1 jonathan
352 1.40 ozaki IPSEC_COMMON_INPUT_CB(m, sav, skip, protoff);
353 1.1 jonathan
354 1.50 ozaki KEY_SA_UNREF(&sav);
355 1.48 ozaki IPSEC_RELEASE_GLOBAL_LOCKS();
356 1.1 jonathan return error;
357 1.57 maxv
358 1.1 jonathan bad:
359 1.1 jonathan if (sav)
360 1.50 ozaki KEY_SA_UNREF(&sav);
361 1.48 ozaki IPSEC_RELEASE_GLOBAL_LOCKS();
362 1.1 jonathan if (m)
363 1.1 jonathan m_freem(m);
364 1.1 jonathan if (tc != NULL)
365 1.52 ozaki pool_cache_put(ipcomp_tdb_crypto_pool_cache, tc);
366 1.1 jonathan if (crp)
367 1.1 jonathan crypto_freereq(crp);
368 1.1 jonathan return error;
369 1.1 jonathan }
370 1.1 jonathan
371 1.1 jonathan /*
372 1.1 jonathan * IPComp output routine, called by ipsec[46]_process_packet()
373 1.1 jonathan */
374 1.1 jonathan static int
375 1.57 maxv ipcomp_output(struct mbuf *m, const struct ipsecrequest *isr,
376 1.57 maxv struct secasvar *sav, struct mbuf **mp, int skip, int protoff)
377 1.1 jonathan {
378 1.38 ryo char buf[IPSEC_ADDRSTRLEN];
379 1.24 drochner const struct comp_algo *ipcompx;
380 1.9 degroote int error, ralen, hlen, maxpacketsize;
381 1.1 jonathan struct cryptodesc *crdc;
382 1.1 jonathan struct cryptop *crp;
383 1.1 jonathan struct tdb_crypto *tc;
384 1.1 jonathan
385 1.34 christos IPSEC_SPLASSERT_SOFTNET(__func__);
386 1.43 ozaki KASSERT(sav != NULL);
387 1.36 ozaki KASSERT(sav->tdb_compalgxform != NULL);
388 1.1 jonathan ipcompx = sav->tdb_compalgxform;
389 1.1 jonathan
390 1.57 maxv /* Raw payload length before comp. */
391 1.57 maxv ralen = m->m_pkthdr.len - skip;
392 1.57 maxv
393 1.57 maxv /* Don't process the packet if it is too short */
394 1.9 degroote if (ralen < ipcompx->minlen) {
395 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_MINLEN);
396 1.43 ozaki return ipsec_process_done(m, isr, sav);
397 1.9 degroote }
398 1.9 degroote
399 1.1 jonathan hlen = IPCOMP_HLENGTH;
400 1.1 jonathan
401 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_OUTPUT);
402 1.1 jonathan
403 1.1 jonathan /* Check for maximum packet size violations. */
404 1.1 jonathan switch (sav->sah->saidx.dst.sa.sa_family) {
405 1.1 jonathan #ifdef INET
406 1.1 jonathan case AF_INET:
407 1.57 maxv maxpacketsize = IP_MAXPACKET;
408 1.1 jonathan break;
409 1.57 maxv #endif
410 1.1 jonathan #ifdef INET6
411 1.1 jonathan case AF_INET6:
412 1.57 maxv maxpacketsize = IPV6_MAXPACKET;
413 1.1 jonathan break;
414 1.57 maxv #endif
415 1.1 jonathan default:
416 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_NOPF);
417 1.34 christos DPRINTF(("%s: unknown/unsupported protocol family %d"
418 1.34 christos ", IPCA %s/%08lx\n", __func__,
419 1.1 jonathan sav->sah->saidx.dst.sa.sa_family,
420 1.38 ryo ipsec_address(&sav->sah->saidx.dst, buf, sizeof(buf)),
421 1.1 jonathan (u_long) ntohl(sav->spi)));
422 1.1 jonathan error = EPFNOSUPPORT;
423 1.1 jonathan goto bad;
424 1.1 jonathan }
425 1.1 jonathan if (skip + hlen + ralen > maxpacketsize) {
426 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_TOOBIG);
427 1.34 christos DPRINTF(("%s: packet in IPCA %s/%08lx got too big "
428 1.34 christos "(len %u, max len %u)\n", __func__,
429 1.38 ryo ipsec_address(&sav->sah->saidx.dst, buf, sizeof(buf)),
430 1.1 jonathan (u_long) ntohl(sav->spi),
431 1.1 jonathan skip + hlen + ralen, maxpacketsize));
432 1.1 jonathan error = EMSGSIZE;
433 1.1 jonathan goto bad;
434 1.1 jonathan }
435 1.1 jonathan
436 1.1 jonathan /* Update the counters */
437 1.18 thorpej IPCOMP_STATADD(IPCOMP_STAT_OBYTES, m->m_pkthdr.len - skip);
438 1.1 jonathan
439 1.1 jonathan m = m_clone(m);
440 1.1 jonathan if (m == NULL) {
441 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_HDROPS);
442 1.34 christos DPRINTF(("%s: cannot clone mbuf chain, IPCA %s/%08lx\n",
443 1.38 ryo __func__,
444 1.38 ryo ipsec_address(&sav->sah->saidx.dst, buf, sizeof(buf)),
445 1.1 jonathan (u_long) ntohl(sav->spi)));
446 1.1 jonathan error = ENOBUFS;
447 1.1 jonathan goto bad;
448 1.1 jonathan }
449 1.1 jonathan
450 1.1 jonathan /* Ok now, we can pass to the crypto processing */
451 1.1 jonathan
452 1.1 jonathan /* Get crypto descriptors */
453 1.1 jonathan crp = crypto_getreq(1);
454 1.1 jonathan if (crp == NULL) {
455 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_CRYPTO);
456 1.34 christos DPRINTF(("%s: failed to acquire crypto descriptor\n",
457 1.34 christos __func__));
458 1.1 jonathan error = ENOBUFS;
459 1.1 jonathan goto bad;
460 1.1 jonathan }
461 1.1 jonathan crdc = crp->crp_desc;
462 1.1 jonathan
463 1.1 jonathan /* Compression descriptor */
464 1.9 degroote crdc->crd_skip = skip;
465 1.9 degroote crdc->crd_len = m->m_pkthdr.len - skip;
466 1.1 jonathan crdc->crd_flags = CRD_F_COMP;
467 1.9 degroote crdc->crd_inject = skip;
468 1.1 jonathan
469 1.1 jonathan /* Compression operation */
470 1.1 jonathan crdc->crd_alg = ipcompx->type;
471 1.1 jonathan
472 1.1 jonathan /* IPsec-specific opaque crypto info */
473 1.52 ozaki tc = pool_cache_get(ipcomp_tdb_crypto_pool_cache, PR_NOWAIT);
474 1.1 jonathan if (tc == NULL) {
475 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_CRYPTO);
476 1.34 christos DPRINTF(("%s: failed to allocate tdb_crypto\n", __func__));
477 1.1 jonathan crypto_freereq(crp);
478 1.1 jonathan error = ENOBUFS;
479 1.1 jonathan goto bad;
480 1.1 jonathan }
481 1.1 jonathan
482 1.49 ozaki {
483 1.49 ozaki int s = pserialize_read_enter();
484 1.49 ozaki
485 1.51 ozaki /*
486 1.51 ozaki * Take another reference to the SP and the SA for opencrypto callback.
487 1.51 ozaki */
488 1.51 ozaki if (__predict_false(isr->sp->state == IPSEC_SPSTATE_DEAD ||
489 1.51 ozaki sav->state == SADB_SASTATE_DEAD)) {
490 1.49 ozaki pserialize_read_exit(s);
491 1.52 ozaki pool_cache_put(ipcomp_tdb_crypto_pool_cache, tc);
492 1.49 ozaki crypto_freereq(crp);
493 1.49 ozaki IPCOMP_STATINC(IPCOMP_STAT_NOTDB);
494 1.49 ozaki error = ENOENT;
495 1.49 ozaki goto bad;
496 1.49 ozaki }
497 1.49 ozaki KEY_SP_REF(isr->sp);
498 1.51 ozaki KEY_SA_REF(sav);
499 1.49 ozaki pserialize_read_exit(s);
500 1.49 ozaki }
501 1.49 ozaki
502 1.1 jonathan tc->tc_isr = isr;
503 1.1 jonathan tc->tc_spi = sav->spi;
504 1.1 jonathan tc->tc_dst = sav->sah->saidx.dst;
505 1.1 jonathan tc->tc_proto = sav->sah->saidx.proto;
506 1.10 degroote tc->tc_skip = skip;
507 1.10 degroote tc->tc_protoff = protoff;
508 1.42 ozaki tc->tc_sav = sav;
509 1.1 jonathan
510 1.1 jonathan /* Crypto operation descriptor */
511 1.1 jonathan crp->crp_ilen = m->m_pkthdr.len; /* Total input length */
512 1.1 jonathan crp->crp_flags = CRYPTO_F_IMBUF;
513 1.13 degroote crp->crp_buf = m;
514 1.1 jonathan crp->crp_callback = ipcomp_output_cb;
515 1.13 degroote crp->crp_opaque = tc;
516 1.1 jonathan crp->crp_sid = sav->tdb_cryptoid;
517 1.1 jonathan
518 1.1 jonathan return crypto_dispatch(crp);
519 1.57 maxv
520 1.1 jonathan bad:
521 1.1 jonathan if (m)
522 1.1 jonathan m_freem(m);
523 1.57 maxv return error;
524 1.1 jonathan }
525 1.1 jonathan
526 1.1 jonathan /*
527 1.1 jonathan * IPComp output callback from the crypto driver.
528 1.1 jonathan */
529 1.1 jonathan static int
530 1.1 jonathan ipcomp_output_cb(struct cryptop *crp)
531 1.1 jonathan {
532 1.38 ryo char buf[IPSEC_ADDRSTRLEN];
533 1.1 jonathan struct tdb_crypto *tc;
534 1.53 ozaki const struct ipsecrequest *isr;
535 1.1 jonathan struct secasvar *sav;
536 1.9 degroote struct mbuf *m, *mo;
537 1.48 ozaki int error, skip, rlen, roff;
538 1.34 christos uint8_t prot;
539 1.34 christos uint16_t cpi;
540 1.9 degroote struct ipcomp * ipcomp;
541 1.48 ozaki IPSEC_DECLARE_LOCK_VARIABLE;
542 1.9 degroote
543 1.36 ozaki KASSERT(crp->crp_opaque != NULL);
544 1.34 christos tc = crp->crp_opaque;
545 1.34 christos m = crp->crp_buf;
546 1.1 jonathan skip = tc->tc_skip;
547 1.1 jonathan rlen = crp->crp_ilen - skip;
548 1.1 jonathan
549 1.48 ozaki IPSEC_ACQUIRE_GLOBAL_LOCKS();
550 1.1 jonathan
551 1.1 jonathan isr = tc->tc_isr;
552 1.42 ozaki sav = tc->tc_sav;
553 1.1 jonathan
554 1.1 jonathan /* Check for crypto errors */
555 1.1 jonathan if (crp->crp_etype) {
556 1.1 jonathan /* Reset session ID */
557 1.1 jonathan if (sav->tdb_cryptoid != 0)
558 1.1 jonathan sav->tdb_cryptoid = crp->crp_sid;
559 1.1 jonathan
560 1.1 jonathan if (crp->crp_etype == EAGAIN) {
561 1.48 ozaki IPSEC_RELEASE_GLOBAL_LOCKS();
562 1.1 jonathan return crypto_dispatch(crp);
563 1.1 jonathan }
564 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_NOXFORM);
565 1.34 christos DPRINTF(("%s: crypto error %d\n", __func__, crp->crp_etype));
566 1.1 jonathan error = crp->crp_etype;
567 1.1 jonathan goto bad;
568 1.1 jonathan }
569 1.45 ozaki
570 1.33 christos IPCOMP_STATINC(IPCOMP_STAT_HIST + ipcomp_stats[sav->alg_comp]);
571 1.1 jonathan
572 1.1 jonathan if (rlen > crp->crp_olen) {
573 1.9 degroote /* Inject IPCOMP header */
574 1.9 degroote mo = m_makespace(m, skip, IPCOMP_HLENGTH, &roff);
575 1.9 degroote if (mo == NULL) {
576 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_WRAP);
577 1.34 christos DPRINTF(("%s: failed to inject IPCOMP header for "
578 1.34 christos "IPCA %s/%08lx\n", __func__,
579 1.38 ryo ipsec_address(&sav->sah->saidx.dst, buf,
580 1.38 ryo sizeof(buf)), (u_long) ntohl(sav->spi)));
581 1.9 degroote error = ENOBUFS;
582 1.9 degroote goto bad;
583 1.9 degroote }
584 1.12 degroote ipcomp = (struct ipcomp *)(mtod(mo, char *) + roff);
585 1.9 degroote
586 1.9 degroote /* Initialize the IPCOMP header */
587 1.9 degroote /* XXX alignment always correct? */
588 1.9 degroote switch (sav->sah->saidx.dst.sa.sa_family) {
589 1.9 degroote #ifdef INET
590 1.9 degroote case AF_INET:
591 1.9 degroote ipcomp->comp_nxt = mtod(m, struct ip *)->ip_p;
592 1.57 maxv break;
593 1.57 maxv #endif
594 1.9 degroote #ifdef INET6
595 1.9 degroote case AF_INET6:
596 1.9 degroote ipcomp->comp_nxt = mtod(m, struct ip6_hdr *)->ip6_nxt;
597 1.57 maxv break;
598 1.9 degroote #endif
599 1.9 degroote }
600 1.9 degroote ipcomp->comp_flags = 0;
601 1.9 degroote
602 1.9 degroote if ((sav->flags & SADB_X_EXT_RAWCPI) == 0)
603 1.57 maxv cpi = sav->alg_enc;
604 1.9 degroote else
605 1.9 degroote cpi = ntohl(sav->spi) & 0xffff;
606 1.9 degroote ipcomp->comp_cpi = htons(cpi);
607 1.9 degroote
608 1.9 degroote /* Fix Next Protocol in IPv4/IPv6 header */
609 1.9 degroote prot = IPPROTO_IPCOMP;
610 1.61 maxv m_copyback(m, tc->tc_protoff, sizeof(prot), &prot);
611 1.9 degroote
612 1.1 jonathan /* Adjust the length in the IP header */
613 1.1 jonathan switch (sav->sah->saidx.dst.sa.sa_family) {
614 1.1 jonathan #ifdef INET
615 1.1 jonathan case AF_INET:
616 1.1 jonathan mtod(m, struct ip *)->ip_len = htons(m->m_pkthdr.len);
617 1.1 jonathan break;
618 1.57 maxv #endif
619 1.1 jonathan #ifdef INET6
620 1.1 jonathan case AF_INET6:
621 1.1 jonathan mtod(m, struct ip6_hdr *)->ip6_plen =
622 1.60 maxv htons(m->m_pkthdr.len - sizeof(struct ip6_hdr));
623 1.1 jonathan break;
624 1.57 maxv #endif
625 1.1 jonathan default:
626 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_NOPF);
627 1.1 jonathan DPRINTF(("ipcomp_output: unknown/unsupported protocol "
628 1.5 perry "family %d, IPCA %s/%08lx\n",
629 1.1 jonathan sav->sah->saidx.dst.sa.sa_family,
630 1.38 ryo ipsec_address(&sav->sah->saidx.dst, buf,
631 1.38 ryo sizeof(buf)), (u_long) ntohl(sav->spi)));
632 1.1 jonathan error = EPFNOSUPPORT;
633 1.1 jonathan goto bad;
634 1.1 jonathan }
635 1.1 jonathan } else {
636 1.1 jonathan /* compression was useless, we have lost time */
637 1.18 thorpej IPCOMP_STATINC(IPCOMP_STAT_USELESS);
638 1.57 maxv DPRINTF(("ipcomp_output_cb: compression was useless: initial"
639 1.57 maxv "size was %d and compressed size is %d\n", rlen,
640 1.57 maxv crp->crp_olen));
641 1.1 jonathan }
642 1.1 jonathan
643 1.1 jonathan /* Release the crypto descriptor */
644 1.52 ozaki pool_cache_put(ipcomp_tdb_crypto_pool_cache, tc);
645 1.1 jonathan crypto_freereq(crp);
646 1.1 jonathan
647 1.1 jonathan /* NB: m is reclaimed by ipsec_process_done. */
648 1.43 ozaki error = ipsec_process_done(m, isr, sav);
649 1.50 ozaki KEY_SA_UNREF(&sav);
650 1.49 ozaki KEY_SP_UNREF(&isr->sp);
651 1.48 ozaki IPSEC_RELEASE_GLOBAL_LOCKS();
652 1.1 jonathan return error;
653 1.57 maxv
654 1.1 jonathan bad:
655 1.1 jonathan if (sav)
656 1.50 ozaki KEY_SA_UNREF(&sav);
657 1.49 ozaki KEY_SP_UNREF(&isr->sp);
658 1.48 ozaki IPSEC_RELEASE_GLOBAL_LOCKS();
659 1.1 jonathan if (m)
660 1.1 jonathan m_freem(m);
661 1.52 ozaki pool_cache_put(ipcomp_tdb_crypto_pool_cache, tc);
662 1.1 jonathan crypto_freereq(crp);
663 1.1 jonathan return error;
664 1.1 jonathan }
665 1.1 jonathan
666 1.1 jonathan static struct xformsw ipcomp_xformsw = {
667 1.39 ozaki .xf_type = XF_IPCOMP,
668 1.39 ozaki .xf_flags = XFT_COMP,
669 1.39 ozaki .xf_name = "IPcomp",
670 1.39 ozaki .xf_init = ipcomp_init,
671 1.39 ozaki .xf_zeroize = ipcomp_zeroize,
672 1.39 ozaki .xf_input = ipcomp_input,
673 1.39 ozaki .xf_output = ipcomp_output,
674 1.39 ozaki .xf_next = NULL,
675 1.1 jonathan };
676 1.1 jonathan
677 1.37 ozaki void
678 1.1 jonathan ipcomp_attach(void)
679 1.1 jonathan {
680 1.18 thorpej ipcompstat_percpu = percpu_alloc(sizeof(uint64_t) * IPCOMP_NSTATS);
681 1.52 ozaki ipcomp_tdb_crypto_pool_cache = pool_cache_init(sizeof(struct tdb_crypto),
682 1.52 ozaki coherency_unit, 0, 0, "ipcomp_tdb_crypto", NULL, IPL_SOFTNET,
683 1.52 ozaki NULL, NULL, NULL);
684 1.1 jonathan xform_register(&ipcomp_xformsw);
685 1.1 jonathan }
686