Skip to content

Commit

Permalink
sctp: create udp4 sock and add its encap_rcv
Browse files Browse the repository at this point in the history
This patch is to add the functions to create/release udp4 sock,
and set the sock's encap_rcv to process the incoming udp encap
sctp packets. In sctp_udp_rcv(), as we can see, all we need to
do is fix the transport header for sctp_rcv(), then it would
implement the part of rfc6951#section-5.4:

  "When an encapsulated packet is received, the UDP header is removed.
   Then, the generic lookup is performed, as done by an SCTP stack
   whenever a packet is received, to find the association for the
   received SCTP packet"

Note that these functions will be called in the last patch of
this patchset when enabling this feature.

v1->v2:
  - Add pr_err() when fails to create udp v4 sock.
v2->v3:
  - Add 'select NET_UDP_TUNNEL' in sctp Kconfig.
v3->v4:
  - No change.
v4->v5:
  - Change to set udp_port to 0 by default.

Signed-off-by: Xin Long <lucien.xin@gmail.com>
Acked-by: Marcelo Ricardo Leitner <marcelo.leitner@gmail.com>
Signed-off-by: Jakub Kicinski <kuba@kernel.org>
  • Loading branch information
Xin Long authored and Jakub Kicinski committed Oct 30, 2020
1 parent 527beb8 commit 965ae44
Show file tree
Hide file tree
Showing 5 changed files with 53 additions and 0 deletions.
5 changes: 5 additions & 0 deletions include/net/netns/sctp.h
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,11 @@ struct netns_sctp {
*/
struct sock *ctl_sock;

/* UDP tunneling listening sock. */
struct sock *udp4_sock;
/* UDP tunneling listening port. */
int udp_port;

/* This is the global local address list.
* We actively maintain this complete list of addresses on
* the system by catching address add/delete events.
Expand Down
2 changes: 2 additions & 0 deletions include/net/sctp/constants.h
Original file line number Diff line number Diff line change
Expand Up @@ -286,6 +286,8 @@ enum { SCTP_MAX_GABS = 16 };
* functions simpler to write.
*/

#define SCTP_DEFAULT_UDP_PORT 9899 /* default UDP tunneling port */

/* These are the values for pf exposure, UNUSED is to keep compatible with old
* applications by default.
*/
Expand Down
2 changes: 2 additions & 0 deletions include/net/sctp/sctp.h
Original file line number Diff line number Diff line change
Expand Up @@ -84,6 +84,8 @@ int sctp_copy_local_addr_list(struct net *net, struct sctp_bind_addr *addr,
struct sctp_pf *sctp_get_pf_specific(sa_family_t family);
int sctp_register_pf(struct sctp_pf *, sa_family_t);
void sctp_addr_wq_mgmt(struct net *, struct sctp_sockaddr_entry *, int);
int sctp_udp_sock_start(struct net *net);
void sctp_udp_sock_stop(struct net *net);

/*
* sctp/socket.c
Expand Down
1 change: 1 addition & 0 deletions net/sctp/Kconfig
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ menuconfig IP_SCTP
select CRYPTO_HMAC
select CRYPTO_SHA1
select LIBCRC32C
select NET_UDP_TUNNEL
help
Stream Control Transmission Protocol

Expand Down
43 changes: 43 additions & 0 deletions net/sctp/protocol.c
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,7 @@
#include <net/addrconf.h>
#include <net/inet_common.h>
#include <net/inet_ecn.h>
#include <net/udp_tunnel.h>

#define MAX_SCTP_PORT_HASH_ENTRIES (64 * 1024)

Expand Down Expand Up @@ -840,6 +841,45 @@ static int sctp_ctl_sock_init(struct net *net)
return 0;
}

static int sctp_udp_rcv(struct sock *sk, struct sk_buff *skb)
{
skb_set_transport_header(skb, sizeof(struct udphdr));
sctp_rcv(skb);
return 0;
}

int sctp_udp_sock_start(struct net *net)
{
struct udp_tunnel_sock_cfg tuncfg = {NULL};
struct udp_port_cfg udp_conf = {0};
struct socket *sock;
int err;

udp_conf.family = AF_INET;
udp_conf.local_ip.s_addr = htonl(INADDR_ANY);
udp_conf.local_udp_port = htons(net->sctp.udp_port);
err = udp_sock_create(net, &udp_conf, &sock);
if (err) {
pr_err("Failed to create the SCTP UDP tunneling v4 sock\n");
return err;
}

tuncfg.encap_type = 1;
tuncfg.encap_rcv = sctp_udp_rcv;
setup_udp_tunnel_sock(net, sock, &tuncfg);
net->sctp.udp4_sock = sock->sk;

return 0;
}

void sctp_udp_sock_stop(struct net *net)
{
if (net->sctp.udp4_sock) {
udp_tunnel_sock_release(net->sctp.udp4_sock->sk_socket);
net->sctp.udp4_sock = NULL;
}
}

/* Register address family specific functions. */
int sctp_register_af(struct sctp_af *af)
{
Expand Down Expand Up @@ -1271,6 +1311,9 @@ static int __net_init sctp_defaults_init(struct net *net)
/* Enable ECN by default. */
net->sctp.ecn_enable = 1;

/* Set UDP tunneling listening port to 0 by default */
net->sctp.udp_port = 0;

/* Set SCOPE policy to enabled */
net->sctp.scope_policy = SCTP_SCOPE_POLICY_ENABLE;

Expand Down

0 comments on commit 965ae44

Please sign in to comment.