cregit-Linux how code gets into the kernel

Release 4.8 net/netfilter/nf_conntrack_proto_dccp.c

Directory: net/netfilter
/*
 * DCCP connection tracking protocol helper
 *
 * Copyright (c) 2005, 2006, 2008 Patrick McHardy <kaber@trash.net>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 2 as
 * published by the Free Software Foundation.
 *
 */
#include <linux/kernel.h>
#include <linux/module.h>
#include <linux/init.h>
#include <linux/sysctl.h>
#include <linux/spinlock.h>
#include <linux/skbuff.h>
#include <linux/dccp.h>
#include <linux/slab.h>

#include <net/net_namespace.h>
#include <net/netns/generic.h>

#include <linux/netfilter/nfnetlink_conntrack.h>
#include <net/netfilter/nf_conntrack.h>
#include <net/netfilter/nf_conntrack_l4proto.h>
#include <net/netfilter/nf_conntrack_ecache.h>
#include <net/netfilter/nf_log.h>

/* Timeouts are based on values from RFC4340:
 *
 * - REQUEST:
 *
 *   8.1.2. Client Request
 *
 *   A client MAY give up on its DCCP-Requests after some time
 *   (3 minutes, for example).
 *
 * - RESPOND:
 *
 *   8.1.3. Server Response
 *
 *   It MAY also leave the RESPOND state for CLOSED after a timeout of
 *   not less than 4MSL (8 minutes);
 *
 * - PARTOPEN:
 *
 *   8.1.5. Handshake Completion
 *
 *   If the client remains in PARTOPEN for more than 4MSL (8 minutes),
 *   it SHOULD reset the connection with Reset Code 2, "Aborted".
 *
 * - OPEN:
 *
 *   The DCCP timestamp overflows after 11.9 hours. If the connection
 *   stays idle this long the sequence number won't be recognized
 *   as valid anymore.
 *
 * - CLOSEREQ/CLOSING:
 *
 *   8.3. Termination
 *
 *   The retransmission timer should initially be set to go off in two
 *   round-trip times and should back off to not less than once every
 *   64 seconds ...
 *
 * - TIMEWAIT:
 *
 *   4.3. States
 *
 *   A server or client socket remains in this state for 2MSL (4 minutes)
 *   after the connection has been town down, ...
 */


#define DCCP_MSL (2 * 60 * HZ)


static const char * const dccp_state_names[] = {
	[CT_DCCP_NONE]		= "NONE",
	[CT_DCCP_REQUEST]	= "REQUEST",
	[CT_DCCP_RESPOND]	= "RESPOND",
	[CT_DCCP_PARTOPEN]	= "PARTOPEN",
	[CT_DCCP_OPEN]		= "OPEN",
	[CT_DCCP_CLOSEREQ]	= "CLOSEREQ",
	[CT_DCCP_CLOSING]	= "CLOSING",
	[CT_DCCP_TIMEWAIT]	= "TIMEWAIT",
	[CT_DCCP_IGNORE]	= "IGNORE",
	[CT_DCCP_INVALID]	= "INVALID",
};


#define sNO	CT_DCCP_NONE

#define sRQ	CT_DCCP_REQUEST

#define sRS	CT_DCCP_RESPOND

#define sPO	CT_DCCP_PARTOPEN

#define sOP	CT_DCCP_OPEN

#define sCR	CT_DCCP_CLOSEREQ

#define sCG	CT_DCCP_CLOSING

#define sTW	CT_DCCP_TIMEWAIT

#define sIG	CT_DCCP_IGNORE

#define sIV	CT_DCCP_INVALID

/*
 * DCCP state transition table
 *
 * The assumption is the same as for TCP tracking:
 *
 * We are the man in the middle. All the packets go through us but might
 * get lost in transit to the destination. It is assumed that the destination
 * can't receive segments we haven't seen.
 *
 * The following states exist:
 *
 * NONE:        Initial state, expecting Request
 * REQUEST:     Request seen, waiting for Response from server
 * RESPOND:     Response from server seen, waiting for Ack from client
 * PARTOPEN:    Ack after Response seen, waiting for packet other than Response,
 *              Reset or Sync from server
 * OPEN:        Packet other than Response, Reset or Sync seen
 * CLOSEREQ:    CloseReq from server seen, expecting Close from client
 * CLOSING:     Close seen, expecting Reset
 * TIMEWAIT:    Reset seen
 * IGNORE:      Not determinable whether packet is valid
 *
 * Some states exist only on one side of the connection: REQUEST, RESPOND,
 * PARTOPEN, CLOSEREQ. For the other side these states are equivalent to
 * the one it was in before.
 *
 * Packets are marked as ignored (sIG) if we don't know if they're valid
 * (for example a reincarnation of a connection we didn't notice is dead
 * already) and the server may send back a connection closing Reset or a
 * Response. They're also used for Sync/SyncAck packets, which we don't
 * care about.
 */
static const u_int8_t

dccp_state_table[CT_DCCP_ROLE_MAX + 1][DCCP_PKT_SYNCACK + 1][CT_DCCP_MAX + 1] = {
	[CT_DCCP_ROLE_CLIENT] = {
		[DCCP_PKT_REQUEST] = {
		/*
                 * sNO -> sRQ           Regular Request
                 * sRQ -> sRQ           Retransmitted Request or reincarnation
                 * sRS -> sRS           Retransmitted Request (apparently Response
                 *                      got lost after we saw it) or reincarnation
                 * sPO -> sIG           Ignore, conntrack might be out of sync
                 * sOP -> sIG           Ignore, conntrack might be out of sync
                 * sCR -> sIG           Ignore, conntrack might be out of sync
                 * sCG -> sIG           Ignore, conntrack might be out of sync
                 * sTW -> sRQ           Reincarnation
                 *
                 *      sNO, sRQ, sRS, sPO. sOP, sCR, sCG, sTW, */
			sRQ, sRQ, sRS, sIG, sIG, sIG, sIG, sRQ,
                },
		[DCCP_PKT_RESPONSE] = {
		/*
                 * sNO -> sIV           Invalid
                 * sRQ -> sIG           Ignore, might be response to ignored Request
                 * sRS -> sIG           Ignore, might be response to ignored Request
                 * sPO -> sIG           Ignore, might be response to ignored Request
                 * sOP -> sIG           Ignore, might be response to ignored Request
                 * sCR -> sIG           Ignore, might be response to ignored Request
                 * sCG -> sIG           Ignore, might be response to ignored Request
                 * sTW -> sIV           Invalid, reincarnation in reverse direction
                 *                      goes through sRQ
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIG, sIG, sIG, sIG, sIG, sIG, sIV,
                },
		[DCCP_PKT_ACK] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sIV           No connection
                 * sRS -> sPO           Ack for Response, move to PARTOPEN (8.1.5.)
                 * sPO -> sPO           Retransmitted Ack for Response, remain in PARTOPEN
                 * sOP -> sOP           Regular ACK, remain in OPEN
                 * sCR -> sCR           Ack in CLOSEREQ MAY be processed (8.3.)
                 * sCG -> sCG           Ack in CLOSING MAY be processed (8.3.)
                 * sTW -> sIV
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIV, sPO, sPO, sOP, sCR, sCG, sIV
		},
		[DCCP_PKT_DATA] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sIV           No connection
                 * sRS -> sIV           No connection
                 * sPO -> sIV           MUST use DataAck in PARTOPEN state (8.1.5.)
                 * sOP -> sOP           Regular Data packet
                 * sCR -> sCR           Data in CLOSEREQ MAY be processed (8.3.)
                 * sCG -> sCG           Data in CLOSING MAY be processed (8.3.)
                 * sTW -> sIV
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIV, sIV, sIV, sOP, sCR, sCG, sIV,
                },
		[DCCP_PKT_DATAACK] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sIV           No connection
                 * sRS -> sPO           Ack for Response, move to PARTOPEN (8.1.5.)
                 * sPO -> sPO           Remain in PARTOPEN state
                 * sOP -> sOP           Regular DataAck packet in OPEN state
                 * sCR -> sCR           DataAck in CLOSEREQ MAY be processed (8.3.)
                 * sCG -> sCG           DataAck in CLOSING MAY be processed (8.3.)
                 * sTW -> sIV
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIV, sPO, sPO, sOP, sCR, sCG, sIV
		},
		[DCCP_PKT_CLOSEREQ] = {
		/*
                 * CLOSEREQ may only be sent by the server.
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIV, sIV, sIV, sIV, sIV, sIV, sIV
		},
		[DCCP_PKT_CLOSE] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sIV           No connection
                 * sRS -> sIV           No connection
                 * sPO -> sCG           Client-initiated close
                 * sOP -> sCG           Client-initiated close
                 * sCR -> sCG           Close in response to CloseReq (8.3.)
                 * sCG -> sCG           Retransmit
                 * sTW -> sIV           Late retransmit, already in TIME_WAIT
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIV, sIV, sCG, sCG, sCG, sIV, sIV
		},
		[DCCP_PKT_RESET] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sTW           Sync received or timeout, SHOULD send Reset (8.1.1.)
                 * sRS -> sTW           Response received without Request
                 * sPO -> sTW           Timeout, SHOULD send Reset (8.1.5.)
                 * sOP -> sTW           Connection reset
                 * sCR -> sTW           Connection reset
                 * sCG -> sTW           Connection reset
                 * sTW -> sIG           Ignore (don't refresh timer)
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sTW, sTW, sTW, sTW, sTW, sTW, sIG
		},
		[DCCP_PKT_SYNC] = {
		/*
                 * We currently ignore Sync packets
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIG, sIG, sIG, sIG, sIG, sIG, sIG, sIG,
                },
		[DCCP_PKT_SYNCACK] = {
		/*
                 * We currently ignore SyncAck packets
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIG, sIG, sIG, sIG, sIG, sIG, sIG, sIG,
                },
        },
	[CT_DCCP_ROLE_SERVER] = {
		[DCCP_PKT_REQUEST] = {
		/*
                 * sNO -> sIV           Invalid
                 * sRQ -> sIG           Ignore, conntrack might be out of sync
                 * sRS -> sIG           Ignore, conntrack might be out of sync
                 * sPO -> sIG           Ignore, conntrack might be out of sync
                 * sOP -> sIG           Ignore, conntrack might be out of sync
                 * sCR -> sIG           Ignore, conntrack might be out of sync
                 * sCG -> sIG           Ignore, conntrack might be out of sync
                 * sTW -> sRQ           Reincarnation, must reverse roles
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIG, sIG, sIG, sIG, sIG, sIG, sRQ
		},
		[DCCP_PKT_RESPONSE] = {
		/*
                 * sNO -> sIV           Response without Request
                 * sRQ -> sRS           Response to clients Request
                 * sRS -> sRS           Retransmitted Response (8.1.3. SHOULD NOT)
                 * sPO -> sIG           Response to an ignored Request or late retransmit
                 * sOP -> sIG           Ignore, might be response to ignored Request
                 * sCR -> sIG           Ignore, might be response to ignored Request
                 * sCG -> sIG           Ignore, might be response to ignored Request
                 * sTW -> sIV           Invalid, Request from client in sTW moves to sRQ
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sRS, sRS, sIG, sIG, sIG, sIG, sIV
		},
		[DCCP_PKT_ACK] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sIV           No connection
                 * sRS -> sIV           No connection
                 * sPO -> sOP           Enter OPEN state (8.1.5.)
                 * sOP -> sOP           Regular Ack in OPEN state
                 * sCR -> sIV           Waiting for Close from client
                 * sCG -> sCG           Ack in CLOSING MAY be processed (8.3.)
                 * sTW -> sIV
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIV, sIV, sOP, sOP, sIV, sCG, sIV
		},
		[DCCP_PKT_DATA] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sIV           No connection
                 * sRS -> sIV           No connection
                 * sPO -> sOP           Enter OPEN state (8.1.5.)
                 * sOP -> sOP           Regular Data packet in OPEN state
                 * sCR -> sIV           Waiting for Close from client
                 * sCG -> sCG           Data in CLOSING MAY be processed (8.3.)
                 * sTW -> sIV
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIV, sIV, sOP, sOP, sIV, sCG, sIV
		},
		[DCCP_PKT_DATAACK] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sIV           No connection
                 * sRS -> sIV           No connection
                 * sPO -> sOP           Enter OPEN state (8.1.5.)
                 * sOP -> sOP           Regular DataAck in OPEN state
                 * sCR -> sIV           Waiting for Close from client
                 * sCG -> sCG           Data in CLOSING MAY be processed (8.3.)
                 * sTW -> sIV
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIV, sIV, sOP, sOP, sIV, sCG, sIV
		},
		[DCCP_PKT_CLOSEREQ] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sIV           No connection
                 * sRS -> sIV           No connection
                 * sPO -> sOP -> sCR    Move directly to CLOSEREQ (8.1.5.)
                 * sOP -> sCR           CloseReq in OPEN state
                 * sCR -> sCR           Retransmit
                 * sCG -> sCR           Simultaneous close, client sends another Close
                 * sTW -> sIV           Already closed
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIV, sIV, sCR, sCR, sCR, sCR, sIV
		},
		[DCCP_PKT_CLOSE] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sIV           No connection
                 * sRS -> sIV           No connection
                 * sPO -> sOP -> sCG    Move direcly to CLOSING
                 * sOP -> sCG           Move to CLOSING
                 * sCR -> sIV           Close after CloseReq is invalid
                 * sCG -> sCG           Retransmit
                 * sTW -> sIV           Already closed
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIV, sIV, sIV, sCG, sCG, sIV, sCG, sIV
		},
		[DCCP_PKT_RESET] = {
		/*
                 * sNO -> sIV           No connection
                 * sRQ -> sTW           Reset in response to Request
                 * sRS -> sTW           Timeout, SHOULD send Reset (8.1.3.)
                 * sPO -> sTW           Timeout, SHOULD send Reset (8.1.3.)
                 * sOP -> sTW
                 * sCR -> sTW
                 * sCG -> sTW
                 * sTW -> sIG           Ignore (don't refresh timer)
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW, sTW */
			sIV, sTW, sTW, sTW, sTW, sTW, sTW, sTW, sIG
		},
		[DCCP_PKT_SYNC] = {
		/*
                 * We currently ignore Sync packets
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIG, sIG, sIG, sIG, sIG, sIG, sIG, sIG,
                },
		[DCCP_PKT_SYNCACK] = {
		/*
                 * We currently ignore SyncAck packets
                 *
                 *      sNO, sRQ, sRS, sPO, sOP, sCR, sCG, sTW */
			sIG, sIG, sIG, sIG, sIG, sIG, sIG, sIG,
                },
        },
};

/* this module per-net specifics */

static int dccp_net_id __read_mostly;

struct dccp_net {
	
struct nf_proto_net pn;
	
int dccp_loose;
	
unsigned int dccp_timeout[CT_DCCP_MAX + 1];
};


static inline struct dccp_net *dccp_pernet(struct net *net) { return net_generic(net, dccp_net_id); }

Contributors

PersonTokensPropCommitsCommitProp
cyrill gorcunovcyrill gorcunov22100.00%1100.00%
Total22100.00%1100.00%


static bool dccp_pkt_to_tuple(const struct sk_buff *skb, unsigned int dataoff, struct net *net, struct nf_conntrack_tuple *tuple) { struct dccp_hdr _hdr, *dh; dh = skb_header_pointer(skb, dataoff, sizeof(_hdr), &_hdr); if (dh == NULL) return false; tuple->src.u.dccp.port = dh->dccph_sport; tuple->dst.u.dccp.port = dh->dccph_dport; return true; }

Contributors

PersonTokensPropCommitsCommitProp
patrick mchardypatrick mchardy8291.11%133.33%
eric w. biedermaneric w. biederman55.56%133.33%
jan engelhardtjan engelhardt33.33%133.33%
Total90100.00%3100.00%


static bool dccp_invert_tuple(struct nf_conntrack_tuple *inv, const struct nf_conntrack_tuple *tuple) { inv->src.u.dccp.port = tuple->dst.u.dccp.port; inv->dst.u.dccp.port = tuple->src.u.dccp.port; return true; }

Contributors

PersonTokensPropCommitsCommitProp
patrick mchardypatrick mchardy5896.67%150.00%
jan engelhardtjan engelhardt23.33%150.00%
Total60100.00%2100.00%


static bool dccp_new(struct nf_conn *ct, const struct sk_buff *skb, unsigned int dataoff, unsigned int *timeouts) { struct net *net = nf_ct_net(ct); struct dccp_net *dn; struct dccp_hdr _dh, *dh; const char *msg; u_int8_t state; dh = skb_header_pointer(skb, dataoff, sizeof(_dh), &_dh); BUG_ON(dh == NULL); state = dccp_state_table[CT_DCCP_ROLE_CLIENT][dh->dccph_type][CT_DCCP_NONE]; switch (state) { default: dn = dccp_pernet(net); if (dn->dccp_loose == 0) { msg = "nf_ct_dccp: not picking up existing connection "; goto out_invalid; } case CT_DCCP_REQUEST: break; case CT_DCCP_INVALID: msg = "nf_ct_dccp: invalid state transition "; goto out_invalid; } ct->proto.dccp.role[IP_CT_DIR_ORIGINAL] = CT_DCCP_ROLE_CLIENT; ct->proto.dccp.role[IP_CT_DIR_REPLY] = CT_DCCP_ROLE_SERVER; ct->proto.dccp.state = CT_DCCP_NONE; ct->proto.dccp.last_pkt = DCCP_PKT_REQUEST; ct->proto.dccp.last_dir = IP_CT_DIR_ORIGINAL; ct->proto.dccp.handshake_seq = 0; return true; out_invalid: if (LOG_INVALID(net, IPPROTO_DCCP)) nf_log_packet(net, nf_ct_l3num(ct), 0, skb, NULL, NULL, NULL, "%s", msg); return false; }

Contributors

PersonTokensPropCommitsCommitProp
patrick mchardypatrick mchardy17771.66%220.00%
changli gaochangli gao3012.15%110.00%
cyrill gorcunovcyrill gorcunov156.07%110.00%
alexey dobriyanalexey dobriyan124.86%110.00%
pablo neira ayusopablo neira ayuso52.02%110.00%
daniel borkmanndaniel borkmann31.21%220.00%
jan engelhardtjan engelhardt31.21%110.00%
gao fenggao feng20.81%110.00%
Total247100.00%10100.00%


static u64 dccp_ack_seq(const struct dccp_hdr *dh) { const struct dccp_hdr_ack_bits *dhack; dhack = (void *)dh + __dccp_basic_hdr_len(dh); return ((u64)ntohs(dhack->dccph_ack_nr_high) << 32) + ntohl(dhack->dccph_ack_nr_low); }

Contributors

PersonTokensPropCommitsCommitProp
patrick mchardypatrick mchardy53100.00%1100.00%
Total53100.00%1100.00%


static unsigned int *dccp_get_timeouts(struct net *net) { return dccp_pernet(net)->dccp_timeout; }

Contributors

PersonTokensPropCommitsCommitProp
pablo neira ayusopablo neira ayuso21100.00%1100.00%
Total21100.00%1100.00%


static int dccp_packet(struct nf_conn *ct, const struct sk_buff *skb, unsigned int dataoff, enum ip_conntrack_info ctinfo, u_int8_t pf, unsigned int hooknum, unsigned int *timeouts) { struct net *net = nf_ct_net(ct); enum ip_conntrack_dir dir = CTINFO2DIR(ctinfo); struct dccp_hdr _dh, *dh; u_int8_t type, old_state, new_state; enum ct_dccp_roles role; dh = skb_header_pointer(skb, dataoff, sizeof(_dh), &_dh); BUG_ON(dh == NULL); type = dh->dccph_type; if (type == DCCP_PKT_RESET && !test_bit(IPS_SEEN_REPLY_BIT, &ct->status)) { /* Tear down connection immediately if only reply is a RESET */ nf_ct_kill_acct(ct, ctinfo, skb); return NF_ACCEPT; } spin_lock_bh(&ct->lock); role = ct->proto.dccp.role[dir]; old_state = ct->proto.dccp.state; new_state = dccp_state_table[role][type][old_state]; switch (new_state) { case CT_DCCP_REQUEST: if (old_state == CT_DCCP_TIMEWAIT && role == CT_DCCP_ROLE_SERVER) { /* Reincarnation in the reverse direction: reopen and * reverse client/server roles. */ ct->proto.dccp.role[dir] = CT_DCCP_ROLE_CLIENT; ct->proto.dccp.role[!dir] = CT_DCCP_ROLE_SERVER; } break; case CT_DCCP_RESPOND: if (old_state == CT_DCCP_REQUEST) ct->proto.dccp.handshake_seq = dccp_hdr_seq(dh); break; case CT_DCCP_PARTOPEN: if (old_state == CT_DCCP_RESPOND && type == DCCP_PKT_ACK && dccp_ack_seq(dh) == ct->proto.dccp.handshake_seq) set_bit(IPS_ASSURED_BIT, &ct->status); break; case CT_DCCP_IGNORE: /* * Connection tracking might be out of sync, so we ignore * packets that might establish a new connection and resync * if the server responds with a valid Response. */ if (ct->proto.dccp.last_dir == !dir && ct->proto.dccp.last_pkt == DCCP_PKT_REQUEST && type == DCCP_PKT_RESPONSE) { ct->proto.dccp.role[!dir] = CT_DCCP_ROLE_CLIENT; ct->proto.dccp.role[dir] = CT_DCCP_ROLE_SERVER; ct->proto.dccp.handshake_seq = dccp_hdr_seq(dh); new_state = CT_DCCP_RESPOND; break; } ct->proto.dccp.last_dir = dir; ct->proto.dccp.last_pkt = type; spin_unlock_bh(&ct->lock); if (LOG_INVALID(net, IPPROTO_DCCP)) nf_log_packet(net, pf, 0, skb, NULL, NULL, NULL, "nf_ct_dccp: invalid packet ignored "); return NF_ACCEPT; case CT_DCCP_INVALID: spin_unlock_bh(&ct->lock); if (LOG_INVALID(net, IPPROTO_DCCP)) nf_log_packet(net, pf, 0, skb, NULL, NULL, NULL, "nf_ct_dccp: invalid state transition "); return -NF_ACCEPT; } ct->proto.dccp.last_dir = dir; ct->proto.dccp.last_pkt = type; ct->proto.dccp.state = new_state; spin_unlock_bh(&ct->lock); if (new_state != old_state) nf_conntrack_event_cache(IPCT_PROTOINFO, ct); nf_ct_refresh_acct(ct, ctinfo, skb, timeouts[new_state]); return NF_ACCEPT; }

Contributors

PersonTokensPropCommitsCommitProp
patrick mchardypatrick mchardy49491.82%222.22%
pablo neira ayusopablo neira ayuso193.53%222.22%
alexey dobriyanalexey dobriyan142.60%111.11%
fabian hugelshoferfabian hugelshofer50.93%111.11%
gao fenggao feng40.74%111.11%
daniel borkmanndaniel borkmann10.19%111.11%
jan engelhardtjan engelhardt10.19%111.11%
Total538100.00%9100.00%


static int dccp_error(struct net *net, struct nf_conn *tmpl, struct sk_buff *skb, unsigned int dataoff, enum ip_conntrack_info *ctinfo, u_int8_t pf, unsigned int hooknum) { struct dccp_hdr _dh, *dh; unsigned int dccp_len = skb->len - dataoff; unsigned int cscov; const char *msg; dh = skb_header_pointer(skb, dataoff, sizeof(_dh), &_dh); if (dh == NULL) { msg = "nf_ct_dccp: short packet "; goto out_invalid; } if (dh->dccph_doff * 4 < sizeof(struct dccp_hdr) || dh->dccph_doff * 4 > dccp_len) { msg = "nf_ct_dccp: truncated/malformed packet "; goto out_invalid; } cscov = dccp_len; if (dh->dccph_cscov) { cscov = (dh->dccph_cscov - 1) * 4; if (cscov > dccp_len) { msg = "nf_ct_dccp: bad checksum coverage "; goto out_invalid; } } if (net->ct.sysctl_checksum && hooknum == NF_INET_PRE_ROUTING && nf_checksum_partial(skb, hooknum, dataoff, cscov, IPPROTO_DCCP, pf)) { msg = "nf_ct_dccp: bad checksum "; goto out_invalid; } if (dh->dccph_type >= DCCP_PKT_INVALID) { msg = "nf_ct_dccp: reserved packet type "; goto out_invalid; } return NF_ACCEPT; out_invalid: if (LOG_INVALID(net, IPPROTO_DCCP)) nf_log_packet(net, pf, 0, skb, NULL, NULL, NULL, "%s", msg); return -NF_ACCEPT; }

Contributors

PersonTokensPropCommitsCommitProp
patrick mchardypatrick mchardy23993.00%222.22%
alexey dobriyanalexey dobriyan124.67%333.33%
daniel borkmanndaniel borkmann31.17%222.22%
gao fenggao feng20.78%111.11%
jan engelhardtjan engelhardt10.39%111.11%
Total257100.00%9100.00%


static void dccp_print_tuple(struct seq_file *s, const struct nf_conntrack_tuple *tuple) { seq_printf(s, "sport=%hu dport=%hu ", ntohs(tuple->src.u.dccp.port), ntohs(tuple->dst.u.dccp.port)); }

Contributors

PersonTokensPropCommitsCommitProp
patrick mchardypatrick mchardy4896.00%150.00%
joe perchesjoe perches24.00%150.00%
Total50100.00%2100.00%


static void dccp_print_conntrack(struct seq_file *s, struct nf_conn *ct) { seq_printf(s, "%s ", dccp_state_names[ct->proto.dccp.state]); }

Contributors

PersonTokensPropCommitsCommitProp
patrick mchardypatrick mchardy3294.12%150.00%
steven rostedtsteven rostedt25.88%150.00%
Total34100.00%2100.00%

#if IS_ENABLED(CONFIG_NF_CT_NETLINK)
static int dccp_to_nlattr(struct sk_buff *skb, struct nlattr *nla, struct nf_conn *ct) { struct nlattr *nest_parms; spin_lock_bh(&ct->lock); nest_parms = nla_nest_start(skb, CTA_PROTOINFO_DCCP | NLA_F_NESTED); if (!nest_parms) goto nla_put_failure; if (nla_put_u8(skb, CTA_PROTOINFO_DCCP_STATE, ct->proto.dccp.state) || nla_put_u8(skb, CTA_PROTOINFO_DCCP_ROLE, ct->proto.dccp.role[IP_CT_DIR_ORIGINAL]) || nla_put_be64(skb, CTA_PROTOINFO_DCCP_HANDSHAKE_SEQ, cpu_to_be64(ct->proto.dccp.handshake_seq), CTA_PROTOINFO_DCCP_PAD)) goto nla_put_failure; nla_nest_end(skb, nest_parms); spin_unlock_bh(&ct->lock); return 0; nla_put_failure: spin_unlock_bh(&ct->lock); return -1; }

Contributors

PersonTokensPropCommitsCommitProp
patrick mchardypatrick mchardy9868.53%233.33%
pablo neira ayusopablo neira ayuso3222.38%233.33%
david s. millerdavid s. miller117.69%116.67%
nicolas dichtelnicolas dichtel21.40%116.67%
Total143100.00%6100.00%

static const struct nla_policy dccp_nla_policy[CTA_PROTOINFO_DCCP_MAX + 1] = { [CTA_PROTOINFO_DCCP_STATE] = { .type = NLA_U8 }, [CTA_PROTOINFO_DCCP_ROLE] = { .type = NLA_U8 }, [CTA_PROTOINFO_DCCP_HANDSHAKE_SEQ] = { .type = NLA_U64 }, [CTA_PROTOINFO_DCCP_PAD] = { .type = NLA_UNSPEC }, };
static int nlattr_to_dccp(struct nlattr *cda[], struct nf_conn *ct) { struct nlattr *attr = cda[CTA_PROTOINFO_DCCP]; struct nlattr *tb[CTA_PROTOINFO_DCCP_MAX + 1]; int err; if (!attr) return 0; err = nla_parse_nested(tb, CTA_PROTOINFO_DCCP_MAX, attr, dccp_nla_policy); if (err < 0) return err; if (!tb[CTA_PROTOINFO_DCCP_STATE] || !tb[CTA_PROTOINFO_DCCP_ROLE] || nla_get_u8(tb[CTA_PROTOINFO_DCCP_ROLE]) > CT_DCCP_ROLE_MAX || nla_get_u8(tb[CTA_PROTOINFO_DCCP_STATE]) >= CT_DCCP_IGNORE) { return -EINVAL; } spin_lock_bh(&ct->lock); ct->proto.dccp.state = nla_get_u8(tb[CTA_PROTOINFO_DCCP_STATE]); if (nla_get_u8(tb[CTA_PROTOINFO_DCCP_ROLE]) == CT_DCCP_ROLE_CLIENT) { ct->proto.dccp.role[IP_CT_DIR_ORIGINAL] = CT_DCCP_ROLE_CLIENT; ct->proto.dccp.role[IP_CT_DIR_REPLY] = CT_DCCP_ROLE_SERVER; } else { ct->proto.dccp.role[IP_CT_DIR_ORIGINAL] = CT_DCCP_ROLE_SERVER; ct->proto.dccp.role[IP_CT_DIR_REPLY] = CT_DCCP_ROLE_CLIENT; } if (tb[CTA_PROTOINFO_DCCP_HANDSHAKE_SEQ]) { ct->proto.dccp.handshake_seq = be64_to_cpu(nla_get_be64(tb[CTA_PROTOINFO_DCCP_HANDSHAKE_SEQ])); } spin_unlock_bh(&ct->lock); return 0; }

Contributors

PersonTokensPropCommitsCommitProp
patrick mchardypatrick mchardy12752.48%250.00%
pablo neira ayusopablo neira ayuso11547.52%250.00%
Total242100.00%4100.00%


static int dccp_nlattr_size(void) { return nla_total_size(0) /* CTA_PROTOINFO_DCCP */ + nla_policy_len(dccp_nla_policy, CTA_PROTOINFO_DCCP_MAX + 1); }

Contributors

PersonTokensPropCommitsCommitProp
holger eitzenbergerholger eitzenberger24100.00%1100.00%
Total24100.00%1100.00%

#endif #if IS_ENABLED(CONFIG_NF_CT_NETLINK_TIMEOUT) #include <linux/netfilter/nfnetlink.h> #include <linux/netfilter/nfnetlink_cttimeout.h>
static int dccp_timeout_nlattr_to_obj(struct nlattr *tb[], struct net *net, void *data) { struct dccp_net *dn = dccp_pernet(net); unsigned int *timeouts = data; int i; /* set default DCCP timeouts. */ for (i=0; i<CT_DCCP_MAX; i++) timeouts[i] = dn->dccp_timeout[i]; /* there's a 1:1 mapping between attributes and protocol states. */ for (i=CTA_TIMEOUT_DCCP_UNSPEC+1; i<CTA_TIMEOUT_DCCP_MAX+1; i++) { if (tb[i]) { timeouts[i] = ntohl(nla_get_be32(tb[i])) * HZ; } } return 0; }

Contributors

PersonTokensPropCommitsCommitProp
pablo neira ayusopablo neira ayuso11194.87%150.00%
gao fenggao feng65.13%150.00%
Total117100.00%2100.00%


static int dccp_timeout_obj_to_nlattr(struct sk_buff *skb, const void *data) { const unsigned int *timeouts = data; int i; for (i=CTA_TIMEOUT_DCCP_UNSPEC+1; i<CTA_TIMEOUT_DCCP_MAX+1; i++) { if (nla_put_be32(skb, i, htonl(timeouts[i] / HZ))) goto nla_put_failure; } return 0; nla_put_failure: return -ENOSPC; }

Contributors

PersonTokensPropCommitsCommitProp
pablo neira ayusopablo neira ayuso6888.31%150.00%
david s. millerdavid s. miller911.69%150.00%
Total77100.00%2100.00%

static const struct nla_policy dccp_timeout_nla_policy[CTA_TIMEOUT_DCCP_MAX+1] = { [CTA_TIMEOUT_DCCP_REQUEST] = { .type = NLA_U32 }, [CTA_TIMEOUT_DCCP_RESPOND] = { .type = NLA_U32 }, [CTA_TIMEOUT_DCCP_PARTOPEN] = { .type = NLA_U32 }, [CTA_TIMEOUT_DCCP_OPEN] = { .type = NLA_U32 }, [CTA_TIMEOUT_DCCP_CLOSEREQ] = { .