[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-ID: <20080916171105.GN8702@ghostprotocols.net>
Date: Tue, 16 Sep 2008 14:11:05 -0300
From: Arnaldo Carvalho de Melo <acme@...hat.com>
To: Rémi Denis-Courmont
<remi.denis-courmont@...ia.com>
Cc: netdev@...r.kernel.org
Subject: Re: [PATCH 13/14] Phonet: emit errors when a packet cannot be
delivered locally
Em Tue, Sep 16, 2008 at 06:08:13PM +0300, Rémi Denis-Courmont escreveu:
> When there is no listener socket for a received packet, send an error
> back to the sender.
>
> Signed-off-by: Remi Denis-Courmont <remi.denis-courmont@...ia.com>
> ---
> net/phonet/af_phonet.c | 82 +++++++++++++++++++++++++++++++++++++++++++++--
> 1 files changed, 78 insertions(+), 4 deletions(-)
>
> diff --git a/net/phonet/af_phonet.c b/net/phonet/af_phonet.c
> index c18664d..3962969 100644
> --- a/net/phonet/af_phonet.c
> +++ b/net/phonet/af_phonet.c
> @@ -134,7 +134,7 @@ EXPORT_SYMBOL(phonet_header_ops);
> * Prepends an ISI header and sends a datagram.
> */
> static int pn_send(struct sk_buff *skb, struct net_device *dev,
> - u16 dst, u16 src, u8 res)
> + u16 dst, u16 src, u8 res, u8 irq)
> {
> struct phonethdr *ph;
> int err;
> @@ -163,7 +163,10 @@ static int pn_send(struct sk_buff *skb, struct net_device *dev,
> skb_reset_mac_header(skb);
> skb->pkt_type = PACKET_LOOPBACK;
> skb_orphan(skb);
> - netif_rx_ni(skb);
> + if (irq)
> + netif_rx(skb);
> + else
> + netif_rx_ni(skb);
> err = 0;
> } else {
> err = dev_hard_header(skb, dev, ntohs(skb->protocol),
> @@ -181,6 +184,18 @@ drop:
> return err;
> }
>
> +static int pn_raw_send(const void *data, int len, struct net_device *dev,
> + u16 dst, u16 src, u8 res)
> +{
> + struct sk_buff *skb = alloc_skb(MAX_PHONET_HEADER + len, GFP_ATOMIC);
> + if (skb == NULL)
> + return -ENOMEM;
> +
> + skb_reserve(skb, MAX_PHONET_HEADER);
> + memcpy(skb_put(skb, len), data, len);
Check if you shouldn't be using skb_copy_to_linear_data
> + return pn_send(skb, dev, dst, src, res, 1);
> +}
> +
> /*
> * Create a Phonet header for the skb and send it out. Returns
> * non-zero error code if failed. The skb is freed then.
> @@ -221,7 +236,7 @@ int pn_skb_send(struct sock *sk, struct sk_buff *skb,
> spin_unlock_bh(&pndevs.lock);
>
> err = pn_send(skb, dev, pn_sockaddr_get_object(target),
> - src, pn_sockaddr_get_resource(target));
> + src, pn_sockaddr_get_resource(target), 0);
> dev_put(dev);
> return err;
>
> @@ -231,6 +246,60 @@ drop:
> }
> EXPORT_SYMBOL(pn_skb_send);
>
> +static inline int can_respond(struct sk_buff *skb)
> +{
> + const struct phonethdr *ph = pn_hdr(skb);
> + struct phonet_device *pnd;
> +
> + if (!pskb_may_pull(skb, 3))
> + return 0;
> + if (skb->data[1] == 0xF0)
> + return 0;
> + if (skb->data[2] == 0x01 || skb->data[2] == 0x14)
> + return 0;
Try not to access skb->data directly, probably you would be better off
using some pn_hdr() like accessor that peeked at the mac_header, etc
> + spin_lock(&pndevs.lock);
> + pnd = __phonet_get_by_index(skb->dev->ifindex);
> + if (!pnd
> + || !phonet_dev2addr(pnd, ph->rdev & 0xFC, PN_FIND_EXACT)) {
> + spin_unlock(&pndevs.lock);
> + return 0;
> + }
> + spin_unlock(&pndevs.lock);
> + return 1;
> +}
> +
> +static int send_obj_unreachable(struct sk_buff *rskb)
> +{
> + struct phonethdr *oph = pn_hdr(rskb);
> + uint8_t data[8];
> +
> + BUG_ON(skb_headlen(rskb) < 2);
> + data[0] = rskb->data[0];
> + data[1] = 0xF0;
> + data[2] = 0x14;
> + data[3] = rskb->data[1];
> + data[4] = 0x00;
> + data[5] = 0x00;
> + data[6] = 0x00;
> + data[7] = 0x00;
Couldn't this be built using some relevant struct, etc?
> + return pn_raw_send(data, sizeof(data), rskb->dev,
> + pn_object(oph->sdev, oph->sobj),
> + pn_object(oph->rdev, oph->robj),
> + oph->function);
> +}
> +
> +static int send_reset_indications(struct sk_buff *rskb)
> +{
> + struct phonethdr *oph = pn_hdr(rskb);
> + uint8_t data[4] = { 0x00, 0x10, 0x00, 0x00 };
> +
> + return pn_raw_send(data, sizeof(data), rskb->dev,
> + pn_object(oph->sdev, 0x00),
> + pn_object(oph->rdev, oph->robj), 0x10);
> +}
> +
> +
> /* packet type functions */
>
> /*
> @@ -269,8 +338,13 @@ static int phonet_rcv(struct sk_buff *skb, struct net_device *dev,
> goto out; /* currently, we cannot be device 0 */
>
> sk = pn_find_sock_by_sa(&sa);
> - if (sk == NULL)
> + if (sk == NULL) {
> + if (can_respond(skb)) {
> + send_obj_unreachable(skb);
> + send_reset_indications(skb);
> + }
> goto out;
> + }
>
> /* Push data to the socket (or other sockets connected to it). */
> err = pn_sk(sk)->handler(sk, skb);
> --
> 1.5.4.3
>
> --
> To unsubscribe from this list: send the line "unsubscribe netdev" in
> the body of a message to majordomo@...r.kernel.org
> More majordomo info at http://vger.kernel.org/majordomo-info.html
--
To unsubscribe from this list: send the line "unsubscribe netdev" in
the body of a message to majordomo@...r.kernel.org
More majordomo info at http://vger.kernel.org/majordomo-info.html
Powered by blists - more mailing lists