diff mbox

RDMA/ipoib: drop skb on path record lookup failure

Message ID 20180522140047.25524-1-evgenii.smirnov@profitbricks.com (mailing list archive)
State Superseded
Headers show

Commit Message

Evgenii Smirnov May 22, 2018, 2 p.m. UTC
In unicast_arp_send function there is an inconsistency in error handling
of path_rec_start call. If path_rec_start is called because of an absent
ah field, skb will be dropped. But if it is called on a creation of a new path,
or if the path is invalid, skb will be added to the tail of path queue.
In case of a new path it will be dropped on path_free, but in case
of invalid path it can stay in the queue forever.

This patch unifies the behavior, dropping skb in all cases
of path_rec_start failure.

Signed-off-by: Evgenii Smirnov <evgenii.smirnov@profitbricks.com>
---
 drivers/infiniband/ulp/ipoib/ipoib_main.c | 55 +++++++++--------------
 1 file changed, 21 insertions(+), 34 deletions(-)
diff mbox

Patch

diff --git a/drivers/infiniband/ulp/ipoib/ipoib_main.c b/drivers/infiniband/ulp/ipoib/ipoib_main.c
index cf291f90b58f..79e00db50bdf 100644
--- a/drivers/infiniband/ulp/ipoib/ipoib_main.c
+++ b/drivers/infiniband/ulp/ipoib/ipoib_main.c
@@ -1039,53 +1039,40 @@  static void unicast_arp_send(struct sk_buff *skb, struct net_device *dev,
 
 		if (!path) {
 			path = path_rec_create(dev, phdr->hwaddr + 4);
+			if (!path)
+				goto drop_and_unlock;
 			new_path = 1;
+		} else {
+			/* make sure there is no changes in the existing path record */
+			init_path_rec(priv, path, phdr->hwaddr + 4);
 		}
-		if (path) {
-			if (!new_path)
-				/* make sure there is no changes in the existing path record */
-				init_path_rec(priv, path, phdr->hwaddr + 4);
-
-			if (skb_queue_len(&path->queue) < IPOIB_MAX_PATH_REC_QUEUE) {
-				push_pseudo_header(skb, phdr->hwaddr);
-				__skb_queue_tail(&path->queue, skb);
-			} else {
-				++dev->stats.tx_dropped;
-				dev_kfree_skb_any(skb);
-			}
 
-			if (!path->query && path_rec_start(dev, path)) {
-				spin_unlock_irqrestore(&priv->lock, flags);
-				if (new_path)
-					path_free(dev, path);
-				return;
-			} else
-				__path_add(dev, path);
-		} else {
+		if (!path->query && path_rec_start(dev, path)) {
+			if (new_path)
+				path_free(dev, path);
 			goto drop_and_unlock;
 		}
 
-		spin_unlock_irqrestore(&priv->lock, flags);
-		return;
-	}
+		if (new_path)
+			__path_add(dev, path);
 
-	if (path->ah) {
-		ipoib_dbg(priv, "Send unicast ARP to %08x\n",
-			  be32_to_cpu(sa_path_get_dlid(&path->pathrec)));
+		if (skb_queue_len(&path->queue) < IPOIB_MAX_PATH_REC_QUEUE) {
+			push_pseudo_header(skb, phdr->hwaddr);
+			__skb_queue_tail(&path->queue, skb);
+		} else {
+			goto drop_and_unlock;
+		}
 
 		spin_unlock_irqrestore(&priv->lock, flags);
-		path->ah->last_send = rn->send(dev, skb, path->ah->ah,
-					       IPOIB_QPN(phdr->hwaddr));
 		return;
-	} else if ((path->query || !path_rec_start(dev, path)) &&
-		   skb_queue_len(&path->queue) < IPOIB_MAX_PATH_REC_QUEUE) {
-		push_pseudo_header(skb, phdr->hwaddr);
-		__skb_queue_tail(&path->queue, skb);
-	} else {
-		goto drop_and_unlock;
 	}
 
+	ipoib_dbg(priv, "Send unicast ARP to %08x\n",
+		  be32_to_cpu(sa_path_get_dlid(&path->pathrec)));
+
 	spin_unlock_irqrestore(&priv->lock, flags);
+	path->ah->last_send = rn->send(dev, skb, path->ah->ah,
+				       IPOIB_QPN(phdr->hwaddr));
 	return;
 
 drop_and_unlock: