filter.c 43.2 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3
/*
 * Linux Socket Filter - Kernel level socket filtering
 *
4 5
 * Based on the design of the Berkeley Packet Filter. The new
 * internal format has been designed by PLUMgrid:
L
Linus Torvalds 已提交
6
 *
7 8 9 10 11 12 13
 *	Copyright (c) 2011 - 2014 PLUMgrid, http://plumgrid.com
 *
 * Authors:
 *
 *	Jay Schulist <jschlst@samba.org>
 *	Alexei Starovoitov <ast@plumgrid.com>
 *	Daniel Borkmann <dborkman@redhat.com>
L
Linus Torvalds 已提交
14 15 16 17 18 19 20
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version
 * 2 of the License, or (at your option) any later version.
 *
 * Andi Kleen - Fix a few bad bugs and races.
21
 * Kris Katterjohn - Added many additional checks in sk_chk_filter()
L
Linus Torvalds 已提交
22 23 24 25 26 27 28 29 30 31 32
 */

#include <linux/module.h>
#include <linux/types.h>
#include <linux/mm.h>
#include <linux/fcntl.h>
#include <linux/socket.h>
#include <linux/in.h>
#include <linux/inet.h>
#include <linux/netdevice.h>
#include <linux/if_packet.h>
33
#include <linux/gfp.h>
L
Linus Torvalds 已提交
34 35
#include <net/ip.h>
#include <net/protocol.h>
36
#include <net/netlink.h>
L
Linus Torvalds 已提交
37 38 39 40 41
#include <linux/skbuff.h>
#include <net/sock.h>
#include <linux/errno.h>
#include <linux/timer.h>
#include <asm/uaccess.h>
42
#include <asm/unaligned.h>
L
Linus Torvalds 已提交
43
#include <linux/filter.h>
44
#include <linux/ratelimit.h>
45
#include <linux/seccomp.h>
E
Eric Dumazet 已提交
46
#include <linux/if_vlan.h>
L
Linus Torvalds 已提交
47

48
/* Registers */
49 50 51 52 53 54 55 56 57 58 59
#define BPF_R0	regs[BPF_REG_0]
#define BPF_R1	regs[BPF_REG_1]
#define BPF_R2	regs[BPF_REG_2]
#define BPF_R3	regs[BPF_REG_3]
#define BPF_R4	regs[BPF_REG_4]
#define BPF_R5	regs[BPF_REG_5]
#define BPF_R6	regs[BPF_REG_6]
#define BPF_R7	regs[BPF_REG_7]
#define BPF_R8	regs[BPF_REG_8]
#define BPF_R9	regs[BPF_REG_9]
#define BPF_R10	regs[BPF_REG_10]
60 61

/* Named registers */
62 63
#define DST	regs[insn->dst_reg]
#define SRC	regs[insn->src_reg]
64 65 66
#define FP	regs[BPF_REG_FP]
#define ARG1	regs[BPF_REG_ARG1]
#define CTX	regs[BPF_REG_CTX]
67
#define IMM	insn->imm
68

69 70 71 72 73
/* No hurry in this branch
 *
 * Exported for the bpf jit load helper.
 */
void *bpf_internal_load_pointer_neg_helper(const struct sk_buff *skb, int k, unsigned int size)
L
Linus Torvalds 已提交
74 75 76 77
{
	u8 *ptr = NULL;

	if (k >= SKF_NET_OFF)
78
		ptr = skb_network_header(skb) + k - SKF_NET_OFF;
L
Linus Torvalds 已提交
79
	else if (k >= SKF_LL_OFF)
80
		ptr = skb_mac_header(skb) + k - SKF_LL_OFF;
81
	if (ptr >= skb->head && ptr + size <= skb_tail_pointer(skb))
L
Linus Torvalds 已提交
82
		return ptr;
83

L
Linus Torvalds 已提交
84 85 86
	return NULL;
}

S
Stephen Hemminger 已提交
87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103
/**
 *	sk_filter - run a packet through a socket filter
 *	@sk: sock associated with &sk_buff
 *	@skb: buffer to filter
 *
 * Run the filter code and then cut skb->data to correct size returned by
 * sk_run_filter. If pkt_len is 0 we toss packet. If skb->len is smaller
 * than pkt_len we keep whole skb->data. This is the socket level
 * wrapper to sk_run_filter. It returns 0 if the packet should
 * be accepted or -EPERM if the packet should be tossed.
 *
 */
int sk_filter(struct sock *sk, struct sk_buff *skb)
{
	int err;
	struct sk_filter *filter;

104 105 106 107 108 109 110 111
	/*
	 * If the skb was allocated from pfmemalloc reserves, only
	 * allow SOCK_MEMALLOC sockets to use it as this socket is
	 * helping free memory
	 */
	if (skb_pfmemalloc(skb) && !sock_flag(sk, SOCK_MEMALLOC))
		return -ENOMEM;

S
Stephen Hemminger 已提交
112 113 114 115
	err = security_sock_rcv_skb(sk, skb);
	if (err)
		return err;

116 117
	rcu_read_lock();
	filter = rcu_dereference(sk->sk_filter);
S
Stephen Hemminger 已提交
118
	if (filter) {
119
		unsigned int pkt_len = SK_RUN_FILTER(filter, skb);
120

S
Stephen Hemminger 已提交
121 122
		err = pkt_len ? pskb_trim(skb, pkt_len) : -EPERM;
	}
123
	rcu_read_unlock();
S
Stephen Hemminger 已提交
124 125 126 127 128

	return err;
}
EXPORT_SYMBOL(sk_filter);

129 130 131 132 133 134 135 136 137
/* Base function for offset calculation. Needs to go into .text section,
 * therefore keeping it non-static as well; will also be used by JITs
 * anyway later on, so do not let the compiler omit it.
 */
noinline u64 __bpf_call_base(u64 r1, u64 r2, u64 r3, u64 r4, u64 r5)
{
	return 0;
}

L
Linus Torvalds 已提交
138
/**
139 140
 *	__sk_run_filter - run a filter on a given context
 *	@ctx: buffer to run the filter on
141
 *	@insn: filter to apply
L
Linus Torvalds 已提交
142
 *
143
 * Decode and apply filter instructions to the skb->data. Return length to
144
 * keep, 0 for none. @ctx is the data we are operating on, @insn is the
145
 * array of filter instructions.
L
Linus Torvalds 已提交
146
 */
147
static unsigned int __sk_run_filter(void *ctx, const struct sock_filter_int *insn)
L
Linus Torvalds 已提交
148
{
149 150 151 152 153
	u64 stack[MAX_BPF_STACK / sizeof(u64)];
	u64 regs[MAX_BPF_REG], tmp;
	static const void *jumptable[256] = {
		[0 ... 255] = &&default_label,
		/* Now overwrite non-defaults ... */
D
Daniel Borkmann 已提交
154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247
		/* 32 bit ALU operations */
		[BPF_ALU | BPF_ADD | BPF_X] = &&ALU_ADD_X,
		[BPF_ALU | BPF_ADD | BPF_K] = &&ALU_ADD_K,
		[BPF_ALU | BPF_SUB | BPF_X] = &&ALU_SUB_X,
		[BPF_ALU | BPF_SUB | BPF_K] = &&ALU_SUB_K,
		[BPF_ALU | BPF_AND | BPF_X] = &&ALU_AND_X,
		[BPF_ALU | BPF_AND | BPF_K] = &&ALU_AND_K,
		[BPF_ALU | BPF_OR | BPF_X]  = &&ALU_OR_X,
		[BPF_ALU | BPF_OR | BPF_K]  = &&ALU_OR_K,
		[BPF_ALU | BPF_LSH | BPF_X] = &&ALU_LSH_X,
		[BPF_ALU | BPF_LSH | BPF_K] = &&ALU_LSH_K,
		[BPF_ALU | BPF_RSH | BPF_X] = &&ALU_RSH_X,
		[BPF_ALU | BPF_RSH | BPF_K] = &&ALU_RSH_K,
		[BPF_ALU | BPF_XOR | BPF_X] = &&ALU_XOR_X,
		[BPF_ALU | BPF_XOR | BPF_K] = &&ALU_XOR_K,
		[BPF_ALU | BPF_MUL | BPF_X] = &&ALU_MUL_X,
		[BPF_ALU | BPF_MUL | BPF_K] = &&ALU_MUL_K,
		[BPF_ALU | BPF_MOV | BPF_X] = &&ALU_MOV_X,
		[BPF_ALU | BPF_MOV | BPF_K] = &&ALU_MOV_K,
		[BPF_ALU | BPF_DIV | BPF_X] = &&ALU_DIV_X,
		[BPF_ALU | BPF_DIV | BPF_K] = &&ALU_DIV_K,
		[BPF_ALU | BPF_MOD | BPF_X] = &&ALU_MOD_X,
		[BPF_ALU | BPF_MOD | BPF_K] = &&ALU_MOD_K,
		[BPF_ALU | BPF_NEG] = &&ALU_NEG,
		[BPF_ALU | BPF_END | BPF_TO_BE] = &&ALU_END_TO_BE,
		[BPF_ALU | BPF_END | BPF_TO_LE] = &&ALU_END_TO_LE,
		/* 64 bit ALU operations */
		[BPF_ALU64 | BPF_ADD | BPF_X] = &&ALU64_ADD_X,
		[BPF_ALU64 | BPF_ADD | BPF_K] = &&ALU64_ADD_K,
		[BPF_ALU64 | BPF_SUB | BPF_X] = &&ALU64_SUB_X,
		[BPF_ALU64 | BPF_SUB | BPF_K] = &&ALU64_SUB_K,
		[BPF_ALU64 | BPF_AND | BPF_X] = &&ALU64_AND_X,
		[BPF_ALU64 | BPF_AND | BPF_K] = &&ALU64_AND_K,
		[BPF_ALU64 | BPF_OR | BPF_X] = &&ALU64_OR_X,
		[BPF_ALU64 | BPF_OR | BPF_K] = &&ALU64_OR_K,
		[BPF_ALU64 | BPF_LSH | BPF_X] = &&ALU64_LSH_X,
		[BPF_ALU64 | BPF_LSH | BPF_K] = &&ALU64_LSH_K,
		[BPF_ALU64 | BPF_RSH | BPF_X] = &&ALU64_RSH_X,
		[BPF_ALU64 | BPF_RSH | BPF_K] = &&ALU64_RSH_K,
		[BPF_ALU64 | BPF_XOR | BPF_X] = &&ALU64_XOR_X,
		[BPF_ALU64 | BPF_XOR | BPF_K] = &&ALU64_XOR_K,
		[BPF_ALU64 | BPF_MUL | BPF_X] = &&ALU64_MUL_X,
		[BPF_ALU64 | BPF_MUL | BPF_K] = &&ALU64_MUL_K,
		[BPF_ALU64 | BPF_MOV | BPF_X] = &&ALU64_MOV_X,
		[BPF_ALU64 | BPF_MOV | BPF_K] = &&ALU64_MOV_K,
		[BPF_ALU64 | BPF_ARSH | BPF_X] = &&ALU64_ARSH_X,
		[BPF_ALU64 | BPF_ARSH | BPF_K] = &&ALU64_ARSH_K,
		[BPF_ALU64 | BPF_DIV | BPF_X] = &&ALU64_DIV_X,
		[BPF_ALU64 | BPF_DIV | BPF_K] = &&ALU64_DIV_K,
		[BPF_ALU64 | BPF_MOD | BPF_X] = &&ALU64_MOD_X,
		[BPF_ALU64 | BPF_MOD | BPF_K] = &&ALU64_MOD_K,
		[BPF_ALU64 | BPF_NEG] = &&ALU64_NEG,
		/* Call instruction */
		[BPF_JMP | BPF_CALL] = &&JMP_CALL,
		/* Jumps */
		[BPF_JMP | BPF_JA] = &&JMP_JA,
		[BPF_JMP | BPF_JEQ | BPF_X] = &&JMP_JEQ_X,
		[BPF_JMP | BPF_JEQ | BPF_K] = &&JMP_JEQ_K,
		[BPF_JMP | BPF_JNE | BPF_X] = &&JMP_JNE_X,
		[BPF_JMP | BPF_JNE | BPF_K] = &&JMP_JNE_K,
		[BPF_JMP | BPF_JGT | BPF_X] = &&JMP_JGT_X,
		[BPF_JMP | BPF_JGT | BPF_K] = &&JMP_JGT_K,
		[BPF_JMP | BPF_JGE | BPF_X] = &&JMP_JGE_X,
		[BPF_JMP | BPF_JGE | BPF_K] = &&JMP_JGE_K,
		[BPF_JMP | BPF_JSGT | BPF_X] = &&JMP_JSGT_X,
		[BPF_JMP | BPF_JSGT | BPF_K] = &&JMP_JSGT_K,
		[BPF_JMP | BPF_JSGE | BPF_X] = &&JMP_JSGE_X,
		[BPF_JMP | BPF_JSGE | BPF_K] = &&JMP_JSGE_K,
		[BPF_JMP | BPF_JSET | BPF_X] = &&JMP_JSET_X,
		[BPF_JMP | BPF_JSET | BPF_K] = &&JMP_JSET_K,
		/* Program return */
		[BPF_JMP | BPF_EXIT] = &&JMP_EXIT,
		/* Store instructions */
		[BPF_STX | BPF_MEM | BPF_B] = &&STX_MEM_B,
		[BPF_STX | BPF_MEM | BPF_H] = &&STX_MEM_H,
		[BPF_STX | BPF_MEM | BPF_W] = &&STX_MEM_W,
		[BPF_STX | BPF_MEM | BPF_DW] = &&STX_MEM_DW,
		[BPF_STX | BPF_XADD | BPF_W] = &&STX_XADD_W,
		[BPF_STX | BPF_XADD | BPF_DW] = &&STX_XADD_DW,
		[BPF_ST | BPF_MEM | BPF_B] = &&ST_MEM_B,
		[BPF_ST | BPF_MEM | BPF_H] = &&ST_MEM_H,
		[BPF_ST | BPF_MEM | BPF_W] = &&ST_MEM_W,
		[BPF_ST | BPF_MEM | BPF_DW] = &&ST_MEM_DW,
		/* Load instructions */
		[BPF_LDX | BPF_MEM | BPF_B] = &&LDX_MEM_B,
		[BPF_LDX | BPF_MEM | BPF_H] = &&LDX_MEM_H,
		[BPF_LDX | BPF_MEM | BPF_W] = &&LDX_MEM_W,
		[BPF_LDX | BPF_MEM | BPF_DW] = &&LDX_MEM_DW,
		[BPF_LD | BPF_ABS | BPF_W] = &&LD_ABS_W,
		[BPF_LD | BPF_ABS | BPF_H] = &&LD_ABS_H,
		[BPF_LD | BPF_ABS | BPF_B] = &&LD_ABS_B,
		[BPF_LD | BPF_IND | BPF_W] = &&LD_IND_W,
		[BPF_LD | BPF_IND | BPF_H] = &&LD_IND_H,
		[BPF_LD | BPF_IND | BPF_B] = &&LD_IND_B,
248
	};
249 250
	void *ptr;
	int off;
L
Linus Torvalds 已提交
251

252 253 254 255 256 257
#define CONT	 ({ insn++; goto select_insn; })
#define CONT_JMP ({ insn++; goto select_insn; })

	FP = (u64) (unsigned long) &stack[ARRAY_SIZE(stack)];
	ARG1 = (u64) (unsigned long) ctx;

258
	/* Registers used in classic BPF programs need to be reset first. */
259 260
	regs[BPF_REG_A] = 0;
	regs[BPF_REG_X] = 0;
261 262 263 264 265 266

select_insn:
	goto *jumptable[insn->code];

	/* ALU */
#define ALU(OPCODE, OP)			\
267
	ALU64_##OPCODE##_X:		\
268
		DST = DST OP SRC;	\
269
		CONT;			\
270
	ALU_##OPCODE##_X:		\
271
		DST = (u32) DST OP (u32) SRC;	\
272
		CONT;			\
273
	ALU64_##OPCODE##_K:		\
274
		DST = DST OP IMM;		\
275
		CONT;			\
276
	ALU_##OPCODE##_K:		\
277
		DST = (u32) DST OP (u32) IMM;	\
278 279
		CONT;

280 281 282 283 284 285 286 287
	ALU(ADD,  +)
	ALU(SUB,  -)
	ALU(AND,  &)
	ALU(OR,   |)
	ALU(LSH, <<)
	ALU(RSH, >>)
	ALU(XOR,  ^)
	ALU(MUL,  *)
288
#undef ALU
D
Daniel Borkmann 已提交
289
	ALU_NEG:
290
		DST = (u32) -DST;
291
		CONT;
D
Daniel Borkmann 已提交
292
	ALU64_NEG:
293
		DST = -DST;
294
		CONT;
295
	ALU_MOV_X:
296
		DST = (u32) SRC;
297
		CONT;
298
	ALU_MOV_K:
299
		DST = (u32) IMM;
300
		CONT;
301
	ALU64_MOV_X:
302
		DST = SRC;
303
		CONT;
304
	ALU64_MOV_K:
305
		DST = IMM;
306
		CONT;
307
	ALU64_ARSH_X:
308
		(*(s64 *) &DST) >>= SRC;
309
		CONT;
310
	ALU64_ARSH_K:
311
		(*(s64 *) &DST) >>= IMM;
312
		CONT;
313
	ALU64_MOD_X:
314
		if (unlikely(SRC == 0))
315
			return 0;
316 317
		tmp = DST;
		DST = do_div(tmp, SRC);
318
		CONT;
319
	ALU_MOD_X:
320
		if (unlikely(SRC == 0))
321
			return 0;
322 323
		tmp = (u32) DST;
		DST = do_div(tmp, (u32) SRC);
324
		CONT;
325
	ALU64_MOD_K:
326 327
		tmp = DST;
		DST = do_div(tmp, IMM);
328
		CONT;
329
	ALU_MOD_K:
330 331
		tmp = (u32) DST;
		DST = do_div(tmp, (u32) IMM);
332
		CONT;
333
	ALU64_DIV_X:
334
		if (unlikely(SRC == 0))
335
			return 0;
336
		do_div(DST, SRC);
337
		CONT;
338
	ALU_DIV_X:
339
		if (unlikely(SRC == 0))
340
			return 0;
341 342 343
		tmp = (u32) DST;
		do_div(tmp, (u32) SRC);
		DST = (u32) tmp;
344
		CONT;
345
	ALU64_DIV_K:
346
		do_div(DST, IMM);
347
		CONT;
348
	ALU_DIV_K:
349 350 351
		tmp = (u32) DST;
		do_div(tmp, (u32) IMM);
		DST = (u32) tmp;
352
		CONT;
353
	ALU_END_TO_BE:
354
		switch (IMM) {
355
		case 16:
356
			DST = (__force u16) cpu_to_be16(DST);
357 358
			break;
		case 32:
359
			DST = (__force u32) cpu_to_be32(DST);
360 361
			break;
		case 64:
362
			DST = (__force u64) cpu_to_be64(DST);
363 364 365
			break;
		}
		CONT;
366
	ALU_END_TO_LE:
367
		switch (IMM) {
368
		case 16:
369
			DST = (__force u16) cpu_to_le16(DST);
370 371
			break;
		case 32:
372
			DST = (__force u32) cpu_to_le32(DST);
373 374
			break;
		case 64:
375
			DST = (__force u64) cpu_to_le64(DST);
376 377 378 379 380
			break;
		}
		CONT;

	/* CALL */
D
Daniel Borkmann 已提交
381
	JMP_CALL:
382 383 384
		/* Function call scratches BPF_R1-BPF_R5 registers,
		 * preserves BPF_R6-BPF_R9, and stores return value
		 * into BPF_R0.
385
		 */
386 387
		BPF_R0 = (__bpf_call_base + insn->imm)(BPF_R1, BPF_R2, BPF_R3,
						       BPF_R4, BPF_R5);
388 389 390
		CONT;

	/* JMP */
D
Daniel Borkmann 已提交
391
	JMP_JA:
392 393
		insn += insn->off;
		CONT;
394
	JMP_JEQ_X:
395
		if (DST == SRC) {
396 397 398 399
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
400
	JMP_JEQ_K:
401
		if (DST == IMM) {
402 403 404 405
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
406
	JMP_JNE_X:
407
		if (DST != SRC) {
408 409 410 411
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
412
	JMP_JNE_K:
413
		if (DST != IMM) {
414 415 416 417
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
418
	JMP_JGT_X:
419
		if (DST > SRC) {
420 421 422 423
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
424
	JMP_JGT_K:
425
		if (DST > IMM) {
426 427 428 429
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
430
	JMP_JGE_X:
431
		if (DST >= SRC) {
432 433 434 435
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
436
	JMP_JGE_K:
437
		if (DST >= IMM) {
438 439 440 441
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
442
	JMP_JSGT_X:
443
		if (((s64) DST) > ((s64) SRC)) {
444 445 446 447
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
448
	JMP_JSGT_K:
449
		if (((s64) DST) > ((s64) IMM)) {
450 451 452 453
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
454
	JMP_JSGE_X:
455
		if (((s64) DST) >= ((s64) SRC)) {
456 457 458 459
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
460
	JMP_JSGE_K:
461
		if (((s64) DST) >= ((s64) IMM)) {
462 463 464 465
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
466
	JMP_JSET_X:
467
		if (DST & SRC) {
468 469 470 471
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
472
	JMP_JSET_K:
473
		if (DST & IMM) {
474 475 476 477
			insn += insn->off;
			CONT_JMP;
		}
		CONT;
D
Daniel Borkmann 已提交
478
	JMP_EXIT:
479
		return BPF_R0;
480 481

	/* STX and ST and LDX*/
482 483 484 485 486 487 488 489 490
#define LDST(SIZEOP, SIZE)						\
	STX_MEM_##SIZEOP:						\
		*(SIZE *)(unsigned long) (DST + insn->off) = SRC;	\
		CONT;							\
	ST_MEM_##SIZEOP:						\
		*(SIZE *)(unsigned long) (DST + insn->off) = IMM;	\
		CONT;							\
	LDX_MEM_##SIZEOP:						\
		DST = *(SIZE *)(unsigned long) (SRC + insn->off);	\
491 492
		CONT;

493 494 495 496
	LDST(B,   u8)
	LDST(H,  u16)
	LDST(W,  u32)
	LDST(DW, u64)
497
#undef LDST
498 499 500
	STX_XADD_W: /* lock xadd *(u32 *)(dst_reg + off16) += src_reg */
		atomic_add((u32) SRC, (atomic_t *)(unsigned long)
			   (DST + insn->off));
501
		CONT;
502 503 504
	STX_XADD_DW: /* lock xadd *(u64 *)(dst_reg + off16) += src_reg */
		atomic64_add((u64) SRC, (atomic64_t *)(unsigned long)
			     (DST + insn->off));
505
		CONT;
506 507
	LD_ABS_W: /* BPF_R0 = ntohl(*(u32 *) (skb->data + imm32)) */
		off = IMM;
508
load_word:
509 510 511 512 513 514
		/* BPF_LD + BPD_ABS and BPF_LD + BPF_IND insns are
		 * only appearing in the programs where ctx ==
		 * skb. All programs keep 'ctx' in regs[BPF_REG_CTX]
		 * == BPF_R6, sk_convert_filter() saves it in BPF_R6,
		 * internal BPF verifier will check that BPF_R6 ==
		 * ctx.
515
		 *
516 517 518
		 * BPF_ABS and BPF_IND are wrappers of function calls,
		 * so they scratch BPF_R1-BPF_R5 registers, preserve
		 * BPF_R6-BPF_R9, and store return value into BPF_R0.
519 520
		 *
		 * Implicit input:
521
		 *   ctx == skb == BPF_R6 == CTX
522 523
		 *
		 * Explicit input:
524 525
		 *   SRC == any register
		 *   IMM == 32-bit immediate
526 527
		 *
		 * Output:
528
		 *   BPF_R0 - 8/16/32-bit skb data converted to cpu endianness
529
		 */
530

531
		ptr = bpf_load_pointer((struct sk_buff *) (unsigned long) CTX, off, 4, &tmp);
532
		if (likely(ptr != NULL)) {
533
			BPF_R0 = get_unaligned_be32(ptr);
534 535
			CONT;
		}
536

537
		return 0;
538 539
	LD_ABS_H: /* BPF_R0 = ntohs(*(u16 *) (skb->data + imm32)) */
		off = IMM;
540
load_half:
541
		ptr = bpf_load_pointer((struct sk_buff *) (unsigned long) CTX, off, 2, &tmp);
542
		if (likely(ptr != NULL)) {
543
			BPF_R0 = get_unaligned_be16(ptr);
544 545
			CONT;
		}
546

547
		return 0;
548 549
	LD_ABS_B: /* BPF_R0 = *(u8 *) (skb->data + imm32) */
		off = IMM;
550
load_byte:
551
		ptr = bpf_load_pointer((struct sk_buff *) (unsigned long) CTX, off, 1, &tmp);
552
		if (likely(ptr != NULL)) {
553
			BPF_R0 = *(u8 *)ptr;
554 555
			CONT;
		}
556

557
		return 0;
558 559
	LD_IND_W: /* BPF_R0 = ntohl(*(u32 *) (skb->data + src_reg + imm32)) */
		off = IMM + SRC;
560
		goto load_word;
561 562
	LD_IND_H: /* BPF_R0 = ntohs(*(u16 *) (skb->data + src_reg + imm32)) */
		off = IMM + SRC;
563
		goto load_half;
564 565
	LD_IND_B: /* BPF_R0 = *(u8 *) (skb->data + src_reg + imm32) */
		off = IMM + SRC;
566 567 568 569 570 571 572 573 574 575 576 577
		goto load_byte;

	default_label:
		/* If we ever reach this, we have a bug somewhere. */
		WARN_RATELIMIT(1, "unknown opcode %02x\n", insn->code);
		return 0;
}

/* Helper to find the offset of pkt_type in sk_buff structure. We want
 * to make sure its still a 3bit field starting at a byte boundary;
 * taken from arch/x86/net/bpf_jit_comp.c.
 */
578 579 580
#ifdef __BIG_ENDIAN_BITFIELD
#define PKT_TYPE_MAX	(7 << 5)
#else
581
#define PKT_TYPE_MAX	7
582
#endif
583 584 585 586 587 588 589 590 591 592 593 594 595 596 597
static unsigned int pkt_type_offset(void)
{
	struct sk_buff skb_probe = { .pkt_type = ~0, };
	u8 *ct = (u8 *) &skb_probe;
	unsigned int off;

	for (off = 0; off < sizeof(struct sk_buff); off++) {
		if (ct[off] == PKT_TYPE_MAX)
			return off;
	}

	pr_err_once("Please fix %s, as pkt_type couldn't be found!\n", __func__);
	return -1;
}

598
static u64 __skb_get_pay_offset(u64 ctx, u64 a, u64 x, u64 r4, u64 r5)
599
{
600
	return __skb_get_poff((struct sk_buff *)(unsigned long) ctx);
601 602
}

603
static u64 __skb_get_nlattr(u64 ctx, u64 a, u64 x, u64 r4, u64 r5)
604
{
605
	struct sk_buff *skb = (struct sk_buff *)(unsigned long) ctx;
606 607 608 609 610
	struct nlattr *nla;

	if (skb_is_nonlinear(skb))
		return 0;

611 612 613
	if (skb->len < sizeof(struct nlattr))
		return 0;

614
	if (a > skb->len - sizeof(struct nlattr))
615 616
		return 0;

617
	nla = nla_find((struct nlattr *) &skb->data[a], skb->len - a, x);
618 619 620 621 622 623
	if (nla)
		return (void *) nla - (void *) skb->data;

	return 0;
}

624
static u64 __skb_get_nlattr_nest(u64 ctx, u64 a, u64 x, u64 r4, u64 r5)
625
{
626
	struct sk_buff *skb = (struct sk_buff *)(unsigned long) ctx;
627 628 629 630 631
	struct nlattr *nla;

	if (skb_is_nonlinear(skb))
		return 0;

632 633 634
	if (skb->len < sizeof(struct nlattr))
		return 0;

635
	if (a > skb->len - sizeof(struct nlattr))
636 637
		return 0;

638 639
	nla = (struct nlattr *) &skb->data[a];
	if (nla->nla_len > skb->len - a)
640 641
		return 0;

642
	nla = nla_find_nested(nla, x);
643 644 645 646 647 648
	if (nla)
		return (void *) nla - (void *) skb->data;

	return 0;
}

649
static u64 __get_raw_cpu_id(u64 ctx, u64 a, u64 x, u64 r4, u64 r5)
650 651 652 653
{
	return raw_smp_processor_id();
}

C
Chema Gonzalez 已提交
654
/* note that this only generates 32-bit random numbers */
655
static u64 __get_random_u32(u64 ctx, u64 a, u64 x, u64 r4, u64 r5)
C
Chema Gonzalez 已提交
656
{
657
	return prandom_u32();
C
Chema Gonzalez 已提交
658 659
}

660 661 662 663 664 665 666 667 668
static bool convert_bpf_extensions(struct sock_filter *fp,
				   struct sock_filter_int **insnp)
{
	struct sock_filter_int *insn = *insnp;

	switch (fp->k) {
	case SKF_AD_OFF + SKF_AD_PROTOCOL:
		BUILD_BUG_ON(FIELD_SIZEOF(struct sk_buff, protocol) != 2);

669
		/* A = *(u16 *) (CTX + offsetof(protocol)) */
670 671
		*insn++ = BPF_LDX_MEM(BPF_H, BPF_REG_A, BPF_REG_CTX,
				      offsetof(struct sk_buff, protocol));
672
		/* A = ntohs(A) [emitting a nop or swap16] */
673
		*insn = BPF_ENDIAN(BPF_FROM_BE, BPF_REG_A, 16);
674 675 676
		break;

	case SKF_AD_OFF + SKF_AD_PKTTYPE:
677 678
		*insn = BPF_LDX_MEM(BPF_B, BPF_REG_A, BPF_REG_CTX,
				    pkt_type_offset());
679 680 681
		if (insn->off < 0)
			return false;
		insn++;
682
		*insn = BPF_ALU32_IMM(BPF_AND, BPF_REG_A, PKT_TYPE_MAX);
683 684
#ifdef __BIG_ENDIAN_BITFIELD
		insn++;
685
                *insn = BPF_ALU32_IMM(BPF_RSH, BPF_REG_A, 5);
686
#endif
687 688 689 690 691 692
		break;

	case SKF_AD_OFF + SKF_AD_IFINDEX:
	case SKF_AD_OFF + SKF_AD_HATYPE:
		BUILD_BUG_ON(FIELD_SIZEOF(struct net_device, ifindex) != 4);
		BUILD_BUG_ON(FIELD_SIZEOF(struct net_device, type) != 2);
693 694 695 696 697 698 699 700 701 702 703 704 705 706
		BUILD_BUG_ON(bytes_to_bpf_size(FIELD_SIZEOF(struct sk_buff, dev)) < 0);

		*insn++ = BPF_LDX_MEM(bytes_to_bpf_size(FIELD_SIZEOF(struct sk_buff, dev)),
				      BPF_REG_TMP, BPF_REG_CTX,
				      offsetof(struct sk_buff, dev));
		/* if (tmp != 0) goto pc + 1 */
		*insn++ = BPF_JMP_IMM(BPF_JNE, BPF_REG_TMP, 0, 1);
		*insn++ = BPF_EXIT_INSN();
		if (fp->k == SKF_AD_OFF + SKF_AD_IFINDEX)
			*insn = BPF_LDX_MEM(BPF_W, BPF_REG_A, BPF_REG_TMP,
					    offsetof(struct net_device, ifindex));
		else
			*insn = BPF_LDX_MEM(BPF_H, BPF_REG_A, BPF_REG_TMP,
					    offsetof(struct net_device, type));
707 708 709 710 711
		break;

	case SKF_AD_OFF + SKF_AD_MARK:
		BUILD_BUG_ON(FIELD_SIZEOF(struct sk_buff, mark) != 4);

712 713
		*insn = BPF_LDX_MEM(BPF_W, BPF_REG_A, BPF_REG_CTX,
				    offsetof(struct sk_buff, mark));
714 715 716 717 718
		break;

	case SKF_AD_OFF + SKF_AD_RXHASH:
		BUILD_BUG_ON(FIELD_SIZEOF(struct sk_buff, hash) != 4);

719 720
		*insn = BPF_LDX_MEM(BPF_W, BPF_REG_A, BPF_REG_CTX,
				    offsetof(struct sk_buff, hash));
721 722 723 724 725
		break;

	case SKF_AD_OFF + SKF_AD_QUEUE:
		BUILD_BUG_ON(FIELD_SIZEOF(struct sk_buff, queue_mapping) != 2);

726 727
		*insn = BPF_LDX_MEM(BPF_H, BPF_REG_A, BPF_REG_CTX,
				    offsetof(struct sk_buff, queue_mapping));
728 729 730 731 732 733 734
		break;

	case SKF_AD_OFF + SKF_AD_VLAN_TAG:
	case SKF_AD_OFF + SKF_AD_VLAN_TAG_PRESENT:
		BUILD_BUG_ON(FIELD_SIZEOF(struct sk_buff, vlan_tci) != 2);
		BUILD_BUG_ON(VLAN_TAG_PRESENT != 0x1000);

735
		/* A = *(u16 *) (CTX + offsetof(vlan_tci)) */
736 737
		*insn++ = BPF_LDX_MEM(BPF_H, BPF_REG_A, BPF_REG_CTX,
				      offsetof(struct sk_buff, vlan_tci));
738
		if (fp->k == SKF_AD_OFF + SKF_AD_VLAN_TAG) {
739 740
			*insn = BPF_ALU32_IMM(BPF_AND, BPF_REG_A,
					      ~VLAN_TAG_PRESENT);
741
		} else {
742
			/* A >>= 12 */
743
			*insn++ = BPF_ALU32_IMM(BPF_RSH, BPF_REG_A, 12);
744 745
			/* A &= 1 */
			*insn = BPF_ALU32_IMM(BPF_AND, BPF_REG_A, 1);
746 747 748 749 750 751 752
		}
		break;

	case SKF_AD_OFF + SKF_AD_PAY_OFFSET:
	case SKF_AD_OFF + SKF_AD_NLATTR:
	case SKF_AD_OFF + SKF_AD_NLATTR_NEST:
	case SKF_AD_OFF + SKF_AD_CPU:
C
Chema Gonzalez 已提交
753
	case SKF_AD_OFF + SKF_AD_RANDOM:
754
		/* arg1 = CTX */
755
		*insn++ = BPF_MOV64_REG(BPF_REG_ARG1, BPF_REG_CTX);
756
		/* arg2 = A */
757
		*insn++ = BPF_MOV64_REG(BPF_REG_ARG2, BPF_REG_A);
758
		/* arg3 = X */
759
		*insn++ = BPF_MOV64_REG(BPF_REG_ARG3, BPF_REG_X);
760
		/* Emit call(arg1=CTX, arg2=A, arg3=X) */
761 762
		switch (fp->k) {
		case SKF_AD_OFF + SKF_AD_PAY_OFFSET:
763
			*insn = BPF_EMIT_CALL(__skb_get_pay_offset);
764 765
			break;
		case SKF_AD_OFF + SKF_AD_NLATTR:
766
			*insn = BPF_EMIT_CALL(__skb_get_nlattr);
767 768
			break;
		case SKF_AD_OFF + SKF_AD_NLATTR_NEST:
769
			*insn = BPF_EMIT_CALL(__skb_get_nlattr_nest);
770 771
			break;
		case SKF_AD_OFF + SKF_AD_CPU:
772
			*insn = BPF_EMIT_CALL(__get_raw_cpu_id);
773
			break;
C
Chema Gonzalez 已提交
774
		case SKF_AD_OFF + SKF_AD_RANDOM:
775
			*insn = BPF_EMIT_CALL(__get_random_u32);
C
Chema Gonzalez 已提交
776
			break;
777 778 779 780
		}
		break;

	case SKF_AD_OFF + SKF_AD_ALU_XOR_X:
781 782
		/* A ^= X */
		*insn = BPF_ALU32_REG(BPF_XOR, BPF_REG_A, BPF_REG_X);
783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831
		break;

	default:
		/* This is just a dummy call to avoid letting the compiler
		 * evict __bpf_call_base() as an optimization. Placed here
		 * where no-one bothers.
		 */
		BUG_ON(__bpf_call_base(0, 0, 0, 0, 0) != 0);
		return false;
	}

	*insnp = insn;
	return true;
}

/**
 *	sk_convert_filter - convert filter program
 *	@prog: the user passed filter program
 *	@len: the length of the user passed filter program
 *	@new_prog: buffer where converted program will be stored
 *	@new_len: pointer to store length of converted program
 *
 * Remap 'sock_filter' style BPF instruction set to 'sock_filter_ext' style.
 * Conversion workflow:
 *
 * 1) First pass for calculating the new program length:
 *   sk_convert_filter(old_prog, old_len, NULL, &new_len)
 *
 * 2) 2nd pass to remap in two passes: 1st pass finds new
 *    jump offsets, 2nd pass remapping:
 *   new_prog = kmalloc(sizeof(struct sock_filter_int) * new_len);
 *   sk_convert_filter(old_prog, old_len, new_prog, &new_len);
 *
 * User BPF's register A is mapped to our BPF register 6, user BPF
 * register X is mapped to BPF register 7; frame pointer is always
 * register 10; Context 'void *ctx' is stored in register 1, that is,
 * for socket filters: ctx == 'struct sk_buff *', for seccomp:
 * ctx == 'struct seccomp_data *'.
 */
int sk_convert_filter(struct sock_filter *prog, int len,
		      struct sock_filter_int *new_prog, int *new_len)
{
	int new_flen = 0, pass = 0, target, i;
	struct sock_filter_int *new_insn;
	struct sock_filter *fp;
	int *addrs = NULL;
	u8 bpf_src;

	BUILD_BUG_ON(BPF_MEMWORDS * sizeof(u32) > MAX_BPF_STACK);
832
	BUILD_BUG_ON(BPF_REG_FP + 1 != MAX_BPF_REG);
833

834
	if (len <= 0 || len > BPF_MAXINSNS)
835 836 837
		return -EINVAL;

	if (new_prog) {
838
		addrs = kcalloc(len, sizeof(*addrs), GFP_KERNEL);
839 840 841 842 843 844 845 846
		if (!addrs)
			return -ENOMEM;
	}

do_pass:
	new_insn = new_prog;
	fp = prog;

847 848
	if (new_insn)
		*new_insn = BPF_MOV64_REG(BPF_REG_CTX, BPF_REG_ARG1);
849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895
	new_insn++;

	for (i = 0; i < len; fp++, i++) {
		struct sock_filter_int tmp_insns[6] = { };
		struct sock_filter_int *insn = tmp_insns;

		if (addrs)
			addrs[i] = new_insn - new_prog;

		switch (fp->code) {
		/* All arithmetic insns and skb loads map as-is. */
		case BPF_ALU | BPF_ADD | BPF_X:
		case BPF_ALU | BPF_ADD | BPF_K:
		case BPF_ALU | BPF_SUB | BPF_X:
		case BPF_ALU | BPF_SUB | BPF_K:
		case BPF_ALU | BPF_AND | BPF_X:
		case BPF_ALU | BPF_AND | BPF_K:
		case BPF_ALU | BPF_OR | BPF_X:
		case BPF_ALU | BPF_OR | BPF_K:
		case BPF_ALU | BPF_LSH | BPF_X:
		case BPF_ALU | BPF_LSH | BPF_K:
		case BPF_ALU | BPF_RSH | BPF_X:
		case BPF_ALU | BPF_RSH | BPF_K:
		case BPF_ALU | BPF_XOR | BPF_X:
		case BPF_ALU | BPF_XOR | BPF_K:
		case BPF_ALU | BPF_MUL | BPF_X:
		case BPF_ALU | BPF_MUL | BPF_K:
		case BPF_ALU | BPF_DIV | BPF_X:
		case BPF_ALU | BPF_DIV | BPF_K:
		case BPF_ALU | BPF_MOD | BPF_X:
		case BPF_ALU | BPF_MOD | BPF_K:
		case BPF_ALU | BPF_NEG:
		case BPF_LD | BPF_ABS | BPF_W:
		case BPF_LD | BPF_ABS | BPF_H:
		case BPF_LD | BPF_ABS | BPF_B:
		case BPF_LD | BPF_IND | BPF_W:
		case BPF_LD | BPF_IND | BPF_H:
		case BPF_LD | BPF_IND | BPF_B:
			/* Check for overloaded BPF extension and
			 * directly convert it if found, otherwise
			 * just move on with mapping.
			 */
			if (BPF_CLASS(fp->code) == BPF_LD &&
			    BPF_MODE(fp->code) == BPF_ABS &&
			    convert_bpf_extensions(fp, &insn))
				break;

896
			*insn = BPF_RAW_INSN(fp->code, BPF_REG_A, BPF_REG_X, 0, fp->k);
897 898
			break;

899 900 901 902 903 904 905
		/* Jump transformation cannot use BPF block macros
		 * everywhere as offset calculation and target updates
		 * require a bit more work than the rest, i.e. jump
		 * opcodes map as-is, but offsets need adjustment.
		 */

#define BPF_EMIT_JMP							\
906 907 908 909 910 911 912 913
	do {								\
		if (target >= len || target < 0)			\
			goto err;					\
		insn->off = addrs ? addrs[target] - addrs[i] - 1 : 0;	\
		/* Adjust pc relative offset for 2nd or 3rd insn. */	\
		insn->off -= insn - tmp_insns;				\
	} while (0)

914 915 916 917
		case BPF_JMP | BPF_JA:
			target = i + fp->k + 1;
			insn->code = fp->code;
			BPF_EMIT_JMP;
918 919 920 921 922 923 924 925 926 927 928 929 930 931 932
			break;

		case BPF_JMP | BPF_JEQ | BPF_K:
		case BPF_JMP | BPF_JEQ | BPF_X:
		case BPF_JMP | BPF_JSET | BPF_K:
		case BPF_JMP | BPF_JSET | BPF_X:
		case BPF_JMP | BPF_JGT | BPF_K:
		case BPF_JMP | BPF_JGT | BPF_X:
		case BPF_JMP | BPF_JGE | BPF_K:
		case BPF_JMP | BPF_JGE | BPF_X:
			if (BPF_SRC(fp->code) == BPF_K && (int) fp->k < 0) {
				/* BPF immediates are signed, zero extend
				 * immediate into tmp register and use it
				 * in compare insn.
				 */
933
				*insn++ = BPF_MOV32_IMM(BPF_REG_TMP, fp->k);
934

935 936
				insn->dst_reg = BPF_REG_A;
				insn->src_reg = BPF_REG_TMP;
937 938
				bpf_src = BPF_X;
			} else {
939 940
				insn->dst_reg = BPF_REG_A;
				insn->src_reg = BPF_REG_X;
941 942
				insn->imm = fp->k;
				bpf_src = BPF_SRC(fp->code);
L
Linus Torvalds 已提交
943
			}
944 945 946 947 948

			/* Common case where 'jump_false' is next insn. */
			if (fp->jf == 0) {
				insn->code = BPF_JMP | BPF_OP(fp->code) | bpf_src;
				target = i + fp->jt + 1;
949
				BPF_EMIT_JMP;
950
				break;
L
Linus Torvalds 已提交
951
			}
952 953 954 955 956

			/* Convert JEQ into JNE when 'jump_true' is next insn. */
			if (fp->jt == 0 && BPF_OP(fp->code) == BPF_JEQ) {
				insn->code = BPF_JMP | BPF_JNE | bpf_src;
				target = i + fp->jf + 1;
957
				BPF_EMIT_JMP;
958
				break;
959
			}
960 961 962 963

			/* Other jumps are mapped into two insns: Jxx and JA. */
			target = i + fp->jt + 1;
			insn->code = BPF_JMP | BPF_OP(fp->code) | bpf_src;
964
			BPF_EMIT_JMP;
965 966 967 968
			insn++;

			insn->code = BPF_JMP | BPF_JA;
			target = i + fp->jf + 1;
969
			BPF_EMIT_JMP;
970 971 972 973
			break;

		/* ldxb 4 * ([14] & 0xf) is remaped into 6 insns. */
		case BPF_LDX | BPF_MSH | BPF_B:
974
			/* tmp = A */
975
			*insn++ = BPF_MOV64_REG(BPF_REG_TMP, BPF_REG_A);
976
			/* A = BPF_R0 = *(u8 *) (skb->data + K) */
977
			*insn++ = BPF_LD_ABS(BPF_B, fp->k);
978
			/* A &= 0xf */
979
			*insn++ = BPF_ALU32_IMM(BPF_AND, BPF_REG_A, 0xf);
980
			/* A <<= 2 */
981
			*insn++ = BPF_ALU32_IMM(BPF_LSH, BPF_REG_A, 2);
982
			/* X = A */
983
			*insn++ = BPF_MOV64_REG(BPF_REG_X, BPF_REG_A);
984
			/* A = tmp */
985
			*insn = BPF_MOV64_REG(BPF_REG_A, BPF_REG_TMP);
986 987 988 989 990
			break;

		/* RET_K, RET_A are remaped into 2 insns. */
		case BPF_RET | BPF_A:
		case BPF_RET | BPF_K:
991 992 993
			*insn++ = BPF_MOV32_RAW(BPF_RVAL(fp->code) == BPF_K ?
						BPF_K : BPF_X, BPF_REG_0,
						BPF_REG_A, fp->k);
994
			*insn = BPF_EXIT_INSN();
995 996 997 998 999
			break;

		/* Store to stack. */
		case BPF_ST:
		case BPF_STX:
1000 1001 1002
			*insn = BPF_STX_MEM(BPF_W, BPF_REG_FP, BPF_CLASS(fp->code) ==
					    BPF_ST ? BPF_REG_A : BPF_REG_X,
					    -(BPF_MEMWORDS - fp->k) * 4);
1003 1004 1005 1006 1007
			break;

		/* Load from stack. */
		case BPF_LD | BPF_MEM:
		case BPF_LDX | BPF_MEM:
1008 1009 1010
			*insn = BPF_LDX_MEM(BPF_W, BPF_CLASS(fp->code) == BPF_LD  ?
					    BPF_REG_A : BPF_REG_X, BPF_REG_FP,
					    -(BPF_MEMWORDS - fp->k) * 4);
1011 1012 1013 1014 1015
			break;

		/* A = K or X = K */
		case BPF_LD | BPF_IMM:
		case BPF_LDX | BPF_IMM:
1016 1017
			*insn = BPF_MOV32_IMM(BPF_CLASS(fp->code) == BPF_LD ?
					      BPF_REG_A : BPF_REG_X, fp->k);
1018 1019 1020 1021
			break;

		/* X = A */
		case BPF_MISC | BPF_TAX:
1022
			*insn = BPF_MOV64_REG(BPF_REG_X, BPF_REG_A);
1023 1024 1025 1026
			break;

		/* A = X */
		case BPF_MISC | BPF_TXA:
1027
			*insn = BPF_MOV64_REG(BPF_REG_A, BPF_REG_X);
1028 1029 1030 1031 1032
			break;

		/* A = skb->len or X = skb->len */
		case BPF_LD | BPF_W | BPF_LEN:
		case BPF_LDX | BPF_W | BPF_LEN:
1033 1034 1035
			*insn = BPF_LDX_MEM(BPF_W, BPF_CLASS(fp->code) == BPF_LD ?
					    BPF_REG_A : BPF_REG_X, BPF_REG_CTX,
					    offsetof(struct sk_buff, len));
1036 1037
			break;

1038
		/* Access seccomp_data fields. */
1039
		case BPF_LDX | BPF_ABS | BPF_W:
1040 1041
			/* A = *(u32 *) (ctx + K) */
			*insn = BPF_LDX_MEM(BPF_W, BPF_REG_A, BPF_REG_CTX, fp->k);
1042 1043
			break;

1044
		/* Unkown instruction. */
L
Linus Torvalds 已提交
1045
		default:
1046
			goto err;
L
Linus Torvalds 已提交
1047
		}
1048 1049 1050 1051 1052 1053

		insn++;
		if (new_prog)
			memcpy(new_insn, tmp_insns,
			       sizeof(*insn) * (insn - tmp_insns));
		new_insn += insn - tmp_insns;
L
Linus Torvalds 已提交
1054 1055
	}

1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071
	if (!new_prog) {
		/* Only calculating new length. */
		*new_len = new_insn - new_prog;
		return 0;
	}

	pass++;
	if (new_flen != new_insn - new_prog) {
		new_flen = new_insn - new_prog;
		if (pass > 2)
			goto err;
		goto do_pass;
	}

	kfree(addrs);
	BUG_ON(*new_len != new_flen);
L
Linus Torvalds 已提交
1072
	return 0;
1073 1074 1075
err:
	kfree(addrs);
	return -EINVAL;
L
Linus Torvalds 已提交
1076 1077
}

1078 1079
/* Security:
 *
1080
 * A BPF program is able to use 16 cells of memory to store intermediate
1081 1082
 * values (check u32 mem[BPF_MEMWORDS] in sk_run_filter()).
 *
1083 1084 1085
 * As we dont want to clear mem[] array for each packet going through
 * sk_run_filter(), we check that filter loaded by user never try to read
 * a cell if not previously written, and we check all branches to be sure
L
Lucas De Marchi 已提交
1086
 * a malicious user doesn't try to abuse us.
1087 1088 1089
 */
static int check_load_and_stores(struct sock_filter *filter, int flen)
{
1090
	u16 *masks, memvalid = 0; /* One bit per cell, 16 cells */
1091 1092 1093
	int pc, ret = 0;

	BUILD_BUG_ON(BPF_MEMWORDS > 16);
1094

1095
	masks = kmalloc_array(flen, sizeof(*masks), GFP_KERNEL);
1096 1097
	if (!masks)
		return -ENOMEM;
1098

1099 1100 1101 1102 1103 1104
	memset(masks, 0xff, flen * sizeof(*masks));

	for (pc = 0; pc < flen; pc++) {
		memvalid &= masks[pc];

		switch (filter[pc].code) {
1105 1106
		case BPF_ST:
		case BPF_STX:
1107 1108
			memvalid |= (1 << filter[pc].k);
			break;
1109 1110
		case BPF_LD | BPF_MEM:
		case BPF_LDX | BPF_MEM:
1111 1112 1113 1114 1115
			if (!(memvalid & (1 << filter[pc].k))) {
				ret = -EINVAL;
				goto error;
			}
			break;
1116 1117
		case BPF_JMP | BPF_JA:
			/* A jump must set masks on target */
1118 1119 1120
			masks[pc + 1 + filter[pc].k] &= memvalid;
			memvalid = ~0;
			break;
1121 1122 1123 1124 1125 1126 1127 1128 1129
		case BPF_JMP | BPF_JEQ | BPF_K:
		case BPF_JMP | BPF_JEQ | BPF_X:
		case BPF_JMP | BPF_JGE | BPF_K:
		case BPF_JMP | BPF_JGE | BPF_X:
		case BPF_JMP | BPF_JGT | BPF_K:
		case BPF_JMP | BPF_JGT | BPF_X:
		case BPF_JMP | BPF_JSET | BPF_K:
		case BPF_JMP | BPF_JSET | BPF_X:
			/* A jump must set masks on targets */
1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140
			masks[pc + 1 + filter[pc].jt] &= memvalid;
			masks[pc + 1 + filter[pc].jf] &= memvalid;
			memvalid = ~0;
			break;
		}
	}
error:
	kfree(masks);
	return ret;
}

1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206
static bool chk_code_allowed(u16 code_to_probe)
{
	static const bool codes[] = {
		/* 32 bit ALU operations */
		[BPF_ALU | BPF_ADD | BPF_K] = true,
		[BPF_ALU | BPF_ADD | BPF_X] = true,
		[BPF_ALU | BPF_SUB | BPF_K] = true,
		[BPF_ALU | BPF_SUB | BPF_X] = true,
		[BPF_ALU | BPF_MUL | BPF_K] = true,
		[BPF_ALU | BPF_MUL | BPF_X] = true,
		[BPF_ALU | BPF_DIV | BPF_K] = true,
		[BPF_ALU | BPF_DIV | BPF_X] = true,
		[BPF_ALU | BPF_MOD | BPF_K] = true,
		[BPF_ALU | BPF_MOD | BPF_X] = true,
		[BPF_ALU | BPF_AND | BPF_K] = true,
		[BPF_ALU | BPF_AND | BPF_X] = true,
		[BPF_ALU | BPF_OR | BPF_K] = true,
		[BPF_ALU | BPF_OR | BPF_X] = true,
		[BPF_ALU | BPF_XOR | BPF_K] = true,
		[BPF_ALU | BPF_XOR | BPF_X] = true,
		[BPF_ALU | BPF_LSH | BPF_K] = true,
		[BPF_ALU | BPF_LSH | BPF_X] = true,
		[BPF_ALU | BPF_RSH | BPF_K] = true,
		[BPF_ALU | BPF_RSH | BPF_X] = true,
		[BPF_ALU | BPF_NEG] = true,
		/* Load instructions */
		[BPF_LD | BPF_W | BPF_ABS] = true,
		[BPF_LD | BPF_H | BPF_ABS] = true,
		[BPF_LD | BPF_B | BPF_ABS] = true,
		[BPF_LD | BPF_W | BPF_LEN] = true,
		[BPF_LD | BPF_W | BPF_IND] = true,
		[BPF_LD | BPF_H | BPF_IND] = true,
		[BPF_LD | BPF_B | BPF_IND] = true,
		[BPF_LD | BPF_IMM] = true,
		[BPF_LD | BPF_MEM] = true,
		[BPF_LDX | BPF_W | BPF_LEN] = true,
		[BPF_LDX | BPF_B | BPF_MSH] = true,
		[BPF_LDX | BPF_IMM] = true,
		[BPF_LDX | BPF_MEM] = true,
		/* Store instructions */
		[BPF_ST] = true,
		[BPF_STX] = true,
		/* Misc instructions */
		[BPF_MISC | BPF_TAX] = true,
		[BPF_MISC | BPF_TXA] = true,
		/* Return instructions */
		[BPF_RET | BPF_K] = true,
		[BPF_RET | BPF_A] = true,
		/* Jump instructions */
		[BPF_JMP | BPF_JA] = true,
		[BPF_JMP | BPF_JEQ | BPF_K] = true,
		[BPF_JMP | BPF_JEQ | BPF_X] = true,
		[BPF_JMP | BPF_JGE | BPF_K] = true,
		[BPF_JMP | BPF_JGE | BPF_X] = true,
		[BPF_JMP | BPF_JGT | BPF_K] = true,
		[BPF_JMP | BPF_JGT | BPF_X] = true,
		[BPF_JMP | BPF_JSET | BPF_K] = true,
		[BPF_JMP | BPF_JSET | BPF_X] = true,
	};

	if (code_to_probe >= ARRAY_SIZE(codes))
		return false;

	return codes[code_to_probe];
}

L
Linus Torvalds 已提交
1207 1208 1209 1210 1211 1212 1213
/**
 *	sk_chk_filter - verify socket filter code
 *	@filter: filter to verify
 *	@flen: length of filter
 *
 * Check the user's filter code. If we let some ugly
 * filter code slip through kaboom! The filter must contain
1214 1215
 * no references or jumps that are out of range, no illegal
 * instructions, and must end with a RET instruction.
L
Linus Torvalds 已提交
1216
 *
1217 1218 1219
 * All jumps are forward as they are not signed.
 *
 * Returns 0 if the rule set is legal or -EINVAL if not.
L
Linus Torvalds 已提交
1220
 */
1221
int sk_chk_filter(struct sock_filter *filter, unsigned int flen)
L
Linus Torvalds 已提交
1222
{
1223
	bool anc_found;
1224
	int pc;
L
Linus Torvalds 已提交
1225

1226
	if (flen == 0 || flen > BPF_MAXINSNS)
L
Linus Torvalds 已提交
1227 1228
		return -EINVAL;

1229
	/* Check the filter code now */
L
Linus Torvalds 已提交
1230
	for (pc = 0; pc < flen; pc++) {
1231
		struct sock_filter *ftest = &filter[pc];
1232

1233 1234
		/* May we actually operate on this code? */
		if (!chk_code_allowed(ftest->code))
1235
			return -EINVAL;
1236

1237
		/* Some instructions need special checks */
1238 1239 1240 1241
		switch (ftest->code) {
		case BPF_ALU | BPF_DIV | BPF_K:
		case BPF_ALU | BPF_MOD | BPF_K:
			/* Check for division by zero */
E
Eric Dumazet 已提交
1242 1243 1244
			if (ftest->k == 0)
				return -EINVAL;
			break;
1245 1246 1247 1248 1249
		case BPF_LD | BPF_MEM:
		case BPF_LDX | BPF_MEM:
		case BPF_ST:
		case BPF_STX:
			/* Check for invalid memory addresses */
1250 1251 1252
			if (ftest->k >= BPF_MEMWORDS)
				return -EINVAL;
			break;
1253 1254
		case BPF_JMP | BPF_JA:
			/* Note, the large ftest->k might cause loops.
1255 1256 1257
			 * Compare this with conditional jumps below,
			 * where offsets are limited. --ANK (981016)
			 */
1258
			if (ftest->k >= (unsigned int)(flen - pc - 1))
1259
				return -EINVAL;
1260
			break;
1261 1262 1263 1264 1265 1266 1267 1268 1269
		case BPF_JMP | BPF_JEQ | BPF_K:
		case BPF_JMP | BPF_JEQ | BPF_X:
		case BPF_JMP | BPF_JGE | BPF_K:
		case BPF_JMP | BPF_JGE | BPF_X:
		case BPF_JMP | BPF_JGT | BPF_K:
		case BPF_JMP | BPF_JGT | BPF_X:
		case BPF_JMP | BPF_JSET | BPF_K:
		case BPF_JMP | BPF_JSET | BPF_X:
			/* Both conditionals must be safe */
1270
			if (pc + ftest->jt + 1 >= flen ||
1271 1272
			    pc + ftest->jf + 1 >= flen)
				return -EINVAL;
1273
			break;
1274 1275 1276
		case BPF_LD | BPF_W | BPF_ABS:
		case BPF_LD | BPF_H | BPF_ABS:
		case BPF_LD | BPF_B | BPF_ABS:
1277
			anc_found = false;
1278 1279 1280
			if (bpf_anc_helper(ftest) & BPF_ANC)
				anc_found = true;
			/* Ancillary operation unknown or unsupported */
1281 1282
			if (anc_found == false && ftest->k >= SKF_AD_OFF)
				return -EINVAL;
1283 1284
		}
	}
1285

1286
	/* Last instruction must be a RET code */
1287
	switch (filter[flen - 1].code) {
1288 1289
	case BPF_RET | BPF_K:
	case BPF_RET | BPF_A:
1290
		return check_load_and_stores(filter, flen);
1291
	}
1292

1293
	return -EINVAL;
L
Linus Torvalds 已提交
1294
}
1295
EXPORT_SYMBOL(sk_chk_filter);
L
Linus Torvalds 已提交
1296

1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327
static int sk_store_orig_filter(struct sk_filter *fp,
				const struct sock_fprog *fprog)
{
	unsigned int fsize = sk_filter_proglen(fprog);
	struct sock_fprog_kern *fkprog;

	fp->orig_prog = kmalloc(sizeof(*fkprog), GFP_KERNEL);
	if (!fp->orig_prog)
		return -ENOMEM;

	fkprog = fp->orig_prog;
	fkprog->len = fprog->len;
	fkprog->filter = kmemdup(fp->insns, fsize, GFP_KERNEL);
	if (!fkprog->filter) {
		kfree(fp->orig_prog);
		return -ENOMEM;
	}

	return 0;
}

static void sk_release_orig_filter(struct sk_filter *fp)
{
	struct sock_fprog_kern *fprog = fp->orig_prog;

	if (fprog) {
		kfree(fprog->filter);
		kfree(fprog);
	}
}

1328
/**
E
Eric Dumazet 已提交
1329
 * 	sk_filter_release_rcu - Release a socket filter by rcu_head
1330 1331
 *	@rcu: rcu_head that contains the sk_filter to free
 */
1332
static void sk_filter_release_rcu(struct rcu_head *rcu)
1333 1334 1335
{
	struct sk_filter *fp = container_of(rcu, struct sk_filter, rcu);

1336
	sk_release_orig_filter(fp);
1337
	sk_filter_free(fp);
1338
}
1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362

/**
 *	sk_filter_release - release a socket filter
 *	@fp: filter to remove
 *
 *	Remove a filter from a socket and release its resources.
 */
static void sk_filter_release(struct sk_filter *fp)
{
	if (atomic_dec_and_test(&fp->refcnt))
		call_rcu(&fp->rcu, sk_filter_release_rcu);
}

void sk_filter_uncharge(struct sock *sk, struct sk_filter *fp)
{
	atomic_sub(sk_filter_size(fp->len), &sk->sk_omem_alloc);
	sk_filter_release(fp);
}

void sk_filter_charge(struct sock *sk, struct sk_filter *fp)
{
	atomic_inc(&fp->refcnt);
	atomic_add(sk_filter_size(fp->len), &sk->sk_omem_alloc);
}
1363

1364 1365 1366 1367 1368 1369 1370 1371 1372 1373 1374
static struct sk_filter *__sk_migrate_realloc(struct sk_filter *fp,
					      struct sock *sk,
					      unsigned int len)
{
	struct sk_filter *fp_new;

	if (sk == NULL)
		return krealloc(fp, len, GFP_KERNEL);

	fp_new = sock_kmalloc(sk, len, GFP_KERNEL);
	if (fp_new) {
1375
		*fp_new = *fp;
1376
		/* As we're keeping orig_prog in fp_new along,
1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391
		 * we need to make sure we're not evicting it
		 * from the old fp.
		 */
		fp->orig_prog = NULL;
		sk_filter_uncharge(sk, fp);
	}

	return fp_new;
}

static struct sk_filter *__sk_migrate_filter(struct sk_filter *fp,
					     struct sock *sk)
{
	struct sock_filter *old_prog;
	struct sk_filter *old_fp;
1392
	int err, new_len, old_len = fp->len;
1393 1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441

	/* We are free to overwrite insns et al right here as it
	 * won't be used at this point in time anymore internally
	 * after the migration to the internal BPF instruction
	 * representation.
	 */
	BUILD_BUG_ON(sizeof(struct sock_filter) !=
		     sizeof(struct sock_filter_int));

	/* Conversion cannot happen on overlapping memory areas,
	 * so we need to keep the user BPF around until the 2nd
	 * pass. At this time, the user BPF is stored in fp->insns.
	 */
	old_prog = kmemdup(fp->insns, old_len * sizeof(struct sock_filter),
			   GFP_KERNEL);
	if (!old_prog) {
		err = -ENOMEM;
		goto out_err;
	}

	/* 1st pass: calculate the new program length. */
	err = sk_convert_filter(old_prog, old_len, NULL, &new_len);
	if (err)
		goto out_err_free;

	/* Expand fp for appending the new filter representation. */
	old_fp = fp;
	fp = __sk_migrate_realloc(old_fp, sk, sk_filter_size(new_len));
	if (!fp) {
		/* The old_fp is still around in case we couldn't
		 * allocate new memory, so uncharge on that one.
		 */
		fp = old_fp;
		err = -ENOMEM;
		goto out_err_free;
	}

	fp->len = new_len;

	/* 2nd pass: remap sock_filter insns into sock_filter_int insns. */
	err = sk_convert_filter(old_prog, old_len, fp->insnsi, &new_len);
	if (err)
		/* 2nd sk_convert_filter() can fail only if it fails
		 * to allocate memory, remapping must succeed. Note,
		 * that at this time old_fp has already been released
		 * by __sk_migrate_realloc().
		 */
		goto out_err_free;

1442 1443
	sk_filter_select_runtime(fp);

1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457
	kfree(old_prog);
	return fp;

out_err_free:
	kfree(old_prog);
out_err:
	/* Rollback filter setup. */
	if (sk != NULL)
		sk_filter_uncharge(sk, fp);
	else
		kfree(fp);
	return ERR_PTR(err);
}

1458 1459 1460 1461
void __weak bpf_int_jit_compile(struct sk_filter *prog)
{
}

1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484
/**
 *	sk_filter_select_runtime - select execution runtime for BPF program
 *	@fp: sk_filter populated with internal BPF program
 *
 * try to JIT internal BPF program, if JIT is not available select interpreter
 * BPF program will be executed via SK_RUN_FILTER() macro
 */
void sk_filter_select_runtime(struct sk_filter *fp)
{
	fp->bpf_func = (void *) __sk_run_filter;

	/* Probe if internal BPF can be JITed */
	bpf_int_jit_compile(fp);
}
EXPORT_SYMBOL_GPL(sk_filter_select_runtime);

/* free internal BPF program */
void sk_filter_free(struct sk_filter *fp)
{
	bpf_jit_free(fp);
}
EXPORT_SYMBOL_GPL(sk_filter_free);

1485 1486
static struct sk_filter *__sk_prepare_filter(struct sk_filter *fp,
					     struct sock *sk)
1487 1488 1489
{
	int err;

1490
	fp->bpf_func = NULL;
1491
	fp->jited = 0;
1492 1493

	err = sk_chk_filter(fp->insns, fp->len);
1494 1495 1496 1497 1498
	if (err) {
		if (sk != NULL)
			sk_filter_uncharge(sk, fp);
		else
			kfree(fp);
1499
		return ERR_PTR(err);
1500
	}
1501

1502 1503 1504
	/* Probe if we can JIT compile the filter and if so, do
	 * the compilation of the filter.
	 */
1505
	bpf_jit_compile(fp);
1506 1507 1508 1509

	/* JIT compiler couldn't process this filter, so do the
	 * internal BPF translation for the optimized interpreter.
	 */
1510
	if (!fp->jited)
1511 1512 1513
		fp = __sk_migrate_filter(fp, sk);

	return fp;
1514 1515 1516 1517
}

/**
 *	sk_unattached_filter_create - create an unattached filter
R
Randy Dunlap 已提交
1518
 *	@pfp: the unattached filter that is created
1519
 *	@fprog: the filter program
1520
 *
R
Randy Dunlap 已提交
1521
 * Create a filter independent of any socket. We first run some
1522 1523 1524 1525 1526
 * sanity checks on it to make sure it does not explode on us later.
 * If an error occurs or there is insufficient memory for the filter
 * a negative errno code is returned. On success the return is zero.
 */
int sk_unattached_filter_create(struct sk_filter **pfp,
1527
				struct sock_fprog_kern *fprog)
1528
{
1529
	unsigned int fsize = sk_filter_proglen(fprog);
1530 1531 1532 1533 1534 1535
	struct sk_filter *fp;

	/* Make sure new filter is there and in the right amounts. */
	if (fprog->filter == NULL)
		return -EINVAL;

1536
	fp = kmalloc(sk_filter_size(fprog->len), GFP_KERNEL);
1537 1538
	if (!fp)
		return -ENOMEM;
1539

1540 1541 1542 1543
	memcpy(fp->insns, fprog->filter, fsize);

	atomic_set(&fp->refcnt, 1);
	fp->len = fprog->len;
1544 1545 1546 1547 1548
	/* Since unattached filters are not copied back to user
	 * space through sk_get_filter(), we do not need to hold
	 * a copy here, and can spare us the work.
	 */
	fp->orig_prog = NULL;
1549

1550 1551 1552 1553 1554 1555
	/* __sk_prepare_filter() already takes care of uncharging
	 * memory in case something goes wrong.
	 */
	fp = __sk_prepare_filter(fp, NULL);
	if (IS_ERR(fp))
		return PTR_ERR(fp);
1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567

	*pfp = fp;
	return 0;
}
EXPORT_SYMBOL_GPL(sk_unattached_filter_create);

void sk_unattached_filter_destroy(struct sk_filter *fp)
{
	sk_filter_release(fp);
}
EXPORT_SYMBOL_GPL(sk_unattached_filter_destroy);

L
Linus Torvalds 已提交
1568 1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579
/**
 *	sk_attach_filter - attach a socket filter
 *	@fprog: the filter program
 *	@sk: the socket to use
 *
 * Attach the user's filter code. We first run some sanity checks on
 * it to make sure it does not explode on us later. If an error
 * occurs or there is insufficient memory for the filter a negative
 * errno code is returned. On success the return is zero.
 */
int sk_attach_filter(struct sock_fprog *fprog, struct sock *sk)
{
1580
	struct sk_filter *fp, *old_fp;
1581
	unsigned int fsize = sk_filter_proglen(fprog);
1582
	unsigned int sk_fsize = sk_filter_size(fprog->len);
L
Linus Torvalds 已提交
1583 1584
	int err;

1585 1586 1587
	if (sock_flag(sk, SOCK_FILTER_LOCKED))
		return -EPERM;

L
Linus Torvalds 已提交
1588
	/* Make sure new filter is there and in the right amounts. */
1589 1590
	if (fprog->filter == NULL)
		return -EINVAL;
L
Linus Torvalds 已提交
1591

1592
	fp = sock_kmalloc(sk, sk_fsize, GFP_KERNEL);
L
Linus Torvalds 已提交
1593 1594
	if (!fp)
		return -ENOMEM;
1595

L
Linus Torvalds 已提交
1596
	if (copy_from_user(fp->insns, fprog->filter, fsize)) {
1597
		sock_kfree_s(sk, fp, sk_fsize);
L
Linus Torvalds 已提交
1598 1599 1600 1601 1602 1603
		return -EFAULT;
	}

	atomic_set(&fp->refcnt, 1);
	fp->len = fprog->len;

1604 1605 1606 1607 1608 1609
	err = sk_store_orig_filter(fp, fprog);
	if (err) {
		sk_filter_uncharge(sk, fp);
		return -ENOMEM;
	}

1610 1611 1612 1613 1614 1615
	/* __sk_prepare_filter() already takes care of uncharging
	 * memory in case something goes wrong.
	 */
	fp = __sk_prepare_filter(fp, sk);
	if (IS_ERR(fp))
		return PTR_ERR(fp);
L
Linus Torvalds 已提交
1616

1617 1618
	old_fp = rcu_dereference_protected(sk->sk_filter,
					   sock_owned_by_user(sk));
1619 1620
	rcu_assign_pointer(sk->sk_filter, fp);

1621
	if (old_fp)
E
Eric Dumazet 已提交
1622
		sk_filter_uncharge(sk, old_fp);
1623

1624
	return 0;
L
Linus Torvalds 已提交
1625
}
1626
EXPORT_SYMBOL_GPL(sk_attach_filter);
L
Linus Torvalds 已提交
1627

1628 1629 1630 1631 1632
int sk_detach_filter(struct sock *sk)
{
	int ret = -ENOENT;
	struct sk_filter *filter;

1633 1634 1635
	if (sock_flag(sk, SOCK_FILTER_LOCKED))
		return -EPERM;

1636 1637
	filter = rcu_dereference_protected(sk->sk_filter,
					   sock_owned_by_user(sk));
1638
	if (filter) {
1639
		RCU_INIT_POINTER(sk->sk_filter, NULL);
E
Eric Dumazet 已提交
1640
		sk_filter_uncharge(sk, filter);
1641 1642
		ret = 0;
	}
1643

1644 1645
	return ret;
}
1646
EXPORT_SYMBOL_GPL(sk_detach_filter);
1647

1648 1649
int sk_get_filter(struct sock *sk, struct sock_filter __user *ubuf,
		  unsigned int len)
1650
{
1651
	struct sock_fprog_kern *fprog;
1652
	struct sk_filter *filter;
1653
	int ret = 0;
1654 1655 1656

	lock_sock(sk);
	filter = rcu_dereference_protected(sk->sk_filter,
1657
					   sock_owned_by_user(sk));
1658 1659
	if (!filter)
		goto out;
1660 1661 1662 1663 1664 1665 1666

	/* We're copying the filter that has been originally attached,
	 * so no conversion/decode needed anymore.
	 */
	fprog = filter->orig_prog;

	ret = fprog->len;
1667
	if (!len)
1668
		/* User space only enquires number of filter blocks. */
1669
		goto out;
1670

1671
	ret = -EINVAL;
1672
	if (len < fprog->len)
1673 1674 1675
		goto out;

	ret = -EFAULT;
1676 1677
	if (copy_to_user(ubuf, fprog->filter, sk_filter_proglen(fprog)))
		goto out;
1678

1679 1680 1681 1682
	/* Instead of bytes, the API requests to return the number
	 * of filter blocks.
	 */
	ret = fprog->len;
1683 1684 1685 1686
out:
	release_sock(sk);
	return ret;
}