Commit 888199b8 authored by Lorenzo Bianconi's avatar Lorenzo Bianconi Committed by Felix Fietkau

mt76: usb: simplify rx buffer allocation

Squash mt76u_buf_alloc_sg and mt76u_buf_alloc and remove duplicated
code. Reuse mt76u_refill_rx in mt76u_buf_alloc
Signed-off-by: default avatarLorenzo Bianconi <lorenzo@kernel.org>
Signed-off-by: default avatarFelix Fietkau <nbd@nbd.name>
parent 4de92bf1
...@@ -751,8 +751,6 @@ void mt76u_single_wr(struct mt76_dev *dev, const u8 req, ...@@ -751,8 +751,6 @@ void mt76u_single_wr(struct mt76_dev *dev, const u8 req,
const u16 offset, const u32 val); const u16 offset, const u32 val);
int mt76u_init(struct mt76_dev *dev, struct usb_interface *intf); int mt76u_init(struct mt76_dev *dev, struct usb_interface *intf);
void mt76u_deinit(struct mt76_dev *dev); void mt76u_deinit(struct mt76_dev *dev);
int mt76u_buf_alloc(struct mt76_dev *dev, struct mt76u_buf *buf,
int len, int data_len, gfp_t gfp);
void mt76u_buf_free(struct mt76u_buf *buf); void mt76u_buf_free(struct mt76u_buf *buf);
int mt76u_submit_buf(struct mt76_dev *dev, int dir, int index, int mt76u_submit_buf(struct mt76_dev *dev, int dir, int index,
struct mt76u_buf *buf, gfp_t gfp, struct mt76u_buf *buf, gfp_t gfp,
......
...@@ -324,41 +324,41 @@ mt76u_fill_rx_sg(struct mt76_dev *dev, struct mt76u_buf *buf, ...@@ -324,41 +324,41 @@ mt76u_fill_rx_sg(struct mt76_dev *dev, struct mt76u_buf *buf,
} }
static int static int
mt76u_buf_alloc_sg(struct mt76_dev *dev, struct mt76u_buf *buf, mt76u_refill_rx(struct mt76_dev *dev, struct mt76_queue *q,
int nsgs, int len, int sglen, gfp_t gfp) struct mt76u_buf *buf, int nsgs, gfp_t gfp)
{ {
buf->urb = usb_alloc_urb(0, gfp); if (dev->usb.sg_en) {
if (!buf->urb) return mt76u_fill_rx_sg(dev, buf, nsgs, q->buf_size,
return -ENOMEM; SKB_WITH_OVERHEAD(q->buf_size));
} else {
buf->urb->sg = devm_kcalloc(dev->dev, nsgs, sizeof(*buf->urb->sg), buf->buf = page_frag_alloc(&q->rx_page, q->buf_size, gfp);
gfp); return buf->buf ? 0 : -ENOMEM;
if (!buf->urb->sg) }
return -ENOMEM;
sg_init_table(buf->urb->sg, nsgs);
buf->dev = dev;
return mt76u_fill_rx_sg(dev, buf, nsgs, len, sglen);
} }
int mt76u_buf_alloc(struct mt76_dev *dev, struct mt76u_buf *buf, static int
int len, int data_len, gfp_t gfp) mt76u_buf_alloc(struct mt76_dev *dev, struct mt76u_buf *buf)
{ {
struct mt76_queue *q = &dev->q_rx[MT_RXQ_MAIN]; struct mt76_queue *q = &dev->q_rx[MT_RXQ_MAIN];
buf->urb = usb_alloc_urb(0, gfp); buf->len = SKB_WITH_OVERHEAD(q->buf_size);
buf->dev = dev;
buf->urb = usb_alloc_urb(0, GFP_KERNEL);
if (!buf->urb) if (!buf->urb)
return -ENOMEM; return -ENOMEM;
buf->buf = page_frag_alloc(&q->rx_page, len, gfp); if (dev->usb.sg_en) {
if (!buf->buf) buf->urb->sg = devm_kcalloc(dev->dev, MT_SG_MAX_SIZE,
sizeof(*buf->urb->sg),
GFP_KERNEL);
if (!buf->urb->sg)
return -ENOMEM; return -ENOMEM;
buf->len = data_len; sg_init_table(buf->urb->sg, MT_SG_MAX_SIZE);
buf->dev = dev; }
return 0; return mt76u_refill_rx(dev, q, buf, MT_SG_MAX_SIZE, GFP_KERNEL);
} }
void mt76u_buf_free(struct mt76u_buf *buf) void mt76u_buf_free(struct mt76u_buf *buf)
...@@ -514,20 +514,6 @@ static void mt76u_complete_rx(struct urb *urb) ...@@ -514,20 +514,6 @@ static void mt76u_complete_rx(struct urb *urb)
spin_unlock_irqrestore(&q->lock, flags); spin_unlock_irqrestore(&q->lock, flags);
} }
static int
mt76u_refill_rx(struct mt76_dev *dev, struct mt76_queue *q,
struct mt76u_buf *buf, int nsgs)
{
if (dev->usb.sg_en) {
return mt76u_fill_rx_sg(dev, buf, nsgs, q->buf_size,
SKB_WITH_OVERHEAD(q->buf_size));
} else {
buf->buf = page_frag_alloc(&q->rx_page, q->buf_size,
GFP_ATOMIC);
return buf->buf ? 0 : -ENOMEM;
}
}
static void mt76u_rx_tasklet(unsigned long data) static void mt76u_rx_tasklet(unsigned long data)
{ {
struct mt76_dev *dev = (struct mt76_dev *)data; struct mt76_dev *dev = (struct mt76_dev *)data;
...@@ -544,7 +530,8 @@ static void mt76u_rx_tasklet(unsigned long data) ...@@ -544,7 +530,8 @@ static void mt76u_rx_tasklet(unsigned long data)
count = mt76u_process_rx_entry(dev, buf); count = mt76u_process_rx_entry(dev, buf);
if (count > 0) { if (count > 0) {
err = mt76u_refill_rx(dev, q, buf, count); err = mt76u_refill_rx(dev, q, buf, count,
GFP_ATOMIC);
if (err < 0) if (err < 0)
break; break;
} }
...@@ -600,16 +587,7 @@ static int mt76u_alloc_rx(struct mt76_dev *dev) ...@@ -600,16 +587,7 @@ static int mt76u_alloc_rx(struct mt76_dev *dev)
q->buf_size = dev->usb.sg_en ? MT_RX_BUF_SIZE : PAGE_SIZE; q->buf_size = dev->usb.sg_en ? MT_RX_BUF_SIZE : PAGE_SIZE;
q->ndesc = MT_NUM_RX_ENTRIES; q->ndesc = MT_NUM_RX_ENTRIES;
for (i = 0; i < q->ndesc; i++) { for (i = 0; i < q->ndesc; i++) {
if (dev->usb.sg_en) err = mt76u_buf_alloc(dev, &q->entry[i].ubuf);
err = mt76u_buf_alloc_sg(dev, &q->entry[i].ubuf,
MT_SG_MAX_SIZE, q->buf_size,
SKB_WITH_OVERHEAD(q->buf_size),
GFP_KERNEL);
else
err = mt76u_buf_alloc(dev, &q->entry[i].ubuf,
q->buf_size,
SKB_WITH_OVERHEAD(q->buf_size),
GFP_KERNEL);
if (err < 0) if (err < 0)
return err; return err;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment