UbiquitousOS
/
OpenCloudOS-Kernel
mirror of https://gitee.com/OpenCloudOS/OpenCloudOS-Kernel.git
11
0
Fork 0
Code Issues Projects Releases Wiki Activity

libertas: clean up lbs_hard_start_xmit() 

Having merged the nest of functions into one, now we can clean it up and
fix the error handling, and the duplication -- and at least make a start
on the locking.

Signed-off-by: David Woodhouse <dwmw2@infradead.org>
Signed-off-by: John W. Linville <linville@tuxdriver.com>
This commit is contained in:
David Woodhouse 2007-12-09 14:37:59 -05:00 committed by David S. Miller
parent 8af23b2f96
commit a2b62dc1f1
1 changed files with 72 additions and 79 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

151
drivers/net/wireless/libertas/tx.c
View File

@ -58,22 +58,16 @@ static u32 convert_radiotap_rate_to_mv(u8 rate)
*/ */
int lbs_hard_start_xmit(struct sk_buff *skb, struct net_device *dev) int lbs_hard_start_xmit(struct sk_buff *skb, struct net_device *dev)
{ {
unsigned long flags;
struct lbs_private *priv = dev->priv; struct lbs_private *priv = dev->priv;
int ret = -1; struct txpd *txpd;
struct txpd localtxpd; char *p802x_hdr;
struct txpd *plocaltxpd = &localtxpd; uint16_t pkt_len;
u8 *p802x_hdr; int ret;
struct tx_radiotap_hdr *pradiotap_hdr;
u32 new_rate;
u8 *ptr = priv->tmptxbuf;
lbs_deb_enter(LBS_DEB_TX); lbs_deb_enter(LBS_DEB_TX);
lbs_deb_hex(LBS_DEB_TX, "TX Data", skb->data, min_t(unsigned int, skb->len, 100)); ret = NETDEV_TX_BUSY;
netif_stop_queue(priv->dev);
if (priv->mesh_dev)
netif_stop_queue(priv->mesh_dev);
if (priv->dnld_sent) { if (priv->dnld_sent) {
lbs_pr_alert( "TX error: dnld_sent = %d, not sending\n", lbs_pr_alert( "TX error: dnld_sent = %d, not sending\n",
@ -94,98 +88,97 @@ int lbs_hard_start_xmit(struct sk_buff *skb, struct net_device *dev)
} }
if (priv->surpriseremoved) if (priv->surpriseremoved)
return -1; goto drop;
if (!skb->len || (skb->len > MRVDRV_ETH_TX_PACKET_BUFFER_SIZE)) { if (!skb->len || (skb->len > MRVDRV_ETH_TX_PACKET_BUFFER_SIZE)) {
lbs_deb_tx("tx err: skb length %d 0 or > %zd\n", lbs_deb_tx("tx err: skb length %d 0 or > %zd\n",
skb->len, MRVDRV_ETH_TX_PACKET_BUFFER_SIZE); skb->len, MRVDRV_ETH_TX_PACKET_BUFFER_SIZE);
goto done_tx; /* We'll never manage to send this one; drop it and return 'OK' */
goto drop;
} }
ret = 0; lbs_deb_hex(LBS_DEB_TX, "TX Data", skb->data, min_t(unsigned int, skb->len, 100));
memset(plocaltxpd, 0, sizeof(struct txpd));
plocaltxpd->tx_packet_length = cpu_to_le16(skb->len); txpd = (void *)priv->tmptxbuf;
memset(txpd, 0, sizeof(struct txpd));
/* offset of actual data */
plocaltxpd->tx_packet_location = cpu_to_le32(sizeof(struct txpd));
p802x_hdr = skb->data; p802x_hdr = skb->data;
if (priv->monitormode != LBS_MONITOR_OFF) { pkt_len = skb->len;
/* locate radiotap header */ if (priv->monitormode != LBS_MONITOR_OFF) {
pradiotap_hdr = (struct tx_radiotap_hdr *)skb->data; struct tx_radiotap_hdr *rtap_hdr = (void *)skb->data;
/* set txpd fields from the radiotap header */ /* set txpd fields from the radiotap header */
new_rate = convert_radiotap_rate_to_mv(pradiotap_hdr->rate); txpd->tx_control = cpu_to_le32(convert_radiotap_rate_to_mv(rtap_hdr->rate));
if (new_rate != 0) {
/* use new tx_control[4:0] */
plocaltxpd->tx_control = cpu_to_le32(new_rate);
}
/* skip the radiotap header */ /* skip the radiotap header */
p802x_hdr += sizeof(struct tx_radiotap_hdr); p802x_hdr += sizeof(*rtap_hdr);
plocaltxpd->tx_packet_length = pkt_len -= sizeof(*rtap_hdr);
cpu_to_le16(le16_to_cpu(plocaltxpd->tx_packet_length)
- sizeof(struct tx_radiotap_hdr));
} /* copy destination address from 802.11 header */
/* copy destination address from 802.3 or 802.11 header */ memcpy(txpd->tx_dest_addr_high, p802x_hdr + 4, ETH_ALEN);
if (priv->monitormode != LBS_MONITOR_OFF)
memcpy(plocaltxpd->tx_dest_addr_high, p802x_hdr + 4, ETH_ALEN);
else
memcpy(plocaltxpd->tx_dest_addr_high, p802x_hdr, ETH_ALEN);
lbs_deb_hex(LBS_DEB_TX, "txpd", (u8 *) plocaltxpd, sizeof(struct txpd));
if (IS_MESH_FRAME(skb)) {
plocaltxpd->tx_control |= cpu_to_le32(TxPD_MESH_FRAME);
}
memcpy(ptr, plocaltxpd, sizeof(struct txpd));
ptr += sizeof(struct txpd);
lbs_deb_hex(LBS_DEB_TX, "Tx Data", (u8 *) p802x_hdr, le16_to_cpu(plocaltxpd->tx_packet_length));
memcpy(ptr, p802x_hdr, le16_to_cpu(plocaltxpd->tx_packet_length));
ret = priv->hw_host_to_card(priv, MVMS_DAT,
priv->tmptxbuf,
le16_to_cpu(plocaltxpd->tx_packet_length) +
sizeof(struct txpd));
if (ret) {
lbs_deb_tx("tx err: hw_host_to_card returned 0x%X\n", ret);
goto done_tx;
}
lbs_deb_tx("%s succeeds\n", __func__);
done_tx:
if (!ret) {
priv->stats.tx_packets++;
priv->stats.tx_bytes += skb->len;
dev->trans_start = jiffies;
} else { } else {
priv->stats.tx_dropped++; /* copy destination address from 802.3 header */
priv->stats.tx_errors++; memcpy(txpd->tx_dest_addr_high, p802x_hdr, ETH_ALEN);
} }
if (!ret && priv->monitormode != LBS_MONITOR_OFF) { txpd->tx_packet_length = cpu_to_le16(pkt_len);
/* Keep the skb to echo it back once Tx feedback is txpd->tx_packet_location = cpu_to_le32(sizeof(struct txpd));
received from FW */
skb_orphan(skb); if (dev == priv->mesh_dev)
/* stop processing outgoing pkts */ txpd->tx_control |= cpu_to_le32(TxPD_MESH_FRAME);
lbs_deb_hex(LBS_DEB_TX, "txpd", (u8 *) &txpd, sizeof(struct txpd));
lbs_deb_hex(LBS_DEB_TX, "Tx Data", (u8 *) p802x_hdr, le16_to_cpu(txpd->tx_packet_length));
memcpy(&txpd[1], p802x_hdr, le16_to_cpu(txpd->tx_packet_length));
/* We need to protect against the queues being restarted before
we get round to stopping them */
spin_lock_irqsave(&priv->driver_lock, flags);
ret = priv->hw_host_to_card(priv, MVMS_DAT, priv->tmptxbuf,
pkt_len + sizeof(struct txpd));
if (!ret) {
lbs_deb_tx("%s succeeds\n", __func__);
/* Stop processing outgoing pkts before submitting */
netif_stop_queue(priv->dev); netif_stop_queue(priv->dev);
if (priv->mesh_dev) if (priv->mesh_dev)
netif_stop_queue(priv->mesh_dev); netif_stop_queue(priv->mesh_dev);
/* Keep the skb around for when we get feedback */ priv->stats.tx_packets++;
priv->currenttxskb = skb; priv->stats.tx_bytes += skb->len;
} else {
dev->trans_start = jiffies;
if (priv->monitormode != LBS_MONITOR_OFF) {
/* Keep the skb to echo it back once Tx feedback is
received from FW */
skb_orphan(skb);
/* Keep the skb around for when we get feedback */
priv->currenttxskb = skb;
}
}
spin_unlock_irqrestore(&priv->driver_lock, flags);
if (ret) {
lbs_deb_tx("tx err: hw_host_to_card returned 0x%X\n", ret);
drop:
priv->stats.tx_dropped++;
priv->stats.tx_errors++;
dev_kfree_skb_any(skb); dev_kfree_skb_any(skb);
} }
/* Even if we dropped the packet, return OK. Otherwise the
packet gets requeued. */
ret = NETDEV_TX_OK;
done: done:
lbs_deb_leave_args(LBS_DEB_TX, "ret %d", ret); lbs_deb_leave_args(LBS_DEB_TX, "ret %d", ret);
return ret; return ret;