aboutsummaryrefslogtreecommitdiffstats
path: root/net/iucv
diff options
context:
space:
mode:
Diffstat (limited to 'net/iucv')
-rw-r--r--net/iucv/af_iucv.c21
1 files changed, 14 insertions, 7 deletions
diff --git a/net/iucv/af_iucv.c b/net/iucv/af_iucv.c
index b3f5f840d067..fee22caf1bad 100644
--- a/net/iucv/af_iucv.c
+++ b/net/iucv/af_iucv.c
@@ -1112,24 +1112,31 @@ static void iucv_callback_txdone(struct iucv_path *path,
1112 struct iucv_message *msg) 1112 struct iucv_message *msg)
1113{ 1113{
1114 struct sock *sk = path->private; 1114 struct sock *sk = path->private;
1115 struct sk_buff *this; 1115 struct sk_buff *this = NULL;
1116 struct sk_buff_head *list = &iucv_sk(sk)->send_skb_q; 1116 struct sk_buff_head *list = &iucv_sk(sk)->send_skb_q;
1117 struct sk_buff *list_skb = list->next; 1117 struct sk_buff *list_skb = list->next;
1118 unsigned long flags; 1118 unsigned long flags;
1119 1119
1120 if (list_skb) { 1120 if (!skb_queue_empty(list)) {
1121 spin_lock_irqsave(&list->lock, flags); 1121 spin_lock_irqsave(&list->lock, flags);
1122 1122
1123 do { 1123 while (list_skb != (struct sk_buff *)list) {
1124 this = list_skb; 1124 if (!memcmp(&msg->tag, list_skb->cb, 4)) {
1125 this = list_skb;
1126 break;
1127 }
1125 list_skb = list_skb->next; 1128 list_skb = list_skb->next;
1126 } while (memcmp(&msg->tag, this->cb, 4) && list_skb); 1129 }
1127 __skb_unlink(this, list); 1130 if (this)
1131 __skb_unlink(this, list);
1128 1132
1129 spin_unlock_irqrestore(&list->lock, flags); 1133 spin_unlock_irqrestore(&list->lock, flags);
1130 1134
1131 kfree_skb(this); 1135 if (this)
1136 kfree_skb(this);
1132 } 1137 }
1138 if (!this)
1139 printk(KERN_ERR "AF_IUCV msg tag %u not found\n", msg->tag);
1133 1140
1134 if (sk->sk_state == IUCV_CLOSING) { 1141 if (sk->sk_state == IUCV_CLOSING) {
1135 if (skb_queue_empty(&iucv_sk(sk)->send_skb_q)) { 1142 if (skb_queue_empty(&iucv_sk(sk)->send_skb_q)) {