lists.openwall.net   lists  /  announce  owl-users  owl-dev  john-users  john-dev  passwdqc-users  yescrypt  popa3d-users  /  oss-security  kernel-hardening  musl  sabotage  tlsify  passwords  /  crypt-dev  xvendor  /  Bugtraq  Full-Disclosure  linux-kernel  linux-netdev  linux-ext4  linux-hardening  linux-cve-announce  PHC 
Open Source and information security mailing list archives
 
Hash Suite: Windows password security audit tool. GUI, reports in PDF.
[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-ID: <52E9127F.9000908@pengutronix.de>
Date:	Wed, 29 Jan 2014 15:38:55 +0100
From:	Marc Kleine-Budde <mkl@...gutronix.de>
To:	Oliver Hartkopp <socketcan@...tkopp.net>,
	Eric Dumazet <eric.dumazet@...il.com>,
	David Miller <davem@...emloft.net>
CC:	Linux Netdev List <netdev@...r.kernel.org>,
	Andre Naujoks <nautsch2@...il.com>,
	"linux-can@...r.kernel.org" <linux-can@...r.kernel.org>
Subject: Re: [PATCH stable 3.11+] can: use private sk reference to detect
 originating socket

Please put linux-can on Cc for CAN related patches.

Marc

On 01/29/2014 02:44 PM, Oliver Hartkopp wrote:
> Commit 376c7311bdb6 (net: add a temporary sanity check in skb_orphan())
> leads to a BUG in can_put_echo_skb() when skb_orphan() is executed.
> 
> The use of skb->sk to detect the originating socket can lead to side effects
> in net/core and net/sched. Therefore the reference needed in net/can/raw.c is
> now stored in a CAN private skbuff space in struct can_skb_priv.
> 
> The reference which comes with the CAN frame is only needed in raw_rcv() and
> checked against his own sock pointer and does only special things if it
> matches. So removing the socket does not hurt as the in-flight skbs are
> removed and the receive filters are purged anyway when the socket disappears.
> 
> Signed-off-by: Oliver Hartkopp <socketcan@...tkopp.net>
> 
> ---
> 
> Here's my idea to fix up the original skb->sk handling concept for detecting
> the originating socket instance. The patch applies properly down to 3.11.
> 
> Eric please take a look if I used sock_alloc_send_skb() correctly in bcm.c.
> Andre please check if you see any functional differences on your machine.
> 
> Tnx & regards,
> Oliver
> 
> ps. I would suggest to move the BUG() in WARN_ON_ONCE() to fulfill the
> requirement to detect a possible misuse but not kill the entire machine.
> BUG() is intended to be used when there's no way to continue any reasonable
> operation. Detecting and fixing this issue half a year after the "temporary
> sanity check" has been integrated is a bad example for using BUG() IMO.
> 
> diff --git a/drivers/net/can/dev.c b/drivers/net/can/dev.c
> index 13a9098..6d51fb7 100644
> --- a/drivers/net/can/dev.c
> +++ b/drivers/net/can/dev.c
> @@ -323,7 +323,6 @@ void can_put_echo_skb(struct sk_buff *skb, struct net_device *dev,
>  	}
>  
>  	if (!priv->echo_skb[idx]) {
> -		struct sock *srcsk = skb->sk;
>  
>  		if (atomic_read(&skb->users) != 1) {
>  			struct sk_buff *old_skb = skb;
> @@ -335,8 +334,6 @@ void can_put_echo_skb(struct sk_buff *skb, struct net_device *dev,
>  		} else
>  			skb_orphan(skb);
>  
> -		skb->sk = srcsk;
> -
>  		/* make settings for echo to reduce code in irq context */
>  		skb->protocol = htons(ETH_P_CAN);
>  		skb->pkt_type = PACKET_BROADCAST;
> @@ -513,6 +510,7 @@ struct sk_buff *alloc_can_skb(struct net_device *dev, struct can_frame **cf)
>  
>  	can_skb_reserve(skb);
>  	can_skb_prv(skb)->ifindex = dev->ifindex;
> +	can_skb_prv(skb)->src_sk = NULL;
>  
>  	*cf = (struct can_frame *)skb_put(skb, sizeof(struct can_frame));
>  	memset(*cf, 0, sizeof(struct can_frame));
> diff --git a/drivers/net/can/janz-ican3.c b/drivers/net/can/janz-ican3.c
> index e24e669..d27a1c9 100644
> --- a/drivers/net/can/janz-ican3.c
> +++ b/drivers/net/can/janz-ican3.c
> @@ -1133,8 +1133,6 @@ static void ican3_handle_message(struct ican3_dev *mod, struct ican3_msg *msg)
>   */
>  static void ican3_put_echo_skb(struct ican3_dev *mod, struct sk_buff *skb)
>  {
> -	struct sock *srcsk = skb->sk;
> -
>  	if (atomic_read(&skb->users) != 1) {
>  		struct sk_buff *old_skb = skb;
>  
> @@ -1142,11 +1140,8 @@ static void ican3_put_echo_skb(struct ican3_dev *mod, struct sk_buff *skb)
>  		kfree_skb(old_skb);
>  		if (!skb)
>  			return;
> -	} else {
> +	} else
>  		skb_orphan(skb);
> -	}
> -
> -	skb->sk = srcsk;
>  
>  	/* save this skb for tx interrupt echo handling */
>  	skb_queue_tail(&mod->echoq, skb);
> diff --git a/drivers/net/can/slcan.c b/drivers/net/can/slcan.c
> index 3fcdae2..44766c18 100644
> --- a/drivers/net/can/slcan.c
> +++ b/drivers/net/can/slcan.c
> @@ -215,6 +215,7 @@ static void slc_bump(struct slcan *sl)
>  
>  	can_skb_reserve(skb);
>  	can_skb_prv(skb)->ifindex = sl->dev->ifindex;
> +	can_skb_prv(skb)->src_sk = NULL;
>  
>  	memcpy(skb_put(skb, sizeof(struct can_frame)),
>  	       &cf, sizeof(struct can_frame));
> diff --git a/drivers/net/can/vcan.c b/drivers/net/can/vcan.c
> index 0a2a5ee..1a89116 100644
> --- a/drivers/net/can/vcan.c
> +++ b/drivers/net/can/vcan.c
> @@ -116,14 +116,11 @@ static netdev_tx_t vcan_tx(struct sk_buff *skb, struct net_device *dev)
>  	/* perform standard echo handling for CAN network interfaces */
>  
>  	if (loop) {
> -		struct sock *srcsk = skb->sk;
> -
>  		skb = skb_share_check(skb, GFP_ATOMIC);
>  		if (!skb)
>  			return NETDEV_TX_OK;
>  
>  		/* receive with packet counting */
> -		skb->sk = srcsk;
>  		vcan_rx(skb, dev);
>  	} else {
>  		/* no looped packets => no counting */
> diff --git a/include/linux/can/skb.h b/include/linux/can/skb.h
> index 2f0543f..a8dc078 100644
> --- a/include/linux/can/skb.h
> +++ b/include/linux/can/skb.h
> @@ -25,10 +25,12 @@
>  /**
>   * struct can_skb_priv - private additional data inside CAN sk_buffs
>   * @ifindex:	ifindex of the first interface the CAN frame appeared on
> + * @src_sk:	pointer to the originating sock to detect self generated skbs
>   * @cf:		align to the following CAN frame at skb->data
>   */
>  struct can_skb_priv {
>  	int ifindex;
> +	struct sock *src_sk;
>  	struct can_frame cf[0];
>  };
>  
> diff --git a/net/can/af_can.c b/net/can/af_can.c
> index d249874..6ed6a23 100644
> --- a/net/can/af_can.c
> +++ b/net/can/af_can.c
> @@ -270,15 +270,6 @@ int can_send(struct sk_buff *skb, int loop)
>  		/* indication for the CAN driver: do loopback */
>  		skb->pkt_type = PACKET_LOOPBACK;
>  
> -		/*
> -		 * The reference to the originating sock may be required
> -		 * by the receiving socket to check whether the frame is
> -		 * its own. Example: can_raw sockopt CAN_RAW_RECV_OWN_MSGS
> -		 * Therefore we have to ensure that skb->sk remains the
> -		 * reference to the originating sock by restoring skb->sk
> -		 * after each skb_clone() or skb_orphan() usage.
> -		 */
> -
>  		if (!(skb->dev->flags & IFF_ECHO)) {
>  			/*
>  			 * If the interface is not capable to do loopback
> @@ -290,7 +281,6 @@ int can_send(struct sk_buff *skb, int loop)
>  				return -ENOMEM;
>  			}
>  
> -			newskb->sk = skb->sk;
>  			newskb->ip_summed = CHECKSUM_UNNECESSARY;
>  			newskb->pkt_type = PACKET_BROADCAST;
>  		}
> diff --git a/net/can/bcm.c b/net/can/bcm.c
> index 3fc737b..f10f521 100644
> --- a/net/can/bcm.c
> +++ b/net/can/bcm.c
> @@ -245,7 +245,9 @@ static void bcm_can_tx(struct bcm_op *op)
>  {
>  	struct sk_buff *skb;
>  	struct net_device *dev;
> +	struct sock *sk = op->sk;
>  	struct can_frame *cf = &op->frames[op->currframe];
> +	int err;
>  
>  	/* no target device? => exit */
>  	if (!op->ifindex)
> @@ -257,18 +259,23 @@ static void bcm_can_tx(struct bcm_op *op)
>  		return;
>  	}
>  
> -	skb = alloc_skb(CFSIZ + sizeof(struct can_skb_priv), gfp_any());
> +	/*
> +	 * we are probably in softirq context (timer, net-rx):
> +	 * get an unblocked skb
> +	 */
> +	sk->sk_allocation = GFP_ATOMIC;
> +	skb = sock_alloc_send_skb(sk, CFSIZ + sizeof(struct can_skb_priv),
> +				  1, &err);
>  	if (!skb)
>  		goto out;
>  
>  	can_skb_reserve(skb);
> -	can_skb_prv(skb)->ifindex = dev->ifindex;
> -
>  	memcpy(skb_put(skb, CFSIZ), cf, CFSIZ);
>  
>  	/* send with loopback */
> +	can_skb_prv(skb)->ifindex = dev->ifindex;
> +	can_skb_prv(skb)->src_sk = sk;
>  	skb->dev = dev;
> -	skb->sk = op->sk;
>  	can_send(skb, 1);
>  
>  	/* update statistics */
> @@ -1203,12 +1210,13 @@ static int bcm_tx_send(struct msghdr *msg, int ifindex, struct sock *sk)
>  	if (!ifindex)
>  		return -ENODEV;
>  
> -	skb = alloc_skb(CFSIZ + sizeof(struct can_skb_priv), GFP_KERNEL);
> +	/* get an unblocked skb */
> +	skb = sock_alloc_send_skb(sk, CFSIZ + sizeof(struct can_skb_priv),
> +				  1, &err);
>  	if (!skb)
>  		return -ENOMEM;
>  
>  	can_skb_reserve(skb);
> -
>  	err = memcpy_fromiovec(skb_put(skb, CFSIZ), msg->msg_iov, CFSIZ);
>  	if (err < 0) {
>  		kfree_skb(skb);
> @@ -1221,10 +1229,11 @@ static int bcm_tx_send(struct msghdr *msg, int ifindex, struct sock *sk)
>  		return -ENODEV;
>  	}
>  
> -	can_skb_prv(skb)->ifindex = dev->ifindex;
> +	/* send with loopback */
> +	can_skb_prv(skb)->ifindex = ifindex;
> +	can_skb_prv(skb)->src_sk = sk;
>  	skb->dev = dev;
> -	skb->sk  = sk;
> -	err = can_send(skb, 1); /* send with loopback */
> +	err = can_send(skb, 1);
>  	dev_put(dev);
>  
>  	if (err)
> diff --git a/net/can/raw.c b/net/can/raw.c
> index 07d72d8..7e67560 100644
> --- a/net/can/raw.c
> +++ b/net/can/raw.c
> @@ -113,12 +113,13 @@ static void raw_rcv(struct sk_buff *oskb, void *data)
>  {
>  	struct sock *sk = (struct sock *)data;
>  	struct raw_sock *ro = raw_sk(sk);
> +	struct sock *src_sk = can_skb_prv(oskb)->src_sk;
>  	struct sockaddr_can *addr;
>  	struct sk_buff *skb;
>  	unsigned int *pflags;
>  
>  	/* check the received tx sock reference */
> -	if (!ro->recv_own_msgs && oskb->sk == sk)
> +	if (!ro->recv_own_msgs && src_sk == sk)
>  		return;
>  
>  	/* do not pass frames with DLC > 8 to a legacy socket */
> @@ -150,9 +151,9 @@ static void raw_rcv(struct sk_buff *oskb, void *data)
>  	/* add CAN specific message flags for raw_recvmsg() */
>  	pflags = raw_flags(skb);
>  	*pflags = 0;
> -	if (oskb->sk)
> +	if (src_sk)
>  		*pflags |= MSG_DONTROUTE;
> -	if (oskb->sk == sk)
> +	if (src_sk == sk)
>  		*pflags |= MSG_CONFIRM;
>  
>  	if (sock_queue_rcv_skb(sk, skb) < 0)
> @@ -705,17 +706,15 @@ static int raw_sendmsg(struct kiocb *iocb, struct socket *sock,
>  		goto put_dev;
>  
>  	can_skb_reserve(skb);
> -	can_skb_prv(skb)->ifindex = dev->ifindex;
> -
>  	err = memcpy_fromiovec(skb_put(skb, size), msg->msg_iov, size);
>  	if (err < 0)
>  		goto free_skb;
>  
>  	sock_tx_timestamp(sk, &skb_shinfo(skb)->tx_flags);
>  
> +	can_skb_prv(skb)->ifindex = dev->ifindex;
> +	can_skb_prv(skb)->src_sk = sk;
>  	skb->dev = dev;
> -	skb->sk  = sk;
> -
>  	err = can_send(skb, ro->loopback);
>  
>  	dev_put(dev);
> 
> 
> --
> To unsubscribe from this list: send the line "unsubscribe netdev" in
> the body of a message to majordomo@...r.kernel.org
> More majordomo info at  http://vger.kernel.org/majordomo-info.html
> 


-- 
Pengutronix e.K.                  | Marc Kleine-Budde           |
Industrial Linux Solutions        | Phone: +49-231-2826-924     |
Vertretung West/Dortmund          | Fax:   +49-5121-206917-5555 |
Amtsgericht Hildesheim, HRA 2686  | http://www.pengutronix.de   |


Download attachment "signature.asc" of type "application/pgp-signature" (243 bytes)

Powered by blists - more mailing lists

Powered by Openwall GNU/*/Linux Powered by OpenVZ