瀏覽代碼

tipc: Fix sk_buff leaks when link congestion is detected

Modifies a TIPC send routine that did not discard the outgoing sk_buff
if it was not transmitted because of link congestion; this eliminates
the potential for buffer leakage in the many callers who did not clean up
the unsent buffer. (The two routines that previously did discard the unsent
buffer have been updated to eliminate their now-redundant clean up.)

Signed-off-by: Allan Stephens <allan.stephens@windriver.com>
Signed-off-by: Paul Gortmaker <paul.gortmaker@windriver.com>
Allan Stephens 14 年之前
父節點
當前提交
bebc55aeff
共有 2 個文件被更改,包括 4 次插入7 次删除
  1. 1 3
      net/tipc/bcast.c
  2. 3 4
      net/tipc/link.c

+ 1 - 3
net/tipc/bcast.c

@@ -407,9 +407,7 @@ int tipc_bclink_send_msg(struct sk_buff *buf)
 	spin_lock_bh(&bc_lock);
 	spin_lock_bh(&bc_lock);
 
 
 	res = tipc_link_send_buf(bcl, buf);
 	res = tipc_link_send_buf(bcl, buf);
-	if (unlikely(res == -ELINKCONG))
-		buf_discard(buf);
-	else
+	if (likely(res > 0))
 		bclink_set_last_sent();
 		bclink_set_last_sent();
 
 
 	bcl->stats.queue_sz_counts++;
 	bcl->stats.queue_sz_counts++;

+ 3 - 4
net/tipc/link.c

@@ -864,8 +864,9 @@ int tipc_link_send_buf(struct link *l_ptr, struct sk_buff *buf)
 
 
 	if (unlikely(queue_size >= queue_limit)) {
 	if (unlikely(queue_size >= queue_limit)) {
 		if (imp <= TIPC_CRITICAL_IMPORTANCE) {
 		if (imp <= TIPC_CRITICAL_IMPORTANCE) {
-			return link_schedule_port(l_ptr, msg_origport(msg),
-						  size);
+			link_schedule_port(l_ptr, msg_origport(msg), size);
+			buf_discard(buf);
+			return -ELINKCONG;
 		}
 		}
 		buf_discard(buf);
 		buf_discard(buf);
 		if (imp > CONN_MANAGER) {
 		if (imp > CONN_MANAGER) {
@@ -1069,8 +1070,6 @@ again:
 			if (likely(buf)) {
 			if (likely(buf)) {
 				res = link_send_buf_fast(l_ptr, buf,
 				res = link_send_buf_fast(l_ptr, buf,
 							 &sender->max_pkt);
 							 &sender->max_pkt);
-				if (unlikely(res < 0))
-					buf_discard(buf);
 exit:
 exit:
 				tipc_node_unlock(node);
 				tipc_node_unlock(node);
 				read_unlock_bh(&tipc_net_lock);
 				read_unlock_bh(&tipc_net_lock);