|
@@ -1470,10 +1470,15 @@ static int netlink_rcv_skb(struct sk_buff *skb, int (*cb)(struct sk_buff *,
|
|
|
|
|
|
while (skb->len >= nlmsg_total_size(0)) {
|
|
while (skb->len >= nlmsg_total_size(0)) {
|
|
nlh = nlmsg_hdr(skb);
|
|
nlh = nlmsg_hdr(skb);
|
|
|
|
+ err = 0;
|
|
|
|
|
|
if (nlh->nlmsg_len < NLMSG_HDRLEN || skb->len < nlh->nlmsg_len)
|
|
if (nlh->nlmsg_len < NLMSG_HDRLEN || skb->len < nlh->nlmsg_len)
|
|
return 0;
|
|
return 0;
|
|
|
|
|
|
|
|
+ /* Only requests are handled by the kernel */
|
|
|
|
+ if (!(nlh->nlmsg_flags & NLM_F_REQUEST))
|
|
|
|
+ goto skip;
|
|
|
|
+
|
|
if (cb(skb, nlh, &err) < 0) {
|
|
if (cb(skb, nlh, &err) < 0) {
|
|
/* Not an error, but we have to interrupt processing
|
|
/* Not an error, but we have to interrupt processing
|
|
* here. Note: that in this case we do not pull
|
|
* here. Note: that in this case we do not pull
|
|
@@ -1481,9 +1486,10 @@ static int netlink_rcv_skb(struct sk_buff *skb, int (*cb)(struct sk_buff *,
|
|
*/
|
|
*/
|
|
if (err == 0)
|
|
if (err == 0)
|
|
return -1;
|
|
return -1;
|
|
|
|
+ }
|
|
|
|
+skip:
|
|
|
|
+ if (nlh->nlmsg_flags & NLM_F_ACK || err)
|
|
netlink_ack(skb, nlh, err);
|
|
netlink_ack(skb, nlh, err);
|
|
- } else if (nlh->nlmsg_flags & NLM_F_ACK)
|
|
|
|
- netlink_ack(skb, nlh, 0);
|
|
|
|
|
|
|
|
netlink_queue_skip(nlh, skb);
|
|
netlink_queue_skip(nlh, skb);
|
|
}
|
|
}
|