goto out;
}
-static struct sk_buff *skb_set_peeked(struct sk_buff *skb)
-{
- struct sk_buff *nskb;
-
- if (skb->peeked)
- return skb;
-
- /* We have to unshare an skb before modifying it. */
- if (!skb_shared(skb))
- goto done;
-
- nskb = skb_clone(skb, GFP_ATOMIC);
- if (!nskb)
- return ERR_PTR(-ENOMEM);
-
- skb->prev->next = nskb;
- skb->next->prev = nskb;
- nskb->prev = skb->prev;
- nskb->next = skb->next;
-
- consume_skb(skb);
- skb = nskb;
-
-done:
- skb->peeked = 1;
-
- return skb;
-}
-
/**
* __skb_recv_datagram - Receive a datagram skbuff
* @sk: socket
struct sk_buff *__skb_recv_datagram(struct sock *sk, unsigned int flags,
int *peeked, int *off, int *err)
{
- struct sk_buff_head *queue = &sk->sk_receive_queue;
struct sk_buff *skb, *last;
- unsigned long cpu_flags;
long timeo;
/*
* Caller is allowed not to check sk->sk_err before skb_recv_datagram()
* Look at current nfs client by the way...
* However, this function was correct in any case. 8)
*/
+ unsigned long cpu_flags;
+ struct sk_buff_head *queue = &sk->sk_receive_queue;
int _off = *off;
last = (struct sk_buff *)queue;
_off -= skb->len;
continue;
}
-
- skb = skb_set_peeked(skb);
- error = PTR_ERR(skb);
- if (IS_ERR(skb))
- goto unlock_err;
-
+ skb->peeked = 1;
atomic_inc(&skb->users);
} else
__skb_unlink(skb, queue);
return NULL;
-unlock_err:
- spin_unlock_irqrestore(&queue->lock, cpu_flags);
no_packet:
*err = error;
return NULL;
if (likely(!sum)) {
if (unlikely(skb->ip_summed == CHECKSUM_COMPLETE))
netdev_rx_csum_fault(skb->dev);
- if (!skb_shared(skb))
- skb->ip_summed = CHECKSUM_UNNECESSARY;
+ skb->ip_summed = CHECKSUM_UNNECESSARY;
}
return sum;
}